storageserver

Documentation

Index

• type Server
  • func NewStorageServer(store *fred.Store) *Server
  • func (s *Server) AddKeygroupTrigger(_ context.Context, req *storage.AddKeygroupTriggerRequest) (*storage.AddKeygroupTriggerResponse, error)
  • func (s *Server) Append(_ context.Context, req *storage.AppendRequest) (*storage.AppendResponse, error)
  • func (s Server) CreateKeygroup(_ context.Context, req *storage.CreateKeygroupRequest) (*storage.CreateKeygroupResponse, error)
  • func (s Server) Delete(_ context.Context, req *storage.DeleteRequest) (*storage.DeleteResponse, error)
  • func (s Server) DeleteKeygroup(_ context.Context, req *storage.DeleteKeygroupRequest) (*storage.DeleteKeygroupResponse, error)
  • func (s *Server) DeleteKeygroupTrigger(_ context.Context, req *storage.DeleteKeygroupTriggerRequest) (*storage.DeleteKeygroupTriggerResponse, error)
  • func (s Server) Exists(_ context.Context, req *storage.ExistsRequest) (*storage.ExistsResponse, error)
  • func (s Server) ExistsKeygroup(_ context.Context, req *storage.ExistsKeygroupRequest) (*storage.ExistsKeygroupResponse, error)
  • func (s *Server) GetKeygroupTrigger(_ context.Context, req *storage.GetKeygroupTriggerRequest) (*storage.GetKeygroupTriggerResponse, error)
  • func (s Server) IDs(_ context.Context, req *storage.IDsRequest) (*storage.IDsResponse, error)
  • func (s Server) Read(_ context.Context, req *storage.ReadRequest) (*storage.ReadResponse, error)
  • func (s Server) ReadAll(_ context.Context, req *storage.ReadAllRequest) (*storage.ReadAllResponse, error)
  • func (s Server) Scan(_ context.Context, req *storage.ScanRequest) (*storage.ScanResponse, error)
  • func (s *Server) Update(_ context.Context, req *storage.UpdateRequest) (*storage.UpdateResponse, 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(_ context.Context, req *storage.AddKeygroupTriggerRequest) (*storage.AddKeygroupTriggerResponse, error)

AddKeygroupTrigger calls specific method of the storage interface.

func (*Server) Append

func (s *Server) Append(_ context.Context, req *storage.AppendRequest) (*storage.AppendResponse, error)

Append calls specific method of the storage interface

func (Server) CreateKeygroup

func (s Server) CreateKeygroup(_ context.Context, req *storage.CreateKeygroupRequest) (*storage.CreateKeygroupResponse, error)

CreateKeygroup calls specific method of the storage interface

func (Server) Delete

func (s Server) Delete(_ context.Context, req *storage.DeleteRequest) (*storage.DeleteResponse, error)

Delete calls specific method of the storage interface

func (Server) DeleteKeygroup

func (s Server) DeleteKeygroup(_ context.Context, req *storage.DeleteKeygroupRequest) (*storage.DeleteKeygroupResponse, error)

DeleteKeygroup calls specific method of the storage interface

func (*Server) DeleteKeygroupTrigger

func (s *Server) DeleteKeygroupTrigger(_ context.Context, req *storage.DeleteKeygroupTriggerRequest) (*storage.DeleteKeygroupTriggerResponse, error)

DeleteKeygroupTrigger calls specific method of the storage interface.

func (Server) Exists

func (s Server) Exists(_ context.Context, req *storage.ExistsRequest) (*storage.ExistsResponse, error)

Exists calls specific method of the storage interface

func (Server) ExistsKeygroup

func (s Server) ExistsKeygroup(_ context.Context, req *storage.ExistsKeygroupRequest) (*storage.ExistsKeygroupResponse, error)

ExistsKeygroup calls specific method of the storage interface

func (*Server) GetKeygroupTrigger

func (s *Server) GetKeygroupTrigger(_ context.Context, req *storage.GetKeygroupTriggerRequest) (*storage.GetKeygroupTriggerResponse, error)

GetKeygroupTrigger calls specific method of the storage interface.

func (Server) IDs

func (s Server) IDs(_ context.Context, req *storage.IDsRequest) (*storage.IDsResponse, error)

IDs calls specific method of the storage interface

func (Server) Read

func (s Server) Read(_ context.Context, req *storage.ReadRequest) (*storage.ReadResponse, error)

Read calls specific method of the storage interface

func (Server) ReadAll

func (s Server) ReadAll(_ context.Context, req *storage.ReadAllRequest) (*storage.ReadAllResponse, error)

ReadAll calls specific method of the storage interface

func (Server) Scan

func (s Server) Scan(_ context.Context, req *storage.ScanRequest) (*storage.ScanResponse, error)

Scan calls specific method of the storage interface

func (*Server) Update

func (s *Server) Update(_ context.Context, req *storage.UpdateRequest) (*storage.UpdateResponse, error)

Update calls specific method of the storage interface