storageserver

Documentation

Index

• type Server
  • func NewStorageServer(store *fred.Store) *Server
  • func (s *Server) AddKeygroupTrigger(ctx context.Context, t *storage.KeygroupTrigger) (*storage.Response, error)
  • func (s *Server) Append(_ context.Context, item *storage.AppendItem) (*storage.Key, error)
  • func (s Server) CreateKeygroup(_ context.Context, kg *storage.Keygroup) (*storage.Response, error)
  • func (s Server) Delete(_ context.Context, key *storage.Key) (*storage.Response, error)
  • func (s Server) DeleteKeygroup(_ context.Context, kg *storage.Keygroup) (*storage.Response, error)
  • func (s *Server) DeleteKeygroupTrigger(ctx context.Context, t *storage.KeygroupTrigger) (*storage.Response, error)
  • func (s Server) Exists(_ context.Context, key *storage.Key) (*storage.Response, error)
  • func (s Server) ExistsKeygroup(ctx context.Context, kg *storage.Keygroup) (*storage.Response, error)
  • func (s *Server) GetKeygroupTrigger(kg *storage.Keygroup, server storage.Database_GetKeygroupTriggerServer) error
  • func (s Server) IDs(kg *storage.Keygroup, server storage.Database_IDsServer) error
  • func (s Server) Read(_ context.Context, key *storage.Key) (*storage.Val, error)
  • func (s Server) ReadAll(kg *storage.Keygroup, server storage.Database_ReadAllServer) error
  • func (s Server) Scan(req *storage.ScanRequest, server storage.Database_ScanServer) error
  • func (s *Server) Update(_ context.Context, item *storage.UpdateItem) (*storage.Response, error)

Types

type Server

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

Server implements the DatabaseServer interface

func NewStorageServer

func NewStorageServer(store *fred.Store) *Server

NewStorageServer creates a new Server to serve GRPC Requests. It answers according to the data/Storage Interface

func (*Server) AddKeygroupTrigger

func (s *Server) AddKeygroupTrigger(ctx context.Context, t *storage.KeygroupTrigger) (*storage.Response, error)

AddKeygroupTrigger calls specific method of the storage interface.

func (*Server) Append

func (s *Server) Append(_ context.Context, item *storage.AppendItem) (*storage.Key, error)

Append calls specific method of the storage interface

func (Server) CreateKeygroup

func (s Server) CreateKeygroup(_ context.Context, kg *storage.Keygroup) (*storage.Response, error)

CreateKeygroup calls specific method of the storage interface

func (Server) Delete

func (s Server) Delete(_ context.Context, key *storage.Key) (*storage.Response, error)

Delete calls specific method of the storage interface

func (Server) DeleteKeygroup

func (s Server) DeleteKeygroup(_ context.Context, kg *storage.Keygroup) (*storage.Response, error)

DeleteKeygroup calls specific method of the storage interface

func (*Server) DeleteKeygroupTrigger

func (s *Server) DeleteKeygroupTrigger(ctx context.Context, t *storage.KeygroupTrigger) (*storage.Response, error)

DeleteKeygroupTrigger calls specific method of the storage interface.

func (Server) Exists

func (s Server) Exists(_ context.Context, key *storage.Key) (*storage.Response, error)

Exists calls specific method of the storage interface

func (Server) ExistsKeygroup

func (s Server) ExistsKeygroup(ctx context.Context, kg *storage.Keygroup) (*storage.Response, error)

ExistsKeygroup calls specific method of the storage interface

func (*Server) GetKeygroupTrigger

func (s *Server) GetKeygroupTrigger(kg *storage.Keygroup, server storage.Database_GetKeygroupTriggerServer) error

GetKeygroupTrigger calls specific method of the storage interface.

func (Server) IDs

func (s Server) IDs(kg *storage.Keygroup, server storage.Database_IDsServer) error

IDs calls specific method of the storage interface

func (Server) Read

func (s Server) Read(_ context.Context, key *storage.Key) (*storage.Val, error)

Read calls specific method of the storage interface

func (Server) ReadAll

func (s Server) ReadAll(kg *storage.Keygroup, server storage.Database_ReadAllServer) error

ReadAll calls specific method of the storage interface

func (Server) Scan

func (s Server) Scan(req *storage.ScanRequest, server storage.Database_ScanServer) error

Scan calls specific method of the storage interface

func (*Server) Update

func (s *Server) Update(_ context.Context, item *storage.UpdateItem) (*storage.Response, error)

Update calls specific method of the storage interface