storage

Documentation

Overview

Package storage provides the storage server.

Index

• type Server
  • func NewServer(ctx context.Context, raft raft.Raft, rbac rbac.Evaluator, ...) *Server
  • func (s *Server) Publish(ctx context.Context, req *v1.PublishRequest) (*v1.PublishResponse, error)
  • func (s *Server) Query(req *v1.QueryRequest, stream v1.Storage_QueryServer) error
  • func (s *Server) Subscribe(req *v1.SubscribeRequest, srv v1.Storage_SubscribeServer) error

Types

type Server

type Server struct {
	v1.UnimplementedStorageServer
	// contains filtered or unexported fields
}

Server is the webmesh storage server.

func NewServer

func NewServer(ctx context.Context, raft raft.Raft, rbac rbac.Evaluator, wg wireguard.Interface) *Server

NewServer returns a new storage Server.

func (*Server) Publish

func (s *Server) Publish(ctx context.Context, req *v1.PublishRequest) (*v1.PublishResponse, error)

func (*Server) Query

func (s *Server) Query(req *v1.QueryRequest, stream v1.Storage_QueryServer) error

func (*Server) Subscribe

func (s *Server) Subscribe(req *v1.SubscribeRequest, srv v1.Storage_SubscribeServer) error