teamserver

Documentation

Index

• Variables
• func Start() error
• func Stop()
• type AuthInterceptor
  • func NewAuthInterceptor() *AuthInterceptor
  • func (a *AuthInterceptor) Stream() grpc.StreamServerInterceptor
  • func (a *AuthInterceptor) Unary() grpc.UnaryServerInterceptor
• type MonarchServer
  • func New() (*MonarchServer, error)
  • func (s *MonarchServer) Agents(_ context.Context, req *clientpb.AgentRequest) (*clientpb.Agents, error)
  • func (s *MonarchServer) Build(ctx context.Context, req *builderpb.BuildRequest) (*clientpb.BuildReply, error)
  • func (s *MonarchServer) Builders(_ context.Context, req *clientpb.BuilderRequest) (*clientpb.Builders, error)
  • func (s *MonarchServer) Commands(_ context.Context, req *builderpb.DescriptionsRequest) (*builderpb.DescriptionsReply, error)
  • func (s *MonarchServer) EndBuild(_ context.Context, req *builderpb.BuildRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) FreeSession(ctx context.Context, r *clientpb.FreeSessionRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) GetMessages(_ *clientpb.Empty, stream rpcpb.Monarch_GetMessagesServer) error
  • func (s *MonarchServer) HttpClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)
  • func (s *MonarchServer) HttpOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)
  • func (s *MonarchServer) HttpsClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)
  • func (s *MonarchServer) HttpsOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)
  • func (s *MonarchServer) Install(req *clientpb.InstallRequest, stream rpcpb.Monarch_InstallServer) error
  • func (s *MonarchServer) LoadProfile(_ context.Context, req *clientpb.SaveProfileRequest) (*clientpb.ProfileData, error)
  • func (s *MonarchServer) LockSession(ctx context.Context, r *clientpb.LockSessionRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) NewAgent(_ context.Context, agent *clientpb.Agent) (*clientpb.Empty, error)
  • func (s *MonarchServer) Notify(_ *clientpb.Empty, stream rpcpb.Monarch_NotifyServer) error
  • func (s *MonarchServer) Options(ctx context.Context, o *builderpb.OptionsRequest) (*builderpb.OptionsReply, error)
  • func (s *MonarchServer) Players(_ context.Context, r *clientpb.PlayerRequest) (*clientpb.Players, error)
  • func (s *MonarchServer) Profiles(_ context.Context, req *clientpb.ProfileRequest) (*clientpb.Profiles, error)
  • func (s *MonarchServer) RmAgents(ctx context.Context, req *clientpb.AgentRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) RmProfiles(ctx context.Context, req *clientpb.ProfileRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) RmSession(ctx context.Context, r *clientpb.SessionsRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) SaveProfile(ctx context.Context, req *clientpb.SaveProfileRequest) (*clientpb.Empty, error)
  • func (s *MonarchServer) Send(_ context.Context, req *clientpb.HTTPRequest) (*clientpb.HTTPResponse, error)
  • func (s *MonarchServer) SendMessage(ctx context.Context, msg *rpcpb.Message) (*clientpb.Empty, error)
  • func (s *MonarchServer) Sessions(_ context.Context, req *clientpb.SessionsRequest) (*clientpb.Sessions, error)
  • func (s *MonarchServer) StageAdd(ctx context.Context, r *clientpb.StageAddRequest) (*rpcpb.Notification, error)
  • func (s *MonarchServer) StageLocal(ctx context.Context, r *clientpb.StageLocalRequest) (*rpcpb.Notification, error)
  • func (s *MonarchServer) StageView(context.Context, *clientpb.Empty) (*clientpb.Stage, error)
  • func (s *MonarchServer) TcpClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)
  • func (s *MonarchServer) TcpOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)
  • func (s *MonarchServer) Uninstall(req *clientpb.UninstallRequest, stream rpcpb.Monarch_UninstallServer) error
  • func (s *MonarchServer) Unstage(ctx context.Context, r *clientpb.UnstageRequest) (*clientpb.Empty, error)

Variables

var (
	ErrNoMetadata = errors.New("no metadata attached")
)

Functions

func Start

func Start() error

func Stop

func Stop()

Types

type AuthInterceptor

type AuthInterceptor struct{}

func NewAuthInterceptor

func NewAuthInterceptor() *AuthInterceptor

func (*AuthInterceptor) Stream

func (a *AuthInterceptor) Stream() grpc.StreamServerInterceptor

func (*AuthInterceptor) Unary

func (a *AuthInterceptor) Unary() grpc.UnaryServerInterceptor

type MonarchServer

type MonarchServer struct {
	rpcpb.UnimplementedMonarchServer
	// contains filtered or unexported fields
}

func New

func New() (*MonarchServer, error)

func (*MonarchServer) Agents

func (s *MonarchServer) Agents(_ context.Context, req *clientpb.AgentRequest) (*clientpb.Agents, error)

func (*MonarchServer) Build

func (s *MonarchServer) Build(ctx context.Context, req *builderpb.BuildRequest) (*clientpb.BuildReply, error)

Build returns a reply for a build request issued by a client. A builder client MUST be sent via ctx otherwise an error is returned.

func (*MonarchServer) Builders

func (s *MonarchServer) Builders(_ context.Context, req *clientpb.BuilderRequest) (*clientpb.Builders, error)

func (*MonarchServer) Commands

func (s *MonarchServer) Commands(_ context.Context, req *builderpb.DescriptionsRequest) (*builderpb.DescriptionsReply, error)

func (*MonarchServer) EndBuild

func (s *MonarchServer) EndBuild(_ context.Context, req *builderpb.BuildRequest) (*clientpb.Empty, error)

func (*MonarchServer) FreeSession

func (s *MonarchServer) FreeSession(ctx context.Context, r *clientpb.FreeSessionRequest) (*clientpb.Empty, error)

func (*MonarchServer) GetMessages

func (s *MonarchServer) GetMessages(_ *clientpb.Empty, stream rpcpb.Monarch_GetMessagesServer) error

func (*MonarchServer) HttpClose

func (s *MonarchServer) HttpClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)

func (*MonarchServer) HttpOpen

func (s *MonarchServer) HttpOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)

func (*MonarchServer) HttpsClose

func (s *MonarchServer) HttpsClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)

func (*MonarchServer) HttpsOpen

func (s *MonarchServer) HttpsOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)

func (*MonarchServer) Install

func (s *MonarchServer) Install(req *clientpb.InstallRequest, stream rpcpb.Monarch_InstallServer) error

func (*MonarchServer) LoadProfile

func (s *MonarchServer) LoadProfile(_ context.Context, req *clientpb.SaveProfileRequest) (*clientpb.ProfileData, error)

func (*MonarchServer) LockSession

func (s *MonarchServer) LockSession(ctx context.Context, r *clientpb.LockSessionRequest) (*clientpb.Empty, error)

func (*MonarchServer) NewAgent

func (s *MonarchServer) NewAgent(_ context.Context, agent *clientpb.Agent) (*clientpb.Empty, error)

func (*MonarchServer) Notify

func (s *MonarchServer) Notify(_ *clientpb.Empty, stream rpcpb.Monarch_NotifyServer) error

func (*MonarchServer) Options

func (s *MonarchServer) Options(ctx context.Context, o *builderpb.OptionsRequest) (*builderpb.OptionsReply, error)

Options returns build options for each request to start the build process A builder client MUST be sent via ctx otherwise an error is returned.

func (*MonarchServer) Players

func (s *MonarchServer) Players(_ context.Context, r *clientpb.PlayerRequest) (*clientpb.Players, error)

func (*MonarchServer) Profiles

func (s *MonarchServer) Profiles(_ context.Context, req *clientpb.ProfileRequest) (*clientpb.Profiles, error)

func (*MonarchServer) RmAgents

func (s *MonarchServer) RmAgents(ctx context.Context, req *clientpb.AgentRequest) (*clientpb.Empty, error)

func (*MonarchServer) RmProfiles

func (s *MonarchServer) RmProfiles(ctx context.Context, req *clientpb.ProfileRequest) (*clientpb.Empty, error)

func (*MonarchServer) RmSession

func (s *MonarchServer) RmSession(ctx context.Context, r *clientpb.SessionsRequest) (*clientpb.Empty, error)

RmSession allows admins (or users who own the associated agent) to explicitly kill a session

func (*MonarchServer) SaveProfile

func (s *MonarchServer) SaveProfile(ctx context.Context, req *clientpb.SaveProfileRequest) (*clientpb.Empty, error)

func (*MonarchServer) Send

func (s *MonarchServer) Send(_ context.Context, req *clientpb.HTTPRequest) (*clientpb.HTTPResponse, error)

func (*MonarchServer) SendMessage

func (s *MonarchServer) SendMessage(ctx context.Context, msg *rpcpb.Message) (*clientpb.Empty, error)

func (*MonarchServer) Sessions

func (s *MonarchServer) Sessions(_ context.Context, req *clientpb.SessionsRequest) (*clientpb.Sessions, error)

func (*MonarchServer) StageAdd

func (s *MonarchServer) StageAdd(ctx context.Context, r *clientpb.StageAddRequest) (*rpcpb.Notification, error)

func (*MonarchServer) StageLocal

func (s *MonarchServer) StageLocal(ctx context.Context, r *clientpb.StageLocalRequest) (*rpcpb.Notification, error)

func (*MonarchServer) StageView

func (s *MonarchServer) StageView(context.Context, *clientpb.Empty) (*clientpb.Stage, error)

func (*MonarchServer) TcpClose

func (s *MonarchServer) TcpClose(context.Context, *clientpb.Empty) (*clientpb.Empty, error)

func (*MonarchServer) TcpOpen

func (s *MonarchServer) TcpOpen(context.Context, *clientpb.Empty) (*rpcpb.Notification, error)

func (*MonarchServer) Uninstall

func (s *MonarchServer) Uninstall(req *clientpb.UninstallRequest, stream rpcpb.Monarch_UninstallServer) error

func (*MonarchServer) Unstage

func (s *MonarchServer) Unstage(ctx context.Context, r *clientpb.UnstageRequest) (*clientpb.Empty, error)