client

package

v0.1.139 Latest Latest Go to latest Published: Apr 21, 2025 License: MIT Imports: 10 Imported by: 0

Details

View Source

const DefaultStoreTTL = 60 * 60

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

This section is empty.

This section is empty.

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

func NewPool() *AddressPool

func (p *AddressPool) Deregister(moduleName string)

func (p *AddressPool) Handler(ctx context.Context, msg *runner.Msg) 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 interface {
	Register(moduleName, addr string)
	Deregister(moduleName string)
}