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 (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: 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 

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 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 (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: 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) Descriptor() protoreflect.EnumDescriptor

func (SESSIONSTATUS) Enum 

func (x SESSIONSTATUS) Enum() *SESSIONSTATUS

func (SESSIONSTATUS) EnumDescriptor deprecated 

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

Deprecated: Use SESSIONSTATUS.Descriptor instead.

func (SESSIONSTATUS) Number 

func (x SESSIONSTATUS) Number() protoreflect.EnumNumber

func (SESSIONSTATUS) String 

func (x SESSIONSTATUS) String() string

func (SESSIONSTATUS) Type 

func (SESSIONSTATUS) Type() protoreflect.EnumType

type ServerCoordinationServiceClient 

type ServerCoordinationServiceClient interface {
	// Status gets worker status requests which include the ongoing jobs the worker is handling and
	// returns the status response which includes the changes the controller would like to make to
	// jobs as well as provide a list of the controllers in the system.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Returns the addresses of HCP Boundary workers, if any
	ListHcpbWorkers(ctx context.Context, in *ListHcpbWorkersRequest, opts ...grpc.CallOption) (*ListHcpbWorkersResponse, error)
}

ServerCoordinationServiceClient is the client API for ServerCoordinationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewServerCoordinationServiceClient 

func NewServerCoordinationServiceClient(cc grpc.ClientConnInterface) ServerCoordinationServiceClient

type ServerCoordinationServiceServer 

type ServerCoordinationServiceServer interface {
	// Status gets worker status requests which include the ongoing jobs the worker is handling and
	// returns the status response which includes the changes the controller would like to make to
	// jobs as well as provide a list of the controllers in the system.
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// Returns the addresses of HCP Boundary workers, if any
	ListHcpbWorkers(context.Context, *ListHcpbWorkersRequest) (*ListHcpbWorkersResponse, error)
	// contains filtered or unexported methods
}

ServerCoordinationServiceServer is the server API for ServerCoordinationService service. All implementations must embed UnimplementedServerCoordinationServiceServer for forward compatibility

type SessionJobInfo 

type SessionJobInfo struct {
	SessionId   string        `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty" class:"public"` // @gotags: `class:"public"`
	Status      SESSIONSTATUS `protobuf:"varint,2,opt,name=status,proto3,enum=controller.servers.services.v1.SESSIONSTATUS" json:"status,omitempty"`
	Connections []*Connection `protobuf:"bytes,3,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionJobInfo) Descriptor deprecated 

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

Deprecated: Use SessionJobInfo.ProtoReflect.Descriptor instead.

func (*SessionJobInfo) GetConnections 

func (x *SessionJobInfo) GetConnections() []*Connection

func (*SessionJobInfo) GetSessionId 

func (x *SessionJobInfo) GetSessionId() string

func (*SessionJobInfo) GetStatus 

func (x *SessionJobInfo) GetStatus() SESSIONSTATUS

func (*SessionJobInfo) ProtoMessage 

func (*SessionJobInfo) ProtoMessage()

func (*SessionJobInfo) ProtoReflect 

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

func (*SessionJobInfo) Reset 

func (x *SessionJobInfo) Reset()

func (*SessionJobInfo) String 

func (x *SessionJobInfo) String() string

type SessionServiceClient 

type SessionServiceClient interface {
	// LookupSession allows a worker to retrieve session information from the
	// controller.
	LookupSession(ctx context.Context, in *LookupSessionRequest, opts ...grpc.CallOption) (*LookupSessionResponse, error)
	// ActivateSession allows a worker to activate a session on a controller.
	ActivateSession(ctx context.Context, in *ActivateSessionRequest, opts ...grpc.CallOption) (*ActivateSessionResponse, error)
	// CancelSession allows a worker to request that the controller cancel a session.
	CancelSession(ctx context.Context, in *CancelSessionRequest, opts ...grpc.CallOption) (*CancelSessionResponse, error)
	// AuthorizeConnection allows a worker to authorize a connection on a controller.
	AuthorizeConnection(ctx context.Context, in *AuthorizeConnectionRequest, opts ...grpc.CallOption) (*AuthorizeConnectionResponse, error)
	// ConnectConnection updates a connection to set it to connected
	ConnectConnection(ctx context.Context, in *ConnectConnectionRequest, opts ...grpc.CallOption) (*ConnectConnectionResponse, error)
	// CloseConnections updates a connection to set it to closed
	CloseConnection(ctx context.Context, in *CloseConnectionRequest, opts ...grpc.CallOption) (*CloseConnectionResponse, error)
}

SessionServiceClient is the client API for SessionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSessionServiceClient 

func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient

type SessionServiceServer 

type SessionServiceServer interface {
	// LookupSession allows a worker to retrieve session information from the
	// controller.
	LookupSession(context.Context, *LookupSessionRequest) (*LookupSessionResponse, error)
	// ActivateSession allows a worker to activate a session on a controller.
	ActivateSession(context.Context, *ActivateSessionRequest) (*ActivateSessionResponse, error)
	// CancelSession allows a worker to request that the controller cancel a session.
	CancelSession(context.Context, *CancelSessionRequest) (*CancelSessionResponse, error)
	// AuthorizeConnection allows a worker to authorize a connection on a controller.
	AuthorizeConnection(context.Context, *AuthorizeConnectionRequest) (*AuthorizeConnectionResponse, error)
	// ConnectConnection updates a connection to set it to connected
	ConnectConnection(context.Context, *ConnectConnectionRequest) (*ConnectConnectionResponse, error)
	// CloseConnections updates a connection to set it to closed
	CloseConnection(context.Context, *CloseConnectionRequest) (*CloseConnectionResponse, error)
	// contains filtered or unexported methods
}

SessionServiceServer is the server API for SessionService service. All implementations must embed UnimplementedSessionServiceServer for forward compatibility

type 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) ListHcpbWorkers(context.Context, *ListHcpbWorkersRequest) (*ListHcpbWorkersResponse, error)

func (UnimplementedServerCoordinationServiceServer) Status 

func (UnimplementedServerCoordinationServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnimplementedSessionServiceServer 

type UnimplementedSessionServiceServer struct {
}

UnimplementedSessionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionServiceServer) ActivateSession 

func (UnimplementedSessionServiceServer) ActivateSession(context.Context, *ActivateSessionRequest) (*ActivateSessionResponse, error)

func (UnimplementedSessionServiceServer) AuthorizeConnection 

func (UnimplementedSessionServiceServer) AuthorizeConnection(context.Context, *AuthorizeConnectionRequest) (*AuthorizeConnectionResponse, error)

func (UnimplementedSessionServiceServer) CancelSession added in v0.1.3 

func (UnimplementedSessionServiceServer) CancelSession(context.Context, *CancelSessionRequest) (*CancelSessionResponse, error)

func (UnimplementedSessionServiceServer) CloseConnection 

func (UnimplementedSessionServiceServer) CloseConnection(context.Context, *CloseConnectionRequest) (*CloseConnectionResponse, error)

func (UnimplementedSessionServiceServer) ConnectConnection 

func (UnimplementedSessionServiceServer) ConnectConnection(context.Context, *ConnectConnectionRequest) (*ConnectConnectionResponse, error)

func (UnimplementedSessionServiceServer) LookupSession 

func (UnimplementedSessionServiceServer) LookupSession(context.Context, *LookupSessionRequest) (*LookupSessionResponse, error)

type UnsafeServerCoordinationServiceServer added in v0.1.2 

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

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

type UnsafeSessionServiceServer added in v0.1.2 

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

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

type UpstreamServer added in v0.9.0 

type UpstreamServer struct {

	// type specifies between controller or worker.
	Type UpstreamServer_TYPE `protobuf:"varint,10,opt,name=type,proto3,enum=controller.servers.services.v1.UpstreamServer_TYPE" json:"type,omitempty"`
	// Address of the daemon
	Address string `protobuf:"bytes,20,opt,name=address,proto3" json:"address,omitempty" class:"public"` // @gotags: `class:"public"`
	// contains filtered or unexported fields
}

UpstreamServer returns the controller address in the StatusResponse but may be used in the future to return worker address.

func (*UpstreamServer) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use UpstreamServer.ProtoReflect.Descriptor instead.

func (*UpstreamServer) GetAddress added in v0.9.0 

func (x *UpstreamServer) GetAddress() string

func (*UpstreamServer) GetType added in v0.9.0 

func (x *UpstreamServer) GetType() UpstreamServer_TYPE

func (*UpstreamServer) ProtoMessage added in v0.9.0 

func (*UpstreamServer) ProtoMessage()

func (*UpstreamServer) ProtoReflect added in v0.9.0 

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

func (*UpstreamServer) Reset added in v0.9.0 

func (x *UpstreamServer) Reset()

func (*UpstreamServer) String added in v0.9.0 

func (x *UpstreamServer) String() string

type UpstreamServer_TYPE added in v0.9.0 

type UpstreamServer_TYPE int32
const (
	UpstreamServer_TYPE_UNSPECIFIED UpstreamServer_TYPE = 0
	UpstreamServer_TYPE_CONTROLLER  UpstreamServer_TYPE = 1
	UpstreamServer_TYPE_WORKER      UpstreamServer_TYPE = 2
)

func (UpstreamServer_TYPE) Descriptor added in v0.9.0 

func (UpstreamServer_TYPE) Descriptor() protoreflect.EnumDescriptor

func (UpstreamServer_TYPE) Enum added in v0.9.0 

func (x UpstreamServer_TYPE) Enum() *UpstreamServer_TYPE

func (UpstreamServer_TYPE) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use UpstreamServer_TYPE.Descriptor instead.

func (UpstreamServer_TYPE) Number added in v0.9.0 

func (x UpstreamServer_TYPE) Number() protoreflect.EnumNumber

func (UpstreamServer_TYPE) String added in v0.9.0 

func (x UpstreamServer_TYPE) String() string

func (UpstreamServer_TYPE) Type added in v0.9.0 

func (UpstreamServer_TYPE) Type() protoreflect.EnumType

type UsernamePassword added in v0.9.1 

type UsernamePassword struct {

	// The username of the credential
	Username string `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"` // @gotags: `class:"public"`
	// The password of the credential
	Password string `protobuf:"bytes,20,opt,name=password,proto3" json:"password,omitempty"` // @gotags: `class:"secret"`
	// contains filtered or unexported fields
}

UsernamePassword is a credential containing a username and a password.

func (*UsernamePassword) Descriptor deprecated added in v0.9.1 

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

Deprecated: Use UsernamePassword.ProtoReflect.Descriptor instead.

func (*UsernamePassword) GetPassword added in v0.9.1 

func (x *UsernamePassword) GetPassword() string

func (*UsernamePassword) GetUsername added in v0.9.1 

func (x *UsernamePassword) GetUsername() string

func (*UsernamePassword) ProtoMessage added in v0.9.1 

func (*UsernamePassword) ProtoMessage()

func (*UsernamePassword) ProtoReflect added in v0.9.1 

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

func (*UsernamePassword) Reset added in v0.9.1 

func (x *UsernamePassword) Reset()

func (*UsernamePassword) String added in v0.9.1 

func (x *UsernamePassword) String() string

type WorkerInfo added in v0.10.0 

type WorkerInfo struct {

	// The id of the worker
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The public address of the worker
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

WorkerInfo contains information about workers for the HcpbWorkerResponse message

func (*WorkerInfo) Descriptor deprecated added in v0.10.0 

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

Deprecated: Use WorkerInfo.ProtoReflect.Descriptor instead.

func (*WorkerInfo) GetAddress added in v0.10.0 

func (x *WorkerInfo) GetAddress() string

func (*WorkerInfo) GetId added in v0.10.0 

func (x *WorkerInfo) GetId() string

func (*WorkerInfo) ProtoMessage added in v0.10.0 

func (*WorkerInfo) ProtoMessage()

func (*WorkerInfo) ProtoReflect added in v0.10.0 

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

func (*WorkerInfo) Reset added in v0.10.0 

func (x *WorkerInfo) Reset()

func (*WorkerInfo) String added in v0.10.0 

func (x *WorkerInfo) String() string

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.