leader

Documentation

Index

• type Leader
  • func New(store storage.Store) *Leader
  • func (n *Leader) NewSession(stream grpc.BidiStreamingServer[control.SessionIn, control.SessionOut]) error
  • func (n *Leader) Register(ctx context.Context, req *control.RegisterRequest) (*control.RegisterResponse, error)
  • func (n *Leader) Start(ctx context.Context) error
  • func (n *Leader) Stop()

Types

type Leader

type Leader struct {
	control.UnsafeServiceServer
	*common.Shared
	// contains filtered or unexported fields
}

Leader implements the Leader role.

func New

func New(store storage.Store) *Leader

func (*Leader) NewSession

func (n *Leader) NewSession(stream grpc.BidiStreamingServer[control.SessionIn, control.SessionOut]) error

func (*Leader) Register

func (n *Leader) Register(ctx context.Context, req *control.RegisterRequest) (*control.RegisterResponse, error)

func (*Leader) Start

func (n *Leader) Start(ctx context.Context) error

func (*Leader) Stop

func (n *Leader) Stop()