def

Documentation

Index

• func NewDefaultClient(sn server.Node, points server.EndPoints) (service.Client, error)
• type DefaultClient
  • func (cc *DefaultClient) Address() string
  • func (cc *DefaultClient) Get(key kv.Key) ([]*kv.Data, error)
  • func (cc *DefaultClient) GetConfig() kv.Config
  • func (cc *DefaultClient) Resolve(serviceNode server.Node) []builder.Address
  • func (cc *DefaultClient) Set(data kv.Data) error
• type DefaultServer
  • func (d *DefaultServer) Get(key kv.Key) ([]*kv.Data, error)
  • func (d *DefaultServer) GetConfig() kv.Config
  • func (d *DefaultServer) GetHealthCheck() service.Health
  • func (d *DefaultServer) IsGRpc() bool
  • func (d *DefaultServer) IsHttp() bool
  • func (d *DefaultServer) IsTcp() bool
  • func (d *DefaultServer) IsTtl() bool
  • func (d *DefaultServer) Set(data kv.Data) error
  • func (d *DefaultServer) Start()
  • func (d *DefaultServer) Stop()

Functions

func NewDefaultClient

func NewDefaultClient(sn server.Node, points server.EndPoints) (service.Client, error)

Types

type DefaultClient

type DefaultClient struct {
	discoveryResolver.Builder

	ServiceNode server.Node
	// contains filtered or unexported fields
}

func (*DefaultClient) Address

func (cc *DefaultClient) Address() string

Address Client interface

func (*DefaultClient) Get

func (cc *DefaultClient) Get(key kv.Key) ([]*kv.Data, error)

Get Config interface

func (*DefaultClient) GetConfig

func (cc *DefaultClient) GetConfig() kv.Config

GetConfig Client interface

func (*DefaultClient) Resolve

func (cc *DefaultClient) Resolve(serviceNode server.Node) []builder.Address

func (*DefaultClient) Set

func (cc *DefaultClient) Set(data kv.Data) error

Set Config interface

type DefaultServer

type DefaultServer struct {
}

func (*DefaultServer) Get

func (d *DefaultServer) Get(key kv.Key) ([]*kv.Data, error)

func (*DefaultServer) GetConfig

func (d *DefaultServer) GetConfig() kv.Config

func (*DefaultServer) GetHealthCheck

func (d *DefaultServer) GetHealthCheck() service.Health

func (*DefaultServer) IsGRpc

func (d *DefaultServer) IsGRpc() bool

func (*DefaultServer) IsHttp

func (d *DefaultServer) IsHttp() bool

func (*DefaultServer) IsTcp

func (d *DefaultServer) IsTcp() bool

func (*DefaultServer) IsTtl

func (d *DefaultServer) IsTtl() bool

func (*DefaultServer) Set

func (d *DefaultServer) Set(data kv.Data) error

func (*DefaultServer) Start

func (d *DefaultServer) Start()

func (*DefaultServer) Stop

func (d *DefaultServer) Stop()