server

Documentation

Index

• func ListenConnectWeb(addr string, dbReader db.DBReader, logger *zap.Logger, encrypted bool) error
• type ConnectServer
  • func (cs *ConnectServer) Get(ctx context.Context, req *connect_go.Request[kvv1.GetRequest]) (*connect_go.Response[kvv1.GetResponse], error)
  • func (cs *ConnectServer) GetByPrefix(ctx context.Context, req *connect_go.Request[kvv1.GetByPrefixRequest]) (*connect_go.Response[kvv1.GetByPrefixResponse], error)
  • func (cs *ConnectServer) GetMany(ctx context.Context, req *connect_go.Request[kvv1.GetManyRequest]) (*connect_go.Response[kvv1.GetManyResponse], error)
  • func (cs *ConnectServer) Scan(ctx context.Context, req *connect_go.Request[kvv1.ScanRequest]) (*connect_go.Response[kvv1.ScanResponse], error)

Functions

func ListenConnectWeb

func ListenConnectWeb(addr string, dbReader db.DBReader, logger *zap.Logger, encrypted bool) error

Types

type ConnectServer

type ConnectServer struct {
	kvconnect.UnimplementedKvHandler
	DBReader db.DBReader
	// contains filtered or unexported fields
}

func (*ConnectServer) Get

func (cs *ConnectServer) Get(ctx context.Context, req *connect_go.Request[kvv1.GetRequest]) (*connect_go.Response[kvv1.GetResponse], error)

func (*ConnectServer) GetByPrefix

func (cs *ConnectServer) GetByPrefix(ctx context.Context, req *connect_go.Request[kvv1.GetByPrefixRequest]) (*connect_go.Response[kvv1.GetByPrefixResponse], error)

func (*ConnectServer) GetMany

func (cs *ConnectServer) GetMany(ctx context.Context, req *connect_go.Request[kvv1.GetManyRequest]) (*connect_go.Response[kvv1.GetManyResponse], error)

func (*ConnectServer) Scan

func (cs *ConnectServer) Scan(ctx context.Context, req *connect_go.Request[kvv1.ScanRequest]) (*connect_go.Response[kvv1.ScanResponse], error)