service

Documentation

Index

• type StorageService
  • func New(s storage.Engine, nodeID uint32) *StorageService
  • func (s *StorageService) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)
  • func (s *StorageService) Put(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)
  • func (s *StorageService) Scan(req *proto.ScanRequest, stream proto.Storage_ScanServer) error

Types

type StorageService

type StorageService struct {
	proto.UnimplementedStorageServer
	// contains filtered or unexported fields
}

func New

func New(s storage.Engine, nodeID uint32) *StorageService

func (*StorageService) Get

func (s *StorageService) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)

func (*StorageService) Put

func (s *StorageService) Put(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)

func (*StorageService) Scan

func (s *StorageService) Scan(req *proto.ScanRequest, stream proto.Storage_ScanServer) error