Documentation ¶
Index ¶
- Variables
- func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
- type AgentAbortUpdate
- type AgentClient
- type AgentCommand
- func (*AgentCommand) Descriptor() ([]byte, []int)deprecated
- func (x *AgentCommand) GetClose() *CloseConnectionRequest
- func (m *AgentCommand) GetCommand() isAgentCommand_Command
- func (x *AgentCommand) GetContainerCommand() *common.ContainerCommandRequest
- func (x *AgentCommand) GetContainerDelete() *ContainerDeleteRequest
- func (x *AgentCommand) GetContainerLog() *ContainerLogRequest
- func (x *AgentCommand) GetContainerState() *ContainerStateRequest
- func (x *AgentCommand) GetDeleteContainers() *common.DeleteContainersRequest
- func (x *AgentCommand) GetDeploy() *VersionDeployRequest
- func (x *AgentCommand) GetDeployLegacy() *DeployRequestLegacy
- func (x *AgentCommand) GetListSecrets() *ListSecretsRequest
- func (x *AgentCommand) GetUpdate() *AgentUpdateRequest
- func (*AgentCommand) ProtoMessage()
- func (x *AgentCommand) ProtoReflect() protoreflect.Message
- func (x *AgentCommand) Reset()
- func (x *AgentCommand) String() string
- type AgentCommand_Close
- type AgentCommand_ContainerCommand
- type AgentCommand_ContainerDelete
- type AgentCommand_ContainerLog
- type AgentCommand_ContainerState
- type AgentCommand_DeleteContainers
- type AgentCommand_Deploy
- type AgentCommand_DeployLegacy
- type AgentCommand_ListSecrets
- type AgentCommand_Update
- type AgentInfo
- func (*AgentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentInfo) GetId() string
- func (x *AgentInfo) GetPublicKey() string
- func (x *AgentInfo) GetVersion() string
- func (*AgentInfo) ProtoMessage()
- func (x *AgentInfo) ProtoReflect() protoreflect.Message
- func (x *AgentInfo) Reset()
- func (x *AgentInfo) String() string
- type AgentServer
- type AgentUpdateRequest
- func (*AgentUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AgentUpdateRequest) GetTag() string
- func (x *AgentUpdateRequest) GetTimeoutSeconds() int32
- func (*AgentUpdateRequest) ProtoMessage()
- func (x *AgentUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *AgentUpdateRequest) Reset()
- func (x *AgentUpdateRequest) String() string
- type Agent_ConnectClient
- type Agent_ConnectServer
- type Agent_ContainerLogClient
- type Agent_ContainerLogServer
- type Agent_ContainerStateClient
- type Agent_ContainerStateServer
- type Agent_DeploymentStatusClient
- type Agent_DeploymentStatusServer
- type CloseConnectionRequest
- func (*CloseConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseConnectionRequest) GetReason() CloseReason
- func (*CloseConnectionRequest) ProtoMessage()
- func (x *CloseConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseConnectionRequest) Reset()
- func (x *CloseConnectionRequest) String() string
- type CloseReason
- func (CloseReason) Descriptor() protoreflect.EnumDescriptor
- func (x CloseReason) Enum() *CloseReason
- func (CloseReason) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloseReason) Number() protoreflect.EnumNumber
- func (x CloseReason) String() string
- func (CloseReason) Type() protoreflect.EnumType
- type CommonContainerConfig
- func (*CommonContainerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CommonContainerConfig) GetArgs() []string
- func (x *CommonContainerConfig) GetCommands() []string
- func (x *CommonContainerConfig) GetConfigContainer() *common.ConfigContainer
- func (x *CommonContainerConfig) GetEnvironment() []string
- func (x *CommonContainerConfig) GetExpose() common.ExposeStrategy
- func (x *CommonContainerConfig) GetImportContainer() *ImportContainer
- func (x *CommonContainerConfig) GetIngress() *common.Ingress
- func (x *CommonContainerConfig) GetInitContainers() []*InitContainer
- func (x *CommonContainerConfig) GetName() string
- func (x *CommonContainerConfig) GetPortRanges() []*PortRangeBinding
- func (x *CommonContainerConfig) GetPorts() []*Port
- func (x *CommonContainerConfig) GetSecrets() map[string]string
- func (x *CommonContainerConfig) GetTTY() bool
- func (x *CommonContainerConfig) GetUser() int64
- func (x *CommonContainerConfig) GetVolumes() []*Volume
- func (*CommonContainerConfig) ProtoMessage()
- func (x *CommonContainerConfig) ProtoReflect() protoreflect.Message
- func (x *CommonContainerConfig) Reset()
- func (x *CommonContainerConfig) String() string
- type ContainerDeleteRequest
- func (*ContainerDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerDeleteRequest) GetName() string
- func (x *ContainerDeleteRequest) GetPrefix() string
- func (*ContainerDeleteRequest) ProtoMessage()
- func (x *ContainerDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *ContainerDeleteRequest) Reset()
- func (x *ContainerDeleteRequest) String() string
- type ContainerLogRequest
- func (*ContainerLogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerLogRequest) GetContainer() *common.ContainerIdentifier
- func (x *ContainerLogRequest) GetStreaming() bool
- func (x *ContainerLogRequest) GetTail() uint32
- func (*ContainerLogRequest) ProtoMessage()
- func (x *ContainerLogRequest) ProtoReflect() protoreflect.Message
- func (x *ContainerLogRequest) Reset()
- func (x *ContainerLogRequest) String() string
- type ContainerStateRequest
- func (*ContainerStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerStateRequest) GetOneShot() bool
- func (x *ContainerStateRequest) GetPrefix() string
- func (*ContainerStateRequest) ProtoMessage()
- func (x *ContainerStateRequest) ProtoReflect() protoreflect.Message
- func (x *ContainerStateRequest) Reset()
- func (x *ContainerStateRequest) String() string
- type CraneContainerConfig
- func (*CraneContainerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CraneContainerConfig) GetAnnotations() *Marker
- func (x *CraneContainerConfig) GetCustomHeaders() []string
- func (x *CraneContainerConfig) GetDeploymentStatregy() common.DeploymentStrategy
- func (x *CraneContainerConfig) GetExtraLBAnnotations() map[string]string
- func (x *CraneContainerConfig) GetHealthCheckConfig() *common.HealthCheckConfig
- func (x *CraneContainerConfig) GetLabels() *Marker
- func (x *CraneContainerConfig) GetMetrics() *Metrics
- func (x *CraneContainerConfig) GetProxyHeaders() bool
- func (x *CraneContainerConfig) GetResourceConfig() *common.ResourceConfig
- func (x *CraneContainerConfig) GetUseLoadBalancer() bool
- func (*CraneContainerConfig) ProtoMessage()
- func (x *CraneContainerConfig) ProtoReflect() protoreflect.Message
- func (x *CraneContainerConfig) Reset()
- func (x *CraneContainerConfig) String() string
- type DagentContainerConfig
- func (*DagentContainerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DagentContainerConfig) GetLabels() map[string]string
- func (x *DagentContainerConfig) GetLogConfig() *LogConfig
- func (x *DagentContainerConfig) GetNetworkMode() common.NetworkMode
- func (x *DagentContainerConfig) GetNetworks() []string
- func (x *DagentContainerConfig) GetRestartPolicy() common.RestartPolicy
- func (*DagentContainerConfig) ProtoMessage()
- func (x *DagentContainerConfig) ProtoReflect() protoreflect.Message
- func (x *DagentContainerConfig) Reset()
- func (x *DagentContainerConfig) String() string
- type DeployRequest
- func (*DeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployRequest) GetCommon() *CommonContainerConfig
- func (x *DeployRequest) GetContainerName() string
- func (x *DeployRequest) GetCrane() *CraneContainerConfig
- func (x *DeployRequest) GetDagent() *DagentContainerConfig
- func (x *DeployRequest) GetId() string
- func (x *DeployRequest) GetImageName() string
- func (x *DeployRequest) GetInstanceConfig() *InstanceConfig
- func (x *DeployRequest) GetRegistry() string
- func (x *DeployRequest) GetRegistryAuth() *RegistryAuth
- func (x *DeployRequest) GetRuntimeConfig() string
- func (x *DeployRequest) GetTag() string
- func (*DeployRequest) ProtoMessage()
- func (x *DeployRequest) ProtoReflect() protoreflect.Message
- func (x *DeployRequest) Reset()
- func (x *DeployRequest) String() string
- type DeployRequestLegacy
- func (*DeployRequestLegacy) Descriptor() ([]byte, []int)deprecated
- func (x *DeployRequestLegacy) GetJson() string
- func (x *DeployRequestLegacy) GetRequestId() string
- func (*DeployRequestLegacy) ProtoMessage()
- func (x *DeployRequestLegacy) ProtoReflect() protoreflect.Message
- func (x *DeployRequestLegacy) Reset()
- func (x *DeployRequestLegacy) String() string
- type DeployResponse
- type Environment
- type ImportContainer
- func (*ImportContainer) Descriptor() ([]byte, []int)deprecated
- func (x *ImportContainer) GetCommand() string
- func (x *ImportContainer) GetEnvironment() map[string]string
- func (x *ImportContainer) GetVolume() string
- func (*ImportContainer) ProtoMessage()
- func (x *ImportContainer) ProtoReflect() protoreflect.Message
- func (x *ImportContainer) Reset()
- func (x *ImportContainer) String() string
- type InitContainer
- func (*InitContainer) Descriptor() ([]byte, []int)deprecated
- func (x *InitContainer) GetArgs() []string
- func (x *InitContainer) GetCommand() []string
- func (x *InitContainer) GetEnvironment() map[string]string
- func (x *InitContainer) GetImage() string
- func (x *InitContainer) GetName() string
- func (x *InitContainer) GetUseParentConfig() bool
- func (x *InitContainer) GetVolumes() []*VolumeLink
- func (*InitContainer) ProtoMessage()
- func (x *InitContainer) ProtoReflect() protoreflect.Message
- func (x *InitContainer) Reset()
- func (x *InitContainer) String() string
- type InstanceConfig
- func (*InstanceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *InstanceConfig) GetEnvironment() *Environment
- func (x *InstanceConfig) GetMountPath() string
- func (x *InstanceConfig) GetPrefix() string
- func (x *InstanceConfig) GetRepositoryPrefix() string
- func (*InstanceConfig) ProtoMessage()
- func (x *InstanceConfig) ProtoReflect() protoreflect.Message
- func (x *InstanceConfig) Reset()
- func (x *InstanceConfig) String() string
- type ListSecretsRequest
- func (*ListSecretsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSecretsRequest) GetName() string
- func (x *ListSecretsRequest) GetPrefix() string
- func (*ListSecretsRequest) ProtoMessage()
- func (x *ListSecretsRequest) ProtoReflect() protoreflect.Message
- func (x *ListSecretsRequest) Reset()
- func (x *ListSecretsRequest) String() string
- type LogConfig
- func (*LogConfig) Descriptor() ([]byte, []int)deprecated
- func (x *LogConfig) GetDriver() common.DriverType
- func (x *LogConfig) GetOptions() map[string]string
- func (*LogConfig) ProtoMessage()
- func (x *LogConfig) ProtoReflect() protoreflect.Message
- func (x *LogConfig) Reset()
- func (x *LogConfig) String() string
- type Marker
- func (*Marker) Descriptor() ([]byte, []int)deprecated
- func (x *Marker) GetDeployment() map[string]string
- func (x *Marker) GetIngress() map[string]string
- func (x *Marker) GetService() map[string]string
- func (*Marker) ProtoMessage()
- func (x *Marker) ProtoReflect() protoreflect.Message
- func (x *Marker) Reset()
- func (x *Marker) String() string
- type Metrics
- type Port
- type PortRange
- type PortRangeBinding
- func (*PortRangeBinding) Descriptor() ([]byte, []int)deprecated
- func (x *PortRangeBinding) GetExternal() *PortRange
- func (x *PortRangeBinding) GetInternal() *PortRange
- func (*PortRangeBinding) ProtoMessage()
- func (x *PortRangeBinding) ProtoReflect() protoreflect.Message
- func (x *PortRangeBinding) Reset()
- func (x *PortRangeBinding) String() string
- type RegistryAuth
- func (*RegistryAuth) Descriptor() ([]byte, []int)deprecated
- func (x *RegistryAuth) GetName() string
- func (x *RegistryAuth) GetPassword() string
- func (x *RegistryAuth) GetUrl() string
- func (x *RegistryAuth) GetUser() string
- func (*RegistryAuth) ProtoMessage()
- func (x *RegistryAuth) ProtoReflect() protoreflect.Message
- func (x *RegistryAuth) Reset()
- func (x *RegistryAuth) String() string
- type UnimplementedAgentServer
- func (UnimplementedAgentServer) AbortUpdate(context.Context, *AgentAbortUpdate) (*common.Empty, error)
- func (UnimplementedAgentServer) Connect(*AgentInfo, Agent_ConnectServer) error
- func (UnimplementedAgentServer) ContainerLog(Agent_ContainerLogServer) error
- func (UnimplementedAgentServer) ContainerState(Agent_ContainerStateServer) error
- func (UnimplementedAgentServer) DeleteContainers(context.Context, *common.DeleteContainersRequest) (*common.Empty, error)
- func (UnimplementedAgentServer) DeploymentStatus(Agent_DeploymentStatusServer) error
- func (UnimplementedAgentServer) SecretList(context.Context, *common.ListSecretsResponse) (*common.Empty, error)
- type UnsafeAgentServer
- type VersionDeployRequest
- func (*VersionDeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VersionDeployRequest) GetId() string
- func (x *VersionDeployRequest) GetReleaseNotes() string
- func (x *VersionDeployRequest) GetRequests() []*DeployRequest
- func (x *VersionDeployRequest) GetVersionName() string
- func (*VersionDeployRequest) ProtoMessage()
- func (x *VersionDeployRequest) ProtoReflect() protoreflect.Message
- func (x *VersionDeployRequest) Reset()
- func (x *VersionDeployRequest) String() string
- type Volume
- func (*Volume) Descriptor() ([]byte, []int)deprecated
- func (x *Volume) GetClass() string
- func (x *Volume) GetName() string
- func (x *Volume) GetPath() string
- func (x *Volume) GetSize() string
- func (x *Volume) GetType() common.VolumeType
- func (*Volume) ProtoMessage()
- func (x *Volume) ProtoReflect() protoreflect.Message
- func (x *Volume) Reset()
- func (x *Volume) String() string
- type VolumeLink
Constants ¶
This section is empty.
Variables ¶
var ( CloseReason_name = map[int32]string{ 0: "CLOSE_REASON_UNSPECIFIED", 1: "CLOSE", 2: "SELF_DESTRUCT", 3: "SHUTDOWN", } CloseReason_value = map[string]int32{ "CLOSE_REASON_UNSPECIFIED": 0, "CLOSE": 1, "SELF_DESTRUCT": 2, "SHUTDOWN": 3, } )
Enum value maps for CloseReason.
var Agent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.Agent", HandlerType: (*AgentServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SecretList", Handler: _Agent_SecretList_Handler, }, { MethodName: "AbortUpdate", Handler: _Agent_AbortUpdate_Handler, }, { MethodName: "DeleteContainers", Handler: _Agent_DeleteContainers_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Connect", Handler: _Agent_Connect_Handler, ServerStreams: true, }, { StreamName: "DeploymentStatus", Handler: _Agent_DeploymentStatus_Handler, ClientStreams: true, }, { StreamName: "ContainerState", Handler: _Agent_ContainerState_Handler, ClientStreams: true, }, { StreamName: "ContainerLog", Handler: _Agent_ContainerLog_Handler, ClientStreams: true, }, }, Metadata: "protobuf/proto/agent.proto", }
Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_protobuf_proto_agent_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServer ¶
func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
Types ¶
type AgentAbortUpdate ¶
type AgentAbortUpdate struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*AgentAbortUpdate) Descriptor
deprecated
func (*AgentAbortUpdate) Descriptor() ([]byte, []int)
Deprecated: Use AgentAbortUpdate.ProtoReflect.Descriptor instead.
func (*AgentAbortUpdate) GetError ¶
func (x *AgentAbortUpdate) GetError() string
func (*AgentAbortUpdate) ProtoMessage ¶
func (*AgentAbortUpdate) ProtoMessage()
func (*AgentAbortUpdate) ProtoReflect ¶
func (x *AgentAbortUpdate) ProtoReflect() protoreflect.Message
func (*AgentAbortUpdate) Reset ¶
func (x *AgentAbortUpdate) Reset()
func (*AgentAbortUpdate) String ¶
func (x *AgentAbortUpdate) String() string
type AgentClient ¶
type AgentClient interface { // * // Subscribe with pre-assigned AgentID, waiting for incoming // deploy requests and prefix status requests. // In both cases, separate, shorter-living channels are opened. // For deployment status reports, closed when ended. // For prefix state reports, should be closed by the server. Connect(ctx context.Context, in *AgentInfo, opts ...grpc.CallOption) (Agent_ConnectClient, error) DeploymentStatus(ctx context.Context, opts ...grpc.CallOption) (Agent_DeploymentStatusClient, error) ContainerState(ctx context.Context, opts ...grpc.CallOption) (Agent_ContainerStateClient, error) SecretList(ctx context.Context, in *common.ListSecretsResponse, opts ...grpc.CallOption) (*common.Empty, error) AbortUpdate(ctx context.Context, in *AgentAbortUpdate, opts ...grpc.CallOption) (*common.Empty, error) DeleteContainers(ctx context.Context, in *common.DeleteContainersRequest, opts ...grpc.CallOption) (*common.Empty, error) ContainerLog(ctx context.Context, opts ...grpc.CallOption) (Agent_ContainerLogClient, error) }
AgentClient is the client API for Agent 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 NewAgentClient ¶
func NewAgentClient(cc grpc.ClientConnInterface) AgentClient
type AgentCommand ¶
type AgentCommand struct { // Types that are assignable to Command: // // *AgentCommand_Deploy // *AgentCommand_ContainerState // *AgentCommand_ContainerDelete // *AgentCommand_DeployLegacy // *AgentCommand_ListSecrets // *AgentCommand_Update // *AgentCommand_Close // *AgentCommand_ContainerCommand // *AgentCommand_DeleteContainers // *AgentCommand_ContainerLog Command isAgentCommand_Command `protobuf_oneof:"command"` // contains filtered or unexported fields }
func (*AgentCommand) Descriptor
deprecated
func (*AgentCommand) Descriptor() ([]byte, []int)
Deprecated: Use AgentCommand.ProtoReflect.Descriptor instead.
func (*AgentCommand) GetClose ¶
func (x *AgentCommand) GetClose() *CloseConnectionRequest
func (*AgentCommand) GetCommand ¶
func (m *AgentCommand) GetCommand() isAgentCommand_Command
func (*AgentCommand) GetContainerCommand ¶
func (x *AgentCommand) GetContainerCommand() *common.ContainerCommandRequest
func (*AgentCommand) GetContainerDelete ¶
func (x *AgentCommand) GetContainerDelete() *ContainerDeleteRequest
func (*AgentCommand) GetContainerLog ¶
func (x *AgentCommand) GetContainerLog() *ContainerLogRequest
func (*AgentCommand) GetContainerState ¶
func (x *AgentCommand) GetContainerState() *ContainerStateRequest
func (*AgentCommand) GetDeleteContainers ¶
func (x *AgentCommand) GetDeleteContainers() *common.DeleteContainersRequest
func (*AgentCommand) GetDeploy ¶
func (x *AgentCommand) GetDeploy() *VersionDeployRequest
func (*AgentCommand) GetDeployLegacy ¶
func (x *AgentCommand) GetDeployLegacy() *DeployRequestLegacy
func (*AgentCommand) GetListSecrets ¶
func (x *AgentCommand) GetListSecrets() *ListSecretsRequest
func (*AgentCommand) GetUpdate ¶
func (x *AgentCommand) GetUpdate() *AgentUpdateRequest
func (*AgentCommand) ProtoMessage ¶
func (*AgentCommand) ProtoMessage()
func (*AgentCommand) ProtoReflect ¶
func (x *AgentCommand) ProtoReflect() protoreflect.Message
func (*AgentCommand) Reset ¶
func (x *AgentCommand) Reset()
func (*AgentCommand) String ¶
func (x *AgentCommand) String() string
type AgentCommand_Close ¶
type AgentCommand_Close struct {
Close *CloseConnectionRequest `protobuf:"bytes,7,opt,name=close,proto3,oneof"`
}
type AgentCommand_ContainerCommand ¶
type AgentCommand_ContainerCommand struct {
ContainerCommand *common.ContainerCommandRequest `protobuf:"bytes,8,opt,name=containerCommand,proto3,oneof"`
}
type AgentCommand_ContainerDelete ¶
type AgentCommand_ContainerDelete struct {
ContainerDelete *ContainerDeleteRequest `protobuf:"bytes,3,opt,name=containerDelete,proto3,oneof"`
}
type AgentCommand_ContainerLog ¶
type AgentCommand_ContainerLog struct {
ContainerLog *ContainerLogRequest `protobuf:"bytes,10,opt,name=containerLog,proto3,oneof"`
}
type AgentCommand_ContainerState ¶
type AgentCommand_ContainerState struct {
ContainerState *ContainerStateRequest `protobuf:"bytes,2,opt,name=containerState,proto3,oneof"`
}
type AgentCommand_DeleteContainers ¶
type AgentCommand_DeleteContainers struct {
DeleteContainers *common.DeleteContainersRequest `protobuf:"bytes,9,opt,name=deleteContainers,proto3,oneof"`
}
type AgentCommand_Deploy ¶
type AgentCommand_Deploy struct {
Deploy *VersionDeployRequest `protobuf:"bytes,1,opt,name=deploy,proto3,oneof"`
}
type AgentCommand_DeployLegacy ¶
type AgentCommand_DeployLegacy struct {
DeployLegacy *DeployRequestLegacy `protobuf:"bytes,4,opt,name=deployLegacy,proto3,oneof"`
}
type AgentCommand_ListSecrets ¶
type AgentCommand_ListSecrets struct {
ListSecrets *ListSecretsRequest `protobuf:"bytes,5,opt,name=listSecrets,proto3,oneof"`
}
type AgentCommand_Update ¶
type AgentCommand_Update struct {
Update *AgentUpdateRequest `protobuf:"bytes,6,opt,name=update,proto3,oneof"`
}
type AgentInfo ¶
type AgentInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` PublicKey string `protobuf:"bytes,3,opt,name=publicKey,proto3" json:"publicKey,omitempty"` // contains filtered or unexported fields }
*
func (*AgentInfo) Descriptor
deprecated
func (*AgentInfo) GetPublicKey ¶
func (*AgentInfo) GetVersion ¶
func (*AgentInfo) ProtoMessage ¶
func (*AgentInfo) ProtoMessage()
func (*AgentInfo) ProtoReflect ¶
func (x *AgentInfo) ProtoReflect() protoreflect.Message
type AgentServer ¶
type AgentServer interface { // * // Subscribe with pre-assigned AgentID, waiting for incoming // deploy requests and prefix status requests. // In both cases, separate, shorter-living channels are opened. // For deployment status reports, closed when ended. // For prefix state reports, should be closed by the server. Connect(*AgentInfo, Agent_ConnectServer) error DeploymentStatus(Agent_DeploymentStatusServer) error ContainerState(Agent_ContainerStateServer) error SecretList(context.Context, *common.ListSecretsResponse) (*common.Empty, error) AbortUpdate(context.Context, *AgentAbortUpdate) (*common.Empty, error) DeleteContainers(context.Context, *common.DeleteContainersRequest) (*common.Empty, error) ContainerLog(Agent_ContainerLogServer) error // contains filtered or unexported methods }
AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility
type AgentUpdateRequest ¶
type AgentUpdateRequest struct { Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` TimeoutSeconds int32 `protobuf:"varint,2,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"` // contains filtered or unexported fields }
Dagent update
func (*AgentUpdateRequest) Descriptor
deprecated
func (*AgentUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use AgentUpdateRequest.ProtoReflect.Descriptor instead.
func (*AgentUpdateRequest) GetTag ¶
func (x *AgentUpdateRequest) GetTag() string
func (*AgentUpdateRequest) GetTimeoutSeconds ¶
func (x *AgentUpdateRequest) GetTimeoutSeconds() int32
func (*AgentUpdateRequest) ProtoMessage ¶
func (*AgentUpdateRequest) ProtoMessage()
func (*AgentUpdateRequest) ProtoReflect ¶
func (x *AgentUpdateRequest) ProtoReflect() protoreflect.Message
func (*AgentUpdateRequest) Reset ¶
func (x *AgentUpdateRequest) Reset()
func (*AgentUpdateRequest) String ¶
func (x *AgentUpdateRequest) String() string
type Agent_ConnectClient ¶
type Agent_ConnectClient interface { Recv() (*AgentCommand, error) grpc.ClientStream }
type Agent_ConnectServer ¶
type Agent_ConnectServer interface { Send(*AgentCommand) error grpc.ServerStream }
type Agent_ContainerLogClient ¶
type Agent_ContainerLogClient interface { Send(*common.ContainerLogMessage) error CloseAndRecv() (*common.Empty, error) grpc.ClientStream }
type Agent_ContainerLogServer ¶
type Agent_ContainerLogServer interface { SendAndClose(*common.Empty) error Recv() (*common.ContainerLogMessage, error) grpc.ServerStream }
type Agent_ContainerStateClient ¶
type Agent_ContainerStateClient interface { Send(*common.ContainerStateListMessage) error CloseAndRecv() (*common.Empty, error) grpc.ClientStream }
type Agent_ContainerStateServer ¶
type Agent_ContainerStateServer interface { SendAndClose(*common.Empty) error Recv() (*common.ContainerStateListMessage, error) grpc.ServerStream }
type Agent_DeploymentStatusClient ¶
type Agent_DeploymentStatusClient interface { Send(*common.DeploymentStatusMessage) error CloseAndRecv() (*common.Empty, error) grpc.ClientStream }
type Agent_DeploymentStatusServer ¶
type Agent_DeploymentStatusServer interface { SendAndClose(*common.Empty) error Recv() (*common.DeploymentStatusMessage, error) grpc.ServerStream }
type CloseConnectionRequest ¶
type CloseConnectionRequest struct { Reason CloseReason `protobuf:"varint,1,opt,name=reason,proto3,enum=agent.CloseReason" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*CloseConnectionRequest) Descriptor
deprecated
func (*CloseConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseConnectionRequest.ProtoReflect.Descriptor instead.
func (*CloseConnectionRequest) GetReason ¶
func (x *CloseConnectionRequest) GetReason() CloseReason
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 CloseReason ¶
type CloseReason int32
Connection close
const ( CloseReason_CLOSE_REASON_UNSPECIFIED CloseReason = 0 CloseReason_CLOSE CloseReason = 1 CloseReason_SELF_DESTRUCT CloseReason = 2 CloseReason_SHUTDOWN CloseReason = 3 )
func (CloseReason) Descriptor ¶
func (CloseReason) Descriptor() protoreflect.EnumDescriptor
func (CloseReason) Enum ¶
func (x CloseReason) Enum() *CloseReason
func (CloseReason) EnumDescriptor
deprecated
func (CloseReason) EnumDescriptor() ([]byte, []int)
Deprecated: Use CloseReason.Descriptor instead.
func (CloseReason) Number ¶
func (x CloseReason) Number() protoreflect.EnumNumber
func (CloseReason) String ¶
func (x CloseReason) String() string
func (CloseReason) Type ¶
func (CloseReason) Type() protoreflect.EnumType
type CommonContainerConfig ¶
type CommonContainerConfig struct { Name string `protobuf:"bytes,101,opt,name=name,proto3" json:"name,omitempty"` Expose *common.ExposeStrategy `protobuf:"varint,102,opt,name=expose,proto3,enum=common.ExposeStrategy,oneof" json:"expose,omitempty"` Ingress *common.Ingress `protobuf:"bytes,103,opt,name=ingress,proto3,oneof" json:"ingress,omitempty"` ConfigContainer *common.ConfigContainer `protobuf:"bytes,104,opt,name=configContainer,proto3,oneof" json:"configContainer,omitempty"` ImportContainer *ImportContainer `protobuf:"bytes,105,opt,name=importContainer,proto3,oneof" json:"importContainer,omitempty"` User *int64 `protobuf:"varint,106,opt,name=user,proto3,oneof" json:"user,omitempty"` TTY *bool `protobuf:"varint,107,opt,name=TTY,proto3,oneof" json:"TTY,omitempty"` Ports []*Port `protobuf:"bytes,1000,rep,name=ports,proto3" json:"ports,omitempty"` PortRanges []*PortRangeBinding `protobuf:"bytes,1001,rep,name=portRanges,proto3" json:"portRanges,omitempty"` Volumes []*Volume `protobuf:"bytes,1002,rep,name=volumes,proto3" json:"volumes,omitempty"` Commands []string `protobuf:"bytes,1003,rep,name=commands,proto3" json:"commands,omitempty"` Args []string `protobuf:"bytes,1004,rep,name=args,proto3" json:"args,omitempty"` Environment []string `protobuf:"bytes,1005,rep,name=environment,proto3" json:"environment,omitempty"` Secrets map[string]string `` /* 158-byte string literal not displayed */ InitContainers []*InitContainer `protobuf:"bytes,1007,rep,name=initContainers,proto3" json:"initContainers,omitempty"` // contains filtered or unexported fields }
func (*CommonContainerConfig) Descriptor
deprecated
func (*CommonContainerConfig) Descriptor() ([]byte, []int)
Deprecated: Use CommonContainerConfig.ProtoReflect.Descriptor instead.
func (*CommonContainerConfig) GetArgs ¶
func (x *CommonContainerConfig) GetArgs() []string
func (*CommonContainerConfig) GetCommands ¶
func (x *CommonContainerConfig) GetCommands() []string
func (*CommonContainerConfig) GetConfigContainer ¶
func (x *CommonContainerConfig) GetConfigContainer() *common.ConfigContainer
func (*CommonContainerConfig) GetEnvironment ¶
func (x *CommonContainerConfig) GetEnvironment() []string
func (*CommonContainerConfig) GetExpose ¶
func (x *CommonContainerConfig) GetExpose() common.ExposeStrategy
func (*CommonContainerConfig) GetImportContainer ¶
func (x *CommonContainerConfig) GetImportContainer() *ImportContainer
func (*CommonContainerConfig) GetIngress ¶
func (x *CommonContainerConfig) GetIngress() *common.Ingress
func (*CommonContainerConfig) GetInitContainers ¶
func (x *CommonContainerConfig) GetInitContainers() []*InitContainer
func (*CommonContainerConfig) GetName ¶
func (x *CommonContainerConfig) GetName() string
func (*CommonContainerConfig) GetPortRanges ¶
func (x *CommonContainerConfig) GetPortRanges() []*PortRangeBinding
func (*CommonContainerConfig) GetPorts ¶
func (x *CommonContainerConfig) GetPorts() []*Port
func (*CommonContainerConfig) GetSecrets ¶
func (x *CommonContainerConfig) GetSecrets() map[string]string
func (*CommonContainerConfig) GetTTY ¶
func (x *CommonContainerConfig) GetTTY() bool
func (*CommonContainerConfig) GetUser ¶
func (x *CommonContainerConfig) GetUser() int64
func (*CommonContainerConfig) GetVolumes ¶
func (x *CommonContainerConfig) GetVolumes() []*Volume
func (*CommonContainerConfig) ProtoMessage ¶
func (*CommonContainerConfig) ProtoMessage()
func (*CommonContainerConfig) ProtoReflect ¶
func (x *CommonContainerConfig) ProtoReflect() protoreflect.Message
func (*CommonContainerConfig) Reset ¶
func (x *CommonContainerConfig) Reset()
func (*CommonContainerConfig) String ¶
func (x *CommonContainerConfig) String() string
type ContainerDeleteRequest ¶
type ContainerDeleteRequest struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ContainerDeleteRequest) Descriptor
deprecated
func (*ContainerDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ContainerDeleteRequest.ProtoReflect.Descriptor instead.
func (*ContainerDeleteRequest) GetName ¶
func (x *ContainerDeleteRequest) GetName() string
func (*ContainerDeleteRequest) GetPrefix ¶
func (x *ContainerDeleteRequest) GetPrefix() string
func (*ContainerDeleteRequest) ProtoMessage ¶
func (*ContainerDeleteRequest) ProtoMessage()
func (*ContainerDeleteRequest) ProtoReflect ¶
func (x *ContainerDeleteRequest) ProtoReflect() protoreflect.Message
func (*ContainerDeleteRequest) Reset ¶
func (x *ContainerDeleteRequest) Reset()
func (*ContainerDeleteRequest) String ¶
func (x *ContainerDeleteRequest) String() string
type ContainerLogRequest ¶
type ContainerLogRequest struct { Container *common.ContainerIdentifier `protobuf:"bytes,1,opt,name=container,proto3" json:"container,omitempty"` Streaming bool `protobuf:"varint,2,opt,name=streaming,proto3" json:"streaming,omitempty"` Tail uint32 `protobuf:"varint,3,opt,name=tail,proto3" json:"tail,omitempty"` // contains filtered or unexported fields }
Container log
func (*ContainerLogRequest) Descriptor
deprecated
func (*ContainerLogRequest) Descriptor() ([]byte, []int)
Deprecated: Use ContainerLogRequest.ProtoReflect.Descriptor instead.
func (*ContainerLogRequest) GetContainer ¶
func (x *ContainerLogRequest) GetContainer() *common.ContainerIdentifier
func (*ContainerLogRequest) GetStreaming ¶
func (x *ContainerLogRequest) GetStreaming() bool
func (*ContainerLogRequest) GetTail ¶
func (x *ContainerLogRequest) GetTail() uint32
func (*ContainerLogRequest) ProtoMessage ¶
func (*ContainerLogRequest) ProtoMessage()
func (*ContainerLogRequest) ProtoReflect ¶
func (x *ContainerLogRequest) ProtoReflect() protoreflect.Message
func (*ContainerLogRequest) Reset ¶
func (x *ContainerLogRequest) Reset()
func (*ContainerLogRequest) String ¶
func (x *ContainerLogRequest) String() string
type ContainerStateRequest ¶
type ContainerStateRequest struct { Prefix *string `protobuf:"bytes,1,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"` OneShot *bool `protobuf:"varint,2,opt,name=oneShot,proto3,oneof" json:"oneShot,omitempty"` // contains filtered or unexported fields }
func (*ContainerStateRequest) Descriptor
deprecated
func (*ContainerStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ContainerStateRequest.ProtoReflect.Descriptor instead.
func (*ContainerStateRequest) GetOneShot ¶
func (x *ContainerStateRequest) GetOneShot() bool
func (*ContainerStateRequest) GetPrefix ¶
func (x *ContainerStateRequest) GetPrefix() string
func (*ContainerStateRequest) ProtoMessage ¶
func (*ContainerStateRequest) ProtoMessage()
func (*ContainerStateRequest) ProtoReflect ¶
func (x *ContainerStateRequest) ProtoReflect() protoreflect.Message
func (*ContainerStateRequest) Reset ¶
func (x *ContainerStateRequest) Reset()
func (*ContainerStateRequest) String ¶
func (x *ContainerStateRequest) String() string
type CraneContainerConfig ¶
type CraneContainerConfig struct { DeploymentStatregy *common.DeploymentStrategy `` /* 129-byte string literal not displayed */ HealthCheckConfig *common.HealthCheckConfig `protobuf:"bytes,101,opt,name=healthCheckConfig,proto3,oneof" json:"healthCheckConfig,omitempty"` ResourceConfig *common.ResourceConfig `protobuf:"bytes,102,opt,name=resourceConfig,proto3,oneof" json:"resourceConfig,omitempty"` ProxyHeaders *bool `protobuf:"varint,103,opt,name=proxyHeaders,proto3,oneof" json:"proxyHeaders,omitempty"` UseLoadBalancer *bool `protobuf:"varint,104,opt,name=useLoadBalancer,proto3,oneof" json:"useLoadBalancer,omitempty"` Annotations *Marker `protobuf:"bytes,105,opt,name=annotations,proto3,oneof" json:"annotations,omitempty"` Labels *Marker `protobuf:"bytes,106,opt,name=labels,proto3,oneof" json:"labels,omitempty"` Metrics *Metrics `protobuf:"bytes,107,opt,name=metrics,proto3,oneof" json:"metrics,omitempty"` CustomHeaders []string `protobuf:"bytes,1000,rep,name=customHeaders,proto3" json:"customHeaders,omitempty"` ExtraLBAnnotations map[string]string `` /* 180-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CraneContainerConfig) Descriptor
deprecated
func (*CraneContainerConfig) Descriptor() ([]byte, []int)
Deprecated: Use CraneContainerConfig.ProtoReflect.Descriptor instead.
func (*CraneContainerConfig) GetAnnotations ¶
func (x *CraneContainerConfig) GetAnnotations() *Marker
func (*CraneContainerConfig) GetCustomHeaders ¶
func (x *CraneContainerConfig) GetCustomHeaders() []string
func (*CraneContainerConfig) GetDeploymentStatregy ¶
func (x *CraneContainerConfig) GetDeploymentStatregy() common.DeploymentStrategy
func (*CraneContainerConfig) GetExtraLBAnnotations ¶
func (x *CraneContainerConfig) GetExtraLBAnnotations() map[string]string
func (*CraneContainerConfig) GetHealthCheckConfig ¶
func (x *CraneContainerConfig) GetHealthCheckConfig() *common.HealthCheckConfig
func (*CraneContainerConfig) GetLabels ¶
func (x *CraneContainerConfig) GetLabels() *Marker
func (*CraneContainerConfig) GetMetrics ¶
func (x *CraneContainerConfig) GetMetrics() *Metrics
func (*CraneContainerConfig) GetProxyHeaders ¶
func (x *CraneContainerConfig) GetProxyHeaders() bool
func (*CraneContainerConfig) GetResourceConfig ¶
func (x *CraneContainerConfig) GetResourceConfig() *common.ResourceConfig
func (*CraneContainerConfig) GetUseLoadBalancer ¶
func (x *CraneContainerConfig) GetUseLoadBalancer() bool
func (*CraneContainerConfig) ProtoMessage ¶
func (*CraneContainerConfig) ProtoMessage()
func (*CraneContainerConfig) ProtoReflect ¶
func (x *CraneContainerConfig) ProtoReflect() protoreflect.Message
func (*CraneContainerConfig) Reset ¶
func (x *CraneContainerConfig) Reset()
func (*CraneContainerConfig) String ¶
func (x *CraneContainerConfig) String() string
type DagentContainerConfig ¶
type DagentContainerConfig struct { LogConfig *LogConfig `protobuf:"bytes,100,opt,name=logConfig,proto3,oneof" json:"logConfig,omitempty"` RestartPolicy *common.RestartPolicy `protobuf:"varint,101,opt,name=restartPolicy,proto3,enum=common.RestartPolicy,oneof" json:"restartPolicy,omitempty"` NetworkMode *common.NetworkMode `protobuf:"varint,102,opt,name=networkMode,proto3,enum=common.NetworkMode,oneof" json:"networkMode,omitempty"` Networks []string `protobuf:"bytes,1000,rep,name=networks,proto3" json:"networks,omitempty"` Labels map[string]string `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DagentContainerConfig) Descriptor
deprecated
func (*DagentContainerConfig) Descriptor() ([]byte, []int)
Deprecated: Use DagentContainerConfig.ProtoReflect.Descriptor instead.
func (*DagentContainerConfig) GetLabels ¶
func (x *DagentContainerConfig) GetLabels() map[string]string
func (*DagentContainerConfig) GetLogConfig ¶
func (x *DagentContainerConfig) GetLogConfig() *LogConfig
func (*DagentContainerConfig) GetNetworkMode ¶
func (x *DagentContainerConfig) GetNetworkMode() common.NetworkMode
func (*DagentContainerConfig) GetNetworks ¶
func (x *DagentContainerConfig) GetNetworks() []string
func (*DagentContainerConfig) GetRestartPolicy ¶
func (x *DagentContainerConfig) GetRestartPolicy() common.RestartPolicy
func (*DagentContainerConfig) ProtoMessage ¶
func (*DagentContainerConfig) ProtoMessage()
func (*DagentContainerConfig) ProtoReflect ¶
func (x *DagentContainerConfig) ProtoReflect() protoreflect.Message
func (*DagentContainerConfig) Reset ¶
func (x *DagentContainerConfig) Reset()
func (*DagentContainerConfig) String ¶
func (x *DagentContainerConfig) String() string
type DeployRequest ¶
type DeployRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ContainerName string `protobuf:"bytes,2,opt,name=containerName,proto3" json:"containerName,omitempty"` // InstanceConfig is set for multiple containers InstanceConfig *InstanceConfig `protobuf:"bytes,3,opt,name=instanceConfig,proto3" json:"instanceConfig,omitempty"` // ContainerConfigs Common *CommonContainerConfig `protobuf:"bytes,4,opt,name=common,proto3,oneof" json:"common,omitempty"` Dagent *DagentContainerConfig `protobuf:"bytes,5,opt,name=dagent,proto3,oneof" json:"dagent,omitempty"` Crane *CraneContainerConfig `protobuf:"bytes,6,opt,name=crane,proto3,oneof" json:"crane,omitempty"` // Runtime info and requirements of a container RuntimeConfig *string `protobuf:"bytes,7,opt,name=runtimeConfig,proto3,oneof" json:"runtimeConfig,omitempty"` Registry *string `protobuf:"bytes,8,opt,name=registry,proto3,oneof" json:"registry,omitempty"` ImageName string `protobuf:"bytes,9,opt,name=imageName,proto3" json:"imageName,omitempty"` Tag string `protobuf:"bytes,10,opt,name=tag,proto3" json:"tag,omitempty"` RegistryAuth *RegistryAuth `protobuf:"bytes,11,opt,name=registryAuth,proto3,oneof" json:"registryAuth,omitempty"` // contains filtered or unexported fields }
func (*DeployRequest) Descriptor
deprecated
func (*DeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.
func (*DeployRequest) GetCommon ¶
func (x *DeployRequest) GetCommon() *CommonContainerConfig
func (*DeployRequest) GetContainerName ¶
func (x *DeployRequest) GetContainerName() string
func (*DeployRequest) GetCrane ¶
func (x *DeployRequest) GetCrane() *CraneContainerConfig
func (*DeployRequest) GetDagent ¶
func (x *DeployRequest) GetDagent() *DagentContainerConfig
func (*DeployRequest) GetId ¶
func (x *DeployRequest) GetId() string
func (*DeployRequest) GetImageName ¶
func (x *DeployRequest) GetImageName() string
func (*DeployRequest) GetInstanceConfig ¶
func (x *DeployRequest) GetInstanceConfig() *InstanceConfig
func (*DeployRequest) GetRegistry ¶
func (x *DeployRequest) GetRegistry() string
func (*DeployRequest) GetRegistryAuth ¶
func (x *DeployRequest) GetRegistryAuth() *RegistryAuth
func (*DeployRequest) GetRuntimeConfig ¶
func (x *DeployRequest) GetRuntimeConfig() string
func (*DeployRequest) GetTag ¶
func (x *DeployRequest) GetTag() string
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) ProtoReflect ¶
func (x *DeployRequest) ProtoReflect() protoreflect.Message
func (*DeployRequest) Reset ¶
func (x *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (x *DeployRequest) String() string
type DeployRequestLegacy ¶
type DeployRequestLegacy struct { RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"` // for early dogger logging Json string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"` // contains filtered or unexported fields }
func (*DeployRequestLegacy) Descriptor
deprecated
func (*DeployRequestLegacy) Descriptor() ([]byte, []int)
Deprecated: Use DeployRequestLegacy.ProtoReflect.Descriptor instead.
func (*DeployRequestLegacy) GetJson ¶
func (x *DeployRequestLegacy) GetJson() string
func (*DeployRequestLegacy) GetRequestId ¶
func (x *DeployRequestLegacy) GetRequestId() string
func (*DeployRequestLegacy) ProtoMessage ¶
func (*DeployRequestLegacy) ProtoMessage()
func (*DeployRequestLegacy) ProtoReflect ¶
func (x *DeployRequestLegacy) ProtoReflect() protoreflect.Message
func (*DeployRequestLegacy) Reset ¶
func (x *DeployRequestLegacy) Reset()
func (*DeployRequestLegacy) String ¶
func (x *DeployRequestLegacy) String() string
type DeployResponse ¶
type DeployResponse struct { Started bool `protobuf:"varint,1,opt,name=started,proto3" json:"started,omitempty"` // contains filtered or unexported fields }
This is more of a placeholder, we could include more, or return this instantly after validation success.
func (*DeployResponse) Descriptor
deprecated
func (*DeployResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.
func (*DeployResponse) GetStarted ¶
func (x *DeployResponse) GetStarted() bool
func (*DeployResponse) ProtoMessage ¶
func (*DeployResponse) ProtoMessage()
func (*DeployResponse) ProtoReflect ¶
func (x *DeployResponse) ProtoReflect() protoreflect.Message
func (*DeployResponse) Reset ¶
func (x *DeployResponse) Reset()
func (*DeployResponse) String ¶
func (x *DeployResponse) String() string
type Environment ¶
type Environment struct { Env []string `protobuf:"bytes,1,rep,name=env,proto3" json:"env,omitempty"` // contains filtered or unexported fields }
* Deploys a single container
func (*Environment) Descriptor
deprecated
func (*Environment) Descriptor() ([]byte, []int)
Deprecated: Use Environment.ProtoReflect.Descriptor instead.
func (*Environment) GetEnv ¶
func (x *Environment) GetEnv() []string
func (*Environment) ProtoMessage ¶
func (*Environment) ProtoMessage()
func (*Environment) ProtoReflect ¶
func (x *Environment) ProtoReflect() protoreflect.Message
func (*Environment) Reset ¶
func (x *Environment) Reset()
func (*Environment) String ¶
func (x *Environment) String() string
type ImportContainer ¶
type ImportContainer struct { Volume string `protobuf:"bytes,100,opt,name=volume,proto3" json:"volume,omitempty"` Command string `protobuf:"bytes,101,opt,name=command,proto3" json:"command,omitempty"` Environment map[string]string `` /* 166-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ImportContainer) Descriptor
deprecated
func (*ImportContainer) Descriptor() ([]byte, []int)
Deprecated: Use ImportContainer.ProtoReflect.Descriptor instead.
func (*ImportContainer) GetCommand ¶
func (x *ImportContainer) GetCommand() string
func (*ImportContainer) GetEnvironment ¶
func (x *ImportContainer) GetEnvironment() map[string]string
func (*ImportContainer) GetVolume ¶
func (x *ImportContainer) GetVolume() string
func (*ImportContainer) ProtoMessage ¶
func (*ImportContainer) ProtoMessage()
func (*ImportContainer) ProtoReflect ¶
func (x *ImportContainer) ProtoReflect() protoreflect.Message
func (*ImportContainer) Reset ¶
func (x *ImportContainer) Reset()
func (*ImportContainer) String ¶
func (x *ImportContainer) String() string
type InitContainer ¶
type InitContainer struct { Name string `protobuf:"bytes,100,opt,name=name,proto3" json:"name,omitempty"` Image string `protobuf:"bytes,101,opt,name=image,proto3" json:"image,omitempty"` UseParentConfig *bool `protobuf:"varint,102,opt,name=useParentConfig,proto3,oneof" json:"useParentConfig,omitempty"` Volumes []*VolumeLink `protobuf:"bytes,1000,rep,name=volumes,proto3" json:"volumes,omitempty"` Command []string `protobuf:"bytes,1001,rep,name=command,proto3" json:"command,omitempty"` Args []string `protobuf:"bytes,1002,rep,name=args,proto3" json:"args,omitempty"` Environment map[string]string `` /* 166-byte string literal not displayed */ // contains filtered or unexported fields }
func (*InitContainer) Descriptor
deprecated
func (*InitContainer) Descriptor() ([]byte, []int)
Deprecated: Use InitContainer.ProtoReflect.Descriptor instead.
func (*InitContainer) GetArgs ¶
func (x *InitContainer) GetArgs() []string
func (*InitContainer) GetCommand ¶
func (x *InitContainer) GetCommand() []string
func (*InitContainer) GetEnvironment ¶
func (x *InitContainer) GetEnvironment() map[string]string
func (*InitContainer) GetImage ¶
func (x *InitContainer) GetImage() string
func (*InitContainer) GetName ¶
func (x *InitContainer) GetName() string
func (*InitContainer) GetUseParentConfig ¶
func (x *InitContainer) GetUseParentConfig() bool
func (*InitContainer) GetVolumes ¶
func (x *InitContainer) GetVolumes() []*VolumeLink
func (*InitContainer) ProtoMessage ¶
func (*InitContainer) ProtoMessage()
func (*InitContainer) ProtoReflect ¶
func (x *InitContainer) ProtoReflect() protoreflect.Message
func (*InitContainer) Reset ¶
func (x *InitContainer) Reset()
func (*InitContainer) String ¶
func (x *InitContainer) String() string
type InstanceConfig ¶
type InstanceConfig struct { // prefix mapped into host folder structure, // used as namespace id Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` MountPath *string `protobuf:"bytes,2,opt,name=mountPath,proto3,oneof" json:"mountPath,omitempty"` // mount path of instance (docker only) Environment *Environment `protobuf:"bytes,3,opt,name=environment,proto3,oneof" json:"environment,omitempty"` // environment variable map (piped) RepositoryPrefix *string `protobuf:"bytes,4,opt,name=repositoryPrefix,proto3,oneof" json:"repositoryPrefix,omitempty"` // registry repo prefix // contains filtered or unexported fields }
func (*InstanceConfig) Descriptor
deprecated
func (*InstanceConfig) Descriptor() ([]byte, []int)
Deprecated: Use InstanceConfig.ProtoReflect.Descriptor instead.
func (*InstanceConfig) GetEnvironment ¶
func (x *InstanceConfig) GetEnvironment() *Environment
func (*InstanceConfig) GetMountPath ¶
func (x *InstanceConfig) GetMountPath() string
func (*InstanceConfig) GetPrefix ¶
func (x *InstanceConfig) GetPrefix() string
func (*InstanceConfig) GetRepositoryPrefix ¶
func (x *InstanceConfig) GetRepositoryPrefix() string
func (*InstanceConfig) ProtoMessage ¶
func (*InstanceConfig) ProtoMessage()
func (*InstanceConfig) ProtoReflect ¶
func (x *InstanceConfig) ProtoReflect() protoreflect.Message
func (*InstanceConfig) Reset ¶
func (x *InstanceConfig) Reset()
func (*InstanceConfig) String ¶
func (x *InstanceConfig) String() string
type ListSecretsRequest ¶
type ListSecretsRequest struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request for a keys of existing secrets in a prefix, eg. namespace
func (*ListSecretsRequest) Descriptor
deprecated
func (*ListSecretsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSecretsRequest.ProtoReflect.Descriptor instead.
func (*ListSecretsRequest) GetName ¶
func (x *ListSecretsRequest) GetName() string
func (*ListSecretsRequest) GetPrefix ¶
func (x *ListSecretsRequest) GetPrefix() string
func (*ListSecretsRequest) ProtoMessage ¶
func (*ListSecretsRequest) ProtoMessage()
func (*ListSecretsRequest) ProtoReflect ¶
func (x *ListSecretsRequest) ProtoReflect() protoreflect.Message
func (*ListSecretsRequest) Reset ¶
func (x *ListSecretsRequest) Reset()
func (*ListSecretsRequest) String ¶
func (x *ListSecretsRequest) String() string
type LogConfig ¶
type LogConfig struct { Driver common.DriverType `protobuf:"varint,100,opt,name=driver,proto3,enum=common.DriverType" json:"driver,omitempty"` Options map[string]string `` /* 158-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LogConfig) Descriptor
deprecated
func (*LogConfig) GetDriver ¶
func (x *LogConfig) GetDriver() common.DriverType
func (*LogConfig) GetOptions ¶
func (*LogConfig) ProtoMessage ¶
func (*LogConfig) ProtoMessage()
func (*LogConfig) ProtoReflect ¶
func (x *LogConfig) ProtoReflect() protoreflect.Message
type Marker ¶
type Marker struct { Deployment map[string]string `` /* 164-byte string literal not displayed */ Service map[string]string `` /* 158-byte string literal not displayed */ Ingress map[string]string `` /* 158-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Marker) Descriptor
deprecated
func (*Marker) GetDeployment ¶
func (*Marker) GetIngress ¶
func (*Marker) GetService ¶
func (*Marker) ProtoMessage ¶
func (*Marker) ProtoMessage()
func (*Marker) ProtoReflect ¶
func (x *Marker) ProtoReflect() protoreflect.Message
type Metrics ¶
type Metrics struct { Port string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*Metrics) Descriptor
deprecated
func (*Metrics) ProtoMessage ¶
func (*Metrics) ProtoMessage()
func (*Metrics) ProtoReflect ¶
func (x *Metrics) ProtoReflect() protoreflect.Message
type Port ¶
type Port struct { Internal int32 `protobuf:"varint,100,opt,name=internal,proto3" json:"internal,omitempty"` External *int32 `protobuf:"varint,101,opt,name=external,proto3,oneof" json:"external,omitempty"` // contains filtered or unexported fields }
func (*Port) Descriptor
deprecated
func (*Port) GetExternal ¶
func (*Port) GetInternal ¶
func (*Port) ProtoMessage ¶
func (*Port) ProtoMessage()
func (*Port) ProtoReflect ¶
func (x *Port) ProtoReflect() protoreflect.Message
type PortRange ¶
type PortRange struct { From int32 `protobuf:"varint,100,opt,name=from,proto3" json:"from,omitempty"` To int32 `protobuf:"varint,101,opt,name=to,proto3" json:"to,omitempty"` // contains filtered or unexported fields }
func (*PortRange) Descriptor
deprecated
func (*PortRange) ProtoMessage ¶
func (*PortRange) ProtoMessage()
func (*PortRange) ProtoReflect ¶
func (x *PortRange) ProtoReflect() protoreflect.Message
type PortRangeBinding ¶
type PortRangeBinding struct { Internal *PortRange `protobuf:"bytes,100,opt,name=internal,proto3" json:"internal,omitempty"` External *PortRange `protobuf:"bytes,101,opt,name=external,proto3" json:"external,omitempty"` // contains filtered or unexported fields }
func (*PortRangeBinding) Descriptor
deprecated
func (*PortRangeBinding) Descriptor() ([]byte, []int)
Deprecated: Use PortRangeBinding.ProtoReflect.Descriptor instead.
func (*PortRangeBinding) GetExternal ¶
func (x *PortRangeBinding) GetExternal() *PortRange
func (*PortRangeBinding) GetInternal ¶
func (x *PortRangeBinding) GetInternal() *PortRange
func (*PortRangeBinding) ProtoMessage ¶
func (*PortRangeBinding) ProtoMessage()
func (*PortRangeBinding) ProtoReflect ¶
func (x *PortRangeBinding) ProtoReflect() protoreflect.Message
func (*PortRangeBinding) Reset ¶
func (x *PortRangeBinding) Reset()
func (*PortRangeBinding) String ¶
func (x *PortRangeBinding) String() string
type RegistryAuth ¶
type RegistryAuth struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*RegistryAuth) Descriptor
deprecated
func (*RegistryAuth) Descriptor() ([]byte, []int)
Deprecated: Use RegistryAuth.ProtoReflect.Descriptor instead.
func (*RegistryAuth) GetName ¶
func (x *RegistryAuth) GetName() string
func (*RegistryAuth) GetPassword ¶
func (x *RegistryAuth) GetPassword() string
func (*RegistryAuth) GetUrl ¶
func (x *RegistryAuth) GetUrl() string
func (*RegistryAuth) GetUser ¶
func (x *RegistryAuth) GetUser() string
func (*RegistryAuth) ProtoMessage ¶
func (*RegistryAuth) ProtoMessage()
func (*RegistryAuth) ProtoReflect ¶
func (x *RegistryAuth) ProtoReflect() protoreflect.Message
func (*RegistryAuth) Reset ¶
func (x *RegistryAuth) Reset()
func (*RegistryAuth) String ¶
func (x *RegistryAuth) String() string
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct { }
UnimplementedAgentServer must be embedded to have forward compatible implementations.
func (UnimplementedAgentServer) AbortUpdate ¶
func (UnimplementedAgentServer) AbortUpdate(context.Context, *AgentAbortUpdate) (*common.Empty, error)
func (UnimplementedAgentServer) Connect ¶
func (UnimplementedAgentServer) Connect(*AgentInfo, Agent_ConnectServer) error
func (UnimplementedAgentServer) ContainerLog ¶
func (UnimplementedAgentServer) ContainerLog(Agent_ContainerLogServer) error
func (UnimplementedAgentServer) ContainerState ¶
func (UnimplementedAgentServer) ContainerState(Agent_ContainerStateServer) error
func (UnimplementedAgentServer) DeleteContainers ¶
func (UnimplementedAgentServer) DeleteContainers(context.Context, *common.DeleteContainersRequest) (*common.Empty, error)
func (UnimplementedAgentServer) DeploymentStatus ¶
func (UnimplementedAgentServer) DeploymentStatus(Agent_DeploymentStatusServer) error
func (UnimplementedAgentServer) SecretList ¶
func (UnimplementedAgentServer) SecretList(context.Context, *common.ListSecretsResponse) (*common.Empty, error)
type UnsafeAgentServer ¶
type UnsafeAgentServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.
type VersionDeployRequest ¶
type VersionDeployRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` VersionName string `protobuf:"bytes,2,opt,name=versionName,proto3" json:"versionName,omitempty"` ReleaseNotes string `protobuf:"bytes,3,opt,name=releaseNotes,proto3" json:"releaseNotes,omitempty"` Requests []*DeployRequest `protobuf:"bytes,4,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*VersionDeployRequest) Descriptor
deprecated
func (*VersionDeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionDeployRequest.ProtoReflect.Descriptor instead.
func (*VersionDeployRequest) GetId ¶
func (x *VersionDeployRequest) GetId() string
func (*VersionDeployRequest) GetReleaseNotes ¶
func (x *VersionDeployRequest) GetReleaseNotes() string
func (*VersionDeployRequest) GetRequests ¶
func (x *VersionDeployRequest) GetRequests() []*DeployRequest
func (*VersionDeployRequest) GetVersionName ¶
func (x *VersionDeployRequest) GetVersionName() string
func (*VersionDeployRequest) ProtoMessage ¶
func (*VersionDeployRequest) ProtoMessage()
func (*VersionDeployRequest) ProtoReflect ¶
func (x *VersionDeployRequest) ProtoReflect() protoreflect.Message
func (*VersionDeployRequest) Reset ¶
func (x *VersionDeployRequest) Reset()
func (*VersionDeployRequest) String ¶
func (x *VersionDeployRequest) String() string
type Volume ¶
type Volume struct { Name string `protobuf:"bytes,100,opt,name=name,proto3" json:"name,omitempty"` Path string `protobuf:"bytes,101,opt,name=path,proto3" json:"path,omitempty"` Size *string `protobuf:"bytes,102,opt,name=size,proto3,oneof" json:"size,omitempty"` Type *common.VolumeType `protobuf:"varint,103,opt,name=type,proto3,enum=common.VolumeType,oneof" json:"type,omitempty"` Class *string `protobuf:"bytes,104,opt,name=class,proto3,oneof" json:"class,omitempty"` // contains filtered or unexported fields }
func (*Volume) Descriptor
deprecated
func (*Volume) GetType ¶
func (x *Volume) GetType() common.VolumeType
func (*Volume) ProtoMessage ¶
func (*Volume) ProtoMessage()
func (*Volume) ProtoReflect ¶
func (x *Volume) ProtoReflect() protoreflect.Message
type VolumeLink ¶
type VolumeLink struct { Name string `protobuf:"bytes,100,opt,name=name,proto3" json:"name,omitempty"` Path string `protobuf:"bytes,101,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*VolumeLink) Descriptor
deprecated
func (*VolumeLink) Descriptor() ([]byte, []int)
Deprecated: Use VolumeLink.ProtoReflect.Descriptor instead.
func (*VolumeLink) GetName ¶
func (x *VolumeLink) GetName() string
func (*VolumeLink) GetPath ¶
func (x *VolumeLink) GetPath() string
func (*VolumeLink) ProtoMessage ¶
func (*VolumeLink) ProtoMessage()
func (*VolumeLink) ProtoReflect ¶
func (x *VolumeLink) ProtoReflect() protoreflect.Message
func (*VolumeLink) Reset ¶
func (x *VolumeLink) Reset()
func (*VolumeLink) String ¶
func (x *VolumeLink) String() string