pb

Jul 18, 2024

Changes in this version

type ControlEnvironmentRequest

+ RequestUser *protos.User

+ func (x *ControlEnvironmentRequest) GetRequestUser() *protos.User

type DestroyEnvironmentRequest

+ RequestUser *protos.User

+ func (x *DestroyEnvironmentRequest) GetRequestUser() *protos.User

type NewAutoEnvironmentRequest

+ RequestUser *protos.User

+ func (x *NewAutoEnvironmentRequest) GetRequestUser() *protos.User

type NewEnvironmentRequest

+ RequestUser *protos.User

+ func (x *NewEnvironmentRequest) GetRequestUser() *protos.User

Jun 4, 2024

Changes in this version

type NewEnvironmentRequest

+ AutoTransition bool

+ func (x *NewEnvironmentRequest) GetAutoTransition() bool

type ShortTaskInfo

+ Critical bool

+ func (x *ShortTaskInfo) GetCritical() bool

May 23, 2024

Changes in this version

+ type Ev_RunEvent = protos.Ev_RunEvent

+ type Event_RunEvent = protos.Event_RunEvent

Mar 22, 2024

Changes in this version

+ const Control_NewEnvironmentAsync_FullMethodName

+ const OpStatus_DONE_ERROR

+ const OpStatus_DONE_OK

+ const OpStatus_DONE_TIMEOUT

+ const OpStatus_NULL

+ const OpStatus_ONGOING

+ const OpStatus_STARTED

+ var OpStatus_name = protos.OpStatus_name

+ var OpStatus_value = protos.OpStatus_value

type ControlClient

+ NewEnvironmentAsync func(ctx context.Context, in *NewEnvironmentRequest, opts ...grpc.CallOption) (*NewEnvironmentReply, error)

type ControlServer

+ NewEnvironmentAsync func(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)

+ type Ev_CallEvent = protos.Ev_CallEvent

+ type Ev_IntegratedServiceEvent = protos.Ev_IntegratedServiceEvent

+ type Ev_MetaEvent_CoreStart = protos.Ev_MetaEvent_CoreStart

+ type Ev_MetaEvent_FrameworkEvent = protos.Ev_MetaEvent_FrameworkEvent

+ type Ev_MetaEvent_MesosHeartbeat = protos.Ev_MetaEvent_MesosHeartbeat

+ type Event_CallEvent = protos.Event_CallEvent

+ type Event_CoreStartEvent = protos.Event_CoreStartEvent

+ type Event_FrameworkEvent = protos.Event_FrameworkEvent

+ type Event_IntegratedServiceEvent = protos.Event_IntegratedServiceEvent

+ type Event_MesosHeartbeatEvent = protos.Event_MesosHeartbeatEvent

+ type OpStatus = protos.OpStatus

+ type Traits = protos.Traits

type UnimplementedControlServer

+ func (UnimplementedControlServer) NewEnvironmentAsync(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)

Mar 4, 2024

Changes in this version

+ const Control_AddRepo_FullMethodName

+ const Control_CleanupTasks_FullMethodName

+ const Control_ControlEnvironment_FullMethodName

+ const Control_DestroyEnvironment_FullMethodName

+ const Control_GetActiveDetectors_FullMethodName

+ const Control_GetAvailableDetectors_FullMethodName

+ const Control_GetEnvironment_FullMethodName

+ const Control_GetEnvironments_FullMethodName

+ const Control_GetFrameworkInfo_FullMethodName

+ const Control_GetIntegratedServices_FullMethodName

+ const Control_GetRoles_FullMethodName

+ const Control_GetTask_FullMethodName

+ const Control_GetTasks_FullMethodName

+ const Control_GetWorkflowTemplates_FullMethodName

+ const Control_ListRepos_FullMethodName

+ const Control_ModifyEnvironment_FullMethodName

+ const Control_NewAutoEnvironment_FullMethodName

+ const Control_NewEnvironment_FullMethodName

+ const Control_RefreshRepos_FullMethodName

+ const Control_RemoveRepo_FullMethodName

+ const Control_SetDefaultRepo_FullMethodName

+ const Control_SetGlobalDefaultRevision_FullMethodName

+ const Control_SetRepoDefaultRevision_FullMethodName

+ const Control_Subscribe_FullMethodName

+ const Control_Teardown_FullMethodName

+ const Control_TrackStatus_FullMethodName

type ControlClient

+ GetAvailableDetectors func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetAvailableDetectorsReply, error)

type ControlServer

+ GetAvailableDetectors func(context.Context, *Empty) (*GetAvailableDetectorsReply, error)

+ type GetAvailableDetectorsReply struct

+ Detectors []string

+ func (*GetAvailableDetectorsReply) Descriptor() ([]byte, []int)

+ func (*GetAvailableDetectorsReply) ProtoMessage()

+ func (x *GetAvailableDetectorsReply) GetDetectors() []string

+ func (x *GetAvailableDetectorsReply) ProtoReflect() protoreflect.Message

+ func (x *GetAvailableDetectorsReply) Reset()

+ func (x *GetAvailableDetectorsReply) String() string

type UnimplementedControlServer

+ func (UnimplementedControlServer) GetAvailableDetectors(context.Context, *Empty) (*GetAvailableDetectorsReply, error)

Sep 1, 2023

Changes in this version

type EnvironmentInfo

+ NumberOfActiveTasks int32

+ NumberOfInactiveTasks int32

+ func (x *EnvironmentInfo) GetNumberOfActiveTasks() int32

+ func (x *EnvironmentInfo) GetNumberOfInactiveTasks() int32

Aug 3, 2023

Changes in this version

type EnvironmentInfo

+ CurrentTransition string

+ func (x *EnvironmentInfo) GetCurrentTransition() string

Jul 13, 2023

Changes in this version

type EnvironmentInfo

+ NumberOfTasks int32

+ func (x *EnvironmentInfo) GetNumberOfTasks() int32

Nov 17, 2022

Changes in this version

type EnvironmentInfo

+ IntegratedServicesData map[string]string

+ func (x *EnvironmentInfo) GetIntegratedServicesData() map[string]string

Aug 1, 2022

Changes in this version

type EnvironmentInfo

+ NumberOfHosts int32

+ func (x *EnvironmentInfo) GetNumberOfHosts() int32

Jul 22, 2022

Changes in this version

type ShortTaskInfo

+ Claimable bool

+ func (x *ShortTaskInfo) GetClaimable() bool

Apr 1, 2022

Changes in this version

type WorkflowTemplateInfo

+ Description string

+ func (x *WorkflowTemplateInfo) GetDescription() string

Mar 24, 2022

Changes in this version

type ControlEnvironmentReply

+ EndOfTransition int64

+ StartOfTransition int64

+ TransitionDuration int64

+ func (x *ControlEnvironmentReply) GetEndOfTransition() int64

+ func (x *ControlEnvironmentReply) GetStartOfTransition() int64

+ func (x *ControlEnvironmentReply) GetTransitionDuration() int64

type EnvironmentInfo

+ Description string

+ func (x *EnvironmentInfo) GetDescription() string

type RoleInfo

+ Description string

+ func (x *RoleInfo) GetDescription() string

Oct 21, 2021

Changes in this version

type GetEnvironmentRequest

+ ShowWorkflowTree bool

+ func (x *GetEnvironmentRequest) GetShowWorkflowTree() bool

type GetEnvironmentsRequest

+ ShowTaskInfos bool

+ func (x *GetEnvironmentsRequest) GetShowTaskInfos() bool

Aug 25, 2021

Changes in this version

type ControlClient

+ GetActiveDetectors func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetActiveDetectorsReply, error)

type ControlServer

+ GetActiveDetectors func(context.Context, *Empty) (*GetActiveDetectorsReply, error)

type EnvironmentInfo

+ IncludedDetectors []string

+ func (x *EnvironmentInfo) GetIncludedDetectors() []string

+ type GetActiveDetectorsReply struct

+ Detectors []string

+ func (*GetActiveDetectorsReply) Descriptor() ([]byte, []int)

+ func (*GetActiveDetectorsReply) ProtoMessage()

+ func (x *GetActiveDetectorsReply) GetDetectors() []string

+ func (x *GetActiveDetectorsReply) ProtoReflect() protoreflect.Message

+ func (x *GetActiveDetectorsReply) Reset()

+ func (x *GetActiveDetectorsReply) String() string

type GetFrameworkInfoReply

+ ActiveDetectors []string

+ AvailableDetectors []string

+ DetectorsInInstance []string

+ func (x *GetFrameworkInfoReply) GetActiveDetectors() []string

+ func (x *GetFrameworkInfoReply) GetAvailableDetectors() []string

+ func (x *GetFrameworkInfoReply) GetDetectorsInInstance() []string

type UnimplementedControlServer

+ func (UnimplementedControlServer) GetActiveDetectors(context.Context, *Empty) (*GetActiveDetectorsReply, error)

Jul 29, 2021

Changes in this version

type VarSpecMessage

+ EnabledIf string

+ Index int32

+ VisibleIf string

+ Widget VarSpecMessage_UiWidget

+ func (x *VarSpecMessage) GetEnabledIf() string

+ func (x *VarSpecMessage) GetIndex() int32

+ func (x *VarSpecMessage) GetVisibleIf() string

+ func (x *VarSpecMessage) GetWidget() VarSpecMessage_UiWidget

type VarSpecMessage_UiWidget

+ const VarSpecMessage_checkBox

+ const VarSpecMessage_radioButtonBox

Jul 20, 2021

Changes in this version

type GetEnvironmentReply

+ Public bool

+ func (x *GetEnvironmentReply) GetPublic() bool

type GetEnvironmentsRequest

+ ShowAll bool

+ func (x *GetEnvironmentsRequest) GetShowAll() bool

type NewEnvironmentReply

+ Public bool

+ func (x *NewEnvironmentReply) GetPublic() bool

type NewEnvironmentRequest

+ Public bool

+ func (x *NewEnvironmentRequest) GetPublic() bool

Jul 2, 2021

Changes in this version

type ControlEnvironmentRequest_Optype

+ const ControlEnvironmentRequest_DEPLOY

Jun 9, 2021

Changes in this version

+ var Control_ServiceDesc = grpc.ServiceDesc

type ListReposRequest

+ GetRevisions bool

+ func (x *ListReposRequest) GetGetRevisions() bool

type RepoInfo

+ Revisions []string

+ func (x *RepoInfo) GetRevisions() []string

May 3, 2021

Changes in this version

+ var VarSpecMessage_Type_name = map[int32]string

+ var VarSpecMessage_Type_value = map[string]int32

+ var VarSpecMessage_UiWidget_name = map[int32]string

+ var VarSpecMessage_UiWidget_value = map[string]int32

type ControlClient

+ GetIntegratedServices func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListIntegratedServicesReply, error)

type ControlServer

+ GetIntegratedServices func(context.Context, *Empty) (*ListIntegratedServicesReply, error)

type GetFrameworkInfoReply

+ ConfigurationEndpoint string

+ func (x *GetFrameworkInfoReply) GetConfigurationEndpoint() string

type GetWorkflowTemplatesRequest

+ AllWorkflows bool

+ NoVarInfo bool

+ func (x *GetWorkflowTemplatesRequest) GetAllWorkflows() bool

+ func (x *GetWorkflowTemplatesRequest) GetNoVarInfo() bool

+ type IntegratedServiceInfo struct

+ ConnectionState string

+ Data string

+ Enabled bool

+ Endpoint string

+ Name string

+ func (*IntegratedServiceInfo) Descriptor() ([]byte, []int)

+ func (*IntegratedServiceInfo) ProtoMessage()

+ func (x *IntegratedServiceInfo) GetConnectionState() string

+ func (x *IntegratedServiceInfo) GetData() string

+ func (x *IntegratedServiceInfo) GetEnabled() bool

+ func (x *IntegratedServiceInfo) GetEndpoint() string

+ func (x *IntegratedServiceInfo) GetName() string

+ func (x *IntegratedServiceInfo) ProtoReflect() protoreflect.Message

+ func (x *IntegratedServiceInfo) Reset()

+ func (x *IntegratedServiceInfo) String() string

+ type ListIntegratedServicesReply struct

+ Services map[string]*IntegratedServiceInfo

+ func (*ListIntegratedServicesReply) Descriptor() ([]byte, []int)

+ func (*ListIntegratedServicesReply) ProtoMessage()

+ func (x *ListIntegratedServicesReply) GetServices() map[string]*IntegratedServiceInfo

+ func (x *ListIntegratedServicesReply) ProtoReflect() protoreflect.Message

+ func (x *ListIntegratedServicesReply) Reset()

+ func (x *ListIntegratedServicesReply) String() string

type UnimplementedControlServer

+ func (UnimplementedControlServer) GetIntegratedServices(context.Context, *Empty) (*ListIntegratedServicesReply, error)

+ type VarSpecMessage struct

+ AllowedValues []string

+ DefaultValue string

+ Description string

+ Label string

+ Panel string

+ Type VarSpecMessage_Type

+ UiWidgetHint VarSpecMessage_UiWidget

+ func (*VarSpecMessage) Descriptor() ([]byte, []int)

+ func (*VarSpecMessage) ProtoMessage()

+ func (x *VarSpecMessage) GetAllowedValues() []string

+ func (x *VarSpecMessage) GetDefaultValue() string

+ func (x *VarSpecMessage) GetDescription() string

+ func (x *VarSpecMessage) GetLabel() string

+ func (x *VarSpecMessage) GetPanel() string

+ func (x *VarSpecMessage) GetType() VarSpecMessage_Type

+ func (x *VarSpecMessage) GetUiWidgetHint() VarSpecMessage_UiWidget

+ func (x *VarSpecMessage) ProtoReflect() protoreflect.Message

+ func (x *VarSpecMessage) Reset()

+ func (x *VarSpecMessage) String() string

+ type VarSpecMessage_Type int32

+ const VarSpecMessage_bool

+ const VarSpecMessage_list

+ const VarSpecMessage_map

+ const VarSpecMessage_number

+ const VarSpecMessage_string

+ func (VarSpecMessage_Type) Descriptor() protoreflect.EnumDescriptor

+ func (VarSpecMessage_Type) EnumDescriptor() ([]byte, []int)

+ func (VarSpecMessage_Type) Type() protoreflect.EnumType

+ func (x VarSpecMessage_Type) Enum() *VarSpecMessage_Type

+ func (x VarSpecMessage_Type) Number() protoreflect.EnumNumber

+ func (x VarSpecMessage_Type) String() string

+ type VarSpecMessage_UiWidget int32

+ const VarSpecMessage_comboBox

+ const VarSpecMessage_dropDownBox

+ const VarSpecMessage_editBox

+ const VarSpecMessage_listBox

+ const VarSpecMessage_slider

+ func (VarSpecMessage_UiWidget) Descriptor() protoreflect.EnumDescriptor

+ func (VarSpecMessage_UiWidget) EnumDescriptor() ([]byte, []int)

+ func (VarSpecMessage_UiWidget) Type() protoreflect.EnumType

+ func (x VarSpecMessage_UiWidget) Enum() *VarSpecMessage_UiWidget

+ func (x VarSpecMessage_UiWidget) Number() protoreflect.EnumNumber

+ func (x VarSpecMessage_UiWidget) String() string

type WorkflowTemplateInfo

+ VarSpecMap map[string]*VarSpecMessage

+ func (x *WorkflowTemplateInfo) GetVarSpecMap() map[string]*VarSpecMessage

Mar 3, 2021

Changes in this version

type EnvironmentInfo

+ NumberOfFlps int32

+ func (x *EnvironmentInfo) GetNumberOfFlps() int32

Feb 10, 2021

Changes in this version

type RoleInfo

+ ConsolidatedStack map[string]string

+ func (x *RoleInfo) GetConsolidatedStack() map[string]string

Feb 8, 2021

Changes in this version

+ var File_protos_o2control_proto protoreflect.FileDescriptor

type AddRepoReply

+ func (x *AddRepoReply) ProtoReflect() protoreflect.Message

type AddRepoRequest

+ func (x *AddRepoRequest) ProtoReflect() protoreflect.Message

type ChannelInfo

+ func (x *ChannelInfo) ProtoReflect() protoreflect.Message

type CleanupTasksReply

+ func (x *CleanupTasksReply) ProtoReflect() protoreflect.Message

type CleanupTasksRequest

+ func (x *CleanupTasksRequest) ProtoReflect() protoreflect.Message

type CommandInfo

+ func (x *CommandInfo) ProtoReflect() protoreflect.Message

type ControlEnvironmentReply

+ func (x *ControlEnvironmentReply) ProtoReflect() protoreflect.Message

type ControlEnvironmentRequest

+ func (x *ControlEnvironmentRequest) ProtoReflect() protoreflect.Message

type ControlEnvironmentRequest_Optype

+ func (ControlEnvironmentRequest_Optype) Descriptor() protoreflect.EnumDescriptor

+ func (ControlEnvironmentRequest_Optype) Type() protoreflect.EnumType

+ func (x ControlEnvironmentRequest_Optype) Enum() *ControlEnvironmentRequest_Optype

+ func (x ControlEnvironmentRequest_Optype) Number() protoreflect.EnumNumber

type DestroyEnvironmentReply

+ func (x *DestroyEnvironmentReply) ProtoReflect() protoreflect.Message

type DestroyEnvironmentRequest

+ func (x *DestroyEnvironmentRequest) ProtoReflect() protoreflect.Message

type Empty

+ func (x *Empty) ProtoReflect() protoreflect.Message

type EnvironmentInfo

+ func (x *EnvironmentInfo) ProtoReflect() protoreflect.Message

type EnvironmentOperation

+ func (x *EnvironmentOperation) ProtoReflect() protoreflect.Message

type EnvironmentOperation_Optype

+ func (EnvironmentOperation_Optype) Descriptor() protoreflect.EnumDescriptor

+ func (EnvironmentOperation_Optype) Type() protoreflect.EnumType

+ func (x EnvironmentOperation_Optype) Enum() *EnvironmentOperation_Optype

+ func (x EnvironmentOperation_Optype) Number() protoreflect.EnumNumber

type Ev_EnvironmentEvent

+ func (x *Ev_EnvironmentEvent) ProtoReflect() protoreflect.Message

type Ev_RoleEvent

+ func (x *Ev_RoleEvent) ProtoReflect() protoreflect.Message

type Ev_TaskEvent

+ func (x *Ev_TaskEvent) ProtoReflect() protoreflect.Message

type Event

+ func (x *Event) ProtoReflect() protoreflect.Message

type Event_MesosHeartbeat

+ func (x *Event_MesosHeartbeat) ProtoReflect() protoreflect.Message

type GetEnvironmentPropertiesReply

+ func (x *GetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message

type GetEnvironmentPropertiesRequest

+ func (x *GetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message

type GetEnvironmentReply

+ func (x *GetEnvironmentReply) ProtoReflect() protoreflect.Message

type GetEnvironmentRequest

+ func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message

type GetEnvironmentsReply

+ func (x *GetEnvironmentsReply) ProtoReflect() protoreflect.Message

type GetEnvironmentsRequest

+ func (x *GetEnvironmentsRequest) ProtoReflect() protoreflect.Message

type GetFrameworkInfoReply

+ func (x *GetFrameworkInfoReply) ProtoReflect() protoreflect.Message

type GetFrameworkInfoRequest

+ func (x *GetFrameworkInfoRequest) ProtoReflect() protoreflect.Message

type GetRolesReply

+ func (x *GetRolesReply) ProtoReflect() protoreflect.Message

type GetRolesRequest

+ func (x *GetRolesRequest) ProtoReflect() protoreflect.Message

type GetTaskReply

+ func (x *GetTaskReply) ProtoReflect() protoreflect.Message

type GetTaskRequest

+ func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

type GetTasksReply

+ func (x *GetTasksReply) ProtoReflect() protoreflect.Message

type GetTasksRequest

+ func (x *GetTasksRequest) ProtoReflect() protoreflect.Message

type GetWorkflowTemplatesReply

+ func (x *GetWorkflowTemplatesReply) ProtoReflect() protoreflect.Message

type GetWorkflowTemplatesRequest

+ func (x *GetWorkflowTemplatesRequest) ProtoReflect() protoreflect.Message

type ListReposReply

+ func (x *ListReposReply) ProtoReflect() protoreflect.Message

type ListReposRequest

+ func (x *ListReposRequest) ProtoReflect() protoreflect.Message

type ModifyEnvironmentReply

+ func (x *ModifyEnvironmentReply) ProtoReflect() protoreflect.Message

type ModifyEnvironmentRequest

+ func (x *ModifyEnvironmentRequest) ProtoReflect() protoreflect.Message

type NewAutoEnvironmentReply

+ func (x *NewAutoEnvironmentReply) ProtoReflect() protoreflect.Message

type NewAutoEnvironmentRequest

+ func (x *NewAutoEnvironmentRequest) ProtoReflect() protoreflect.Message

type NewEnvironmentReply

+ func (x *NewEnvironmentReply) ProtoReflect() protoreflect.Message

type NewEnvironmentRequest

+ func (x *NewEnvironmentRequest) ProtoReflect() protoreflect.Message

type RefreshReposRequest

+ func (x *RefreshReposRequest) ProtoReflect() protoreflect.Message

type RemoveRepoReply

+ func (x *RemoveRepoReply) ProtoReflect() protoreflect.Message

type RemoveRepoRequest

+ func (x *RemoveRepoRequest) ProtoReflect() protoreflect.Message

type RepoInfo

+ func (x *RepoInfo) ProtoReflect() protoreflect.Message

type RoleInfo

+ func (x *RoleInfo) ProtoReflect() protoreflect.Message

type SetDefaultRepoRequest

+ func (x *SetDefaultRepoRequest) ProtoReflect() protoreflect.Message

type SetEnvironmentPropertiesReply

+ func (x *SetEnvironmentPropertiesReply) ProtoReflect() protoreflect.Message

type SetEnvironmentPropertiesRequest

+ func (x *SetEnvironmentPropertiesRequest) ProtoReflect() protoreflect.Message

type SetGlobalDefaultRevisionRequest

+ func (x *SetGlobalDefaultRevisionRequest) ProtoReflect() protoreflect.Message

type SetRepoDefaultRevisionReply

+ func (x *SetRepoDefaultRevisionReply) ProtoReflect() protoreflect.Message

type SetRepoDefaultRevisionRequest

+ func (x *SetRepoDefaultRevisionRequest) ProtoReflect() protoreflect.Message

type ShortTaskInfo

+ func (x *ShortTaskInfo) ProtoReflect() protoreflect.Message

type StatusReply

+ func (x *StatusReply) ProtoReflect() protoreflect.Message

type StatusRequest

+ func (x *StatusRequest) ProtoReflect() protoreflect.Message

type StatusUpdate

+ func (x *StatusUpdate) ProtoReflect() protoreflect.Message

type StatusUpdate_Level

+ func (StatusUpdate_Level) Descriptor() protoreflect.EnumDescriptor

+ func (StatusUpdate_Level) Type() protoreflect.EnumType

+ func (x StatusUpdate_Level) Enum() *StatusUpdate_Level

+ func (x StatusUpdate_Level) Number() protoreflect.EnumNumber

type SubscribeRequest

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

type TaskClassInfo

+ func (x *TaskClassInfo) ProtoReflect() protoreflect.Message

type TaskDeploymentInfo

+ func (x *TaskDeploymentInfo) ProtoReflect() protoreflect.Message

type TaskInfo

+ func (x *TaskInfo) ProtoReflect() protoreflect.Message

type TeardownReply

+ func (x *TeardownReply) ProtoReflect() protoreflect.Message

type TeardownRequest

+ func (x *TeardownRequest) ProtoReflect() protoreflect.Message

+ type UnsafeControlServer interface

type Version

+ func (x *Version) ProtoReflect() protoreflect.Message

type WorkflowTemplateInfo

+ func (x *WorkflowTemplateInfo) ProtoReflect() protoreflect.Message

Feb 1, 2021

Changes in this version

type ControlClient

+ NewAutoEnvironment func(ctx context.Context, in *NewAutoEnvironmentRequest, opts ...grpc.CallOption) (*NewAutoEnvironmentReply, error)

type ControlServer

+ NewAutoEnvironment func(context.Context, *NewAutoEnvironmentRequest) (*NewAutoEnvironmentReply, error)

+ type Ev_EnvironmentEvent struct

+ CurrentRunNumber uint32

+ EnvironmentId string

+ Error string

+ Message string

+ State string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_EnvironmentEvent) Descriptor() ([]byte, []int)

+ func (*Ev_EnvironmentEvent) ProtoMessage()

+ func (m *Ev_EnvironmentEvent) GetCurrentRunNumber() uint32

+ func (m *Ev_EnvironmentEvent) GetEnvironmentId() string

+ func (m *Ev_EnvironmentEvent) GetError() string

+ func (m *Ev_EnvironmentEvent) GetMessage() string

+ func (m *Ev_EnvironmentEvent) GetState() string

+ func (m *Ev_EnvironmentEvent) Marshal() (dAtA []byte, err error)

+ func (m *Ev_EnvironmentEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentEvent) Reset()

+ func (m *Ev_EnvironmentEvent) Size() (n int)

+ func (m *Ev_EnvironmentEvent) String() string

+ func (m *Ev_EnvironmentEvent) Unmarshal(dAtA []byte) error

+ func (m *Ev_EnvironmentEvent) XXX_DiscardUnknown()

+ func (m *Ev_EnvironmentEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_EnvironmentEvent) XXX_Merge(src proto.Message)

+ func (m *Ev_EnvironmentEvent) XXX_Size() int

+ func (m *Ev_EnvironmentEvent) XXX_Unmarshal(b []byte) error

+ type Ev_RoleEvent struct

+ Name string

+ RolePath string

+ State string

+ Status string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_RoleEvent) Descriptor() ([]byte, []int)

+ func (*Ev_RoleEvent) ProtoMessage()

+ func (m *Ev_RoleEvent) GetName() string

+ func (m *Ev_RoleEvent) GetRolePath() string

+ func (m *Ev_RoleEvent) GetState() string

+ func (m *Ev_RoleEvent) GetStatus() string

+ func (m *Ev_RoleEvent) Marshal() (dAtA []byte, err error)

+ func (m *Ev_RoleEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_RoleEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_RoleEvent) Reset()

+ func (m *Ev_RoleEvent) Size() (n int)

+ func (m *Ev_RoleEvent) String() string

+ func (m *Ev_RoleEvent) Unmarshal(dAtA []byte) error

+ func (m *Ev_RoleEvent) XXX_DiscardUnknown()

+ func (m *Ev_RoleEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_RoleEvent) XXX_Merge(src proto.Message)

+ func (m *Ev_RoleEvent) XXX_Size() int

+ func (m *Ev_RoleEvent) XXX_Unmarshal(b []byte) error

+ type Ev_TaskEvent struct

+ ClassName string

+ Hostname string

+ Name string

+ State string

+ Status string

+ Taskid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_TaskEvent) Descriptor() ([]byte, []int)

+ func (*Ev_TaskEvent) ProtoMessage()

+ func (m *Ev_TaskEvent) GetClassName() string

+ func (m *Ev_TaskEvent) GetHostname() string

+ func (m *Ev_TaskEvent) GetName() string

+ func (m *Ev_TaskEvent) GetState() string

+ func (m *Ev_TaskEvent) GetStatus() string

+ func (m *Ev_TaskEvent) GetTaskid() string

+ func (m *Ev_TaskEvent) Marshal() (dAtA []byte, err error)

+ func (m *Ev_TaskEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_TaskEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_TaskEvent) Reset()

+ func (m *Ev_TaskEvent) Size() (n int)

+ func (m *Ev_TaskEvent) String() string

+ func (m *Ev_TaskEvent) Unmarshal(dAtA []byte) error

+ func (m *Ev_TaskEvent) XXX_DiscardUnknown()

+ func (m *Ev_TaskEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_TaskEvent) XXX_Merge(src proto.Message)

+ func (m *Ev_TaskEvent) XXX_Size() int

+ func (m *Ev_TaskEvent) XXX_Unmarshal(b []byte) error

type Event

+ func (m *Event) GetEnvironmentEvent() *Ev_EnvironmentEvent

+ func (m *Event) GetRoleEvent() *Ev_RoleEvent

+ func (m *Event) GetTaskEvent() *Ev_TaskEvent

+ type Event_EnvironmentEvent struct

+ EnvironmentEvent *Ev_EnvironmentEvent

+ func (m *Event_EnvironmentEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentEvent) Size() (n int)

+ type Event_RoleEvent struct

+ RoleEvent *Ev_RoleEvent

+ func (m *Event_RoleEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_RoleEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_RoleEvent) Size() (n int)

+ type Event_TaskEvent struct

+ TaskEvent *Ev_TaskEvent

+ func (m *Event_TaskEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_TaskEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_TaskEvent) Size() (n int)

+ type NewAutoEnvironmentReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewAutoEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*NewAutoEnvironmentReply) ProtoMessage()

+ func (m *NewAutoEnvironmentReply) Marshal() (dAtA []byte, err error)

+ func (m *NewAutoEnvironmentReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *NewAutoEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NewAutoEnvironmentReply) Reset()

+ func (m *NewAutoEnvironmentReply) Size() (n int)

+ func (m *NewAutoEnvironmentReply) String() string

+ func (m *NewAutoEnvironmentReply) Unmarshal(dAtA []byte) error

+ func (m *NewAutoEnvironmentReply) XXX_DiscardUnknown()

+ func (m *NewAutoEnvironmentReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NewAutoEnvironmentReply) XXX_Merge(src proto.Message)

+ func (m *NewAutoEnvironmentReply) XXX_Size() int

+ func (m *NewAutoEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type NewAutoEnvironmentRequest struct

+ Id string

+ Vars map[string]string

+ WorkflowTemplate string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewAutoEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*NewAutoEnvironmentRequest) ProtoMessage()

+ func (m *NewAutoEnvironmentRequest) GetId() string

+ func (m *NewAutoEnvironmentRequest) GetVars() map[string]string

+ func (m *NewAutoEnvironmentRequest) GetWorkflowTemplate() string

+ func (m *NewAutoEnvironmentRequest) Marshal() (dAtA []byte, err error)

+ func (m *NewAutoEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *NewAutoEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NewAutoEnvironmentRequest) Reset()

+ func (m *NewAutoEnvironmentRequest) Size() (n int)

+ func (m *NewAutoEnvironmentRequest) String() string

+ func (m *NewAutoEnvironmentRequest) Unmarshal(dAtA []byte) error

+ func (m *NewAutoEnvironmentRequest) XXX_DiscardUnknown()

+ func (m *NewAutoEnvironmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NewAutoEnvironmentRequest) XXX_Merge(src proto.Message)

+ func (m *NewAutoEnvironmentRequest) XXX_Size() int

+ func (m *NewAutoEnvironmentRequest) XXX_Unmarshal(b []byte) error

type ShortTaskInfo

+ SandboxStdout string

+ func (m *ShortTaskInfo) GetSandboxStdout() string

type SubscribeRequest

+ Id string

+ func (m *SubscribeRequest) GetId() string

type UnimplementedControlServer

+ func (*UnimplementedControlServer) NewAutoEnvironment(ctx context.Context, req *NewAutoEnvironmentRequest) (*NewAutoEnvironmentReply, error)

Jul 24, 2020

Changes in this version

type ShortTaskInfo

+ Pid string

+ func (m *ShortTaskInfo) GetPid() string

Jun 29, 2020

Changes in this version

type ControlClient

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Control_SubscribeClient, error)

type ControlServer

+ Subscribe func(*SubscribeRequest, Control_SubscribeServer) error

+ type Control_SubscribeClient interface

+ Recv func() (*Event, error)

+ type Control_SubscribeServer interface

+ Send func(*Event) error

+ type Ev_EnvironmentCreated struct

+ Environment *EnvironmentInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_EnvironmentCreated) Descriptor() ([]byte, []int)

+ func (*Ev_EnvironmentCreated) ProtoMessage()

+ func (m *Ev_EnvironmentCreated) GetEnvironment() *EnvironmentInfo

+ func (m *Ev_EnvironmentCreated) Marshal() (dAtA []byte, err error)

+ func (m *Ev_EnvironmentCreated) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentCreated) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentCreated) Reset()

+ func (m *Ev_EnvironmentCreated) Size() (n int)

+ func (m *Ev_EnvironmentCreated) String() string

+ func (m *Ev_EnvironmentCreated) Unmarshal(dAtA []byte) error

+ func (m *Ev_EnvironmentCreated) XXX_DiscardUnknown()

+ func (m *Ev_EnvironmentCreated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_EnvironmentCreated) XXX_Merge(src proto.Message)

+ func (m *Ev_EnvironmentCreated) XXX_Size() int

+ func (m *Ev_EnvironmentCreated) XXX_Unmarshal(b []byte) error

+ type Ev_EnvironmentDestroyed struct

+ CleanupTasksReply *CleanupTasksReply

+ Environmentid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_EnvironmentDestroyed) Descriptor() ([]byte, []int)

+ func (*Ev_EnvironmentDestroyed) ProtoMessage()

+ func (m *Ev_EnvironmentDestroyed) GetCleanupTasksReply() *CleanupTasksReply

+ func (m *Ev_EnvironmentDestroyed) GetEnvironmentid() string

+ func (m *Ev_EnvironmentDestroyed) Marshal() (dAtA []byte, err error)

+ func (m *Ev_EnvironmentDestroyed) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentDestroyed) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentDestroyed) Reset()

+ func (m *Ev_EnvironmentDestroyed) Size() (n int)

+ func (m *Ev_EnvironmentDestroyed) String() string

+ func (m *Ev_EnvironmentDestroyed) Unmarshal(dAtA []byte) error

+ func (m *Ev_EnvironmentDestroyed) XXX_DiscardUnknown()

+ func (m *Ev_EnvironmentDestroyed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_EnvironmentDestroyed) XXX_Merge(src proto.Message)

+ func (m *Ev_EnvironmentDestroyed) XXX_Size() int

+ func (m *Ev_EnvironmentDestroyed) XXX_Unmarshal(b []byte) error

+ type Ev_EnvironmentError struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_EnvironmentError) Descriptor() ([]byte, []int)

+ func (*Ev_EnvironmentError) ProtoMessage()

+ func (m *Ev_EnvironmentError) Marshal() (dAtA []byte, err error)

+ func (m *Ev_EnvironmentError) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentError) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentError) Reset()

+ func (m *Ev_EnvironmentError) Size() (n int)

+ func (m *Ev_EnvironmentError) String() string

+ func (m *Ev_EnvironmentError) Unmarshal(dAtA []byte) error

+ func (m *Ev_EnvironmentError) XXX_DiscardUnknown()

+ func (m *Ev_EnvironmentError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_EnvironmentError) XXX_Merge(src proto.Message)

+ func (m *Ev_EnvironmentError) XXX_Size() int

+ func (m *Ev_EnvironmentError) XXX_Unmarshal(b []byte) error

+ type Ev_EnvironmentStateChanged struct

+ Destination string

+ Event string

+ Source string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_EnvironmentStateChanged) Descriptor() ([]byte, []int)

+ func (*Ev_EnvironmentStateChanged) ProtoMessage()

+ func (m *Ev_EnvironmentStateChanged) GetDestination() string

+ func (m *Ev_EnvironmentStateChanged) GetEvent() string

+ func (m *Ev_EnvironmentStateChanged) GetSource() string

+ func (m *Ev_EnvironmentStateChanged) Marshal() (dAtA []byte, err error)

+ func (m *Ev_EnvironmentStateChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentStateChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_EnvironmentStateChanged) Reset()

+ func (m *Ev_EnvironmentStateChanged) Size() (n int)

+ func (m *Ev_EnvironmentStateChanged) String() string

+ func (m *Ev_EnvironmentStateChanged) Unmarshal(dAtA []byte) error

+ func (m *Ev_EnvironmentStateChanged) XXX_DiscardUnknown()

+ func (m *Ev_EnvironmentStateChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_EnvironmentStateChanged) XXX_Merge(src proto.Message)

+ func (m *Ev_EnvironmentStateChanged) XXX_Size() int

+ func (m *Ev_EnvironmentStateChanged) XXX_Unmarshal(b []byte) error

+ type Ev_KillTasksMesos struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_KillTasksMesos) Descriptor() ([]byte, []int)

+ func (*Ev_KillTasksMesos) ProtoMessage()

+ func (m *Ev_KillTasksMesos) Marshal() (dAtA []byte, err error)

+ func (m *Ev_KillTasksMesos) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_KillTasksMesos) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_KillTasksMesos) Reset()

+ func (m *Ev_KillTasksMesos) Size() (n int)

+ func (m *Ev_KillTasksMesos) String() string

+ func (m *Ev_KillTasksMesos) Unmarshal(dAtA []byte) error

+ func (m *Ev_KillTasksMesos) XXX_DiscardUnknown()

+ func (m *Ev_KillTasksMesos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_KillTasksMesos) XXX_Merge(src proto.Message)

+ func (m *Ev_KillTasksMesos) XXX_Size() int

+ func (m *Ev_KillTasksMesos) XXX_Unmarshal(b []byte) error

+ type Ev_MesosTaskCreated struct

+ ExecutorResources string

+ Taskresources string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_MesosTaskCreated) Descriptor() ([]byte, []int)

+ func (*Ev_MesosTaskCreated) ProtoMessage()

+ func (m *Ev_MesosTaskCreated) GetExecutorResources() string

+ func (m *Ev_MesosTaskCreated) GetTaskresources() string

+ func (m *Ev_MesosTaskCreated) Marshal() (dAtA []byte, err error)

+ func (m *Ev_MesosTaskCreated) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_MesosTaskCreated) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_MesosTaskCreated) Reset()

+ func (m *Ev_MesosTaskCreated) Size() (n int)

+ func (m *Ev_MesosTaskCreated) String() string

+ func (m *Ev_MesosTaskCreated) Unmarshal(dAtA []byte) error

+ func (m *Ev_MesosTaskCreated) XXX_DiscardUnknown()

+ func (m *Ev_MesosTaskCreated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_MesosTaskCreated) XXX_Merge(src proto.Message)

+ func (m *Ev_MesosTaskCreated) XXX_Size() int

+ func (m *Ev_MesosTaskCreated) XXX_Unmarshal(b []byte) error

+ type Ev_TaskLaunched struct

+ Taskid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_TaskLaunched) Descriptor() ([]byte, []int)

+ func (*Ev_TaskLaunched) ProtoMessage()

+ func (m *Ev_TaskLaunched) GetTaskid() string

+ func (m *Ev_TaskLaunched) Marshal() (dAtA []byte, err error)

+ func (m *Ev_TaskLaunched) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_TaskLaunched) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_TaskLaunched) Reset()

+ func (m *Ev_TaskLaunched) Size() (n int)

+ func (m *Ev_TaskLaunched) String() string

+ func (m *Ev_TaskLaunched) Unmarshal(dAtA []byte) error

+ func (m *Ev_TaskLaunched) XXX_DiscardUnknown()

+ func (m *Ev_TaskLaunched) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_TaskLaunched) XXX_Merge(src proto.Message)

+ func (m *Ev_TaskLaunched) XXX_Size() int

+ func (m *Ev_TaskLaunched) XXX_Unmarshal(b []byte) error

+ type Ev_TaskStateChanged struct

+ State string

+ Taskid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_TaskStateChanged) Descriptor() ([]byte, []int)

+ func (*Ev_TaskStateChanged) ProtoMessage()

+ func (m *Ev_TaskStateChanged) GetState() string

+ func (m *Ev_TaskStateChanged) GetTaskid() string

+ func (m *Ev_TaskStateChanged) Marshal() (dAtA []byte, err error)

+ func (m *Ev_TaskStateChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_TaskStateChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_TaskStateChanged) Reset()

+ func (m *Ev_TaskStateChanged) Size() (n int)

+ func (m *Ev_TaskStateChanged) String() string

+ func (m *Ev_TaskStateChanged) Unmarshal(dAtA []byte) error

+ func (m *Ev_TaskStateChanged) XXX_DiscardUnknown()

+ func (m *Ev_TaskStateChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_TaskStateChanged) XXX_Merge(src proto.Message)

+ func (m *Ev_TaskStateChanged) XXX_Size() int

+ func (m *Ev_TaskStateChanged) XXX_Unmarshal(b []byte) error

+ type Ev_TaskStatusChanged struct

+ Status string

+ Taskid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ev_TaskStatusChanged) Descriptor() ([]byte, []int)

+ func (*Ev_TaskStatusChanged) ProtoMessage()

+ func (m *Ev_TaskStatusChanged) GetStatus() string

+ func (m *Ev_TaskStatusChanged) GetTaskid() string

+ func (m *Ev_TaskStatusChanged) Marshal() (dAtA []byte, err error)

+ func (m *Ev_TaskStatusChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Ev_TaskStatusChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Ev_TaskStatusChanged) Reset()

+ func (m *Ev_TaskStatusChanged) Size() (n int)

+ func (m *Ev_TaskStatusChanged) String() string

+ func (m *Ev_TaskStatusChanged) Unmarshal(dAtA []byte) error

+ func (m *Ev_TaskStatusChanged) XXX_DiscardUnknown()

+ func (m *Ev_TaskStatusChanged) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Ev_TaskStatusChanged) XXX_Merge(src proto.Message)

+ func (m *Ev_TaskStatusChanged) XXX_Size() int

+ func (m *Ev_TaskStatusChanged) XXX_Unmarshal(b []byte) error

+ type Event struct

+ Payload isEvent_Payload

+ Timestamp string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewEnvironmentCreatedEvent(ei *EnvironmentInfo) *Event

+ func NewEnvironmentDestroyedEvent(ctrl *CleanupTasksReply, envid string) *Event

+ func NewEnvironmentErrorEvent() *Event

+ func NewEnvironmentStateEvent(cmdb []byte) *Event

+ func NewEventMesosTaskCreated(resourcesRequest, executorResources string) *Event

+ func NewEventTaskLaunch(taskid string) *Event

+ func NewEventTaskState(taskid, state string) *Event

+ func NewEventTaskStatus(status *mesos.TaskStatus) *Event

+ func NewKillTasksEvent() *Event

+ func WrapEvent(ce isEvent_Payload) *Event

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (*Event) XXX_OneofWrappers() []interface{}

+ func (m *Event) GetEnvironmentCreated() *Ev_EnvironmentCreated

+ func (m *Event) GetEnvironmentDestroyed() *Ev_EnvironmentDestroyed

+ func (m *Event) GetEnvironmentError() *Ev_EnvironmentError

+ func (m *Event) GetEnvironmentStateChanged() *Ev_EnvironmentStateChanged

+ func (m *Event) GetKilltasksMesos() *Ev_KillTasksMesos

+ func (m *Event) GetMesosTaskcreated() *Ev_MesosTaskCreated

+ func (m *Event) GetPayload() isEvent_Payload

+ func (m *Event) GetTaskStateChanged() *Ev_TaskStateChanged

+ func (m *Event) GetTaskStatusChanged() *Ev_TaskStatusChanged

+ func (m *Event) GetTasklaunched() *Ev_TaskLaunched

+ func (m *Event) GetTimestamp() string

+ func (m *Event) Marshal() (dAtA []byte, err error)

+ func (m *Event) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event) Reset()

+ func (m *Event) Size() (n int)

+ func (m *Event) String() string

+ func (m *Event) Unmarshal(dAtA []byte) error

+ func (m *Event) XXX_DiscardUnknown()

+ func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Event) XXX_Merge(src proto.Message)

+ func (m *Event) XXX_Size() int

+ func (m *Event) XXX_Unmarshal(b []byte) error

+ type Event_EnvironmentCreated struct

+ EnvironmentCreated *Ev_EnvironmentCreated

+ func (m *Event_EnvironmentCreated) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentCreated) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentCreated) Size() (n int)

+ type Event_EnvironmentDestroyed struct

+ EnvironmentDestroyed *Ev_EnvironmentDestroyed

+ func (m *Event_EnvironmentDestroyed) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentDestroyed) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentDestroyed) Size() (n int)

+ type Event_EnvironmentError struct

+ EnvironmentError *Ev_EnvironmentError

+ func (m *Event_EnvironmentError) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentError) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentError) Size() (n int)

+ type Event_EnvironmentStateChanged struct

+ EnvironmentStateChanged *Ev_EnvironmentStateChanged

+ func (m *Event_EnvironmentStateChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentStateChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_EnvironmentStateChanged) Size() (n int)

+ type Event_KilltasksMesos struct

+ KilltasksMesos *Ev_KillTasksMesos

+ func (m *Event_KilltasksMesos) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_KilltasksMesos) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_KilltasksMesos) Size() (n int)

+ type Event_MesosTaskcreated struct

+ MesosTaskcreated *Ev_MesosTaskCreated

+ func (m *Event_MesosTaskcreated) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_MesosTaskcreated) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_MesosTaskcreated) Size() (n int)

+ type Event_TaskStateChanged struct

+ TaskStateChanged *Ev_TaskStateChanged

+ func (m *Event_TaskStateChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_TaskStateChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_TaskStateChanged) Size() (n int)

+ type Event_TaskStatusChanged struct

+ TaskStatusChanged *Ev_TaskStatusChanged

+ func (m *Event_TaskStatusChanged) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_TaskStatusChanged) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_TaskStatusChanged) Size() (n int)

+ type Event_Tasklaunched struct

+ Tasklaunched *Ev_TaskLaunched

+ func (m *Event_Tasklaunched) MarshalTo(dAtA []byte) (int, error)

+ func (m *Event_Tasklaunched) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Event_Tasklaunched) Size() (n int)

+ type SubscribeRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

+ func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) Size() (n int)

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

+ func (m *SubscribeRequest) XXX_DiscardUnknown()

+ func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeRequest) XXX_Size() int

+ func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type UnimplementedControlServer

+ func (*UnimplementedControlServer) Subscribe(req *SubscribeRequest, srv Control_SubscribeServer) error

Jun 15, 2020

Changes in this version

type DestroyEnvironmentRequest

+ Force bool

+ func (m *DestroyEnvironmentRequest) GetForce() bool

Mar 13, 2020

Changes in this version

type AddRepoReply

+ Info string

+ NewDefaultRevision string

+ func (m *AddRepoReply) GetInfo() string

+ func (m *AddRepoReply) GetNewDefaultRevision() string

type AddRepoRequest

+ DefaultRevision string

+ func (m *AddRepoRequest) GetDefaultRevision() string

type ControlClient

+ SetGlobalDefaultRevision func(ctx context.Context, in *SetGlobalDefaultRevisionRequest, ...) (*Empty, error)

+ SetRepoDefaultRevision func(ctx context.Context, in *SetRepoDefaultRevisionRequest, ...) (*SetRepoDefaultRevisionReply, error)

type ControlServer

+ SetGlobalDefaultRevision func(context.Context, *SetGlobalDefaultRevisionRequest) (*Empty, error)

+ SetRepoDefaultRevision func(context.Context, *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error)

type DestroyEnvironmentRequest

+ AllowInRunningState bool

+ func (m *DestroyEnvironmentRequest) GetAllowInRunningState() bool

type EnvironmentInfo

+ Defaults map[string]string

+ UserVars map[string]string

+ Vars map[string]string

+ func (m *EnvironmentInfo) GetDefaults() map[string]string

+ func (m *EnvironmentInfo) GetUserVars() map[string]string

+ func (m *EnvironmentInfo) GetVars() map[string]string

+ type GetEnvironmentPropertiesReply struct

+ Properties map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentPropertiesReply) ProtoMessage()

+ func (m *GetEnvironmentPropertiesReply) GetProperties() map[string]string

+ func (m *GetEnvironmentPropertiesReply) Marshal() (dAtA []byte, err error)

+ func (m *GetEnvironmentPropertiesReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetEnvironmentPropertiesReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetEnvironmentPropertiesReply) Reset()

+ func (m *GetEnvironmentPropertiesReply) Size() (n int)

+ func (m *GetEnvironmentPropertiesReply) String() string

+ func (m *GetEnvironmentPropertiesReply) Unmarshal(dAtA []byte) error

+ func (m *GetEnvironmentPropertiesReply) XXX_DiscardUnknown()

+ func (m *GetEnvironmentPropertiesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetEnvironmentPropertiesReply) XXX_Merge(src proto.Message)

+ func (m *GetEnvironmentPropertiesReply) XXX_Size() int

+ func (m *GetEnvironmentPropertiesReply) XXX_Unmarshal(b []byte) error

+ type GetEnvironmentPropertiesRequest struct

+ ExcludeGlobals bool

+ Id string

+ Queries []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentPropertiesRequest) ProtoMessage()

+ func (m *GetEnvironmentPropertiesRequest) GetExcludeGlobals() bool

+ func (m *GetEnvironmentPropertiesRequest) GetId() string

+ func (m *GetEnvironmentPropertiesRequest) GetQueries() []string

+ func (m *GetEnvironmentPropertiesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetEnvironmentPropertiesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetEnvironmentPropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetEnvironmentPropertiesRequest) Reset()

+ func (m *GetEnvironmentPropertiesRequest) Size() (n int)

+ func (m *GetEnvironmentPropertiesRequest) String() string

+ func (m *GetEnvironmentPropertiesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetEnvironmentPropertiesRequest) XXX_DiscardUnknown()

+ func (m *GetEnvironmentPropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetEnvironmentPropertiesRequest) XXX_Merge(src proto.Message)

+ func (m *GetEnvironmentPropertiesRequest) XXX_Size() int

+ func (m *GetEnvironmentPropertiesRequest) XXX_Unmarshal(b []byte) error

type ListReposReply

+ GlobalDefaultRevision string

+ func (m *ListReposReply) GetGlobalDefaultRevision() string

type NewEnvironmentRequest

+ Vars map[string]string

+ func (m *NewEnvironmentRequest) GetVars() map[string]string

type RepoInfo

+ DefaultRevision string

+ func (m *RepoInfo) GetDefaultRevision() string

type RoleInfo

+ Defaults map[string]string

+ UserVars map[string]string

+ Vars map[string]string

+ func (m *RoleInfo) GetDefaults() map[string]string

+ func (m *RoleInfo) GetUserVars() map[string]string

+ func (m *RoleInfo) GetVars() map[string]string

+ type SetEnvironmentPropertiesReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetEnvironmentPropertiesReply) Descriptor() ([]byte, []int)

+ func (*SetEnvironmentPropertiesReply) ProtoMessage()

+ func (m *SetEnvironmentPropertiesReply) Marshal() (dAtA []byte, err error)

+ func (m *SetEnvironmentPropertiesReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetEnvironmentPropertiesReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetEnvironmentPropertiesReply) Reset()

+ func (m *SetEnvironmentPropertiesReply) Size() (n int)

+ func (m *SetEnvironmentPropertiesReply) String() string

+ func (m *SetEnvironmentPropertiesReply) Unmarshal(dAtA []byte) error

+ func (m *SetEnvironmentPropertiesReply) XXX_DiscardUnknown()

+ func (m *SetEnvironmentPropertiesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetEnvironmentPropertiesReply) XXX_Merge(src proto.Message)

+ func (m *SetEnvironmentPropertiesReply) XXX_Size() int

+ func (m *SetEnvironmentPropertiesReply) XXX_Unmarshal(b []byte) error

+ type SetEnvironmentPropertiesRequest struct

+ Id string

+ Properties map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetEnvironmentPropertiesRequest) Descriptor() ([]byte, []int)

+ func (*SetEnvironmentPropertiesRequest) ProtoMessage()

+ func (m *SetEnvironmentPropertiesRequest) GetId() string

+ func (m *SetEnvironmentPropertiesRequest) GetProperties() map[string]string

+ func (m *SetEnvironmentPropertiesRequest) Marshal() (dAtA []byte, err error)

+ func (m *SetEnvironmentPropertiesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetEnvironmentPropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetEnvironmentPropertiesRequest) Reset()

+ func (m *SetEnvironmentPropertiesRequest) Size() (n int)

+ func (m *SetEnvironmentPropertiesRequest) String() string

+ func (m *SetEnvironmentPropertiesRequest) Unmarshal(dAtA []byte) error

+ func (m *SetEnvironmentPropertiesRequest) XXX_DiscardUnknown()

+ func (m *SetEnvironmentPropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetEnvironmentPropertiesRequest) XXX_Merge(src proto.Message)

+ func (m *SetEnvironmentPropertiesRequest) XXX_Size() int

+ func (m *SetEnvironmentPropertiesRequest) XXX_Unmarshal(b []byte) error

+ type SetGlobalDefaultRevisionRequest struct

+ Revision string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetGlobalDefaultRevisionRequest) Descriptor() ([]byte, []int)

+ func (*SetGlobalDefaultRevisionRequest) ProtoMessage()

+ func (m *SetGlobalDefaultRevisionRequest) GetRevision() string

+ func (m *SetGlobalDefaultRevisionRequest) Marshal() (dAtA []byte, err error)

+ func (m *SetGlobalDefaultRevisionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetGlobalDefaultRevisionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetGlobalDefaultRevisionRequest) Reset()

+ func (m *SetGlobalDefaultRevisionRequest) Size() (n int)

+ func (m *SetGlobalDefaultRevisionRequest) String() string

+ func (m *SetGlobalDefaultRevisionRequest) Unmarshal(dAtA []byte) error

+ func (m *SetGlobalDefaultRevisionRequest) XXX_DiscardUnknown()

+ func (m *SetGlobalDefaultRevisionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetGlobalDefaultRevisionRequest) XXX_Merge(src proto.Message)

+ func (m *SetGlobalDefaultRevisionRequest) XXX_Size() int

+ func (m *SetGlobalDefaultRevisionRequest) XXX_Unmarshal(b []byte) error

+ type SetRepoDefaultRevisionReply struct

+ Info string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetRepoDefaultRevisionReply) Descriptor() ([]byte, []int)

+ func (*SetRepoDefaultRevisionReply) ProtoMessage()

+ func (m *SetRepoDefaultRevisionReply) GetInfo() string

+ func (m *SetRepoDefaultRevisionReply) Marshal() (dAtA []byte, err error)

+ func (m *SetRepoDefaultRevisionReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetRepoDefaultRevisionReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetRepoDefaultRevisionReply) Reset()

+ func (m *SetRepoDefaultRevisionReply) Size() (n int)

+ func (m *SetRepoDefaultRevisionReply) String() string

+ func (m *SetRepoDefaultRevisionReply) Unmarshal(dAtA []byte) error

+ func (m *SetRepoDefaultRevisionReply) XXX_DiscardUnknown()

+ func (m *SetRepoDefaultRevisionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetRepoDefaultRevisionReply) XXX_Merge(src proto.Message)

+ func (m *SetRepoDefaultRevisionReply) XXX_Size() int

+ func (m *SetRepoDefaultRevisionReply) XXX_Unmarshal(b []byte) error

+ type SetRepoDefaultRevisionRequest struct

+ Index int32

+ Revision string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetRepoDefaultRevisionRequest) Descriptor() ([]byte, []int)

+ func (*SetRepoDefaultRevisionRequest) ProtoMessage()

+ func (m *SetRepoDefaultRevisionRequest) GetIndex() int32

+ func (m *SetRepoDefaultRevisionRequest) GetRevision() string

+ func (m *SetRepoDefaultRevisionRequest) Marshal() (dAtA []byte, err error)

+ func (m *SetRepoDefaultRevisionRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetRepoDefaultRevisionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetRepoDefaultRevisionRequest) Reset()

+ func (m *SetRepoDefaultRevisionRequest) Size() (n int)

+ func (m *SetRepoDefaultRevisionRequest) String() string

+ func (m *SetRepoDefaultRevisionRequest) Unmarshal(dAtA []byte) error

+ func (m *SetRepoDefaultRevisionRequest) XXX_DiscardUnknown()

+ func (m *SetRepoDefaultRevisionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetRepoDefaultRevisionRequest) XXX_Merge(src proto.Message)

+ func (m *SetRepoDefaultRevisionRequest) XXX_Size() int

+ func (m *SetRepoDefaultRevisionRequest) XXX_Unmarshal(b []byte) error

type TaskInfo

+ Properties map[string]string

+ func (m *TaskInfo) GetProperties() map[string]string

type UnimplementedControlServer

+ func (*UnimplementedControlServer) SetGlobalDefaultRevision(ctx context.Context, req *SetGlobalDefaultRevisionRequest) (*Empty, error)

+ func (*UnimplementedControlServer) SetRepoDefaultRevision(ctx context.Context, req *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error)

Jan 22, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupO2Control = fmt.Errorf("proto: unexpected end of group")

Oct 21, 2019

Changes in this version

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Marshal() (dAtA []byte, err error)

+ func (m *Empty) MarshalTo(dAtA []byte) (int, error)

+ func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) String() string

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (m *Empty) XXX_DiscardUnknown()

+ func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

Oct 3, 2019

Changes in this version

type AddRepoReply

+ func (m *AddRepoReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type AddRepoRequest

+ func (m *AddRepoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ChannelInfo

+ func (m *ChannelInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type CleanupTasksReply

+ func (m *CleanupTasksReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type CleanupTasksRequest

+ func (m *CleanupTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type CommandInfo

+ func (m *CommandInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlEnvironmentReply

+ func (m *ControlEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ControlEnvironmentRequest

+ func (m *ControlEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type DestroyEnvironmentReply

+ func (m *DestroyEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type DestroyEnvironmentRequest

+ func (m *DestroyEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type EnvironmentInfo

+ func (m *EnvironmentInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type EnvironmentOperation

+ func (m *EnvironmentOperation) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Event_MesosHeartbeat

+ func (m *Event_MesosHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetEnvironmentReply

+ func (m *GetEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetEnvironmentRequest

+ func (m *GetEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetEnvironmentsReply

+ func (m *GetEnvironmentsReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetEnvironmentsRequest

+ func (m *GetEnvironmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetFrameworkInfoReply

+ func (m *GetFrameworkInfoReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetFrameworkInfoRequest

+ func (m *GetFrameworkInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetRolesReply

+ func (m *GetRolesReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetRolesRequest

+ func (m *GetRolesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTaskReply

+ func (m *GetTaskReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTaskRequest

+ func (m *GetTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTasksReply

+ func (m *GetTasksReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTasksRequest

+ func (m *GetTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetWorkflowTemplatesReply

+ func (m *GetWorkflowTemplatesReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetWorkflowTemplatesRequest

+ AllBranches bool

+ AllTags bool

+ RepoPattern string

+ RevisionPattern string

+ func (m *GetWorkflowTemplatesRequest) GetAllBranches() bool

+ func (m *GetWorkflowTemplatesRequest) GetAllTags() bool

+ func (m *GetWorkflowTemplatesRequest) GetRepoPattern() string

+ func (m *GetWorkflowTemplatesRequest) GetRevisionPattern() string

+ func (m *GetWorkflowTemplatesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ListReposReply

+ func (m *ListReposReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ListReposRequest

+ func (m *ListReposRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ModifyEnvironmentReply

+ func (m *ModifyEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ModifyEnvironmentRequest

+ func (m *ModifyEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type NewEnvironmentReply

+ func (m *NewEnvironmentReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type NewEnvironmentRequest

+ func (m *NewEnvironmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RefreshReposReply

+ func (m *RefreshReposReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RefreshReposRequest

+ func (m *RefreshReposRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RemoveRepoReply

+ func (m *RemoveRepoReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RemoveRepoRequest

+ func (m *RemoveRepoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RepoInfo

+ func (m *RepoInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type RoleInfo

+ func (m *RoleInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SetDefaultRepoReply

+ func (m *SetDefaultRepoReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SetDefaultRepoRequest

+ func (m *SetDefaultRepoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type ShortTaskInfo

+ func (m *ShortTaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type StatusReply

+ func (m *StatusReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type StatusRequest

+ func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type StatusUpdate

+ func (*StatusUpdate) XXX_OneofWrappers() []interface{}

+ func (m *StatusUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

type StatusUpdate_MesosHeartbeat

+ func (m *StatusUpdate_MesosHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TaskClassInfo

+ func (m *TaskClassInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TaskDeploymentInfo

+ func (m *TaskDeploymentInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TaskInfo

+ func (m *TaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TeardownReply

+ func (m *TeardownReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TeardownRequest

+ func (m *TeardownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ type UnimplementedControlServer struct

+ func (*UnimplementedControlServer) AddRepo(ctx context.Context, req *AddRepoRequest) (*AddRepoReply, error)

+ func (*UnimplementedControlServer) CleanupTasks(ctx context.Context, req *CleanupTasksRequest) (*CleanupTasksReply, error)

+ func (*UnimplementedControlServer) ControlEnvironment(ctx context.Context, req *ControlEnvironmentRequest) (*ControlEnvironmentReply, error)

+ func (*UnimplementedControlServer) DestroyEnvironment(ctx context.Context, req *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error)

+ func (*UnimplementedControlServer) GetEnvironment(ctx context.Context, req *GetEnvironmentRequest) (*GetEnvironmentReply, error)

+ func (*UnimplementedControlServer) GetEnvironments(ctx context.Context, req *GetEnvironmentsRequest) (*GetEnvironmentsReply, error)

+ func (*UnimplementedControlServer) GetFrameworkInfo(ctx context.Context, req *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error)

+ func (*UnimplementedControlServer) GetRoles(ctx context.Context, req *GetRolesRequest) (*GetRolesReply, error)

+ func (*UnimplementedControlServer) GetTask(ctx context.Context, req *GetTaskRequest) (*GetTaskReply, error)

+ func (*UnimplementedControlServer) GetTasks(ctx context.Context, req *GetTasksRequest) (*GetTasksReply, error)

+ func (*UnimplementedControlServer) GetWorkflowTemplates(ctx context.Context, req *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error)

+ func (*UnimplementedControlServer) ListRepos(ctx context.Context, req *ListReposRequest) (*ListReposReply, error)

+ func (*UnimplementedControlServer) ModifyEnvironment(ctx context.Context, req *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error)

+ func (*UnimplementedControlServer) NewEnvironment(ctx context.Context, req *NewEnvironmentRequest) (*NewEnvironmentReply, error)

+ func (*UnimplementedControlServer) RefreshRepos(ctx context.Context, req *RefreshReposRequest) (*RefreshReposReply, error)

+ func (*UnimplementedControlServer) RemoveRepo(ctx context.Context, req *RemoveRepoRequest) (*RemoveRepoReply, error)

+ func (*UnimplementedControlServer) SetDefaultRepo(ctx context.Context, req *SetDefaultRepoRequest) (*SetDefaultRepoReply, error)

+ func (*UnimplementedControlServer) Teardown(ctx context.Context, req *TeardownRequest) (*TeardownReply, error)

+ func (*UnimplementedControlServer) TrackStatus(req *StatusRequest, srv Control_TrackStatusServer) error

type Version

+ func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

type WorkflowTemplateInfo

+ Revision string

+ func (m *WorkflowTemplateInfo) GetRevision() string

+ func (m *WorkflowTemplateInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

Aug 26, 2019

Changes in this version

+ type AddRepoReply struct

+ ErrorString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AddRepoReply) Descriptor() ([]byte, []int)

+ func (*AddRepoReply) ProtoMessage()

+ func (m *AddRepoReply) GetErrorString() string

+ func (m *AddRepoReply) Marshal() (dAtA []byte, err error)

+ func (m *AddRepoReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *AddRepoReply) Reset()

+ func (m *AddRepoReply) Size() (n int)

+ func (m *AddRepoReply) String() string

+ func (m *AddRepoReply) Unmarshal(dAtA []byte) error

+ func (m *AddRepoReply) XXX_DiscardUnknown()

+ func (m *AddRepoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AddRepoReply) XXX_Merge(src proto.Message)

+ func (m *AddRepoReply) XXX_Size() int

+ func (m *AddRepoReply) XXX_Unmarshal(b []byte) error

+ type AddRepoRequest struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AddRepoRequest) Descriptor() ([]byte, []int)

+ func (*AddRepoRequest) ProtoMessage()

+ func (m *AddRepoRequest) GetName() string

+ func (m *AddRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *AddRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *AddRepoRequest) Reset()

+ func (m *AddRepoRequest) Size() (n int)

+ func (m *AddRepoRequest) String() string

+ func (m *AddRepoRequest) Unmarshal(dAtA []byte) error

+ func (m *AddRepoRequest) XXX_DiscardUnknown()

+ func (m *AddRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AddRepoRequest) XXX_Merge(src proto.Message)

+ func (m *AddRepoRequest) XXX_Size() int

+ func (m *AddRepoRequest) XXX_Unmarshal(b []byte) error

type ControlClient

+ AddRepo func(ctx context.Context, in *AddRepoRequest, opts ...grpc.CallOption) (*AddRepoReply, error)

+ ListRepos func(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposReply, error)

+ RefreshRepos func(ctx context.Context, in *RefreshReposRequest, opts ...grpc.CallOption) (*RefreshReposReply, error)

+ RemoveRepo func(ctx context.Context, in *RemoveRepoRequest, opts ...grpc.CallOption) (*RemoveRepoReply, error)

+ SetDefaultRepo func(ctx context.Context, in *SetDefaultRepoRequest, opts ...grpc.CallOption) (*SetDefaultRepoReply, error)

type ControlServer

+ AddRepo func(context.Context, *AddRepoRequest) (*AddRepoReply, error)

+ ListRepos func(context.Context, *ListReposRequest) (*ListReposReply, error)

+ RefreshRepos func(context.Context, *RefreshReposRequest) (*RefreshReposReply, error)

+ RemoveRepo func(context.Context, *RemoveRepoRequest) (*RemoveRepoReply, error)

+ SetDefaultRepo func(context.Context, *SetDefaultRepoRequest) (*SetDefaultRepoReply, error)

+ type ListReposReply struct

+ Repos []*RepoInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListReposReply) Descriptor() ([]byte, []int)

+ func (*ListReposReply) ProtoMessage()

+ func (m *ListReposReply) GetRepos() []*RepoInfo

+ func (m *ListReposReply) Marshal() (dAtA []byte, err error)

+ func (m *ListReposReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListReposReply) Reset()

+ func (m *ListReposReply) Size() (n int)

+ func (m *ListReposReply) String() string

+ func (m *ListReposReply) Unmarshal(dAtA []byte) error

+ func (m *ListReposReply) XXX_DiscardUnknown()

+ func (m *ListReposReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListReposReply) XXX_Merge(src proto.Message)

+ func (m *ListReposReply) XXX_Size() int

+ func (m *ListReposReply) XXX_Unmarshal(b []byte) error

+ type ListReposRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListReposRequest) Descriptor() ([]byte, []int)

+ func (*ListReposRequest) ProtoMessage()

+ func (m *ListReposRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListReposRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListReposRequest) Reset()

+ func (m *ListReposRequest) Size() (n int)

+ func (m *ListReposRequest) String() string

+ func (m *ListReposRequest) Unmarshal(dAtA []byte) error

+ func (m *ListReposRequest) XXX_DiscardUnknown()

+ func (m *ListReposRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ListReposRequest) XXX_Merge(src proto.Message)

+ func (m *ListReposRequest) XXX_Size() int

+ func (m *ListReposRequest) XXX_Unmarshal(b []byte) error

+ type RefreshReposReply struct

+ ErrorString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RefreshReposReply) Descriptor() ([]byte, []int)

+ func (*RefreshReposReply) ProtoMessage()

+ func (m *RefreshReposReply) GetErrorString() string

+ func (m *RefreshReposReply) Marshal() (dAtA []byte, err error)

+ func (m *RefreshReposReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshReposReply) Reset()

+ func (m *RefreshReposReply) Size() (n int)

+ func (m *RefreshReposReply) String() string

+ func (m *RefreshReposReply) Unmarshal(dAtA []byte) error

+ func (m *RefreshReposReply) XXX_DiscardUnknown()

+ func (m *RefreshReposReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshReposReply) XXX_Merge(src proto.Message)

+ func (m *RefreshReposReply) XXX_Size() int

+ func (m *RefreshReposReply) XXX_Unmarshal(b []byte) error

+ type RefreshReposRequest struct

+ Index int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RefreshReposRequest) Descriptor() ([]byte, []int)

+ func (*RefreshReposRequest) ProtoMessage()

+ func (m *RefreshReposRequest) GetIndex() int32

+ func (m *RefreshReposRequest) Marshal() (dAtA []byte, err error)

+ func (m *RefreshReposRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshReposRequest) Reset()

+ func (m *RefreshReposRequest) Size() (n int)

+ func (m *RefreshReposRequest) String() string

+ func (m *RefreshReposRequest) Unmarshal(dAtA []byte) error

+ func (m *RefreshReposRequest) XXX_DiscardUnknown()

+ func (m *RefreshReposRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshReposRequest) XXX_Merge(src proto.Message)

+ func (m *RefreshReposRequest) XXX_Size() int

+ func (m *RefreshReposRequest) XXX_Unmarshal(b []byte) error

+ type RemoveRepoReply struct

+ NewDefaultRepo string

+ Ok bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveRepoReply) Descriptor() ([]byte, []int)

+ func (*RemoveRepoReply) ProtoMessage()

+ func (m *RemoveRepoReply) GetNewDefaultRepo() string

+ func (m *RemoveRepoReply) GetOk() bool

+ func (m *RemoveRepoReply) Marshal() (dAtA []byte, err error)

+ func (m *RemoveRepoReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveRepoReply) Reset()

+ func (m *RemoveRepoReply) Size() (n int)

+ func (m *RemoveRepoReply) String() string

+ func (m *RemoveRepoReply) Unmarshal(dAtA []byte) error

+ func (m *RemoveRepoReply) XXX_DiscardUnknown()

+ func (m *RemoveRepoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveRepoReply) XXX_Merge(src proto.Message)

+ func (m *RemoveRepoReply) XXX_Size() int

+ func (m *RemoveRepoReply) XXX_Unmarshal(b []byte) error

+ type RemoveRepoRequest struct

+ Index int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoveRepoRequest) Descriptor() ([]byte, []int)

+ func (*RemoveRepoRequest) ProtoMessage()

+ func (m *RemoveRepoRequest) GetIndex() int32

+ func (m *RemoveRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *RemoveRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RemoveRepoRequest) Reset()

+ func (m *RemoveRepoRequest) Size() (n int)

+ func (m *RemoveRepoRequest) String() string

+ func (m *RemoveRepoRequest) Unmarshal(dAtA []byte) error

+ func (m *RemoveRepoRequest) XXX_DiscardUnknown()

+ func (m *RemoveRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RemoveRepoRequest) XXX_Merge(src proto.Message)

+ func (m *RemoveRepoRequest) XXX_Size() int

+ func (m *RemoveRepoRequest) XXX_Unmarshal(b []byte) error

+ type RepoInfo struct

+ Default bool

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RepoInfo) Descriptor() ([]byte, []int)

+ func (*RepoInfo) ProtoMessage()

+ func (m *RepoInfo) GetDefault() bool

+ func (m *RepoInfo) GetName() string

+ func (m *RepoInfo) Marshal() (dAtA []byte, err error)

+ func (m *RepoInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *RepoInfo) Reset()

+ func (m *RepoInfo) Size() (n int)

+ func (m *RepoInfo) String() string

+ func (m *RepoInfo) Unmarshal(dAtA []byte) error

+ func (m *RepoInfo) XXX_DiscardUnknown()

+ func (m *RepoInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RepoInfo) XXX_Merge(src proto.Message)

+ func (m *RepoInfo) XXX_Size() int

+ func (m *RepoInfo) XXX_Unmarshal(b []byte) error

+ type SetDefaultRepoReply struct

+ ErrorString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetDefaultRepoReply) Descriptor() ([]byte, []int)

+ func (*SetDefaultRepoReply) ProtoMessage()

+ func (m *SetDefaultRepoReply) GetErrorString() string

+ func (m *SetDefaultRepoReply) Marshal() (dAtA []byte, err error)

+ func (m *SetDefaultRepoReply) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetDefaultRepoReply) Reset()

+ func (m *SetDefaultRepoReply) Size() (n int)

+ func (m *SetDefaultRepoReply) String() string

+ func (m *SetDefaultRepoReply) Unmarshal(dAtA []byte) error

+ func (m *SetDefaultRepoReply) XXX_DiscardUnknown()

+ func (m *SetDefaultRepoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetDefaultRepoReply) XXX_Merge(src proto.Message)

+ func (m *SetDefaultRepoReply) XXX_Size() int

+ func (m *SetDefaultRepoReply) XXX_Unmarshal(b []byte) error

+ type SetDefaultRepoRequest struct

+ Index int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetDefaultRepoRequest) Descriptor() ([]byte, []int)

+ func (*SetDefaultRepoRequest) ProtoMessage()

+ func (m *SetDefaultRepoRequest) GetIndex() int32

+ func (m *SetDefaultRepoRequest) Marshal() (dAtA []byte, err error)

+ func (m *SetDefaultRepoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetDefaultRepoRequest) Reset()

+ func (m *SetDefaultRepoRequest) Size() (n int)

+ func (m *SetDefaultRepoRequest) String() string

+ func (m *SetDefaultRepoRequest) Unmarshal(dAtA []byte) error

+ func (m *SetDefaultRepoRequest) XXX_DiscardUnknown()

+ func (m *SetDefaultRepoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetDefaultRepoRequest) XXX_Merge(src proto.Message)

+ func (m *SetDefaultRepoRequest) XXX_Size() int

+ func (m *SetDefaultRepoRequest) XXX_Unmarshal(b []byte) error

+ type WorkflowTemplateInfo struct

+ Repo string

+ Template string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowTemplateInfo) Descriptor() ([]byte, []int)

+ func (*WorkflowTemplateInfo) ProtoMessage()

+ func (m *WorkflowTemplateInfo) GetRepo() string

+ func (m *WorkflowTemplateInfo) GetTemplate() string

+ func (m *WorkflowTemplateInfo) Marshal() (dAtA []byte, err error)

+ func (m *WorkflowTemplateInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *WorkflowTemplateInfo) Reset()

+ func (m *WorkflowTemplateInfo) Size() (n int)

+ func (m *WorkflowTemplateInfo) String() string

+ func (m *WorkflowTemplateInfo) Unmarshal(dAtA []byte) error

+ func (m *WorkflowTemplateInfo) XXX_DiscardUnknown()

+ func (m *WorkflowTemplateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowTemplateInfo) XXX_Merge(src proto.Message)

+ func (m *WorkflowTemplateInfo) XXX_Size() int

+ func (m *WorkflowTemplateInfo) XXX_Unmarshal(b []byte) error

Jul 17, 2019

Changes in this version

type DestroyEnvironmentReply

+ CleanupTasksReply *CleanupTasksReply

+ func (m *DestroyEnvironmentReply) GetCleanupTasksReply() *CleanupTasksReply

type DestroyEnvironmentRequest

+ KeepTasks bool

+ func (m *DestroyEnvironmentRequest) GetKeepTasks() bool

May 14, 2019

Changes in this version

type ControlEnvironmentReply

+ CurrentRunNumber uint64

+ func (m *ControlEnvironmentReply) GetCurrentRunNumber() uint64

type EnvironmentInfo

+ CurrentRunNumber uint64

+ func (m *EnvironmentInfo) GetCurrentRunNumber() uint64

Apr 30, 2019

Changes in this version

type GetFrameworkInfoReply

+ InstanceName string

+ Version *Version

+ func (m *GetFrameworkInfoReply) GetInstanceName() string

+ func (m *GetFrameworkInfoReply) GetVersion() *Version

+ type Version struct

+ Build string

+ Major int32

+ Minor int32

+ Patch int32

+ ProductName string

+ VersionStr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Version) Descriptor() ([]byte, []int)

+ func (*Version) ProtoMessage()

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

Mar 12, 2019

Changes in this version

+ var ControlEnvironmentRequest_Optype_name = map[int32]string

+ var ControlEnvironmentRequest_Optype_value = map[string]int32

+ var EnvironmentOperation_Optype_name = map[int32]string

+ var EnvironmentOperation_Optype_value = map[string]int32

+ var ErrIntOverflowO2Control = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthO2Control = fmt.Errorf("proto: negative length found during unmarshaling")

+ var StatusUpdate_Level_name = map[int32]string

+ var StatusUpdate_Level_value = map[string]int32

+ func RegisterControlServer(s *grpc.Server, srv ControlServer)

+ type ChannelInfo struct

+ Name string

+ Target string

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ChannelInfo) Descriptor() ([]byte, []int)

+ func (*ChannelInfo) ProtoMessage()

+ func (dst *ChannelInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ChannelInfo) XXX_Unmarshal(b []byte) error

+ type CleanupTasksReply struct

+ KilledTasks []*ShortTaskInfo

+ RunningTasks []*ShortTaskInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CleanupTasksReply) Descriptor() ([]byte, []int)

+ func (*CleanupTasksReply) ProtoMessage()

+ func (dst *CleanupTasksReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *CleanupTasksReply) XXX_Unmarshal(b []byte) error

+ type CleanupTasksRequest struct

+ TaskIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CleanupTasksRequest) Descriptor() ([]byte, []int)

+ func (*CleanupTasksRequest) ProtoMessage()

+ func (dst *CleanupTasksRequest) XXX_Merge(src proto.Message)

+ func (m *CleanupTasksRequest) GetTaskIds() []string

+ func (m *CleanupTasksRequest) Marshal() (dAtA []byte, err error)

+ func (m *CleanupTasksRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *CleanupTasksRequest) XXX_Unmarshal(b []byte) error

+ type CommandInfo struct

+ Arguments []string

+ Env []string

+ Shell bool

+ User string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommandInfo) Descriptor() ([]byte, []int)

+ func (*CommandInfo) ProtoMessage()

+ func (dst *CommandInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *CommandInfo) XXX_Unmarshal(b []byte) error

+ type ControlClient interface

+ CleanupTasks func(ctx context.Context, in *CleanupTasksRequest, opts ...grpc.CallOption) (*CleanupTasksReply, error)

+ ControlEnvironment func(ctx context.Context, in *ControlEnvironmentRequest, opts ...grpc.CallOption) (*ControlEnvironmentReply, error)

+ DestroyEnvironment func(ctx context.Context, in *DestroyEnvironmentRequest, opts ...grpc.CallOption) (*DestroyEnvironmentReply, error)

+ GetEnvironment func(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentReply, error)

+ GetEnvironments func(ctx context.Context, in *GetEnvironmentsRequest, opts ...grpc.CallOption) (*GetEnvironmentsReply, error)

+ GetFrameworkInfo func(ctx context.Context, in *GetFrameworkInfoRequest, opts ...grpc.CallOption) (*GetFrameworkInfoReply, error)

+ GetRoles func(ctx context.Context, in *GetRolesRequest, opts ...grpc.CallOption) (*GetRolesReply, error)

+ GetTask func(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskReply, error)

+ GetTasks func(ctx context.Context, in *GetTasksRequest, opts ...grpc.CallOption) (*GetTasksReply, error)

+ GetWorkflowTemplates func(ctx context.Context, in *GetWorkflowTemplatesRequest, opts ...grpc.CallOption) (*GetWorkflowTemplatesReply, error)

+ ModifyEnvironment func(ctx context.Context, in *ModifyEnvironmentRequest, opts ...grpc.CallOption) (*ModifyEnvironmentReply, error)

+ NewEnvironment func(ctx context.Context, in *NewEnvironmentRequest, opts ...grpc.CallOption) (*NewEnvironmentReply, error)

+ Teardown func(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*TeardownReply, error)

+ TrackStatus func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Control_TrackStatusClient, error)

+ func NewControlClient(cc *grpc.ClientConn) ControlClient

+ type ControlEnvironmentReply struct

+ Id string

+ State string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*ControlEnvironmentReply) ProtoMessage()

+ func (dst *ControlEnvironmentReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ControlEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type ControlEnvironmentRequest struct

+ Id string

+ Type ControlEnvironmentRequest_Optype

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ControlEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*ControlEnvironmentRequest) ProtoMessage()

+ func (dst *ControlEnvironmentRequest) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ControlEnvironmentRequest) XXX_Unmarshal(b []byte) error

+ type ControlEnvironmentRequest_Optype int32

+ const ControlEnvironmentRequest_CONFIGURE

+ const ControlEnvironmentRequest_GO_ERROR

+ const ControlEnvironmentRequest_NOOP

+ const ControlEnvironmentRequest_RESET

+ const ControlEnvironmentRequest_START_ACTIVITY

+ const ControlEnvironmentRequest_STOP_ACTIVITY

+ func (ControlEnvironmentRequest_Optype) EnumDescriptor() ([]byte, []int)

+ func (x ControlEnvironmentRequest_Optype) String() string

+ type ControlServer interface

+ CleanupTasks func(context.Context, *CleanupTasksRequest) (*CleanupTasksReply, error)

+ ControlEnvironment func(context.Context, *ControlEnvironmentRequest) (*ControlEnvironmentReply, error)

+ DestroyEnvironment func(context.Context, *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error)

+ GetEnvironment func(context.Context, *GetEnvironmentRequest) (*GetEnvironmentReply, error)

+ GetEnvironments func(context.Context, *GetEnvironmentsRequest) (*GetEnvironmentsReply, error)

+ GetFrameworkInfo func(context.Context, *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error)

+ GetRoles func(context.Context, *GetRolesRequest) (*GetRolesReply, error)

+ GetTask func(context.Context, *GetTaskRequest) (*GetTaskReply, error)

+ GetTasks func(context.Context, *GetTasksRequest) (*GetTasksReply, error)

+ GetWorkflowTemplates func(context.Context, *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error)

+ ModifyEnvironment func(context.Context, *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error)

+ NewEnvironment func(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)

+ Teardown func(context.Context, *TeardownRequest) (*TeardownReply, error)

+ TrackStatus func(*StatusRequest, Control_TrackStatusServer) error

+ type Control_TrackStatusClient interface

+ Recv func() (*StatusReply, error)

+ type Control_TrackStatusServer interface

+ Send func(*StatusReply) error

+ type DestroyEnvironmentReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DestroyEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*DestroyEnvironmentReply) ProtoMessage()

+ func (dst *DestroyEnvironmentReply) XXX_Merge(src proto.Message)

+ func (m *DestroyEnvironmentReply) Marshal() (dAtA []byte, err error)

+ func (m *DestroyEnvironmentReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *DestroyEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type DestroyEnvironmentRequest struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DestroyEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*DestroyEnvironmentRequest) ProtoMessage()

+ func (dst *DestroyEnvironmentRequest) XXX_Merge(src proto.Message)

+ func (m *DestroyEnvironmentRequest) GetId() string

+ func (m *DestroyEnvironmentRequest) Marshal() (dAtA []byte, err error)

+ func (m *DestroyEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *DestroyEnvironmentRequest) XXX_Unmarshal(b []byte) error

+ type EnvironmentInfo struct

+ CreatedWhen string

+ Id string

+ RootRole string

+ State string

+ Tasks []*ShortTaskInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EnvironmentInfo) Descriptor() ([]byte, []int)

+ func (*EnvironmentInfo) ProtoMessage()

+ func (dst *EnvironmentInfo) XXX_Merge(src proto.Message)

+ func (m *EnvironmentInfo) GetCreatedWhen() string

+ 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 (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_Size() int

+ func (m *EnvironmentInfo) XXX_Unmarshal(b []byte) error

+ type EnvironmentOperation struct

+ RoleName string

+ Type EnvironmentOperation_Optype

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EnvironmentOperation) Descriptor() ([]byte, []int)

+ func (*EnvironmentOperation) ProtoMessage()

+ func (dst *EnvironmentOperation) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *EnvironmentOperation) XXX_Unmarshal(b []byte) error

+ type EnvironmentOperation_Optype int32

+ const EnvironmentOperation_ADD_ROLE

+ const EnvironmentOperation_NOOP

+ const EnvironmentOperation_REMOVE_ROLE

+ func (EnvironmentOperation_Optype) EnumDescriptor() ([]byte, []int)

+ func (x EnvironmentOperation_Optype) String() string

+ type Event_MesosHeartbeat struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Event_MesosHeartbeat) Descriptor() ([]byte, []int)

+ func (*Event_MesosHeartbeat) ProtoMessage()

+ func (dst *Event_MesosHeartbeat) XXX_Merge(src proto.Message)

+ func (m *Event_MesosHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *Event_MesosHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *Event_MesosHeartbeat) XXX_Unmarshal(b []byte) error

+ type GetEnvironmentReply struct

+ Environment *EnvironmentInfo

+ Workflow *RoleInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentReply) ProtoMessage()

+ func (dst *GetEnvironmentReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *GetEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type GetEnvironmentRequest struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentRequest) ProtoMessage()

+ func (dst *GetEnvironmentRequest) XXX_Merge(src proto.Message)

+ func (m *GetEnvironmentRequest) GetId() string

+ func (m *GetEnvironmentRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetEnvironmentRequest) XXX_Unmarshal(b []byte) error

+ type GetEnvironmentsReply struct

+ Environments []*EnvironmentInfo

+ FrameworkId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentsReply) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentsReply) ProtoMessage()

+ func (dst *GetEnvironmentsReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *GetEnvironmentsReply) XXX_Unmarshal(b []byte) error

+ type GetEnvironmentsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetEnvironmentsRequest) Descriptor() ([]byte, []int)

+ func (*GetEnvironmentsRequest) ProtoMessage()

+ func (dst *GetEnvironmentsRequest) XXX_Merge(src proto.Message)

+ func (m *GetEnvironmentsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetEnvironmentsRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetEnvironmentsRequest) XXX_Unmarshal(b []byte) error

+ type GetFrameworkInfoReply struct

+ EnvironmentsCount int32

+ FrameworkId string

+ HostsCount int32

+ State string

+ TasksCount int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetFrameworkInfoReply) Descriptor() ([]byte, []int)

+ func (*GetFrameworkInfoReply) ProtoMessage()

+ func (dst *GetFrameworkInfoReply) XXX_Merge(src proto.Message)

+ func (m *GetFrameworkInfoReply) GetEnvironmentsCount() int32

+ func (m *GetFrameworkInfoReply) GetFrameworkId() string

+ func (m *GetFrameworkInfoReply) GetHostsCount() int32

+ func (m *GetFrameworkInfoReply) GetState() string

+ func (m *GetFrameworkInfoReply) GetTasksCount() int32

+ func (m *GetFrameworkInfoReply) Marshal() (dAtA []byte, err error)

+ func (m *GetFrameworkInfoReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetFrameworkInfoReply) XXX_Unmarshal(b []byte) error

+ type GetFrameworkInfoRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetFrameworkInfoRequest) Descriptor() ([]byte, []int)

+ func (*GetFrameworkInfoRequest) ProtoMessage()

+ func (dst *GetFrameworkInfoRequest) XXX_Merge(src proto.Message)

+ func (m *GetFrameworkInfoRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetFrameworkInfoRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetFrameworkInfoRequest) XXX_Unmarshal(b []byte) error

+ type GetRolesReply struct

+ Roles []*RoleInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetRolesReply) Descriptor() ([]byte, []int)

+ func (*GetRolesReply) ProtoMessage()

+ func (dst *GetRolesReply) XXX_Merge(src proto.Message)

+ func (m *GetRolesReply) GetRoles() []*RoleInfo

+ func (m *GetRolesReply) Marshal() (dAtA []byte, err error)

+ func (m *GetRolesReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetRolesReply) XXX_Unmarshal(b []byte) error

+ type GetRolesRequest struct

+ EnvId string

+ PathSpec string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetRolesRequest) Descriptor() ([]byte, []int)

+ func (*GetRolesRequest) ProtoMessage()

+ func (dst *GetRolesRequest) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *GetRolesRequest) XXX_Unmarshal(b []byte) error

+ type GetTaskReply struct

+ Task *TaskInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskReply) Descriptor() ([]byte, []int)

+ func (*GetTaskReply) ProtoMessage()

+ func (dst *GetTaskReply) XXX_Merge(src proto.Message)

+ func (m *GetTaskReply) GetTask() *TaskInfo

+ func (m *GetTaskReply) Marshal() (dAtA []byte, err error)

+ func (m *GetTaskReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetTaskReply) XXX_Unmarshal(b []byte) error

+ type GetTaskRequest struct

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTaskRequest) Descriptor() ([]byte, []int)

+ func (*GetTaskRequest) ProtoMessage()

+ func (dst *GetTaskRequest) XXX_Merge(src proto.Message)

+ func (m *GetTaskRequest) GetTaskId() string

+ func (m *GetTaskRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTaskRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error

+ type GetTasksReply struct

+ Tasks []*ShortTaskInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTasksReply) Descriptor() ([]byte, []int)

+ func (*GetTasksReply) ProtoMessage()

+ func (dst *GetTasksReply) XXX_Merge(src proto.Message)

+ func (m *GetTasksReply) GetTasks() []*ShortTaskInfo

+ func (m *GetTasksReply) Marshal() (dAtA []byte, err error)

+ func (m *GetTasksReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetTasksReply) XXX_Unmarshal(b []byte) error

+ type GetTasksRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTasksRequest) Descriptor() ([]byte, []int)

+ func (*GetTasksRequest) ProtoMessage()

+ func (dst *GetTasksRequest) XXX_Merge(src proto.Message)

+ func (m *GetTasksRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTasksRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetTasksRequest) XXX_Unmarshal(b []byte) error

+ type GetWorkflowTemplatesReply struct

+ WorkflowTemplates []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowTemplatesReply) Descriptor() ([]byte, []int)

+ func (*GetWorkflowTemplatesReply) ProtoMessage()

+ func (dst *GetWorkflowTemplatesReply) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowTemplatesReply) GetWorkflowTemplates() []string

+ func (m *GetWorkflowTemplatesReply) Marshal() (dAtA []byte, err error)

+ func (m *GetWorkflowTemplatesReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetWorkflowTemplatesReply) XXX_Unmarshal(b []byte) error

+ type GetWorkflowTemplatesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetWorkflowTemplatesRequest) Descriptor() ([]byte, []int)

+ func (*GetWorkflowTemplatesRequest) ProtoMessage()

+ func (dst *GetWorkflowTemplatesRequest) XXX_Merge(src proto.Message)

+ func (m *GetWorkflowTemplatesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetWorkflowTemplatesRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *GetWorkflowTemplatesRequest) XXX_Unmarshal(b []byte) error

+ type ModifyEnvironmentReply struct

+ FailedOperations []*EnvironmentOperation

+ Id string

+ State string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ModifyEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*ModifyEnvironmentReply) ProtoMessage()

+ func (dst *ModifyEnvironmentReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ModifyEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type ModifyEnvironmentRequest struct

+ Id string

+ Operations []*EnvironmentOperation

+ ReconfigureAll bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ModifyEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*ModifyEnvironmentRequest) ProtoMessage()

+ func (dst *ModifyEnvironmentRequest) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ModifyEnvironmentRequest) XXX_Unmarshal(b []byte) error

+ type NewEnvironmentReply struct

+ Environment *EnvironmentInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewEnvironmentReply) Descriptor() ([]byte, []int)

+ func (*NewEnvironmentReply) ProtoMessage()

+ func (dst *NewEnvironmentReply) XXX_Merge(src proto.Message)

+ func (m *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo

+ func (m *NewEnvironmentReply) Marshal() (dAtA []byte, err error)

+ func (m *NewEnvironmentReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *NewEnvironmentReply) XXX_Unmarshal(b []byte) error

+ type NewEnvironmentRequest struct

+ WorkflowTemplate string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NewEnvironmentRequest) Descriptor() ([]byte, []int)

+ func (*NewEnvironmentRequest) ProtoMessage()

+ func (dst *NewEnvironmentRequest) XXX_Merge(src proto.Message)

+ func (m *NewEnvironmentRequest) GetWorkflowTemplate() string

+ func (m *NewEnvironmentRequest) Marshal() (dAtA []byte, err error)

+ func (m *NewEnvironmentRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *NewEnvironmentRequest) XXX_Unmarshal(b []byte) error

+ type RoleInfo struct

+ FullPath string

+ Name string

+ Roles []*RoleInfo

+ State string

+ Status string

+ TaskIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RoleInfo) Descriptor() ([]byte, []int)

+ func (*RoleInfo) ProtoMessage()

+ func (dst *RoleInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *RoleInfo) XXX_Unmarshal(b []byte) error

+ type ShortTaskInfo struct

+ ClassName string

+ DeploymentInfo *TaskDeploymentInfo

+ Locked bool

+ Name string

+ State string

+ Status string

+ TaskId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ShortTaskInfo) Descriptor() ([]byte, []int)

+ func (*ShortTaskInfo) ProtoMessage()

+ func (dst *ShortTaskInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *ShortTaskInfo) XXX_Unmarshal(b []byte) error

+ type StatusReply struct

+ State string

+ StatusUpdates []*StatusUpdate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StatusReply) Descriptor() ([]byte, []int)

+ func (*StatusReply) ProtoMessage()

+ func (dst *StatusReply) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *StatusReply) XXX_Unmarshal(b []byte) error

+ type StatusRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StatusRequest) Descriptor() ([]byte, []int)

+ func (*StatusRequest) ProtoMessage()

+ func (dst *StatusRequest) XXX_Merge(src proto.Message)

+ func (m *StatusRequest) Marshal() (dAtA []byte, err error)

+ func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *StatusRequest) XXX_Unmarshal(b []byte) error

+ type StatusUpdate struct

+ Event isStatusUpdate_Event

+ Level StatusUpdate_Level

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StatusUpdate) Descriptor() ([]byte, []int)

+ func (*StatusUpdate) ProtoMessage()

+ func (*StatusUpdate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *StatusUpdate) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *StatusUpdate) XXX_Unmarshal(b []byte) error

+ type StatusUpdate_Level int32

+ const StatusUpdate_DEBUG

+ const StatusUpdate_ERROR

+ const StatusUpdate_INFO

+ const StatusUpdate_WARNING

+ func (StatusUpdate_Level) EnumDescriptor() ([]byte, []int)

+ func (x StatusUpdate_Level) String() string

+ type StatusUpdate_MesosHeartbeat struct

+ MesosHeartbeat *Event_MesosHeartbeat

+ func (m *StatusUpdate_MesosHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *StatusUpdate_MesosHeartbeat) Size() (n int)

+ type TaskClassInfo struct

+ ControlMode string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskClassInfo) Descriptor() ([]byte, []int)

+ func (*TaskClassInfo) ProtoMessage()

+ func (dst *TaskClassInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *TaskClassInfo) XXX_Unmarshal(b []byte) error

+ type TaskDeploymentInfo struct

+ AgentId string

+ ExecutorId string

+ Hostname string

+ OfferId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskDeploymentInfo) Descriptor() ([]byte, []int)

+ func (*TaskDeploymentInfo) ProtoMessage()

+ func (dst *TaskDeploymentInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *TaskDeploymentInfo) XXX_Unmarshal(b []byte) error

+ type TaskInfo struct

+ ClassInfo *TaskClassInfo

+ CommandInfo *CommandInfo

+ EnvId string

+ InboundChannels []*ChannelInfo

+ OutboundChannels []*ChannelInfo

+ ShortInfo *ShortTaskInfo

+ TaskPath string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskInfo) Descriptor() ([]byte, []int)

+ func (*TaskInfo) ProtoMessage()

+ func (dst *TaskInfo) XXX_Merge(src proto.Message)

+ 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 (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_Size() int

+ func (m *TaskInfo) XXX_Unmarshal(b []byte) error

+ type TeardownReply struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TeardownReply) Descriptor() ([]byte, []int)

+ func (*TeardownReply) ProtoMessage()

+ func (dst *TeardownReply) XXX_Merge(src proto.Message)

+ func (m *TeardownReply) Marshal() (dAtA []byte, err error)

+ func (m *TeardownReply) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *TeardownReply) XXX_Unmarshal(b []byte) error

+ type TeardownRequest struct

+ Reason string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TeardownRequest) Descriptor() ([]byte, []int)

+ func (*TeardownRequest) ProtoMessage()

+ func (dst *TeardownRequest) XXX_Merge(src proto.Message)

+ func (m *TeardownRequest) GetReason() string

+ func (m *TeardownRequest) Marshal() (dAtA []byte, err error)

+ func (m *TeardownRequest) MarshalTo(dAtA []byte) (int, error)

+ 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_Size() int

+ func (m *TeardownRequest) XXX_Unmarshal(b []byte) error