server

Documentation

Overview

Package server handles satisfying the api.RSCAServer interface for the gRPC connection from the clients.

Index

• Variables
• type Server
  • func NewServer(logger *zap.Logger, st state.State) *Server
  • func (s *Server) ListHosts(_ *api.Empty, stream api.Admin_ListHostsServer) error
  • func (s *Server) Pipe(stream api.RSCA_PipeServer) error
  • func (s *Server) RemoveHost(_ context.Context, in *api.RemoveHostRequest) (*api.RemoveHostResponse, error)
  • func (s *Server) Run(ctx context.Context, cfg config.Conf) func() error
  • func (s *Server) Send(msg *api.Message) error
  • func (s *Server) TriggerAll(_ context.Context, m *api.Members) (*api.TriggerAllResponse, error)
  • func (s *Server) TriggerInfo(_ context.Context, m *api.Members) (*api.TriggerInfoResponse, error)

Variables

var ErrUnknownMessageType = errors.New("unknown message type")

ErrUnknownMessageType is returned when a message is of unknown type.

Types

type Server

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

Server is a api.RSCAServer for co-ordinating streams from clients.

func NewServer

func NewServer(logger *zap.Logger, st state.State) *Server

NewServer returns a prepared server object.

func (*Server) ListHosts

func (s *Server) ListHosts(_ *api.Empty, stream api.Admin_ListHostsServer) error

ListHosts returns a list of hosts currently registered with the server.

func (*Server) Pipe

func (s *Server) Pipe(stream api.RSCA_PipeServer) error

Pipe handles incoming streams and maintains the stream map.

func (*Server) RemoveHost

func (s *Server) RemoveHost(_ context.Context, in *api.RemoveHostRequest) (*api.RemoveHostResponse, error)

RemoveHost removes a specified list of hosts from the server.

func (*Server) Run

func (s *Server) Run(ctx context.Context, cfg config.Conf) func() error

Run is the background runner for the server.

func (*Server) Send

func (s *Server) Send(msg *api.Message) error

Send sends a supplied message to the clients specified in the api.Message:Recipients.

func (*Server) TriggerAll

func (s *Server) TriggerAll(_ context.Context, m *api.Members) (*api.TriggerAllResponse, error)

TriggerAll triggers all the services on a matching host.

func (*Server) TriggerInfo

func (s *Server) TriggerInfo(_ context.Context, m *api.Members) (*api.TriggerInfoResponse, error)

TriggerInfo triggers an information update from the host (repeat-registration).