keyvalue

package

v0.9.6 Latest Latest Go to latest Published: Sep 26, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewClient(cc grpc.ClientConnInterface) *Client

func (k Client) Get(ctx context.Context, key string) ([]byte, error)

func (k Client) PruneExpiredEntries(ctx context.Context, maxAge time.Duration) (int64, error)

func (k Client) Store(ctx context.Context, key string, val []byte) error

type Server struct {
	pb.UnimplementedKeyValueStoreServer
	// contains filtered or unexported fields
}

func NewServer(impl core.KeyValueStore) *Server

func (s Server) GetValueForKey(ctx context.Context, req *pb.GetValueForKeyRequest) (*pb.GetValueForKeyResponse, error)

func (s Server) PruneExpiredEntries(ctx context.Context, req *pb.PruneExpiredEntriesRequest) (*pb.PruneExpiredEntriesResponse, error)

func (s Server) StoreKeyValue(ctx context.Context, req *pb.StoreKeyValueRequest) (*emptypb.Empty, error)

Path	Synopsis
test