teamserver

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 28, 2023 License: BSD-3-Clause Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.