Documentation ¶
Index ¶
- Variables
- func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)
- type AddRepoReply
- func (*AddRepoReply) Descriptor() ([]byte, []int)deprecated
- func (x *AddRepoReply) GetInfo() string
- func (x *AddRepoReply) GetNewDefaultRevision() string
- func (*AddRepoReply) ProtoMessage()
- func (x *AddRepoReply) ProtoReflect() protoreflect.Message
- func (x *AddRepoReply) Reset()
- func (x *AddRepoReply) String() string
- type AddRepoRequest
- func (*AddRepoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddRepoRequest) GetDefaultRevision() string
- func (x *AddRepoRequest) GetName() string
- func (*AddRepoRequest) ProtoMessage()
- func (x *AddRepoRequest) ProtoReflect() protoreflect.Message
- func (x *AddRepoRequest) Reset()
- func (x *AddRepoRequest) String() string
- type ChannelInfo
- func (*ChannelInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelInfo) GetName() string
- func (x *ChannelInfo) GetTarget() string
- func (x *ChannelInfo) GetType() string
- func (*ChannelInfo) ProtoMessage()
- func (x *ChannelInfo) ProtoReflect() protoreflect.Message
- func (x *ChannelInfo) Reset()
- func (x *ChannelInfo) String() string
- type CleanupTasksReply
- func (*CleanupTasksReply) Descriptor() ([]byte, []int)deprecated
- func (x *CleanupTasksReply) GetKilledTasks() []*ShortTaskInfo
- func (x *CleanupTasksReply) GetRunningTasks() []*ShortTaskInfo
- func (*CleanupTasksReply) ProtoMessage()
- func (x *CleanupTasksReply) ProtoReflect() protoreflect.Message
- func (x *CleanupTasksReply) Reset()
- func (x *CleanupTasksReply) String() string
- type CleanupTasksRequest
- func (*CleanupTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CleanupTasksRequest) GetTaskIds() []string
- func (*CleanupTasksRequest) ProtoMessage()
- func (x *CleanupTasksRequest) ProtoReflect() protoreflect.Message
- func (x *CleanupTasksRequest) Reset()
- func (x *CleanupTasksRequest) String() string
- type CommandInfo
- func (*CommandInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CommandInfo) GetArguments() []string
- func (x *CommandInfo) GetEnv() []string
- func (x *CommandInfo) GetShell() bool
- func (x *CommandInfo) GetUser() string
- func (x *CommandInfo) GetValue() string
- func (*CommandInfo) ProtoMessage()
- func (x *CommandInfo) ProtoReflect() protoreflect.Message
- func (x *CommandInfo) Reset()
- func (x *CommandInfo) String() string
- type ControlClient
- type ControlEnvironmentReply
- func (*ControlEnvironmentReply) Descriptor() ([]byte, []int)deprecated
- func (x *ControlEnvironmentReply) GetCurrentRunNumber() uint32
- func (x *ControlEnvironmentReply) GetEndOfTransition() int64
- func (x *ControlEnvironmentReply) GetId() string
- func (x *ControlEnvironmentReply) GetStartOfTransition() int64
- func (x *ControlEnvironmentReply) GetState() string
- func (x *ControlEnvironmentReply) GetTransitionDuration() int64
- func (*ControlEnvironmentReply) ProtoMessage()
- func (x *ControlEnvironmentReply) ProtoReflect() protoreflect.Message
- func (x *ControlEnvironmentReply) Reset()
- func (x *ControlEnvironmentReply) String() string
- type ControlEnvironmentRequest
- func (*ControlEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ControlEnvironmentRequest) GetId() string
- func (x *ControlEnvironmentRequest) GetType() ControlEnvironmentRequest_Optype
- func (*ControlEnvironmentRequest) ProtoMessage()
- func (x *ControlEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *ControlEnvironmentRequest) Reset()
- func (x *ControlEnvironmentRequest) String() string
- type ControlEnvironmentRequest_Optype
- func (ControlEnvironmentRequest_Optype) Descriptor() protoreflect.EnumDescriptor
- func (x ControlEnvironmentRequest_Optype) Enum() *ControlEnvironmentRequest_Optype
- func (ControlEnvironmentRequest_Optype) EnumDescriptor() ([]byte, []int)deprecated
- func (x ControlEnvironmentRequest_Optype) Number() protoreflect.EnumNumber
- func (x ControlEnvironmentRequest_Optype) String() string
- func (ControlEnvironmentRequest_Optype) Type() protoreflect.EnumType
- type ControlServer
- type Control_SubscribeClient
- type Control_SubscribeServer
- type Control_TrackStatusClient
- type Control_TrackStatusServer
- type DestroyEnvironmentReply
- func (*DestroyEnvironmentReply) Descriptor() ([]byte, []int)deprecated
- func (x *DestroyEnvironmentReply) GetCleanupTasksReply() *CleanupTasksReply
- func (*DestroyEnvironmentReply) ProtoMessage()
- func (x *DestroyEnvironmentReply) ProtoReflect() protoreflect.Message
- func (x *DestroyEnvironmentReply) Reset()
- func (x *DestroyEnvironmentReply) String() string
- type DestroyEnvironmentRequest
- func (*DestroyEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DestroyEnvironmentRequest) GetAllowInRunningState() bool
- func (x *DestroyEnvironmentRequest) GetForce() bool
- func (x *DestroyEnvironmentRequest) GetId() string
- func (x *DestroyEnvironmentRequest) GetKeepTasks() bool
- func (*DestroyEnvironmentRequest) ProtoMessage()
- func (x *DestroyEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *DestroyEnvironmentRequest) Reset()
- func (x *DestroyEnvironmentRequest) String() string
- type Empty
- type EnvironmentInfo
- func (*EnvironmentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *EnvironmentInfo) GetCreatedWhen() int64
- func (x *EnvironmentInfo) GetCurrentRunNumber() uint32
- func (x *EnvironmentInfo) GetDefaults() map[string]string
- func (x *EnvironmentInfo) GetDescription() string
- func (x *EnvironmentInfo) GetId() string
- func (x *EnvironmentInfo) GetIncludedDetectors() []string
- func (x *EnvironmentInfo) GetNumberOfFlps() int32
- func (x *EnvironmentInfo) GetNumberOfHosts() int32
- func (x *EnvironmentInfo) GetRootRole() string
- func (x *EnvironmentInfo) GetState() string
- func (x *EnvironmentInfo) GetTasks() []*ShortTaskInfo
- func (x *EnvironmentInfo) GetUserVars() map[string]string
- func (x *EnvironmentInfo) GetVars() map[string]string
- func (*EnvironmentInfo) ProtoMessage()
- func (x *EnvironmentInfo) ProtoReflect() protoreflect.Message
- func (x *EnvironmentInfo) Reset()
- func (x *EnvironmentInfo) String() string
- type EnvironmentOperation
- func (*EnvironmentOperation) Descriptor() ([]byte, []int)deprecated
- func (x *EnvironmentOperation) GetRoleName() string
- func (x *EnvironmentOperation) GetType() EnvironmentOperation_Optype
- func (*EnvironmentOperation) ProtoMessage()
- func (x *EnvironmentOperation) ProtoReflect() protoreflect.Message
- func (x *EnvironmentOperation) Reset()
- func (x *EnvironmentOperation) String() string
- type EnvironmentOperation_Optype
- func (EnvironmentOperation_Optype) Descriptor() protoreflect.EnumDescriptor
- func (x EnvironmentOperation_Optype) Enum() *EnvironmentOperation_Optype
- func (EnvironmentOperation_Optype) EnumDescriptor() ([]byte, []int)deprecated
- func (x EnvironmentOperation_Optype) Number() protoreflect.EnumNumber
- func (x EnvironmentOperation_Optype) String() string
- func (EnvironmentOperation_Optype) Type() protoreflect.EnumType
- type Ev_EnvironmentEvent
- func (*Ev_EnvironmentEvent) Descriptor() ([]byte, []int)deprecated
- func (x *Ev_EnvironmentEvent) GetCurrentRunNumber() uint32
- func (x *Ev_EnvironmentEvent) GetEnvironmentId() string
- func (x *Ev_EnvironmentEvent) GetError() string
- func (x *Ev_EnvironmentEvent) GetMessage() string
- func (x *Ev_EnvironmentEvent) GetState() string
- func (*Ev_EnvironmentEvent) ProtoMessage()
- func (x *Ev_EnvironmentEvent) ProtoReflect() protoreflect.Message
- func (x *Ev_EnvironmentEvent) Reset()
- func (x *Ev_EnvironmentEvent) String() string
- type Ev_RoleEvent
- func (*Ev_RoleEvent) Descriptor() ([]byte, []int)deprecated
- func (x *Ev_RoleEvent) GetName() string
- func (x *Ev_RoleEvent) GetRolePath() string
- func (x *Ev_RoleEvent) GetState() string
- func (x *Ev_RoleEvent) GetStatus() string
- func (*Ev_RoleEvent) ProtoMessage()
- func (x *Ev_RoleEvent) ProtoReflect() protoreflect.Message
- func (x *Ev_RoleEvent) Reset()
- func (x *Ev_RoleEvent) String() string
- type Ev_TaskEvent
- func (*Ev_TaskEvent) Descriptor() ([]byte, []int)deprecated
- func (x *Ev_TaskEvent) GetClassName() string
- func (x *Ev_TaskEvent) GetHostname() string
- func (x *Ev_TaskEvent) GetName() string
- func (x *Ev_TaskEvent) GetState() string
- func (x *Ev_TaskEvent) GetStatus() string
- func (x *Ev_TaskEvent) GetTaskid() string
- func (*Ev_TaskEvent) ProtoMessage()
- func (x *Ev_TaskEvent) ProtoReflect() protoreflect.Message
- func (x *Ev_TaskEvent) Reset()
- func (x *Ev_TaskEvent) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetEnvironmentEvent() *Ev_EnvironmentEvent
- func (m *Event) GetPayload() isEvent_Payload
- func (x *Event) GetRoleEvent() *Ev_RoleEvent
- func (x *Event) GetTaskEvent() *Ev_TaskEvent
- func (x *Event) GetTimestamp() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Event_EnvironmentEvent
- type Event_MesosHeartbeat
- type Event_RoleEvent
- type Event_TaskEvent
- type GetActiveDetectorsReply
- func (*GetActiveDetectorsReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveDetectorsReply) GetDetectors() []string
- func (*GetActiveDetectorsReply) ProtoMessage()
- func (x *GetActiveDetectorsReply) ProtoReflect() protoreflect.Message
- func (x *GetActiveDetectorsReply) Reset()
- func (x *GetActiveDetectorsReply) String() string
- type GetEnvironmentPropertiesReply
- func (*GetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentPropertiesReply) GetProperties() map[string]string
- func (*GetEnvironmentPropertiesReply) ProtoMessage()
- func (x *GetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentPropertiesReply) Reset()
- func (x *GetEnvironmentPropertiesReply) String() string
- type GetEnvironmentPropertiesRequest
- func (*GetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentPropertiesRequest) GetExcludeGlobals() bool
- func (x *GetEnvironmentPropertiesRequest) GetId() string
- func (x *GetEnvironmentPropertiesRequest) GetQueries() []string
- func (*GetEnvironmentPropertiesRequest) ProtoMessage()
- func (x *GetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentPropertiesRequest) Reset()
- func (x *GetEnvironmentPropertiesRequest) String() string
- type GetEnvironmentReply
- func (*GetEnvironmentReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentReply) GetEnvironment() *EnvironmentInfo
- func (x *GetEnvironmentReply) GetPublic() bool
- func (x *GetEnvironmentReply) GetWorkflow() *RoleInfo
- func (*GetEnvironmentReply) ProtoMessage()
- func (x *GetEnvironmentReply) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentReply) Reset()
- func (x *GetEnvironmentReply) String() string
- type GetEnvironmentRequest
- func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentRequest) GetId() string
- func (x *GetEnvironmentRequest) GetShowWorkflowTree() bool
- func (*GetEnvironmentRequest) ProtoMessage()
- func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentRequest) Reset()
- func (x *GetEnvironmentRequest) String() string
- type GetEnvironmentsReply
- func (*GetEnvironmentsReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentsReply) GetEnvironments() []*EnvironmentInfo
- func (x *GetEnvironmentsReply) GetFrameworkId() string
- func (*GetEnvironmentsReply) ProtoMessage()
- func (x *GetEnvironmentsReply) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentsReply) Reset()
- func (x *GetEnvironmentsReply) String() string
- type GetEnvironmentsRequest
- func (*GetEnvironmentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentsRequest) GetShowAll() bool
- func (x *GetEnvironmentsRequest) GetShowTaskInfos() bool
- func (*GetEnvironmentsRequest) ProtoMessage()
- func (x *GetEnvironmentsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentsRequest) Reset()
- func (x *GetEnvironmentsRequest) String() string
- type GetFrameworkInfoReply
- func (*GetFrameworkInfoReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetFrameworkInfoReply) GetActiveDetectors() []string
- func (x *GetFrameworkInfoReply) GetAvailableDetectors() []string
- func (x *GetFrameworkInfoReply) GetConfigurationEndpoint() string
- func (x *GetFrameworkInfoReply) GetDetectorsInInstance() []string
- func (x *GetFrameworkInfoReply) GetEnvironmentsCount() int32
- func (x *GetFrameworkInfoReply) GetFrameworkId() string
- func (x *GetFrameworkInfoReply) GetHostsCount() int32
- func (x *GetFrameworkInfoReply) GetInstanceName() string
- func (x *GetFrameworkInfoReply) GetState() string
- func (x *GetFrameworkInfoReply) GetTasksCount() int32
- func (x *GetFrameworkInfoReply) GetVersion() *Version
- func (*GetFrameworkInfoReply) ProtoMessage()
- func (x *GetFrameworkInfoReply) ProtoReflect() protoreflect.Message
- func (x *GetFrameworkInfoReply) Reset()
- func (x *GetFrameworkInfoReply) String() string
- type GetFrameworkInfoRequest
- type GetRolesReply
- type GetRolesRequest
- func (*GetRolesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRolesRequest) GetEnvId() string
- func (x *GetRolesRequest) GetPathSpec() string
- func (*GetRolesRequest) ProtoMessage()
- func (x *GetRolesRequest) ProtoReflect() protoreflect.Message
- func (x *GetRolesRequest) Reset()
- func (x *GetRolesRequest) String() string
- type GetTaskReply
- type GetTaskRequest
- type GetTasksReply
- type GetTasksRequest
- type GetWorkflowTemplatesReply
- func (*GetWorkflowTemplatesReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowTemplatesReply) GetWorkflowTemplates() []*WorkflowTemplateInfo
- func (*GetWorkflowTemplatesReply) ProtoMessage()
- func (x *GetWorkflowTemplatesReply) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowTemplatesReply) Reset()
- func (x *GetWorkflowTemplatesReply) String() string
- type GetWorkflowTemplatesRequest
- func (*GetWorkflowTemplatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWorkflowTemplatesRequest) GetAllBranches() bool
- func (x *GetWorkflowTemplatesRequest) GetAllTags() bool
- func (x *GetWorkflowTemplatesRequest) GetAllWorkflows() bool
- func (x *GetWorkflowTemplatesRequest) GetRepoPattern() string
- func (x *GetWorkflowTemplatesRequest) GetRevisionPattern() string
- func (*GetWorkflowTemplatesRequest) ProtoMessage()
- func (x *GetWorkflowTemplatesRequest) ProtoReflect() protoreflect.Message
- func (x *GetWorkflowTemplatesRequest) Reset()
- func (x *GetWorkflowTemplatesRequest) String() string
- type IntegratedServiceInfo
- func (*IntegratedServiceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *IntegratedServiceInfo) GetConnectionState() string
- func (x *IntegratedServiceInfo) GetData() string
- func (x *IntegratedServiceInfo) GetEnabled() bool
- func (x *IntegratedServiceInfo) GetEndpoint() string
- func (x *IntegratedServiceInfo) GetName() string
- func (*IntegratedServiceInfo) ProtoMessage()
- func (x *IntegratedServiceInfo) ProtoReflect() protoreflect.Message
- func (x *IntegratedServiceInfo) Reset()
- func (x *IntegratedServiceInfo) String() string
- type ListIntegratedServicesReply
- func (*ListIntegratedServicesReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListIntegratedServicesReply) GetServices() map[string]*IntegratedServiceInfo
- func (*ListIntegratedServicesReply) ProtoMessage()
- func (x *ListIntegratedServicesReply) ProtoReflect() protoreflect.Message
- func (x *ListIntegratedServicesReply) Reset()
- func (x *ListIntegratedServicesReply) String() string
- type ListReposReply
- func (*ListReposReply) Descriptor() ([]byte, []int)deprecated
- func (x *ListReposReply) GetGlobalDefaultRevision() string
- func (x *ListReposReply) GetRepos() []*RepoInfo
- func (*ListReposReply) ProtoMessage()
- func (x *ListReposReply) ProtoReflect() protoreflect.Message
- func (x *ListReposReply) Reset()
- func (x *ListReposReply) String() string
- type ListReposRequest
- type ModifyEnvironmentReply
- func (*ModifyEnvironmentReply) Descriptor() ([]byte, []int)deprecated
- func (x *ModifyEnvironmentReply) GetFailedOperations() []*EnvironmentOperation
- func (x *ModifyEnvironmentReply) GetId() string
- func (x *ModifyEnvironmentReply) GetState() string
- func (*ModifyEnvironmentReply) ProtoMessage()
- func (x *ModifyEnvironmentReply) ProtoReflect() protoreflect.Message
- func (x *ModifyEnvironmentReply) Reset()
- func (x *ModifyEnvironmentReply) String() string
- type ModifyEnvironmentRequest
- func (*ModifyEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ModifyEnvironmentRequest) GetId() string
- func (x *ModifyEnvironmentRequest) GetOperations() []*EnvironmentOperation
- func (x *ModifyEnvironmentRequest) GetReconfigureAll() bool
- func (*ModifyEnvironmentRequest) ProtoMessage()
- func (x *ModifyEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *ModifyEnvironmentRequest) Reset()
- func (x *ModifyEnvironmentRequest) String() string
- type NewAutoEnvironmentReply
- type NewAutoEnvironmentRequest
- func (*NewAutoEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewAutoEnvironmentRequest) GetId() string
- func (x *NewAutoEnvironmentRequest) GetVars() map[string]string
- func (x *NewAutoEnvironmentRequest) GetWorkflowTemplate() string
- func (*NewAutoEnvironmentRequest) ProtoMessage()
- func (x *NewAutoEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *NewAutoEnvironmentRequest) Reset()
- func (x *NewAutoEnvironmentRequest) String() string
- type NewEnvironmentReply
- func (*NewEnvironmentReply) Descriptor() ([]byte, []int)deprecated
- func (x *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo
- func (x *NewEnvironmentReply) GetPublic() bool
- func (*NewEnvironmentReply) ProtoMessage()
- func (x *NewEnvironmentReply) ProtoReflect() protoreflect.Message
- func (x *NewEnvironmentReply) Reset()
- func (x *NewEnvironmentReply) String() string
- type NewEnvironmentRequest
- func (*NewEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NewEnvironmentRequest) GetPublic() bool
- func (x *NewEnvironmentRequest) GetVars() map[string]string
- func (x *NewEnvironmentRequest) GetWorkflowTemplate() string
- func (*NewEnvironmentRequest) ProtoMessage()
- func (x *NewEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *NewEnvironmentRequest) Reset()
- func (x *NewEnvironmentRequest) String() string
- type RefreshReposRequest
- func (*RefreshReposRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshReposRequest) GetIndex() int32
- func (*RefreshReposRequest) ProtoMessage()
- func (x *RefreshReposRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshReposRequest) Reset()
- func (x *RefreshReposRequest) String() string
- type RemoveRepoReply
- type RemoveRepoRequest
- type RepoInfo
- func (*RepoInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RepoInfo) GetDefault() bool
- func (x *RepoInfo) GetDefaultRevision() string
- func (x *RepoInfo) GetName() string
- func (x *RepoInfo) GetRevisions() []string
- func (*RepoInfo) ProtoMessage()
- func (x *RepoInfo) ProtoReflect() protoreflect.Message
- func (x *RepoInfo) Reset()
- func (x *RepoInfo) String() string
- type RoleInfo
- func (*RoleInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RoleInfo) GetConsolidatedStack() map[string]string
- func (x *RoleInfo) GetDefaults() map[string]string
- func (x *RoleInfo) GetDescription() string
- func (x *RoleInfo) GetFullPath() string
- func (x *RoleInfo) GetName() string
- func (x *RoleInfo) GetRoles() []*RoleInfo
- func (x *RoleInfo) GetState() string
- func (x *RoleInfo) GetStatus() string
- func (x *RoleInfo) GetTaskIds() []string
- func (x *RoleInfo) GetUserVars() map[string]string
- func (x *RoleInfo) GetVars() map[string]string
- func (*RoleInfo) ProtoMessage()
- func (x *RoleInfo) ProtoReflect() protoreflect.Message
- func (x *RoleInfo) Reset()
- func (x *RoleInfo) String() string
- type SetDefaultRepoRequest
- func (*SetDefaultRepoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetDefaultRepoRequest) GetIndex() int32
- func (*SetDefaultRepoRequest) ProtoMessage()
- func (x *SetDefaultRepoRequest) ProtoReflect() protoreflect.Message
- func (x *SetDefaultRepoRequest) Reset()
- func (x *SetDefaultRepoRequest) String() string
- type SetEnvironmentPropertiesReply
- func (*SetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)deprecated
- func (*SetEnvironmentPropertiesReply) ProtoMessage()
- func (x *SetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message
- func (x *SetEnvironmentPropertiesReply) Reset()
- func (x *SetEnvironmentPropertiesReply) String() string
- type SetEnvironmentPropertiesRequest
- func (*SetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetEnvironmentPropertiesRequest) GetId() string
- func (x *SetEnvironmentPropertiesRequest) GetProperties() map[string]string
- func (*SetEnvironmentPropertiesRequest) ProtoMessage()
- func (x *SetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message
- func (x *SetEnvironmentPropertiesRequest) Reset()
- func (x *SetEnvironmentPropertiesRequest) String() string
- type SetGlobalDefaultRevisionRequest
- func (*SetGlobalDefaultRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetGlobalDefaultRevisionRequest) GetRevision() string
- func (*SetGlobalDefaultRevisionRequest) ProtoMessage()
- func (x *SetGlobalDefaultRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *SetGlobalDefaultRevisionRequest) Reset()
- func (x *SetGlobalDefaultRevisionRequest) String() string
- type SetRepoDefaultRevisionReply
- func (*SetRepoDefaultRevisionReply) Descriptor() ([]byte, []int)deprecated
- func (x *SetRepoDefaultRevisionReply) GetInfo() string
- func (*SetRepoDefaultRevisionReply) ProtoMessage()
- func (x *SetRepoDefaultRevisionReply) ProtoReflect() protoreflect.Message
- func (x *SetRepoDefaultRevisionReply) Reset()
- func (x *SetRepoDefaultRevisionReply) String() string
- type SetRepoDefaultRevisionRequest
- func (*SetRepoDefaultRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetRepoDefaultRevisionRequest) GetIndex() int32
- func (x *SetRepoDefaultRevisionRequest) GetRevision() string
- func (*SetRepoDefaultRevisionRequest) ProtoMessage()
- func (x *SetRepoDefaultRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *SetRepoDefaultRevisionRequest) Reset()
- func (x *SetRepoDefaultRevisionRequest) String() string
- type ShortTaskInfo
- func (*ShortTaskInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ShortTaskInfo) GetClaimable() bool
- func (x *ShortTaskInfo) GetClassName() string
- func (x *ShortTaskInfo) GetDeploymentInfo() *TaskDeploymentInfo
- func (x *ShortTaskInfo) GetLocked() bool
- func (x *ShortTaskInfo) GetName() string
- func (x *ShortTaskInfo) GetPid() string
- func (x *ShortTaskInfo) GetSandboxStdout() string
- func (x *ShortTaskInfo) GetState() string
- func (x *ShortTaskInfo) GetStatus() string
- func (x *ShortTaskInfo) GetTaskId() string
- func (*ShortTaskInfo) ProtoMessage()
- func (x *ShortTaskInfo) ProtoReflect() protoreflect.Message
- func (x *ShortTaskInfo) Reset()
- func (x *ShortTaskInfo) String() string
- type StatusReply
- func (*StatusReply) Descriptor() ([]byte, []int)deprecated
- func (x *StatusReply) GetState() string
- func (x *StatusReply) GetStatusUpdates() []*StatusUpdate
- func (*StatusReply) ProtoMessage()
- func (x *StatusReply) ProtoReflect() protoreflect.Message
- func (x *StatusReply) Reset()
- func (x *StatusReply) String() string
- type StatusRequest
- type StatusUpdate
- func (*StatusUpdate) Descriptor() ([]byte, []int)deprecated
- func (m *StatusUpdate) GetEvent() isStatusUpdate_Event
- func (x *StatusUpdate) GetLevel() StatusUpdate_Level
- func (x *StatusUpdate) GetMesosHeartbeat() *Event_MesosHeartbeat
- func (*StatusUpdate) ProtoMessage()
- func (x *StatusUpdate) ProtoReflect() protoreflect.Message
- func (x *StatusUpdate) Reset()
- func (x *StatusUpdate) String() string
- type StatusUpdate_Level
- func (StatusUpdate_Level) Descriptor() protoreflect.EnumDescriptor
- func (x StatusUpdate_Level) Enum() *StatusUpdate_Level
- func (StatusUpdate_Level) EnumDescriptor() ([]byte, []int)deprecated
- func (x StatusUpdate_Level) Number() protoreflect.EnumNumber
- func (x StatusUpdate_Level) String() string
- func (StatusUpdate_Level) Type() protoreflect.EnumType
- type StatusUpdate_MesosHeartbeat
- type SubscribeRequest
- type TaskClassInfo
- func (*TaskClassInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskClassInfo) GetControlMode() string
- func (x *TaskClassInfo) GetName() string
- func (*TaskClassInfo) ProtoMessage()
- func (x *TaskClassInfo) ProtoReflect() protoreflect.Message
- func (x *TaskClassInfo) Reset()
- func (x *TaskClassInfo) String() string
- type TaskDeploymentInfo
- func (*TaskDeploymentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskDeploymentInfo) GetAgentId() string
- func (x *TaskDeploymentInfo) GetExecutorId() string
- func (x *TaskDeploymentInfo) GetHostname() string
- func (x *TaskDeploymentInfo) GetOfferId() string
- func (*TaskDeploymentInfo) ProtoMessage()
- func (x *TaskDeploymentInfo) ProtoReflect() protoreflect.Message
- func (x *TaskDeploymentInfo) Reset()
- func (x *TaskDeploymentInfo) String() string
- type TaskInfo
- func (*TaskInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TaskInfo) GetClassInfo() *TaskClassInfo
- func (x *TaskInfo) GetCommandInfo() *CommandInfo
- func (x *TaskInfo) GetEnvId() string
- func (x *TaskInfo) GetInboundChannels() []*ChannelInfo
- func (x *TaskInfo) GetOutboundChannels() []*ChannelInfo
- func (x *TaskInfo) GetProperties() map[string]string
- func (x *TaskInfo) GetShortInfo() *ShortTaskInfo
- func (x *TaskInfo) GetTaskPath() string
- func (*TaskInfo) ProtoMessage()
- func (x *TaskInfo) ProtoReflect() protoreflect.Message
- func (x *TaskInfo) Reset()
- func (x *TaskInfo) String() string
- type TeardownReply
- type TeardownRequest
- type UnimplementedControlServer
- func (UnimplementedControlServer) AddRepo(context.Context, *AddRepoRequest) (*AddRepoReply, error)
- func (UnimplementedControlServer) CleanupTasks(context.Context, *CleanupTasksRequest) (*CleanupTasksReply, error)
- func (UnimplementedControlServer) ControlEnvironment(context.Context, *ControlEnvironmentRequest) (*ControlEnvironmentReply, error)
- func (UnimplementedControlServer) DestroyEnvironment(context.Context, *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error)
- func (UnimplementedControlServer) GetActiveDetectors(context.Context, *Empty) (*GetActiveDetectorsReply, error)
- func (UnimplementedControlServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentReply, error)
- func (UnimplementedControlServer) GetEnvironments(context.Context, *GetEnvironmentsRequest) (*GetEnvironmentsReply, error)
- func (UnimplementedControlServer) GetFrameworkInfo(context.Context, *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error)
- func (UnimplementedControlServer) GetIntegratedServices(context.Context, *Empty) (*ListIntegratedServicesReply, error)
- func (UnimplementedControlServer) GetRoles(context.Context, *GetRolesRequest) (*GetRolesReply, error)
- func (UnimplementedControlServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)
- func (UnimplementedControlServer) GetTasks(context.Context, *GetTasksRequest) (*GetTasksReply, error)
- func (UnimplementedControlServer) GetWorkflowTemplates(context.Context, *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error)
- func (UnimplementedControlServer) ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
- func (UnimplementedControlServer) ModifyEnvironment(context.Context, *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error)
- func (UnimplementedControlServer) NewAutoEnvironment(context.Context, *NewAutoEnvironmentRequest) (*NewAutoEnvironmentReply, error)
- func (UnimplementedControlServer) NewEnvironment(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)
- func (UnimplementedControlServer) RefreshRepos(context.Context, *RefreshReposRequest) (*Empty, error)
- func (UnimplementedControlServer) RemoveRepo(context.Context, *RemoveRepoRequest) (*RemoveRepoReply, error)
- func (UnimplementedControlServer) SetDefaultRepo(context.Context, *SetDefaultRepoRequest) (*Empty, error)
- func (UnimplementedControlServer) SetGlobalDefaultRevision(context.Context, *SetGlobalDefaultRevisionRequest) (*Empty, error)
- func (UnimplementedControlServer) SetRepoDefaultRevision(context.Context, *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error)
- func (UnimplementedControlServer) Subscribe(*SubscribeRequest, Control_SubscribeServer) error
- func (UnimplementedControlServer) Teardown(context.Context, *TeardownRequest) (*TeardownReply, error)
- func (UnimplementedControlServer) TrackStatus(*StatusRequest, Control_TrackStatusServer) error
- type UnsafeControlServer
- type VarSpecMessage
- func (*VarSpecMessage) Descriptor() ([]byte, []int)deprecated
- func (x *VarSpecMessage) GetAllowedValues() []string
- func (x *VarSpecMessage) GetDefaultValue() string
- func (x *VarSpecMessage) GetDescription() string
- func (x *VarSpecMessage) GetEnabledIf() string
- func (x *VarSpecMessage) GetIndex() int32
- func (x *VarSpecMessage) GetLabel() string
- func (x *VarSpecMessage) GetPanel() string
- func (x *VarSpecMessage) GetType() VarSpecMessage_Type
- func (x *VarSpecMessage) GetVisibleIf() string
- func (x *VarSpecMessage) GetWidget() VarSpecMessage_UiWidget
- func (*VarSpecMessage) ProtoMessage()
- func (x *VarSpecMessage) ProtoReflect() protoreflect.Message
- func (x *VarSpecMessage) Reset()
- func (x *VarSpecMessage) String() string
- type VarSpecMessage_Type
- func (VarSpecMessage_Type) Descriptor() protoreflect.EnumDescriptor
- func (x VarSpecMessage_Type) Enum() *VarSpecMessage_Type
- func (VarSpecMessage_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x VarSpecMessage_Type) Number() protoreflect.EnumNumber
- func (x VarSpecMessage_Type) String() string
- func (VarSpecMessage_Type) Type() protoreflect.EnumType
- type VarSpecMessage_UiWidget
- func (VarSpecMessage_UiWidget) Descriptor() protoreflect.EnumDescriptor
- func (x VarSpecMessage_UiWidget) Enum() *VarSpecMessage_UiWidget
- func (VarSpecMessage_UiWidget) EnumDescriptor() ([]byte, []int)deprecated
- func (x VarSpecMessage_UiWidget) Number() protoreflect.EnumNumber
- func (x VarSpecMessage_UiWidget) String() string
- func (VarSpecMessage_UiWidget) Type() protoreflect.EnumType
- type Version
- func (*Version) Descriptor() ([]byte, []int)deprecated
- func (x *Version) GetBuild() string
- func (x *Version) GetMajor() int32
- func (x *Version) GetMinor() int32
- func (x *Version) GetPatch() int32
- func (x *Version) GetProductName() string
- func (x *Version) GetVersionStr() string
- func (*Version) ProtoMessage()
- func (x *Version) ProtoReflect() protoreflect.Message
- func (x *Version) Reset()
- func (x *Version) String() string
- type WorkflowTemplateInfo
- func (*WorkflowTemplateInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowTemplateInfo) GetDescription() string
- func (x *WorkflowTemplateInfo) GetRepo() string
- func (x *WorkflowTemplateInfo) GetRevision() string
- func (x *WorkflowTemplateInfo) GetTemplate() string
- func (x *WorkflowTemplateInfo) GetVarSpecMap() map[string]*VarSpecMessage
- func (*WorkflowTemplateInfo) ProtoMessage()
- func (x *WorkflowTemplateInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowTemplateInfo) Reset()
- func (x *WorkflowTemplateInfo) String() string
Constants ¶
This section is empty.
Variables ¶
var ( StatusUpdate_Level_name = map[int32]string{ 0: "DEBUG", 1: "INFO", 2: "WARNING", 3: "ERROR", } StatusUpdate_Level_value = map[string]int32{ "DEBUG": 0, "INFO": 1, "WARNING": 2, "ERROR": 3, } )
Enum value maps for StatusUpdate_Level.
var ( ControlEnvironmentRequest_Optype_name = map[int32]string{ 0: "NOOP", 1: "START_ACTIVITY", 2: "STOP_ACTIVITY", 3: "CONFIGURE", 4: "RESET", 5: "GO_ERROR", 6: "DEPLOY", } ControlEnvironmentRequest_Optype_value = map[string]int32{ "NOOP": 0, "START_ACTIVITY": 1, "STOP_ACTIVITY": 2, "CONFIGURE": 3, "RESET": 4, "GO_ERROR": 5, "DEPLOY": 6, } )
Enum value maps for ControlEnvironmentRequest_Optype.
var ( EnvironmentOperation_Optype_name = map[int32]string{ 0: "NOOP", 3: "REMOVE_ROLE", 4: "ADD_ROLE", } EnvironmentOperation_Optype_value = map[string]int32{ "NOOP": 0, "REMOVE_ROLE": 3, "ADD_ROLE": 4, } )
Enum value maps for EnvironmentOperation_Optype.
var ( VarSpecMessage_UiWidget_name = map[int32]string{ 0: "editBox", 1: "slider", 2: "listBox", 3: "dropDownBox", 4: "comboBox", 5: "radioButtonBox", 6: "checkBox", } VarSpecMessage_UiWidget_value = map[string]int32{ "editBox": 0, "slider": 1, "listBox": 2, "dropDownBox": 3, "comboBox": 4, "radioButtonBox": 5, "checkBox": 6, } )
Enum value maps for VarSpecMessage_UiWidget.
var ( VarSpecMessage_Type_name = map[int32]string{ 0: "string", 1: "number", 2: "bool", 3: "list", 4: "map", } VarSpecMessage_Type_value = map[string]int32{ "string": 0, "number": 1, "bool": 2, "list": 3, "map": 4, } )
Enum value maps for VarSpecMessage_Type.
var Control_ServiceDesc = grpc.ServiceDesc{ ServiceName: "o2control.Control", HandlerType: (*ControlServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetFrameworkInfo", Handler: _Control_GetFrameworkInfo_Handler, }, { MethodName: "Teardown", Handler: _Control_Teardown_Handler, }, { MethodName: "GetEnvironments", Handler: _Control_GetEnvironments_Handler, }, { MethodName: "NewAutoEnvironment", Handler: _Control_NewAutoEnvironment_Handler, }, { MethodName: "NewEnvironment", Handler: _Control_NewEnvironment_Handler, }, { MethodName: "GetEnvironment", Handler: _Control_GetEnvironment_Handler, }, { MethodName: "ControlEnvironment", Handler: _Control_ControlEnvironment_Handler, }, { MethodName: "ModifyEnvironment", Handler: _Control_ModifyEnvironment_Handler, }, { MethodName: "DestroyEnvironment", Handler: _Control_DestroyEnvironment_Handler, }, { MethodName: "GetActiveDetectors", Handler: _Control_GetActiveDetectors_Handler, }, { MethodName: "GetTasks", Handler: _Control_GetTasks_Handler, }, { MethodName: "GetTask", Handler: _Control_GetTask_Handler, }, { MethodName: "CleanupTasks", Handler: _Control_CleanupTasks_Handler, }, { MethodName: "GetRoles", Handler: _Control_GetRoles_Handler, }, { MethodName: "GetWorkflowTemplates", Handler: _Control_GetWorkflowTemplates_Handler, }, { MethodName: "ListRepos", Handler: _Control_ListRepos_Handler, }, { MethodName: "AddRepo", Handler: _Control_AddRepo_Handler, }, { MethodName: "RemoveRepo", Handler: _Control_RemoveRepo_Handler, }, { MethodName: "RefreshRepos", Handler: _Control_RefreshRepos_Handler, }, { MethodName: "SetDefaultRepo", Handler: _Control_SetDefaultRepo_Handler, }, { MethodName: "SetGlobalDefaultRevision", Handler: _Control_SetGlobalDefaultRevision_Handler, }, { MethodName: "SetRepoDefaultRevision", Handler: _Control_SetRepoDefaultRevision_Handler, }, { MethodName: "GetIntegratedServices", Handler: _Control_GetIntegratedServices_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "TrackStatus", Handler: _Control_TrackStatus_Handler, ServerStreams: true, }, { StreamName: "Subscribe", Handler: _Control_Subscribe_Handler, ServerStreams: true, }, }, Metadata: "protos/o2control.proto", }
Control_ServiceDesc is the grpc.ServiceDesc for Control service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_protos_o2control_proto protoreflect.FileDescriptor
Functions ¶
func RegisterControlServer ¶
func RegisterControlServer(s grpc.ServiceRegistrar, srv ControlServer)
Types ¶
type AddRepoReply ¶ added in v0.10.0
type AddRepoReply struct { NewDefaultRevision string `protobuf:"bytes,1,opt,name=newDefaultRevision,proto3" json:"newDefaultRevision,omitempty"` Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*AddRepoReply) Descriptor
deprecated
added in
v0.10.0
func (*AddRepoReply) Descriptor() ([]byte, []int)
Deprecated: Use AddRepoReply.ProtoReflect.Descriptor instead.
func (*AddRepoReply) GetInfo ¶ added in v0.12.90
func (x *AddRepoReply) GetInfo() string
func (*AddRepoReply) GetNewDefaultRevision ¶ added in v0.12.90
func (x *AddRepoReply) GetNewDefaultRevision() string
func (*AddRepoReply) ProtoMessage ¶ added in v0.10.0
func (*AddRepoReply) ProtoMessage()
func (*AddRepoReply) ProtoReflect ¶ added in v0.19.90
func (x *AddRepoReply) ProtoReflect() protoreflect.Message
func (*AddRepoReply) Reset ¶ added in v0.10.0
func (x *AddRepoReply) Reset()
func (*AddRepoReply) String ¶ added in v0.10.0
func (x *AddRepoReply) String() string
type AddRepoRequest ¶ added in v0.10.0
type AddRepoRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` DefaultRevision string `protobuf:"bytes,2,opt,name=defaultRevision,proto3" json:"defaultRevision,omitempty"` // contains filtered or unexported fields }
func (*AddRepoRequest) Descriptor
deprecated
added in
v0.10.0
func (*AddRepoRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRepoRequest.ProtoReflect.Descriptor instead.
func (*AddRepoRequest) GetDefaultRevision ¶ added in v0.12.90
func (x *AddRepoRequest) GetDefaultRevision() string
func (*AddRepoRequest) GetName ¶ added in v0.10.0
func (x *AddRepoRequest) GetName() string
func (*AddRepoRequest) ProtoMessage ¶ added in v0.10.0
func (*AddRepoRequest) ProtoMessage()
func (*AddRepoRequest) ProtoReflect ¶ added in v0.19.90
func (x *AddRepoRequest) ProtoReflect() protoreflect.Message
func (*AddRepoRequest) Reset ¶ added in v0.10.0
func (x *AddRepoRequest) Reset()
func (*AddRepoRequest) String ¶ added in v0.10.0
func (x *AddRepoRequest) String() string
type ChannelInfo ¶
type ChannelInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
func (*ChannelInfo) Descriptor
deprecated
func (*ChannelInfo) Descriptor() ([]byte, []int)
Deprecated: Use ChannelInfo.ProtoReflect.Descriptor instead.
func (*ChannelInfo) GetName ¶
func (x *ChannelInfo) GetName() string
func (*ChannelInfo) GetTarget ¶
func (x *ChannelInfo) GetTarget() string
func (*ChannelInfo) GetType ¶
func (x *ChannelInfo) GetType() string
func (*ChannelInfo) ProtoMessage ¶
func (*ChannelInfo) ProtoMessage()
func (*ChannelInfo) ProtoReflect ¶ added in v0.19.90
func (x *ChannelInfo) ProtoReflect() protoreflect.Message
func (*ChannelInfo) Reset ¶
func (x *ChannelInfo) Reset()
func (*ChannelInfo) String ¶
func (x *ChannelInfo) String() string
type CleanupTasksReply ¶
type CleanupTasksReply struct { KilledTasks []*ShortTaskInfo `protobuf:"bytes,1,rep,name=killedTasks,proto3" json:"killedTasks,omitempty"` RunningTasks []*ShortTaskInfo `protobuf:"bytes,2,rep,name=runningTasks,proto3" json:"runningTasks,omitempty"` // contains filtered or unexported fields }
func (*CleanupTasksReply) Descriptor
deprecated
func (*CleanupTasksReply) Descriptor() ([]byte, []int)
Deprecated: Use CleanupTasksReply.ProtoReflect.Descriptor instead.
func (*CleanupTasksReply) GetKilledTasks ¶
func (x *CleanupTasksReply) GetKilledTasks() []*ShortTaskInfo
func (*CleanupTasksReply) GetRunningTasks ¶
func (x *CleanupTasksReply) GetRunningTasks() []*ShortTaskInfo
func (*CleanupTasksReply) ProtoMessage ¶
func (*CleanupTasksReply) ProtoMessage()
func (*CleanupTasksReply) ProtoReflect ¶ added in v0.19.90
func (x *CleanupTasksReply) ProtoReflect() protoreflect.Message
func (*CleanupTasksReply) Reset ¶
func (x *CleanupTasksReply) Reset()
func (*CleanupTasksReply) String ¶
func (x *CleanupTasksReply) String() string
type CleanupTasksRequest ¶
type CleanupTasksRequest struct { TaskIds []string `protobuf:"bytes,1,rep,name=taskIds,proto3" json:"taskIds,omitempty"` // contains filtered or unexported fields }
func (*CleanupTasksRequest) Descriptor
deprecated
func (*CleanupTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use CleanupTasksRequest.ProtoReflect.Descriptor instead.
func (*CleanupTasksRequest) GetTaskIds ¶
func (x *CleanupTasksRequest) GetTaskIds() []string
func (*CleanupTasksRequest) ProtoMessage ¶
func (*CleanupTasksRequest) ProtoMessage()
func (*CleanupTasksRequest) ProtoReflect ¶ added in v0.19.90
func (x *CleanupTasksRequest) ProtoReflect() protoreflect.Message
func (*CleanupTasksRequest) Reset ¶
func (x *CleanupTasksRequest) Reset()
func (*CleanupTasksRequest) String ¶
func (x *CleanupTasksRequest) String() string
type CommandInfo ¶
type CommandInfo struct { Env []string `protobuf:"bytes,1,rep,name=env,proto3" json:"env,omitempty"` Shell bool `protobuf:"varint,2,opt,name=shell,proto3" json:"shell,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Arguments []string `protobuf:"bytes,4,rep,name=arguments,proto3" json:"arguments,omitempty"` User string `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*CommandInfo) Descriptor
deprecated
func (*CommandInfo) Descriptor() ([]byte, []int)
Deprecated: Use CommandInfo.ProtoReflect.Descriptor instead.
func (*CommandInfo) GetArguments ¶
func (x *CommandInfo) GetArguments() []string
func (*CommandInfo) GetEnv ¶
func (x *CommandInfo) GetEnv() []string
func (*CommandInfo) GetShell ¶
func (x *CommandInfo) GetShell() bool
func (*CommandInfo) GetUser ¶
func (x *CommandInfo) GetUser() string
func (*CommandInfo) GetValue ¶
func (x *CommandInfo) GetValue() string
func (*CommandInfo) ProtoMessage ¶
func (*CommandInfo) ProtoMessage()
func (*CommandInfo) ProtoReflect ¶ added in v0.19.90
func (x *CommandInfo) ProtoReflect() protoreflect.Message
func (*CommandInfo) Reset ¶
func (x *CommandInfo) Reset()
func (*CommandInfo) String ¶
func (x *CommandInfo) String() string
type ControlClient ¶
type ControlClient interface { TrackStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Control_TrackStatusClient, error) GetFrameworkInfo(ctx context.Context, in *GetFrameworkInfoRequest, opts ...grpc.CallOption) (*GetFrameworkInfoReply, error) Teardown(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*TeardownReply, error) GetEnvironments(ctx context.Context, in *GetEnvironmentsRequest, opts ...grpc.CallOption) (*GetEnvironmentsReply, error) NewAutoEnvironment(ctx context.Context, in *NewAutoEnvironmentRequest, opts ...grpc.CallOption) (*NewAutoEnvironmentReply, error) NewEnvironment(ctx context.Context, in *NewEnvironmentRequest, opts ...grpc.CallOption) (*NewEnvironmentReply, error) GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentReply, error) ControlEnvironment(ctx context.Context, in *ControlEnvironmentRequest, opts ...grpc.CallOption) (*ControlEnvironmentReply, error) ModifyEnvironment(ctx context.Context, in *ModifyEnvironmentRequest, opts ...grpc.CallOption) (*ModifyEnvironmentReply, error) DestroyEnvironment(ctx context.Context, in *DestroyEnvironmentRequest, opts ...grpc.CallOption) (*DestroyEnvironmentReply, error) GetActiveDetectors(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetActiveDetectorsReply, error) GetTasks(ctx context.Context, in *GetTasksRequest, opts ...grpc.CallOption) (*GetTasksReply, error) GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskReply, error) CleanupTasks(ctx context.Context, in *CleanupTasksRequest, opts ...grpc.CallOption) (*CleanupTasksReply, error) GetRoles(ctx context.Context, in *GetRolesRequest, opts ...grpc.CallOption) (*GetRolesReply, error) GetWorkflowTemplates(ctx context.Context, in *GetWorkflowTemplatesRequest, opts ...grpc.CallOption) (*GetWorkflowTemplatesReply, error) ListRepos(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposReply, error) AddRepo(ctx context.Context, in *AddRepoRequest, opts ...grpc.CallOption) (*AddRepoReply, error) RemoveRepo(ctx context.Context, in *RemoveRepoRequest, opts ...grpc.CallOption) (*RemoveRepoReply, error) RefreshRepos(ctx context.Context, in *RefreshReposRequest, opts ...grpc.CallOption) (*Empty, error) SetDefaultRepo(ctx context.Context, in *SetDefaultRepoRequest, opts ...grpc.CallOption) (*Empty, error) SetGlobalDefaultRevision(ctx context.Context, in *SetGlobalDefaultRevisionRequest, opts ...grpc.CallOption) (*Empty, error) SetRepoDefaultRevision(ctx context.Context, in *SetRepoDefaultRevisionRequest, opts ...grpc.CallOption) (*SetRepoDefaultRevisionReply, error) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Control_SubscribeClient, error) GetIntegratedServices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListIntegratedServicesReply, error) }
ControlClient is the client API for Control 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 NewControlClient ¶
func NewControlClient(cc grpc.ClientConnInterface) ControlClient
type ControlEnvironmentReply ¶
type ControlEnvironmentReply struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` CurrentRunNumber uint32 `protobuf:"varint,3,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"` // All times are in milliseconds StartOfTransition int64 `protobuf:"varint,4,opt,name=startOfTransition,proto3" json:"startOfTransition,omitempty"` EndOfTransition int64 `protobuf:"varint,5,opt,name=endOfTransition,proto3" json:"endOfTransition,omitempty"` TransitionDuration int64 `protobuf:"varint,6,opt,name=transitionDuration,proto3" json:"transitionDuration,omitempty"` // contains filtered or unexported fields }
func (*ControlEnvironmentReply) Descriptor
deprecated
func (*ControlEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use ControlEnvironmentReply.ProtoReflect.Descriptor instead.
func (*ControlEnvironmentReply) GetCurrentRunNumber ¶ added in v0.8.0
func (x *ControlEnvironmentReply) GetCurrentRunNumber() uint32
func (*ControlEnvironmentReply) GetEndOfTransition ¶ added in v0.37.0
func (x *ControlEnvironmentReply) GetEndOfTransition() int64
func (*ControlEnvironmentReply) GetId ¶
func (x *ControlEnvironmentReply) GetId() string
func (*ControlEnvironmentReply) GetStartOfTransition ¶ added in v0.37.0
func (x *ControlEnvironmentReply) GetStartOfTransition() int64
func (*ControlEnvironmentReply) GetState ¶
func (x *ControlEnvironmentReply) GetState() string
func (*ControlEnvironmentReply) GetTransitionDuration ¶ added in v0.37.0
func (x *ControlEnvironmentReply) GetTransitionDuration() int64
func (*ControlEnvironmentReply) ProtoMessage ¶
func (*ControlEnvironmentReply) ProtoMessage()
func (*ControlEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *ControlEnvironmentReply) ProtoReflect() protoreflect.Message
func (*ControlEnvironmentReply) Reset ¶
func (x *ControlEnvironmentReply) Reset()
func (*ControlEnvironmentReply) String ¶
func (x *ControlEnvironmentReply) String() string
type ControlEnvironmentRequest ¶
type ControlEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Type ControlEnvironmentRequest_Optype `protobuf:"varint,2,opt,name=type,proto3,enum=o2control.ControlEnvironmentRequest_Optype" json:"type,omitempty"` // contains filtered or unexported fields }
func (*ControlEnvironmentRequest) Descriptor
deprecated
func (*ControlEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use ControlEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*ControlEnvironmentRequest) GetId ¶
func (x *ControlEnvironmentRequest) GetId() string
func (*ControlEnvironmentRequest) GetType ¶
func (x *ControlEnvironmentRequest) GetType() ControlEnvironmentRequest_Optype
func (*ControlEnvironmentRequest) ProtoMessage ¶
func (*ControlEnvironmentRequest) ProtoMessage()
func (*ControlEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *ControlEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*ControlEnvironmentRequest) Reset ¶
func (x *ControlEnvironmentRequest) Reset()
func (*ControlEnvironmentRequest) String ¶
func (x *ControlEnvironmentRequest) String() string
type ControlEnvironmentRequest_Optype ¶
type ControlEnvironmentRequest_Optype int32
const ( ControlEnvironmentRequest_NOOP ControlEnvironmentRequest_Optype = 0 ControlEnvironmentRequest_START_ACTIVITY ControlEnvironmentRequest_Optype = 1 ControlEnvironmentRequest_STOP_ACTIVITY ControlEnvironmentRequest_Optype = 2 ControlEnvironmentRequest_CONFIGURE ControlEnvironmentRequest_Optype = 3 ControlEnvironmentRequest_RESET ControlEnvironmentRequest_Optype = 4 ControlEnvironmentRequest_GO_ERROR ControlEnvironmentRequest_Optype = 5 ControlEnvironmentRequest_DEPLOY ControlEnvironmentRequest_Optype = 6 )
func (ControlEnvironmentRequest_Optype) Descriptor ¶ added in v0.19.90
func (ControlEnvironmentRequest_Optype) Descriptor() protoreflect.EnumDescriptor
func (ControlEnvironmentRequest_Optype) Enum ¶ added in v0.19.90
func (x ControlEnvironmentRequest_Optype) Enum() *ControlEnvironmentRequest_Optype
func (ControlEnvironmentRequest_Optype) EnumDescriptor
deprecated
func (ControlEnvironmentRequest_Optype) EnumDescriptor() ([]byte, []int)
Deprecated: Use ControlEnvironmentRequest_Optype.Descriptor instead.
func (ControlEnvironmentRequest_Optype) Number ¶ added in v0.19.90
func (x ControlEnvironmentRequest_Optype) Number() protoreflect.EnumNumber
func (ControlEnvironmentRequest_Optype) String ¶
func (x ControlEnvironmentRequest_Optype) String() string
func (ControlEnvironmentRequest_Optype) Type ¶ added in v0.19.90
func (ControlEnvironmentRequest_Optype) Type() protoreflect.EnumType
type ControlServer ¶
type ControlServer interface { TrackStatus(*StatusRequest, Control_TrackStatusServer) error GetFrameworkInfo(context.Context, *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error) Teardown(context.Context, *TeardownRequest) (*TeardownReply, error) GetEnvironments(context.Context, *GetEnvironmentsRequest) (*GetEnvironmentsReply, error) NewAutoEnvironment(context.Context, *NewAutoEnvironmentRequest) (*NewAutoEnvironmentReply, error) NewEnvironment(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error) GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentReply, error) ControlEnvironment(context.Context, *ControlEnvironmentRequest) (*ControlEnvironmentReply, error) ModifyEnvironment(context.Context, *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error) DestroyEnvironment(context.Context, *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error) GetActiveDetectors(context.Context, *Empty) (*GetActiveDetectorsReply, error) GetTasks(context.Context, *GetTasksRequest) (*GetTasksReply, error) GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error) CleanupTasks(context.Context, *CleanupTasksRequest) (*CleanupTasksReply, error) GetRoles(context.Context, *GetRolesRequest) (*GetRolesReply, error) GetWorkflowTemplates(context.Context, *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error) ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error) AddRepo(context.Context, *AddRepoRequest) (*AddRepoReply, error) RemoveRepo(context.Context, *RemoveRepoRequest) (*RemoveRepoReply, error) RefreshRepos(context.Context, *RefreshReposRequest) (*Empty, error) SetDefaultRepo(context.Context, *SetDefaultRepoRequest) (*Empty, error) SetGlobalDefaultRevision(context.Context, *SetGlobalDefaultRevisionRequest) (*Empty, error) SetRepoDefaultRevision(context.Context, *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error) Subscribe(*SubscribeRequest, Control_SubscribeServer) error GetIntegratedServices(context.Context, *Empty) (*ListIntegratedServicesReply, error) }
ControlServer is the server API for Control service. All implementations should embed UnimplementedControlServer for forward compatibility
type Control_SubscribeClient ¶ added in v0.14.4
type Control_SubscribeClient interface { Recv() (*Event, error) grpc.ClientStream }
type Control_SubscribeServer ¶ added in v0.14.4
type Control_SubscribeServer interface { Send(*Event) error grpc.ServerStream }
type Control_TrackStatusClient ¶
type Control_TrackStatusClient interface { Recv() (*StatusReply, error) grpc.ClientStream }
type Control_TrackStatusServer ¶
type Control_TrackStatusServer interface { Send(*StatusReply) error grpc.ServerStream }
type DestroyEnvironmentReply ¶
type DestroyEnvironmentReply struct { CleanupTasksReply *CleanupTasksReply `protobuf:"bytes,1,opt,name=cleanupTasksReply,proto3" json:"cleanupTasksReply,omitempty"` // contains filtered or unexported fields }
func (*DestroyEnvironmentReply) Descriptor
deprecated
func (*DestroyEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use DestroyEnvironmentReply.ProtoReflect.Descriptor instead.
func (*DestroyEnvironmentReply) GetCleanupTasksReply ¶ added in v0.9.1
func (x *DestroyEnvironmentReply) GetCleanupTasksReply() *CleanupTasksReply
func (*DestroyEnvironmentReply) ProtoMessage ¶
func (*DestroyEnvironmentReply) ProtoMessage()
func (*DestroyEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *DestroyEnvironmentReply) ProtoReflect() protoreflect.Message
func (*DestroyEnvironmentReply) Reset ¶
func (x *DestroyEnvironmentReply) Reset()
func (*DestroyEnvironmentReply) String ¶
func (x *DestroyEnvironmentReply) String() string
type DestroyEnvironmentRequest ¶
type DestroyEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` KeepTasks bool `protobuf:"varint,2,opt,name=keepTasks,proto3" json:"keepTasks,omitempty"` AllowInRunningState bool `protobuf:"varint,3,opt,name=allowInRunningState,proto3" json:"allowInRunningState,omitempty"` Force bool `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
func (*DestroyEnvironmentRequest) Descriptor
deprecated
func (*DestroyEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use DestroyEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*DestroyEnvironmentRequest) GetAllowInRunningState ¶ added in v0.12.90
func (x *DestroyEnvironmentRequest) GetAllowInRunningState() bool
func (*DestroyEnvironmentRequest) GetForce ¶ added in v0.14.3
func (x *DestroyEnvironmentRequest) GetForce() bool
func (*DestroyEnvironmentRequest) GetId ¶
func (x *DestroyEnvironmentRequest) GetId() string
func (*DestroyEnvironmentRequest) GetKeepTasks ¶ added in v0.9.1
func (x *DestroyEnvironmentRequest) GetKeepTasks() bool
func (*DestroyEnvironmentRequest) ProtoMessage ¶
func (*DestroyEnvironmentRequest) ProtoMessage()
func (*DestroyEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *DestroyEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*DestroyEnvironmentRequest) Reset ¶
func (x *DestroyEnvironmentRequest) Reset()
func (*DestroyEnvironmentRequest) String ¶
func (x *DestroyEnvironmentRequest) String() string
type Empty ¶ added in v0.11.1
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
added in
v0.11.1
func (*Empty) ProtoMessage ¶ added in v0.11.1
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶ added in v0.19.90
func (x *Empty) ProtoReflect() protoreflect.Message
type EnvironmentInfo ¶
type EnvironmentInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CreatedWhen int64 `protobuf:"varint,2,opt,name=createdWhen,proto3" json:"createdWhen,omitempty"` // msec State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` Tasks []*ShortTaskInfo `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"` RootRole string `protobuf:"bytes,5,opt,name=rootRole,proto3" json:"rootRole,omitempty"` CurrentRunNumber uint32 `protobuf:"varint,6,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"` Defaults map[string]string `` /* 157-byte string literal not displayed */ Vars map[string]string `` /* 149-byte string literal not displayed */ UserVars map[string]string `` /* 157-byte string literal not displayed */ NumberOfFlps int32 `protobuf:"varint,10,opt,name=numberOfFlps,proto3" json:"numberOfFlps,omitempty"` IncludedDetectors []string `protobuf:"bytes,11,rep,name=includedDetectors,proto3" json:"includedDetectors,omitempty"` Description string `protobuf:"bytes,12,opt,name=description,proto3" json:"description,omitempty"` NumberOfHosts int32 `protobuf:"varint,13,opt,name=numberOfHosts,proto3" json:"numberOfHosts,omitempty"` // contains filtered or unexported fields }
func (*EnvironmentInfo) Descriptor
deprecated
func (*EnvironmentInfo) Descriptor() ([]byte, []int)
Deprecated: Use EnvironmentInfo.ProtoReflect.Descriptor instead.
func (*EnvironmentInfo) GetCreatedWhen ¶
func (x *EnvironmentInfo) GetCreatedWhen() int64
func (*EnvironmentInfo) GetCurrentRunNumber ¶ added in v0.8.0
func (x *EnvironmentInfo) GetCurrentRunNumber() uint32
func (*EnvironmentInfo) GetDefaults ¶ added in v0.12.90
func (x *EnvironmentInfo) GetDefaults() map[string]string
func (*EnvironmentInfo) GetDescription ¶ added in v0.37.0
func (x *EnvironmentInfo) GetDescription() string
func (*EnvironmentInfo) GetId ¶
func (x *EnvironmentInfo) GetId() string
func (*EnvironmentInfo) GetIncludedDetectors ¶ added in v0.26.3
func (x *EnvironmentInfo) GetIncludedDetectors() []string
func (*EnvironmentInfo) GetNumberOfFlps ¶ added in v0.20.80
func (x *EnvironmentInfo) GetNumberOfFlps() int32
func (*EnvironmentInfo) GetNumberOfHosts ¶ added in v0.48.0
func (x *EnvironmentInfo) GetNumberOfHosts() int32
func (*EnvironmentInfo) GetRootRole ¶
func (x *EnvironmentInfo) GetRootRole() string
func (*EnvironmentInfo) GetState ¶
func (x *EnvironmentInfo) GetState() string
func (*EnvironmentInfo) GetTasks ¶
func (x *EnvironmentInfo) GetTasks() []*ShortTaskInfo
func (*EnvironmentInfo) GetUserVars ¶ added in v0.12.90
func (x *EnvironmentInfo) GetUserVars() map[string]string
func (*EnvironmentInfo) GetVars ¶ added in v0.12.90
func (x *EnvironmentInfo) GetVars() map[string]string
func (*EnvironmentInfo) ProtoMessage ¶
func (*EnvironmentInfo) ProtoMessage()
func (*EnvironmentInfo) ProtoReflect ¶ added in v0.19.90
func (x *EnvironmentInfo) ProtoReflect() protoreflect.Message
func (*EnvironmentInfo) Reset ¶
func (x *EnvironmentInfo) Reset()
func (*EnvironmentInfo) String ¶
func (x *EnvironmentInfo) String() string
type EnvironmentOperation ¶
type EnvironmentOperation struct { Type EnvironmentOperation_Optype `protobuf:"varint,1,opt,name=type,proto3,enum=o2control.EnvironmentOperation_Optype" json:"type,omitempty"` RoleName string `protobuf:"bytes,2,opt,name=roleName,proto3" json:"roleName,omitempty"` // contains filtered or unexported fields }
func (*EnvironmentOperation) Descriptor
deprecated
func (*EnvironmentOperation) Descriptor() ([]byte, []int)
Deprecated: Use EnvironmentOperation.ProtoReflect.Descriptor instead.
func (*EnvironmentOperation) GetRoleName ¶
func (x *EnvironmentOperation) GetRoleName() string
func (*EnvironmentOperation) GetType ¶
func (x *EnvironmentOperation) GetType() EnvironmentOperation_Optype
func (*EnvironmentOperation) ProtoMessage ¶
func (*EnvironmentOperation) ProtoMessage()
func (*EnvironmentOperation) ProtoReflect ¶ added in v0.19.90
func (x *EnvironmentOperation) ProtoReflect() protoreflect.Message
func (*EnvironmentOperation) Reset ¶
func (x *EnvironmentOperation) Reset()
func (*EnvironmentOperation) String ¶
func (x *EnvironmentOperation) String() string
type EnvironmentOperation_Optype ¶
type EnvironmentOperation_Optype int32
const ( EnvironmentOperation_NOOP EnvironmentOperation_Optype = 0 EnvironmentOperation_REMOVE_ROLE EnvironmentOperation_Optype = 3 EnvironmentOperation_ADD_ROLE EnvironmentOperation_Optype = 4 )
func (EnvironmentOperation_Optype) Descriptor ¶ added in v0.19.90
func (EnvironmentOperation_Optype) Descriptor() protoreflect.EnumDescriptor
func (EnvironmentOperation_Optype) Enum ¶ added in v0.19.90
func (x EnvironmentOperation_Optype) Enum() *EnvironmentOperation_Optype
func (EnvironmentOperation_Optype) EnumDescriptor
deprecated
func (EnvironmentOperation_Optype) EnumDescriptor() ([]byte, []int)
Deprecated: Use EnvironmentOperation_Optype.Descriptor instead.
func (EnvironmentOperation_Optype) Number ¶ added in v0.19.90
func (x EnvironmentOperation_Optype) Number() protoreflect.EnumNumber
func (EnvironmentOperation_Optype) String ¶
func (x EnvironmentOperation_Optype) String() string
func (EnvironmentOperation_Optype) Type ¶ added in v0.19.90
func (EnvironmentOperation_Optype) Type() protoreflect.EnumType
type Ev_EnvironmentEvent ¶ added in v0.19.80
type Ev_EnvironmentEvent struct { EnvironmentId string `protobuf:"bytes,1,opt,name=environmentId,proto3" json:"environmentId,omitempty"` State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` CurrentRunNumber uint32 `protobuf:"varint,3,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Ev_EnvironmentEvent) Descriptor
deprecated
added in
v0.19.80
func (*Ev_EnvironmentEvent) Descriptor() ([]byte, []int)
Deprecated: Use Ev_EnvironmentEvent.ProtoReflect.Descriptor instead.
func (*Ev_EnvironmentEvent) GetCurrentRunNumber ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) GetCurrentRunNumber() uint32
func (*Ev_EnvironmentEvent) GetEnvironmentId ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) GetEnvironmentId() string
func (*Ev_EnvironmentEvent) GetError ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) GetError() string
func (*Ev_EnvironmentEvent) GetMessage ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) GetMessage() string
func (*Ev_EnvironmentEvent) GetState ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) GetState() string
func (*Ev_EnvironmentEvent) ProtoMessage ¶ added in v0.19.80
func (*Ev_EnvironmentEvent) ProtoMessage()
func (*Ev_EnvironmentEvent) ProtoReflect ¶ added in v0.19.90
func (x *Ev_EnvironmentEvent) ProtoReflect() protoreflect.Message
func (*Ev_EnvironmentEvent) Reset ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) Reset()
func (*Ev_EnvironmentEvent) String ¶ added in v0.19.80
func (x *Ev_EnvironmentEvent) String() string
type Ev_RoleEvent ¶ added in v0.19.80
type Ev_RoleEvent struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` RolePath string `protobuf:"bytes,4,opt,name=rolePath,proto3" json:"rolePath,omitempty"` // contains filtered or unexported fields }
func (*Ev_RoleEvent) Descriptor
deprecated
added in
v0.19.80
func (*Ev_RoleEvent) Descriptor() ([]byte, []int)
Deprecated: Use Ev_RoleEvent.ProtoReflect.Descriptor instead.
func (*Ev_RoleEvent) GetName ¶ added in v0.19.80
func (x *Ev_RoleEvent) GetName() string
func (*Ev_RoleEvent) GetRolePath ¶ added in v0.19.80
func (x *Ev_RoleEvent) GetRolePath() string
func (*Ev_RoleEvent) GetState ¶ added in v0.19.80
func (x *Ev_RoleEvent) GetState() string
func (*Ev_RoleEvent) GetStatus ¶ added in v0.19.80
func (x *Ev_RoleEvent) GetStatus() string
func (*Ev_RoleEvent) ProtoMessage ¶ added in v0.19.80
func (*Ev_RoleEvent) ProtoMessage()
func (*Ev_RoleEvent) ProtoReflect ¶ added in v0.19.90
func (x *Ev_RoleEvent) ProtoReflect() protoreflect.Message
func (*Ev_RoleEvent) Reset ¶ added in v0.19.80
func (x *Ev_RoleEvent) Reset()
func (*Ev_RoleEvent) String ¶ added in v0.19.80
func (x *Ev_RoleEvent) String() string
type Ev_TaskEvent ¶ added in v0.19.80
type Ev_TaskEvent struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Taskid string `protobuf:"bytes,2,opt,name=taskid,proto3" json:"taskid,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"` ClassName string `protobuf:"bytes,6,opt,name=className,proto3" json:"className,omitempty"` // contains filtered or unexported fields }
func (*Ev_TaskEvent) Descriptor
deprecated
added in
v0.19.80
func (*Ev_TaskEvent) Descriptor() ([]byte, []int)
Deprecated: Use Ev_TaskEvent.ProtoReflect.Descriptor instead.
func (*Ev_TaskEvent) GetClassName ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetClassName() string
func (*Ev_TaskEvent) GetHostname ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetHostname() string
func (*Ev_TaskEvent) GetName ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetName() string
func (*Ev_TaskEvent) GetState ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetState() string
func (*Ev_TaskEvent) GetStatus ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetStatus() string
func (*Ev_TaskEvent) GetTaskid ¶ added in v0.19.80
func (x *Ev_TaskEvent) GetTaskid() string
func (*Ev_TaskEvent) ProtoMessage ¶ added in v0.19.80
func (*Ev_TaskEvent) ProtoMessage()
func (*Ev_TaskEvent) ProtoReflect ¶ added in v0.19.90
func (x *Ev_TaskEvent) ProtoReflect() protoreflect.Message
func (*Ev_TaskEvent) Reset ¶ added in v0.19.80
func (x *Ev_TaskEvent) Reset()
func (*Ev_TaskEvent) String ¶ added in v0.19.80
func (x *Ev_TaskEvent) String() string
type Event ¶ added in v0.14.4
type Event struct { Timestamp string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Types that are assignable to Payload: // *Event_EnvironmentEvent // *Event_TaskEvent // *Event_RoleEvent Payload isEvent_Payload `protobuf_oneof:"Payload"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
added in
v0.14.4
func (*Event) GetEnvironmentEvent ¶ added in v0.19.80
func (x *Event) GetEnvironmentEvent() *Ev_EnvironmentEvent
func (*Event) GetPayload ¶ added in v0.14.4
func (m *Event) GetPayload() isEvent_Payload
func (*Event) GetRoleEvent ¶ added in v0.19.80
func (x *Event) GetRoleEvent() *Ev_RoleEvent
func (*Event) GetTaskEvent ¶ added in v0.19.80
func (x *Event) GetTaskEvent() *Ev_TaskEvent
func (*Event) GetTimestamp ¶ added in v0.14.4
func (*Event) ProtoMessage ¶ added in v0.14.4
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶ added in v0.19.90
func (x *Event) ProtoReflect() protoreflect.Message
type Event_EnvironmentEvent ¶ added in v0.19.80
type Event_EnvironmentEvent struct {
EnvironmentEvent *Ev_EnvironmentEvent `protobuf:"bytes,2,opt,name=environmentEvent,proto3,oneof"`
}
type Event_MesosHeartbeat ¶
type Event_MesosHeartbeat struct {
// contains filtered or unexported fields
}
func (*Event_MesosHeartbeat) Descriptor
deprecated
func (*Event_MesosHeartbeat) Descriptor() ([]byte, []int)
Deprecated: Use Event_MesosHeartbeat.ProtoReflect.Descriptor instead.
func (*Event_MesosHeartbeat) ProtoMessage ¶
func (*Event_MesosHeartbeat) ProtoMessage()
func (*Event_MesosHeartbeat) ProtoReflect ¶ added in v0.19.90
func (x *Event_MesosHeartbeat) ProtoReflect() protoreflect.Message
func (*Event_MesosHeartbeat) Reset ¶
func (x *Event_MesosHeartbeat) Reset()
func (*Event_MesosHeartbeat) String ¶
func (x *Event_MesosHeartbeat) String() string
type Event_RoleEvent ¶ added in v0.19.80
type Event_RoleEvent struct {
RoleEvent *Ev_RoleEvent `protobuf:"bytes,4,opt,name=roleEvent,proto3,oneof"`
}
type Event_TaskEvent ¶ added in v0.19.80
type Event_TaskEvent struct {
TaskEvent *Ev_TaskEvent `protobuf:"bytes,3,opt,name=taskEvent,proto3,oneof"`
}
type GetActiveDetectorsReply ¶ added in v0.26.3
type GetActiveDetectorsReply struct { Detectors []string `protobuf:"bytes,1,rep,name=detectors,proto3" json:"detectors,omitempty"` // contains filtered or unexported fields }
func (*GetActiveDetectorsReply) Descriptor
deprecated
added in
v0.26.3
func (*GetActiveDetectorsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveDetectorsReply.ProtoReflect.Descriptor instead.
func (*GetActiveDetectorsReply) GetDetectors ¶ added in v0.26.3
func (x *GetActiveDetectorsReply) GetDetectors() []string
func (*GetActiveDetectorsReply) ProtoMessage ¶ added in v0.26.3
func (*GetActiveDetectorsReply) ProtoMessage()
func (*GetActiveDetectorsReply) ProtoReflect ¶ added in v0.26.3
func (x *GetActiveDetectorsReply) ProtoReflect() protoreflect.Message
func (*GetActiveDetectorsReply) Reset ¶ added in v0.26.3
func (x *GetActiveDetectorsReply) Reset()
func (*GetActiveDetectorsReply) String ¶ added in v0.26.3
func (x *GetActiveDetectorsReply) String() string
type GetEnvironmentPropertiesReply ¶ added in v0.12.90
type GetEnvironmentPropertiesReply struct { Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetEnvironmentPropertiesReply) Descriptor
deprecated
added in
v0.12.90
func (*GetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentPropertiesReply.ProtoReflect.Descriptor instead.
func (*GetEnvironmentPropertiesReply) GetProperties ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesReply) GetProperties() map[string]string
func (*GetEnvironmentPropertiesReply) ProtoMessage ¶ added in v0.12.90
func (*GetEnvironmentPropertiesReply) ProtoMessage()
func (*GetEnvironmentPropertiesReply) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message
func (*GetEnvironmentPropertiesReply) Reset ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesReply) Reset()
func (*GetEnvironmentPropertiesReply) String ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesReply) String() string
type GetEnvironmentPropertiesRequest ¶ added in v0.12.90
type GetEnvironmentPropertiesRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // If len(queries) == 0, we return an // empty map. // To retrieve all KVs, use query '*' Queries []string `protobuf:"bytes,2,rep,name=queries,proto3" json:"queries,omitempty"` ExcludeGlobals bool `protobuf:"varint,3,opt,name=excludeGlobals,proto3" json:"excludeGlobals,omitempty"` // contains filtered or unexported fields }
func (*GetEnvironmentPropertiesRequest) Descriptor
deprecated
added in
v0.12.90
func (*GetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentPropertiesRequest.ProtoReflect.Descriptor instead.
func (*GetEnvironmentPropertiesRequest) GetExcludeGlobals ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesRequest) GetExcludeGlobals() bool
func (*GetEnvironmentPropertiesRequest) GetId ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesRequest) GetId() string
func (*GetEnvironmentPropertiesRequest) GetQueries ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesRequest) GetQueries() []string
func (*GetEnvironmentPropertiesRequest) ProtoMessage ¶ added in v0.12.90
func (*GetEnvironmentPropertiesRequest) ProtoMessage()
func (*GetEnvironmentPropertiesRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message
func (*GetEnvironmentPropertiesRequest) Reset ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesRequest) Reset()
func (*GetEnvironmentPropertiesRequest) String ¶ added in v0.12.90
func (x *GetEnvironmentPropertiesRequest) String() string
type GetEnvironmentReply ¶
type GetEnvironmentReply struct { Environment *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` Workflow *RoleInfo `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` Public bool `protobuf:"varint,3,opt,name=public,proto3" json:"public,omitempty"` // contains filtered or unexported fields }
func (*GetEnvironmentReply) Descriptor
deprecated
func (*GetEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentReply.ProtoReflect.Descriptor instead.
func (*GetEnvironmentReply) GetEnvironment ¶
func (x *GetEnvironmentReply) GetEnvironment() *EnvironmentInfo
func (*GetEnvironmentReply) GetPublic ¶ added in v0.25.0
func (x *GetEnvironmentReply) GetPublic() bool
func (*GetEnvironmentReply) GetWorkflow ¶
func (x *GetEnvironmentReply) GetWorkflow() *RoleInfo
func (*GetEnvironmentReply) ProtoMessage ¶
func (*GetEnvironmentReply) ProtoMessage()
func (*GetEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentReply) ProtoReflect() protoreflect.Message
func (*GetEnvironmentReply) Reset ¶
func (x *GetEnvironmentReply) Reset()
func (*GetEnvironmentReply) String ¶
func (x *GetEnvironmentReply) String() string
type GetEnvironmentRequest ¶
type GetEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ShowWorkflowTree bool `protobuf:"varint,2,opt,name=showWorkflowTree,proto3" json:"showWorkflowTree,omitempty"` // contains filtered or unexported fields }
func (*GetEnvironmentRequest) Descriptor
deprecated
func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*GetEnvironmentRequest) GetId ¶
func (x *GetEnvironmentRequest) GetId() string
func (*GetEnvironmentRequest) GetShowWorkflowTree ¶ added in v0.27.80
func (x *GetEnvironmentRequest) GetShowWorkflowTree() bool
func (*GetEnvironmentRequest) ProtoMessage ¶
func (*GetEnvironmentRequest) ProtoMessage()
func (*GetEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*GetEnvironmentRequest) Reset ¶
func (x *GetEnvironmentRequest) Reset()
func (*GetEnvironmentRequest) String ¶
func (x *GetEnvironmentRequest) String() string
type GetEnvironmentsReply ¶
type GetEnvironmentsReply struct { FrameworkId string `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"` Environments []*EnvironmentInfo `protobuf:"bytes,2,rep,name=environments,proto3" json:"environments,omitempty"` // contains filtered or unexported fields }
func (*GetEnvironmentsReply) Descriptor
deprecated
func (*GetEnvironmentsReply) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentsReply.ProtoReflect.Descriptor instead.
func (*GetEnvironmentsReply) GetEnvironments ¶
func (x *GetEnvironmentsReply) GetEnvironments() []*EnvironmentInfo
func (*GetEnvironmentsReply) GetFrameworkId ¶
func (x *GetEnvironmentsReply) GetFrameworkId() string
func (*GetEnvironmentsReply) ProtoMessage ¶
func (*GetEnvironmentsReply) ProtoMessage()
func (*GetEnvironmentsReply) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentsReply) ProtoReflect() protoreflect.Message
func (*GetEnvironmentsReply) Reset ¶
func (x *GetEnvironmentsReply) Reset()
func (*GetEnvironmentsReply) String ¶
func (x *GetEnvironmentsReply) String() string
type GetEnvironmentsRequest ¶
type GetEnvironmentsRequest struct { ShowAll bool `protobuf:"varint,1,opt,name=showAll,proto3" json:"showAll,omitempty"` ShowTaskInfos bool `protobuf:"varint,2,opt,name=showTaskInfos,proto3" json:"showTaskInfos,omitempty"` // contains filtered or unexported fields }
////////////////////////////////////// Environment //////////////////////////////////////
func (*GetEnvironmentsRequest) Descriptor
deprecated
func (*GetEnvironmentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentsRequest.ProtoReflect.Descriptor instead.
func (*GetEnvironmentsRequest) GetShowAll ¶ added in v0.25.0
func (x *GetEnvironmentsRequest) GetShowAll() bool
func (*GetEnvironmentsRequest) GetShowTaskInfos ¶ added in v0.27.80
func (x *GetEnvironmentsRequest) GetShowTaskInfos() bool
func (*GetEnvironmentsRequest) ProtoMessage ¶
func (*GetEnvironmentsRequest) ProtoMessage()
func (*GetEnvironmentsRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetEnvironmentsRequest) ProtoReflect() protoreflect.Message
func (*GetEnvironmentsRequest) Reset ¶
func (x *GetEnvironmentsRequest) Reset()
func (*GetEnvironmentsRequest) String ¶
func (x *GetEnvironmentsRequest) String() string
type GetFrameworkInfoReply ¶
type GetFrameworkInfoReply struct { FrameworkId string `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"` EnvironmentsCount int32 `protobuf:"varint,2,opt,name=environmentsCount,proto3" json:"environmentsCount,omitempty"` TasksCount int32 `protobuf:"varint,3,opt,name=tasksCount,proto3" json:"tasksCount,omitempty"` State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` HostsCount int32 `protobuf:"varint,5,opt,name=hostsCount,proto3" json:"hostsCount,omitempty"` InstanceName string `protobuf:"bytes,6,opt,name=instanceName,proto3" json:"instanceName,omitempty"` Version *Version `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"` ConfigurationEndpoint string `protobuf:"bytes,8,opt,name=configurationEndpoint,proto3" json:"configurationEndpoint,omitempty"` DetectorsInInstance []string `protobuf:"bytes,9,rep,name=detectorsInInstance,proto3" json:"detectorsInInstance,omitempty"` ActiveDetectors []string `protobuf:"bytes,10,rep,name=activeDetectors,proto3" json:"activeDetectors,omitempty"` AvailableDetectors []string `protobuf:"bytes,11,rep,name=availableDetectors,proto3" json:"availableDetectors,omitempty"` // contains filtered or unexported fields }
func (*GetFrameworkInfoReply) Descriptor
deprecated
func (*GetFrameworkInfoReply) Descriptor() ([]byte, []int)
Deprecated: Use GetFrameworkInfoReply.ProtoReflect.Descriptor instead.
func (*GetFrameworkInfoReply) GetActiveDetectors ¶ added in v0.26.3
func (x *GetFrameworkInfoReply) GetActiveDetectors() []string
func (*GetFrameworkInfoReply) GetAvailableDetectors ¶ added in v0.26.3
func (x *GetFrameworkInfoReply) GetAvailableDetectors() []string
func (*GetFrameworkInfoReply) GetConfigurationEndpoint ¶ added in v0.22.80
func (x *GetFrameworkInfoReply) GetConfigurationEndpoint() string
func (*GetFrameworkInfoReply) GetDetectorsInInstance ¶ added in v0.26.3
func (x *GetFrameworkInfoReply) GetDetectorsInInstance() []string
func (*GetFrameworkInfoReply) GetEnvironmentsCount ¶
func (x *GetFrameworkInfoReply) GetEnvironmentsCount() int32
func (*GetFrameworkInfoReply) GetFrameworkId ¶
func (x *GetFrameworkInfoReply) GetFrameworkId() string
func (*GetFrameworkInfoReply) GetHostsCount ¶
func (x *GetFrameworkInfoReply) GetHostsCount() int32
func (*GetFrameworkInfoReply) GetInstanceName ¶ added in v0.7.0
func (x *GetFrameworkInfoReply) GetInstanceName() string
func (*GetFrameworkInfoReply) GetState ¶
func (x *GetFrameworkInfoReply) GetState() string
func (*GetFrameworkInfoReply) GetTasksCount ¶
func (x *GetFrameworkInfoReply) GetTasksCount() int32
func (*GetFrameworkInfoReply) GetVersion ¶ added in v0.7.0
func (x *GetFrameworkInfoReply) GetVersion() *Version
func (*GetFrameworkInfoReply) ProtoMessage ¶
func (*GetFrameworkInfoReply) ProtoMessage()
func (*GetFrameworkInfoReply) ProtoReflect ¶ added in v0.19.90
func (x *GetFrameworkInfoReply) ProtoReflect() protoreflect.Message
func (*GetFrameworkInfoReply) Reset ¶
func (x *GetFrameworkInfoReply) Reset()
func (*GetFrameworkInfoReply) String ¶
func (x *GetFrameworkInfoReply) String() string
type GetFrameworkInfoRequest ¶
type GetFrameworkInfoRequest struct {
// contains filtered or unexported fields
}
////////////////////////////////////// Framework //////////////////////////////////////
func (*GetFrameworkInfoRequest) Descriptor
deprecated
func (*GetFrameworkInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFrameworkInfoRequest.ProtoReflect.Descriptor instead.
func (*GetFrameworkInfoRequest) ProtoMessage ¶
func (*GetFrameworkInfoRequest) ProtoMessage()
func (*GetFrameworkInfoRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetFrameworkInfoRequest) ProtoReflect() protoreflect.Message
func (*GetFrameworkInfoRequest) Reset ¶
func (x *GetFrameworkInfoRequest) Reset()
func (*GetFrameworkInfoRequest) String ¶
func (x *GetFrameworkInfoRequest) String() string
type GetRolesReply ¶
type GetRolesReply struct { Roles []*RoleInfo `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"` // contains filtered or unexported fields }
func (*GetRolesReply) Descriptor
deprecated
func (*GetRolesReply) Descriptor() ([]byte, []int)
Deprecated: Use GetRolesReply.ProtoReflect.Descriptor instead.
func (*GetRolesReply) GetRoles ¶
func (x *GetRolesReply) GetRoles() []*RoleInfo
func (*GetRolesReply) ProtoMessage ¶
func (*GetRolesReply) ProtoMessage()
func (*GetRolesReply) ProtoReflect ¶ added in v0.19.90
func (x *GetRolesReply) ProtoReflect() protoreflect.Message
func (*GetRolesReply) Reset ¶
func (x *GetRolesReply) Reset()
func (*GetRolesReply) String ¶
func (x *GetRolesReply) String() string
type GetRolesRequest ¶
type GetRolesRequest struct { EnvId string `protobuf:"bytes,1,opt,name=envId,proto3" json:"envId,omitempty"` PathSpec string `protobuf:"bytes,2,opt,name=pathSpec,proto3" json:"pathSpec,omitempty"` // contains filtered or unexported fields }
////////////////////////////////////// Roles //////////////////////////////////////
func (*GetRolesRequest) Descriptor
deprecated
func (*GetRolesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRolesRequest.ProtoReflect.Descriptor instead.
func (*GetRolesRequest) GetEnvId ¶
func (x *GetRolesRequest) GetEnvId() string
func (*GetRolesRequest) GetPathSpec ¶
func (x *GetRolesRequest) GetPathSpec() string
func (*GetRolesRequest) ProtoMessage ¶
func (*GetRolesRequest) ProtoMessage()
func (*GetRolesRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetRolesRequest) ProtoReflect() protoreflect.Message
func (*GetRolesRequest) Reset ¶
func (x *GetRolesRequest) Reset()
func (*GetRolesRequest) String ¶
func (x *GetRolesRequest) String() string
type GetTaskReply ¶
type GetTaskReply struct { Task *TaskInfo `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` // contains filtered or unexported fields }
func (*GetTaskReply) Descriptor
deprecated
func (*GetTaskReply) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskReply.ProtoReflect.Descriptor instead.
func (*GetTaskReply) GetTask ¶
func (x *GetTaskReply) GetTask() *TaskInfo
func (*GetTaskReply) ProtoMessage ¶
func (*GetTaskReply) ProtoMessage()
func (*GetTaskReply) ProtoReflect ¶ added in v0.19.90
func (x *GetTaskReply) ProtoReflect() protoreflect.Message
func (*GetTaskReply) Reset ¶
func (x *GetTaskReply) Reset()
func (*GetTaskReply) String ¶
func (x *GetTaskReply) String() string
type GetTaskRequest ¶
type GetTaskRequest struct { TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"` // contains filtered or unexported fields }
func (*GetTaskRequest) Descriptor
deprecated
func (*GetTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.
func (*GetTaskRequest) GetTaskId ¶
func (x *GetTaskRequest) GetTaskId() string
func (*GetTaskRequest) ProtoMessage ¶
func (*GetTaskRequest) ProtoMessage()
func (*GetTaskRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetTaskRequest) ProtoReflect() protoreflect.Message
func (*GetTaskRequest) Reset ¶
func (x *GetTaskRequest) Reset()
func (*GetTaskRequest) String ¶
func (x *GetTaskRequest) String() string
type GetTasksReply ¶
type GetTasksReply struct { Tasks []*ShortTaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` // contains filtered or unexported fields }
func (*GetTasksReply) Descriptor
deprecated
func (*GetTasksReply) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksReply.ProtoReflect.Descriptor instead.
func (*GetTasksReply) GetTasks ¶
func (x *GetTasksReply) GetTasks() []*ShortTaskInfo
func (*GetTasksReply) ProtoMessage ¶
func (*GetTasksReply) ProtoMessage()
func (*GetTasksReply) ProtoReflect ¶ added in v0.19.90
func (x *GetTasksReply) ProtoReflect() protoreflect.Message
func (*GetTasksReply) Reset ¶
func (x *GetTasksReply) Reset()
func (*GetTasksReply) String ¶
func (x *GetTasksReply) String() string
type GetTasksRequest ¶
type GetTasksRequest struct {
// contains filtered or unexported fields
}
func (*GetTasksRequest) Descriptor
deprecated
func (*GetTasksRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTasksRequest.ProtoReflect.Descriptor instead.
func (*GetTasksRequest) ProtoMessage ¶
func (*GetTasksRequest) ProtoMessage()
func (*GetTasksRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetTasksRequest) ProtoReflect() protoreflect.Message
func (*GetTasksRequest) Reset ¶
func (x *GetTasksRequest) Reset()
func (*GetTasksRequest) String ¶
func (x *GetTasksRequest) String() string
type GetWorkflowTemplatesReply ¶
type GetWorkflowTemplatesReply struct { WorkflowTemplates []*WorkflowTemplateInfo `protobuf:"bytes,1,rep,name=workflowTemplates,proto3" json:"workflowTemplates,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowTemplatesReply) Descriptor
deprecated
func (*GetWorkflowTemplatesReply) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowTemplatesReply.ProtoReflect.Descriptor instead.
func (*GetWorkflowTemplatesReply) GetWorkflowTemplates ¶
func (x *GetWorkflowTemplatesReply) GetWorkflowTemplates() []*WorkflowTemplateInfo
func (*GetWorkflowTemplatesReply) ProtoMessage ¶
func (*GetWorkflowTemplatesReply) ProtoMessage()
func (*GetWorkflowTemplatesReply) ProtoReflect ¶ added in v0.19.90
func (x *GetWorkflowTemplatesReply) ProtoReflect() protoreflect.Message
func (*GetWorkflowTemplatesReply) Reset ¶
func (x *GetWorkflowTemplatesReply) Reset()
func (*GetWorkflowTemplatesReply) String ¶
func (x *GetWorkflowTemplatesReply) String() string
type GetWorkflowTemplatesRequest ¶
type GetWorkflowTemplatesRequest struct { RepoPattern string `protobuf:"bytes,1,opt,name=repoPattern,proto3" json:"repoPattern,omitempty"` RevisionPattern string `protobuf:"bytes,2,opt,name=revisionPattern,proto3" json:"revisionPattern,omitempty"` AllBranches bool `protobuf:"varint,3,opt,name=allBranches,proto3" json:"allBranches,omitempty"` AllTags bool `protobuf:"varint,4,opt,name=allTags,proto3" json:"allTags,omitempty"` AllWorkflows bool `protobuf:"varint,5,opt,name=allWorkflows,proto3" json:"allWorkflows,omitempty"` // contains filtered or unexported fields }
func (*GetWorkflowTemplatesRequest) Descriptor
deprecated
func (*GetWorkflowTemplatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetWorkflowTemplatesRequest.ProtoReflect.Descriptor instead.
func (*GetWorkflowTemplatesRequest) GetAllBranches ¶ added in v0.11.0
func (x *GetWorkflowTemplatesRequest) GetAllBranches() bool
func (*GetWorkflowTemplatesRequest) GetAllTags ¶ added in v0.11.0
func (x *GetWorkflowTemplatesRequest) GetAllTags() bool
func (*GetWorkflowTemplatesRequest) GetAllWorkflows ¶ added in v0.22.80
func (x *GetWorkflowTemplatesRequest) GetAllWorkflows() bool
func (*GetWorkflowTemplatesRequest) GetRepoPattern ¶ added in v0.11.0
func (x *GetWorkflowTemplatesRequest) GetRepoPattern() string
func (*GetWorkflowTemplatesRequest) GetRevisionPattern ¶ added in v0.11.0
func (x *GetWorkflowTemplatesRequest) GetRevisionPattern() string
func (*GetWorkflowTemplatesRequest) ProtoMessage ¶
func (*GetWorkflowTemplatesRequest) ProtoMessage()
func (*GetWorkflowTemplatesRequest) ProtoReflect ¶ added in v0.19.90
func (x *GetWorkflowTemplatesRequest) ProtoReflect() protoreflect.Message
func (*GetWorkflowTemplatesRequest) Reset ¶
func (x *GetWorkflowTemplatesRequest) Reset()
func (*GetWorkflowTemplatesRequest) String ¶
func (x *GetWorkflowTemplatesRequest) String() string
type IntegratedServiceInfo ¶ added in v0.22.80
type IntegratedServiceInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // user-visible service name, e.g. "DD scheduler" Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"` Endpoint string `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"` ConnectionState string `protobuf:"bytes,4,opt,name=connectionState,proto3" json:"connectionState,omitempty"` // allowed values: READY, CONNECTING, TRANSIENT_FAILURE, IDLE, SHUTDOWN Data string `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` // always a JSON payload with a map<string, string> inside. // contains filtered or unexported fields }
func (*IntegratedServiceInfo) Descriptor
deprecated
added in
v0.22.80
func (*IntegratedServiceInfo) Descriptor() ([]byte, []int)
Deprecated: Use IntegratedServiceInfo.ProtoReflect.Descriptor instead.
func (*IntegratedServiceInfo) GetConnectionState ¶ added in v0.22.80
func (x *IntegratedServiceInfo) GetConnectionState() string
func (*IntegratedServiceInfo) GetData ¶ added in v0.22.80
func (x *IntegratedServiceInfo) GetData() string
func (*IntegratedServiceInfo) GetEnabled ¶ added in v0.22.80
func (x *IntegratedServiceInfo) GetEnabled() bool
func (*IntegratedServiceInfo) GetEndpoint ¶ added in v0.22.80
func (x *IntegratedServiceInfo) GetEndpoint() string
func (*IntegratedServiceInfo) GetName ¶ added in v0.22.80
func (x *IntegratedServiceInfo) GetName() string
func (*IntegratedServiceInfo) ProtoMessage ¶ added in v0.22.80
func (*IntegratedServiceInfo) ProtoMessage()
func (*IntegratedServiceInfo) ProtoReflect ¶ added in v0.22.80
func (x *IntegratedServiceInfo) ProtoReflect() protoreflect.Message
func (*IntegratedServiceInfo) Reset ¶ added in v0.22.80
func (x *IntegratedServiceInfo) Reset()
func (*IntegratedServiceInfo) String ¶ added in v0.22.80
func (x *IntegratedServiceInfo) String() string
type ListIntegratedServicesReply ¶ added in v0.22.80
type ListIntegratedServicesReply struct { Services map[string]*IntegratedServiceInfo `` // keys are IDs (e.g. "ddsched"), the service name should be displayed to users instead /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListIntegratedServicesReply) Descriptor
deprecated
added in
v0.22.80
func (*ListIntegratedServicesReply) Descriptor() ([]byte, []int)
Deprecated: Use ListIntegratedServicesReply.ProtoReflect.Descriptor instead.
func (*ListIntegratedServicesReply) GetServices ¶ added in v0.22.80
func (x *ListIntegratedServicesReply) GetServices() map[string]*IntegratedServiceInfo
func (*ListIntegratedServicesReply) ProtoMessage ¶ added in v0.22.80
func (*ListIntegratedServicesReply) ProtoMessage()
func (*ListIntegratedServicesReply) ProtoReflect ¶ added in v0.22.80
func (x *ListIntegratedServicesReply) ProtoReflect() protoreflect.Message
func (*ListIntegratedServicesReply) Reset ¶ added in v0.22.80
func (x *ListIntegratedServicesReply) Reset()
func (*ListIntegratedServicesReply) String ¶ added in v0.22.80
func (x *ListIntegratedServicesReply) String() string
type ListReposReply ¶ added in v0.10.0
type ListReposReply struct { Repos []*RepoInfo `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"` GlobalDefaultRevision string `protobuf:"bytes,2,opt,name=globalDefaultRevision,proto3" json:"globalDefaultRevision,omitempty"` // contains filtered or unexported fields }
func (*ListReposReply) Descriptor
deprecated
added in
v0.10.0
func (*ListReposReply) Descriptor() ([]byte, []int)
Deprecated: Use ListReposReply.ProtoReflect.Descriptor instead.
func (*ListReposReply) GetGlobalDefaultRevision ¶ added in v0.12.90
func (x *ListReposReply) GetGlobalDefaultRevision() string
func (*ListReposReply) GetRepos ¶ added in v0.10.0
func (x *ListReposReply) GetRepos() []*RepoInfo
func (*ListReposReply) ProtoMessage ¶ added in v0.10.0
func (*ListReposReply) ProtoMessage()
func (*ListReposReply) ProtoReflect ¶ added in v0.19.90
func (x *ListReposReply) ProtoReflect() protoreflect.Message
func (*ListReposReply) Reset ¶ added in v0.10.0
func (x *ListReposReply) Reset()
func (*ListReposReply) String ¶ added in v0.10.0
func (x *ListReposReply) String() string
type ListReposRequest ¶ added in v0.10.0
type ListReposRequest struct { GetRevisions bool `protobuf:"varint,1,opt,name=getRevisions,proto3" json:"getRevisions,omitempty"` // contains filtered or unexported fields }
func (*ListReposRequest) Descriptor
deprecated
added in
v0.10.0
func (*ListReposRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListReposRequest.ProtoReflect.Descriptor instead.
func (*ListReposRequest) GetGetRevisions ¶ added in v0.23.80
func (x *ListReposRequest) GetGetRevisions() bool
func (*ListReposRequest) ProtoMessage ¶ added in v0.10.0
func (*ListReposRequest) ProtoMessage()
func (*ListReposRequest) ProtoReflect ¶ added in v0.19.90
func (x *ListReposRequest) ProtoReflect() protoreflect.Message
func (*ListReposRequest) Reset ¶ added in v0.10.0
func (x *ListReposRequest) Reset()
func (*ListReposRequest) String ¶ added in v0.10.0
func (x *ListReposRequest) String() string
type ModifyEnvironmentReply ¶
type ModifyEnvironmentReply struct { FailedOperations []*EnvironmentOperation `protobuf:"bytes,1,rep,name=failedOperations,proto3" json:"failedOperations,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*ModifyEnvironmentReply) Descriptor
deprecated
func (*ModifyEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use ModifyEnvironmentReply.ProtoReflect.Descriptor instead.
func (*ModifyEnvironmentReply) GetFailedOperations ¶
func (x *ModifyEnvironmentReply) GetFailedOperations() []*EnvironmentOperation
func (*ModifyEnvironmentReply) GetId ¶
func (x *ModifyEnvironmentReply) GetId() string
func (*ModifyEnvironmentReply) GetState ¶
func (x *ModifyEnvironmentReply) GetState() string
func (*ModifyEnvironmentReply) ProtoMessage ¶
func (*ModifyEnvironmentReply) ProtoMessage()
func (*ModifyEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *ModifyEnvironmentReply) ProtoReflect() protoreflect.Message
func (*ModifyEnvironmentReply) Reset ¶
func (x *ModifyEnvironmentReply) Reset()
func (*ModifyEnvironmentReply) String ¶
func (x *ModifyEnvironmentReply) String() string
type ModifyEnvironmentRequest ¶
type ModifyEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Operations []*EnvironmentOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"` ReconfigureAll bool `protobuf:"varint,3,opt,name=reconfigureAll,proto3" json:"reconfigureAll,omitempty"` // contains filtered or unexported fields }
func (*ModifyEnvironmentRequest) Descriptor
deprecated
func (*ModifyEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use ModifyEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*ModifyEnvironmentRequest) GetId ¶
func (x *ModifyEnvironmentRequest) GetId() string
func (*ModifyEnvironmentRequest) GetOperations ¶
func (x *ModifyEnvironmentRequest) GetOperations() []*EnvironmentOperation
func (*ModifyEnvironmentRequest) GetReconfigureAll ¶
func (x *ModifyEnvironmentRequest) GetReconfigureAll() bool
func (*ModifyEnvironmentRequest) ProtoMessage ¶
func (*ModifyEnvironmentRequest) ProtoMessage()
func (*ModifyEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *ModifyEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*ModifyEnvironmentRequest) Reset ¶
func (x *ModifyEnvironmentRequest) Reset()
func (*ModifyEnvironmentRequest) String ¶
func (x *ModifyEnvironmentRequest) String() string
type NewAutoEnvironmentReply ¶ added in v0.19.80
type NewAutoEnvironmentReply struct {
// contains filtered or unexported fields
}
func (*NewAutoEnvironmentReply) Descriptor
deprecated
added in
v0.19.80
func (*NewAutoEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use NewAutoEnvironmentReply.ProtoReflect.Descriptor instead.
func (*NewAutoEnvironmentReply) ProtoMessage ¶ added in v0.19.80
func (*NewAutoEnvironmentReply) ProtoMessage()
func (*NewAutoEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *NewAutoEnvironmentReply) ProtoReflect() protoreflect.Message
func (*NewAutoEnvironmentReply) Reset ¶ added in v0.19.80
func (x *NewAutoEnvironmentReply) Reset()
func (*NewAutoEnvironmentReply) String ¶ added in v0.19.80
func (x *NewAutoEnvironmentReply) String() string
type NewAutoEnvironmentRequest ¶ added in v0.19.80
type NewAutoEnvironmentRequest struct { WorkflowTemplate string `protobuf:"bytes,1,opt,name=workflowTemplate,proto3" json:"workflowTemplate,omitempty"` Vars map[string]string `` /* 149-byte string literal not displayed */ Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NewAutoEnvironmentRequest) Descriptor
deprecated
added in
v0.19.80
func (*NewAutoEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewAutoEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*NewAutoEnvironmentRequest) GetId ¶ added in v0.19.80
func (x *NewAutoEnvironmentRequest) GetId() string
func (*NewAutoEnvironmentRequest) GetVars ¶ added in v0.19.80
func (x *NewAutoEnvironmentRequest) GetVars() map[string]string
func (*NewAutoEnvironmentRequest) GetWorkflowTemplate ¶ added in v0.19.80
func (x *NewAutoEnvironmentRequest) GetWorkflowTemplate() string
func (*NewAutoEnvironmentRequest) ProtoMessage ¶ added in v0.19.80
func (*NewAutoEnvironmentRequest) ProtoMessage()
func (*NewAutoEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *NewAutoEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*NewAutoEnvironmentRequest) Reset ¶ added in v0.19.80
func (x *NewAutoEnvironmentRequest) Reset()
func (*NewAutoEnvironmentRequest) String ¶ added in v0.19.80
func (x *NewAutoEnvironmentRequest) String() string
type NewEnvironmentReply ¶
type NewEnvironmentReply struct { Environment *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` Public bool `protobuf:"varint,2,opt,name=public,proto3" json:"public,omitempty"` // contains filtered or unexported fields }
func (*NewEnvironmentReply) Descriptor
deprecated
func (*NewEnvironmentReply) Descriptor() ([]byte, []int)
Deprecated: Use NewEnvironmentReply.ProtoReflect.Descriptor instead.
func (*NewEnvironmentReply) GetEnvironment ¶
func (x *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo
func (*NewEnvironmentReply) GetPublic ¶ added in v0.25.0
func (x *NewEnvironmentReply) GetPublic() bool
func (*NewEnvironmentReply) ProtoMessage ¶
func (*NewEnvironmentReply) ProtoMessage()
func (*NewEnvironmentReply) ProtoReflect ¶ added in v0.19.90
func (x *NewEnvironmentReply) ProtoReflect() protoreflect.Message
func (*NewEnvironmentReply) Reset ¶
func (x *NewEnvironmentReply) Reset()
func (*NewEnvironmentReply) String ¶
func (x *NewEnvironmentReply) String() string
type NewEnvironmentRequest ¶
type NewEnvironmentRequest struct { WorkflowTemplate string `protobuf:"bytes,1,opt,name=workflowTemplate,proto3" json:"workflowTemplate,omitempty"` Vars map[string]string `` /* 149-byte string literal not displayed */ Public bool `protobuf:"varint,3,opt,name=public,proto3" json:"public,omitempty"` // contains filtered or unexported fields }
func (*NewEnvironmentRequest) Descriptor
deprecated
func (*NewEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*NewEnvironmentRequest) GetPublic ¶ added in v0.25.0
func (x *NewEnvironmentRequest) GetPublic() bool
func (*NewEnvironmentRequest) GetVars ¶ added in v0.12.90
func (x *NewEnvironmentRequest) GetVars() map[string]string
func (*NewEnvironmentRequest) GetWorkflowTemplate ¶
func (x *NewEnvironmentRequest) GetWorkflowTemplate() string
func (*NewEnvironmentRequest) ProtoMessage ¶
func (*NewEnvironmentRequest) ProtoMessage()
func (*NewEnvironmentRequest) ProtoReflect ¶ added in v0.19.90
func (x *NewEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*NewEnvironmentRequest) Reset ¶
func (x *NewEnvironmentRequest) Reset()
func (*NewEnvironmentRequest) String ¶
func (x *NewEnvironmentRequest) String() string
type RefreshReposRequest ¶ added in v0.10.0
type RefreshReposRequest struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` // contains filtered or unexported fields }
func (*RefreshReposRequest) Descriptor
deprecated
added in
v0.10.0
func (*RefreshReposRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshReposRequest.ProtoReflect.Descriptor instead.
func (*RefreshReposRequest) GetIndex ¶ added in v0.10.0
func (x *RefreshReposRequest) GetIndex() int32
func (*RefreshReposRequest) ProtoMessage ¶ added in v0.10.0
func (*RefreshReposRequest) ProtoMessage()
func (*RefreshReposRequest) ProtoReflect ¶ added in v0.19.90
func (x *RefreshReposRequest) ProtoReflect() protoreflect.Message
func (*RefreshReposRequest) Reset ¶ added in v0.10.0
func (x *RefreshReposRequest) Reset()
func (*RefreshReposRequest) String ¶ added in v0.10.0
func (x *RefreshReposRequest) String() string
type RemoveRepoReply ¶ added in v0.10.0
type RemoveRepoReply struct { NewDefaultRepo string `protobuf:"bytes,1,opt,name=newDefaultRepo,proto3" json:"newDefaultRepo,omitempty"` // contains filtered or unexported fields }
func (*RemoveRepoReply) Descriptor
deprecated
added in
v0.10.0
func (*RemoveRepoReply) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRepoReply.ProtoReflect.Descriptor instead.
func (*RemoveRepoReply) GetNewDefaultRepo ¶ added in v0.10.0
func (x *RemoveRepoReply) GetNewDefaultRepo() string
func (*RemoveRepoReply) ProtoMessage ¶ added in v0.10.0
func (*RemoveRepoReply) ProtoMessage()
func (*RemoveRepoReply) ProtoReflect ¶ added in v0.19.90
func (x *RemoveRepoReply) ProtoReflect() protoreflect.Message
func (*RemoveRepoReply) Reset ¶ added in v0.10.0
func (x *RemoveRepoReply) Reset()
func (*RemoveRepoReply) String ¶ added in v0.10.0
func (x *RemoveRepoReply) String() string
type RemoveRepoRequest ¶ added in v0.10.0
type RemoveRepoRequest struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` // contains filtered or unexported fields }
func (*RemoveRepoRequest) Descriptor
deprecated
added in
v0.10.0
func (*RemoveRepoRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRepoRequest.ProtoReflect.Descriptor instead.
func (*RemoveRepoRequest) GetIndex ¶ added in v0.10.0
func (x *RemoveRepoRequest) GetIndex() int32
func (*RemoveRepoRequest) ProtoMessage ¶ added in v0.10.0
func (*RemoveRepoRequest) ProtoMessage()
func (*RemoveRepoRequest) ProtoReflect ¶ added in v0.19.90
func (x *RemoveRepoRequest) ProtoReflect() protoreflect.Message
func (*RemoveRepoRequest) Reset ¶ added in v0.10.0
func (x *RemoveRepoRequest) Reset()
func (*RemoveRepoRequest) String ¶ added in v0.10.0
func (x *RemoveRepoRequest) String() string
type RepoInfo ¶ added in v0.10.0
type RepoInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Default bool `protobuf:"varint,2,opt,name=default,proto3" json:"default,omitempty"` DefaultRevision string `protobuf:"bytes,3,opt,name=defaultRevision,proto3" json:"defaultRevision,omitempty"` Revisions []string `protobuf:"bytes,4,rep,name=revisions,proto3" json:"revisions,omitempty"` // contains filtered or unexported fields }
func (*RepoInfo) Descriptor
deprecated
added in
v0.10.0
func (*RepoInfo) GetDefault ¶ added in v0.10.0
func (*RepoInfo) GetDefaultRevision ¶ added in v0.12.90
func (*RepoInfo) GetRevisions ¶ added in v0.23.80
func (*RepoInfo) ProtoMessage ¶ added in v0.10.0
func (*RepoInfo) ProtoMessage()
func (*RepoInfo) ProtoReflect ¶ added in v0.19.90
func (x *RepoInfo) ProtoReflect() protoreflect.Message
type RoleInfo ¶
type RoleInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` FullPath string `protobuf:"bytes,4,opt,name=fullPath,proto3" json:"fullPath,omitempty"` TaskIds []string `protobuf:"bytes,5,rep,name=taskIds,proto3" json:"taskIds,omitempty"` Roles []*RoleInfo `protobuf:"bytes,6,rep,name=roles,proto3" json:"roles,omitempty"` Defaults map[string]string `` /* 157-byte string literal not displayed */ Vars map[string]string `` /* 149-byte string literal not displayed */ UserVars map[string]string `` /* 157-byte string literal not displayed */ ConsolidatedStack map[string]string `` /* 176-byte string literal not displayed */ Description string `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
func (*RoleInfo) Descriptor
deprecated
func (*RoleInfo) GetConsolidatedStack ¶ added in v0.20.2
func (*RoleInfo) GetDefaults ¶ added in v0.12.90
func (*RoleInfo) GetDescription ¶ added in v0.37.0
func (*RoleInfo) GetFullPath ¶
func (*RoleInfo) GetTaskIds ¶
func (*RoleInfo) GetUserVars ¶ added in v0.12.90
func (*RoleInfo) ProtoMessage ¶
func (*RoleInfo) ProtoMessage()
func (*RoleInfo) ProtoReflect ¶ added in v0.19.90
func (x *RoleInfo) ProtoReflect() protoreflect.Message
type SetDefaultRepoRequest ¶ added in v0.10.0
type SetDefaultRepoRequest struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` // contains filtered or unexported fields }
func (*SetDefaultRepoRequest) Descriptor
deprecated
added in
v0.10.0
func (*SetDefaultRepoRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetDefaultRepoRequest.ProtoReflect.Descriptor instead.
func (*SetDefaultRepoRequest) GetIndex ¶ added in v0.10.0
func (x *SetDefaultRepoRequest) GetIndex() int32
func (*SetDefaultRepoRequest) ProtoMessage ¶ added in v0.10.0
func (*SetDefaultRepoRequest) ProtoMessage()
func (*SetDefaultRepoRequest) ProtoReflect ¶ added in v0.19.90
func (x *SetDefaultRepoRequest) ProtoReflect() protoreflect.Message
func (*SetDefaultRepoRequest) Reset ¶ added in v0.10.0
func (x *SetDefaultRepoRequest) Reset()
func (*SetDefaultRepoRequest) String ¶ added in v0.10.0
func (x *SetDefaultRepoRequest) String() string
type SetEnvironmentPropertiesReply ¶ added in v0.12.90
type SetEnvironmentPropertiesReply struct {
// contains filtered or unexported fields
}
func (*SetEnvironmentPropertiesReply) Descriptor
deprecated
added in
v0.12.90
func (*SetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)
Deprecated: Use SetEnvironmentPropertiesReply.ProtoReflect.Descriptor instead.
func (*SetEnvironmentPropertiesReply) ProtoMessage ¶ added in v0.12.90
func (*SetEnvironmentPropertiesReply) ProtoMessage()
func (*SetEnvironmentPropertiesReply) ProtoReflect ¶ added in v0.19.90
func (x *SetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message
func (*SetEnvironmentPropertiesReply) Reset ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesReply) Reset()
func (*SetEnvironmentPropertiesReply) String ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesReply) String() string
type SetEnvironmentPropertiesRequest ¶ added in v0.12.90
type SetEnvironmentPropertiesRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // If properties == nil, the core sets nothing // and reply ok Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
////////////////////////////////////// Environment, GET/SET properties //////////////////////////////////////
func (*SetEnvironmentPropertiesRequest) Descriptor
deprecated
added in
v0.12.90
func (*SetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetEnvironmentPropertiesRequest.ProtoReflect.Descriptor instead.
func (*SetEnvironmentPropertiesRequest) GetId ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesRequest) GetId() string
func (*SetEnvironmentPropertiesRequest) GetProperties ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesRequest) GetProperties() map[string]string
func (*SetEnvironmentPropertiesRequest) ProtoMessage ¶ added in v0.12.90
func (*SetEnvironmentPropertiesRequest) ProtoMessage()
func (*SetEnvironmentPropertiesRequest) ProtoReflect ¶ added in v0.19.90
func (x *SetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message
func (*SetEnvironmentPropertiesRequest) Reset ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesRequest) Reset()
func (*SetEnvironmentPropertiesRequest) String ¶ added in v0.12.90
func (x *SetEnvironmentPropertiesRequest) String() string
type SetGlobalDefaultRevisionRequest ¶ added in v0.12.90
type SetGlobalDefaultRevisionRequest struct { Revision string `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"` // contains filtered or unexported fields }
func (*SetGlobalDefaultRevisionRequest) Descriptor
deprecated
added in
v0.12.90
func (*SetGlobalDefaultRevisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetGlobalDefaultRevisionRequest.ProtoReflect.Descriptor instead.
func (*SetGlobalDefaultRevisionRequest) GetRevision ¶ added in v0.12.90
func (x *SetGlobalDefaultRevisionRequest) GetRevision() string
func (*SetGlobalDefaultRevisionRequest) ProtoMessage ¶ added in v0.12.90
func (*SetGlobalDefaultRevisionRequest) ProtoMessage()
func (*SetGlobalDefaultRevisionRequest) ProtoReflect ¶ added in v0.19.90
func (x *SetGlobalDefaultRevisionRequest) ProtoReflect() protoreflect.Message
func (*SetGlobalDefaultRevisionRequest) Reset ¶ added in v0.12.90
func (x *SetGlobalDefaultRevisionRequest) Reset()
func (*SetGlobalDefaultRevisionRequest) String ¶ added in v0.12.90
func (x *SetGlobalDefaultRevisionRequest) String() string
type SetRepoDefaultRevisionReply ¶ added in v0.12.90
type SetRepoDefaultRevisionReply struct { Info string `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*SetRepoDefaultRevisionReply) Descriptor
deprecated
added in
v0.12.90
func (*SetRepoDefaultRevisionReply) Descriptor() ([]byte, []int)
Deprecated: Use SetRepoDefaultRevisionReply.ProtoReflect.Descriptor instead.
func (*SetRepoDefaultRevisionReply) GetInfo ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionReply) GetInfo() string
func (*SetRepoDefaultRevisionReply) ProtoMessage ¶ added in v0.12.90
func (*SetRepoDefaultRevisionReply) ProtoMessage()
func (*SetRepoDefaultRevisionReply) ProtoReflect ¶ added in v0.19.90
func (x *SetRepoDefaultRevisionReply) ProtoReflect() protoreflect.Message
func (*SetRepoDefaultRevisionReply) Reset ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionReply) Reset()
func (*SetRepoDefaultRevisionReply) String ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionReply) String() string
type SetRepoDefaultRevisionRequest ¶ added in v0.12.90
type SetRepoDefaultRevisionRequest struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"` // contains filtered or unexported fields }
func (*SetRepoDefaultRevisionRequest) Descriptor
deprecated
added in
v0.12.90
func (*SetRepoDefaultRevisionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRepoDefaultRevisionRequest.ProtoReflect.Descriptor instead.
func (*SetRepoDefaultRevisionRequest) GetIndex ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionRequest) GetIndex() int32
func (*SetRepoDefaultRevisionRequest) GetRevision ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionRequest) GetRevision() string
func (*SetRepoDefaultRevisionRequest) ProtoMessage ¶ added in v0.12.90
func (*SetRepoDefaultRevisionRequest) ProtoMessage()
func (*SetRepoDefaultRevisionRequest) ProtoReflect ¶ added in v0.19.90
func (x *SetRepoDefaultRevisionRequest) ProtoReflect() protoreflect.Message
func (*SetRepoDefaultRevisionRequest) Reset ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionRequest) Reset()
func (*SetRepoDefaultRevisionRequest) String ¶ added in v0.12.90
func (x *SetRepoDefaultRevisionRequest) String() string
type ShortTaskInfo ¶
type ShortTaskInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Locked bool `protobuf:"varint,2,opt,name=locked,proto3" json:"locked,omitempty"` TaskId string `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"` Status string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"` State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"` ClassName string `protobuf:"bytes,6,opt,name=className,proto3" json:"className,omitempty"` DeploymentInfo *TaskDeploymentInfo `protobuf:"bytes,7,opt,name=deploymentInfo,proto3" json:"deploymentInfo,omitempty"` Pid string `protobuf:"bytes,8,opt,name=pid,proto3" json:"pid,omitempty"` SandboxStdout string `protobuf:"bytes,9,opt,name=sandboxStdout,proto3" json:"sandboxStdout,omitempty"` Claimable bool `protobuf:"varint,10,opt,name=claimable,proto3" json:"claimable,omitempty"` // contains filtered or unexported fields }
////////////////////////////////////// Tasks //////////////////////////////////////
func (*ShortTaskInfo) Descriptor
deprecated
func (*ShortTaskInfo) Descriptor() ([]byte, []int)
Deprecated: Use ShortTaskInfo.ProtoReflect.Descriptor instead.
func (*ShortTaskInfo) GetClaimable ¶ added in v0.47.0
func (x *ShortTaskInfo) GetClaimable() bool
func (*ShortTaskInfo) GetClassName ¶
func (x *ShortTaskInfo) GetClassName() string
func (*ShortTaskInfo) GetDeploymentInfo ¶
func (x *ShortTaskInfo) GetDeploymentInfo() *TaskDeploymentInfo
func (*ShortTaskInfo) GetLocked ¶
func (x *ShortTaskInfo) GetLocked() bool
func (*ShortTaskInfo) GetName ¶
func (x *ShortTaskInfo) GetName() string
func (*ShortTaskInfo) GetPid ¶ added in v0.14.91
func (x *ShortTaskInfo) GetPid() string
func (*ShortTaskInfo) GetSandboxStdout ¶ added in v0.19.80
func (x *ShortTaskInfo) GetSandboxStdout() string
func (*ShortTaskInfo) GetState ¶
func (x *ShortTaskInfo) GetState() string
func (*ShortTaskInfo) GetStatus ¶
func (x *ShortTaskInfo) GetStatus() string
func (*ShortTaskInfo) GetTaskId ¶
func (x *ShortTaskInfo) GetTaskId() string
func (*ShortTaskInfo) ProtoMessage ¶
func (*ShortTaskInfo) ProtoMessage()
func (*ShortTaskInfo) ProtoReflect ¶ added in v0.19.90
func (x *ShortTaskInfo) ProtoReflect() protoreflect.Message
func (*ShortTaskInfo) Reset ¶
func (x *ShortTaskInfo) Reset()
func (*ShortTaskInfo) String ¶
func (x *ShortTaskInfo) String() string
type StatusReply ¶
type StatusReply struct { State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` StatusUpdates []*StatusUpdate `protobuf:"bytes,2,rep,name=statusUpdates,proto3" json:"statusUpdates,omitempty"` // contains filtered or unexported fields }
func (*StatusReply) Descriptor
deprecated
func (*StatusReply) Descriptor() ([]byte, []int)
Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.
func (*StatusReply) GetState ¶
func (x *StatusReply) GetState() string
func (*StatusReply) GetStatusUpdates ¶
func (x *StatusReply) GetStatusUpdates() []*StatusUpdate
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) ProtoReflect ¶ added in v0.19.90
func (x *StatusReply) ProtoReflect() protoreflect.Message
func (*StatusReply) Reset ¶
func (x *StatusReply) Reset()
func (*StatusReply) String ¶
func (x *StatusReply) String() string
type StatusRequest ¶
type StatusRequest struct {
// contains filtered or unexported fields
}
////////////////////////////////////// Global status //////////////////////////////////////
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶ added in v0.19.90
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusUpdate ¶
type StatusUpdate struct { Level StatusUpdate_Level `protobuf:"varint,1,opt,name=level,proto3,enum=o2control.StatusUpdate_Level" json:"level,omitempty"` // Types that are assignable to Event: // *StatusUpdate_MesosHeartbeat Event isStatusUpdate_Event `protobuf_oneof:"Event"` // contains filtered or unexported fields }
func (*StatusUpdate) Descriptor
deprecated
func (*StatusUpdate) Descriptor() ([]byte, []int)
Deprecated: Use StatusUpdate.ProtoReflect.Descriptor instead.
func (*StatusUpdate) GetEvent ¶
func (m *StatusUpdate) GetEvent() isStatusUpdate_Event
func (*StatusUpdate) GetLevel ¶
func (x *StatusUpdate) GetLevel() StatusUpdate_Level
func (*StatusUpdate) GetMesosHeartbeat ¶
func (x *StatusUpdate) GetMesosHeartbeat() *Event_MesosHeartbeat
func (*StatusUpdate) ProtoMessage ¶
func (*StatusUpdate) ProtoMessage()
func (*StatusUpdate) ProtoReflect ¶ added in v0.19.90
func (x *StatusUpdate) ProtoReflect() protoreflect.Message
func (*StatusUpdate) Reset ¶
func (x *StatusUpdate) Reset()
func (*StatusUpdate) String ¶
func (x *StatusUpdate) String() string
type StatusUpdate_Level ¶
type StatusUpdate_Level int32
const ( StatusUpdate_DEBUG StatusUpdate_Level = 0 StatusUpdate_INFO StatusUpdate_Level = 1 StatusUpdate_WARNING StatusUpdate_Level = 2 StatusUpdate_ERROR StatusUpdate_Level = 3 )
func (StatusUpdate_Level) Descriptor ¶ added in v0.19.90
func (StatusUpdate_Level) Descriptor() protoreflect.EnumDescriptor
func (StatusUpdate_Level) Enum ¶ added in v0.19.90
func (x StatusUpdate_Level) Enum() *StatusUpdate_Level
func (StatusUpdate_Level) EnumDescriptor
deprecated
func (StatusUpdate_Level) EnumDescriptor() ([]byte, []int)
Deprecated: Use StatusUpdate_Level.Descriptor instead.
func (StatusUpdate_Level) Number ¶ added in v0.19.90
func (x StatusUpdate_Level) Number() protoreflect.EnumNumber
func (StatusUpdate_Level) String ¶
func (x StatusUpdate_Level) String() string
func (StatusUpdate_Level) Type ¶ added in v0.19.90
func (StatusUpdate_Level) Type() protoreflect.EnumType
type StatusUpdate_MesosHeartbeat ¶
type StatusUpdate_MesosHeartbeat struct {
MesosHeartbeat *Event_MesosHeartbeat `protobuf:"bytes,2,opt,name=mesosHeartbeat,proto3,oneof"` //TODO add other events here and in events.proto
}
type SubscribeRequest ¶ added in v0.14.4
type SubscribeRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
added in
v0.14.4
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetId ¶ added in v0.19.80
func (x *SubscribeRequest) GetId() string
func (*SubscribeRequest) ProtoMessage ¶ added in v0.14.4
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶ added in v0.19.90
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶ added in v0.14.4
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶ added in v0.14.4
func (x *SubscribeRequest) String() string
type TaskClassInfo ¶
type TaskClassInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ControlMode string `protobuf:"bytes,2,opt,name=controlMode,proto3" json:"controlMode,omitempty"` // contains filtered or unexported fields }
func (*TaskClassInfo) Descriptor
deprecated
func (*TaskClassInfo) Descriptor() ([]byte, []int)
Deprecated: Use TaskClassInfo.ProtoReflect.Descriptor instead.
func (*TaskClassInfo) GetControlMode ¶
func (x *TaskClassInfo) GetControlMode() string
func (*TaskClassInfo) GetName ¶
func (x *TaskClassInfo) GetName() string
func (*TaskClassInfo) ProtoMessage ¶
func (*TaskClassInfo) ProtoMessage()
func (*TaskClassInfo) ProtoReflect ¶ added in v0.19.90
func (x *TaskClassInfo) ProtoReflect() protoreflect.Message
func (*TaskClassInfo) Reset ¶
func (x *TaskClassInfo) Reset()
func (*TaskClassInfo) String ¶
func (x *TaskClassInfo) String() string
type TaskDeploymentInfo ¶
type TaskDeploymentInfo struct { Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"` AgentId string `protobuf:"bytes,2,opt,name=agentId,proto3" json:"agentId,omitempty"` OfferId string `protobuf:"bytes,3,opt,name=offerId,proto3" json:"offerId,omitempty"` ExecutorId string `protobuf:"bytes,4,opt,name=executorId,proto3" json:"executorId,omitempty"` // contains filtered or unexported fields }
func (*TaskDeploymentInfo) Descriptor
deprecated
func (*TaskDeploymentInfo) Descriptor() ([]byte, []int)
Deprecated: Use TaskDeploymentInfo.ProtoReflect.Descriptor instead.
func (*TaskDeploymentInfo) GetAgentId ¶
func (x *TaskDeploymentInfo) GetAgentId() string
func (*TaskDeploymentInfo) GetExecutorId ¶
func (x *TaskDeploymentInfo) GetExecutorId() string
func (*TaskDeploymentInfo) GetHostname ¶
func (x *TaskDeploymentInfo) GetHostname() string
func (*TaskDeploymentInfo) GetOfferId ¶
func (x *TaskDeploymentInfo) GetOfferId() string
func (*TaskDeploymentInfo) ProtoMessage ¶
func (*TaskDeploymentInfo) ProtoMessage()
func (*TaskDeploymentInfo) ProtoReflect ¶ added in v0.19.90
func (x *TaskDeploymentInfo) ProtoReflect() protoreflect.Message
func (*TaskDeploymentInfo) Reset ¶
func (x *TaskDeploymentInfo) Reset()
func (*TaskDeploymentInfo) String ¶
func (x *TaskDeploymentInfo) String() string
type TaskInfo ¶
type TaskInfo struct { ShortInfo *ShortTaskInfo `protobuf:"bytes,1,opt,name=shortInfo,proto3" json:"shortInfo,omitempty"` ClassInfo *TaskClassInfo `protobuf:"bytes,2,opt,name=classInfo,proto3" json:"classInfo,omitempty"` InboundChannels []*ChannelInfo `protobuf:"bytes,3,rep,name=inboundChannels,proto3" json:"inboundChannels,omitempty"` OutboundChannels []*ChannelInfo `protobuf:"bytes,4,rep,name=outboundChannels,proto3" json:"outboundChannels,omitempty"` CommandInfo *CommandInfo `protobuf:"bytes,5,opt,name=commandInfo,proto3" json:"commandInfo,omitempty"` TaskPath string `protobuf:"bytes,6,opt,name=taskPath,proto3" json:"taskPath,omitempty"` EnvId string `protobuf:"bytes,7,opt,name=envId,proto3" json:"envId,omitempty"` Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TaskInfo) Descriptor
deprecated
func (*TaskInfo) GetClassInfo ¶
func (x *TaskInfo) GetClassInfo() *TaskClassInfo
func (*TaskInfo) GetCommandInfo ¶
func (x *TaskInfo) GetCommandInfo() *CommandInfo
func (*TaskInfo) GetInboundChannels ¶
func (x *TaskInfo) GetInboundChannels() []*ChannelInfo
func (*TaskInfo) GetOutboundChannels ¶
func (x *TaskInfo) GetOutboundChannels() []*ChannelInfo
func (*TaskInfo) GetProperties ¶ added in v0.12.90
func (*TaskInfo) GetShortInfo ¶
func (x *TaskInfo) GetShortInfo() *ShortTaskInfo
func (*TaskInfo) GetTaskPath ¶
func (*TaskInfo) ProtoMessage ¶
func (*TaskInfo) ProtoMessage()
func (*TaskInfo) ProtoReflect ¶ added in v0.19.90
func (x *TaskInfo) ProtoReflect() protoreflect.Message
type TeardownReply ¶
type TeardownReply struct {
// contains filtered or unexported fields
}
func (*TeardownReply) Descriptor
deprecated
func (*TeardownReply) Descriptor() ([]byte, []int)
Deprecated: Use TeardownReply.ProtoReflect.Descriptor instead.
func (*TeardownReply) ProtoMessage ¶
func (*TeardownReply) ProtoMessage()
func (*TeardownReply) ProtoReflect ¶ added in v0.19.90
func (x *TeardownReply) ProtoReflect() protoreflect.Message
func (*TeardownReply) Reset ¶
func (x *TeardownReply) Reset()
func (*TeardownReply) String ¶
func (x *TeardownReply) String() string
type TeardownRequest ¶
type TeardownRequest struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
Not implemented yet
func (*TeardownRequest) Descriptor
deprecated
func (*TeardownRequest) Descriptor() ([]byte, []int)
Deprecated: Use TeardownRequest.ProtoReflect.Descriptor instead.
func (*TeardownRequest) GetReason ¶
func (x *TeardownRequest) GetReason() string
func (*TeardownRequest) ProtoMessage ¶
func (*TeardownRequest) ProtoMessage()
func (*TeardownRequest) ProtoReflect ¶ added in v0.19.90
func (x *TeardownRequest) ProtoReflect() protoreflect.Message
func (*TeardownRequest) Reset ¶
func (x *TeardownRequest) Reset()
func (*TeardownRequest) String ¶
func (x *TeardownRequest) String() string
type UnimplementedControlServer ¶ added in v0.11.0
type UnimplementedControlServer struct { }
UnimplementedControlServer should be embedded to have forward compatible implementations.
func (UnimplementedControlServer) AddRepo ¶ added in v0.11.0
func (UnimplementedControlServer) AddRepo(context.Context, *AddRepoRequest) (*AddRepoReply, error)
func (UnimplementedControlServer) CleanupTasks ¶ added in v0.11.0
func (UnimplementedControlServer) CleanupTasks(context.Context, *CleanupTasksRequest) (*CleanupTasksReply, error)
func (UnimplementedControlServer) ControlEnvironment ¶ added in v0.11.0
func (UnimplementedControlServer) ControlEnvironment(context.Context, *ControlEnvironmentRequest) (*ControlEnvironmentReply, error)
func (UnimplementedControlServer) DestroyEnvironment ¶ added in v0.11.0
func (UnimplementedControlServer) DestroyEnvironment(context.Context, *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error)
func (UnimplementedControlServer) GetActiveDetectors ¶ added in v0.26.3
func (UnimplementedControlServer) GetActiveDetectors(context.Context, *Empty) (*GetActiveDetectorsReply, error)
func (UnimplementedControlServer) GetEnvironment ¶ added in v0.11.0
func (UnimplementedControlServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentReply, error)
func (UnimplementedControlServer) GetEnvironments ¶ added in v0.11.0
func (UnimplementedControlServer) GetEnvironments(context.Context, *GetEnvironmentsRequest) (*GetEnvironmentsReply, error)
func (UnimplementedControlServer) GetFrameworkInfo ¶ added in v0.11.0
func (UnimplementedControlServer) GetFrameworkInfo(context.Context, *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error)
func (UnimplementedControlServer) GetIntegratedServices ¶ added in v0.22.80
func (UnimplementedControlServer) GetIntegratedServices(context.Context, *Empty) (*ListIntegratedServicesReply, error)
func (UnimplementedControlServer) GetRoles ¶ added in v0.11.0
func (UnimplementedControlServer) GetRoles(context.Context, *GetRolesRequest) (*GetRolesReply, error)
func (UnimplementedControlServer) GetTask ¶ added in v0.11.0
func (UnimplementedControlServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)
func (UnimplementedControlServer) GetTasks ¶ added in v0.11.0
func (UnimplementedControlServer) GetTasks(context.Context, *GetTasksRequest) (*GetTasksReply, error)
func (UnimplementedControlServer) GetWorkflowTemplates ¶ added in v0.11.0
func (UnimplementedControlServer) GetWorkflowTemplates(context.Context, *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error)
func (UnimplementedControlServer) ListRepos ¶ added in v0.11.0
func (UnimplementedControlServer) ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
func (UnimplementedControlServer) ModifyEnvironment ¶ added in v0.11.0
func (UnimplementedControlServer) ModifyEnvironment(context.Context, *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error)
func (UnimplementedControlServer) NewAutoEnvironment ¶ added in v0.19.80
func (UnimplementedControlServer) NewAutoEnvironment(context.Context, *NewAutoEnvironmentRequest) (*NewAutoEnvironmentReply, error)
func (UnimplementedControlServer) NewEnvironment ¶ added in v0.11.0
func (UnimplementedControlServer) NewEnvironment(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)
func (UnimplementedControlServer) RefreshRepos ¶ added in v0.11.0
func (UnimplementedControlServer) RefreshRepos(context.Context, *RefreshReposRequest) (*Empty, error)
func (UnimplementedControlServer) RemoveRepo ¶ added in v0.11.0
func (UnimplementedControlServer) RemoveRepo(context.Context, *RemoveRepoRequest) (*RemoveRepoReply, error)
func (UnimplementedControlServer) SetDefaultRepo ¶ added in v0.11.0
func (UnimplementedControlServer) SetDefaultRepo(context.Context, *SetDefaultRepoRequest) (*Empty, error)
func (UnimplementedControlServer) SetGlobalDefaultRevision ¶ added in v0.12.90
func (UnimplementedControlServer) SetGlobalDefaultRevision(context.Context, *SetGlobalDefaultRevisionRequest) (*Empty, error)
func (UnimplementedControlServer) SetRepoDefaultRevision ¶ added in v0.12.90
func (UnimplementedControlServer) SetRepoDefaultRevision(context.Context, *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error)
func (UnimplementedControlServer) Subscribe ¶ added in v0.14.4
func (UnimplementedControlServer) Subscribe(*SubscribeRequest, Control_SubscribeServer) error
func (UnimplementedControlServer) Teardown ¶ added in v0.11.0
func (UnimplementedControlServer) Teardown(context.Context, *TeardownRequest) (*TeardownReply, error)
func (UnimplementedControlServer) TrackStatus ¶ added in v0.11.0
func (UnimplementedControlServer) TrackStatus(*StatusRequest, Control_TrackStatusServer) error
type UnsafeControlServer ¶ added in v0.19.90
type UnsafeControlServer interface {
// contains filtered or unexported methods
}
UnsafeControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServer will result in compilation errors.
type VarSpecMessage ¶ added in v0.22.80
type VarSpecMessage struct { DefaultValue string `protobuf:"bytes,1,opt,name=defaultValue,proto3" json:"defaultValue,omitempty"` Type VarSpecMessage_Type `protobuf:"varint,2,opt,name=type,proto3,enum=o2control.VarSpecMessage_Type" json:"type,omitempty"` Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` Widget VarSpecMessage_UiWidget `protobuf:"varint,5,opt,name=widget,proto3,enum=o2control.VarSpecMessage_UiWidget" json:"widget,omitempty"` Panel string `protobuf:"bytes,6,opt,name=panel,proto3" json:"panel,omitempty"` // hint for the UI on where to put or group the given variable input AllowedValues []string `protobuf:"bytes,7,rep,name=allowedValues,proto3" json:"allowedValues,omitempty"` // list of offered values from which to choose (only for some UiWidgets) Index int32 `protobuf:"varint,8,opt,name=index,proto3" json:"index,omitempty"` VisibleIf string `protobuf:"bytes,9,opt,name=visibleIf,proto3" json:"visibleIf,omitempty"` // JS expression that evaluates to bool EnabledIf string `protobuf:"bytes,10,opt,name=enabledIf,proto3" json:"enabledIf,omitempty"` // JS expression that evaluates to bool // contains filtered or unexported fields }
func (*VarSpecMessage) Descriptor
deprecated
added in
v0.22.80
func (*VarSpecMessage) Descriptor() ([]byte, []int)
Deprecated: Use VarSpecMessage.ProtoReflect.Descriptor instead.
func (*VarSpecMessage) GetAllowedValues ¶ added in v0.22.80
func (x *VarSpecMessage) GetAllowedValues() []string
func (*VarSpecMessage) GetDefaultValue ¶ added in v0.22.80
func (x *VarSpecMessage) GetDefaultValue() string
func (*VarSpecMessage) GetDescription ¶ added in v0.22.80
func (x *VarSpecMessage) GetDescription() string
func (*VarSpecMessage) GetEnabledIf ¶ added in v0.25.80
func (x *VarSpecMessage) GetEnabledIf() string
func (*VarSpecMessage) GetIndex ¶ added in v0.25.80
func (x *VarSpecMessage) GetIndex() int32
func (*VarSpecMessage) GetLabel ¶ added in v0.22.80
func (x *VarSpecMessage) GetLabel() string
func (*VarSpecMessage) GetPanel ¶ added in v0.22.80
func (x *VarSpecMessage) GetPanel() string
func (*VarSpecMessage) GetType ¶ added in v0.22.80
func (x *VarSpecMessage) GetType() VarSpecMessage_Type
func (*VarSpecMessage) GetVisibleIf ¶ added in v0.25.80
func (x *VarSpecMessage) GetVisibleIf() string
func (*VarSpecMessage) GetWidget ¶ added in v0.25.80
func (x *VarSpecMessage) GetWidget() VarSpecMessage_UiWidget
func (*VarSpecMessage) ProtoMessage ¶ added in v0.22.80
func (*VarSpecMessage) ProtoMessage()
func (*VarSpecMessage) ProtoReflect ¶ added in v0.22.80
func (x *VarSpecMessage) ProtoReflect() protoreflect.Message
func (*VarSpecMessage) Reset ¶ added in v0.22.80
func (x *VarSpecMessage) Reset()
func (*VarSpecMessage) String ¶ added in v0.22.80
func (x *VarSpecMessage) String() string
type VarSpecMessage_Type ¶ added in v0.22.80
type VarSpecMessage_Type int32
const ( VarSpecMessage_string VarSpecMessage_Type = 0 VarSpecMessage_number VarSpecMessage_Type = 1 VarSpecMessage_bool VarSpecMessage_Type = 2 VarSpecMessage_list VarSpecMessage_Type = 3 VarSpecMessage_map VarSpecMessage_Type = 4 )
func (VarSpecMessage_Type) Descriptor ¶ added in v0.22.80
func (VarSpecMessage_Type) Descriptor() protoreflect.EnumDescriptor
func (VarSpecMessage_Type) Enum ¶ added in v0.22.80
func (x VarSpecMessage_Type) Enum() *VarSpecMessage_Type
func (VarSpecMessage_Type) EnumDescriptor
deprecated
added in
v0.22.80
func (VarSpecMessage_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use VarSpecMessage_Type.Descriptor instead.
func (VarSpecMessage_Type) Number ¶ added in v0.22.80
func (x VarSpecMessage_Type) Number() protoreflect.EnumNumber
func (VarSpecMessage_Type) String ¶ added in v0.22.80
func (x VarSpecMessage_Type) String() string
func (VarSpecMessage_Type) Type ¶ added in v0.22.80
func (VarSpecMessage_Type) Type() protoreflect.EnumType
type VarSpecMessage_UiWidget ¶ added in v0.22.80
type VarSpecMessage_UiWidget int32
const ( VarSpecMessage_editBox VarSpecMessage_UiWidget = 0 // plain string input line, can accept types number (like a spinBox) and string VarSpecMessage_slider VarSpecMessage_UiWidget = 1 // input widget exclusively for numbers, range allowedValues[0]-[1] VarSpecMessage_listBox VarSpecMessage_UiWidget = 2 // displays a list of items, can accept types number, string or list; if number/string ==> single selection, otherwise multiple selection allowed VarSpecMessage_dropDownBox VarSpecMessage_UiWidget = 3 VarSpecMessage_comboBox VarSpecMessage_UiWidget = 4 VarSpecMessage_radioButtonBox VarSpecMessage_UiWidget = 5 VarSpecMessage_checkBox VarSpecMessage_UiWidget = 6 )
func (VarSpecMessage_UiWidget) Descriptor ¶ added in v0.22.80
func (VarSpecMessage_UiWidget) Descriptor() protoreflect.EnumDescriptor
func (VarSpecMessage_UiWidget) Enum ¶ added in v0.22.80
func (x VarSpecMessage_UiWidget) Enum() *VarSpecMessage_UiWidget
func (VarSpecMessage_UiWidget) EnumDescriptor
deprecated
added in
v0.22.80
func (VarSpecMessage_UiWidget) EnumDescriptor() ([]byte, []int)
Deprecated: Use VarSpecMessage_UiWidget.Descriptor instead.
func (VarSpecMessage_UiWidget) Number ¶ added in v0.22.80
func (x VarSpecMessage_UiWidget) Number() protoreflect.EnumNumber
func (VarSpecMessage_UiWidget) String ¶ added in v0.22.80
func (x VarSpecMessage_UiWidget) String() string
func (VarSpecMessage_UiWidget) Type ¶ added in v0.22.80
func (VarSpecMessage_UiWidget) Type() protoreflect.EnumType
type Version ¶ added in v0.7.0
type Version struct { Major int32 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"` Minor int32 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"` Patch int32 `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"` Build string `protobuf:"bytes,4,opt,name=build,proto3" json:"build,omitempty"` ProductName string `protobuf:"bytes,5,opt,name=productName,proto3" json:"productName,omitempty"` VersionStr string `protobuf:"bytes,6,opt,name=versionStr,proto3" json:"versionStr,omitempty"` // contains filtered or unexported fields }
func (*Version) Descriptor
deprecated
added in
v0.7.0
func (*Version) GetProductName ¶ added in v0.7.0
func (*Version) GetVersionStr ¶ added in v0.7.0
func (*Version) ProtoMessage ¶ added in v0.7.0
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶ added in v0.19.90
func (x *Version) ProtoReflect() protoreflect.Message
type WorkflowTemplateInfo ¶ added in v0.10.0
type WorkflowTemplateInfo struct { Repo string `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"` Template string `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"` Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"` VarSpecMap map[string]*VarSpecMessage `` /* 161-byte string literal not displayed */ Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
func (*WorkflowTemplateInfo) Descriptor
deprecated
added in
v0.10.0
func (*WorkflowTemplateInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowTemplateInfo.ProtoReflect.Descriptor instead.
func (*WorkflowTemplateInfo) GetDescription ¶ added in v0.38.0
func (x *WorkflowTemplateInfo) GetDescription() string
func (*WorkflowTemplateInfo) GetRepo ¶ added in v0.10.0
func (x *WorkflowTemplateInfo) GetRepo() string
func (*WorkflowTemplateInfo) GetRevision ¶ added in v0.11.0
func (x *WorkflowTemplateInfo) GetRevision() string
func (*WorkflowTemplateInfo) GetTemplate ¶ added in v0.10.0
func (x *WorkflowTemplateInfo) GetTemplate() string
func (*WorkflowTemplateInfo) GetVarSpecMap ¶ added in v0.22.80
func (x *WorkflowTemplateInfo) GetVarSpecMap() map[string]*VarSpecMessage
func (*WorkflowTemplateInfo) ProtoMessage ¶ added in v0.10.0
func (*WorkflowTemplateInfo) ProtoMessage()
func (*WorkflowTemplateInfo) ProtoReflect ¶ added in v0.19.90
func (x *WorkflowTemplateInfo) ProtoReflect() protoreflect.Message
func (*WorkflowTemplateInfo) Reset ¶ added in v0.10.0
func (x *WorkflowTemplateInfo) Reset()
func (*WorkflowTemplateInfo) String ¶ added in v0.10.0
func (x *WorkflowTemplateInfo) String() string