Documentation
¶
Index ¶
- Variables
- func RegisterServerCoordinationServiceServer(s grpc.ServiceRegistrar, srv ServerCoordinationServiceServer)
- func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
- type ActivateSessionRequest
- func (*ActivateSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateSessionRequest) GetSessionId() string
- func (x *ActivateSessionRequest) GetStatus() SESSIONSTATUS
- func (x *ActivateSessionRequest) GetTofuToken() string
- func (x *ActivateSessionRequest) GetVersion() uint32
- func (x *ActivateSessionRequest) GetWorkerId() string
- func (*ActivateSessionRequest) ProtoMessage()
- func (x *ActivateSessionRequest) ProtoReflect() protoreflect.Message
- func (x *ActivateSessionRequest) Reset()
- func (x *ActivateSessionRequest) String() string
- type ActivateSessionResponse
- func (*ActivateSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateSessionResponse) GetStatus() SESSIONSTATUS
- func (*ActivateSessionResponse) ProtoMessage()
- func (x *ActivateSessionResponse) ProtoReflect() protoreflect.Message
- func (x *ActivateSessionResponse) Reset()
- func (x *ActivateSessionResponse) String() string
- type AuthorizeConnectionRequest
- func (*AuthorizeConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeConnectionRequest) GetSessionId() string
- func (x *AuthorizeConnectionRequest) GetWorkerId() string
- func (*AuthorizeConnectionRequest) ProtoMessage()
- func (x *AuthorizeConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *AuthorizeConnectionRequest) Reset()
- func (x *AuthorizeConnectionRequest) String() string
- type AuthorizeConnectionResponse
- func (*AuthorizeConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthorizeConnectionResponse) GetConnectionId() string
- func (x *AuthorizeConnectionResponse) GetConnectionsLeft() int32
- func (x *AuthorizeConnectionResponse) GetStatus() CONNECTIONSTATUS
- func (*AuthorizeConnectionResponse) ProtoMessage()
- func (x *AuthorizeConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *AuthorizeConnectionResponse) Reset()
- func (x *AuthorizeConnectionResponse) String() string
- type CHANGETYPE
- type CONNECTIONSTATUS
- func (CONNECTIONSTATUS) Descriptor() protoreflect.EnumDescriptor
- func (x CONNECTIONSTATUS) Enum() *CONNECTIONSTATUS
- func (CONNECTIONSTATUS) EnumDescriptor() ([]byte, []int)deprecated
- func (x CONNECTIONSTATUS) Number() protoreflect.EnumNumber
- func (x CONNECTIONSTATUS) String() string
- func (CONNECTIONSTATUS) Type() protoreflect.EnumType
- type CancelSessionRequest
- func (*CancelSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelSessionRequest) GetSessionId() string
- func (*CancelSessionRequest) ProtoMessage()
- func (x *CancelSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CancelSessionRequest) Reset()
- func (x *CancelSessionRequest) String() string
- type CancelSessionResponse
- func (*CancelSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CancelSessionResponse) GetStatus() SESSIONSTATUS
- func (*CancelSessionResponse) ProtoMessage()
- func (x *CancelSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CancelSessionResponse) Reset()
- func (x *CancelSessionResponse) String() string
- type CloseConnectionRequest
- func (*CloseConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseConnectionRequest) GetCloseRequestData() []*CloseConnectionRequestData
- func (*CloseConnectionRequest) ProtoMessage()
- func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseConnectionRequest) Reset()
- func (x *CloseConnectionRequest) String() string
- type CloseConnectionRequestData
- func (*CloseConnectionRequestData) Descriptor() ([]byte, []int)deprecated
- func (x *CloseConnectionRequestData) GetBytesDown() uint64
- func (x *CloseConnectionRequestData) GetBytesUp() uint64
- func (x *CloseConnectionRequestData) GetConnectionId() string
- func (x *CloseConnectionRequestData) GetReason() string
- func (*CloseConnectionRequestData) ProtoMessage()
- func (x *CloseConnectionRequestData) ProtoReflect() protoreflect.Message
- func (x *CloseConnectionRequestData) Reset()
- func (x *CloseConnectionRequestData) String() string
- type CloseConnectionResponse
- func (*CloseConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseConnectionResponse) GetCloseResponseData() []*CloseConnectionResponseData
- func (*CloseConnectionResponse) ProtoMessage()
- func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *CloseConnectionResponse) Reset()
- func (x *CloseConnectionResponse) String() string
- type CloseConnectionResponseData
- func (*CloseConnectionResponseData) Descriptor() ([]byte, []int)deprecated
- func (x *CloseConnectionResponseData) GetConnectionId() string
- func (x *CloseConnectionResponseData) GetStatus() CONNECTIONSTATUS
- func (*CloseConnectionResponseData) ProtoMessage()
- func (x *CloseConnectionResponseData) ProtoReflect() protoreflect.Message
- func (x *CloseConnectionResponseData) Reset()
- func (x *CloseConnectionResponseData) String() string
- type ConnectConnectionRequest
- func (*ConnectConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectConnectionRequest) GetClientTcpAddress() string
- func (x *ConnectConnectionRequest) GetClientTcpPort() uint32
- func (x *ConnectConnectionRequest) GetConnectionId() string
- func (x *ConnectConnectionRequest) GetEndpointTcpAddress() string
- func (x *ConnectConnectionRequest) GetEndpointTcpPort() uint32
- func (x *ConnectConnectionRequest) GetType() string
- func (*ConnectConnectionRequest) ProtoMessage()
- func (x *ConnectConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectConnectionRequest) Reset()
- func (x *ConnectConnectionRequest) String() string
- type ConnectConnectionResponse
- func (*ConnectConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectConnectionResponse) GetStatus() CONNECTIONSTATUS
- func (*ConnectConnectionResponse) ProtoMessage()
- func (x *ConnectConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectConnectionResponse) Reset()
- func (x *ConnectConnectionResponse) String() string
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)deprecated
- func (x *Connection) GetConnectionId() string
- func (x *Connection) GetStatus() CONNECTIONSTATUS
- func (*Connection) ProtoMessage()
- func (x *Connection) ProtoReflect() protoreflect.Message
- func (x *Connection) Reset()
- func (x *Connection) String() string
- type JOBTYPE
- type Job
- type JobChangeRequest
- func (*JobChangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobChangeRequest) GetJob() *Job
- func (x *JobChangeRequest) GetRequestType() CHANGETYPE
- func (*JobChangeRequest) ProtoMessage()
- func (x *JobChangeRequest) ProtoReflect() protoreflect.Message
- func (x *JobChangeRequest) Reset()
- func (x *JobChangeRequest) String() string
- type JobStatus
- type Job_SessionInfo
- type LookupSessionRequest
- func (*LookupSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupSessionRequest) GetServerId() string
- func (x *LookupSessionRequest) GetSessionId() string
- func (*LookupSessionRequest) ProtoMessage()
- func (x *LookupSessionRequest) ProtoReflect() protoreflect.Message
- func (x *LookupSessionRequest) Reset()
- func (x *LookupSessionRequest) String() string
- type LookupSessionResponse
- func (*LookupSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupSessionResponse) GetAuthorization() *targets.SessionAuthorizationData
- func (x *LookupSessionResponse) GetConnectionLimit() int32
- func (x *LookupSessionResponse) GetConnectionsLeft() int32
- func (x *LookupSessionResponse) GetEndpoint() string
- func (x *LookupSessionResponse) GetExpiration() *timestamppb.Timestamp
- func (x *LookupSessionResponse) GetHostId() string
- func (x *LookupSessionResponse) GetHostSetId() string
- func (x *LookupSessionResponse) GetStatus() SESSIONSTATUS
- func (x *LookupSessionResponse) GetTargetId() string
- func (x *LookupSessionResponse) GetTofuToken() string
- func (x *LookupSessionResponse) GetUserId() string
- func (x *LookupSessionResponse) GetVersion() uint32
- func (*LookupSessionResponse) ProtoMessage()
- func (x *LookupSessionResponse) ProtoReflect() protoreflect.Message
- func (x *LookupSessionResponse) Reset()
- func (x *LookupSessionResponse) String() string
- type SESSIONSTATUS
- func (SESSIONSTATUS) Descriptor() protoreflect.EnumDescriptor
- func (x SESSIONSTATUS) Enum() *SESSIONSTATUS
- func (SESSIONSTATUS) EnumDescriptor() ([]byte, []int)deprecated
- func (x SESSIONSTATUS) Number() protoreflect.EnumNumber
- func (x SESSIONSTATUS) String() string
- func (SESSIONSTATUS) Type() protoreflect.EnumType
- type ServerCoordinationServiceClient
- type ServerCoordinationServiceServer
- type SessionJobInfo
- func (*SessionJobInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SessionJobInfo) GetConnections() []*Connection
- func (x *SessionJobInfo) GetSessionId() string
- func (x *SessionJobInfo) GetStatus() SESSIONSTATUS
- func (*SessionJobInfo) ProtoMessage()
- func (x *SessionJobInfo) ProtoReflect() protoreflect.Message
- func (x *SessionJobInfo) Reset()
- func (x *SessionJobInfo) String() string
- type SessionServiceClient
- type SessionServiceServer
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRequest) GetJobs() []*JobStatus
- func (x *StatusRequest) GetUpdateTags() bool
- func (x *StatusRequest) GetWorker() *servers.Server
- func (*StatusRequest) ProtoMessage()
- func (x *StatusRequest) ProtoReflect() protoreflect.Message
- func (x *StatusRequest) Reset()
- func (x *StatusRequest) String() string
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetControllers() []*servers.Server
- func (x *StatusResponse) GetJobsRequests() []*JobChangeRequest
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type UnimplementedServerCoordinationServiceServer
- type UnimplementedSessionServiceServer
- func (UnimplementedSessionServiceServer) ActivateSession(context.Context, *ActivateSessionRequest) (*ActivateSessionResponse, error)
- func (UnimplementedSessionServiceServer) AuthorizeConnection(context.Context, *AuthorizeConnectionRequest) (*AuthorizeConnectionResponse, error)
- func (UnimplementedSessionServiceServer) CancelSession(context.Context, *CancelSessionRequest) (*CancelSessionResponse, error)
- func (UnimplementedSessionServiceServer) CloseConnection(context.Context, *CloseConnectionRequest) (*CloseConnectionResponse, error)
- func (UnimplementedSessionServiceServer) ConnectConnection(context.Context, *ConnectConnectionRequest) (*ConnectConnectionResponse, error)
- func (UnimplementedSessionServiceServer) LookupSession(context.Context, *LookupSessionRequest) (*LookupSessionResponse, error)
- type UnsafeServerCoordinationServiceServer
- type UnsafeSessionServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( CONNECTIONSTATUS_name = map[int32]string{ 0: "CONNECTIONSTATUS_UNSPECIFIED", 1: "CONNECTIONSTATUS_AUTHORIZED", 2: "CONNECTIONSTATUS_CONNECTED", 3: "CONNECTIONSTATUS_CLOSED", } CONNECTIONSTATUS_value = map[string]int32{ "CONNECTIONSTATUS_UNSPECIFIED": 0, "CONNECTIONSTATUS_AUTHORIZED": 1, "CONNECTIONSTATUS_CONNECTED": 2, "CONNECTIONSTATUS_CLOSED": 3, } )
Enum value maps for CONNECTIONSTATUS.
var ( SESSIONSTATUS_name = map[int32]string{ 0: "SESSIONSTATUS_UNSPECIFIED", 1: "SESSIONSTATUS_PENDING", 2: "SESSIONSTATUS_ACTIVE", 3: "SESSIONSTATUS_CANCELING", 4: "SESSIONSTATUS_TERMINATED", } SESSIONSTATUS_value = map[string]int32{ "SESSIONSTATUS_UNSPECIFIED": 0, "SESSIONSTATUS_PENDING": 1, "SESSIONSTATUS_ACTIVE": 2, "SESSIONSTATUS_CANCELING": 3, "SESSIONSTATUS_TERMINATED": 4, } )
Enum value maps for SESSIONSTATUS.
var ( JOBTYPE_name = map[int32]string{ 0: "JOBTYPE_UNSPECIFIED", 1: "JOBTYPE_SESSION", } JOBTYPE_value = map[string]int32{ "JOBTYPE_UNSPECIFIED": 0, "JOBTYPE_SESSION": 1, } )
Enum value maps for JOBTYPE.
var ( CHANGETYPE_name = map[int32]string{ 0: "CHANGETYPE_UNSPECIFIED", 1: "CHANGETYPE_UPDATE_STATE", } CHANGETYPE_value = map[string]int32{ "CHANGETYPE_UNSPECIFIED": 0, "CHANGETYPE_UPDATE_STATE": 1, } )
Enum value maps for CHANGETYPE.
var File_controller_servers_services_v1_server_coordination_service_proto protoreflect.FileDescriptor
var File_controller_servers_services_v1_session_service_proto protoreflect.FileDescriptor
var ServerCoordinationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "controller.servers.services.v1.ServerCoordinationService", HandlerType: (*ServerCoordinationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Status", Handler: _ServerCoordinationService_Status_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "controller/servers/services/v1/server_coordination_service.proto", }
ServerCoordinationService_ServiceDesc is the grpc.ServiceDesc for ServerCoordinationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SessionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "controller.servers.services.v1.SessionService", HandlerType: (*SessionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "LookupSession", Handler: _SessionService_LookupSession_Handler, }, { MethodName: "ActivateSession", Handler: _SessionService_ActivateSession_Handler, }, { MethodName: "CancelSession", Handler: _SessionService_CancelSession_Handler, }, { MethodName: "AuthorizeConnection", Handler: _SessionService_AuthorizeConnection_Handler, }, { MethodName: "ConnectConnection", Handler: _SessionService_ConnectConnection_Handler, }, { MethodName: "CloseConnection", Handler: _SessionService_CloseConnection_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "controller/servers/services/v1/session_service.proto", }
SessionService_ServiceDesc is the grpc.ServiceDesc for SessionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServerCoordinationServiceServer ¶
func RegisterServerCoordinationServiceServer(s grpc.ServiceRegistrar, srv ServerCoordinationServiceServer)
func RegisterSessionServiceServer ¶
func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
Types ¶
type ActivateSessionRequest ¶
type ActivateSessionRequest struct { SessionId string `protobuf:"bytes,10,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` TofuToken string `protobuf:"bytes,20,opt,name=tofu_token,json=tofuToken,proto3" json:"tofu_token,omitempty"` Version uint32 `protobuf:"varint,30,opt,name=version,proto3" json:"version,omitempty"` WorkerId string `protobuf:"bytes,40,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` Status SESSIONSTATUS `protobuf:"varint,50,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ActivateSessionRequest) Descriptor
deprecated
func (*ActivateSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSessionRequest.ProtoReflect.Descriptor instead.
func (*ActivateSessionRequest) GetSessionId ¶
func (x *ActivateSessionRequest) GetSessionId() string
func (*ActivateSessionRequest) GetStatus ¶
func (x *ActivateSessionRequest) GetStatus() SESSIONSTATUS
func (*ActivateSessionRequest) GetTofuToken ¶
func (x *ActivateSessionRequest) GetTofuToken() string
func (*ActivateSessionRequest) GetVersion ¶
func (x *ActivateSessionRequest) GetVersion() uint32
func (*ActivateSessionRequest) GetWorkerId ¶
func (x *ActivateSessionRequest) GetWorkerId() string
func (*ActivateSessionRequest) ProtoMessage ¶
func (*ActivateSessionRequest) ProtoMessage()
func (*ActivateSessionRequest) ProtoReflect ¶
func (x *ActivateSessionRequest) ProtoReflect() protoreflect.Message
func (*ActivateSessionRequest) Reset ¶
func (x *ActivateSessionRequest) Reset()
func (*ActivateSessionRequest) String ¶
func (x *ActivateSessionRequest) String() string
type ActivateSessionResponse ¶
type ActivateSessionResponse struct { Status SESSIONSTATUS `protobuf:"varint,10,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ActivateSessionResponse) Descriptor
deprecated
func (*ActivateSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivateSessionResponse.ProtoReflect.Descriptor instead.
func (*ActivateSessionResponse) GetStatus ¶
func (x *ActivateSessionResponse) GetStatus() SESSIONSTATUS
func (*ActivateSessionResponse) ProtoMessage ¶
func (*ActivateSessionResponse) ProtoMessage()
func (*ActivateSessionResponse) ProtoReflect ¶
func (x *ActivateSessionResponse) ProtoReflect() protoreflect.Message
func (*ActivateSessionResponse) Reset ¶
func (x *ActivateSessionResponse) Reset()
func (*ActivateSessionResponse) String ¶
func (x *ActivateSessionResponse) String() string
type AuthorizeConnectionRequest ¶
type AuthorizeConnectionRequest struct { SessionId string `protobuf:"bytes,10,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` WorkerId string `protobuf:"bytes,20,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` // contains filtered or unexported fields }
func (*AuthorizeConnectionRequest) Descriptor
deprecated
func (*AuthorizeConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeConnectionRequest.ProtoReflect.Descriptor instead.
func (*AuthorizeConnectionRequest) GetSessionId ¶
func (x *AuthorizeConnectionRequest) GetSessionId() string
func (*AuthorizeConnectionRequest) GetWorkerId ¶ added in v0.2.2
func (x *AuthorizeConnectionRequest) GetWorkerId() string
func (*AuthorizeConnectionRequest) ProtoMessage ¶
func (*AuthorizeConnectionRequest) ProtoMessage()
func (*AuthorizeConnectionRequest) ProtoReflect ¶
func (x *AuthorizeConnectionRequest) ProtoReflect() protoreflect.Message
func (*AuthorizeConnectionRequest) Reset ¶
func (x *AuthorizeConnectionRequest) Reset()
func (*AuthorizeConnectionRequest) String ¶
func (x *AuthorizeConnectionRequest) String() string
type AuthorizeConnectionResponse ¶
type AuthorizeConnectionResponse struct { ConnectionId string `protobuf:"bytes,10,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Status CONNECTIONSTATUS `protobuf:"varint,20,opt,name=status,proto3,enum=controller.servers.services.v1.CONNECTIONSTATUS" json:"status,omitempty"` ConnectionsLeft int32 `protobuf:"varint,30,opt,name=connections_left,json=connectionsLeft,proto3" json:"connections_left,omitempty"` // contains filtered or unexported fields }
func (*AuthorizeConnectionResponse) Descriptor
deprecated
func (*AuthorizeConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthorizeConnectionResponse.ProtoReflect.Descriptor instead.
func (*AuthorizeConnectionResponse) GetConnectionId ¶
func (x *AuthorizeConnectionResponse) GetConnectionId() string
func (*AuthorizeConnectionResponse) GetConnectionsLeft ¶
func (x *AuthorizeConnectionResponse) GetConnectionsLeft() int32
func (*AuthorizeConnectionResponse) GetStatus ¶
func (x *AuthorizeConnectionResponse) GetStatus() CONNECTIONSTATUS
func (*AuthorizeConnectionResponse) ProtoMessage ¶
func (*AuthorizeConnectionResponse) ProtoMessage()
func (*AuthorizeConnectionResponse) ProtoReflect ¶
func (x *AuthorizeConnectionResponse) ProtoReflect() protoreflect.Message
func (*AuthorizeConnectionResponse) Reset ¶
func (x *AuthorizeConnectionResponse) Reset()
func (*AuthorizeConnectionResponse) String ¶
func (x *AuthorizeConnectionResponse) String() string
type CHANGETYPE ¶
type CHANGETYPE int32
const ( CHANGETYPE_CHANGETYPE_UNSPECIFIED CHANGETYPE = 0 // Indicates to the worker to update its knowledge of the state, which may // cause action to be taken. CHANGETYPE_CHANGETYPE_UPDATE_STATE CHANGETYPE = 1 )
func (CHANGETYPE) Descriptor ¶
func (CHANGETYPE) Descriptor() protoreflect.EnumDescriptor
func (CHANGETYPE) Enum ¶
func (x CHANGETYPE) Enum() *CHANGETYPE
func (CHANGETYPE) EnumDescriptor
deprecated
func (CHANGETYPE) EnumDescriptor() ([]byte, []int)
Deprecated: Use CHANGETYPE.Descriptor instead.
func (CHANGETYPE) Number ¶
func (x CHANGETYPE) Number() protoreflect.EnumNumber
func (CHANGETYPE) String ¶
func (x CHANGETYPE) String() string
func (CHANGETYPE) Type ¶
func (CHANGETYPE) Type() protoreflect.EnumType
type CONNECTIONSTATUS ¶
type CONNECTIONSTATUS int32
const ( CONNECTIONSTATUS_CONNECTIONSTATUS_UNSPECIFIED CONNECTIONSTATUS = 0 CONNECTIONSTATUS_CONNECTIONSTATUS_AUTHORIZED CONNECTIONSTATUS = 1 CONNECTIONSTATUS_CONNECTIONSTATUS_CONNECTED CONNECTIONSTATUS = 2 CONNECTIONSTATUS_CONNECTIONSTATUS_CLOSED CONNECTIONSTATUS = 3 )
func (CONNECTIONSTATUS) Descriptor ¶
func (CONNECTIONSTATUS) Descriptor() protoreflect.EnumDescriptor
func (CONNECTIONSTATUS) Enum ¶
func (x CONNECTIONSTATUS) Enum() *CONNECTIONSTATUS
func (CONNECTIONSTATUS) EnumDescriptor
deprecated
func (CONNECTIONSTATUS) EnumDescriptor() ([]byte, []int)
Deprecated: Use CONNECTIONSTATUS.Descriptor instead.
func (CONNECTIONSTATUS) Number ¶
func (x CONNECTIONSTATUS) Number() protoreflect.EnumNumber
func (CONNECTIONSTATUS) String ¶
func (x CONNECTIONSTATUS) String() string
func (CONNECTIONSTATUS) Type ¶
func (CONNECTIONSTATUS) Type() protoreflect.EnumType
type CancelSessionRequest ¶ added in v0.1.3
type CancelSessionRequest struct { SessionId string `protobuf:"bytes,10,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // contains filtered or unexported fields }
func (*CancelSessionRequest) Descriptor
deprecated
added in
v0.1.3
func (*CancelSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelSessionRequest.ProtoReflect.Descriptor instead.
func (*CancelSessionRequest) GetSessionId ¶ added in v0.1.3
func (x *CancelSessionRequest) GetSessionId() string
func (*CancelSessionRequest) ProtoMessage ¶ added in v0.1.3
func (*CancelSessionRequest) ProtoMessage()
func (*CancelSessionRequest) ProtoReflect ¶ added in v0.1.3
func (x *CancelSessionRequest) ProtoReflect() protoreflect.Message
func (*CancelSessionRequest) Reset ¶ added in v0.1.3
func (x *CancelSessionRequest) Reset()
func (*CancelSessionRequest) String ¶ added in v0.1.3
func (x *CancelSessionRequest) String() string
type CancelSessionResponse ¶ added in v0.1.3
type CancelSessionResponse struct { Status SESSIONSTATUS `protobuf:"varint,10,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*CancelSessionResponse) Descriptor
deprecated
added in
v0.1.3
func (*CancelSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelSessionResponse.ProtoReflect.Descriptor instead.
func (*CancelSessionResponse) GetStatus ¶ added in v0.1.3
func (x *CancelSessionResponse) GetStatus() SESSIONSTATUS
func (*CancelSessionResponse) ProtoMessage ¶ added in v0.1.3
func (*CancelSessionResponse) ProtoMessage()
func (*CancelSessionResponse) ProtoReflect ¶ added in v0.1.3
func (x *CancelSessionResponse) ProtoReflect() protoreflect.Message
func (*CancelSessionResponse) Reset ¶ added in v0.1.3
func (x *CancelSessionResponse) Reset()
func (*CancelSessionResponse) String ¶ added in v0.1.3
func (x *CancelSessionResponse) String() string
type CloseConnectionRequest ¶
type CloseConnectionRequest struct { CloseRequestData []*CloseConnectionRequestData `protobuf:"bytes,10,rep,name=close_request_data,json=closeRequestData,proto3" json:"close_request_data,omitempty"` // contains filtered or unexported fields }
func (*CloseConnectionRequest) Descriptor
deprecated
func (*CloseConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseConnectionRequest.ProtoReflect.Descriptor instead.
func (*CloseConnectionRequest) GetCloseRequestData ¶
func (x *CloseConnectionRequest) GetCloseRequestData() []*CloseConnectionRequestData
func (*CloseConnectionRequest) ProtoMessage ¶
func (*CloseConnectionRequest) ProtoMessage()
func (*CloseConnectionRequest) ProtoReflect ¶
func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message
func (*CloseConnectionRequest) Reset ¶
func (x *CloseConnectionRequest) Reset()
func (*CloseConnectionRequest) String ¶
func (x *CloseConnectionRequest) String() string
type CloseConnectionRequestData ¶
type CloseConnectionRequestData struct { ConnectionId string `protobuf:"bytes,10,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` BytesUp uint64 `protobuf:"varint,20,opt,name=bytes_up,json=bytesUp,proto3" json:"bytes_up,omitempty"` BytesDown uint64 `protobuf:"varint,30,opt,name=bytes_down,json=bytesDown,proto3" json:"bytes_down,omitempty"` Reason string `protobuf:"bytes,40,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*CloseConnectionRequestData) Descriptor
deprecated
func (*CloseConnectionRequestData) Descriptor() ([]byte, []int)
Deprecated: Use CloseConnectionRequestData.ProtoReflect.Descriptor instead.
func (*CloseConnectionRequestData) GetBytesDown ¶
func (x *CloseConnectionRequestData) GetBytesDown() uint64
func (*CloseConnectionRequestData) GetBytesUp ¶
func (x *CloseConnectionRequestData) GetBytesUp() uint64
func (*CloseConnectionRequestData) GetConnectionId ¶
func (x *CloseConnectionRequestData) GetConnectionId() string
func (*CloseConnectionRequestData) GetReason ¶
func (x *CloseConnectionRequestData) GetReason() string
func (*CloseConnectionRequestData) ProtoMessage ¶
func (*CloseConnectionRequestData) ProtoMessage()
func (*CloseConnectionRequestData) ProtoReflect ¶
func (x *CloseConnectionRequestData) ProtoReflect() protoreflect.Message
func (*CloseConnectionRequestData) Reset ¶
func (x *CloseConnectionRequestData) Reset()
func (*CloseConnectionRequestData) String ¶
func (x *CloseConnectionRequestData) String() string
type CloseConnectionResponse ¶
type CloseConnectionResponse struct { CloseResponseData []*CloseConnectionResponseData `protobuf:"bytes,10,rep,name=close_response_data,json=closeResponseData,proto3" json:"close_response_data,omitempty"` // contains filtered or unexported fields }
func (*CloseConnectionResponse) Descriptor
deprecated
func (*CloseConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseConnectionResponse.ProtoReflect.Descriptor instead.
func (*CloseConnectionResponse) GetCloseResponseData ¶
func (x *CloseConnectionResponse) GetCloseResponseData() []*CloseConnectionResponseData
func (*CloseConnectionResponse) ProtoMessage ¶
func (*CloseConnectionResponse) ProtoMessage()
func (*CloseConnectionResponse) ProtoReflect ¶
func (x *CloseConnectionResponse) ProtoReflect() protoreflect.Message
func (*CloseConnectionResponse) Reset ¶
func (x *CloseConnectionResponse) Reset()
func (*CloseConnectionResponse) String ¶
func (x *CloseConnectionResponse) String() string
type CloseConnectionResponseData ¶
type CloseConnectionResponseData struct { ConnectionId string `protobuf:"bytes,10,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Status CONNECTIONSTATUS `protobuf:"varint,20,opt,name=status,proto3,enum=controller.servers.services.v1.CONNECTIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*CloseConnectionResponseData) Descriptor
deprecated
func (*CloseConnectionResponseData) Descriptor() ([]byte, []int)
Deprecated: Use CloseConnectionResponseData.ProtoReflect.Descriptor instead.
func (*CloseConnectionResponseData) GetConnectionId ¶
func (x *CloseConnectionResponseData) GetConnectionId() string
func (*CloseConnectionResponseData) GetStatus ¶
func (x *CloseConnectionResponseData) GetStatus() CONNECTIONSTATUS
func (*CloseConnectionResponseData) ProtoMessage ¶
func (*CloseConnectionResponseData) ProtoMessage()
func (*CloseConnectionResponseData) ProtoReflect ¶
func (x *CloseConnectionResponseData) ProtoReflect() protoreflect.Message
func (*CloseConnectionResponseData) Reset ¶
func (x *CloseConnectionResponseData) Reset()
func (*CloseConnectionResponseData) String ¶
func (x *CloseConnectionResponseData) String() string
type ConnectConnectionRequest ¶
type ConnectConnectionRequest struct { ConnectionId string `protobuf:"bytes,10,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` ClientTcpAddress string `protobuf:"bytes,20,opt,name=client_tcp_address,json=clientTcpAddress,proto3" json:"client_tcp_address,omitempty"` ClientTcpPort uint32 `protobuf:"varint,30,opt,name=client_tcp_port,json=clientTcpPort,proto3" json:"client_tcp_port,omitempty"` EndpointTcpAddress string `protobuf:"bytes,40,opt,name=endpoint_tcp_address,json=endpointTcpAddress,proto3" json:"endpoint_tcp_address,omitempty"` EndpointTcpPort uint32 `protobuf:"varint,50,opt,name=endpoint_tcp_port,json=endpointTcpPort,proto3" json:"endpoint_tcp_port,omitempty"` Type string `protobuf:"bytes,60,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ConnectConnectionRequest) Descriptor
deprecated
func (*ConnectConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectConnectionRequest.ProtoReflect.Descriptor instead.
func (*ConnectConnectionRequest) GetClientTcpAddress ¶
func (x *ConnectConnectionRequest) GetClientTcpAddress() string
func (*ConnectConnectionRequest) GetClientTcpPort ¶
func (x *ConnectConnectionRequest) GetClientTcpPort() uint32
func (*ConnectConnectionRequest) GetConnectionId ¶
func (x *ConnectConnectionRequest) GetConnectionId() string
func (*ConnectConnectionRequest) GetEndpointTcpAddress ¶
func (x *ConnectConnectionRequest) GetEndpointTcpAddress() string
func (*ConnectConnectionRequest) GetEndpointTcpPort ¶
func (x *ConnectConnectionRequest) GetEndpointTcpPort() uint32
func (*ConnectConnectionRequest) GetType ¶
func (x *ConnectConnectionRequest) GetType() string
func (*ConnectConnectionRequest) ProtoMessage ¶
func (*ConnectConnectionRequest) ProtoMessage()
func (*ConnectConnectionRequest) ProtoReflect ¶
func (x *ConnectConnectionRequest) ProtoReflect() protoreflect.Message
func (*ConnectConnectionRequest) Reset ¶
func (x *ConnectConnectionRequest) Reset()
func (*ConnectConnectionRequest) String ¶
func (x *ConnectConnectionRequest) String() string
type ConnectConnectionResponse ¶
type ConnectConnectionResponse struct { Status CONNECTIONSTATUS `protobuf:"varint,10,opt,name=status,proto3,enum=controller.servers.services.v1.CONNECTIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ConnectConnectionResponse) Descriptor
deprecated
func (*ConnectConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectConnectionResponse.ProtoReflect.Descriptor instead.
func (*ConnectConnectionResponse) GetStatus ¶
func (x *ConnectConnectionResponse) GetStatus() CONNECTIONSTATUS
func (*ConnectConnectionResponse) ProtoMessage ¶
func (*ConnectConnectionResponse) ProtoMessage()
func (*ConnectConnectionResponse) ProtoReflect ¶
func (x *ConnectConnectionResponse) ProtoReflect() protoreflect.Message
func (*ConnectConnectionResponse) Reset ¶
func (x *ConnectConnectionResponse) Reset()
func (*ConnectConnectionResponse) String ¶
func (x *ConnectConnectionResponse) String() string
type Connection ¶
type Connection struct { ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` Status CONNECTIONSTATUS `protobuf:"varint,2,opt,name=status,proto3,enum=controller.servers.services.v1.CONNECTIONSTATUS" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Connection) Descriptor
deprecated
func (*Connection) Descriptor() ([]byte, []int)
Deprecated: Use Connection.ProtoReflect.Descriptor instead.
func (*Connection) GetConnectionId ¶
func (x *Connection) GetConnectionId() string
func (*Connection) GetStatus ¶
func (x *Connection) GetStatus() CONNECTIONSTATUS
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) ProtoReflect ¶
func (x *Connection) ProtoReflect() protoreflect.Message
func (*Connection) Reset ¶
func (x *Connection) Reset()
func (*Connection) String ¶
func (x *Connection) String() string
type JOBTYPE ¶
type JOBTYPE int32
func (JOBTYPE) Descriptor ¶
func (JOBTYPE) Descriptor() protoreflect.EnumDescriptor
func (JOBTYPE) EnumDescriptor
deprecated
func (JOBTYPE) Number ¶
func (x JOBTYPE) Number() protoreflect.EnumNumber
func (JOBTYPE) Type ¶
func (JOBTYPE) Type() protoreflect.EnumType
type Job ¶
type Job struct { Type JOBTYPE `protobuf:"varint,1,opt,name=type,proto3,enum=controller.servers.services.v1.JOBTYPE" json:"type,omitempty"` // Types that are assignable to JobInfo: // *Job_SessionInfo JobInfo isJob_JobInfo `protobuf_oneof:"job_info"` // contains filtered or unexported fields }
func (*Job) Descriptor
deprecated
func (*Job) GetJobInfo ¶
func (m *Job) GetJobInfo() isJob_JobInfo
func (*Job) GetSessionInfo ¶
func (x *Job) GetSessionInfo() *SessionJobInfo
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobChangeRequest ¶
type JobChangeRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` RequestType CHANGETYPE `` /* 142-byte string literal not displayed */ // contains filtered or unexported fields }
func (*JobChangeRequest) Descriptor
deprecated
func (*JobChangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobChangeRequest.ProtoReflect.Descriptor instead.
func (*JobChangeRequest) GetJob ¶
func (x *JobChangeRequest) GetJob() *Job
func (*JobChangeRequest) GetRequestType ¶
func (x *JobChangeRequest) GetRequestType() CHANGETYPE
func (*JobChangeRequest) ProtoMessage ¶
func (*JobChangeRequest) ProtoMessage()
func (*JobChangeRequest) ProtoReflect ¶
func (x *JobChangeRequest) ProtoReflect() protoreflect.Message
func (*JobChangeRequest) Reset ¶
func (x *JobChangeRequest) Reset()
func (*JobChangeRequest) String ¶
func (x *JobChangeRequest) String() string
type JobStatus ¶
type JobStatus struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*JobStatus) Descriptor
deprecated
func (*JobStatus) ProtoMessage ¶
func (*JobStatus) ProtoMessage()
func (*JobStatus) ProtoReflect ¶
func (x *JobStatus) ProtoReflect() protoreflect.Message
type Job_SessionInfo ¶
type Job_SessionInfo struct { // This value is specified when type is JOBTYPE_SESSION. SessionInfo *SessionJobInfo `protobuf:"bytes,2,opt,name=session_info,json=sessionInfo,proto3,oneof"` }
type LookupSessionRequest ¶
type LookupSessionRequest struct { // The session ID from the client SessionId string `protobuf:"bytes,10,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // The name of the requesting worker, used for filtering to ensure this // worker is allowed to handle this session. ServerId string `protobuf:"bytes,20,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"` // contains filtered or unexported fields }
func (*LookupSessionRequest) Descriptor
deprecated
func (*LookupSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupSessionRequest.ProtoReflect.Descriptor instead.
func (*LookupSessionRequest) GetServerId ¶ added in v0.1.5
func (x *LookupSessionRequest) GetServerId() string
func (*LookupSessionRequest) GetSessionId ¶
func (x *LookupSessionRequest) GetSessionId() string
func (*LookupSessionRequest) ProtoMessage ¶
func (*LookupSessionRequest) ProtoMessage()
func (*LookupSessionRequest) ProtoReflect ¶
func (x *LookupSessionRequest) ProtoReflect() protoreflect.Message
func (*LookupSessionRequest) Reset ¶
func (x *LookupSessionRequest) Reset()
func (*LookupSessionRequest) String ¶
func (x *LookupSessionRequest) String() string
type LookupSessionResponse ¶
type LookupSessionResponse struct { Authorization *targets.SessionAuthorizationData `protobuf:"bytes,10,opt,name=authorization,proto3" json:"authorization,omitempty"` TofuToken string `protobuf:"bytes,20,opt,name=tofu_token,json=tofuToken,proto3" json:"tofu_token,omitempty"` Version uint32 `protobuf:"varint,30,opt,name=version,proto3" json:"version,omitempty"` Endpoint string `protobuf:"bytes,40,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Expiration *timestamppb.Timestamp `protobuf:"bytes,50,opt,name=expiration,proto3" json:"expiration,omitempty"` Status SESSIONSTATUS `protobuf:"varint,60,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"` ConnectionLimit int32 `protobuf:"varint,70,opt,name=connection_limit,json=connectionLimit,proto3" json:"connection_limit,omitempty"` ConnectionsLeft int32 `protobuf:"varint,80,opt,name=connections_left,json=connectionsLeft,proto3" json:"connections_left,omitempty"` HostId string `protobuf:"bytes,90,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"` HostSetId string `protobuf:"bytes,100,opt,name=host_set_id,json=hostSetId,proto3" json:"host_set_id,omitempty"` TargetId string `protobuf:"bytes,110,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"` UserId string `protobuf:"bytes,120,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` // contains filtered or unexported fields }
LookupSessionResponse contains information necessary for a client to establish a session.
func (*LookupSessionResponse) Descriptor
deprecated
func (*LookupSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupSessionResponse.ProtoReflect.Descriptor instead.
func (*LookupSessionResponse) GetAuthorization ¶
func (x *LookupSessionResponse) GetAuthorization() *targets.SessionAuthorizationData
func (*LookupSessionResponse) GetConnectionLimit ¶
func (x *LookupSessionResponse) GetConnectionLimit() int32
func (*LookupSessionResponse) GetConnectionsLeft ¶
func (x *LookupSessionResponse) GetConnectionsLeft() int32
func (*LookupSessionResponse) GetEndpoint ¶
func (x *LookupSessionResponse) GetEndpoint() string
func (*LookupSessionResponse) GetExpiration ¶
func (x *LookupSessionResponse) GetExpiration() *timestamppb.Timestamp
func (*LookupSessionResponse) GetHostId ¶
func (x *LookupSessionResponse) GetHostId() string
func (*LookupSessionResponse) GetHostSetId ¶
func (x *LookupSessionResponse) GetHostSetId() string
func (*LookupSessionResponse) GetStatus ¶
func (x *LookupSessionResponse) GetStatus() SESSIONSTATUS
func (*LookupSessionResponse) GetTargetId ¶
func (x *LookupSessionResponse) GetTargetId() string
func (*LookupSessionResponse) GetTofuToken ¶
func (x *LookupSessionResponse) GetTofuToken() string
func (*LookupSessionResponse) GetUserId ¶
func (x *LookupSessionResponse) GetUserId() string
func (*LookupSessionResponse) GetVersion ¶
func (x *LookupSessionResponse) GetVersion() uint32
func (*LookupSessionResponse) ProtoMessage ¶
func (*LookupSessionResponse) ProtoMessage()
func (*LookupSessionResponse) ProtoReflect ¶
func (x *LookupSessionResponse) ProtoReflect() protoreflect.Message
func (*LookupSessionResponse) Reset ¶
func (x *LookupSessionResponse) Reset()
func (*LookupSessionResponse) String ¶
func (x *LookupSessionResponse) String() string
type SESSIONSTATUS ¶
type SESSIONSTATUS int32
const ( SESSIONSTATUS_SESSIONSTATUS_UNSPECIFIED SESSIONSTATUS = 0 SESSIONSTATUS_SESSIONSTATUS_PENDING SESSIONSTATUS = 1 SESSIONSTATUS_SESSIONSTATUS_ACTIVE SESSIONSTATUS = 2 SESSIONSTATUS_SESSIONSTATUS_CANCELING SESSIONSTATUS = 3 SESSIONSTATUS_SESSIONSTATUS_TERMINATED SESSIONSTATUS = 4 )
func (SESSIONSTATUS) Descriptor ¶
func (SESSIONSTATUS) Descriptor() protoreflect.EnumDescriptor
func (SESSIONSTATUS) Enum ¶
func (x SESSIONSTATUS) Enum() *SESSIONSTATUS
func (SESSIONSTATUS) EnumDescriptor
deprecated
func (SESSIONSTATUS) EnumDescriptor() ([]byte, []int)
Deprecated: Use SESSIONSTATUS.Descriptor instead.
func (SESSIONSTATUS) Number ¶
func (x SESSIONSTATUS) Number() protoreflect.EnumNumber
func (SESSIONSTATUS) String ¶
func (x SESSIONSTATUS) String() string
func (SESSIONSTATUS) Type ¶
func (SESSIONSTATUS) Type() protoreflect.EnumType
type ServerCoordinationServiceClient ¶
type ServerCoordinationServiceClient interface { // Status gets worker status requests which include the ongoing jobs the worker is handling and // returns the status response which includes the changes the controller would like to make to // jobs as well as provide a list of the controllers in the system. Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) }
ServerCoordinationServiceClient is the client API for ServerCoordinationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewServerCoordinationServiceClient ¶
func NewServerCoordinationServiceClient(cc grpc.ClientConnInterface) ServerCoordinationServiceClient
type ServerCoordinationServiceServer ¶
type ServerCoordinationServiceServer interface { // Status gets worker status requests which include the ongoing jobs the worker is handling and // returns the status response which includes the changes the controller would like to make to // jobs as well as provide a list of the controllers in the system. Status(context.Context, *StatusRequest) (*StatusResponse, error) // contains filtered or unexported methods }
ServerCoordinationServiceServer is the server API for ServerCoordinationService service. All implementations must embed UnimplementedServerCoordinationServiceServer for forward compatibility
type SessionJobInfo ¶
type SessionJobInfo struct { SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` Status SESSIONSTATUS `protobuf:"varint,2,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"` Connections []*Connection `protobuf:"bytes,3,rep,name=connections,proto3" json:"connections,omitempty"` // contains filtered or unexported fields }
func (*SessionJobInfo) Descriptor
deprecated
func (*SessionJobInfo) Descriptor() ([]byte, []int)
Deprecated: Use SessionJobInfo.ProtoReflect.Descriptor instead.
func (*SessionJobInfo) GetConnections ¶
func (x *SessionJobInfo) GetConnections() []*Connection
func (*SessionJobInfo) GetSessionId ¶
func (x *SessionJobInfo) GetSessionId() string
func (*SessionJobInfo) GetStatus ¶
func (x *SessionJobInfo) GetStatus() SESSIONSTATUS
func (*SessionJobInfo) ProtoMessage ¶
func (*SessionJobInfo) ProtoMessage()
func (*SessionJobInfo) ProtoReflect ¶
func (x *SessionJobInfo) ProtoReflect() protoreflect.Message
func (*SessionJobInfo) Reset ¶
func (x *SessionJobInfo) Reset()
func (*SessionJobInfo) String ¶
func (x *SessionJobInfo) String() string
type SessionServiceClient ¶
type SessionServiceClient interface { // GetSession allows a worker to retrieve session information from the // controller. LookupSession(ctx context.Context, in *LookupSessionRequest, opts ...grpc.CallOption) (*LookupSessionResponse, error) // ActivateSession allows a worker to activate a session on a controller. ActivateSession(ctx context.Context, in *ActivateSessionRequest, opts ...grpc.CallOption) (*ActivateSessionResponse, error) // CancelSession allows a worker to request that the controller cancel a session. CancelSession(ctx context.Context, in *CancelSessionRequest, opts ...grpc.CallOption) (*CancelSessionResponse, error) // AuthorizeConnection allows a worker to authorize a connection on a controller. AuthorizeConnection(ctx context.Context, in *AuthorizeConnectionRequest, opts ...grpc.CallOption) (*AuthorizeConnectionResponse, error) // ConnectConnection updates a connection to set it to connected ConnectConnection(ctx context.Context, in *ConnectConnectionRequest, opts ...grpc.CallOption) (*ConnectConnectionResponse, error) // CloseConnections updates a connection to set it to closed CloseConnection(ctx context.Context, in *CloseConnectionRequest, opts ...grpc.CallOption) (*CloseConnectionResponse, error) }
SessionServiceClient is the client API for SessionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMockSessionServiceClient ¶ added in v0.5.1
func NewMockSessionServiceClient() SessionServiceClient
func NewSessionServiceClient ¶
func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient
type SessionServiceServer ¶
type SessionServiceServer interface { // GetSession allows a worker to retrieve session information from the // controller. LookupSession(context.Context, *LookupSessionRequest) (*LookupSessionResponse, error) // ActivateSession allows a worker to activate a session on a controller. ActivateSession(context.Context, *ActivateSessionRequest) (*ActivateSessionResponse, error) // CancelSession allows a worker to request that the controller cancel a session. CancelSession(context.Context, *CancelSessionRequest) (*CancelSessionResponse, error) // AuthorizeConnection allows a worker to authorize a connection on a controller. AuthorizeConnection(context.Context, *AuthorizeConnectionRequest) (*AuthorizeConnectionResponse, error) // ConnectConnection updates a connection to set it to connected ConnectConnection(context.Context, *ConnectConnectionRequest) (*ConnectConnectionResponse, error) // CloseConnections updates a connection to set it to closed CloseConnection(context.Context, *CloseConnectionRequest) (*CloseConnectionResponse, error) // contains filtered or unexported methods }
SessionServiceServer is the server API for SessionService service. All implementations must embed UnimplementedSessionServiceServer for forward compatibility
type StatusRequest ¶
type StatusRequest struct { // The worker info. We could use information from the TLS connection but this // is easier and going the other route doesn't provijde much benefit -- if you // get access to the key and spoof the connection, you're already compromised. Worker *servers.Server `protobuf:"bytes,10,opt,name=worker,proto3" json:"worker,omitempty"` // Jobs which this worker wants to report the status. Jobs []*JobStatus `protobuf:"bytes,20,rep,name=jobs,proto3" json:"jobs,omitempty"` // Whether to update tags from the Server block on this RPC. We only need to // do this at startup or (at some point) SIGHUP, so specifying when it's // changed allows us to avoid constant database operations for something that // won't change very often, if ever. UpdateTags bool `protobuf:"varint,30,opt,name=update_tags,json=updateTags,proto3" json:"update_tags,omitempty"` // contains filtered or unexported fields }
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) GetJobs ¶
func (x *StatusRequest) GetJobs() []*JobStatus
func (*StatusRequest) GetUpdateTags ¶ added in v0.1.5
func (x *StatusRequest) GetUpdateTags() bool
func (*StatusRequest) GetWorker ¶
func (x *StatusRequest) GetWorker() *servers.Server
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct { // Active controllers. This can be used (eventually) for connection // management. Controllers []*servers.Server `protobuf:"bytes,10,rep,name=controllers,proto3" json:"controllers,omitempty"` // List of jobs and the expected state changes. For example, this will // include jobs witch change type of canceled for jobs which are active on a // worker but should be canceled. This could also contain a request to start a // job such as a worker -> worker proxy for establishing a session through an // enclave. JobsRequests []*JobChangeRequest `protobuf:"bytes,20,rep,name=jobs_requests,json=jobsRequests,proto3" json:"jobs_requests,omitempty"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetControllers ¶
func (x *StatusResponse) GetControllers() []*servers.Server
func (*StatusResponse) GetJobsRequests ¶
func (x *StatusResponse) GetJobsRequests() []*JobChangeRequest
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type UnimplementedServerCoordinationServiceServer ¶
type UnimplementedServerCoordinationServiceServer struct { }
UnimplementedServerCoordinationServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedServerCoordinationServiceServer) Status ¶
func (UnimplementedServerCoordinationServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
type UnimplementedSessionServiceServer ¶
type UnimplementedSessionServiceServer struct { }
UnimplementedSessionServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSessionServiceServer) ActivateSession ¶
func (UnimplementedSessionServiceServer) ActivateSession(context.Context, *ActivateSessionRequest) (*ActivateSessionResponse, error)
func (UnimplementedSessionServiceServer) AuthorizeConnection ¶
func (UnimplementedSessionServiceServer) AuthorizeConnection(context.Context, *AuthorizeConnectionRequest) (*AuthorizeConnectionResponse, error)
func (UnimplementedSessionServiceServer) CancelSession ¶ added in v0.1.3
func (UnimplementedSessionServiceServer) CancelSession(context.Context, *CancelSessionRequest) (*CancelSessionResponse, error)
func (UnimplementedSessionServiceServer) CloseConnection ¶
func (UnimplementedSessionServiceServer) CloseConnection(context.Context, *CloseConnectionRequest) (*CloseConnectionResponse, error)
func (UnimplementedSessionServiceServer) ConnectConnection ¶
func (UnimplementedSessionServiceServer) ConnectConnection(context.Context, *ConnectConnectionRequest) (*ConnectConnectionResponse, error)
func (UnimplementedSessionServiceServer) LookupSession ¶
func (UnimplementedSessionServiceServer) LookupSession(context.Context, *LookupSessionRequest) (*LookupSessionResponse, error)
type UnsafeServerCoordinationServiceServer ¶ added in v0.1.2
type UnsafeServerCoordinationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeServerCoordinationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerCoordinationServiceServer will result in compilation errors.
type UnsafeSessionServiceServer ¶ added in v0.1.2
type UnsafeSessionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSessionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionServiceServer will result in compilation errors.