Documentation ¶
Index ¶
- Variables
- func NewMockSessionServiceClient() *mockSessionServiceClient
- 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 (*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 (x *ConnectConnectionRequest) GetUserClientIp() 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 Credential
- func (*Credential) Descriptor() ([]byte, []int)deprecated
- func (m *Credential) GetCredential() isCredential_Credential
- func (x *Credential) GetSshPrivateKey() *SshPrivateKey
- func (x *Credential) GetUsernamePassword() *UsernamePassword
- func (*Credential) ProtoMessage()
- func (x *Credential) ProtoReflect() protoreflect.Message
- func (x *Credential) Reset()
- func (x *Credential) String() string
- type Credential_SshPrivateKey
- type Credential_UsernamePassword
- 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 ListHcpbWorkersRequest
- type ListHcpbWorkersResponse
- func (*ListHcpbWorkersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListHcpbWorkersResponse) GetWorkers() []*WorkerInfo
- func (*ListHcpbWorkersResponse) ProtoMessage()
- func (x *ListHcpbWorkersResponse) ProtoReflect() protoreflect.Message
- func (x *ListHcpbWorkersResponse) Reset()
- func (x *ListHcpbWorkersResponse) String() string
- type LookupSessionRequest
- func (*LookupSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupSessionRequest) GetSessionId() string
- func (x *LookupSessionRequest) GetWorkerId() 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) GetCredentials() []*Credential
- 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 SshPrivateKey
- func (*SshPrivateKey) Descriptor() ([]byte, []int)deprecated
- func (x *SshPrivateKey) GetPrivateKey() string
- func (x *SshPrivateKey) GetPrivateKeyPassphrase() string
- func (x *SshPrivateKey) GetUsername() string
- func (*SshPrivateKey) ProtoMessage()
- func (x *SshPrivateKey) ProtoReflect() protoreflect.Message
- func (x *SshPrivateKey) Reset()
- func (x *SshPrivateKey) String() string
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRequest) GetJobs() []*JobStatus
- func (x *StatusRequest) GetUpdateTags() bool
- func (x *StatusRequest) GetWorkerStatus() *servers.ServerWorkerStatus
- 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) GetCalculatedUpstreams() []*UpstreamServer
- func (x *StatusResponse) GetJobsRequests() []*JobChangeRequest
- func (x *StatusResponse) GetWorkerId() string
- 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
- type UpstreamServer
- func (*UpstreamServer) Descriptor() ([]byte, []int)deprecated
- func (x *UpstreamServer) GetAddress() string
- func (x *UpstreamServer) GetType() UpstreamServer_TYPE
- func (*UpstreamServer) ProtoMessage()
- func (x *UpstreamServer) ProtoReflect() protoreflect.Message
- func (x *UpstreamServer) Reset()
- func (x *UpstreamServer) String() string
- type UpstreamServer_TYPE
- func (UpstreamServer_TYPE) Descriptor() protoreflect.EnumDescriptor
- func (x UpstreamServer_TYPE) Enum() *UpstreamServer_TYPE
- func (UpstreamServer_TYPE) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpstreamServer_TYPE) Number() protoreflect.EnumNumber
- func (x UpstreamServer_TYPE) String() string
- func (UpstreamServer_TYPE) Type() protoreflect.EnumType
- type UsernamePassword
- func (*UsernamePassword) Descriptor() ([]byte, []int)deprecated
- func (x *UsernamePassword) GetPassword() string
- func (x *UsernamePassword) GetUsername() string
- func (*UsernamePassword) ProtoMessage()
- func (x *UsernamePassword) ProtoReflect() protoreflect.Message
- func (x *UsernamePassword) Reset()
- func (x *UsernamePassword) String() string
- type WorkerInfo
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 ( UpstreamServer_TYPE_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "TYPE_CONTROLLER", 2: "TYPE_WORKER", } UpstreamServer_TYPE_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "TYPE_CONTROLLER": 1, "TYPE_WORKER": 2, } )
Enum value maps for UpstreamServer_TYPE.
var File_controller_servers_services_v1_credential_proto protoreflect.FileDescriptor
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, }, { MethodName: "ListHcpbWorkers", Handler: _ServerCoordinationService_ListHcpbWorkers_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 NewMockSessionServiceClient ¶ added in v0.5.1
func NewMockSessionServiceClient() *mockSessionServiceClient
NewMockSessionServiceClient returns a mock SessionServiceClient which allows the mocking out specific calls to a SessionService by assigning values to the respective mock client member variables.
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" class:"public"` // @gotags: `class:"public"` TofuToken string `protobuf:"bytes,20,opt,name=tofu_token,json=tofuToken,proto3" json:"tofu_token,omitempty" class:"secret"` // @gotags: `class:"secret"` Version uint32 `protobuf:"varint,30,opt,name=version,proto3" json:"version,omitempty" class:"public"` // @gotags: `class:"public"` Status SESSIONSTATUS `` // @gotags: `class:"public"` /* 132-byte string literal not displayed */ // 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) 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 `` // @gotags: `class:"public"` /* 132-byte string literal not displayed */ // 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" class:"public"` // @gotags: `class:"public"` WorkerId string `protobuf:"bytes,20,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty" class:"public"` // @gotags: `class:"public"` // 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" class:"public"` // @gotags: `class:"public"` Status CONNECTIONSTATUS `` // @gotags: `class:"public"` /* 135-byte string literal not displayed */ ConnectionsLeft int32 `protobuf:"varint,30,opt,name=connections_left,json=connectionsLeft,proto3" json:"connections_left,omitempty" class:"public"` // @gotags: `class:"public"` // 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" class:"public"` // @gotags: `class:"public"` // 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 `` // @gotags: `class:"public"` /* 132-byte string literal not displayed */ // 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 `` // @gotags: `class:"public"` /* 127-byte string literal not displayed */ // 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" class:"public"` // @gotags: `class:"public"` BytesUp uint64 `protobuf:"varint,20,opt,name=bytes_up,json=bytesUp,proto3" json:"bytes_up,omitempty" class:"public"` // @gotags: `class:"public"` BytesDown uint64 `protobuf:"varint,30,opt,name=bytes_down,json=bytesDown,proto3" json:"bytes_down,omitempty" class:"public"` // @gotags: `class:"public"` Reason string `protobuf:"bytes,40,opt,name=reason,proto3" json:"reason,omitempty" class:"public"` // @gotags: `class:"public"` // 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 `` // @gotags: `class:"public"` /* 130-byte string literal not displayed */ // 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 `` // @gotags: `class:"public"` /* 135-byte string literal not displayed */ // 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" class:"public"` // @gotags: `class:"public"` ClientTcpAddress string `` // @gotags: `class:"public"` /* 127-byte string literal not displayed */ ClientTcpPort uint32 `protobuf:"varint,30,opt,name=client_tcp_port,json=clientTcpPort,proto3" json:"client_tcp_port,omitempty" class:"public"` // @gotags: `class:"public"` EndpointTcpAddress string `` // @gotags: `class:"public"` /* 133-byte string literal not displayed */ EndpointTcpPort uint32 `protobuf:"varint,50,opt,name=endpoint_tcp_port,json=endpointTcpPort,proto3" json:"endpoint_tcp_port,omitempty" class:"public"` // @gotags: `class:"public"` Type string `protobuf:"bytes,60,opt,name=type,proto3" json:"type,omitempty" class:"public"` // @gotags: `class:"public"` // user_client_ip is the user's client ip for the connection as determined by // the inbound http request handler UserClientIp string `protobuf:"bytes,70,opt,name=user_client_ip,json=userClientIp,proto3" json:"user_client_ip,omitempty" class:"public"` // @gotags: `class:"public" // 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) GetUserClientIp ¶ added in v0.7.4
func (x *ConnectConnectionRequest) GetUserClientIp() 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 `` // @gotags: `class:"public"` /* 135-byte string literal not displayed */ // 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" class:"public"` // @gotags: `class:"public"` 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 Credential ¶ added in v0.7.4
type Credential struct { // Types that are assignable to Credential: // *Credential_UsernamePassword // *Credential_SshPrivateKey Credential isCredential_Credential `protobuf_oneof:"credential"` // contains filtered or unexported fields }
func (*Credential) Descriptor
deprecated
added in
v0.7.4
func (*Credential) Descriptor() ([]byte, []int)
Deprecated: Use Credential.ProtoReflect.Descriptor instead.
func (*Credential) GetCredential ¶ added in v0.7.4
func (m *Credential) GetCredential() isCredential_Credential
func (*Credential) GetSshPrivateKey ¶ added in v0.10.0
func (x *Credential) GetSshPrivateKey() *SshPrivateKey
func (*Credential) GetUsernamePassword ¶ added in v0.9.1
func (x *Credential) GetUsernamePassword() *UsernamePassword
func (*Credential) ProtoMessage ¶ added in v0.7.4
func (*Credential) ProtoMessage()
func (*Credential) ProtoReflect ¶ added in v0.7.4
func (x *Credential) ProtoReflect() protoreflect.Message
func (*Credential) Reset ¶ added in v0.7.4
func (x *Credential) Reset()
func (*Credential) String ¶ added in v0.7.4
func (x *Credential) String() string
type Credential_SshPrivateKey ¶ added in v0.10.0
type Credential_SshPrivateKey struct {
SshPrivateKey *SshPrivateKey `protobuf:"bytes,3,opt,name=ssh_private_key,json=sshPrivateKey,proto3,oneof"`
}
type Credential_UsernamePassword ¶ added in v0.9.1
type Credential_UsernamePassword struct {
UsernamePassword *UsernamePassword `protobuf:"bytes,2,opt,name=username_password,json=usernamePassword,proto3,oneof"`
}
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 ListHcpbWorkersRequest ¶ added in v0.10.0
type ListHcpbWorkersRequest struct {
// contains filtered or unexported fields
}
A HCP Boundary workers request. Empty for now.
func (*ListHcpbWorkersRequest) Descriptor
deprecated
added in
v0.10.0
func (*ListHcpbWorkersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListHcpbWorkersRequest.ProtoReflect.Descriptor instead.
func (*ListHcpbWorkersRequest) ProtoMessage ¶ added in v0.10.0
func (*ListHcpbWorkersRequest) ProtoMessage()
func (*ListHcpbWorkersRequest) ProtoReflect ¶ added in v0.10.0
func (x *ListHcpbWorkersRequest) ProtoReflect() protoreflect.Message
func (*ListHcpbWorkersRequest) Reset ¶ added in v0.10.0
func (x *ListHcpbWorkersRequest) Reset()
func (*ListHcpbWorkersRequest) String ¶ added in v0.10.0
func (x *ListHcpbWorkersRequest) String() string
type ListHcpbWorkersResponse ¶ added in v0.10.0
type ListHcpbWorkersResponse struct { Workers []*WorkerInfo `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"` // contains filtered or unexported fields }
A response containing worker information
func (*ListHcpbWorkersResponse) Descriptor
deprecated
added in
v0.10.0
func (*ListHcpbWorkersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListHcpbWorkersResponse.ProtoReflect.Descriptor instead.
func (*ListHcpbWorkersResponse) GetWorkers ¶ added in v0.10.0
func (x *ListHcpbWorkersResponse) GetWorkers() []*WorkerInfo
func (*ListHcpbWorkersResponse) ProtoMessage ¶ added in v0.10.0
func (*ListHcpbWorkersResponse) ProtoMessage()
func (*ListHcpbWorkersResponse) ProtoReflect ¶ added in v0.10.0
func (x *ListHcpbWorkersResponse) ProtoReflect() protoreflect.Message
func (*ListHcpbWorkersResponse) Reset ¶ added in v0.10.0
func (x *ListHcpbWorkersResponse) Reset()
func (*ListHcpbWorkersResponse) String ¶ added in v0.10.0
func (x *ListHcpbWorkersResponse) String() string
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" class:"public"` // @gotags: `class:"public"` // The id of the requesting worker, used for filtering to ensure this worker // can handle this session WorkerId string `protobuf:"bytes,20,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty" class:"public"` // @gotags: `class:"public"` // contains filtered or unexported fields }
func (*LookupSessionRequest) Descriptor
deprecated
func (*LookupSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupSessionRequest.ProtoReflect.Descriptor instead.
func (*LookupSessionRequest) GetSessionId ¶
func (x *LookupSessionRequest) GetSessionId() string
func (*LookupSessionRequest) GetWorkerId ¶ added in v0.9.0
func (x *LookupSessionRequest) GetWorkerId() 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" class:"secret"` // @gotags: `class:"secret"` Version uint32 `protobuf:"varint,30,opt,name=version,proto3" json:"version,omitempty" class:"public"` // @gotags: `class:"public"` Endpoint string `protobuf:"bytes,40,opt,name=endpoint,proto3" json:"endpoint,omitempty" class:"public"` // @gotags: `class:"public"` Expiration *timestamppb.Timestamp `protobuf:"bytes,50,opt,name=expiration,proto3" json:"expiration,omitempty" class:"public"` // @gotags: `class:"public"` Status SESSIONSTATUS `` // @gotags: `class:"public"` /* 132-byte string literal not displayed */ ConnectionLimit int32 `protobuf:"varint,70,opt,name=connection_limit,json=connectionLimit,proto3" json:"connection_limit,omitempty" class:"public"` // @gotags: `class:"public"` ConnectionsLeft int32 `protobuf:"varint,80,opt,name=connections_left,json=connectionsLeft,proto3" json:"connections_left,omitempty" class:"public"` // @gotags: `class:"public"` HostId string `protobuf:"bytes,90,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty" class:"public"` // @gotags: `class:"public"` HostSetId string `protobuf:"bytes,100,opt,name=host_set_id,json=hostSetId,proto3" json:"host_set_id,omitempty" class:"public"` // @gotags: `class:"public"` TargetId string `protobuf:"bytes,110,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty" class:"public"` // @gotags: `class:"public"` UserId string `protobuf:"bytes,120,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty" class:"public"` // @gotags: `class:"public"` Credentials []*Credential `protobuf:"bytes,130,rep,name=credentials,proto3" json:"credentials,omitempty" class:"secret"` // @gotags: `class:"secret"` // 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) GetCredentials ¶ added in v0.7.4
func (x *LookupSessionResponse) GetCredentials() []*Credential
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) // Returns the addresses of HCP Boundary workers, if any ListHcpbWorkers(ctx context.Context, in *ListHcpbWorkersRequest, opts ...grpc.CallOption) (*ListHcpbWorkersResponse, 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) // Returns the addresses of HCP Boundary workers, if any ListHcpbWorkers(context.Context, *ListHcpbWorkersRequest) (*ListHcpbWorkersResponse, 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" class:"public"` // @gotags: `class:"public"` 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 { // LookupSession 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 NewSessionServiceClient ¶
func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient
type SessionServiceServer ¶
type SessionServiceServer interface { // LookupSession 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 SshPrivateKey ¶ added in v0.10.0
type SshPrivateKey struct { // The username of the credential Username string `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"` // @gotags: `class:"public"` // The private key of the credential PrivateKey string `protobuf:"bytes,20,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"` // @gotags: `class:"secret"` // The optional passphrase of the private_key PrivateKeyPassphrase string `protobuf:"bytes,30,opt,name=private_key_passphrase,json=privateKeyPassphrase,proto3" json:"private_key_passphrase,omitempty"` // @gotags: `class:"secret"` // contains filtered or unexported fields }
SshPrivateKey is a credential containing a username a private key and an optional private key passphrase.
func (*SshPrivateKey) Descriptor
deprecated
added in
v0.10.0
func (*SshPrivateKey) Descriptor() ([]byte, []int)
Deprecated: Use SshPrivateKey.ProtoReflect.Descriptor instead.
func (*SshPrivateKey) GetPrivateKey ¶ added in v0.10.0
func (x *SshPrivateKey) GetPrivateKey() string
func (*SshPrivateKey) GetPrivateKeyPassphrase ¶ added in v0.10.0
func (x *SshPrivateKey) GetPrivateKeyPassphrase() string
func (*SshPrivateKey) GetUsername ¶ added in v0.10.0
func (x *SshPrivateKey) GetUsername() string
func (*SshPrivateKey) ProtoMessage ¶ added in v0.10.0
func (*SshPrivateKey) ProtoMessage()
func (*SshPrivateKey) ProtoReflect ¶ added in v0.10.0
func (x *SshPrivateKey) ProtoReflect() protoreflect.Message
func (*SshPrivateKey) Reset ¶ added in v0.10.0
func (x *SshPrivateKey) Reset()
func (*SshPrivateKey) String ¶ added in v0.10.0
func (x *SshPrivateKey) String() string
type StatusRequest ¶
type StatusRequest struct { // 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"` // Replaces the old worker field: // The worker info. We could use information from the TLS connection but this // is easier and going the other route doesn't provide much benefit -- if you // get access to the key and spoof the connection, you're already compromised. WorkerStatus *servers.ServerWorkerStatus `protobuf:"bytes,40,opt,name=worker_status,json=workerStatus,proto3" json:"worker_status,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) GetWorkerStatus ¶ added in v0.9.0
func (x *StatusRequest) GetWorkerStatus() *servers.ServerWorkerStatus
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 { // 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"` // UpstreamServer currently returns the controller address in the StatusResponse. CalculatedUpstreams []*UpstreamServer `protobuf:"bytes,30,rep,name=calculated_upstreams,json=calculatedUpstreams,proto3" json:"calculated_upstreams,omitempty"` // The ID of the worker which made the request. The worker can send this value in subsequent requests so the // controller does not need to do a database lookup for the id using the name field. WorkerId string `protobuf:"bytes,40,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty" class:"public"` // @gotags: `class:"public"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetCalculatedUpstreams ¶ added in v0.9.0
func (x *StatusResponse) GetCalculatedUpstreams() []*UpstreamServer
func (*StatusResponse) GetJobsRequests ¶
func (x *StatusResponse) GetJobsRequests() []*JobChangeRequest
func (*StatusResponse) GetWorkerId ¶ added in v0.9.0
func (x *StatusResponse) GetWorkerId() string
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) ListHcpbWorkers ¶ added in v0.10.0
func (UnimplementedServerCoordinationServiceServer) ListHcpbWorkers(context.Context, *ListHcpbWorkersRequest) (*ListHcpbWorkersResponse, error)
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.
type UpstreamServer ¶ added in v0.9.0
type UpstreamServer struct { // type specifies between controller or worker. Type UpstreamServer_TYPE `protobuf:"varint,10,opt,name=type,proto3,enum=controller.servers.services.v1.UpstreamServer_TYPE" json:"type,omitempty"` // Address of the daemon Address string `protobuf:"bytes,20,opt,name=address,proto3" json:"address,omitempty" class:"public"` // @gotags: `class:"public"` // contains filtered or unexported fields }
UpstreamServer returns the controller address in the StatusResponse but may be used in the future to return worker address.
func (*UpstreamServer) Descriptor
deprecated
added in
v0.9.0
func (*UpstreamServer) Descriptor() ([]byte, []int)
Deprecated: Use UpstreamServer.ProtoReflect.Descriptor instead.
func (*UpstreamServer) GetAddress ¶ added in v0.9.0
func (x *UpstreamServer) GetAddress() string
func (*UpstreamServer) GetType ¶ added in v0.9.0
func (x *UpstreamServer) GetType() UpstreamServer_TYPE
func (*UpstreamServer) ProtoMessage ¶ added in v0.9.0
func (*UpstreamServer) ProtoMessage()
func (*UpstreamServer) ProtoReflect ¶ added in v0.9.0
func (x *UpstreamServer) ProtoReflect() protoreflect.Message
func (*UpstreamServer) Reset ¶ added in v0.9.0
func (x *UpstreamServer) Reset()
func (*UpstreamServer) String ¶ added in v0.9.0
func (x *UpstreamServer) String() string
type UpstreamServer_TYPE ¶ added in v0.9.0
type UpstreamServer_TYPE int32
const ( UpstreamServer_TYPE_UNSPECIFIED UpstreamServer_TYPE = 0 UpstreamServer_TYPE_CONTROLLER UpstreamServer_TYPE = 1 UpstreamServer_TYPE_WORKER UpstreamServer_TYPE = 2 )
func (UpstreamServer_TYPE) Descriptor ¶ added in v0.9.0
func (UpstreamServer_TYPE) Descriptor() protoreflect.EnumDescriptor
func (UpstreamServer_TYPE) Enum ¶ added in v0.9.0
func (x UpstreamServer_TYPE) Enum() *UpstreamServer_TYPE
func (UpstreamServer_TYPE) EnumDescriptor
deprecated
added in
v0.9.0
func (UpstreamServer_TYPE) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpstreamServer_TYPE.Descriptor instead.
func (UpstreamServer_TYPE) Number ¶ added in v0.9.0
func (x UpstreamServer_TYPE) Number() protoreflect.EnumNumber
func (UpstreamServer_TYPE) String ¶ added in v0.9.0
func (x UpstreamServer_TYPE) String() string
func (UpstreamServer_TYPE) Type ¶ added in v0.9.0
func (UpstreamServer_TYPE) Type() protoreflect.EnumType
type UsernamePassword ¶ added in v0.9.1
type UsernamePassword struct { // The username of the credential Username string `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"` // @gotags: `class:"public"` // The password of the credential Password string `protobuf:"bytes,20,opt,name=password,proto3" json:"password,omitempty"` // @gotags: `class:"secret"` // contains filtered or unexported fields }
UsernamePassword is a credential containing a username and a password.
func (*UsernamePassword) Descriptor
deprecated
added in
v0.9.1
func (*UsernamePassword) Descriptor() ([]byte, []int)
Deprecated: Use UsernamePassword.ProtoReflect.Descriptor instead.
func (*UsernamePassword) GetPassword ¶ added in v0.9.1
func (x *UsernamePassword) GetPassword() string
func (*UsernamePassword) GetUsername ¶ added in v0.9.1
func (x *UsernamePassword) GetUsername() string
func (*UsernamePassword) ProtoMessage ¶ added in v0.9.1
func (*UsernamePassword) ProtoMessage()
func (*UsernamePassword) ProtoReflect ¶ added in v0.9.1
func (x *UsernamePassword) ProtoReflect() protoreflect.Message
func (*UsernamePassword) Reset ¶ added in v0.9.1
func (x *UsernamePassword) Reset()
func (*UsernamePassword) String ¶ added in v0.9.1
func (x *UsernamePassword) String() string
type WorkerInfo ¶ added in v0.10.0
type WorkerInfo struct { // The id of the worker Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // The public address of the worker Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
WorkerInfo contains information about workers for the HcpbWorkerResponse message
func (*WorkerInfo) Descriptor
deprecated
added in
v0.10.0
func (*WorkerInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.
func (*WorkerInfo) GetAddress ¶ added in v0.10.0
func (x *WorkerInfo) GetAddress() string
func (*WorkerInfo) GetId ¶ added in v0.10.0
func (x *WorkerInfo) GetId() string
func (*WorkerInfo) ProtoMessage ¶ added in v0.10.0
func (*WorkerInfo) ProtoMessage()
func (*WorkerInfo) ProtoReflect ¶ added in v0.10.0
func (x *WorkerInfo) ProtoReflect() protoreflect.Message
func (*WorkerInfo) Reset ¶ added in v0.10.0
func (x *WorkerInfo) Reset()
func (*WorkerInfo) String ¶ added in v0.10.0
func (x *WorkerInfo) String() string