gossip

Documentation

Overview

Package gossip provides a gossip registry based on hashicorp/memberlist

Index

• Variables
• func Address(a string) registry.Opt
• func Advertise(a string) registry.Opt
• func Config(c *memberlist.Config) registry.Opt
• func ConnectRetry(v bool) registry.Opt
• func ConnectTimeout(td time.Duration) registry.Opt
• func NewRegistry(opts registry.Cfg) registry.Registry
• func Secret(k []byte) registry.Opt
• type Cfg

Variables

var (
	// You should change this if using secure
	DefaultSecret = []byte("micro-gossip-key") // exactly 16 bytes
	ExpiryTick    = time.Second * 1            // needs to be smaller than registry.RegisterTTL
	MaxPacketSize = 512
)

Functions

func Address

func Address(a string) registry.Opt

Address to bind to - host:port

func Advertise

func Advertise(a string) registry.Opt

The address to advertise for other gossip members to connect to - host:port

func Config

func Config(c *memberlist.Config) registry.Opt

Config sets *memberlist.Config for configuring gossip

func ConnectRetry

func ConnectRetry(v bool) registry.Opt

ConnectRetry enables reconnect to registry then connection closed, use with ConnectTimeout to specify how long retry

func ConnectTimeout

func ConnectTimeout(td time.Duration) registry.Opt

ConnectTimeout sets the registry connect timeout. Use -1 to specify infinite timeout

func NewRegistry

func NewRegistry(opts registry.Cfg) registry.Registry

func Secret

func Secret(k []byte) registry.Opt

Secret specifies an encryption key. The value should be either 16, 24, or 32 bytes to select AES-128, AES-192, or AES-256.

Types

type Cfg

type Cfg struct {
}