services

package
v0.12.1 Latest Latest
Warning

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

Go to latest
Published: Mar 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 (
	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.

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

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 (*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 (*AuthorizeConnectionResponse) ProtoMessage

func (*AuthorizeConnectionResponse) ProtoMessage()

func (*AuthorizeConnectionResponse) ProtoReflect

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 (*AuthorizedDownstreamWorkerList) Reset added in v0.12.1

func (x *AuthorizedDownstreamWorkerList) Reset()

func (*AuthorizedDownstreamWorkerList) String added in v0.12.1

type AuthorizedWorkerList deprecated added in v0.11.1

type AuthorizedWorkerList struct {

	// the key id of authorized workers
	//
	// Deprecated: Do not use.
	WorkerKeyIdentifiers []string `protobuf:"bytes,1,rep,name=worker_key_identifiers,json=workerKeyIdentifiers,proto3" json:"worker_key_identifiers,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Do not use.

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: Do not use.

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

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) Enum

func (CONNECTIONSTATUS) EnumDescriptor deprecated

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

Deprecated: Use CONNECTIONSTATUS.Descriptor instead.

func (CONNECTIONSTATUS) Number

func (CONNECTIONSTATUS) String

func (x CONNECTIONSTATUS) String() string

func (CONNECTIONSTATUS) Type

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 (*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 (*CloseConnectionResponseData) ProtoMessage

func (*CloseConnectionResponseData) ProtoMessage()

func (*CloseConnectionResponseData) ProtoReflect

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 (*ConnectConnectionResponse) ProtoMessage

func (*ConnectConnectionResponse) ProtoMessage()

func (*ConnectConnectionResponse) ProtoReflect

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 JOBTYPE

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

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
	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) 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_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: Do not use.
	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: Do not use.
	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 (*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: Do not use.

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: Do not use.

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) Enum

func (x SESSIONSTATUS) Enum() *SESSIONSTATUS

func (SESSIONSTATUS) EnumDescriptor deprecated

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

Deprecated: Use SESSIONSTATUS.Descriptor instead.

func (SESSIONSTATUS) Number

func (SESSIONSTATUS) String

func (x SESSIONSTATUS) String() string

func (SESSIONSTATUS) Type

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.

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.

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: Do not use.
	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: Do not use.

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: Do not use.
	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: Do not use.

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) Status

type UnimplementedSessionServiceServer

type UnimplementedSessionServiceServer struct {
}

UnimplementedSessionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionServiceServer) ActivateSession

func (UnimplementedSessionServiceServer) AuthorizeConnection

func (UnimplementedSessionServiceServer) CancelSession added in v0.1.3

func (UnimplementedSessionServiceServer) CloseConnection

func (UnimplementedSessionServiceServer) ConnectConnection

func (UnimplementedSessionServiceServer) LookupSession

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) Enum added in v0.9.0

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 (UpstreamServer_TYPE) String added in v0.9.0

func (x UpstreamServer_TYPE) String() string

func (UpstreamServer_TYPE) Type added in v0.9.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL