Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gossipcache

package module

Go to main page

Versions in this module

v0

v0.4.0

Apr 12, 2023

Changes in this version

+ const DefaultCacheBasePath

+ const DefaultCacheReplicas

+ func InferCacheBaseURL(cfg *memberlist.Config) (string, error)

+ func NewGossipTransport(conf *Config) (memberlist.Transport, *transport.Config, error)

+ func NewGossipTransportConfig(conf *Config) (*transport.Config, error)

+ func PrepareCacheBaseURL(s string) (string, error)

+ type Config struct

+ CacheBasePath string

+ CacheBaseURL string

+ CacheReplicas int

+ ClientTLSConfig *tls.Config

+ Context context.Context

+ Logger slog.Logger

+ Memberlist *memberlist.Config

+ Transport *transport.Config

+ func (conf *Config) SetDefaults() error

+ type GossipCache struct

v0.3.1

Apr 9, 2023

v0.3.0

Apr 2, 2023

Changes in this version

+ func NewGroupCacheLogger(l slog.Logger) groupcache.Logger

+ func NewMemberlistLogger(l slog.Logger) *log.Logger

+ func SetGroupCacheLogger(l slog.Logger)

+ func SetMemberlistLogger(cfg *memberlist.Config, l slog.Logger) error

+ type Cluster struct

+ func NewCluster(conf *memberlist.Config, options ...ClusterConfigOption) (*Cluster, error)

+ func Prepare(conf *memberlist.Config, options ...ClusterConfigOption) (*Cluster, *memberlist.Config, error)

+ func (cluster *Cluster) Create() error

+ type ClusterConfigOption func(*Cluster, *memberlist.Config) error

+ func WithAddress(host string) ClusterConfigOption

+ func WithAliveDelegate(handler func(*Cluster, *memberlist.Node) error) ClusterConfigOption

+ func WithConflictDelegate(handler func(*Cluster, *memberlist.Node, *memberlist.Node)) ClusterConfigOption

+ func WithDefaultLANConfig() ClusterConfigOption

+ func WithDefaultLocalConfig() ClusterConfigOption

+ func WithDefaultWANConfig() ClusterConfigOption

+ func WithDelegateProtocolVersion(version, min, max uint8) ClusterConfigOption

+ func WithEventDelegate(handler func(*Cluster, *memberlist.Node, memberlist.NodeEventType)) ClusterConfigOption

+ func WithGetBroadcastDelegate(handler func(*Cluster, int, int) [][]byte) ClusterConfigOption

+ func WithGossipAdvertise(host string, port int16) ClusterConfigOption

+ func WithGossipKey(salt string, key []byte) ClusterConfigOption

+ func WithGossipKeyBase64(salt, key string) ClusterConfigOption

+ func WithGossipLogger(logger slog.Logger) ClusterConfigOption

+ func WithGossipPort(port int16) ClusterConfigOption

+ func WithLocalStateDelegate(handler func(*Cluster, bool) []byte) ClusterConfigOption

+ func WithMergeDelegate(handler func(*Cluster, []*memberlist.Node) error) ClusterConfigOption

+ func WithMergeRemoteStateDelegate(handler func(*Cluster, []byte, bool)) ClusterConfigOption

+ func WithNodeMetaDelegate(handler func(cluster *Cluster, limit int) []byte) ClusterConfigOption

+ func WithNotifyMsgDelegate(handler func(cluster *Cluster, userData []byte)) ClusterConfigOption

+ func WithPingDelegate(payload []byte, ...) ClusterConfigOption

+ func WithTransport(transport memberlist.Transport) ClusterConfigOption

+ type ClusterDelegate struct

+ func (cd *ClusterDelegate) AckPayload() []byte

+ func (cd *ClusterDelegate) GetBroadcasts(overhead, limit int) [][]byte

+ func (cd *ClusterDelegate) LocalState(join bool) []byte

+ func (cd *ClusterDelegate) MergeRemoteState(buf []byte, join bool)

+ func (cd *ClusterDelegate) NodeMeta(limit int) []byte

+ func (cd *ClusterDelegate) NotifyAlive(peer *memberlist.Node) error

+ func (cd *ClusterDelegate) NotifyConflict(existing, other *memberlist.Node)

+ func (cd *ClusterDelegate) NotifyJoin(node *memberlist.Node)

+ func (cd *ClusterDelegate) NotifyLeave(node *memberlist.Node)

+ func (cd *ClusterDelegate) NotifyMerge(peers []*memberlist.Node) error

+ func (cd *ClusterDelegate) NotifyMsg(userData []byte)

+ func (cd *ClusterDelegate) NotifyPingComplete(peer *memberlist.Node, rtt time.Duration, payload []byte)

+ func (cd *ClusterDelegate) NotifyUpdate(node *memberlist.Node)

+ type GroupCacheLogger struct

+ func (gcl *GroupCacheLogger) Debug() groupcache.Logger

+ func (gcl *GroupCacheLogger) Error() groupcache.Logger

+ func (gcl *GroupCacheLogger) ErrorField(label string, err error) groupcache.Logger

+ func (gcl *GroupCacheLogger) Info() groupcache.Logger

+ func (gcl *GroupCacheLogger) Printf(format string, args ...any)

+ func (gcl *GroupCacheLogger) StringField(label string, val string) groupcache.Logger

+ func (gcl *GroupCacheLogger) Warn() groupcache.Logger

+ func (gcl *GroupCacheLogger) WithFields(fields map[string]any) groupcache.Logger