cache

Documentation

Index

• Constants
• type ClientCache
  • func NewSDKClientCache(opts ClientCacheOpts) *ClientCache
  • func (c *ClientCache) CloseAll()
  • func (c *ClientCache) Get(info clientcore.NodeInfo) (clientcore.Client, error)
• type ClientCacheOpts

Constants

const DefaultBufferSize = 4 * 1024 * 1024 // 4MB

DefaultBufferSize describes default max GRPC message size. Unfortunately GRPC lib contains this const in private.

Types

type ClientCache

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

ClientCache is a structure around neofs-sdk-go/client to reuse already created clients.

func NewSDKClientCache

func NewSDKClientCache(opts ClientCacheOpts) *ClientCache

NewSDKClientCache creates instance of client cache. `opts` are used for new client creation.

func (*ClientCache) CloseAll

func (c *ClientCache) CloseAll()

CloseAll closes underlying connections of all cached clients.

Ignores closing errors.

func (*ClientCache) Get

func (c *ClientCache) Get(info clientcore.NodeInfo) (clientcore.Client, error)

Get function returns existing client or creates a new one.

type ClientCacheOpts

type ClientCacheOpts struct {
	DialTimeout      time.Duration
	StreamTimeout    time.Duration
	ReconnectTimeout time.Duration
	ResponseCallback func(client.ResponseMetaInfo) error
	AllowExternal    bool
	Buffers          *sync.Pool
	Logger           *zap.Logger
}