Documentation ¶
Index ¶
- Variables
- func RegisterControlServer(s *grpc.Server, srv ControlServer)
- type ChannelInfo
- func (*ChannelInfo) Descriptor() ([]byte, []int)
- func (m *ChannelInfo) GetName() string
- func (m *ChannelInfo) GetTarget() string
- func (m *ChannelInfo) GetType() string
- func (m *ChannelInfo) Marshal() (dAtA []byte, err error)
- func (m *ChannelInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ChannelInfo) ProtoMessage()
- func (m *ChannelInfo) Reset()
- func (m *ChannelInfo) Size() (n int)
- func (m *ChannelInfo) String() string
- func (m *ChannelInfo) Unmarshal(dAtA []byte) error
- func (m *ChannelInfo) XXX_DiscardUnknown()
- func (m *ChannelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelInfo) XXX_Merge(src proto.Message)
- func (m *ChannelInfo) XXX_Size() int
- func (m *ChannelInfo) XXX_Unmarshal(b []byte) error
- type CleanupTasksReply
- func (*CleanupTasksReply) Descriptor() ([]byte, []int)
- func (m *CleanupTasksReply) GetKilledTasks() []*ShortTaskInfo
- func (m *CleanupTasksReply) GetRunningTasks() []*ShortTaskInfo
- func (m *CleanupTasksReply) Marshal() (dAtA []byte, err error)
- func (m *CleanupTasksReply) MarshalTo(dAtA []byte) (int, error)
- func (*CleanupTasksReply) ProtoMessage()
- func (m *CleanupTasksReply) Reset()
- func (m *CleanupTasksReply) Size() (n int)
- func (m *CleanupTasksReply) String() string
- func (m *CleanupTasksReply) Unmarshal(dAtA []byte) error
- func (m *CleanupTasksReply) XXX_DiscardUnknown()
- func (m *CleanupTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CleanupTasksReply) XXX_Merge(src proto.Message)
- func (m *CleanupTasksReply) XXX_Size() int
- func (m *CleanupTasksReply) XXX_Unmarshal(b []byte) error
- type CleanupTasksRequest
- func (*CleanupTasksRequest) Descriptor() ([]byte, []int)
- func (m *CleanupTasksRequest) GetTaskIds() []string
- func (m *CleanupTasksRequest) Marshal() (dAtA []byte, err error)
- func (m *CleanupTasksRequest) MarshalTo(dAtA []byte) (int, error)
- func (*CleanupTasksRequest) ProtoMessage()
- func (m *CleanupTasksRequest) Reset()
- func (m *CleanupTasksRequest) Size() (n int)
- func (m *CleanupTasksRequest) String() string
- func (m *CleanupTasksRequest) Unmarshal(dAtA []byte) error
- func (m *CleanupTasksRequest) XXX_DiscardUnknown()
- func (m *CleanupTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CleanupTasksRequest) XXX_Merge(src proto.Message)
- func (m *CleanupTasksRequest) XXX_Size() int
- func (m *CleanupTasksRequest) XXX_Unmarshal(b []byte) error
- type CommandInfo
- func (*CommandInfo) Descriptor() ([]byte, []int)
- func (m *CommandInfo) GetArguments() []string
- func (m *CommandInfo) GetEnv() []string
- func (m *CommandInfo) GetShell() bool
- func (m *CommandInfo) GetUser() string
- func (m *CommandInfo) GetValue() string
- func (m *CommandInfo) Marshal() (dAtA []byte, err error)
- func (m *CommandInfo) MarshalTo(dAtA []byte) (int, error)
- func (*CommandInfo) ProtoMessage()
- func (m *CommandInfo) Reset()
- func (m *CommandInfo) Size() (n int)
- func (m *CommandInfo) String() string
- func (m *CommandInfo) Unmarshal(dAtA []byte) error
- func (m *CommandInfo) XXX_DiscardUnknown()
- func (m *CommandInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandInfo) XXX_Merge(src proto.Message)
- func (m *CommandInfo) XXX_Size() int
- func (m *CommandInfo) XXX_Unmarshal(b []byte) error
- type ControlClient
- type ControlEnvironmentReply
- func (*ControlEnvironmentReply) Descriptor() ([]byte, []int)
- func (m *ControlEnvironmentReply) GetCurrentRunNumber() uint64
- func (m *ControlEnvironmentReply) GetId() string
- func (m *ControlEnvironmentReply) GetState() string
- func (m *ControlEnvironmentReply) Marshal() (dAtA []byte, err error)
- func (m *ControlEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
- func (*ControlEnvironmentReply) ProtoMessage()
- func (m *ControlEnvironmentReply) Reset()
- func (m *ControlEnvironmentReply) Size() (n int)
- func (m *ControlEnvironmentReply) String() string
- func (m *ControlEnvironmentReply) Unmarshal(dAtA []byte) error
- func (m *ControlEnvironmentReply) XXX_DiscardUnknown()
- func (m *ControlEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ControlEnvironmentReply) XXX_Merge(src proto.Message)
- func (m *ControlEnvironmentReply) XXX_Size() int
- func (m *ControlEnvironmentReply) XXX_Unmarshal(b []byte) error
- type ControlEnvironmentRequest
- func (*ControlEnvironmentRequest) Descriptor() ([]byte, []int)
- func (m *ControlEnvironmentRequest) GetId() string
- func (m *ControlEnvironmentRequest) GetType() ControlEnvironmentRequest_Optype
- func (m *ControlEnvironmentRequest) Marshal() (dAtA []byte, err error)
- func (m *ControlEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ControlEnvironmentRequest) ProtoMessage()
- func (m *ControlEnvironmentRequest) Reset()
- func (m *ControlEnvironmentRequest) Size() (n int)
- func (m *ControlEnvironmentRequest) String() string
- func (m *ControlEnvironmentRequest) Unmarshal(dAtA []byte) error
- func (m *ControlEnvironmentRequest) XXX_DiscardUnknown()
- func (m *ControlEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ControlEnvironmentRequest) XXX_Merge(src proto.Message)
- func (m *ControlEnvironmentRequest) XXX_Size() int
- func (m *ControlEnvironmentRequest) XXX_Unmarshal(b []byte) error
- type ControlEnvironmentRequest_Optype
- type ControlServer
- type Control_TrackStatusClient
- type Control_TrackStatusServer
- type DestroyEnvironmentReply
- func (*DestroyEnvironmentReply) Descriptor() ([]byte, []int)
- func (m *DestroyEnvironmentReply) Marshal() (dAtA []byte, err error)
- func (m *DestroyEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
- func (*DestroyEnvironmentReply) ProtoMessage()
- func (m *DestroyEnvironmentReply) Reset()
- func (m *DestroyEnvironmentReply) Size() (n int)
- func (m *DestroyEnvironmentReply) String() string
- func (m *DestroyEnvironmentReply) Unmarshal(dAtA []byte) error
- func (m *DestroyEnvironmentReply) XXX_DiscardUnknown()
- func (m *DestroyEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyEnvironmentReply) XXX_Merge(src proto.Message)
- func (m *DestroyEnvironmentReply) XXX_Size() int
- func (m *DestroyEnvironmentReply) XXX_Unmarshal(b []byte) error
- type DestroyEnvironmentRequest
- func (*DestroyEnvironmentRequest) Descriptor() ([]byte, []int)
- func (m *DestroyEnvironmentRequest) GetId() string
- func (m *DestroyEnvironmentRequest) Marshal() (dAtA []byte, err error)
- func (m *DestroyEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DestroyEnvironmentRequest) ProtoMessage()
- func (m *DestroyEnvironmentRequest) Reset()
- func (m *DestroyEnvironmentRequest) Size() (n int)
- func (m *DestroyEnvironmentRequest) String() string
- func (m *DestroyEnvironmentRequest) Unmarshal(dAtA []byte) error
- func (m *DestroyEnvironmentRequest) XXX_DiscardUnknown()
- func (m *DestroyEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DestroyEnvironmentRequest) XXX_Merge(src proto.Message)
- func (m *DestroyEnvironmentRequest) XXX_Size() int
- func (m *DestroyEnvironmentRequest) XXX_Unmarshal(b []byte) error
- type EnvironmentInfo
- func (*EnvironmentInfo) Descriptor() ([]byte, []int)
- func (m *EnvironmentInfo) GetCreatedWhen() string
- func (m *EnvironmentInfo) GetCurrentRunNumber() uint64
- func (m *EnvironmentInfo) GetId() string
- func (m *EnvironmentInfo) GetRootRole() string
- func (m *EnvironmentInfo) GetState() string
- func (m *EnvironmentInfo) GetTasks() []*ShortTaskInfo
- func (m *EnvironmentInfo) Marshal() (dAtA []byte, err error)
- func (m *EnvironmentInfo) MarshalTo(dAtA []byte) (int, error)
- func (*EnvironmentInfo) ProtoMessage()
- func (m *EnvironmentInfo) Reset()
- func (m *EnvironmentInfo) Size() (n int)
- func (m *EnvironmentInfo) String() string
- func (m *EnvironmentInfo) Unmarshal(dAtA []byte) error
- func (m *EnvironmentInfo) XXX_DiscardUnknown()
- func (m *EnvironmentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvironmentInfo) XXX_Merge(src proto.Message)
- func (m *EnvironmentInfo) XXX_Size() int
- func (m *EnvironmentInfo) XXX_Unmarshal(b []byte) error
- type EnvironmentOperation
- func (*EnvironmentOperation) Descriptor() ([]byte, []int)
- func (m *EnvironmentOperation) GetRoleName() string
- func (m *EnvironmentOperation) GetType() EnvironmentOperation_Optype
- func (m *EnvironmentOperation) Marshal() (dAtA []byte, err error)
- func (m *EnvironmentOperation) MarshalTo(dAtA []byte) (int, error)
- func (*EnvironmentOperation) ProtoMessage()
- func (m *EnvironmentOperation) Reset()
- func (m *EnvironmentOperation) Size() (n int)
- func (m *EnvironmentOperation) String() string
- func (m *EnvironmentOperation) Unmarshal(dAtA []byte) error
- func (m *EnvironmentOperation) XXX_DiscardUnknown()
- func (m *EnvironmentOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnvironmentOperation) XXX_Merge(src proto.Message)
- func (m *EnvironmentOperation) XXX_Size() int
- func (m *EnvironmentOperation) XXX_Unmarshal(b []byte) error
- type EnvironmentOperation_Optype
- type Event_MesosHeartbeat
- func (*Event_MesosHeartbeat) Descriptor() ([]byte, []int)
- func (m *Event_MesosHeartbeat) Marshal() (dAtA []byte, err error)
- func (m *Event_MesosHeartbeat) MarshalTo(dAtA []byte) (int, error)
- func (*Event_MesosHeartbeat) ProtoMessage()
- func (m *Event_MesosHeartbeat) Reset()
- func (m *Event_MesosHeartbeat) Size() (n int)
- func (m *Event_MesosHeartbeat) String() string
- func (m *Event_MesosHeartbeat) Unmarshal(dAtA []byte) error
- func (m *Event_MesosHeartbeat) XXX_DiscardUnknown()
- func (m *Event_MesosHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event_MesosHeartbeat) XXX_Merge(src proto.Message)
- func (m *Event_MesosHeartbeat) XXX_Size() int
- func (m *Event_MesosHeartbeat) XXX_Unmarshal(b []byte) error
- type GetEnvironmentReply
- func (*GetEnvironmentReply) Descriptor() ([]byte, []int)
- func (m *GetEnvironmentReply) GetEnvironment() *EnvironmentInfo
- func (m *GetEnvironmentReply) GetWorkflow() *RoleInfo
- func (m *GetEnvironmentReply) Marshal() (dAtA []byte, err error)
- func (m *GetEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetEnvironmentReply) ProtoMessage()
- func (m *GetEnvironmentReply) Reset()
- func (m *GetEnvironmentReply) Size() (n int)
- func (m *GetEnvironmentReply) String() string
- func (m *GetEnvironmentReply) Unmarshal(dAtA []byte) error
- func (m *GetEnvironmentReply) XXX_DiscardUnknown()
- func (m *GetEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetEnvironmentReply) XXX_Merge(src proto.Message)
- func (m *GetEnvironmentReply) XXX_Size() int
- func (m *GetEnvironmentReply) XXX_Unmarshal(b []byte) error
- type GetEnvironmentRequest
- func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)
- func (m *GetEnvironmentRequest) GetId() string
- func (m *GetEnvironmentRequest) Marshal() (dAtA []byte, err error)
- func (m *GetEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetEnvironmentRequest) ProtoMessage()
- func (m *GetEnvironmentRequest) Reset()
- func (m *GetEnvironmentRequest) Size() (n int)
- func (m *GetEnvironmentRequest) String() string
- func (m *GetEnvironmentRequest) Unmarshal(dAtA []byte) error
- func (m *GetEnvironmentRequest) XXX_DiscardUnknown()
- func (m *GetEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetEnvironmentRequest) XXX_Merge(src proto.Message)
- func (m *GetEnvironmentRequest) XXX_Size() int
- func (m *GetEnvironmentRequest) XXX_Unmarshal(b []byte) error
- type GetEnvironmentsReply
- func (*GetEnvironmentsReply) Descriptor() ([]byte, []int)
- func (m *GetEnvironmentsReply) GetEnvironments() []*EnvironmentInfo
- func (m *GetEnvironmentsReply) GetFrameworkId() string
- func (m *GetEnvironmentsReply) Marshal() (dAtA []byte, err error)
- func (m *GetEnvironmentsReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetEnvironmentsReply) ProtoMessage()
- func (m *GetEnvironmentsReply) Reset()
- func (m *GetEnvironmentsReply) Size() (n int)
- func (m *GetEnvironmentsReply) String() string
- func (m *GetEnvironmentsReply) Unmarshal(dAtA []byte) error
- func (m *GetEnvironmentsReply) XXX_DiscardUnknown()
- func (m *GetEnvironmentsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetEnvironmentsReply) XXX_Merge(src proto.Message)
- func (m *GetEnvironmentsReply) XXX_Size() int
- func (m *GetEnvironmentsReply) XXX_Unmarshal(b []byte) error
- type GetEnvironmentsRequest
- func (*GetEnvironmentsRequest) Descriptor() ([]byte, []int)
- func (m *GetEnvironmentsRequest) Marshal() (dAtA []byte, err error)
- func (m *GetEnvironmentsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetEnvironmentsRequest) ProtoMessage()
- func (m *GetEnvironmentsRequest) Reset()
- func (m *GetEnvironmentsRequest) Size() (n int)
- func (m *GetEnvironmentsRequest) String() string
- func (m *GetEnvironmentsRequest) Unmarshal(dAtA []byte) error
- func (m *GetEnvironmentsRequest) XXX_DiscardUnknown()
- func (m *GetEnvironmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetEnvironmentsRequest) XXX_Merge(src proto.Message)
- func (m *GetEnvironmentsRequest) XXX_Size() int
- func (m *GetEnvironmentsRequest) XXX_Unmarshal(b []byte) error
- type GetFrameworkInfoReply
- func (*GetFrameworkInfoReply) Descriptor() ([]byte, []int)
- func (m *GetFrameworkInfoReply) GetEnvironmentsCount() int32
- func (m *GetFrameworkInfoReply) GetFrameworkId() string
- func (m *GetFrameworkInfoReply) GetHostsCount() int32
- func (m *GetFrameworkInfoReply) GetInstanceName() string
- func (m *GetFrameworkInfoReply) GetState() string
- func (m *GetFrameworkInfoReply) GetTasksCount() int32
- func (m *GetFrameworkInfoReply) GetVersion() *Version
- func (m *GetFrameworkInfoReply) Marshal() (dAtA []byte, err error)
- func (m *GetFrameworkInfoReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetFrameworkInfoReply) ProtoMessage()
- func (m *GetFrameworkInfoReply) Reset()
- func (m *GetFrameworkInfoReply) Size() (n int)
- func (m *GetFrameworkInfoReply) String() string
- func (m *GetFrameworkInfoReply) Unmarshal(dAtA []byte) error
- func (m *GetFrameworkInfoReply) XXX_DiscardUnknown()
- func (m *GetFrameworkInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFrameworkInfoReply) XXX_Merge(src proto.Message)
- func (m *GetFrameworkInfoReply) XXX_Size() int
- func (m *GetFrameworkInfoReply) XXX_Unmarshal(b []byte) error
- type GetFrameworkInfoRequest
- func (*GetFrameworkInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetFrameworkInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetFrameworkInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetFrameworkInfoRequest) ProtoMessage()
- func (m *GetFrameworkInfoRequest) Reset()
- func (m *GetFrameworkInfoRequest) Size() (n int)
- func (m *GetFrameworkInfoRequest) String() string
- func (m *GetFrameworkInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetFrameworkInfoRequest) XXX_DiscardUnknown()
- func (m *GetFrameworkInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetFrameworkInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetFrameworkInfoRequest) XXX_Size() int
- func (m *GetFrameworkInfoRequest) XXX_Unmarshal(b []byte) error
- type GetRolesReply
- func (*GetRolesReply) Descriptor() ([]byte, []int)
- func (m *GetRolesReply) GetRoles() []*RoleInfo
- func (m *GetRolesReply) Marshal() (dAtA []byte, err error)
- func (m *GetRolesReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetRolesReply) ProtoMessage()
- func (m *GetRolesReply) Reset()
- func (m *GetRolesReply) Size() (n int)
- func (m *GetRolesReply) String() string
- func (m *GetRolesReply) Unmarshal(dAtA []byte) error
- func (m *GetRolesReply) XXX_DiscardUnknown()
- func (m *GetRolesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRolesReply) XXX_Merge(src proto.Message)
- func (m *GetRolesReply) XXX_Size() int
- func (m *GetRolesReply) XXX_Unmarshal(b []byte) error
- type GetRolesRequest
- func (*GetRolesRequest) Descriptor() ([]byte, []int)
- func (m *GetRolesRequest) GetEnvId() string
- func (m *GetRolesRequest) GetPathSpec() string
- func (m *GetRolesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRolesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetRolesRequest) ProtoMessage()
- func (m *GetRolesRequest) Reset()
- func (m *GetRolesRequest) Size() (n int)
- func (m *GetRolesRequest) String() string
- func (m *GetRolesRequest) Unmarshal(dAtA []byte) error
- func (m *GetRolesRequest) XXX_DiscardUnknown()
- func (m *GetRolesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRolesRequest) XXX_Merge(src proto.Message)
- func (m *GetRolesRequest) XXX_Size() int
- func (m *GetRolesRequest) XXX_Unmarshal(b []byte) error
- type GetTaskReply
- func (*GetTaskReply) Descriptor() ([]byte, []int)
- func (m *GetTaskReply) GetTask() *TaskInfo
- func (m *GetTaskReply) Marshal() (dAtA []byte, err error)
- func (m *GetTaskReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetTaskReply) ProtoMessage()
- func (m *GetTaskReply) Reset()
- func (m *GetTaskReply) Size() (n int)
- func (m *GetTaskReply) String() string
- func (m *GetTaskReply) Unmarshal(dAtA []byte) error
- func (m *GetTaskReply) XXX_DiscardUnknown()
- func (m *GetTaskReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTaskReply) XXX_Merge(src proto.Message)
- func (m *GetTaskReply) XXX_Size() int
- func (m *GetTaskReply) XXX_Unmarshal(b []byte) error
- type GetTaskRequest
- func (*GetTaskRequest) Descriptor() ([]byte, []int)
- func (m *GetTaskRequest) GetTaskId() string
- func (m *GetTaskRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTaskRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetTaskRequest) ProtoMessage()
- func (m *GetTaskRequest) Reset()
- func (m *GetTaskRequest) Size() (n int)
- func (m *GetTaskRequest) String() string
- func (m *GetTaskRequest) Unmarshal(dAtA []byte) error
- func (m *GetTaskRequest) XXX_DiscardUnknown()
- func (m *GetTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTaskRequest) XXX_Merge(src proto.Message)
- func (m *GetTaskRequest) XXX_Size() int
- func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error
- type GetTasksReply
- func (*GetTasksReply) Descriptor() ([]byte, []int)
- func (m *GetTasksReply) GetTasks() []*ShortTaskInfo
- func (m *GetTasksReply) Marshal() (dAtA []byte, err error)
- func (m *GetTasksReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetTasksReply) ProtoMessage()
- func (m *GetTasksReply) Reset()
- func (m *GetTasksReply) Size() (n int)
- func (m *GetTasksReply) String() string
- func (m *GetTasksReply) Unmarshal(dAtA []byte) error
- func (m *GetTasksReply) XXX_DiscardUnknown()
- func (m *GetTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTasksReply) XXX_Merge(src proto.Message)
- func (m *GetTasksReply) XXX_Size() int
- func (m *GetTasksReply) XXX_Unmarshal(b []byte) error
- type GetTasksRequest
- func (*GetTasksRequest) Descriptor() ([]byte, []int)
- func (m *GetTasksRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTasksRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetTasksRequest) ProtoMessage()
- func (m *GetTasksRequest) Reset()
- func (m *GetTasksRequest) Size() (n int)
- func (m *GetTasksRequest) String() string
- func (m *GetTasksRequest) Unmarshal(dAtA []byte) error
- func (m *GetTasksRequest) XXX_DiscardUnknown()
- func (m *GetTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTasksRequest) XXX_Merge(src proto.Message)
- func (m *GetTasksRequest) XXX_Size() int
- func (m *GetTasksRequest) XXX_Unmarshal(b []byte) error
- type GetWorkflowTemplatesReply
- func (*GetWorkflowTemplatesReply) Descriptor() ([]byte, []int)
- func (m *GetWorkflowTemplatesReply) GetWorkflowTemplates() []string
- func (m *GetWorkflowTemplatesReply) Marshal() (dAtA []byte, err error)
- func (m *GetWorkflowTemplatesReply) MarshalTo(dAtA []byte) (int, error)
- func (*GetWorkflowTemplatesReply) ProtoMessage()
- func (m *GetWorkflowTemplatesReply) Reset()
- func (m *GetWorkflowTemplatesReply) Size() (n int)
- func (m *GetWorkflowTemplatesReply) String() string
- func (m *GetWorkflowTemplatesReply) Unmarshal(dAtA []byte) error
- func (m *GetWorkflowTemplatesReply) XXX_DiscardUnknown()
- func (m *GetWorkflowTemplatesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetWorkflowTemplatesReply) XXX_Merge(src proto.Message)
- func (m *GetWorkflowTemplatesReply) XXX_Size() int
- func (m *GetWorkflowTemplatesReply) XXX_Unmarshal(b []byte) error
- type GetWorkflowTemplatesRequest
- func (*GetWorkflowTemplatesRequest) Descriptor() ([]byte, []int)
- func (m *GetWorkflowTemplatesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetWorkflowTemplatesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetWorkflowTemplatesRequest) ProtoMessage()
- func (m *GetWorkflowTemplatesRequest) Reset()
- func (m *GetWorkflowTemplatesRequest) Size() (n int)
- func (m *GetWorkflowTemplatesRequest) String() string
- func (m *GetWorkflowTemplatesRequest) Unmarshal(dAtA []byte) error
- func (m *GetWorkflowTemplatesRequest) XXX_DiscardUnknown()
- func (m *GetWorkflowTemplatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetWorkflowTemplatesRequest) XXX_Merge(src proto.Message)
- func (m *GetWorkflowTemplatesRequest) XXX_Size() int
- func (m *GetWorkflowTemplatesRequest) XXX_Unmarshal(b []byte) error
- type ModifyEnvironmentReply
- func (*ModifyEnvironmentReply) Descriptor() ([]byte, []int)
- func (m *ModifyEnvironmentReply) GetFailedOperations() []*EnvironmentOperation
- func (m *ModifyEnvironmentReply) GetId() string
- func (m *ModifyEnvironmentReply) GetState() string
- func (m *ModifyEnvironmentReply) Marshal() (dAtA []byte, err error)
- func (m *ModifyEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
- func (*ModifyEnvironmentReply) ProtoMessage()
- func (m *ModifyEnvironmentReply) Reset()
- func (m *ModifyEnvironmentReply) Size() (n int)
- func (m *ModifyEnvironmentReply) String() string
- func (m *ModifyEnvironmentReply) Unmarshal(dAtA []byte) error
- func (m *ModifyEnvironmentReply) XXX_DiscardUnknown()
- func (m *ModifyEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModifyEnvironmentReply) XXX_Merge(src proto.Message)
- func (m *ModifyEnvironmentReply) XXX_Size() int
- func (m *ModifyEnvironmentReply) XXX_Unmarshal(b []byte) error
- type ModifyEnvironmentRequest
- func (*ModifyEnvironmentRequest) Descriptor() ([]byte, []int)
- func (m *ModifyEnvironmentRequest) GetId() string
- func (m *ModifyEnvironmentRequest) GetOperations() []*EnvironmentOperation
- func (m *ModifyEnvironmentRequest) GetReconfigureAll() bool
- func (m *ModifyEnvironmentRequest) Marshal() (dAtA []byte, err error)
- func (m *ModifyEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ModifyEnvironmentRequest) ProtoMessage()
- func (m *ModifyEnvironmentRequest) Reset()
- func (m *ModifyEnvironmentRequest) Size() (n int)
- func (m *ModifyEnvironmentRequest) String() string
- func (m *ModifyEnvironmentRequest) Unmarshal(dAtA []byte) error
- func (m *ModifyEnvironmentRequest) XXX_DiscardUnknown()
- func (m *ModifyEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModifyEnvironmentRequest) XXX_Merge(src proto.Message)
- func (m *ModifyEnvironmentRequest) XXX_Size() int
- func (m *ModifyEnvironmentRequest) XXX_Unmarshal(b []byte) error
- type NewEnvironmentReply
- func (*NewEnvironmentReply) Descriptor() ([]byte, []int)
- func (m *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo
- func (m *NewEnvironmentReply) Marshal() (dAtA []byte, err error)
- func (m *NewEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
- func (*NewEnvironmentReply) ProtoMessage()
- func (m *NewEnvironmentReply) Reset()
- func (m *NewEnvironmentReply) Size() (n int)
- func (m *NewEnvironmentReply) String() string
- func (m *NewEnvironmentReply) Unmarshal(dAtA []byte) error
- func (m *NewEnvironmentReply) XXX_DiscardUnknown()
- func (m *NewEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewEnvironmentReply) XXX_Merge(src proto.Message)
- func (m *NewEnvironmentReply) XXX_Size() int
- func (m *NewEnvironmentReply) XXX_Unmarshal(b []byte) error
- type NewEnvironmentRequest
- func (*NewEnvironmentRequest) Descriptor() ([]byte, []int)
- func (m *NewEnvironmentRequest) GetWorkflowTemplate() string
- func (m *NewEnvironmentRequest) Marshal() (dAtA []byte, err error)
- func (m *NewEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (*NewEnvironmentRequest) ProtoMessage()
- func (m *NewEnvironmentRequest) Reset()
- func (m *NewEnvironmentRequest) Size() (n int)
- func (m *NewEnvironmentRequest) String() string
- func (m *NewEnvironmentRequest) Unmarshal(dAtA []byte) error
- func (m *NewEnvironmentRequest) XXX_DiscardUnknown()
- func (m *NewEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewEnvironmentRequest) XXX_Merge(src proto.Message)
- func (m *NewEnvironmentRequest) XXX_Size() int
- func (m *NewEnvironmentRequest) XXX_Unmarshal(b []byte) error
- type RoleInfo
- func (*RoleInfo) Descriptor() ([]byte, []int)
- func (m *RoleInfo) GetFullPath() string
- func (m *RoleInfo) GetName() string
- func (m *RoleInfo) GetRoles() []*RoleInfo
- func (m *RoleInfo) GetState() string
- func (m *RoleInfo) GetStatus() string
- func (m *RoleInfo) GetTaskIds() []string
- func (m *RoleInfo) Marshal() (dAtA []byte, err error)
- func (m *RoleInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RoleInfo) ProtoMessage()
- func (m *RoleInfo) Reset()
- func (m *RoleInfo) Size() (n int)
- func (m *RoleInfo) String() string
- func (m *RoleInfo) Unmarshal(dAtA []byte) error
- func (m *RoleInfo) XXX_DiscardUnknown()
- func (m *RoleInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RoleInfo) XXX_Merge(src proto.Message)
- func (m *RoleInfo) XXX_Size() int
- func (m *RoleInfo) XXX_Unmarshal(b []byte) error
- type ShortTaskInfo
- func (*ShortTaskInfo) Descriptor() ([]byte, []int)
- func (m *ShortTaskInfo) GetClassName() string
- func (m *ShortTaskInfo) GetDeploymentInfo() *TaskDeploymentInfo
- func (m *ShortTaskInfo) GetLocked() bool
- func (m *ShortTaskInfo) GetName() string
- func (m *ShortTaskInfo) GetState() string
- func (m *ShortTaskInfo) GetStatus() string
- func (m *ShortTaskInfo) GetTaskId() string
- func (m *ShortTaskInfo) Marshal() (dAtA []byte, err error)
- func (m *ShortTaskInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ShortTaskInfo) ProtoMessage()
- func (m *ShortTaskInfo) Reset()
- func (m *ShortTaskInfo) Size() (n int)
- func (m *ShortTaskInfo) String() string
- func (m *ShortTaskInfo) Unmarshal(dAtA []byte) error
- func (m *ShortTaskInfo) XXX_DiscardUnknown()
- func (m *ShortTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShortTaskInfo) XXX_Merge(src proto.Message)
- func (m *ShortTaskInfo) XXX_Size() int
- func (m *ShortTaskInfo) XXX_Unmarshal(b []byte) error
- type StatusReply
- func (*StatusReply) Descriptor() ([]byte, []int)
- func (m *StatusReply) GetState() string
- func (m *StatusReply) GetStatusUpdates() []*StatusUpdate
- func (m *StatusReply) Marshal() (dAtA []byte, err error)
- func (m *StatusReply) MarshalTo(dAtA []byte) (int, error)
- func (*StatusReply) ProtoMessage()
- func (m *StatusReply) Reset()
- func (m *StatusReply) Size() (n int)
- func (m *StatusReply) String() string
- func (m *StatusReply) Unmarshal(dAtA []byte) error
- func (m *StatusReply) XXX_DiscardUnknown()
- func (m *StatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusReply) XXX_Merge(src proto.Message)
- func (m *StatusReply) XXX_Size() int
- func (m *StatusReply) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (m *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type StatusUpdate
- func (*StatusUpdate) Descriptor() ([]byte, []int)
- func (m *StatusUpdate) GetEvent() isStatusUpdate_Event
- func (m *StatusUpdate) GetLevel() StatusUpdate_Level
- func (m *StatusUpdate) GetMesosHeartbeat() *Event_MesosHeartbeat
- func (m *StatusUpdate) Marshal() (dAtA []byte, err error)
- func (m *StatusUpdate) MarshalTo(dAtA []byte) (int, error)
- func (*StatusUpdate) ProtoMessage()
- func (m *StatusUpdate) Reset()
- func (m *StatusUpdate) Size() (n int)
- func (m *StatusUpdate) String() string
- func (m *StatusUpdate) Unmarshal(dAtA []byte) error
- func (m *StatusUpdate) XXX_DiscardUnknown()
- func (m *StatusUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusUpdate) XXX_Merge(src proto.Message)
- func (*StatusUpdate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StatusUpdate) XXX_Size() int
- func (m *StatusUpdate) XXX_Unmarshal(b []byte) error
- type StatusUpdate_Level
- type StatusUpdate_MesosHeartbeat
- type TaskClassInfo
- func (*TaskClassInfo) Descriptor() ([]byte, []int)
- func (m *TaskClassInfo) GetControlMode() string
- func (m *TaskClassInfo) GetName() string
- func (m *TaskClassInfo) Marshal() (dAtA []byte, err error)
- func (m *TaskClassInfo) MarshalTo(dAtA []byte) (int, error)
- func (*TaskClassInfo) ProtoMessage()
- func (m *TaskClassInfo) Reset()
- func (m *TaskClassInfo) Size() (n int)
- func (m *TaskClassInfo) String() string
- func (m *TaskClassInfo) Unmarshal(dAtA []byte) error
- func (m *TaskClassInfo) XXX_DiscardUnknown()
- func (m *TaskClassInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskClassInfo) XXX_Merge(src proto.Message)
- func (m *TaskClassInfo) XXX_Size() int
- func (m *TaskClassInfo) XXX_Unmarshal(b []byte) error
- type TaskDeploymentInfo
- func (*TaskDeploymentInfo) Descriptor() ([]byte, []int)
- func (m *TaskDeploymentInfo) GetAgentId() string
- func (m *TaskDeploymentInfo) GetExecutorId() string
- func (m *TaskDeploymentInfo) GetHostname() string
- func (m *TaskDeploymentInfo) GetOfferId() string
- func (m *TaskDeploymentInfo) Marshal() (dAtA []byte, err error)
- func (m *TaskDeploymentInfo) MarshalTo(dAtA []byte) (int, error)
- func (*TaskDeploymentInfo) ProtoMessage()
- func (m *TaskDeploymentInfo) Reset()
- func (m *TaskDeploymentInfo) Size() (n int)
- func (m *TaskDeploymentInfo) String() string
- func (m *TaskDeploymentInfo) Unmarshal(dAtA []byte) error
- func (m *TaskDeploymentInfo) XXX_DiscardUnknown()
- func (m *TaskDeploymentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskDeploymentInfo) XXX_Merge(src proto.Message)
- func (m *TaskDeploymentInfo) XXX_Size() int
- func (m *TaskDeploymentInfo) XXX_Unmarshal(b []byte) error
- type TaskInfo
- func (*TaskInfo) Descriptor() ([]byte, []int)
- func (m *TaskInfo) GetClassInfo() *TaskClassInfo
- func (m *TaskInfo) GetCommandInfo() *CommandInfo
- func (m *TaskInfo) GetEnvId() string
- func (m *TaskInfo) GetInboundChannels() []*ChannelInfo
- func (m *TaskInfo) GetOutboundChannels() []*ChannelInfo
- func (m *TaskInfo) GetShortInfo() *ShortTaskInfo
- func (m *TaskInfo) GetTaskPath() string
- func (m *TaskInfo) Marshal() (dAtA []byte, err error)
- func (m *TaskInfo) MarshalTo(dAtA []byte) (int, error)
- func (*TaskInfo) ProtoMessage()
- func (m *TaskInfo) Reset()
- func (m *TaskInfo) Size() (n int)
- func (m *TaskInfo) String() string
- func (m *TaskInfo) Unmarshal(dAtA []byte) error
- func (m *TaskInfo) XXX_DiscardUnknown()
- func (m *TaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TaskInfo) XXX_Merge(src proto.Message)
- func (m *TaskInfo) XXX_Size() int
- func (m *TaskInfo) XXX_Unmarshal(b []byte) error
- type TeardownReply
- func (*TeardownReply) Descriptor() ([]byte, []int)
- func (m *TeardownReply) Marshal() (dAtA []byte, err error)
- func (m *TeardownReply) MarshalTo(dAtA []byte) (int, error)
- func (*TeardownReply) ProtoMessage()
- func (m *TeardownReply) Reset()
- func (m *TeardownReply) Size() (n int)
- func (m *TeardownReply) String() string
- func (m *TeardownReply) Unmarshal(dAtA []byte) error
- func (m *TeardownReply) XXX_DiscardUnknown()
- func (m *TeardownReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TeardownReply) XXX_Merge(src proto.Message)
- func (m *TeardownReply) XXX_Size() int
- func (m *TeardownReply) XXX_Unmarshal(b []byte) error
- type TeardownRequest
- func (*TeardownRequest) Descriptor() ([]byte, []int)
- func (m *TeardownRequest) GetReason() string
- func (m *TeardownRequest) Marshal() (dAtA []byte, err error)
- func (m *TeardownRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TeardownRequest) ProtoMessage()
- func (m *TeardownRequest) Reset()
- func (m *TeardownRequest) Size() (n int)
- func (m *TeardownRequest) String() string
- func (m *TeardownRequest) Unmarshal(dAtA []byte) error
- func (m *TeardownRequest) XXX_DiscardUnknown()
- func (m *TeardownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TeardownRequest) XXX_Merge(src proto.Message)
- func (m *TeardownRequest) XXX_Size() int
- func (m *TeardownRequest) XXX_Unmarshal(b []byte) error
- type Version
- func (*Version) Descriptor() ([]byte, []int)
- func (m *Version) GetBuild() string
- func (m *Version) GetMajor() int32
- func (m *Version) GetMinor() int32
- func (m *Version) GetPatch() int32
- func (m *Version) GetProductName() string
- func (m *Version) GetVersionStr() string
- func (m *Version) Marshal() (dAtA []byte, err error)
- func (m *Version) MarshalTo(dAtA []byte) (int, error)
- func (*Version) ProtoMessage()
- func (m *Version) Reset()
- func (m *Version) Size() (n int)
- func (m *Version) String() string
- func (m *Version) Unmarshal(dAtA []byte) error
- func (m *Version) XXX_DiscardUnknown()
- func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Version) XXX_Merge(src proto.Message)
- func (m *Version) XXX_Size() int
- func (m *Version) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthO2Control = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowO2Control = fmt.Errorf("proto: integer overflow") )
var ControlEnvironmentRequest_Optype_name = map[int32]string{
0: "NOOP",
1: "START_ACTIVITY",
2: "STOP_ACTIVITY",
3: "CONFIGURE",
4: "RESET",
5: "GO_ERROR",
}
var ControlEnvironmentRequest_Optype_value = map[string]int32{
"NOOP": 0,
"START_ACTIVITY": 1,
"STOP_ACTIVITY": 2,
"CONFIGURE": 3,
"RESET": 4,
"GO_ERROR": 5,
}
var EnvironmentOperation_Optype_name = map[int32]string{
0: "NOOP",
3: "REMOVE_ROLE",
4: "ADD_ROLE",
}
var EnvironmentOperation_Optype_value = map[string]int32{
"NOOP": 0,
"REMOVE_ROLE": 3,
"ADD_ROLE": 4,
}
var StatusUpdate_Level_name = map[int32]string{
0: "DEBUG",
1: "INFO",
2: "WARNING",
3: "ERROR",
}
var StatusUpdate_Level_value = map[string]int32{
"DEBUG": 0,
"INFO": 1,
"WARNING": 2,
"ERROR": 3,
}
Functions ¶
func RegisterControlServer ¶
func RegisterControlServer(s *grpc.Server, srv ControlServer)
Types ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelInfo) Descriptor ¶
func (*ChannelInfo) Descriptor() ([]byte, []int)
func (*ChannelInfo) GetName ¶
func (m *ChannelInfo) GetName() string
func (*ChannelInfo) GetTarget ¶
func (m *ChannelInfo) GetTarget() string
func (*ChannelInfo) GetType ¶
func (m *ChannelInfo) GetType() string
func (*ChannelInfo) Marshal ¶
func (m *ChannelInfo) Marshal() (dAtA []byte, err error)
func (*ChannelInfo) ProtoMessage ¶
func (*ChannelInfo) ProtoMessage()
func (*ChannelInfo) Reset ¶
func (m *ChannelInfo) Reset()
func (*ChannelInfo) Size ¶
func (m *ChannelInfo) Size() (n int)
func (*ChannelInfo) String ¶
func (m *ChannelInfo) String() string
func (*ChannelInfo) Unmarshal ¶
func (m *ChannelInfo) Unmarshal(dAtA []byte) error
func (*ChannelInfo) XXX_DiscardUnknown ¶
func (m *ChannelInfo) XXX_DiscardUnknown()
func (*ChannelInfo) XXX_Marshal ¶
func (m *ChannelInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelInfo) XXX_Merge ¶
func (m *ChannelInfo) XXX_Merge(src proto.Message)
func (*ChannelInfo) XXX_Size ¶
func (m *ChannelInfo) XXX_Size() int
func (*ChannelInfo) XXX_Unmarshal ¶
func (m *ChannelInfo) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CleanupTasksReply) Descriptor ¶
func (*CleanupTasksReply) Descriptor() ([]byte, []int)
func (*CleanupTasksReply) GetKilledTasks ¶
func (m *CleanupTasksReply) GetKilledTasks() []*ShortTaskInfo
func (*CleanupTasksReply) GetRunningTasks ¶
func (m *CleanupTasksReply) GetRunningTasks() []*ShortTaskInfo
func (*CleanupTasksReply) Marshal ¶
func (m *CleanupTasksReply) Marshal() (dAtA []byte, err error)
func (*CleanupTasksReply) MarshalTo ¶
func (m *CleanupTasksReply) MarshalTo(dAtA []byte) (int, error)
func (*CleanupTasksReply) ProtoMessage ¶
func (*CleanupTasksReply) ProtoMessage()
func (*CleanupTasksReply) Reset ¶
func (m *CleanupTasksReply) Reset()
func (*CleanupTasksReply) Size ¶
func (m *CleanupTasksReply) Size() (n int)
func (*CleanupTasksReply) String ¶
func (m *CleanupTasksReply) String() string
func (*CleanupTasksReply) Unmarshal ¶
func (m *CleanupTasksReply) Unmarshal(dAtA []byte) error
func (*CleanupTasksReply) XXX_DiscardUnknown ¶
func (m *CleanupTasksReply) XXX_DiscardUnknown()
func (*CleanupTasksReply) XXX_Marshal ¶
func (m *CleanupTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CleanupTasksReply) XXX_Merge ¶
func (m *CleanupTasksReply) XXX_Merge(src proto.Message)
func (*CleanupTasksReply) XXX_Size ¶
func (m *CleanupTasksReply) XXX_Size() int
func (*CleanupTasksReply) XXX_Unmarshal ¶
func (m *CleanupTasksReply) XXX_Unmarshal(b []byte) error
type CleanupTasksRequest ¶
type CleanupTasksRequest struct { TaskIds []string `protobuf:"bytes,1,rep,name=taskIds,proto3" json:"taskIds,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CleanupTasksRequest) Descriptor ¶
func (*CleanupTasksRequest) Descriptor() ([]byte, []int)
func (*CleanupTasksRequest) GetTaskIds ¶
func (m *CleanupTasksRequest) GetTaskIds() []string
func (*CleanupTasksRequest) Marshal ¶
func (m *CleanupTasksRequest) Marshal() (dAtA []byte, err error)
func (*CleanupTasksRequest) MarshalTo ¶
func (m *CleanupTasksRequest) MarshalTo(dAtA []byte) (int, error)
func (*CleanupTasksRequest) ProtoMessage ¶
func (*CleanupTasksRequest) ProtoMessage()
func (*CleanupTasksRequest) Reset ¶
func (m *CleanupTasksRequest) Reset()
func (*CleanupTasksRequest) Size ¶
func (m *CleanupTasksRequest) Size() (n int)
func (*CleanupTasksRequest) String ¶
func (m *CleanupTasksRequest) String() string
func (*CleanupTasksRequest) Unmarshal ¶
func (m *CleanupTasksRequest) Unmarshal(dAtA []byte) error
func (*CleanupTasksRequest) XXX_DiscardUnknown ¶
func (m *CleanupTasksRequest) XXX_DiscardUnknown()
func (*CleanupTasksRequest) XXX_Marshal ¶
func (m *CleanupTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CleanupTasksRequest) XXX_Merge ¶
func (m *CleanupTasksRequest) XXX_Merge(src proto.Message)
func (*CleanupTasksRequest) XXX_Size ¶
func (m *CleanupTasksRequest) XXX_Size() int
func (*CleanupTasksRequest) XXX_Unmarshal ¶
func (m *CleanupTasksRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CommandInfo) Descriptor ¶
func (*CommandInfo) Descriptor() ([]byte, []int)
func (*CommandInfo) GetArguments ¶
func (m *CommandInfo) GetArguments() []string
func (*CommandInfo) GetEnv ¶
func (m *CommandInfo) GetEnv() []string
func (*CommandInfo) GetShell ¶
func (m *CommandInfo) GetShell() bool
func (*CommandInfo) GetUser ¶
func (m *CommandInfo) GetUser() string
func (*CommandInfo) GetValue ¶
func (m *CommandInfo) GetValue() string
func (*CommandInfo) Marshal ¶
func (m *CommandInfo) Marshal() (dAtA []byte, err error)
func (*CommandInfo) ProtoMessage ¶
func (*CommandInfo) ProtoMessage()
func (*CommandInfo) Reset ¶
func (m *CommandInfo) Reset()
func (*CommandInfo) Size ¶
func (m *CommandInfo) Size() (n int)
func (*CommandInfo) String ¶
func (m *CommandInfo) String() string
func (*CommandInfo) Unmarshal ¶
func (m *CommandInfo) Unmarshal(dAtA []byte) error
func (*CommandInfo) XXX_DiscardUnknown ¶
func (m *CommandInfo) XXX_DiscardUnknown()
func (*CommandInfo) XXX_Marshal ¶
func (m *CommandInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandInfo) XXX_Merge ¶
func (m *CommandInfo) XXX_Merge(src proto.Message)
func (*CommandInfo) XXX_Size ¶
func (m *CommandInfo) XXX_Size() int
func (*CommandInfo) XXX_Unmarshal ¶
func (m *CommandInfo) XXX_Unmarshal(b []byte) error
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) 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) 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) }
ControlClient is the client API for Control service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewControlClient ¶
func NewControlClient(cc *grpc.ClientConn) 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 uint64 `protobuf:"varint,3,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ControlEnvironmentReply) Descriptor ¶
func (*ControlEnvironmentReply) Descriptor() ([]byte, []int)
func (*ControlEnvironmentReply) GetCurrentRunNumber ¶ added in v0.8.0
func (m *ControlEnvironmentReply) GetCurrentRunNumber() uint64
func (*ControlEnvironmentReply) GetId ¶
func (m *ControlEnvironmentReply) GetId() string
func (*ControlEnvironmentReply) GetState ¶
func (m *ControlEnvironmentReply) GetState() string
func (*ControlEnvironmentReply) Marshal ¶
func (m *ControlEnvironmentReply) Marshal() (dAtA []byte, err error)
func (*ControlEnvironmentReply) MarshalTo ¶
func (m *ControlEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
func (*ControlEnvironmentReply) ProtoMessage ¶
func (*ControlEnvironmentReply) ProtoMessage()
func (*ControlEnvironmentReply) Reset ¶
func (m *ControlEnvironmentReply) Reset()
func (*ControlEnvironmentReply) Size ¶
func (m *ControlEnvironmentReply) Size() (n int)
func (*ControlEnvironmentReply) String ¶
func (m *ControlEnvironmentReply) String() string
func (*ControlEnvironmentReply) Unmarshal ¶
func (m *ControlEnvironmentReply) Unmarshal(dAtA []byte) error
func (*ControlEnvironmentReply) XXX_DiscardUnknown ¶
func (m *ControlEnvironmentReply) XXX_DiscardUnknown()
func (*ControlEnvironmentReply) XXX_Marshal ¶
func (m *ControlEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ControlEnvironmentReply) XXX_Merge ¶
func (m *ControlEnvironmentReply) XXX_Merge(src proto.Message)
func (*ControlEnvironmentReply) XXX_Size ¶
func (m *ControlEnvironmentReply) XXX_Size() int
func (*ControlEnvironmentReply) XXX_Unmarshal ¶
func (m *ControlEnvironmentReply) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ControlEnvironmentRequest) Descriptor ¶
func (*ControlEnvironmentRequest) Descriptor() ([]byte, []int)
func (*ControlEnvironmentRequest) GetId ¶
func (m *ControlEnvironmentRequest) GetId() string
func (*ControlEnvironmentRequest) GetType ¶
func (m *ControlEnvironmentRequest) GetType() ControlEnvironmentRequest_Optype
func (*ControlEnvironmentRequest) Marshal ¶
func (m *ControlEnvironmentRequest) Marshal() (dAtA []byte, err error)
func (*ControlEnvironmentRequest) MarshalTo ¶
func (m *ControlEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*ControlEnvironmentRequest) ProtoMessage ¶
func (*ControlEnvironmentRequest) ProtoMessage()
func (*ControlEnvironmentRequest) Reset ¶
func (m *ControlEnvironmentRequest) Reset()
func (*ControlEnvironmentRequest) Size ¶
func (m *ControlEnvironmentRequest) Size() (n int)
func (*ControlEnvironmentRequest) String ¶
func (m *ControlEnvironmentRequest) String() string
func (*ControlEnvironmentRequest) Unmarshal ¶
func (m *ControlEnvironmentRequest) Unmarshal(dAtA []byte) error
func (*ControlEnvironmentRequest) XXX_DiscardUnknown ¶
func (m *ControlEnvironmentRequest) XXX_DiscardUnknown()
func (*ControlEnvironmentRequest) XXX_Marshal ¶
func (m *ControlEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ControlEnvironmentRequest) XXX_Merge ¶
func (m *ControlEnvironmentRequest) XXX_Merge(src proto.Message)
func (*ControlEnvironmentRequest) XXX_Size ¶
func (m *ControlEnvironmentRequest) XXX_Size() int
func (*ControlEnvironmentRequest) XXX_Unmarshal ¶
func (m *ControlEnvironmentRequest) XXX_Unmarshal(b []byte) error
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 )
func (ControlEnvironmentRequest_Optype) EnumDescriptor ¶
func (ControlEnvironmentRequest_Optype) EnumDescriptor() ([]byte, []int)
func (ControlEnvironmentRequest_Optype) String ¶
func (x ControlEnvironmentRequest_Optype) String() string
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) 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) 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) }
ControlServer is the server API for Control service.
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 { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DestroyEnvironmentReply) Descriptor ¶
func (*DestroyEnvironmentReply) Descriptor() ([]byte, []int)
func (*DestroyEnvironmentReply) Marshal ¶
func (m *DestroyEnvironmentReply) Marshal() (dAtA []byte, err error)
func (*DestroyEnvironmentReply) MarshalTo ¶
func (m *DestroyEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
func (*DestroyEnvironmentReply) ProtoMessage ¶
func (*DestroyEnvironmentReply) ProtoMessage()
func (*DestroyEnvironmentReply) Reset ¶
func (m *DestroyEnvironmentReply) Reset()
func (*DestroyEnvironmentReply) Size ¶
func (m *DestroyEnvironmentReply) Size() (n int)
func (*DestroyEnvironmentReply) String ¶
func (m *DestroyEnvironmentReply) String() string
func (*DestroyEnvironmentReply) Unmarshal ¶
func (m *DestroyEnvironmentReply) Unmarshal(dAtA []byte) error
func (*DestroyEnvironmentReply) XXX_DiscardUnknown ¶
func (m *DestroyEnvironmentReply) XXX_DiscardUnknown()
func (*DestroyEnvironmentReply) XXX_Marshal ¶
func (m *DestroyEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroyEnvironmentReply) XXX_Merge ¶
func (m *DestroyEnvironmentReply) XXX_Merge(src proto.Message)
func (*DestroyEnvironmentReply) XXX_Size ¶
func (m *DestroyEnvironmentReply) XXX_Size() int
func (*DestroyEnvironmentReply) XXX_Unmarshal ¶
func (m *DestroyEnvironmentReply) XXX_Unmarshal(b []byte) error
type DestroyEnvironmentRequest ¶
type DestroyEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DestroyEnvironmentRequest) Descriptor ¶
func (*DestroyEnvironmentRequest) Descriptor() ([]byte, []int)
func (*DestroyEnvironmentRequest) GetId ¶
func (m *DestroyEnvironmentRequest) GetId() string
func (*DestroyEnvironmentRequest) Marshal ¶
func (m *DestroyEnvironmentRequest) Marshal() (dAtA []byte, err error)
func (*DestroyEnvironmentRequest) MarshalTo ¶
func (m *DestroyEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*DestroyEnvironmentRequest) ProtoMessage ¶
func (*DestroyEnvironmentRequest) ProtoMessage()
func (*DestroyEnvironmentRequest) Reset ¶
func (m *DestroyEnvironmentRequest) Reset()
func (*DestroyEnvironmentRequest) Size ¶
func (m *DestroyEnvironmentRequest) Size() (n int)
func (*DestroyEnvironmentRequest) String ¶
func (m *DestroyEnvironmentRequest) String() string
func (*DestroyEnvironmentRequest) Unmarshal ¶
func (m *DestroyEnvironmentRequest) Unmarshal(dAtA []byte) error
func (*DestroyEnvironmentRequest) XXX_DiscardUnknown ¶
func (m *DestroyEnvironmentRequest) XXX_DiscardUnknown()
func (*DestroyEnvironmentRequest) XXX_Marshal ¶
func (m *DestroyEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DestroyEnvironmentRequest) XXX_Merge ¶
func (m *DestroyEnvironmentRequest) XXX_Merge(src proto.Message)
func (*DestroyEnvironmentRequest) XXX_Size ¶
func (m *DestroyEnvironmentRequest) XXX_Size() int
func (*DestroyEnvironmentRequest) XXX_Unmarshal ¶
func (m *DestroyEnvironmentRequest) XXX_Unmarshal(b []byte) error
type EnvironmentInfo ¶
type EnvironmentInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` CreatedWhen string `protobuf:"bytes,2,opt,name=createdWhen,proto3" json:"createdWhen,omitempty"` 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 uint64 `protobuf:"varint,6,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EnvironmentInfo) Descriptor ¶
func (*EnvironmentInfo) Descriptor() ([]byte, []int)
func (*EnvironmentInfo) GetCreatedWhen ¶
func (m *EnvironmentInfo) GetCreatedWhen() string
func (*EnvironmentInfo) GetCurrentRunNumber ¶ added in v0.8.0
func (m *EnvironmentInfo) GetCurrentRunNumber() uint64
func (*EnvironmentInfo) GetId ¶
func (m *EnvironmentInfo) GetId() string
func (*EnvironmentInfo) GetRootRole ¶
func (m *EnvironmentInfo) GetRootRole() string
func (*EnvironmentInfo) GetState ¶
func (m *EnvironmentInfo) GetState() string
func (*EnvironmentInfo) GetTasks ¶
func (m *EnvironmentInfo) GetTasks() []*ShortTaskInfo
func (*EnvironmentInfo) Marshal ¶
func (m *EnvironmentInfo) Marshal() (dAtA []byte, err error)
func (*EnvironmentInfo) ProtoMessage ¶
func (*EnvironmentInfo) ProtoMessage()
func (*EnvironmentInfo) Reset ¶
func (m *EnvironmentInfo) Reset()
func (*EnvironmentInfo) Size ¶
func (m *EnvironmentInfo) Size() (n int)
func (*EnvironmentInfo) String ¶
func (m *EnvironmentInfo) String() string
func (*EnvironmentInfo) Unmarshal ¶
func (m *EnvironmentInfo) Unmarshal(dAtA []byte) error
func (*EnvironmentInfo) XXX_DiscardUnknown ¶
func (m *EnvironmentInfo) XXX_DiscardUnknown()
func (*EnvironmentInfo) XXX_Marshal ¶
func (m *EnvironmentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvironmentInfo) XXX_Merge ¶
func (m *EnvironmentInfo) XXX_Merge(src proto.Message)
func (*EnvironmentInfo) XXX_Size ¶
func (m *EnvironmentInfo) XXX_Size() int
func (*EnvironmentInfo) XXX_Unmarshal ¶
func (m *EnvironmentInfo) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EnvironmentOperation) Descriptor ¶
func (*EnvironmentOperation) Descriptor() ([]byte, []int)
func (*EnvironmentOperation) GetRoleName ¶
func (m *EnvironmentOperation) GetRoleName() string
func (*EnvironmentOperation) GetType ¶
func (m *EnvironmentOperation) GetType() EnvironmentOperation_Optype
func (*EnvironmentOperation) Marshal ¶
func (m *EnvironmentOperation) Marshal() (dAtA []byte, err error)
func (*EnvironmentOperation) MarshalTo ¶
func (m *EnvironmentOperation) MarshalTo(dAtA []byte) (int, error)
func (*EnvironmentOperation) ProtoMessage ¶
func (*EnvironmentOperation) ProtoMessage()
func (*EnvironmentOperation) Reset ¶
func (m *EnvironmentOperation) Reset()
func (*EnvironmentOperation) Size ¶
func (m *EnvironmentOperation) Size() (n int)
func (*EnvironmentOperation) String ¶
func (m *EnvironmentOperation) String() string
func (*EnvironmentOperation) Unmarshal ¶
func (m *EnvironmentOperation) Unmarshal(dAtA []byte) error
func (*EnvironmentOperation) XXX_DiscardUnknown ¶
func (m *EnvironmentOperation) XXX_DiscardUnknown()
func (*EnvironmentOperation) XXX_Marshal ¶
func (m *EnvironmentOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnvironmentOperation) XXX_Merge ¶
func (m *EnvironmentOperation) XXX_Merge(src proto.Message)
func (*EnvironmentOperation) XXX_Size ¶
func (m *EnvironmentOperation) XXX_Size() int
func (*EnvironmentOperation) XXX_Unmarshal ¶
func (m *EnvironmentOperation) XXX_Unmarshal(b []byte) error
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) EnumDescriptor ¶
func (EnvironmentOperation_Optype) EnumDescriptor() ([]byte, []int)
func (EnvironmentOperation_Optype) String ¶
func (x EnvironmentOperation_Optype) String() string
type Event_MesosHeartbeat ¶
type Event_MesosHeartbeat struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Event_MesosHeartbeat) Descriptor ¶
func (*Event_MesosHeartbeat) Descriptor() ([]byte, []int)
func (*Event_MesosHeartbeat) Marshal ¶
func (m *Event_MesosHeartbeat) Marshal() (dAtA []byte, err error)
func (*Event_MesosHeartbeat) MarshalTo ¶
func (m *Event_MesosHeartbeat) MarshalTo(dAtA []byte) (int, error)
func (*Event_MesosHeartbeat) ProtoMessage ¶
func (*Event_MesosHeartbeat) ProtoMessage()
func (*Event_MesosHeartbeat) Reset ¶
func (m *Event_MesosHeartbeat) Reset()
func (*Event_MesosHeartbeat) Size ¶
func (m *Event_MesosHeartbeat) Size() (n int)
func (*Event_MesosHeartbeat) String ¶
func (m *Event_MesosHeartbeat) String() string
func (*Event_MesosHeartbeat) Unmarshal ¶
func (m *Event_MesosHeartbeat) Unmarshal(dAtA []byte) error
func (*Event_MesosHeartbeat) XXX_DiscardUnknown ¶
func (m *Event_MesosHeartbeat) XXX_DiscardUnknown()
func (*Event_MesosHeartbeat) XXX_Marshal ¶
func (m *Event_MesosHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Event_MesosHeartbeat) XXX_Merge ¶
func (m *Event_MesosHeartbeat) XXX_Merge(src proto.Message)
func (*Event_MesosHeartbeat) XXX_Size ¶
func (m *Event_MesosHeartbeat) XXX_Size() int
func (*Event_MesosHeartbeat) XXX_Unmarshal ¶
func (m *Event_MesosHeartbeat) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetEnvironmentReply) Descriptor ¶
func (*GetEnvironmentReply) Descriptor() ([]byte, []int)
func (*GetEnvironmentReply) GetEnvironment ¶
func (m *GetEnvironmentReply) GetEnvironment() *EnvironmentInfo
func (*GetEnvironmentReply) GetWorkflow ¶
func (m *GetEnvironmentReply) GetWorkflow() *RoleInfo
func (*GetEnvironmentReply) Marshal ¶
func (m *GetEnvironmentReply) Marshal() (dAtA []byte, err error)
func (*GetEnvironmentReply) MarshalTo ¶
func (m *GetEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
func (*GetEnvironmentReply) ProtoMessage ¶
func (*GetEnvironmentReply) ProtoMessage()
func (*GetEnvironmentReply) Reset ¶
func (m *GetEnvironmentReply) Reset()
func (*GetEnvironmentReply) Size ¶
func (m *GetEnvironmentReply) Size() (n int)
func (*GetEnvironmentReply) String ¶
func (m *GetEnvironmentReply) String() string
func (*GetEnvironmentReply) Unmarshal ¶
func (m *GetEnvironmentReply) Unmarshal(dAtA []byte) error
func (*GetEnvironmentReply) XXX_DiscardUnknown ¶
func (m *GetEnvironmentReply) XXX_DiscardUnknown()
func (*GetEnvironmentReply) XXX_Marshal ¶
func (m *GetEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetEnvironmentReply) XXX_Merge ¶
func (m *GetEnvironmentReply) XXX_Merge(src proto.Message)
func (*GetEnvironmentReply) XXX_Size ¶
func (m *GetEnvironmentReply) XXX_Size() int
func (*GetEnvironmentReply) XXX_Unmarshal ¶
func (m *GetEnvironmentReply) XXX_Unmarshal(b []byte) error
type GetEnvironmentRequest ¶
type GetEnvironmentRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetEnvironmentRequest) Descriptor ¶
func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)
func (*GetEnvironmentRequest) GetId ¶
func (m *GetEnvironmentRequest) GetId() string
func (*GetEnvironmentRequest) Marshal ¶
func (m *GetEnvironmentRequest) Marshal() (dAtA []byte, err error)
func (*GetEnvironmentRequest) MarshalTo ¶
func (m *GetEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetEnvironmentRequest) ProtoMessage ¶
func (*GetEnvironmentRequest) ProtoMessage()
func (*GetEnvironmentRequest) Reset ¶
func (m *GetEnvironmentRequest) Reset()
func (*GetEnvironmentRequest) Size ¶
func (m *GetEnvironmentRequest) Size() (n int)
func (*GetEnvironmentRequest) String ¶
func (m *GetEnvironmentRequest) String() string
func (*GetEnvironmentRequest) Unmarshal ¶
func (m *GetEnvironmentRequest) Unmarshal(dAtA []byte) error
func (*GetEnvironmentRequest) XXX_DiscardUnknown ¶
func (m *GetEnvironmentRequest) XXX_DiscardUnknown()
func (*GetEnvironmentRequest) XXX_Marshal ¶
func (m *GetEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetEnvironmentRequest) XXX_Merge ¶
func (m *GetEnvironmentRequest) XXX_Merge(src proto.Message)
func (*GetEnvironmentRequest) XXX_Size ¶
func (m *GetEnvironmentRequest) XXX_Size() int
func (*GetEnvironmentRequest) XXX_Unmarshal ¶
func (m *GetEnvironmentRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetEnvironmentsReply) Descriptor ¶
func (*GetEnvironmentsReply) Descriptor() ([]byte, []int)
func (*GetEnvironmentsReply) GetEnvironments ¶
func (m *GetEnvironmentsReply) GetEnvironments() []*EnvironmentInfo
func (*GetEnvironmentsReply) GetFrameworkId ¶
func (m *GetEnvironmentsReply) GetFrameworkId() string
func (*GetEnvironmentsReply) Marshal ¶
func (m *GetEnvironmentsReply) Marshal() (dAtA []byte, err error)
func (*GetEnvironmentsReply) MarshalTo ¶
func (m *GetEnvironmentsReply) MarshalTo(dAtA []byte) (int, error)
func (*GetEnvironmentsReply) ProtoMessage ¶
func (*GetEnvironmentsReply) ProtoMessage()
func (*GetEnvironmentsReply) Reset ¶
func (m *GetEnvironmentsReply) Reset()
func (*GetEnvironmentsReply) Size ¶
func (m *GetEnvironmentsReply) Size() (n int)
func (*GetEnvironmentsReply) String ¶
func (m *GetEnvironmentsReply) String() string
func (*GetEnvironmentsReply) Unmarshal ¶
func (m *GetEnvironmentsReply) Unmarshal(dAtA []byte) error
func (*GetEnvironmentsReply) XXX_DiscardUnknown ¶
func (m *GetEnvironmentsReply) XXX_DiscardUnknown()
func (*GetEnvironmentsReply) XXX_Marshal ¶
func (m *GetEnvironmentsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetEnvironmentsReply) XXX_Merge ¶
func (m *GetEnvironmentsReply) XXX_Merge(src proto.Message)
func (*GetEnvironmentsReply) XXX_Size ¶
func (m *GetEnvironmentsReply) XXX_Size() int
func (*GetEnvironmentsReply) XXX_Unmarshal ¶
func (m *GetEnvironmentsReply) XXX_Unmarshal(b []byte) error
type GetEnvironmentsRequest ¶
type GetEnvironmentsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
////////////////////////////////////// Environment //////////////////////////////////////
func (*GetEnvironmentsRequest) Descriptor ¶
func (*GetEnvironmentsRequest) Descriptor() ([]byte, []int)
func (*GetEnvironmentsRequest) Marshal ¶
func (m *GetEnvironmentsRequest) Marshal() (dAtA []byte, err error)
func (*GetEnvironmentsRequest) MarshalTo ¶
func (m *GetEnvironmentsRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetEnvironmentsRequest) ProtoMessage ¶
func (*GetEnvironmentsRequest) ProtoMessage()
func (*GetEnvironmentsRequest) Reset ¶
func (m *GetEnvironmentsRequest) Reset()
func (*GetEnvironmentsRequest) Size ¶
func (m *GetEnvironmentsRequest) Size() (n int)
func (*GetEnvironmentsRequest) String ¶
func (m *GetEnvironmentsRequest) String() string
func (*GetEnvironmentsRequest) Unmarshal ¶
func (m *GetEnvironmentsRequest) Unmarshal(dAtA []byte) error
func (*GetEnvironmentsRequest) XXX_DiscardUnknown ¶
func (m *GetEnvironmentsRequest) XXX_DiscardUnknown()
func (*GetEnvironmentsRequest) XXX_Marshal ¶
func (m *GetEnvironmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetEnvironmentsRequest) XXX_Merge ¶
func (m *GetEnvironmentsRequest) XXX_Merge(src proto.Message)
func (*GetEnvironmentsRequest) XXX_Size ¶
func (m *GetEnvironmentsRequest) XXX_Size() int
func (*GetEnvironmentsRequest) XXX_Unmarshal ¶
func (m *GetEnvironmentsRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetFrameworkInfoReply) Descriptor ¶
func (*GetFrameworkInfoReply) Descriptor() ([]byte, []int)
func (*GetFrameworkInfoReply) GetEnvironmentsCount ¶
func (m *GetFrameworkInfoReply) GetEnvironmentsCount() int32
func (*GetFrameworkInfoReply) GetFrameworkId ¶
func (m *GetFrameworkInfoReply) GetFrameworkId() string
func (*GetFrameworkInfoReply) GetHostsCount ¶
func (m *GetFrameworkInfoReply) GetHostsCount() int32
func (*GetFrameworkInfoReply) GetInstanceName ¶ added in v0.7.0
func (m *GetFrameworkInfoReply) GetInstanceName() string
func (*GetFrameworkInfoReply) GetState ¶
func (m *GetFrameworkInfoReply) GetState() string
func (*GetFrameworkInfoReply) GetTasksCount ¶
func (m *GetFrameworkInfoReply) GetTasksCount() int32
func (*GetFrameworkInfoReply) GetVersion ¶ added in v0.7.0
func (m *GetFrameworkInfoReply) GetVersion() *Version
func (*GetFrameworkInfoReply) Marshal ¶
func (m *GetFrameworkInfoReply) Marshal() (dAtA []byte, err error)
func (*GetFrameworkInfoReply) MarshalTo ¶
func (m *GetFrameworkInfoReply) MarshalTo(dAtA []byte) (int, error)
func (*GetFrameworkInfoReply) ProtoMessage ¶
func (*GetFrameworkInfoReply) ProtoMessage()
func (*GetFrameworkInfoReply) Reset ¶
func (m *GetFrameworkInfoReply) Reset()
func (*GetFrameworkInfoReply) Size ¶
func (m *GetFrameworkInfoReply) Size() (n int)
func (*GetFrameworkInfoReply) String ¶
func (m *GetFrameworkInfoReply) String() string
func (*GetFrameworkInfoReply) Unmarshal ¶
func (m *GetFrameworkInfoReply) Unmarshal(dAtA []byte) error
func (*GetFrameworkInfoReply) XXX_DiscardUnknown ¶
func (m *GetFrameworkInfoReply) XXX_DiscardUnknown()
func (*GetFrameworkInfoReply) XXX_Marshal ¶
func (m *GetFrameworkInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFrameworkInfoReply) XXX_Merge ¶
func (m *GetFrameworkInfoReply) XXX_Merge(src proto.Message)
func (*GetFrameworkInfoReply) XXX_Size ¶
func (m *GetFrameworkInfoReply) XXX_Size() int
func (*GetFrameworkInfoReply) XXX_Unmarshal ¶
func (m *GetFrameworkInfoReply) XXX_Unmarshal(b []byte) error
type GetFrameworkInfoRequest ¶
type GetFrameworkInfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
////////////////////////////////////// Framework //////////////////////////////////////
func (*GetFrameworkInfoRequest) Descriptor ¶
func (*GetFrameworkInfoRequest) Descriptor() ([]byte, []int)
func (*GetFrameworkInfoRequest) Marshal ¶
func (m *GetFrameworkInfoRequest) Marshal() (dAtA []byte, err error)
func (*GetFrameworkInfoRequest) MarshalTo ¶
func (m *GetFrameworkInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetFrameworkInfoRequest) ProtoMessage ¶
func (*GetFrameworkInfoRequest) ProtoMessage()
func (*GetFrameworkInfoRequest) Reset ¶
func (m *GetFrameworkInfoRequest) Reset()
func (*GetFrameworkInfoRequest) Size ¶
func (m *GetFrameworkInfoRequest) Size() (n int)
func (*GetFrameworkInfoRequest) String ¶
func (m *GetFrameworkInfoRequest) String() string
func (*GetFrameworkInfoRequest) Unmarshal ¶
func (m *GetFrameworkInfoRequest) Unmarshal(dAtA []byte) error
func (*GetFrameworkInfoRequest) XXX_DiscardUnknown ¶
func (m *GetFrameworkInfoRequest) XXX_DiscardUnknown()
func (*GetFrameworkInfoRequest) XXX_Marshal ¶
func (m *GetFrameworkInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetFrameworkInfoRequest) XXX_Merge ¶
func (m *GetFrameworkInfoRequest) XXX_Merge(src proto.Message)
func (*GetFrameworkInfoRequest) XXX_Size ¶
func (m *GetFrameworkInfoRequest) XXX_Size() int
func (*GetFrameworkInfoRequest) XXX_Unmarshal ¶
func (m *GetFrameworkInfoRequest) XXX_Unmarshal(b []byte) error
type GetRolesReply ¶
type GetRolesReply struct { Roles []*RoleInfo `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRolesReply) Descriptor ¶
func (*GetRolesReply) Descriptor() ([]byte, []int)
func (*GetRolesReply) GetRoles ¶
func (m *GetRolesReply) GetRoles() []*RoleInfo
func (*GetRolesReply) Marshal ¶
func (m *GetRolesReply) Marshal() (dAtA []byte, err error)
func (*GetRolesReply) ProtoMessage ¶
func (*GetRolesReply) ProtoMessage()
func (*GetRolesReply) Reset ¶
func (m *GetRolesReply) Reset()
func (*GetRolesReply) Size ¶
func (m *GetRolesReply) Size() (n int)
func (*GetRolesReply) String ¶
func (m *GetRolesReply) String() string
func (*GetRolesReply) Unmarshal ¶
func (m *GetRolesReply) Unmarshal(dAtA []byte) error
func (*GetRolesReply) XXX_DiscardUnknown ¶
func (m *GetRolesReply) XXX_DiscardUnknown()
func (*GetRolesReply) XXX_Marshal ¶
func (m *GetRolesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRolesReply) XXX_Merge ¶
func (m *GetRolesReply) XXX_Merge(src proto.Message)
func (*GetRolesReply) XXX_Size ¶
func (m *GetRolesReply) XXX_Size() int
func (*GetRolesReply) XXX_Unmarshal ¶
func (m *GetRolesReply) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
////////////////////////////////////// Roles //////////////////////////////////////
func (*GetRolesRequest) Descriptor ¶
func (*GetRolesRequest) Descriptor() ([]byte, []int)
func (*GetRolesRequest) GetEnvId ¶
func (m *GetRolesRequest) GetEnvId() string
func (*GetRolesRequest) GetPathSpec ¶
func (m *GetRolesRequest) GetPathSpec() string
func (*GetRolesRequest) Marshal ¶
func (m *GetRolesRequest) Marshal() (dAtA []byte, err error)
func (*GetRolesRequest) ProtoMessage ¶
func (*GetRolesRequest) ProtoMessage()
func (*GetRolesRequest) Reset ¶
func (m *GetRolesRequest) Reset()
func (*GetRolesRequest) Size ¶
func (m *GetRolesRequest) Size() (n int)
func (*GetRolesRequest) String ¶
func (m *GetRolesRequest) String() string
func (*GetRolesRequest) Unmarshal ¶
func (m *GetRolesRequest) Unmarshal(dAtA []byte) error
func (*GetRolesRequest) XXX_DiscardUnknown ¶
func (m *GetRolesRequest) XXX_DiscardUnknown()
func (*GetRolesRequest) XXX_Marshal ¶
func (m *GetRolesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRolesRequest) XXX_Merge ¶
func (m *GetRolesRequest) XXX_Merge(src proto.Message)
func (*GetRolesRequest) XXX_Size ¶
func (m *GetRolesRequest) XXX_Size() int
func (*GetRolesRequest) XXX_Unmarshal ¶
func (m *GetRolesRequest) XXX_Unmarshal(b []byte) error
type GetTaskReply ¶
type GetTaskReply struct { Task *TaskInfo `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTaskReply) Descriptor ¶
func (*GetTaskReply) Descriptor() ([]byte, []int)
func (*GetTaskReply) GetTask ¶
func (m *GetTaskReply) GetTask() *TaskInfo
func (*GetTaskReply) Marshal ¶
func (m *GetTaskReply) Marshal() (dAtA []byte, err error)
func (*GetTaskReply) ProtoMessage ¶
func (*GetTaskReply) ProtoMessage()
func (*GetTaskReply) Reset ¶
func (m *GetTaskReply) Reset()
func (*GetTaskReply) Size ¶
func (m *GetTaskReply) Size() (n int)
func (*GetTaskReply) String ¶
func (m *GetTaskReply) String() string
func (*GetTaskReply) Unmarshal ¶
func (m *GetTaskReply) Unmarshal(dAtA []byte) error
func (*GetTaskReply) XXX_DiscardUnknown ¶
func (m *GetTaskReply) XXX_DiscardUnknown()
func (*GetTaskReply) XXX_Marshal ¶
func (m *GetTaskReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTaskReply) XXX_Merge ¶
func (m *GetTaskReply) XXX_Merge(src proto.Message)
func (*GetTaskReply) XXX_Size ¶
func (m *GetTaskReply) XXX_Size() int
func (*GetTaskReply) XXX_Unmarshal ¶
func (m *GetTaskReply) XXX_Unmarshal(b []byte) error
type GetTaskRequest ¶
type GetTaskRequest struct { TaskId string `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTaskRequest) Descriptor ¶
func (*GetTaskRequest) Descriptor() ([]byte, []int)
func (*GetTaskRequest) GetTaskId ¶
func (m *GetTaskRequest) GetTaskId() string
func (*GetTaskRequest) Marshal ¶
func (m *GetTaskRequest) Marshal() (dAtA []byte, err error)
func (*GetTaskRequest) ProtoMessage ¶
func (*GetTaskRequest) ProtoMessage()
func (*GetTaskRequest) Reset ¶
func (m *GetTaskRequest) Reset()
func (*GetTaskRequest) Size ¶
func (m *GetTaskRequest) Size() (n int)
func (*GetTaskRequest) String ¶
func (m *GetTaskRequest) String() string
func (*GetTaskRequest) Unmarshal ¶
func (m *GetTaskRequest) Unmarshal(dAtA []byte) error
func (*GetTaskRequest) XXX_DiscardUnknown ¶
func (m *GetTaskRequest) XXX_DiscardUnknown()
func (*GetTaskRequest) XXX_Marshal ¶
func (m *GetTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTaskRequest) XXX_Merge ¶
func (m *GetTaskRequest) XXX_Merge(src proto.Message)
func (*GetTaskRequest) XXX_Size ¶
func (m *GetTaskRequest) XXX_Size() int
func (*GetTaskRequest) XXX_Unmarshal ¶
func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error
type GetTasksReply ¶
type GetTasksReply struct { Tasks []*ShortTaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTasksReply) Descriptor ¶
func (*GetTasksReply) Descriptor() ([]byte, []int)
func (*GetTasksReply) GetTasks ¶
func (m *GetTasksReply) GetTasks() []*ShortTaskInfo
func (*GetTasksReply) Marshal ¶
func (m *GetTasksReply) Marshal() (dAtA []byte, err error)
func (*GetTasksReply) ProtoMessage ¶
func (*GetTasksReply) ProtoMessage()
func (*GetTasksReply) Reset ¶
func (m *GetTasksReply) Reset()
func (*GetTasksReply) Size ¶
func (m *GetTasksReply) Size() (n int)
func (*GetTasksReply) String ¶
func (m *GetTasksReply) String() string
func (*GetTasksReply) Unmarshal ¶
func (m *GetTasksReply) Unmarshal(dAtA []byte) error
func (*GetTasksReply) XXX_DiscardUnknown ¶
func (m *GetTasksReply) XXX_DiscardUnknown()
func (*GetTasksReply) XXX_Marshal ¶
func (m *GetTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTasksReply) XXX_Merge ¶
func (m *GetTasksReply) XXX_Merge(src proto.Message)
func (*GetTasksReply) XXX_Size ¶
func (m *GetTasksReply) XXX_Size() int
func (*GetTasksReply) XXX_Unmarshal ¶
func (m *GetTasksReply) XXX_Unmarshal(b []byte) error
type GetTasksRequest ¶
type GetTasksRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTasksRequest) Descriptor ¶
func (*GetTasksRequest) Descriptor() ([]byte, []int)
func (*GetTasksRequest) Marshal ¶
func (m *GetTasksRequest) Marshal() (dAtA []byte, err error)
func (*GetTasksRequest) ProtoMessage ¶
func (*GetTasksRequest) ProtoMessage()
func (*GetTasksRequest) Reset ¶
func (m *GetTasksRequest) Reset()
func (*GetTasksRequest) Size ¶
func (m *GetTasksRequest) Size() (n int)
func (*GetTasksRequest) String ¶
func (m *GetTasksRequest) String() string
func (*GetTasksRequest) Unmarshal ¶
func (m *GetTasksRequest) Unmarshal(dAtA []byte) error
func (*GetTasksRequest) XXX_DiscardUnknown ¶
func (m *GetTasksRequest) XXX_DiscardUnknown()
func (*GetTasksRequest) XXX_Marshal ¶
func (m *GetTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTasksRequest) XXX_Merge ¶
func (m *GetTasksRequest) XXX_Merge(src proto.Message)
func (*GetTasksRequest) XXX_Size ¶
func (m *GetTasksRequest) XXX_Size() int
func (*GetTasksRequest) XXX_Unmarshal ¶
func (m *GetTasksRequest) XXX_Unmarshal(b []byte) error
type GetWorkflowTemplatesReply ¶
type GetWorkflowTemplatesReply struct { WorkflowTemplates []string `protobuf:"bytes,1,rep,name=workflowTemplates,proto3" json:"workflowTemplates,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetWorkflowTemplatesReply) Descriptor ¶
func (*GetWorkflowTemplatesReply) Descriptor() ([]byte, []int)
func (*GetWorkflowTemplatesReply) GetWorkflowTemplates ¶
func (m *GetWorkflowTemplatesReply) GetWorkflowTemplates() []string
func (*GetWorkflowTemplatesReply) Marshal ¶
func (m *GetWorkflowTemplatesReply) Marshal() (dAtA []byte, err error)
func (*GetWorkflowTemplatesReply) MarshalTo ¶
func (m *GetWorkflowTemplatesReply) MarshalTo(dAtA []byte) (int, error)
func (*GetWorkflowTemplatesReply) ProtoMessage ¶
func (*GetWorkflowTemplatesReply) ProtoMessage()
func (*GetWorkflowTemplatesReply) Reset ¶
func (m *GetWorkflowTemplatesReply) Reset()
func (*GetWorkflowTemplatesReply) Size ¶
func (m *GetWorkflowTemplatesReply) Size() (n int)
func (*GetWorkflowTemplatesReply) String ¶
func (m *GetWorkflowTemplatesReply) String() string
func (*GetWorkflowTemplatesReply) Unmarshal ¶
func (m *GetWorkflowTemplatesReply) Unmarshal(dAtA []byte) error
func (*GetWorkflowTemplatesReply) XXX_DiscardUnknown ¶
func (m *GetWorkflowTemplatesReply) XXX_DiscardUnknown()
func (*GetWorkflowTemplatesReply) XXX_Marshal ¶
func (m *GetWorkflowTemplatesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetWorkflowTemplatesReply) XXX_Merge ¶
func (m *GetWorkflowTemplatesReply) XXX_Merge(src proto.Message)
func (*GetWorkflowTemplatesReply) XXX_Size ¶
func (m *GetWorkflowTemplatesReply) XXX_Size() int
func (*GetWorkflowTemplatesReply) XXX_Unmarshal ¶
func (m *GetWorkflowTemplatesReply) XXX_Unmarshal(b []byte) error
type GetWorkflowTemplatesRequest ¶
type GetWorkflowTemplatesRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetWorkflowTemplatesRequest) Descriptor ¶
func (*GetWorkflowTemplatesRequest) Descriptor() ([]byte, []int)
func (*GetWorkflowTemplatesRequest) Marshal ¶
func (m *GetWorkflowTemplatesRequest) Marshal() (dAtA []byte, err error)
func (*GetWorkflowTemplatesRequest) MarshalTo ¶
func (m *GetWorkflowTemplatesRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetWorkflowTemplatesRequest) ProtoMessage ¶
func (*GetWorkflowTemplatesRequest) ProtoMessage()
func (*GetWorkflowTemplatesRequest) Reset ¶
func (m *GetWorkflowTemplatesRequest) Reset()
func (*GetWorkflowTemplatesRequest) Size ¶
func (m *GetWorkflowTemplatesRequest) Size() (n int)
func (*GetWorkflowTemplatesRequest) String ¶
func (m *GetWorkflowTemplatesRequest) String() string
func (*GetWorkflowTemplatesRequest) Unmarshal ¶
func (m *GetWorkflowTemplatesRequest) Unmarshal(dAtA []byte) error
func (*GetWorkflowTemplatesRequest) XXX_DiscardUnknown ¶
func (m *GetWorkflowTemplatesRequest) XXX_DiscardUnknown()
func (*GetWorkflowTemplatesRequest) XXX_Marshal ¶
func (m *GetWorkflowTemplatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetWorkflowTemplatesRequest) XXX_Merge ¶
func (m *GetWorkflowTemplatesRequest) XXX_Merge(src proto.Message)
func (*GetWorkflowTemplatesRequest) XXX_Size ¶
func (m *GetWorkflowTemplatesRequest) XXX_Size() int
func (*GetWorkflowTemplatesRequest) XXX_Unmarshal ¶
func (m *GetWorkflowTemplatesRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyEnvironmentReply) Descriptor ¶
func (*ModifyEnvironmentReply) Descriptor() ([]byte, []int)
func (*ModifyEnvironmentReply) GetFailedOperations ¶
func (m *ModifyEnvironmentReply) GetFailedOperations() []*EnvironmentOperation
func (*ModifyEnvironmentReply) GetId ¶
func (m *ModifyEnvironmentReply) GetId() string
func (*ModifyEnvironmentReply) GetState ¶
func (m *ModifyEnvironmentReply) GetState() string
func (*ModifyEnvironmentReply) Marshal ¶
func (m *ModifyEnvironmentReply) Marshal() (dAtA []byte, err error)
func (*ModifyEnvironmentReply) MarshalTo ¶
func (m *ModifyEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
func (*ModifyEnvironmentReply) ProtoMessage ¶
func (*ModifyEnvironmentReply) ProtoMessage()
func (*ModifyEnvironmentReply) Reset ¶
func (m *ModifyEnvironmentReply) Reset()
func (*ModifyEnvironmentReply) Size ¶
func (m *ModifyEnvironmentReply) Size() (n int)
func (*ModifyEnvironmentReply) String ¶
func (m *ModifyEnvironmentReply) String() string
func (*ModifyEnvironmentReply) Unmarshal ¶
func (m *ModifyEnvironmentReply) Unmarshal(dAtA []byte) error
func (*ModifyEnvironmentReply) XXX_DiscardUnknown ¶
func (m *ModifyEnvironmentReply) XXX_DiscardUnknown()
func (*ModifyEnvironmentReply) XXX_Marshal ¶
func (m *ModifyEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyEnvironmentReply) XXX_Merge ¶
func (m *ModifyEnvironmentReply) XXX_Merge(src proto.Message)
func (*ModifyEnvironmentReply) XXX_Size ¶
func (m *ModifyEnvironmentReply) XXX_Size() int
func (*ModifyEnvironmentReply) XXX_Unmarshal ¶
func (m *ModifyEnvironmentReply) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ModifyEnvironmentRequest) Descriptor ¶
func (*ModifyEnvironmentRequest) Descriptor() ([]byte, []int)
func (*ModifyEnvironmentRequest) GetId ¶
func (m *ModifyEnvironmentRequest) GetId() string
func (*ModifyEnvironmentRequest) GetOperations ¶
func (m *ModifyEnvironmentRequest) GetOperations() []*EnvironmentOperation
func (*ModifyEnvironmentRequest) GetReconfigureAll ¶
func (m *ModifyEnvironmentRequest) GetReconfigureAll() bool
func (*ModifyEnvironmentRequest) Marshal ¶
func (m *ModifyEnvironmentRequest) Marshal() (dAtA []byte, err error)
func (*ModifyEnvironmentRequest) MarshalTo ¶
func (m *ModifyEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*ModifyEnvironmentRequest) ProtoMessage ¶
func (*ModifyEnvironmentRequest) ProtoMessage()
func (*ModifyEnvironmentRequest) Reset ¶
func (m *ModifyEnvironmentRequest) Reset()
func (*ModifyEnvironmentRequest) Size ¶
func (m *ModifyEnvironmentRequest) Size() (n int)
func (*ModifyEnvironmentRequest) String ¶
func (m *ModifyEnvironmentRequest) String() string
func (*ModifyEnvironmentRequest) Unmarshal ¶
func (m *ModifyEnvironmentRequest) Unmarshal(dAtA []byte) error
func (*ModifyEnvironmentRequest) XXX_DiscardUnknown ¶
func (m *ModifyEnvironmentRequest) XXX_DiscardUnknown()
func (*ModifyEnvironmentRequest) XXX_Marshal ¶
func (m *ModifyEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyEnvironmentRequest) XXX_Merge ¶
func (m *ModifyEnvironmentRequest) XXX_Merge(src proto.Message)
func (*ModifyEnvironmentRequest) XXX_Size ¶
func (m *ModifyEnvironmentRequest) XXX_Size() int
func (*ModifyEnvironmentRequest) XXX_Unmarshal ¶
func (m *ModifyEnvironmentRequest) XXX_Unmarshal(b []byte) error
type NewEnvironmentReply ¶
type NewEnvironmentReply struct { Environment *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NewEnvironmentReply) Descriptor ¶
func (*NewEnvironmentReply) Descriptor() ([]byte, []int)
func (*NewEnvironmentReply) GetEnvironment ¶
func (m *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo
func (*NewEnvironmentReply) Marshal ¶
func (m *NewEnvironmentReply) Marshal() (dAtA []byte, err error)
func (*NewEnvironmentReply) MarshalTo ¶
func (m *NewEnvironmentReply) MarshalTo(dAtA []byte) (int, error)
func (*NewEnvironmentReply) ProtoMessage ¶
func (*NewEnvironmentReply) ProtoMessage()
func (*NewEnvironmentReply) Reset ¶
func (m *NewEnvironmentReply) Reset()
func (*NewEnvironmentReply) Size ¶
func (m *NewEnvironmentReply) Size() (n int)
func (*NewEnvironmentReply) String ¶
func (m *NewEnvironmentReply) String() string
func (*NewEnvironmentReply) Unmarshal ¶
func (m *NewEnvironmentReply) Unmarshal(dAtA []byte) error
func (*NewEnvironmentReply) XXX_DiscardUnknown ¶
func (m *NewEnvironmentReply) XXX_DiscardUnknown()
func (*NewEnvironmentReply) XXX_Marshal ¶
func (m *NewEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewEnvironmentReply) XXX_Merge ¶
func (m *NewEnvironmentReply) XXX_Merge(src proto.Message)
func (*NewEnvironmentReply) XXX_Size ¶
func (m *NewEnvironmentReply) XXX_Size() int
func (*NewEnvironmentReply) XXX_Unmarshal ¶
func (m *NewEnvironmentReply) XXX_Unmarshal(b []byte) error
type NewEnvironmentRequest ¶
type NewEnvironmentRequest struct { WorkflowTemplate string `protobuf:"bytes,1,opt,name=workflowTemplate,proto3" json:"workflowTemplate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NewEnvironmentRequest) Descriptor ¶
func (*NewEnvironmentRequest) Descriptor() ([]byte, []int)
func (*NewEnvironmentRequest) GetWorkflowTemplate ¶
func (m *NewEnvironmentRequest) GetWorkflowTemplate() string
func (*NewEnvironmentRequest) Marshal ¶
func (m *NewEnvironmentRequest) Marshal() (dAtA []byte, err error)
func (*NewEnvironmentRequest) MarshalTo ¶
func (m *NewEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*NewEnvironmentRequest) ProtoMessage ¶
func (*NewEnvironmentRequest) ProtoMessage()
func (*NewEnvironmentRequest) Reset ¶
func (m *NewEnvironmentRequest) Reset()
func (*NewEnvironmentRequest) Size ¶
func (m *NewEnvironmentRequest) Size() (n int)
func (*NewEnvironmentRequest) String ¶
func (m *NewEnvironmentRequest) String() string
func (*NewEnvironmentRequest) Unmarshal ¶
func (m *NewEnvironmentRequest) Unmarshal(dAtA []byte) error
func (*NewEnvironmentRequest) XXX_DiscardUnknown ¶
func (m *NewEnvironmentRequest) XXX_DiscardUnknown()
func (*NewEnvironmentRequest) XXX_Marshal ¶
func (m *NewEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewEnvironmentRequest) XXX_Merge ¶
func (m *NewEnvironmentRequest) XXX_Merge(src proto.Message)
func (*NewEnvironmentRequest) XXX_Size ¶
func (m *NewEnvironmentRequest) XXX_Size() int
func (*NewEnvironmentRequest) XXX_Unmarshal ¶
func (m *NewEnvironmentRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RoleInfo) Descriptor ¶
func (*RoleInfo) GetFullPath ¶
func (*RoleInfo) GetTaskIds ¶
func (*RoleInfo) ProtoMessage ¶
func (*RoleInfo) ProtoMessage()
func (*RoleInfo) XXX_DiscardUnknown ¶
func (m *RoleInfo) XXX_DiscardUnknown()
func (*RoleInfo) XXX_Marshal ¶
func (*RoleInfo) XXX_Unmarshal ¶
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
////////////////////////////////////// Tasks //////////////////////////////////////
func (*ShortTaskInfo) Descriptor ¶
func (*ShortTaskInfo) Descriptor() ([]byte, []int)
func (*ShortTaskInfo) GetClassName ¶
func (m *ShortTaskInfo) GetClassName() string
func (*ShortTaskInfo) GetDeploymentInfo ¶
func (m *ShortTaskInfo) GetDeploymentInfo() *TaskDeploymentInfo
func (*ShortTaskInfo) GetLocked ¶
func (m *ShortTaskInfo) GetLocked() bool
func (*ShortTaskInfo) GetName ¶
func (m *ShortTaskInfo) GetName() string
func (*ShortTaskInfo) GetState ¶
func (m *ShortTaskInfo) GetState() string
func (*ShortTaskInfo) GetStatus ¶
func (m *ShortTaskInfo) GetStatus() string
func (*ShortTaskInfo) GetTaskId ¶
func (m *ShortTaskInfo) GetTaskId() string
func (*ShortTaskInfo) Marshal ¶
func (m *ShortTaskInfo) Marshal() (dAtA []byte, err error)
func (*ShortTaskInfo) ProtoMessage ¶
func (*ShortTaskInfo) ProtoMessage()
func (*ShortTaskInfo) Reset ¶
func (m *ShortTaskInfo) Reset()
func (*ShortTaskInfo) Size ¶
func (m *ShortTaskInfo) Size() (n int)
func (*ShortTaskInfo) String ¶
func (m *ShortTaskInfo) String() string
func (*ShortTaskInfo) Unmarshal ¶
func (m *ShortTaskInfo) Unmarshal(dAtA []byte) error
func (*ShortTaskInfo) XXX_DiscardUnknown ¶
func (m *ShortTaskInfo) XXX_DiscardUnknown()
func (*ShortTaskInfo) XXX_Marshal ¶
func (m *ShortTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShortTaskInfo) XXX_Merge ¶
func (m *ShortTaskInfo) XXX_Merge(src proto.Message)
func (*ShortTaskInfo) XXX_Size ¶
func (m *ShortTaskInfo) XXX_Size() int
func (*ShortTaskInfo) XXX_Unmarshal ¶
func (m *ShortTaskInfo) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusReply) Descriptor ¶
func (*StatusReply) Descriptor() ([]byte, []int)
func (*StatusReply) GetState ¶
func (m *StatusReply) GetState() string
func (*StatusReply) GetStatusUpdates ¶
func (m *StatusReply) GetStatusUpdates() []*StatusUpdate
func (*StatusReply) Marshal ¶
func (m *StatusReply) Marshal() (dAtA []byte, err error)
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) Reset ¶
func (m *StatusReply) Reset()
func (*StatusReply) Size ¶
func (m *StatusReply) Size() (n int)
func (*StatusReply) String ¶
func (m *StatusReply) String() string
func (*StatusReply) Unmarshal ¶
func (m *StatusReply) Unmarshal(dAtA []byte) error
func (*StatusReply) XXX_DiscardUnknown ¶
func (m *StatusReply) XXX_DiscardUnknown()
func (*StatusReply) XXX_Marshal ¶
func (m *StatusReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusReply) XXX_Merge ¶
func (m *StatusReply) XXX_Merge(src proto.Message)
func (*StatusReply) XXX_Size ¶
func (m *StatusReply) XXX_Size() int
func (*StatusReply) XXX_Unmarshal ¶
func (m *StatusReply) XXX_Unmarshal(b []byte) error
type StatusRequest ¶
type StatusRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
////////////////////////////////////// Global status //////////////////////////////////////
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
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 valid to be assigned to Event: // *StatusUpdate_MesosHeartbeat Event isStatusUpdate_Event `protobuf_oneof:"Event"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusUpdate) Descriptor ¶
func (*StatusUpdate) Descriptor() ([]byte, []int)
func (*StatusUpdate) GetEvent ¶
func (m *StatusUpdate) GetEvent() isStatusUpdate_Event
func (*StatusUpdate) GetLevel ¶
func (m *StatusUpdate) GetLevel() StatusUpdate_Level
func (*StatusUpdate) GetMesosHeartbeat ¶
func (m *StatusUpdate) GetMesosHeartbeat() *Event_MesosHeartbeat
func (*StatusUpdate) Marshal ¶
func (m *StatusUpdate) Marshal() (dAtA []byte, err error)
func (*StatusUpdate) ProtoMessage ¶
func (*StatusUpdate) ProtoMessage()
func (*StatusUpdate) Reset ¶
func (m *StatusUpdate) Reset()
func (*StatusUpdate) Size ¶
func (m *StatusUpdate) Size() (n int)
func (*StatusUpdate) String ¶
func (m *StatusUpdate) String() string
func (*StatusUpdate) Unmarshal ¶
func (m *StatusUpdate) Unmarshal(dAtA []byte) error
func (*StatusUpdate) XXX_DiscardUnknown ¶
func (m *StatusUpdate) XXX_DiscardUnknown()
func (*StatusUpdate) XXX_Marshal ¶
func (m *StatusUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusUpdate) XXX_Merge ¶
func (m *StatusUpdate) XXX_Merge(src proto.Message)
func (*StatusUpdate) XXX_OneofFuncs ¶
func (*StatusUpdate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*StatusUpdate) XXX_Size ¶
func (m *StatusUpdate) XXX_Size() int
func (*StatusUpdate) XXX_Unmarshal ¶
func (m *StatusUpdate) XXX_Unmarshal(b []byte) error
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) EnumDescriptor ¶
func (StatusUpdate_Level) EnumDescriptor() ([]byte, []int)
func (StatusUpdate_Level) String ¶
func (x StatusUpdate_Level) String() string
type StatusUpdate_MesosHeartbeat ¶
type StatusUpdate_MesosHeartbeat struct {
MesosHeartbeat *Event_MesosHeartbeat `protobuf:"bytes,2,opt,name=mesosHeartbeat,proto3,oneof"`
}
func (*StatusUpdate_MesosHeartbeat) MarshalTo ¶
func (m *StatusUpdate_MesosHeartbeat) MarshalTo(dAtA []byte) (int, error)
func (*StatusUpdate_MesosHeartbeat) Size ¶
func (m *StatusUpdate_MesosHeartbeat) Size() (n int)
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskClassInfo) Descriptor ¶
func (*TaskClassInfo) Descriptor() ([]byte, []int)
func (*TaskClassInfo) GetControlMode ¶
func (m *TaskClassInfo) GetControlMode() string
func (*TaskClassInfo) GetName ¶
func (m *TaskClassInfo) GetName() string
func (*TaskClassInfo) Marshal ¶
func (m *TaskClassInfo) Marshal() (dAtA []byte, err error)
func (*TaskClassInfo) ProtoMessage ¶
func (*TaskClassInfo) ProtoMessage()
func (*TaskClassInfo) Reset ¶
func (m *TaskClassInfo) Reset()
func (*TaskClassInfo) Size ¶
func (m *TaskClassInfo) Size() (n int)
func (*TaskClassInfo) String ¶
func (m *TaskClassInfo) String() string
func (*TaskClassInfo) Unmarshal ¶
func (m *TaskClassInfo) Unmarshal(dAtA []byte) error
func (*TaskClassInfo) XXX_DiscardUnknown ¶
func (m *TaskClassInfo) XXX_DiscardUnknown()
func (*TaskClassInfo) XXX_Marshal ¶
func (m *TaskClassInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TaskClassInfo) XXX_Merge ¶
func (m *TaskClassInfo) XXX_Merge(src proto.Message)
func (*TaskClassInfo) XXX_Size ¶
func (m *TaskClassInfo) XXX_Size() int
func (*TaskClassInfo) XXX_Unmarshal ¶
func (m *TaskClassInfo) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskDeploymentInfo) Descriptor ¶
func (*TaskDeploymentInfo) Descriptor() ([]byte, []int)
func (*TaskDeploymentInfo) GetAgentId ¶
func (m *TaskDeploymentInfo) GetAgentId() string
func (*TaskDeploymentInfo) GetExecutorId ¶
func (m *TaskDeploymentInfo) GetExecutorId() string
func (*TaskDeploymentInfo) GetHostname ¶
func (m *TaskDeploymentInfo) GetHostname() string
func (*TaskDeploymentInfo) GetOfferId ¶
func (m *TaskDeploymentInfo) GetOfferId() string
func (*TaskDeploymentInfo) Marshal ¶
func (m *TaskDeploymentInfo) Marshal() (dAtA []byte, err error)
func (*TaskDeploymentInfo) MarshalTo ¶
func (m *TaskDeploymentInfo) MarshalTo(dAtA []byte) (int, error)
func (*TaskDeploymentInfo) ProtoMessage ¶
func (*TaskDeploymentInfo) ProtoMessage()
func (*TaskDeploymentInfo) Reset ¶
func (m *TaskDeploymentInfo) Reset()
func (*TaskDeploymentInfo) Size ¶
func (m *TaskDeploymentInfo) Size() (n int)
func (*TaskDeploymentInfo) String ¶
func (m *TaskDeploymentInfo) String() string
func (*TaskDeploymentInfo) Unmarshal ¶
func (m *TaskDeploymentInfo) Unmarshal(dAtA []byte) error
func (*TaskDeploymentInfo) XXX_DiscardUnknown ¶
func (m *TaskDeploymentInfo) XXX_DiscardUnknown()
func (*TaskDeploymentInfo) XXX_Marshal ¶
func (m *TaskDeploymentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TaskDeploymentInfo) XXX_Merge ¶
func (m *TaskDeploymentInfo) XXX_Merge(src proto.Message)
func (*TaskDeploymentInfo) XXX_Size ¶
func (m *TaskDeploymentInfo) XXX_Size() int
func (*TaskDeploymentInfo) XXX_Unmarshal ¶
func (m *TaskDeploymentInfo) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TaskInfo) Descriptor ¶
func (*TaskInfo) GetClassInfo ¶
func (m *TaskInfo) GetClassInfo() *TaskClassInfo
func (*TaskInfo) GetCommandInfo ¶
func (m *TaskInfo) GetCommandInfo() *CommandInfo
func (*TaskInfo) GetInboundChannels ¶
func (m *TaskInfo) GetInboundChannels() []*ChannelInfo
func (*TaskInfo) GetOutboundChannels ¶
func (m *TaskInfo) GetOutboundChannels() []*ChannelInfo
func (*TaskInfo) GetShortInfo ¶
func (m *TaskInfo) GetShortInfo() *ShortTaskInfo
func (*TaskInfo) GetTaskPath ¶
func (*TaskInfo) ProtoMessage ¶
func (*TaskInfo) ProtoMessage()
func (*TaskInfo) XXX_DiscardUnknown ¶
func (m *TaskInfo) XXX_DiscardUnknown()
func (*TaskInfo) XXX_Marshal ¶
func (*TaskInfo) XXX_Unmarshal ¶
type TeardownReply ¶
type TeardownReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TeardownReply) Descriptor ¶
func (*TeardownReply) Descriptor() ([]byte, []int)
func (*TeardownReply) Marshal ¶
func (m *TeardownReply) Marshal() (dAtA []byte, err error)
func (*TeardownReply) ProtoMessage ¶
func (*TeardownReply) ProtoMessage()
func (*TeardownReply) Reset ¶
func (m *TeardownReply) Reset()
func (*TeardownReply) Size ¶
func (m *TeardownReply) Size() (n int)
func (*TeardownReply) String ¶
func (m *TeardownReply) String() string
func (*TeardownReply) Unmarshal ¶
func (m *TeardownReply) Unmarshal(dAtA []byte) error
func (*TeardownReply) XXX_DiscardUnknown ¶
func (m *TeardownReply) XXX_DiscardUnknown()
func (*TeardownReply) XXX_Marshal ¶
func (m *TeardownReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TeardownReply) XXX_Merge ¶
func (m *TeardownReply) XXX_Merge(src proto.Message)
func (*TeardownReply) XXX_Size ¶
func (m *TeardownReply) XXX_Size() int
func (*TeardownReply) XXX_Unmarshal ¶
func (m *TeardownReply) XXX_Unmarshal(b []byte) error
type TeardownRequest ¶
type TeardownRequest struct { Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Not implemented yet
func (*TeardownRequest) Descriptor ¶
func (*TeardownRequest) Descriptor() ([]byte, []int)
func (*TeardownRequest) GetReason ¶
func (m *TeardownRequest) GetReason() string
func (*TeardownRequest) Marshal ¶
func (m *TeardownRequest) Marshal() (dAtA []byte, err error)
func (*TeardownRequest) ProtoMessage ¶
func (*TeardownRequest) ProtoMessage()
func (*TeardownRequest) Reset ¶
func (m *TeardownRequest) Reset()
func (*TeardownRequest) Size ¶
func (m *TeardownRequest) Size() (n int)
func (*TeardownRequest) String ¶
func (m *TeardownRequest) String() string
func (*TeardownRequest) Unmarshal ¶
func (m *TeardownRequest) Unmarshal(dAtA []byte) error
func (*TeardownRequest) XXX_DiscardUnknown ¶
func (m *TeardownRequest) XXX_DiscardUnknown()
func (*TeardownRequest) XXX_Marshal ¶
func (m *TeardownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TeardownRequest) XXX_Merge ¶
func (m *TeardownRequest) XXX_Merge(src proto.Message)
func (*TeardownRequest) XXX_Size ¶
func (m *TeardownRequest) XXX_Size() int
func (*TeardownRequest) XXX_Unmarshal ¶
func (m *TeardownRequest) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Version) Descriptor ¶ 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) XXX_DiscardUnknown ¶ added in v0.7.0
func (m *Version) XXX_DiscardUnknown()