server

Documentation

Index

• type NodeInfo
• type Server
  • func New(cfg config.Config) *Server
  • func (s *Server) Delete(ctx context.Context, req *themis.DeleteRequest) (*themis.DeleteResponse, error)
  • func (s *Server) Get(ctx context.Context, req *themis.GetRequest) (*themis.GetResponse, error)
  • func (s *Server) Put(ctx context.Context, req *themis.PutRequest) (*themis.PutResponse, error)
  • func (s *Server) Run()
  • func (s *Server) SearchByPrefix(ctx context.Context, req *themis.SearchRequest) (*themis.SearchResponse, error)
  • func (s *Server) Watch(ctx context.Context, req *themis.WatchRequest) (*themis.WatchResponse, error)
  • func (s *Server) WatchStream(req *themis.WatchRequest, tw themis.Themis_WatchStreamServer) error

Types

type NodeInfo

type NodeInfo struct {
	Name    string
	Address string
	Term    int32

	LeaderName    string
	LeaderAddress string

	Server map[string]string
	// contains filtered or unexported fields
}

type Server

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

func New

func New(cfg config.Config) *Server

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, req *themis.DeleteRequest) (*themis.DeleteResponse, error)

func (*Server) Get

func (s *Server) Get(ctx context.Context, req *themis.GetRequest) (*themis.GetResponse, error)

func (*Server) Put

func (s *Server) Put(ctx context.Context, req *themis.PutRequest) (*themis.PutResponse, error)

func (*Server) Run

func (s *Server) Run()

func (*Server) SearchByPrefix

func (s *Server) SearchByPrefix(ctx context.Context, req *themis.SearchRequest) (*themis.SearchResponse, error)

func (*Server) Watch

func (s *Server) Watch(ctx context.Context, req *themis.WatchRequest) (*themis.WatchResponse, error)

func (*Server) WatchStream

func (s *Server) WatchStream(req *themis.WatchRequest, tw themis.Themis_WatchStreamServer) error