client

README

gRPC client to deal with other modules in cluster

Documentation

Index

• Constants
• type AddressPool
  • func NewPool() *AddressPool
  • func (p *AddressPool) Deregister(moduleName string)
  • func (p *AddressPool) Handler(ctx context.Context, msg *runner.Msg) ([]byte, error)
  • func (p *AddressPool) Register(moduleName, addr string)
  • func (p *AddressPool) SetLogger(l logr.Logger) *AddressPool
  • func (p *AddressPool) Start(ctx context.Context) error
• type Pool

Constants

const DefaultStoreTTL = 60 * 60

DefaultStoreTTL for how long we keep grpc client in a pool, default 1h

Types

type AddressPool

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

func NewPool

func NewPool() *AddressPool

func (*AddressPool) Deregister

func (p *AddressPool) Deregister(moduleName string)

func (*AddressPool) Handler

func (p *AddressPool) Handler(ctx context.Context, msg *runner.Msg) ([]byte, error)

func (*AddressPool) Register

func (p *AddressPool) Register(moduleName, addr string)

func (*AddressPool) SetLogger

func (p *AddressPool) SetLogger(l logr.Logger) *AddressPool

func (*AddressPool) Start

func (p *AddressPool) Start(ctx context.Context) error

type Pool

type Pool interface {
	Register(moduleName, addr string)
	Deregister(moduleName string)
}