discovery

Documentation

Index

• Constants
• func Init()
• type Debug
  • func (m *Debug) Close()
  • func (m *Debug) Get(key string, dir bool) (*discovery.KVPairs, error)
  • func (m *Debug) Incr(key string) (int64, error)
  • func (m *Debug) KeepAlive(key, value string, ttl time.Duration) error
  • func (m *Debug) Set(key, value string, ttl time.Duration) error
  • func (m *Debug) Type() string
  • func (m *Debug) Watch(key string, _ uint64, dir bool) (discovery.EventChan, error)
• type Discovery
  • func (m *Discovery) GetAddresses(service string) []resolver.Address
  • func (m *Discovery) PassthroughAddr(component string) (int64, string)
  • func (m *Discovery) Register(component, addr string, opts ...discovery.Option) (int64, error)
• type NodeInfo
  • func (info *NodeInfo) String() string

Constants

const (
	ServicePrefix    = "service"
	ServiceNodeIDKey = "node_id"
)

Functions

func Init

func Init()

Types

type Debug

type Debug struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Debug) Close

func (m *Debug) Close()

Close the provider connection.

func (*Debug) Get

func (m *Debug) Get(key string, dir bool) (*discovery.KVPairs, error)

Get the value of the specified key or directory.

func (*Debug) Incr

func (m *Debug) Incr(key string) (int64, error)

Incr invokes an atomic value increase for the specified key.

func (*Debug) KeepAlive

func (m *Debug) KeepAlive(key, value string, ttl time.Duration) error

KeepAlive sets value and updates the ttl for the specified key.

func (*Debug) Set

func (m *Debug) Set(key, value string, ttl time.Duration) error

Set value for the specified key with a specified ttl.

func (*Debug) Type

func (m *Debug) Type() string

Type returns the backend provider type.

func (*Debug) Watch

func (m *Debug) Watch(key string, _ uint64, dir bool) (discovery.EventChan, error)

Watch for changes of the specified key or directory.

type Discovery

type Discovery struct {
	// contains filtered or unexported fields
}

func (*Discovery) GetAddresses

func (m *Discovery) GetAddresses(service string) []resolver.Address

GetAddresses returns rpc service addresses.

func (*Discovery) PassthroughAddr

func (m *Discovery) PassthroughAddr(component string) (int64, string)

PassthroughAddr returns service unique ID and rpc address registered for the component.

func (*Discovery) Register

func (m *Discovery) Register(component, addr string, opts ...discovery.Option) (int64, error)

Register rpc address of the component node.

type NodeInfo

type NodeInfo struct {
	TTL      time.Duration     `json:"ttl,omitempty"`
	UniqueID int64             `json:"unique_id,omitempty"`
	Service  string            `json:"service,omitempty"`
	Address  string            `json:"address,omitempty"`
	Metadata map[string]string `json:"metadata,omitempty"`
}

func (*NodeInfo) String

func (info *NodeInfo) String() string