grpc

Documentation

Index

• type GatewayServer
  • func NewGatewayServer(manager *gateway.Manager) *GatewayServer
  • func (s *GatewayServer) CreateCommandStream(stream gatewayProto.GatewayService_CreateCommandStreamServer) error
  • func (s *GatewayServer) GetServerTime(context.Context, *gatewayProto.Empty) (*gatewayProto.GetServerTimeReply, error)
• type JobServer
  • func NewJobServer(manager *gateway.Manager) *JobServer
  • func (s *JobServer) PushCommandToRoom(ctx context.Context, roomID string, cmd *gateway.Command)
  • func (s *JobServer) SendCommandToSession(ctx context.Context, sessionID string, command *gateway.Command)
  • func (s *JobServer) SendJobs(ctx context.Context, in *gatewayProto.SendJobRequest) (*gatewayProto.EmptyReply, error)

Types

type GatewayServer

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

func NewGatewayServer

func NewGatewayServer(manager *gateway.Manager) *GatewayServer

func (*GatewayServer) CreateCommandStream

func (s *GatewayServer) CreateCommandStream(stream gatewayProto.GatewayService_CreateCommandStreamServer) error

func (*GatewayServer) GetServerTime

func (s *GatewayServer) GetServerTime(context.Context, *gatewayProto.Empty) (*gatewayProto.GetServerTimeReply, error)

type JobServer

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

func NewJobServer

func NewJobServer(manager *gateway.Manager) *JobServer

func (*JobServer) PushCommandToRoom

func (s *JobServer) PushCommandToRoom(ctx context.Context, roomID string, cmd *gateway.Command)

func (*JobServer) SendCommandToSession

func (s *JobServer) SendCommandToSession(ctx context.Context, sessionID string, command *gateway.Command)

func (*JobServer) SendJobs

func (s *JobServer) SendJobs(ctx context.Context, in *gatewayProto.SendJobRequest) (*gatewayProto.EmptyReply, error)