server

Documentation

Index

• type RPCWrapper
• type ZKS
  • func NewServer(cfg *settings.Settings) (*ZKS, error)
  • func (z *ZKS) BoundAddrs() []net.Addr
  • func (z *ZKS) Run(ctx context.Context) error

Types

type RPCWrapper

type RPCWrapper struct {
	Message    rpc.Message
	Payload    interface{}
	Identifier string

	// CloseAfterWritingErr is set to a non nil error if the server session
	// should be closed after writing this message.
	CloseAfterWritingErr error
}

RPCWrapper is a wrapped RPC Message for internal use. This is required because RPC messages consist of 2 discrete pieces.

type ZKS

type ZKS struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer(cfg *settings.Settings) (*ZKS, error)

func (*ZKS) BoundAddrs

func (z *ZKS) BoundAddrs() []net.Addr

BoundAddrs returns the addresses the server is bound to listen to.

func (*ZKS) Run

func (z *ZKS) Run(ctx context.Context) error