services

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: MPL-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

View Source 
var (
	SessionProcessingError_name = map[int32]string{
		0: "SESSION_PROCESSING_ERROR_UNSPECIFIED",
		1: "SESSION_PROCESSING_ERROR_UNRECOGNIZED",
	}
	SessionProcessingError_value = map[string]int32{
		"SESSION_PROCESSING_ERROR_UNSPECIFIED":  0,
		"SESSION_PROCESSING_ERROR_UNRECOGNIZED": 1,
	}
)

Enum value maps for SessionProcessingError.

View Source 
var (
	JOBTYPE_name = map[int32]string{
		0: "JOBTYPE_UNSPECIFIED",
		1: "JOBTYPE_SESSION",
		2: "JOBTYPE_MONITOR_SESSION",
	}
	JOBTYPE_value = map[string]int32{
		"JOBTYPE_UNSPECIFIED":     0,
		"JOBTYPE_SESSION":         1,
		"JOBTYPE_MONITOR_SESSION": 2,
	}
)

Enum value maps for JOBTYPE.

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

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

View Source 
var (
	MsgType_name = map[int32]string{
		0: "MSG_TYPE_UNSPECIFIED",
		1: "MSG_TYPE_ECHO",
		2: "MSG_TYPE_UNWRAP_KEYS",
		3: "MSG_TYPE_VERIFY_SIGNATURE",
		4: "MSG_TYPE_CLOSE_SESSION_RECORDING",
		5: "MSG_TYPE_CLOSE_CONNECTION_RECORDING",
		6: "MSG_TYPE_CREATE_CHANNEL_RECORDING",
	}
	MsgType_value = map[string]int32{
		"MSG_TYPE_UNSPECIFIED":                0,
		"MSG_TYPE_ECHO":                       1,
		"MSG_TYPE_UNWRAP_KEYS":                2,
		"MSG_TYPE_VERIFY_SIGNATURE":           3,
		"MSG_TYPE_CLOSE_SESSION_RECORDING":    4,
		"MSG_TYPE_CLOSE_CONNECTION_RECORDING": 5,
		"MSG_TYPE_CREATE_CHANNEL_RECORDING":   6,
	}
)

Enum value maps for MsgType.

View Source 
var File_controller_servers_services_v1_credential_proto protoreflect.FileDescriptor
View Source 
var File_controller_servers_services_v1_server_coordination_service_proto protoreflect.FileDescriptor
View Source 
var File_controller_servers_services_v1_session_service_proto protoreflect.FileDescriptor
View Source 
var File_controller_servers_services_v1_upstream_message_service_proto protoreflect.FileDescriptor
View Source 
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)

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

View Source 
var UpstreamMessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controller.servers.services.v1.UpstreamMessageService",
	HandlerType: (*UpstreamMessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpstreamMessage",
			Handler:    _UpstreamMessageService_UpstreamMessage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "controller/servers/services/v1/upstream_message_service.proto",
}

UpstreamMessageService_ServiceDesc is the grpc.ServiceDesc for UpstreamMessageService 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)

func RegisterUpstreamMessageServiceServer added in v0.13.0 

func RegisterUpstreamMessageServiceServer(s grpc.ServiceRegistrar, srv UpstreamMessageServiceServer)

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"`
	// protocol_context contains information specific to the protocol being
	// proxied.  This is not needed to be set for tcp sessions.
	ProtocolContext *anypb.Any `protobuf:"bytes,40,opt,name=protocol_context,json=protocolContext,proto3" json:"protocol_context,omitempty" class:"public"` // @gotags: `class:"public"`
	// route specifies the workers the connection will be sent through
	Route []string `protobuf:"bytes,50,rep,name=route,proto3" json:"route,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) GetProtocolContext added in v0.12.0 

func (x *AuthorizeConnectionResponse) GetProtocolContext() *anypb.Any

func (*AuthorizeConnectionResponse) GetRoute added in v0.12.0 

func (x *AuthorizeConnectionResponse) GetRoute() []string

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 AuthorizedDownstreamWorkerList added in v0.12.1 

type AuthorizedDownstreamWorkerList struct {

	// the key id of authorized workers which do not have a worker id known yet
	// to the requester.
	UnmappedWorkerKeyIdentifiers []string `` /* 149-byte string literal not displayed */
	// the public id of workers that were reported as being connected and which
	// are known by the controller.
	WorkerPublicIds []string `protobuf:"bytes,2,rep,name=worker_public_ids,json=workerPublicIds,proto3" json:"worker_public_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthorizedDownstreamWorkerList) Descriptor deprecated added in v0.12.1 

func (*AuthorizedDownstreamWorkerList) Descriptor() ([]byte, []int)

Deprecated: Use AuthorizedDownstreamWorkerList.ProtoReflect.Descriptor instead.

func (*AuthorizedDownstreamWorkerList) GetUnmappedWorkerKeyIdentifiers added in v0.12.1 

func (x *AuthorizedDownstreamWorkerList) GetUnmappedWorkerKeyIdentifiers() []string

func (*AuthorizedDownstreamWorkerList) GetWorkerPublicIds added in v0.12.1 

func (x *AuthorizedDownstreamWorkerList) GetWorkerPublicIds() []string

func (*AuthorizedDownstreamWorkerList) ProtoMessage added in v0.12.1 

func (*AuthorizedDownstreamWorkerList) ProtoMessage()

func (*AuthorizedDownstreamWorkerList) ProtoReflect added in v0.12.1 

func (x *AuthorizedDownstreamWorkerList) ProtoReflect() protoreflect.Message

func (*AuthorizedDownstreamWorkerList) Reset added in v0.12.1 

func (x *AuthorizedDownstreamWorkerList) Reset()

func (*AuthorizedDownstreamWorkerList) String added in v0.12.1 

func (x *AuthorizedDownstreamWorkerList) String() string

type AuthorizedWorkerList deprecated added in v0.11.1 

type AuthorizedWorkerList struct {

	// the key id of authorized workers
	//
	// Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.
	WorkerKeyIdentifiers []string `protobuf:"bytes,1,rep,name=worker_key_identifiers,json=workerKeyIdentifiers,proto3" json:"worker_key_identifiers,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.

func (*AuthorizedWorkerList) Descriptor deprecated added in v0.11.1 

func (*AuthorizedWorkerList) Descriptor() ([]byte, []int)

Deprecated: Use AuthorizedWorkerList.ProtoReflect.Descriptor instead.

func (*AuthorizedWorkerList) GetWorkerKeyIdentifiers deprecated added in v0.11.1 

func (x *AuthorizedWorkerList) GetWorkerKeyIdentifiers() []string

Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.

func (*AuthorizedWorkerList) ProtoMessage added in v0.11.1 

func (*AuthorizedWorkerList) ProtoMessage()

func (*AuthorizedWorkerList) ProtoReflect added in v0.11.1 

func (x *AuthorizedWorkerList) ProtoReflect() protoreflect.Message

func (*AuthorizedWorkerList) Reset added in v0.11.1 

func (x *AuthorizedWorkerList) Reset()

func (*AuthorizedWorkerList) String added in v0.11.1 

func (x *AuthorizedWorkerList) 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      int64  `protobuf:"varint,20,opt,name=bytes_up,json=bytesUp,proto3" json:"bytes_up,omitempty" class:"public"`               // @gotags: `class:"public"`
	BytesDown    int64  `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() int64

func (*CloseConnectionRequestData) GetBytesUp 

func (x *CloseConnectionRequestData) GetBytesUp() int64

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"`
	BytesUp      int64            `protobuf:"varint,3,opt,name=bytes_up,json=bytesUp,proto3" json:"bytes_up,omitempty" class:"public"`       // @gotags: `class:"public"`
	BytesDown    int64            `protobuf:"varint,4,opt,name=bytes_down,json=bytesDown,proto3" json:"bytes_down,omitempty" class:"public"` // @gotags: `class:"public"`
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated 

func (*Connection) Descriptor() ([]byte, []int)

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetBytesDown added in v0.11.1 

func (x *Connection) GetBytesDown() int64

func (*Connection) GetBytesUp added in v0.11.1 

func (x *Connection) GetBytesUp() int64

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_SshCertificate
	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) GetSshCertificate added in v0.12.0 

func (x *Credential) GetSshCertificate() *SshCertificate

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_SshCertificate added in v0.12.0 

type Credential_SshCertificate struct {
	SshCertificate *SshCertificate `protobuf:"bytes,4,opt,name=ssh_certificate,json=sshCertificate,proto3,oneof"`
}

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 EchoUpstreamMessageRequest added in v0.13.0 

type EchoUpstreamMessageRequest struct {
	Msg string `protobuf:"bytes,10,opt,name=msg,proto3" json:"msg,omitempty" class:"secret"` // @gotags: `class:"secret"
	// contains filtered or unexported fields
}

func (*EchoUpstreamMessageRequest) Descriptor deprecated added in v0.13.0 

func (*EchoUpstreamMessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use EchoUpstreamMessageRequest.ProtoReflect.Descriptor instead.

func (*EchoUpstreamMessageRequest) GetMsg added in v0.13.0 

func (x *EchoUpstreamMessageRequest) GetMsg() string

func (*EchoUpstreamMessageRequest) ProtoMessage added in v0.13.0 

func (*EchoUpstreamMessageRequest) ProtoMessage()

func (*EchoUpstreamMessageRequest) ProtoReflect added in v0.13.0 

func (x *EchoUpstreamMessageRequest) ProtoReflect() protoreflect.Message

func (*EchoUpstreamMessageRequest) Reset added in v0.13.0 

func (x *EchoUpstreamMessageRequest) Reset()

func (*EchoUpstreamMessageRequest) String added in v0.13.0 

func (x *EchoUpstreamMessageRequest) String() string

type EchoUpstreamMessageResponse added in v0.13.0 

type EchoUpstreamMessageResponse struct {
	Msg string `protobuf:"bytes,10,opt,name=msg,proto3" json:"msg,omitempty" class:"secret"` // @gotags: `class:"secret"
	// contains filtered or unexported fields
}

func (*EchoUpstreamMessageResponse) Descriptor deprecated added in v0.13.0 

func (*EchoUpstreamMessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use EchoUpstreamMessageResponse.ProtoReflect.Descriptor instead.

func (*EchoUpstreamMessageResponse) GetMsg added in v0.13.0 

func (x *EchoUpstreamMessageResponse) GetMsg() string

func (*EchoUpstreamMessageResponse) ProtoMessage added in v0.13.0 

func (*EchoUpstreamMessageResponse) ProtoMessage()

func (*EchoUpstreamMessageResponse) ProtoReflect added in v0.13.0 

func (x *EchoUpstreamMessageResponse) ProtoReflect() protoreflect.Message

func (*EchoUpstreamMessageResponse) Reset added in v0.13.0 

func (x *EchoUpstreamMessageResponse) Reset()

func (*EchoUpstreamMessageResponse) String added in v0.13.0 

func (x *EchoUpstreamMessageResponse) String() string

type JOBTYPE 

type JOBTYPE int32
const (
	JOBTYPE_JOBTYPE_UNSPECIFIED     JOBTYPE = 0
	JOBTYPE_JOBTYPE_SESSION         JOBTYPE = 1
	JOBTYPE_JOBTYPE_MONITOR_SESSION JOBTYPE = 2
)

func (JOBTYPE) Descriptor 

func (JOBTYPE) Descriptor() protoreflect.EnumDescriptor

func (JOBTYPE) Enum 

func (x JOBTYPE) Enum() *JOBTYPE

func (JOBTYPE) EnumDescriptor deprecated 

func (JOBTYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use JOBTYPE.Descriptor instead.

func (JOBTYPE) Number 

func (x JOBTYPE) Number() protoreflect.EnumNumber

func (JOBTYPE) String 

func (x JOBTYPE) String() string

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
	//	*Job_MonitorSessionInfo
	JobInfo isJob_JobInfo `protobuf_oneof:"job_info"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetJobInfo 

func (m *Job) GetJobInfo() isJob_JobInfo

func (*Job) GetMonitorSessionInfo added in v0.13.0 

func (x *Job) GetMonitorSessionInfo() *MonitorSessionJobInfo

func (*Job) GetSessionInfo 

func (x *Job) GetSessionInfo() *SessionJobInfo

func (*Job) GetType 

func (x *Job) GetType() JOBTYPE

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetJob 

func (x *JobStatus) GetJob() *Job

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

func (x *JobStatus) ProtoReflect() protoreflect.Message

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) String 

func (x *JobStatus) String() string

type Job_MonitorSessionInfo added in v0.13.0 

type Job_MonitorSessionInfo struct {
	MonitorSessionInfo *MonitorSessionJobInfo `protobuf:"bytes,3,opt,name=monitor_session_info,json=monitorSessionInfo,proto3,oneof"`
}

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 is deprecated on this response message.  Instead use the
	// credentials field inside the ProtocolContext message.
	//
	// Deprecated: Marked as deprecated in controller/servers/services/v1/session_service.proto.
	Credentials []*Credential `protobuf:"bytes,130,rep,name=credentials,proto3" json:"credentials,omitempty" class:"secret"` // @gotags: `class:"secret"`
	// pkcs8_host_keys is deprecated on this response message.
	//
	// Deprecated: Marked as deprecated in controller/servers/services/v1/session_service.proto.
	Pkcs8HostKeys [][]byte `protobuf:"bytes,140,rep,name=pkcs8_host_keys,json=pkcs8HostKeys,proto3" json:"pkcs8_host_keys,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 deprecated added in v0.7.4 

func (x *LookupSessionResponse) GetCredentials() []*Credential

Deprecated: Marked as deprecated in controller/servers/services/v1/session_service.proto.

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) GetPkcs8HostKeys deprecated added in v0.11.0 

func (x *LookupSessionResponse) GetPkcs8HostKeys() [][]byte

Deprecated: Marked as deprecated in controller/servers/services/v1/session_service.proto.

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 MonitorSessionJobInfo added in v0.13.0 

type MonitorSessionJobInfo struct {
	SessionId string        `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" class:"public"` // @gotags: `class:"public"`
	Status    SESSIONSTATUS ``                                                                                                        // @gotags: `class:"public"`
	/* 131-byte string literal not displayed */
	ProcessingError SessionProcessingError `` // @gotags: `class:"public"`
	/* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MonitorSessionJobInfo) Descriptor deprecated added in v0.13.0 

func (*MonitorSessionJobInfo) Descriptor() ([]byte, []int)

Deprecated: Use MonitorSessionJobInfo.ProtoReflect.Descriptor instead.

func (*MonitorSessionJobInfo) GetProcessingError added in v0.13.0 

func (x *MonitorSessionJobInfo) GetProcessingError() SessionProcessingError

func (*MonitorSessionJobInfo) GetSessionId added in v0.13.0 

func (x *MonitorSessionJobInfo) GetSessionId() string

func (*MonitorSessionJobInfo) GetStatus added in v0.13.0 

func (x *MonitorSessionJobInfo) GetStatus() SESSIONSTATUS

func (*MonitorSessionJobInfo) ProtoMessage added in v0.13.0 

func (*MonitorSessionJobInfo) ProtoMessage()

func (*MonitorSessionJobInfo) ProtoReflect added in v0.13.0 

func (x *MonitorSessionJobInfo) ProtoReflect() protoreflect.Message

func (*MonitorSessionJobInfo) Reset added in v0.13.0 

func (x *MonitorSessionJobInfo) Reset()

func (*MonitorSessionJobInfo) String added in v0.13.0 

func (x *MonitorSessionJobInfo) String() string

type MsgType added in v0.13.0 

type MsgType int32

defines the set of unknown message types 

const (
	MsgType_MSG_TYPE_UNSPECIFIED                MsgType = 0
	MsgType_MSG_TYPE_ECHO                       MsgType = 1 // currently this only used for testing.
	MsgType_MSG_TYPE_UNWRAP_KEYS                MsgType = 2
	MsgType_MSG_TYPE_VERIFY_SIGNATURE           MsgType = 3
	MsgType_MSG_TYPE_CLOSE_SESSION_RECORDING    MsgType = 4
	MsgType_MSG_TYPE_CLOSE_CONNECTION_RECORDING MsgType = 5
	MsgType_MSG_TYPE_CREATE_CHANNEL_RECORDING   MsgType = 6
)

func (MsgType) Descriptor added in v0.13.0 

func (MsgType) Descriptor() protoreflect.EnumDescriptor

func (MsgType) Enum added in v0.13.0 

func (x MsgType) Enum() *MsgType

func (MsgType) EnumDescriptor deprecated added in v0.13.0 

func (MsgType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MsgType.Descriptor instead.

func (MsgType) Number added in v0.13.0 

func (x MsgType) Number() protoreflect.EnumNumber

func (MsgType) String added in v0.13.0 

func (x MsgType) String() string

func (MsgType) Type added in v0.13.0 

func (MsgType) Type() protoreflect.EnumType

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"`
	ProcessingError SessionProcessingError `` // @gotags: `class:"public"`
	/* 181-byte string literal not displayed */
	// 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) GetProcessingError added in v0.13.0 

func (x *SessionJobInfo) GetProcessingError() SessionProcessingError

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 SessionProcessingError added in v0.13.0 

type SessionProcessingError int32
const (
	SessionProcessingError_SESSION_PROCESSING_ERROR_UNSPECIFIED  SessionProcessingError = 0
	SessionProcessingError_SESSION_PROCESSING_ERROR_UNRECOGNIZED SessionProcessingError = 1
)

func (SessionProcessingError) Descriptor added in v0.13.0 

func (SessionProcessingError) Descriptor() protoreflect.EnumDescriptor

func (SessionProcessingError) Enum added in v0.13.0 

func (x SessionProcessingError) Enum() *SessionProcessingError

func (SessionProcessingError) EnumDescriptor deprecated added in v0.13.0 

func (SessionProcessingError) EnumDescriptor() ([]byte, []int)

Deprecated: Use SessionProcessingError.Descriptor instead.

func (SessionProcessingError) Number added in v0.13.0 

func (x SessionProcessingError) Number() protoreflect.EnumNumber

func (SessionProcessingError) String added in v0.13.0 

func (x SessionProcessingError) String() string

func (SessionProcessingError) Type added in v0.13.0 

func (SessionProcessingError) Type() protoreflect.EnumType

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 SshCertificate added in v0.12.0 

type SshCertificate 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 client certificate signed by a CA to establish trust of the private key.
	Certificate string `protobuf:"bytes,30,opt,name=certificate,proto3" json:"certificate,omitempty"` // @gotags: `class:"public"`
	// contains filtered or unexported fields
}

SshCertificate is a credential containing a username, private key, and client certificate.

func (*SshCertificate) Descriptor deprecated added in v0.12.0 

func (*SshCertificate) Descriptor() ([]byte, []int)

Deprecated: Use SshCertificate.ProtoReflect.Descriptor instead.

func (*SshCertificate) GetCertificate added in v0.12.0 

func (x *SshCertificate) GetCertificate() string

func (*SshCertificate) GetPrivateKey added in v0.12.0 

func (x *SshCertificate) GetPrivateKey() string

func (*SshCertificate) GetUsername added in v0.12.0 

func (x *SshCertificate) GetUsername() string

func (*SshCertificate) ProtoMessage added in v0.12.0 

func (*SshCertificate) ProtoMessage()

func (*SshCertificate) ProtoReflect added in v0.12.0 

func (x *SshCertificate) ProtoReflect() protoreflect.Message

func (*SshCertificate) Reset added in v0.12.0 

func (x *SshCertificate) Reset()

func (*SshCertificate) String added in v0.12.0 

func (x *SshCertificate) String() string

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"`
	// The worker key identifiers presented by all downstreams connected to this
	// worker.
	// Deprecated. Should be removed in 0.15.0 at which time
	// connected_unmapped_worker_key_identifiers should be used exclusively.
	//
	// Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.
	ConnectedWorkerKeyIdentifiers []string `` /* 153-byte string literal not displayed */
	// The worker key identifiers for downstream workers for which there
	// is not a known worker id mapping for them yet.
	ConnectedUnmappedWorkerKeyIdentifiers []string `` /* 179-byte string literal not displayed */
	// The worker public ids of all downstreams connected to this worker if known.
	// While there may be workers with key ids in the connected_worker_key_identifiers
	// list and their public ids in this list, once the requesting worker is aware
	// of the association, it should only populate this field.
	ConnectedWorkerPublicIds []string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

func (*StatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetConnectedUnmappedWorkerKeyIdentifiers added in v0.12.1 

func (x *StatusRequest) GetConnectedUnmappedWorkerKeyIdentifiers() []string

func (*StatusRequest) GetConnectedWorkerKeyIdentifiers deprecated added in v0.11.1 

func (x *StatusRequest) GetConnectedWorkerKeyIdentifiers() []string

Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.

func (*StatusRequest) GetConnectedWorkerPublicIds added in v0.12.1 

func (x *StatusRequest) GetConnectedWorkerPublicIds() []string

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"`
	// Of the worker key identifiers provided in the request, these are the ones
	// which are authorized to remain connected.
	// This is deprecated.  Use authorized_downstream_workers instead. This
	// should be removed in version 0.15.0.
	//
	// Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.
	AuthorizedWorkers *AuthorizedWorkerList `protobuf:"bytes,50,opt,name=authorized_workers,json=authorizedWorkers,proto3" json:"authorized_workers,omitempty"`
	// Of the downstream workers in the request, these are the ones
	// which are authorized to remain connected.
	AuthorizedDownstreamWorkers *AuthorizedDownstreamWorkerList `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

func (*StatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetAuthorizedDownstreamWorkers added in v0.12.1 

func (x *StatusResponse) GetAuthorizedDownstreamWorkers() *AuthorizedDownstreamWorkerList

func (*StatusResponse) GetAuthorizedWorkers deprecated added in v0.11.1 

func (x *StatusResponse) GetAuthorizedWorkers() *AuthorizedWorkerList

Deprecated: Marked as deprecated in controller/servers/services/v1/server_coordination_service.proto.

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 UnimplementedUpstreamMessageServiceServer added in v0.13.0 

type UnimplementedUpstreamMessageServiceServer struct {
}

UnimplementedUpstreamMessageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUpstreamMessageServiceServer) UpstreamMessage added in v0.13.0 

func (UnimplementedUpstreamMessageServiceServer) UpstreamMessage(context.Context, *UpstreamMessageRequest) (*UpstreamMessageResponse, 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 UnsafeUpstreamMessageServiceServer added in v0.13.0 

type UnsafeUpstreamMessageServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUpstreamMessageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpstreamMessageServiceServer will result in compilation errors.

type UpstreamMessageRequest added in v0.13.0 

type UpstreamMessageRequest struct {

	// the node credentials key id for the worker originated the request
	OriginatingWorkerKeyId string `` // @gotags: `class:"public"
	/* 147-byte string literal not displayed */
	// the type of the encrypted_message which must have a
	// RegisterUpstreamMessageHandler or codesUnimplemented will be returned
	MsgType MsgType `` /* 128-byte string literal not displayed */
	// message will either be encrypted (ct) or plaintext (pt) based on its
	// msg_type
	//
	// Types that are assignable to Message:
	//
	//	*UpstreamMessageRequest_Ct
	//	*UpstreamMessageRequest_Pt
	Message isUpstreamMessageRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*UpstreamMessageRequest) Descriptor deprecated added in v0.13.0 

func (*UpstreamMessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamMessageRequest.ProtoReflect.Descriptor instead.

func (*UpstreamMessageRequest) GetCt added in v0.13.0 

func (x *UpstreamMessageRequest) GetCt() []byte

func (*UpstreamMessageRequest) GetMessage added in v0.13.0 

func (m *UpstreamMessageRequest) GetMessage() isUpstreamMessageRequest_Message

func (*UpstreamMessageRequest) GetMsgType added in v0.13.0 

func (x *UpstreamMessageRequest) GetMsgType() MsgType

func (*UpstreamMessageRequest) GetOriginatingWorkerKeyId added in v0.13.0 

func (x *UpstreamMessageRequest) GetOriginatingWorkerKeyId() string

func (*UpstreamMessageRequest) GetPt added in v0.13.0 

func (x *UpstreamMessageRequest) GetPt() []byte

func (*UpstreamMessageRequest) ProtoMessage added in v0.13.0 

func (*UpstreamMessageRequest) ProtoMessage()

func (*UpstreamMessageRequest) ProtoReflect added in v0.13.0 

func (x *UpstreamMessageRequest) ProtoReflect() protoreflect.Message

func (*UpstreamMessageRequest) Reset added in v0.13.0 

func (x *UpstreamMessageRequest) Reset()

func (*UpstreamMessageRequest) String added in v0.13.0 

func (x *UpstreamMessageRequest) String() string

type UpstreamMessageRequest_Ct added in v0.13.0 

type UpstreamMessageRequest_Ct struct {
	// the encrypted upstream message. This message is encrypted with the
	// originating worker's types.NodeCredentials.
	Ct []byte `protobuf:"bytes,30,opt,name=ct,proto3,oneof" class:"secret"` // @gotags: `class:"secret"
}

type UpstreamMessageRequest_Pt added in v0.13.0 

type UpstreamMessageRequest_Pt struct {
	// the plaintext upstream message.
	Pt []byte `protobuf:"bytes,40,opt,name=pt,proto3,oneof" class:"public"` // @gotags: `class:"public"
}

type UpstreamMessageResponse added in v0.13.0 

type UpstreamMessageResponse struct {

	// the encryped response message. This message is encrypted with the
	// originating worker's types.NodeCredentials.
	// message will either be encrypted (ct) or plaintext (pt) based on its
	// msg_type
	//
	// Types that are assignable to Message:
	//
	//	*UpstreamMessageResponse_Ct
	//	*UpstreamMessageResponse_Pt
	Message isUpstreamMessageResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*UpstreamMessageResponse) Descriptor deprecated added in v0.13.0 

func (*UpstreamMessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamMessageResponse.ProtoReflect.Descriptor instead.

func (*UpstreamMessageResponse) GetCt added in v0.13.0 

func (x *UpstreamMessageResponse) GetCt() []byte

func (*UpstreamMessageResponse) GetMessage added in v0.13.0 

func (m *UpstreamMessageResponse) GetMessage() isUpstreamMessageResponse_Message

func (*UpstreamMessageResponse) GetPt added in v0.13.0 

func (x *UpstreamMessageResponse) GetPt() []byte

func (*UpstreamMessageResponse) ProtoMessage added in v0.13.0 

func (*UpstreamMessageResponse) ProtoMessage()

func (*UpstreamMessageResponse) ProtoReflect added in v0.13.0 

func (x *UpstreamMessageResponse) ProtoReflect() protoreflect.Message

func (*UpstreamMessageResponse) Reset added in v0.13.0 

func (x *UpstreamMessageResponse) Reset()

func (*UpstreamMessageResponse) String added in v0.13.0 

func (x *UpstreamMessageResponse) String() string

type UpstreamMessageResponse_Ct added in v0.13.0 

type UpstreamMessageResponse_Ct struct {
	// the encrypted upstream message. This message is encrypted with the
	// originating worker's types.NodeCredentials.
	Ct []byte `protobuf:"bytes,10,opt,name=ct,proto3,oneof" class:"secret"` // @gotags: `class:"secret"
}

type UpstreamMessageResponse_Pt added in v0.13.0 

type UpstreamMessageResponse_Pt struct {
	// the plaintext upstream message.
	Pt []byte `protobuf:"bytes,20,opt,name=pt,proto3,oneof" class:"public"` // @gotags: `class:"public"
}

type UpstreamMessageServiceClient added in v0.13.0 

type UpstreamMessageServiceClient interface {
	// sends an upstream message to the controller.
	UpstreamMessage(ctx context.Context, in *UpstreamMessageRequest, opts ...grpc.CallOption) (*UpstreamMessageResponse, error)
}

UpstreamMessageServiceClient is the client API for UpstreamMessageService 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 NewUpstreamMessageServiceClient added in v0.13.0 

func NewUpstreamMessageServiceClient(cc grpc.ClientConnInterface) UpstreamMessageServiceClient

type UpstreamMessageServiceServer added in v0.13.0 

type UpstreamMessageServiceServer interface {
	// sends an upstream message to the controller.
	UpstreamMessage(context.Context, *UpstreamMessageRequest) (*UpstreamMessageResponse, error)
	// contains filtered or unexported methods
}

UpstreamMessageServiceServer is the server API for UpstreamMessageService service. All implementations must embed UnimplementedUpstreamMessageServiceServer for forward compatibility

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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