grpcproxy

Documentation

Index

• func New(clients *GrpcClients, storageMode string, accessLogger cache.Logger, ...) cache.Proxy
• type DataMessage
• type GrpcClients
  • func NewGrpcClients(cc *grpc.ClientConn) *GrpcClients
  • func (c *GrpcClients) CheckCapabilities(zstd bool) error
• type RecvStream
• type StreamReadCloser
  • func (s *StreamReadCloser[M]) Close() error
  • func (s *StreamReadCloser[M]) Read(p []byte) (int, error)

Functions

func New

func New(clients *GrpcClients, storageMode string,
	accessLogger cache.Logger, errorLogger cache.Logger,
	numUploaders, maxQueuedUploads int) cache.Proxy

Types

type DataMessage

type DataMessage interface {
	GetData() []byte
}

type GrpcClients

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

func NewGrpcClients

func NewGrpcClients(cc *grpc.ClientConn) *GrpcClients

func (*GrpcClients) CheckCapabilities

func (c *GrpcClients) CheckCapabilities(zstd bool) error

type RecvStream

type RecvStream[M DataMessage] interface {
	Recv() (M, error)
	CloseSend() error
}

type StreamReadCloser

type StreamReadCloser[M DataMessage] struct {
	Stream RecvStream[M]
	// contains filtered or unexported fields
}

func (*StreamReadCloser[M]) Close

func (s *StreamReadCloser[M]) Close() error

func (*StreamReadCloser[M]) Read

func (s *StreamReadCloser[M]) Read(p []byte) (int, error)