Versions in this module Expand all Collapse all v2 v2.5.0 Jan 3, 2025 v2.4.4 May 11, 2024 Changes in this version + func New(clients *GrpcClients, storageMode string, accessLogger cache.Logger, ...) cache.Proxy + type DataMessage interface + GetData func() []byte + type GrpcClients struct + func NewGrpcClients(cc *grpc.ClientConn) *GrpcClients + func (c *GrpcClients) CheckCapabilities(zstd bool) error + type RecvStream interface + CloseSend func() error + Recv func() (M, error) + type StreamReadCloser struct + Stream RecvStream[M] + func (s *StreamReadCloser[M]) Close() error + func (s *StreamReadCloser[M]) Read(p []byte) (int, error)
Go to main page