storageserver

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 3, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL