kanata_discovery

Documentation

Index

• Variables
• type Discovery
  • func NewDiscovery(endpoints []string, namespace string) (Discovery, error)
• type Node

Variables

var (
	ErrSessionExpired           = errors.New("session expired")
	ErrIllegalPathNodeCharacter = errors.New("illegal path node character")
	ErrPathNodeEmpty            = errors.New("path node empty")
	ErrNoServiceFound           = errors.New("no service found")
)

Types

type Discovery

type Discovery interface {
	Start() error
	GracefulShutdown() error

	AcquireSession() (int64, error)
	SessionHeatbeat(session int64) error

	PublishService(node *Node, service, version string, tags []string, session int64) error
	PickOneFromTag(service, version, tag string) (*Node, error)
	PickAllFromTag(service, version, tag string) ([]*Node, error)
}

func NewDiscovery

func NewDiscovery(endpoints []string, namespace string) (Discovery, error)

type Node

type Node struct {
	Weight int `json:"weight"` // 1-65535, 0 default

	Address []byte `json:"address"`
	Port    uint16 `json:"port"`
	// contains filtered or unexported fields
}