membership

Documentation

Overview

Package membership contains the webmesh membership service.

Index

• type Options
• type Server
  • func NewServer(ctx context.Context, opts Options) *Server
  • func (s *Server) Apply(ctx context.Context, log *v1.RaftLogEntry) (*v1.RaftApplyResponse, error)
  • func (s *Server) GetCurrentConsensus(ctx context.Context, _ *v1.StorageConsensusRequest) (*v1.StorageConsensusResponse, error)
  • func (s *Server) Join(ctx context.Context, req *v1.JoinRequest) (*v1.JoinResponse, error)
  • func (s *Server) Leave(ctx context.Context, req *v1.LeaveRequest) (*v1.LeaveResponse, error)
  • func (s *Server) SubscribePeers(req *v1.SubscribePeersRequest, stream v1.Membership_SubscribePeersServer) error
  • func (s *Server) Update(ctx context.Context, req *v1.UpdateRequest) (*v1.UpdateResponse, error)

Types

type Options

type Options struct {
	NodeID  types.NodeID
	Storage storage.Provider
	Plugins plugins.Manager
	RBAC    rbac.Evaluator
	Meshnet meshnet.Manager
}

Options are the options for the Membership service.

type Server

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

Server is the webmesh Membership service.

func NewServer

func NewServer(ctx context.Context, opts Options) *Server

NewServer returns a new Server.

func (*Server) Apply

func (s *Server) Apply(ctx context.Context, log *v1.RaftLogEntry) (*v1.RaftApplyResponse, error)

func (*Server) GetCurrentConsensus

func (s *Server) GetCurrentConsensus(ctx context.Context, _ *v1.StorageConsensusRequest) (*v1.StorageConsensusResponse, error)

func (*Server) Join

func (s *Server) Join(ctx context.Context, req *v1.JoinRequest) (*v1.JoinResponse, error)

func (*Server) Leave

func (s *Server) Leave(ctx context.Context, req *v1.LeaveRequest) (*v1.LeaveResponse, error)

func (*Server) SubscribePeers

func (s *Server) SubscribePeers(req *v1.SubscribePeersRequest, stream v1.Membership_SubscribePeersServer) error

func (*Server) Update

func (s *Server) Update(ctx context.Context, req *v1.UpdateRequest) (*v1.UpdateResponse, error)