pb

package
v0.17.82 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 13, 2020 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthO2Control        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowO2Control          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupO2Control = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ControlEnvironmentRequest_Optype_name = map[int32]string{
	0: "NOOP",
	1: "START_ACTIVITY",
	2: "STOP_ACTIVITY",
	3: "CONFIGURE",
	4: "RESET",
	5: "GO_ERROR",
}
View Source 
var ControlEnvironmentRequest_Optype_value = map[string]int32{
	"NOOP":           0,
	"START_ACTIVITY": 1,
	"STOP_ACTIVITY":  2,
	"CONFIGURE":      3,
	"RESET":          4,
	"GO_ERROR":       5,
}
View Source 
var EnvironmentOperation_Optype_name = map[int32]string{
	0: "NOOP",
	3: "REMOVE_ROLE",
	4: "ADD_ROLE",
}
View Source 
var EnvironmentOperation_Optype_value = map[string]int32{
	"NOOP":        0,
	"REMOVE_ROLE": 3,
	"ADD_ROLE":    4,
}
View Source 
var StatusUpdate_Level_name = map[int32]string{
	0: "DEBUG",
	1: "INFO",
	2: "WARNING",
	3: "ERROR",
}
View Source 
var StatusUpdate_Level_value = map[string]int32{
	"DEBUG":   0,
	"INFO":    1,
	"WARNING": 2,
	"ERROR":   3,
}

Functions

func RegisterControlServer 

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

Types

type AddRepoReply added in v0.10.0 

type AddRepoReply struct {
	NewDefaultRevision   string   `protobuf:"bytes,1,opt,name=newDefaultRevision,proto3" json:"newDefaultRevision,omitempty"`
	Info                 string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRepoReply) Descriptor added in v0.10.0 

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

func (*AddRepoReply) GetInfo added in v0.12.90 

func (m *AddRepoReply) GetInfo() string

func (*AddRepoReply) GetNewDefaultRevision added in v0.12.90 

func (m *AddRepoReply) GetNewDefaultRevision() string

func (*AddRepoReply) Marshal added in v0.10.0 

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

func (*AddRepoReply) MarshalTo added in v0.10.0 

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

func (*AddRepoReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*AddRepoReply) ProtoMessage added in v0.10.0 

func (*AddRepoReply) ProtoMessage()

func (*AddRepoReply) Reset added in v0.10.0 

func (m *AddRepoReply) Reset()

func (*AddRepoReply) Size added in v0.10.0 

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

func (*AddRepoReply) String added in v0.10.0 

func (m *AddRepoReply) String() string

func (*AddRepoReply) Unmarshal added in v0.10.0 

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

func (*AddRepoReply) XXX_DiscardUnknown added in v0.10.0 

func (m *AddRepoReply) XXX_DiscardUnknown()

func (*AddRepoReply) XXX_Marshal added in v0.10.0 

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

func (*AddRepoReply) XXX_Merge added in v0.10.0 

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

func (*AddRepoReply) XXX_Size added in v0.10.0 

func (m *AddRepoReply) XXX_Size() int

func (*AddRepoReply) XXX_Unmarshal added in v0.10.0 

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

type AddRepoRequest added in v0.10.0 

type AddRepoRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DefaultRevision      string   `protobuf:"bytes,2,opt,name=defaultRevision,proto3" json:"defaultRevision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRepoRequest) Descriptor added in v0.10.0 

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

func (*AddRepoRequest) GetDefaultRevision added in v0.12.90 

func (m *AddRepoRequest) GetDefaultRevision() string

func (*AddRepoRequest) GetName added in v0.10.0 

func (m *AddRepoRequest) GetName() string

func (*AddRepoRequest) Marshal added in v0.10.0 

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

func (*AddRepoRequest) MarshalTo added in v0.10.0 

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

func (*AddRepoRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*AddRepoRequest) ProtoMessage added in v0.10.0 

func (*AddRepoRequest) ProtoMessage()

func (*AddRepoRequest) Reset added in v0.10.0 

func (m *AddRepoRequest) Reset()

func (*AddRepoRequest) Size added in v0.10.0 

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

func (*AddRepoRequest) String added in v0.10.0 

func (m *AddRepoRequest) String() string

func (*AddRepoRequest) Unmarshal added in v0.10.0 

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

func (*AddRepoRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *AddRepoRequest) XXX_DiscardUnknown()

func (*AddRepoRequest) XXX_Marshal added in v0.10.0 

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

func (*AddRepoRequest) XXX_Merge added in v0.10.0 

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

func (*AddRepoRequest) XXX_Size added in v0.10.0 

func (m *AddRepoRequest) XXX_Size() int

func (*AddRepoRequest) XXX_Unmarshal added in v0.10.0 

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

type ChannelInfo 

type ChannelInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Target               string   `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChannelInfo) Descriptor 

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

func (*ChannelInfo) GetName 

func (m *ChannelInfo) GetName() string

func (*ChannelInfo) GetTarget 

func (m *ChannelInfo) GetTarget() string

func (*ChannelInfo) GetType 

func (m *ChannelInfo) GetType() string

func (*ChannelInfo) Marshal 

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

func (*ChannelInfo) MarshalTo 

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

func (*ChannelInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*ChannelInfo) ProtoMessage 

func (*ChannelInfo) ProtoMessage()

func (*ChannelInfo) Reset 

func (m *ChannelInfo) Reset()

func (*ChannelInfo) Size 

func (m *ChannelInfo) Size() (n int)

func (*ChannelInfo) String 

func (m *ChannelInfo) String() string

func (*ChannelInfo) Unmarshal 

func (m *ChannelInfo) Unmarshal(dAtA []byte) error

func (*ChannelInfo) XXX_DiscardUnknown 

func (m *ChannelInfo) XXX_DiscardUnknown()

func (*ChannelInfo) XXX_Marshal 

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

func (*ChannelInfo) XXX_Merge 

func (m *ChannelInfo) XXX_Merge(src proto.Message)

func (*ChannelInfo) XXX_Size 

func (m *ChannelInfo) XXX_Size() int

func (*ChannelInfo) XXX_Unmarshal 

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

type CleanupTasksReply 

type CleanupTasksReply struct {
	KilledTasks          []*ShortTaskInfo `protobuf:"bytes,1,rep,name=killedTasks,proto3" json:"killedTasks,omitempty"`
	RunningTasks         []*ShortTaskInfo `protobuf:"bytes,2,rep,name=runningTasks,proto3" json:"runningTasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CleanupTasksReply) Descriptor 

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

func (*CleanupTasksReply) GetKilledTasks 

func (m *CleanupTasksReply) GetKilledTasks() []*ShortTaskInfo

func (*CleanupTasksReply) GetRunningTasks 

func (m *CleanupTasksReply) GetRunningTasks() []*ShortTaskInfo

func (*CleanupTasksReply) Marshal 

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

func (*CleanupTasksReply) MarshalTo 

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

func (*CleanupTasksReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*CleanupTasksReply) ProtoMessage 

func (*CleanupTasksReply) ProtoMessage()

func (*CleanupTasksReply) Reset 

func (m *CleanupTasksReply) Reset()

func (*CleanupTasksReply) Size 

func (m *CleanupTasksReply) Size() (n int)

func (*CleanupTasksReply) String 

func (m *CleanupTasksReply) String() string

func (*CleanupTasksReply) Unmarshal 

func (m *CleanupTasksReply) Unmarshal(dAtA []byte) error

func (*CleanupTasksReply) XXX_DiscardUnknown 

func (m *CleanupTasksReply) XXX_DiscardUnknown()

func (*CleanupTasksReply) XXX_Marshal 

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

func (*CleanupTasksReply) XXX_Merge 

func (m *CleanupTasksReply) XXX_Merge(src proto.Message)

func (*CleanupTasksReply) XXX_Size 

func (m *CleanupTasksReply) XXX_Size() int

func (*CleanupTasksReply) XXX_Unmarshal 

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

type CleanupTasksRequest 

type CleanupTasksRequest struct {
	TaskIds              []string `protobuf:"bytes,1,rep,name=taskIds,proto3" json:"taskIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CleanupTasksRequest) Descriptor 

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

func (*CleanupTasksRequest) GetTaskIds 

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

func (*CleanupTasksRequest) Marshal 

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

func (*CleanupTasksRequest) MarshalTo 

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

func (*CleanupTasksRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*CleanupTasksRequest) ProtoMessage 

func (*CleanupTasksRequest) ProtoMessage()

func (*CleanupTasksRequest) Reset 

func (m *CleanupTasksRequest) Reset()

func (*CleanupTasksRequest) Size 

func (m *CleanupTasksRequest) Size() (n int)

func (*CleanupTasksRequest) String 

func (m *CleanupTasksRequest) String() string

func (*CleanupTasksRequest) Unmarshal 

func (m *CleanupTasksRequest) Unmarshal(dAtA []byte) error

func (*CleanupTasksRequest) XXX_DiscardUnknown 

func (m *CleanupTasksRequest) XXX_DiscardUnknown()

func (*CleanupTasksRequest) XXX_Marshal 

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

func (*CleanupTasksRequest) XXX_Merge 

func (m *CleanupTasksRequest) XXX_Merge(src proto.Message)

func (*CleanupTasksRequest) XXX_Size 

func (m *CleanupTasksRequest) XXX_Size() int

func (*CleanupTasksRequest) XXX_Unmarshal 

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

type CommandInfo 

type CommandInfo struct {
	Env                  []string `protobuf:"bytes,1,rep,name=env,proto3" json:"env,omitempty"`
	Shell                bool     `protobuf:"varint,2,opt,name=shell,proto3" json:"shell,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Arguments            []string `protobuf:"bytes,4,rep,name=arguments,proto3" json:"arguments,omitempty"`
	User                 string   `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CommandInfo) Descriptor 

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

func (*CommandInfo) GetArguments 

func (m *CommandInfo) GetArguments() []string

func (*CommandInfo) GetEnv 

func (m *CommandInfo) GetEnv() []string

func (*CommandInfo) GetShell 

func (m *CommandInfo) GetShell() bool

func (*CommandInfo) GetUser 

func (m *CommandInfo) GetUser() string

func (*CommandInfo) GetValue 

func (m *CommandInfo) GetValue() string

func (*CommandInfo) Marshal 

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

func (*CommandInfo) MarshalTo 

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

func (*CommandInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset 

func (m *CommandInfo) Reset()

func (*CommandInfo) Size 

func (m *CommandInfo) Size() (n int)

func (*CommandInfo) String 

func (m *CommandInfo) String() string

func (*CommandInfo) Unmarshal 

func (m *CommandInfo) Unmarshal(dAtA []byte) error

func (*CommandInfo) XXX_DiscardUnknown 

func (m *CommandInfo) XXX_DiscardUnknown()

func (*CommandInfo) XXX_Marshal 

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

func (*CommandInfo) XXX_Merge 

func (m *CommandInfo) XXX_Merge(src proto.Message)

func (*CommandInfo) XXX_Size 

func (m *CommandInfo) XXX_Size() int

func (*CommandInfo) XXX_Unmarshal 

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

type ControlClient 

type ControlClient interface {
	TrackStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Control_TrackStatusClient, error)
	GetFrameworkInfo(ctx context.Context, in *GetFrameworkInfoRequest, opts ...grpc.CallOption) (*GetFrameworkInfoReply, error)
	Teardown(ctx context.Context, in *TeardownRequest, opts ...grpc.CallOption) (*TeardownReply, error)
	GetEnvironments(ctx context.Context, in *GetEnvironmentsRequest, opts ...grpc.CallOption) (*GetEnvironmentsReply, error)
	NewEnvironment(ctx context.Context, in *NewEnvironmentRequest, opts ...grpc.CallOption) (*NewEnvironmentReply, error)
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*GetEnvironmentReply, error)
	ControlEnvironment(ctx context.Context, in *ControlEnvironmentRequest, opts ...grpc.CallOption) (*ControlEnvironmentReply, error)
	ModifyEnvironment(ctx context.Context, in *ModifyEnvironmentRequest, opts ...grpc.CallOption) (*ModifyEnvironmentReply, error)
	DestroyEnvironment(ctx context.Context, in *DestroyEnvironmentRequest, opts ...grpc.CallOption) (*DestroyEnvironmentReply, error)
	GetTasks(ctx context.Context, in *GetTasksRequest, opts ...grpc.CallOption) (*GetTasksReply, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskReply, error)
	CleanupTasks(ctx context.Context, in *CleanupTasksRequest, opts ...grpc.CallOption) (*CleanupTasksReply, error)
	GetRoles(ctx context.Context, in *GetRolesRequest, opts ...grpc.CallOption) (*GetRolesReply, error)
	GetWorkflowTemplates(ctx context.Context, in *GetWorkflowTemplatesRequest, opts ...grpc.CallOption) (*GetWorkflowTemplatesReply, error)
	ListRepos(ctx context.Context, in *ListReposRequest, opts ...grpc.CallOption) (*ListReposReply, error)
	AddRepo(ctx context.Context, in *AddRepoRequest, opts ...grpc.CallOption) (*AddRepoReply, error)
	RemoveRepo(ctx context.Context, in *RemoveRepoRequest, opts ...grpc.CallOption) (*RemoveRepoReply, error)
	RefreshRepos(ctx context.Context, in *RefreshReposRequest, opts ...grpc.CallOption) (*Empty, error)
	SetDefaultRepo(ctx context.Context, in *SetDefaultRepoRequest, opts ...grpc.CallOption) (*Empty, error)
	SetGlobalDefaultRevision(ctx context.Context, in *SetGlobalDefaultRevisionRequest, opts ...grpc.CallOption) (*Empty, error)
	SetRepoDefaultRevision(ctx context.Context, in *SetRepoDefaultRevisionRequest, opts ...grpc.CallOption) (*SetRepoDefaultRevisionReply, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Control_SubscribeClient, error)
}

ControlClient is the client API for Control service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControlClient 

func NewControlClient(cc *grpc.ClientConn) ControlClient

type ControlEnvironmentReply 

type ControlEnvironmentReply struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	CurrentRunNumber     uint32   `protobuf:"varint,3,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlEnvironmentReply) Descriptor 

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

func (*ControlEnvironmentReply) GetCurrentRunNumber added in v0.8.0 

func (m *ControlEnvironmentReply) GetCurrentRunNumber() uint32

func (*ControlEnvironmentReply) GetId 

func (m *ControlEnvironmentReply) GetId() string

func (*ControlEnvironmentReply) GetState 

func (m *ControlEnvironmentReply) GetState() string

func (*ControlEnvironmentReply) Marshal 

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

func (*ControlEnvironmentReply) MarshalTo 

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

func (*ControlEnvironmentReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*ControlEnvironmentReply) ProtoMessage 

func (*ControlEnvironmentReply) ProtoMessage()

func (*ControlEnvironmentReply) Reset 

func (m *ControlEnvironmentReply) Reset()

func (*ControlEnvironmentReply) Size 

func (m *ControlEnvironmentReply) Size() (n int)

func (*ControlEnvironmentReply) String 

func (m *ControlEnvironmentReply) String() string

func (*ControlEnvironmentReply) Unmarshal 

func (m *ControlEnvironmentReply) Unmarshal(dAtA []byte) error

func (*ControlEnvironmentReply) XXX_DiscardUnknown 

func (m *ControlEnvironmentReply) XXX_DiscardUnknown()

func (*ControlEnvironmentReply) XXX_Marshal 

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

func (*ControlEnvironmentReply) XXX_Merge 

func (m *ControlEnvironmentReply) XXX_Merge(src proto.Message)

func (*ControlEnvironmentReply) XXX_Size 

func (m *ControlEnvironmentReply) XXX_Size() int

func (*ControlEnvironmentReply) XXX_Unmarshal 

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

type ControlEnvironmentRequest 

type ControlEnvironmentRequest struct {
	Id                   string                           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 ControlEnvironmentRequest_Optype `protobuf:"varint,2,opt,name=type,proto3,enum=o2control.ControlEnvironmentRequest_Optype" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*ControlEnvironmentRequest) Descriptor 

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

func (*ControlEnvironmentRequest) GetId 

func (m *ControlEnvironmentRequest) GetId() string

func (*ControlEnvironmentRequest) GetType 

func (m *ControlEnvironmentRequest) GetType() ControlEnvironmentRequest_Optype

func (*ControlEnvironmentRequest) Marshal 

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

func (*ControlEnvironmentRequest) MarshalTo 

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

func (*ControlEnvironmentRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*ControlEnvironmentRequest) ProtoMessage 

func (*ControlEnvironmentRequest) ProtoMessage()

func (*ControlEnvironmentRequest) Reset 

func (m *ControlEnvironmentRequest) Reset()

func (*ControlEnvironmentRequest) Size 

func (m *ControlEnvironmentRequest) Size() (n int)

func (*ControlEnvironmentRequest) String 

func (m *ControlEnvironmentRequest) String() string

func (*ControlEnvironmentRequest) Unmarshal 

func (m *ControlEnvironmentRequest) Unmarshal(dAtA []byte) error

func (*ControlEnvironmentRequest) XXX_DiscardUnknown 

func (m *ControlEnvironmentRequest) XXX_DiscardUnknown()

func (*ControlEnvironmentRequest) XXX_Marshal 

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

func (*ControlEnvironmentRequest) XXX_Merge 

func (m *ControlEnvironmentRequest) XXX_Merge(src proto.Message)

func (*ControlEnvironmentRequest) XXX_Size 

func (m *ControlEnvironmentRequest) XXX_Size() int

func (*ControlEnvironmentRequest) XXX_Unmarshal 

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

type ControlEnvironmentRequest_Optype 

type ControlEnvironmentRequest_Optype int32
const (
	ControlEnvironmentRequest_NOOP           ControlEnvironmentRequest_Optype = 0
	ControlEnvironmentRequest_START_ACTIVITY ControlEnvironmentRequest_Optype = 1
	ControlEnvironmentRequest_STOP_ACTIVITY  ControlEnvironmentRequest_Optype = 2
	ControlEnvironmentRequest_CONFIGURE      ControlEnvironmentRequest_Optype = 3
	ControlEnvironmentRequest_RESET          ControlEnvironmentRequest_Optype = 4
	ControlEnvironmentRequest_GO_ERROR       ControlEnvironmentRequest_Optype = 5
)

func (ControlEnvironmentRequest_Optype) EnumDescriptor 

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

func (ControlEnvironmentRequest_Optype) String 

func (x ControlEnvironmentRequest_Optype) String() string

type ControlServer 

type ControlServer interface {
	TrackStatus(*StatusRequest, Control_TrackStatusServer) error
	GetFrameworkInfo(context.Context, *GetFrameworkInfoRequest) (*GetFrameworkInfoReply, error)
	Teardown(context.Context, *TeardownRequest) (*TeardownReply, error)
	GetEnvironments(context.Context, *GetEnvironmentsRequest) (*GetEnvironmentsReply, error)
	NewEnvironment(context.Context, *NewEnvironmentRequest) (*NewEnvironmentReply, error)
	GetEnvironment(context.Context, *GetEnvironmentRequest) (*GetEnvironmentReply, error)
	ControlEnvironment(context.Context, *ControlEnvironmentRequest) (*ControlEnvironmentReply, error)
	ModifyEnvironment(context.Context, *ModifyEnvironmentRequest) (*ModifyEnvironmentReply, error)
	DestroyEnvironment(context.Context, *DestroyEnvironmentRequest) (*DestroyEnvironmentReply, error)
	GetTasks(context.Context, *GetTasksRequest) (*GetTasksReply, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskReply, error)
	CleanupTasks(context.Context, *CleanupTasksRequest) (*CleanupTasksReply, error)
	GetRoles(context.Context, *GetRolesRequest) (*GetRolesReply, error)
	GetWorkflowTemplates(context.Context, *GetWorkflowTemplatesRequest) (*GetWorkflowTemplatesReply, error)
	ListRepos(context.Context, *ListReposRequest) (*ListReposReply, error)
	AddRepo(context.Context, *AddRepoRequest) (*AddRepoReply, error)
	RemoveRepo(context.Context, *RemoveRepoRequest) (*RemoveRepoReply, error)
	RefreshRepos(context.Context, *RefreshReposRequest) (*Empty, error)
	SetDefaultRepo(context.Context, *SetDefaultRepoRequest) (*Empty, error)
	SetGlobalDefaultRevision(context.Context, *SetGlobalDefaultRevisionRequest) (*Empty, error)
	SetRepoDefaultRevision(context.Context, *SetRepoDefaultRevisionRequest) (*SetRepoDefaultRevisionReply, error)
	Subscribe(*SubscribeRequest, Control_SubscribeServer) error
}

ControlServer is the server API for Control service.

type Control_SubscribeClient added in v0.14.4 

type Control_SubscribeClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Control_SubscribeServer added in v0.14.4 

type Control_SubscribeServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Control_TrackStatusClient 

type Control_TrackStatusClient interface {
	Recv() (*StatusReply, error)
	grpc.ClientStream
}

type Control_TrackStatusServer 

type Control_TrackStatusServer interface {
	Send(*StatusReply) error
	grpc.ServerStream
}

type DestroyEnvironmentReply 

type DestroyEnvironmentReply struct {
	CleanupTasksReply    *CleanupTasksReply `protobuf:"bytes,1,opt,name=cleanupTasksReply,proto3" json:"cleanupTasksReply,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*DestroyEnvironmentReply) Descriptor 

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

func (*DestroyEnvironmentReply) GetCleanupTasksReply added in v0.9.1 

func (m *DestroyEnvironmentReply) GetCleanupTasksReply() *CleanupTasksReply

func (*DestroyEnvironmentReply) Marshal 

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

func (*DestroyEnvironmentReply) MarshalTo 

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

func (*DestroyEnvironmentReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*DestroyEnvironmentReply) ProtoMessage 

func (*DestroyEnvironmentReply) ProtoMessage()

func (*DestroyEnvironmentReply) Reset 

func (m *DestroyEnvironmentReply) Reset()

func (*DestroyEnvironmentReply) Size 

func (m *DestroyEnvironmentReply) Size() (n int)

func (*DestroyEnvironmentReply) String 

func (m *DestroyEnvironmentReply) String() string

func (*DestroyEnvironmentReply) Unmarshal 

func (m *DestroyEnvironmentReply) Unmarshal(dAtA []byte) error

func (*DestroyEnvironmentReply) XXX_DiscardUnknown 

func (m *DestroyEnvironmentReply) XXX_DiscardUnknown()

func (*DestroyEnvironmentReply) XXX_Marshal 

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

func (*DestroyEnvironmentReply) XXX_Merge 

func (m *DestroyEnvironmentReply) XXX_Merge(src proto.Message)

func (*DestroyEnvironmentReply) XXX_Size 

func (m *DestroyEnvironmentReply) XXX_Size() int

func (*DestroyEnvironmentReply) XXX_Unmarshal 

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

type DestroyEnvironmentRequest 

type DestroyEnvironmentRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	KeepTasks            bool     `protobuf:"varint,2,opt,name=keepTasks,proto3" json:"keepTasks,omitempty"`
	AllowInRunningState  bool     `protobuf:"varint,3,opt,name=allowInRunningState,proto3" json:"allowInRunningState,omitempty"`
	Force                bool     `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DestroyEnvironmentRequest) Descriptor 

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

func (*DestroyEnvironmentRequest) GetAllowInRunningState added in v0.12.90 

func (m *DestroyEnvironmentRequest) GetAllowInRunningState() bool

func (*DestroyEnvironmentRequest) GetForce added in v0.14.3 

func (m *DestroyEnvironmentRequest) GetForce() bool

func (*DestroyEnvironmentRequest) GetId 

func (m *DestroyEnvironmentRequest) GetId() string

func (*DestroyEnvironmentRequest) GetKeepTasks added in v0.9.1 

func (m *DestroyEnvironmentRequest) GetKeepTasks() bool

func (*DestroyEnvironmentRequest) Marshal 

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

func (*DestroyEnvironmentRequest) MarshalTo 

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

func (*DestroyEnvironmentRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*DestroyEnvironmentRequest) ProtoMessage 

func (*DestroyEnvironmentRequest) ProtoMessage()

func (*DestroyEnvironmentRequest) Reset 

func (m *DestroyEnvironmentRequest) Reset()

func (*DestroyEnvironmentRequest) Size 

func (m *DestroyEnvironmentRequest) Size() (n int)

func (*DestroyEnvironmentRequest) String 

func (m *DestroyEnvironmentRequest) String() string

func (*DestroyEnvironmentRequest) Unmarshal 

func (m *DestroyEnvironmentRequest) Unmarshal(dAtA []byte) error

func (*DestroyEnvironmentRequest) XXX_DiscardUnknown 

func (m *DestroyEnvironmentRequest) XXX_DiscardUnknown()

func (*DestroyEnvironmentRequest) XXX_Marshal 

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

func (*DestroyEnvironmentRequest) XXX_Merge 

func (m *DestroyEnvironmentRequest) XXX_Merge(src proto.Message)

func (*DestroyEnvironmentRequest) XXX_Size 

func (m *DestroyEnvironmentRequest) XXX_Size() int

func (*DestroyEnvironmentRequest) XXX_Unmarshal 

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

type Empty added in v0.11.1 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor added in v0.11.1 

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

func (*Empty) Marshal added in v0.11.1 

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

func (*Empty) MarshalTo added in v0.11.1 

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

func (*Empty) MarshalToSizedBuffer added in v0.11.1 

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

func (*Empty) ProtoMessage added in v0.11.1 

func (*Empty) ProtoMessage()

func (*Empty) Reset added in v0.11.1 

func (m *Empty) Reset()

func (*Empty) Size added in v0.11.1 

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

func (*Empty) String added in v0.11.1 

func (m *Empty) String() string

func (*Empty) Unmarshal added in v0.11.1 

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

func (*Empty) XXX_DiscardUnknown added in v0.11.1 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal added in v0.11.1 

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

func (*Empty) XXX_Merge added in v0.11.1 

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

func (*Empty) XXX_Size added in v0.11.1 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal added in v0.11.1 

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

type EnvironmentInfo 

type EnvironmentInfo struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedWhen          string            `protobuf:"bytes,2,opt,name=createdWhen,proto3" json:"createdWhen,omitempty"`
	State                string            `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Tasks                []*ShortTaskInfo  `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"`
	RootRole             string            `protobuf:"bytes,5,opt,name=rootRole,proto3" json:"rootRole,omitempty"`
	CurrentRunNumber     uint32            `protobuf:"varint,6,opt,name=currentRunNumber,proto3" json:"currentRunNumber,omitempty"`
	Defaults             map[string]string `` /* 157-byte string literal not displayed */
	Vars                 map[string]string `` /* 149-byte string literal not displayed */
	UserVars             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EnvironmentInfo) Descriptor 

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

func (*EnvironmentInfo) GetCreatedWhen 

func (m *EnvironmentInfo) GetCreatedWhen() string

func (*EnvironmentInfo) GetCurrentRunNumber added in v0.8.0 

func (m *EnvironmentInfo) GetCurrentRunNumber() uint32

func (*EnvironmentInfo) GetDefaults added in v0.12.90 

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

func (*EnvironmentInfo) GetId 

func (m *EnvironmentInfo) GetId() string

func (*EnvironmentInfo) GetRootRole 

func (m *EnvironmentInfo) GetRootRole() string

func (*EnvironmentInfo) GetState 

func (m *EnvironmentInfo) GetState() string

func (*EnvironmentInfo) GetTasks 

func (m *EnvironmentInfo) GetTasks() []*ShortTaskInfo

func (*EnvironmentInfo) GetUserVars added in v0.12.90 

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

func (*EnvironmentInfo) GetVars added in v0.12.90 

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

func (*EnvironmentInfo) Marshal 

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

func (*EnvironmentInfo) MarshalTo 

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

func (*EnvironmentInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*EnvironmentInfo) ProtoMessage 

func (*EnvironmentInfo) ProtoMessage()

func (*EnvironmentInfo) Reset 

func (m *EnvironmentInfo) Reset()

func (*EnvironmentInfo) Size 

func (m *EnvironmentInfo) Size() (n int)

func (*EnvironmentInfo) String 

func (m *EnvironmentInfo) String() string

func (*EnvironmentInfo) Unmarshal 

func (m *EnvironmentInfo) Unmarshal(dAtA []byte) error

func (*EnvironmentInfo) XXX_DiscardUnknown 

func (m *EnvironmentInfo) XXX_DiscardUnknown()

func (*EnvironmentInfo) XXX_Marshal 

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

func (*EnvironmentInfo) XXX_Merge 

func (m *EnvironmentInfo) XXX_Merge(src proto.Message)

func (*EnvironmentInfo) XXX_Size 

func (m *EnvironmentInfo) XXX_Size() int

func (*EnvironmentInfo) XXX_Unmarshal 

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

type EnvironmentOperation 

type EnvironmentOperation struct {
	Type                 EnvironmentOperation_Optype `protobuf:"varint,1,opt,name=type,proto3,enum=o2control.EnvironmentOperation_Optype" json:"type,omitempty"`
	RoleName             string                      `protobuf:"bytes,2,opt,name=roleName,proto3" json:"roleName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*EnvironmentOperation) Descriptor 

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

func (*EnvironmentOperation) GetRoleName 

func (m *EnvironmentOperation) GetRoleName() string

func (*EnvironmentOperation) GetType 

func (m *EnvironmentOperation) GetType() EnvironmentOperation_Optype

func (*EnvironmentOperation) Marshal 

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

func (*EnvironmentOperation) MarshalTo 

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

func (*EnvironmentOperation) MarshalToSizedBuffer added in v0.11.0 

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

func (*EnvironmentOperation) ProtoMessage 

func (*EnvironmentOperation) ProtoMessage()

func (*EnvironmentOperation) Reset 

func (m *EnvironmentOperation) Reset()

func (*EnvironmentOperation) Size 

func (m *EnvironmentOperation) Size() (n int)

func (*EnvironmentOperation) String 

func (m *EnvironmentOperation) String() string

func (*EnvironmentOperation) Unmarshal 

func (m *EnvironmentOperation) Unmarshal(dAtA []byte) error

func (*EnvironmentOperation) XXX_DiscardUnknown 

func (m *EnvironmentOperation) XXX_DiscardUnknown()

func (*EnvironmentOperation) XXX_Marshal 

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

func (*EnvironmentOperation) XXX_Merge 

func (m *EnvironmentOperation) XXX_Merge(src proto.Message)

func (*EnvironmentOperation) XXX_Size 

func (m *EnvironmentOperation) XXX_Size() int

func (*EnvironmentOperation) XXX_Unmarshal 

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

type EnvironmentOperation_Optype 

type EnvironmentOperation_Optype int32
const (
	EnvironmentOperation_NOOP        EnvironmentOperation_Optype = 0
	EnvironmentOperation_REMOVE_ROLE EnvironmentOperation_Optype = 3
	EnvironmentOperation_ADD_ROLE    EnvironmentOperation_Optype = 4
)

func (EnvironmentOperation_Optype) EnumDescriptor 

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

func (EnvironmentOperation_Optype) String 

func (x EnvironmentOperation_Optype) String() string

type Ev_EnvironmentCreated added in v0.14.4 

type Ev_EnvironmentCreated struct {
	Environment          *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Ev_EnvironmentCreated) Descriptor added in v0.14.4 

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

func (*Ev_EnvironmentCreated) GetEnvironment added in v0.14.4 

func (m *Ev_EnvironmentCreated) GetEnvironment() *EnvironmentInfo

func (*Ev_EnvironmentCreated) Marshal added in v0.14.4 

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

func (*Ev_EnvironmentCreated) MarshalTo added in v0.14.4 

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

func (*Ev_EnvironmentCreated) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_EnvironmentCreated) ProtoMessage added in v0.14.4 

func (*Ev_EnvironmentCreated) ProtoMessage()

func (*Ev_EnvironmentCreated) Reset added in v0.14.4 

func (m *Ev_EnvironmentCreated) Reset()

func (*Ev_EnvironmentCreated) Size added in v0.14.4 

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

func (*Ev_EnvironmentCreated) String added in v0.14.4 

func (m *Ev_EnvironmentCreated) String() string

func (*Ev_EnvironmentCreated) Unmarshal added in v0.14.4 

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

func (*Ev_EnvironmentCreated) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_EnvironmentCreated) XXX_DiscardUnknown()

func (*Ev_EnvironmentCreated) XXX_Marshal added in v0.14.4 

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

func (*Ev_EnvironmentCreated) XXX_Merge added in v0.14.4 

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

func (*Ev_EnvironmentCreated) XXX_Size added in v0.14.4 

func (m *Ev_EnvironmentCreated) XXX_Size() int

func (*Ev_EnvironmentCreated) XXX_Unmarshal added in v0.14.4 

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

type Ev_EnvironmentDestroyed added in v0.14.4 

type Ev_EnvironmentDestroyed struct {
	CleanupTasksReply    *CleanupTasksReply `protobuf:"bytes,1,opt,name=cleanupTasksReply,proto3" json:"cleanupTasksReply,omitempty"`
	Environmentid        string             `protobuf:"bytes,2,opt,name=environmentid,proto3" json:"environmentid,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Ev_EnvironmentDestroyed) Descriptor added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) GetCleanupTasksReply added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) GetCleanupTasksReply() *CleanupTasksReply

func (*Ev_EnvironmentDestroyed) GetEnvironmentid added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) GetEnvironmentid() string

func (*Ev_EnvironmentDestroyed) Marshal added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) MarshalTo added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) ProtoMessage added in v0.14.4 

func (*Ev_EnvironmentDestroyed) ProtoMessage()

func (*Ev_EnvironmentDestroyed) Reset added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) Reset()

func (*Ev_EnvironmentDestroyed) Size added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) String added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) String() string

func (*Ev_EnvironmentDestroyed) Unmarshal added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) XXX_DiscardUnknown()

func (*Ev_EnvironmentDestroyed) XXX_Marshal added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) XXX_Merge added in v0.14.4 

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

func (*Ev_EnvironmentDestroyed) XXX_Size added in v0.14.4 

func (m *Ev_EnvironmentDestroyed) XXX_Size() int

func (*Ev_EnvironmentDestroyed) XXX_Unmarshal added in v0.14.4 

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

type Ev_EnvironmentError added in v0.14.4 

type Ev_EnvironmentError struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_EnvironmentError) Descriptor added in v0.14.4 

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

func (*Ev_EnvironmentError) Marshal added in v0.14.4 

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

func (*Ev_EnvironmentError) MarshalTo added in v0.14.4 

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

func (*Ev_EnvironmentError) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_EnvironmentError) ProtoMessage added in v0.14.4 

func (*Ev_EnvironmentError) ProtoMessage()

func (*Ev_EnvironmentError) Reset added in v0.14.4 

func (m *Ev_EnvironmentError) Reset()

func (*Ev_EnvironmentError) Size added in v0.14.4 

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

func (*Ev_EnvironmentError) String added in v0.14.4 

func (m *Ev_EnvironmentError) String() string

func (*Ev_EnvironmentError) Unmarshal added in v0.14.4 

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

func (*Ev_EnvironmentError) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_EnvironmentError) XXX_DiscardUnknown()

func (*Ev_EnvironmentError) XXX_Marshal added in v0.14.4 

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

func (*Ev_EnvironmentError) XXX_Merge added in v0.14.4 

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

func (*Ev_EnvironmentError) XXX_Size added in v0.14.4 

func (m *Ev_EnvironmentError) XXX_Size() int

func (*Ev_EnvironmentError) XXX_Unmarshal added in v0.14.4 

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

type Ev_EnvironmentStateChanged added in v0.14.4 

type Ev_EnvironmentStateChanged struct {
	Event                string   `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Destination          string   `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_EnvironmentStateChanged) Descriptor added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) GetDestination added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) GetDestination() string

func (*Ev_EnvironmentStateChanged) GetEvent added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) GetEvent() string

func (*Ev_EnvironmentStateChanged) GetSource added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) GetSource() string

func (*Ev_EnvironmentStateChanged) Marshal added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) MarshalTo added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) ProtoMessage added in v0.14.4 

func (*Ev_EnvironmentStateChanged) ProtoMessage()

func (*Ev_EnvironmentStateChanged) Reset added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) Reset()

func (*Ev_EnvironmentStateChanged) Size added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) String added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) String() string

func (*Ev_EnvironmentStateChanged) Unmarshal added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) XXX_DiscardUnknown()

func (*Ev_EnvironmentStateChanged) XXX_Marshal added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) XXX_Merge added in v0.14.4 

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

func (*Ev_EnvironmentStateChanged) XXX_Size added in v0.14.4 

func (m *Ev_EnvironmentStateChanged) XXX_Size() int

func (*Ev_EnvironmentStateChanged) XXX_Unmarshal added in v0.14.4 

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

type Ev_KillTasksMesos added in v0.14.4 

type Ev_KillTasksMesos struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_KillTasksMesos) Descriptor added in v0.14.4 

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

func (*Ev_KillTasksMesos) Marshal added in v0.14.4 

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

func (*Ev_KillTasksMesos) MarshalTo added in v0.14.4 

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

func (*Ev_KillTasksMesos) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_KillTasksMesos) ProtoMessage added in v0.14.4 

func (*Ev_KillTasksMesos) ProtoMessage()

func (*Ev_KillTasksMesos) Reset added in v0.14.4 

func (m *Ev_KillTasksMesos) Reset()

func (*Ev_KillTasksMesos) Size added in v0.14.4 

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

func (*Ev_KillTasksMesos) String added in v0.14.4 

func (m *Ev_KillTasksMesos) String() string

func (*Ev_KillTasksMesos) Unmarshal added in v0.14.4 

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

func (*Ev_KillTasksMesos) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_KillTasksMesos) XXX_DiscardUnknown()

func (*Ev_KillTasksMesos) XXX_Marshal added in v0.14.4 

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

func (*Ev_KillTasksMesos) XXX_Merge added in v0.14.4 

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

func (*Ev_KillTasksMesos) XXX_Size added in v0.14.4 

func (m *Ev_KillTasksMesos) XXX_Size() int

func (*Ev_KillTasksMesos) XXX_Unmarshal added in v0.14.4 

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

type Ev_MesosTaskCreated added in v0.14.4 

type Ev_MesosTaskCreated struct {
	Taskresources        string   `protobuf:"bytes,1,opt,name=taskresources,proto3" json:"taskresources,omitempty"`
	ExecutorResources    string   `protobuf:"bytes,2,opt,name=executorResources,proto3" json:"executorResources,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_MesosTaskCreated) Descriptor added in v0.14.4 

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

func (*Ev_MesosTaskCreated) GetExecutorResources added in v0.14.4 

func (m *Ev_MesosTaskCreated) GetExecutorResources() string

func (*Ev_MesosTaskCreated) GetTaskresources added in v0.14.4 

func (m *Ev_MesosTaskCreated) GetTaskresources() string

func (*Ev_MesosTaskCreated) Marshal added in v0.14.4 

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

func (*Ev_MesosTaskCreated) MarshalTo added in v0.14.4 

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

func (*Ev_MesosTaskCreated) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_MesosTaskCreated) ProtoMessage added in v0.14.4 

func (*Ev_MesosTaskCreated) ProtoMessage()

func (*Ev_MesosTaskCreated) Reset added in v0.14.4 

func (m *Ev_MesosTaskCreated) Reset()

func (*Ev_MesosTaskCreated) Size added in v0.14.4 

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

func (*Ev_MesosTaskCreated) String added in v0.14.4 

func (m *Ev_MesosTaskCreated) String() string

func (*Ev_MesosTaskCreated) Unmarshal added in v0.14.4 

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

func (*Ev_MesosTaskCreated) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_MesosTaskCreated) XXX_DiscardUnknown()

func (*Ev_MesosTaskCreated) XXX_Marshal added in v0.14.4 

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

func (*Ev_MesosTaskCreated) XXX_Merge added in v0.14.4 

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

func (*Ev_MesosTaskCreated) XXX_Size added in v0.14.4 

func (m *Ev_MesosTaskCreated) XXX_Size() int

func (*Ev_MesosTaskCreated) XXX_Unmarshal added in v0.14.4 

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

type Ev_TaskLaunched added in v0.14.4 

type Ev_TaskLaunched struct {
	Taskid               string   `protobuf:"bytes,1,opt,name=taskid,proto3" json:"taskid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_TaskLaunched) Descriptor added in v0.14.4 

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

func (*Ev_TaskLaunched) GetTaskid added in v0.14.4 

func (m *Ev_TaskLaunched) GetTaskid() string

func (*Ev_TaskLaunched) Marshal added in v0.14.4 

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

func (*Ev_TaskLaunched) MarshalTo added in v0.14.4 

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

func (*Ev_TaskLaunched) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_TaskLaunched) ProtoMessage added in v0.14.4 

func (*Ev_TaskLaunched) ProtoMessage()

func (*Ev_TaskLaunched) Reset added in v0.14.4 

func (m *Ev_TaskLaunched) Reset()

func (*Ev_TaskLaunched) Size added in v0.14.4 

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

func (*Ev_TaskLaunched) String added in v0.14.4 

func (m *Ev_TaskLaunched) String() string

func (*Ev_TaskLaunched) Unmarshal added in v0.14.4 

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

func (*Ev_TaskLaunched) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_TaskLaunched) XXX_DiscardUnknown()

func (*Ev_TaskLaunched) XXX_Marshal added in v0.14.4 

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

func (*Ev_TaskLaunched) XXX_Merge added in v0.14.4 

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

func (*Ev_TaskLaunched) XXX_Size added in v0.14.4 

func (m *Ev_TaskLaunched) XXX_Size() int

func (*Ev_TaskLaunched) XXX_Unmarshal added in v0.14.4 

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

type Ev_TaskStateChanged added in v0.14.4 

type Ev_TaskStateChanged struct {
	Taskid               string   `protobuf:"bytes,1,opt,name=taskid,proto3" json:"taskid,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_TaskStateChanged) Descriptor added in v0.14.4 

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

func (*Ev_TaskStateChanged) GetState added in v0.14.4 

func (m *Ev_TaskStateChanged) GetState() string

func (*Ev_TaskStateChanged) GetTaskid added in v0.14.4 

func (m *Ev_TaskStateChanged) GetTaskid() string

func (*Ev_TaskStateChanged) Marshal added in v0.14.4 

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

func (*Ev_TaskStateChanged) MarshalTo added in v0.14.4 

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

func (*Ev_TaskStateChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_TaskStateChanged) ProtoMessage added in v0.14.4 

func (*Ev_TaskStateChanged) ProtoMessage()

func (*Ev_TaskStateChanged) Reset added in v0.14.4 

func (m *Ev_TaskStateChanged) Reset()

func (*Ev_TaskStateChanged) Size added in v0.14.4 

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

func (*Ev_TaskStateChanged) String added in v0.14.4 

func (m *Ev_TaskStateChanged) String() string

func (*Ev_TaskStateChanged) Unmarshal added in v0.14.4 

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

func (*Ev_TaskStateChanged) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_TaskStateChanged) XXX_DiscardUnknown()

func (*Ev_TaskStateChanged) XXX_Marshal added in v0.14.4 

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

func (*Ev_TaskStateChanged) XXX_Merge added in v0.14.4 

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

func (*Ev_TaskStateChanged) XXX_Size added in v0.14.4 

func (m *Ev_TaskStateChanged) XXX_Size() int

func (*Ev_TaskStateChanged) XXX_Unmarshal added in v0.14.4 

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

type Ev_TaskStatusChanged added in v0.14.4 

type Ev_TaskStatusChanged struct {
	Taskid               string   `protobuf:"bytes,1,opt,name=taskid,proto3" json:"taskid,omitempty"`
	Status               string   `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ev_TaskStatusChanged) Descriptor added in v0.14.4 

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

func (*Ev_TaskStatusChanged) GetStatus added in v0.14.4 

func (m *Ev_TaskStatusChanged) GetStatus() string

func (*Ev_TaskStatusChanged) GetTaskid added in v0.14.4 

func (m *Ev_TaskStatusChanged) GetTaskid() string

func (*Ev_TaskStatusChanged) Marshal added in v0.14.4 

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

func (*Ev_TaskStatusChanged) MarshalTo added in v0.14.4 

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

func (*Ev_TaskStatusChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Ev_TaskStatusChanged) ProtoMessage added in v0.14.4 

func (*Ev_TaskStatusChanged) ProtoMessage()

func (*Ev_TaskStatusChanged) Reset added in v0.14.4 

func (m *Ev_TaskStatusChanged) Reset()

func (*Ev_TaskStatusChanged) Size added in v0.14.4 

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

func (*Ev_TaskStatusChanged) String added in v0.14.4 

func (m *Ev_TaskStatusChanged) String() string

func (*Ev_TaskStatusChanged) Unmarshal added in v0.14.4 

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

func (*Ev_TaskStatusChanged) XXX_DiscardUnknown added in v0.14.4 

func (m *Ev_TaskStatusChanged) XXX_DiscardUnknown()

func (*Ev_TaskStatusChanged) XXX_Marshal added in v0.14.4 

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

func (*Ev_TaskStatusChanged) XXX_Merge added in v0.14.4 

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

func (*Ev_TaskStatusChanged) XXX_Size added in v0.14.4 

func (m *Ev_TaskStatusChanged) XXX_Size() int

func (*Ev_TaskStatusChanged) XXX_Unmarshal added in v0.14.4 

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

type Event added in v0.14.4 

type Event struct {
	Timestamp string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*Event_EnvironmentStateChanged
	//	*Event_EnvironmentCreated
	//	*Event_TaskStateChanged
	//	*Event_TaskStatusChanged
	//	*Event_Tasklaunched
	//	*Event_MesosTaskcreated
	//	*Event_EnvironmentDestroyed
	//	*Event_EnvironmentError
	//	*Event_KilltasksMesos
	Payload              isEvent_Payload `protobuf_oneof:"Payload"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewEnvironmentCreatedEvent added in v0.14.4 

func NewEnvironmentCreatedEvent(ei *EnvironmentInfo) *Event

func NewEnvironmentDestroyedEvent added in v0.14.4 

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

func NewEnvironmentErrorEvent added in v0.14.4 

func NewEnvironmentErrorEvent() *Event

func NewEnvironmentStateEvent added in v0.14.4 

func NewEnvironmentStateEvent(cmdb []byte) *Event

func NewEventMesosTaskCreated added in v0.14.4 

func NewEventMesosTaskCreated(resourcesRequest, executorResources string) *Event

func NewEventTaskLaunch added in v0.14.4 

func NewEventTaskLaunch(taskid string) *Event

func NewEventTaskState added in v0.14.4 

func NewEventTaskState(taskid, state string) *Event

func NewEventTaskStatus added in v0.14.4 

func NewEventTaskStatus(status *mesos.TaskStatus) *Event

func NewKillTasksEvent added in v0.14.4 

func NewKillTasksEvent() *Event

func WrapEvent added in v0.14.4 

func WrapEvent(ce isEvent_Payload) *Event

func (*Event) Descriptor added in v0.14.4 

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

func (*Event) GetEnvironmentCreated added in v0.14.4 

func (m *Event) GetEnvironmentCreated() *Ev_EnvironmentCreated

func (*Event) GetEnvironmentDestroyed added in v0.14.4 

func (m *Event) GetEnvironmentDestroyed() *Ev_EnvironmentDestroyed

func (*Event) GetEnvironmentError added in v0.14.4 

func (m *Event) GetEnvironmentError() *Ev_EnvironmentError

func (*Event) GetEnvironmentStateChanged added in v0.14.4 

func (m *Event) GetEnvironmentStateChanged() *Ev_EnvironmentStateChanged

func (*Event) GetKilltasksMesos added in v0.14.4 

func (m *Event) GetKilltasksMesos() *Ev_KillTasksMesos

func (*Event) GetMesosTaskcreated added in v0.14.4 

func (m *Event) GetMesosTaskcreated() *Ev_MesosTaskCreated

func (*Event) GetPayload added in v0.14.4 

func (m *Event) GetPayload() isEvent_Payload

func (*Event) GetTaskStateChanged added in v0.14.4 

func (m *Event) GetTaskStateChanged() *Ev_TaskStateChanged

func (*Event) GetTaskStatusChanged added in v0.14.4 

func (m *Event) GetTaskStatusChanged() *Ev_TaskStatusChanged

func (*Event) GetTasklaunched added in v0.14.4 

func (m *Event) GetTasklaunched() *Ev_TaskLaunched

func (*Event) GetTimestamp added in v0.14.4 

func (m *Event) GetTimestamp() string

func (*Event) Marshal added in v0.14.4 

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

func (*Event) MarshalTo added in v0.14.4 

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

func (*Event) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event) ProtoMessage added in v0.14.4 

func (*Event) ProtoMessage()

func (*Event) Reset added in v0.14.4 

func (m *Event) Reset()

func (*Event) Size added in v0.14.4 

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

func (*Event) String added in v0.14.4 

func (m *Event) String() string

func (*Event) Unmarshal added in v0.14.4 

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

func (*Event) XXX_DiscardUnknown added in v0.14.4 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal added in v0.14.4 

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

func (*Event) XXX_Merge added in v0.14.4 

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

func (*Event) XXX_OneofWrappers added in v0.14.4 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size added in v0.14.4 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal added in v0.14.4 

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

type Event_EnvironmentCreated added in v0.14.4 

type Event_EnvironmentCreated struct {
	EnvironmentCreated *Ev_EnvironmentCreated `protobuf:"bytes,3,opt,name=environmentCreated,proto3,oneof" json:"environmentCreated,omitempty"`
}

func (*Event_EnvironmentCreated) MarshalTo added in v0.14.4 

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

func (*Event_EnvironmentCreated) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_EnvironmentCreated) Size added in v0.14.4 

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

type Event_EnvironmentDestroyed added in v0.14.4 

type Event_EnvironmentDestroyed struct {
	EnvironmentDestroyed *Ev_EnvironmentDestroyed `protobuf:"bytes,8,opt,name=environmentDestroyed,proto3,oneof" json:"environmentDestroyed,omitempty"`
}

func (*Event_EnvironmentDestroyed) MarshalTo added in v0.14.4 

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

func (*Event_EnvironmentDestroyed) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_EnvironmentDestroyed) Size added in v0.14.4 

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

type Event_EnvironmentError added in v0.14.4 

type Event_EnvironmentError struct {
	EnvironmentError *Ev_EnvironmentError `protobuf:"bytes,9,opt,name=environmentError,proto3,oneof" json:"environmentError,omitempty"`
}

func (*Event_EnvironmentError) MarshalTo added in v0.14.4 

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

func (*Event_EnvironmentError) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_EnvironmentError) Size added in v0.14.4 

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

type Event_EnvironmentStateChanged added in v0.14.4 

type Event_EnvironmentStateChanged struct {
	EnvironmentStateChanged *Ev_EnvironmentStateChanged `protobuf:"bytes,2,opt,name=environmentStateChanged,proto3,oneof" json:"environmentStateChanged,omitempty"`
}

func (*Event_EnvironmentStateChanged) MarshalTo added in v0.14.4 

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

func (*Event_EnvironmentStateChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_EnvironmentStateChanged) Size added in v0.14.4 

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

type Event_KilltasksMesos added in v0.14.4 

type Event_KilltasksMesos struct {
	KilltasksMesos *Ev_KillTasksMesos `protobuf:"bytes,10,opt,name=killtasksMesos,proto3,oneof" json:"killtasksMesos,omitempty"`
}

func (*Event_KilltasksMesos) MarshalTo added in v0.14.4 

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

func (*Event_KilltasksMesos) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_KilltasksMesos) Size added in v0.14.4 

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

type Event_MesosHeartbeat 

type Event_MesosHeartbeat struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Event_MesosHeartbeat) Descriptor 

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

func (*Event_MesosHeartbeat) Marshal 

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

func (*Event_MesosHeartbeat) MarshalTo 

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

func (*Event_MesosHeartbeat) MarshalToSizedBuffer added in v0.11.0 

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

func (*Event_MesosHeartbeat) ProtoMessage 

func (*Event_MesosHeartbeat) ProtoMessage()

func (*Event_MesosHeartbeat) Reset 

func (m *Event_MesosHeartbeat) Reset()

func (*Event_MesosHeartbeat) Size 

func (m *Event_MesosHeartbeat) Size() (n int)

func (*Event_MesosHeartbeat) String 

func (m *Event_MesosHeartbeat) String() string

func (*Event_MesosHeartbeat) Unmarshal 

func (m *Event_MesosHeartbeat) Unmarshal(dAtA []byte) error

func (*Event_MesosHeartbeat) XXX_DiscardUnknown 

func (m *Event_MesosHeartbeat) XXX_DiscardUnknown()

func (*Event_MesosHeartbeat) XXX_Marshal 

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

func (*Event_MesosHeartbeat) XXX_Merge 

func (m *Event_MesosHeartbeat) XXX_Merge(src proto.Message)

func (*Event_MesosHeartbeat) XXX_Size 

func (m *Event_MesosHeartbeat) XXX_Size() int

func (*Event_MesosHeartbeat) XXX_Unmarshal 

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

type Event_MesosTaskcreated added in v0.14.4 

type Event_MesosTaskcreated struct {
	MesosTaskcreated *Ev_MesosTaskCreated `protobuf:"bytes,7,opt,name=mesosTaskcreated,proto3,oneof" json:"mesosTaskcreated,omitempty"`
}

func (*Event_MesosTaskcreated) MarshalTo added in v0.14.4 

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

func (*Event_MesosTaskcreated) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_MesosTaskcreated) Size added in v0.14.4 

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

type Event_TaskStateChanged added in v0.14.4 

type Event_TaskStateChanged struct {
	TaskStateChanged *Ev_TaskStateChanged `protobuf:"bytes,4,opt,name=taskStateChanged,proto3,oneof" json:"taskStateChanged,omitempty"`
}

func (*Event_TaskStateChanged) MarshalTo added in v0.14.4 

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

func (*Event_TaskStateChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_TaskStateChanged) Size added in v0.14.4 

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

type Event_TaskStatusChanged added in v0.14.4 

type Event_TaskStatusChanged struct {
	TaskStatusChanged *Ev_TaskStatusChanged `protobuf:"bytes,5,opt,name=taskStatusChanged,proto3,oneof" json:"taskStatusChanged,omitempty"`
}

func (*Event_TaskStatusChanged) MarshalTo added in v0.14.4 

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

func (*Event_TaskStatusChanged) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_TaskStatusChanged) Size added in v0.14.4 

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

type Event_Tasklaunched added in v0.14.4 

type Event_Tasklaunched struct {
	Tasklaunched *Ev_TaskLaunched `protobuf:"bytes,6,opt,name=tasklaunched,proto3,oneof" json:"tasklaunched,omitempty"`
}

func (*Event_Tasklaunched) MarshalTo added in v0.14.4 

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

func (*Event_Tasklaunched) MarshalToSizedBuffer added in v0.14.4 

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

func (*Event_Tasklaunched) Size added in v0.14.4 

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

type GetEnvironmentPropertiesReply added in v0.12.90 

type GetEnvironmentPropertiesReply struct {
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetEnvironmentPropertiesReply) Descriptor added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) GetProperties added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) Marshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) MarshalTo added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) MarshalToSizedBuffer added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) ProtoMessage added in v0.12.90 

func (*GetEnvironmentPropertiesReply) ProtoMessage()

func (*GetEnvironmentPropertiesReply) Reset added in v0.12.90 

func (m *GetEnvironmentPropertiesReply) Reset()

func (*GetEnvironmentPropertiesReply) Size added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) String added in v0.12.90 

func (m *GetEnvironmentPropertiesReply) String() string

func (*GetEnvironmentPropertiesReply) Unmarshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) XXX_DiscardUnknown added in v0.12.90 

func (m *GetEnvironmentPropertiesReply) XXX_DiscardUnknown()

func (*GetEnvironmentPropertiesReply) XXX_Marshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) XXX_Merge added in v0.12.90 

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

func (*GetEnvironmentPropertiesReply) XXX_Size added in v0.12.90 

func (m *GetEnvironmentPropertiesReply) XXX_Size() int

func (*GetEnvironmentPropertiesReply) XXX_Unmarshal added in v0.12.90 

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

type GetEnvironmentPropertiesRequest added in v0.12.90 

type GetEnvironmentPropertiesRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// If len(queries) == 0, we return an
	// empty map.
	// To retrieve all KVs, use query '*'
	Queries              []string `protobuf:"bytes,2,rep,name=queries,proto3" json:"queries,omitempty"`
	ExcludeGlobals       bool     `protobuf:"varint,3,opt,name=excludeGlobals,proto3" json:"excludeGlobals,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetEnvironmentPropertiesRequest) Descriptor added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) GetExcludeGlobals added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) GetExcludeGlobals() bool

func (*GetEnvironmentPropertiesRequest) GetId added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) GetId() string

func (*GetEnvironmentPropertiesRequest) GetQueries added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) Marshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) MarshalTo added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) MarshalToSizedBuffer added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) ProtoMessage added in v0.12.90 

func (*GetEnvironmentPropertiesRequest) ProtoMessage()

func (*GetEnvironmentPropertiesRequest) Reset added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) Reset()

func (*GetEnvironmentPropertiesRequest) Size added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) String added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) String() string

func (*GetEnvironmentPropertiesRequest) Unmarshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) XXX_DiscardUnknown added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) XXX_DiscardUnknown()

func (*GetEnvironmentPropertiesRequest) XXX_Marshal added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) XXX_Merge added in v0.12.90 

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

func (*GetEnvironmentPropertiesRequest) XXX_Size added in v0.12.90 

func (m *GetEnvironmentPropertiesRequest) XXX_Size() int

func (*GetEnvironmentPropertiesRequest) XXX_Unmarshal added in v0.12.90 

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

type GetEnvironmentReply 

type GetEnvironmentReply struct {
	Environment          *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	Workflow             *RoleInfo        `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetEnvironmentReply) Descriptor 

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

func (*GetEnvironmentReply) GetEnvironment 

func (m *GetEnvironmentReply) GetEnvironment() *EnvironmentInfo

func (*GetEnvironmentReply) GetWorkflow 

func (m *GetEnvironmentReply) GetWorkflow() *RoleInfo

func (*GetEnvironmentReply) Marshal 

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

func (*GetEnvironmentReply) MarshalTo 

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

func (*GetEnvironmentReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetEnvironmentReply) ProtoMessage 

func (*GetEnvironmentReply) ProtoMessage()

func (*GetEnvironmentReply) Reset 

func (m *GetEnvironmentReply) Reset()

func (*GetEnvironmentReply) Size 

func (m *GetEnvironmentReply) Size() (n int)

func (*GetEnvironmentReply) String 

func (m *GetEnvironmentReply) String() string

func (*GetEnvironmentReply) Unmarshal 

func (m *GetEnvironmentReply) Unmarshal(dAtA []byte) error

func (*GetEnvironmentReply) XXX_DiscardUnknown 

func (m *GetEnvironmentReply) XXX_DiscardUnknown()

func (*GetEnvironmentReply) XXX_Marshal 

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

func (*GetEnvironmentReply) XXX_Merge 

func (m *GetEnvironmentReply) XXX_Merge(src proto.Message)

func (*GetEnvironmentReply) XXX_Size 

func (m *GetEnvironmentReply) XXX_Size() int

func (*GetEnvironmentReply) XXX_Unmarshal 

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

type GetEnvironmentRequest 

type GetEnvironmentRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetEnvironmentRequest) Descriptor 

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

func (*GetEnvironmentRequest) GetId 

func (m *GetEnvironmentRequest) GetId() string

func (*GetEnvironmentRequest) Marshal 

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

func (*GetEnvironmentRequest) MarshalTo 

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

func (*GetEnvironmentRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetEnvironmentRequest) ProtoMessage 

func (*GetEnvironmentRequest) ProtoMessage()

func (*GetEnvironmentRequest) Reset 

func (m *GetEnvironmentRequest) Reset()

func (*GetEnvironmentRequest) Size 

func (m *GetEnvironmentRequest) Size() (n int)

func (*GetEnvironmentRequest) String 

func (m *GetEnvironmentRequest) String() string

func (*GetEnvironmentRequest) Unmarshal 

func (m *GetEnvironmentRequest) Unmarshal(dAtA []byte) error

func (*GetEnvironmentRequest) XXX_DiscardUnknown 

func (m *GetEnvironmentRequest) XXX_DiscardUnknown()

func (*GetEnvironmentRequest) XXX_Marshal 

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

func (*GetEnvironmentRequest) XXX_Merge 

func (m *GetEnvironmentRequest) XXX_Merge(src proto.Message)

func (*GetEnvironmentRequest) XXX_Size 

func (m *GetEnvironmentRequest) XXX_Size() int

func (*GetEnvironmentRequest) XXX_Unmarshal 

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

type GetEnvironmentsReply 

type GetEnvironmentsReply struct {
	FrameworkId          string             `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"`
	Environments         []*EnvironmentInfo `protobuf:"bytes,2,rep,name=environments,proto3" json:"environments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetEnvironmentsReply) Descriptor 

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

func (*GetEnvironmentsReply) GetEnvironments 

func (m *GetEnvironmentsReply) GetEnvironments() []*EnvironmentInfo

func (*GetEnvironmentsReply) GetFrameworkId 

func (m *GetEnvironmentsReply) GetFrameworkId() string

func (*GetEnvironmentsReply) Marshal 

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

func (*GetEnvironmentsReply) MarshalTo 

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

func (*GetEnvironmentsReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetEnvironmentsReply) ProtoMessage 

func (*GetEnvironmentsReply) ProtoMessage()

func (*GetEnvironmentsReply) Reset 

func (m *GetEnvironmentsReply) Reset()

func (*GetEnvironmentsReply) Size 

func (m *GetEnvironmentsReply) Size() (n int)

func (*GetEnvironmentsReply) String 

func (m *GetEnvironmentsReply) String() string

func (*GetEnvironmentsReply) Unmarshal 

func (m *GetEnvironmentsReply) Unmarshal(dAtA []byte) error

func (*GetEnvironmentsReply) XXX_DiscardUnknown 

func (m *GetEnvironmentsReply) XXX_DiscardUnknown()

func (*GetEnvironmentsReply) XXX_Marshal 

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

func (*GetEnvironmentsReply) XXX_Merge 

func (m *GetEnvironmentsReply) XXX_Merge(src proto.Message)

func (*GetEnvironmentsReply) XXX_Size 

func (m *GetEnvironmentsReply) XXX_Size() int

func (*GetEnvironmentsReply) XXX_Unmarshal 

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

type GetEnvironmentsRequest 

type GetEnvironmentsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

////////////////////////////////////// Environment //////////////////////////////////////

func (*GetEnvironmentsRequest) Descriptor 

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

func (*GetEnvironmentsRequest) Marshal 

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

func (*GetEnvironmentsRequest) MarshalTo 

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

func (*GetEnvironmentsRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetEnvironmentsRequest) ProtoMessage 

func (*GetEnvironmentsRequest) ProtoMessage()

func (*GetEnvironmentsRequest) Reset 

func (m *GetEnvironmentsRequest) Reset()

func (*GetEnvironmentsRequest) Size 

func (m *GetEnvironmentsRequest) Size() (n int)

func (*GetEnvironmentsRequest) String 

func (m *GetEnvironmentsRequest) String() string

func (*GetEnvironmentsRequest) Unmarshal 

func (m *GetEnvironmentsRequest) Unmarshal(dAtA []byte) error

func (*GetEnvironmentsRequest) XXX_DiscardUnknown 

func (m *GetEnvironmentsRequest) XXX_DiscardUnknown()

func (*GetEnvironmentsRequest) XXX_Marshal 

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

func (*GetEnvironmentsRequest) XXX_Merge 

func (m *GetEnvironmentsRequest) XXX_Merge(src proto.Message)

func (*GetEnvironmentsRequest) XXX_Size 

func (m *GetEnvironmentsRequest) XXX_Size() int

func (*GetEnvironmentsRequest) XXX_Unmarshal 

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

type GetFrameworkInfoReply 

type GetFrameworkInfoReply struct {
	FrameworkId          string   `protobuf:"bytes,1,opt,name=frameworkId,proto3" json:"frameworkId,omitempty"`
	EnvironmentsCount    int32    `protobuf:"varint,2,opt,name=environmentsCount,proto3" json:"environmentsCount,omitempty"`
	TasksCount           int32    `protobuf:"varint,3,opt,name=tasksCount,proto3" json:"tasksCount,omitempty"`
	State                string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	HostsCount           int32    `protobuf:"varint,5,opt,name=hostsCount,proto3" json:"hostsCount,omitempty"`
	InstanceName         string   `protobuf:"bytes,6,opt,name=instanceName,proto3" json:"instanceName,omitempty"`
	Version              *Version `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetFrameworkInfoReply) Descriptor 

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

func (*GetFrameworkInfoReply) GetEnvironmentsCount 

func (m *GetFrameworkInfoReply) GetEnvironmentsCount() int32

func (*GetFrameworkInfoReply) GetFrameworkId 

func (m *GetFrameworkInfoReply) GetFrameworkId() string

func (*GetFrameworkInfoReply) GetHostsCount 

func (m *GetFrameworkInfoReply) GetHostsCount() int32

func (*GetFrameworkInfoReply) GetInstanceName added in v0.7.0 

func (m *GetFrameworkInfoReply) GetInstanceName() string

func (*GetFrameworkInfoReply) GetState 

func (m *GetFrameworkInfoReply) GetState() string

func (*GetFrameworkInfoReply) GetTasksCount 

func (m *GetFrameworkInfoReply) GetTasksCount() int32

func (*GetFrameworkInfoReply) GetVersion added in v0.7.0 

func (m *GetFrameworkInfoReply) GetVersion() *Version

func (*GetFrameworkInfoReply) Marshal 

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

func (*GetFrameworkInfoReply) MarshalTo 

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

func (*GetFrameworkInfoReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetFrameworkInfoReply) ProtoMessage 

func (*GetFrameworkInfoReply) ProtoMessage()

func (*GetFrameworkInfoReply) Reset 

func (m *GetFrameworkInfoReply) Reset()

func (*GetFrameworkInfoReply) Size 

func (m *GetFrameworkInfoReply) Size() (n int)

func (*GetFrameworkInfoReply) String 

func (m *GetFrameworkInfoReply) String() string

func (*GetFrameworkInfoReply) Unmarshal 

func (m *GetFrameworkInfoReply) Unmarshal(dAtA []byte) error

func (*GetFrameworkInfoReply) XXX_DiscardUnknown 

func (m *GetFrameworkInfoReply) XXX_DiscardUnknown()

func (*GetFrameworkInfoReply) XXX_Marshal 

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

func (*GetFrameworkInfoReply) XXX_Merge 

func (m *GetFrameworkInfoReply) XXX_Merge(src proto.Message)

func (*GetFrameworkInfoReply) XXX_Size 

func (m *GetFrameworkInfoReply) XXX_Size() int

func (*GetFrameworkInfoReply) XXX_Unmarshal 

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

type GetFrameworkInfoRequest 

type GetFrameworkInfoRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

////////////////////////////////////// Framework //////////////////////////////////////

func (*GetFrameworkInfoRequest) Descriptor 

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

func (*GetFrameworkInfoRequest) Marshal 

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

func (*GetFrameworkInfoRequest) MarshalTo 

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

func (*GetFrameworkInfoRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetFrameworkInfoRequest) ProtoMessage 

func (*GetFrameworkInfoRequest) ProtoMessage()

func (*GetFrameworkInfoRequest) Reset 

func (m *GetFrameworkInfoRequest) Reset()

func (*GetFrameworkInfoRequest) Size 

func (m *GetFrameworkInfoRequest) Size() (n int)

func (*GetFrameworkInfoRequest) String 

func (m *GetFrameworkInfoRequest) String() string

func (*GetFrameworkInfoRequest) Unmarshal 

func (m *GetFrameworkInfoRequest) Unmarshal(dAtA []byte) error

func (*GetFrameworkInfoRequest) XXX_DiscardUnknown 

func (m *GetFrameworkInfoRequest) XXX_DiscardUnknown()

func (*GetFrameworkInfoRequest) XXX_Marshal 

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

func (*GetFrameworkInfoRequest) XXX_Merge 

func (m *GetFrameworkInfoRequest) XXX_Merge(src proto.Message)

func (*GetFrameworkInfoRequest) XXX_Size 

func (m *GetFrameworkInfoRequest) XXX_Size() int

func (*GetFrameworkInfoRequest) XXX_Unmarshal 

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

type GetRolesReply 

type GetRolesReply struct {
	Roles                []*RoleInfo `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetRolesReply) Descriptor 

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

func (*GetRolesReply) GetRoles 

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

func (*GetRolesReply) Marshal 

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

func (*GetRolesReply) MarshalTo 

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

func (*GetRolesReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRolesReply) ProtoMessage 

func (*GetRolesReply) ProtoMessage()

func (*GetRolesReply) Reset 

func (m *GetRolesReply) Reset()

func (*GetRolesReply) Size 

func (m *GetRolesReply) Size() (n int)

func (*GetRolesReply) String 

func (m *GetRolesReply) String() string

func (*GetRolesReply) Unmarshal 

func (m *GetRolesReply) Unmarshal(dAtA []byte) error

func (*GetRolesReply) XXX_DiscardUnknown 

func (m *GetRolesReply) XXX_DiscardUnknown()

func (*GetRolesReply) XXX_Marshal 

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

func (*GetRolesReply) XXX_Merge 

func (m *GetRolesReply) XXX_Merge(src proto.Message)

func (*GetRolesReply) XXX_Size 

func (m *GetRolesReply) XXX_Size() int

func (*GetRolesReply) XXX_Unmarshal 

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

type GetRolesRequest 

type GetRolesRequest struct {
	EnvId                string   `protobuf:"bytes,1,opt,name=envId,proto3" json:"envId,omitempty"`
	PathSpec             string   `protobuf:"bytes,2,opt,name=pathSpec,proto3" json:"pathSpec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

////////////////////////////////////// Roles //////////////////////////////////////

func (*GetRolesRequest) Descriptor 

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

func (*GetRolesRequest) GetEnvId 

func (m *GetRolesRequest) GetEnvId() string

func (*GetRolesRequest) GetPathSpec 

func (m *GetRolesRequest) GetPathSpec() string

func (*GetRolesRequest) Marshal 

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

func (*GetRolesRequest) MarshalTo 

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

func (*GetRolesRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRolesRequest) ProtoMessage 

func (*GetRolesRequest) ProtoMessage()

func (*GetRolesRequest) Reset 

func (m *GetRolesRequest) Reset()

func (*GetRolesRequest) Size 

func (m *GetRolesRequest) Size() (n int)

func (*GetRolesRequest) String 

func (m *GetRolesRequest) String() string

func (*GetRolesRequest) Unmarshal 

func (m *GetRolesRequest) Unmarshal(dAtA []byte) error

func (*GetRolesRequest) XXX_DiscardUnknown 

func (m *GetRolesRequest) XXX_DiscardUnknown()

func (*GetRolesRequest) XXX_Marshal 

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

func (*GetRolesRequest) XXX_Merge 

func (m *GetRolesRequest) XXX_Merge(src proto.Message)

func (*GetRolesRequest) XXX_Size 

func (m *GetRolesRequest) XXX_Size() int

func (*GetRolesRequest) XXX_Unmarshal 

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

type GetTaskReply 

type GetTaskReply struct {
	Task                 *TaskInfo `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetTaskReply) Descriptor 

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

func (*GetTaskReply) GetTask 

func (m *GetTaskReply) GetTask() *TaskInfo

func (*GetTaskReply) Marshal 

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

func (*GetTaskReply) MarshalTo 

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

func (*GetTaskReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetTaskReply) ProtoMessage 

func (*GetTaskReply) ProtoMessage()

func (*GetTaskReply) Reset 

func (m *GetTaskReply) Reset()

func (*GetTaskReply) Size 

func (m *GetTaskReply) Size() (n int)

func (*GetTaskReply) String 

func (m *GetTaskReply) String() string

func (*GetTaskReply) Unmarshal 

func (m *GetTaskReply) Unmarshal(dAtA []byte) error

func (*GetTaskReply) XXX_DiscardUnknown 

func (m *GetTaskReply) XXX_DiscardUnknown()

func (*GetTaskReply) XXX_Marshal 

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

func (*GetTaskReply) XXX_Merge 

func (m *GetTaskReply) XXX_Merge(src proto.Message)

func (*GetTaskReply) XXX_Size 

func (m *GetTaskReply) XXX_Size() int

func (*GetTaskReply) XXX_Unmarshal 

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

type GetTaskRequest 

type GetTaskRequest struct {
	TaskId               string   `protobuf:"bytes,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskRequest) Descriptor 

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

func (*GetTaskRequest) GetTaskId 

func (m *GetTaskRequest) GetTaskId() string

func (*GetTaskRequest) Marshal 

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

func (*GetTaskRequest) MarshalTo 

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

func (*GetTaskRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) Size 

func (m *GetTaskRequest) Size() (n int)

func (*GetTaskRequest) String 

func (m *GetTaskRequest) String() string

func (*GetTaskRequest) Unmarshal 

func (m *GetTaskRequest) Unmarshal(dAtA []byte) error

func (*GetTaskRequest) XXX_DiscardUnknown 

func (m *GetTaskRequest) XXX_DiscardUnknown()

func (*GetTaskRequest) XXX_Marshal 

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

func (*GetTaskRequest) XXX_Merge 

func (m *GetTaskRequest) XXX_Merge(src proto.Message)

func (*GetTaskRequest) XXX_Size 

func (m *GetTaskRequest) XXX_Size() int

func (*GetTaskRequest) XXX_Unmarshal 

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

type GetTasksReply 

type GetTasksReply struct {
	Tasks                []*ShortTaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetTasksReply) Descriptor 

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

func (*GetTasksReply) GetTasks 

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

func (*GetTasksReply) Marshal 

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

func (*GetTasksReply) MarshalTo 

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

func (*GetTasksReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetTasksReply) ProtoMessage 

func (*GetTasksReply) ProtoMessage()

func (*GetTasksReply) Reset 

func (m *GetTasksReply) Reset()

func (*GetTasksReply) Size 

func (m *GetTasksReply) Size() (n int)

func (*GetTasksReply) String 

func (m *GetTasksReply) String() string

func (*GetTasksReply) Unmarshal 

func (m *GetTasksReply) Unmarshal(dAtA []byte) error

func (*GetTasksReply) XXX_DiscardUnknown 

func (m *GetTasksReply) XXX_DiscardUnknown()

func (*GetTasksReply) XXX_Marshal 

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

func (*GetTasksReply) XXX_Merge 

func (m *GetTasksReply) XXX_Merge(src proto.Message)

func (*GetTasksReply) XXX_Size 

func (m *GetTasksReply) XXX_Size() int

func (*GetTasksReply) XXX_Unmarshal 

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

type GetTasksRequest 

type GetTasksRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTasksRequest) Descriptor 

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

func (*GetTasksRequest) Marshal 

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

func (*GetTasksRequest) MarshalTo 

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

func (*GetTasksRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetTasksRequest) ProtoMessage 

func (*GetTasksRequest) ProtoMessage()

func (*GetTasksRequest) Reset 

func (m *GetTasksRequest) Reset()

func (*GetTasksRequest) Size 

func (m *GetTasksRequest) Size() (n int)

func (*GetTasksRequest) String 

func (m *GetTasksRequest) String() string

func (*GetTasksRequest) Unmarshal 

func (m *GetTasksRequest) Unmarshal(dAtA []byte) error

func (*GetTasksRequest) XXX_DiscardUnknown 

func (m *GetTasksRequest) XXX_DiscardUnknown()

func (*GetTasksRequest) XXX_Marshal 

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

func (*GetTasksRequest) XXX_Merge 

func (m *GetTasksRequest) XXX_Merge(src proto.Message)

func (*GetTasksRequest) XXX_Size 

func (m *GetTasksRequest) XXX_Size() int

func (*GetTasksRequest) XXX_Unmarshal 

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

type GetWorkflowTemplatesReply 

type GetWorkflowTemplatesReply struct {
	WorkflowTemplates    []*WorkflowTemplateInfo `protobuf:"bytes,1,rep,name=workflowTemplates,proto3" json:"workflowTemplates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetWorkflowTemplatesReply) Descriptor 

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

func (*GetWorkflowTemplatesReply) GetWorkflowTemplates 

func (m *GetWorkflowTemplatesReply) GetWorkflowTemplates() []*WorkflowTemplateInfo

func (*GetWorkflowTemplatesReply) Marshal 

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

func (*GetWorkflowTemplatesReply) MarshalTo 

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

func (*GetWorkflowTemplatesReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetWorkflowTemplatesReply) ProtoMessage 

func (*GetWorkflowTemplatesReply) ProtoMessage()

func (*GetWorkflowTemplatesReply) Reset 

func (m *GetWorkflowTemplatesReply) Reset()

func (*GetWorkflowTemplatesReply) Size 

func (m *GetWorkflowTemplatesReply) Size() (n int)

func (*GetWorkflowTemplatesReply) String 

func (m *GetWorkflowTemplatesReply) String() string

func (*GetWorkflowTemplatesReply) Unmarshal 

func (m *GetWorkflowTemplatesReply) Unmarshal(dAtA []byte) error

func (*GetWorkflowTemplatesReply) XXX_DiscardUnknown 

func (m *GetWorkflowTemplatesReply) XXX_DiscardUnknown()

func (*GetWorkflowTemplatesReply) XXX_Marshal 

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

func (*GetWorkflowTemplatesReply) XXX_Merge 

func (m *GetWorkflowTemplatesReply) XXX_Merge(src proto.Message)

func (*GetWorkflowTemplatesReply) XXX_Size 

func (m *GetWorkflowTemplatesReply) XXX_Size() int

func (*GetWorkflowTemplatesReply) XXX_Unmarshal 

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

type GetWorkflowTemplatesRequest 

type GetWorkflowTemplatesRequest struct {
	RepoPattern          string   `protobuf:"bytes,1,opt,name=repoPattern,proto3" json:"repoPattern,omitempty"`
	RevisionPattern      string   `protobuf:"bytes,2,opt,name=revisionPattern,proto3" json:"revisionPattern,omitempty"`
	AllBranches          bool     `protobuf:"varint,3,opt,name=allBranches,proto3" json:"allBranches,omitempty"`
	AllTags              bool     `protobuf:"varint,4,opt,name=allTags,proto3" json:"allTags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkflowTemplatesRequest) Descriptor 

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

func (*GetWorkflowTemplatesRequest) GetAllBranches added in v0.11.0 

func (m *GetWorkflowTemplatesRequest) GetAllBranches() bool

func (*GetWorkflowTemplatesRequest) GetAllTags added in v0.11.0 

func (m *GetWorkflowTemplatesRequest) GetAllTags() bool

func (*GetWorkflowTemplatesRequest) GetRepoPattern added in v0.11.0 

func (m *GetWorkflowTemplatesRequest) GetRepoPattern() string

func (*GetWorkflowTemplatesRequest) GetRevisionPattern added in v0.11.0 

func (m *GetWorkflowTemplatesRequest) GetRevisionPattern() string

func (*GetWorkflowTemplatesRequest) Marshal 

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

func (*GetWorkflowTemplatesRequest) MarshalTo 

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

func (*GetWorkflowTemplatesRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetWorkflowTemplatesRequest) ProtoMessage 

func (*GetWorkflowTemplatesRequest) ProtoMessage()

func (*GetWorkflowTemplatesRequest) Reset 

func (m *GetWorkflowTemplatesRequest) Reset()

func (*GetWorkflowTemplatesRequest) Size 

func (m *GetWorkflowTemplatesRequest) Size() (n int)

func (*GetWorkflowTemplatesRequest) String 

func (m *GetWorkflowTemplatesRequest) String() string

func (*GetWorkflowTemplatesRequest) Unmarshal 

func (m *GetWorkflowTemplatesRequest) Unmarshal(dAtA []byte) error

func (*GetWorkflowTemplatesRequest) XXX_DiscardUnknown 

func (m *GetWorkflowTemplatesRequest) XXX_DiscardUnknown()

func (*GetWorkflowTemplatesRequest) XXX_Marshal 

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

func (*GetWorkflowTemplatesRequest) XXX_Merge 

func (m *GetWorkflowTemplatesRequest) XXX_Merge(src proto.Message)

func (*GetWorkflowTemplatesRequest) XXX_Size 

func (m *GetWorkflowTemplatesRequest) XXX_Size() int

func (*GetWorkflowTemplatesRequest) XXX_Unmarshal 

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

type ListReposReply added in v0.10.0 

type ListReposReply struct {
	Repos                 []*RepoInfo `protobuf:"bytes,1,rep,name=repos,proto3" json:"repos,omitempty"`
	GlobalDefaultRevision string      `protobuf:"bytes,2,opt,name=globalDefaultRevision,proto3" json:"globalDefaultRevision,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}    `json:"-"`
	XXX_unrecognized      []byte      `json:"-"`
	XXX_sizecache         int32       `json:"-"`
}

func (*ListReposReply) Descriptor added in v0.10.0 

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

func (*ListReposReply) GetGlobalDefaultRevision added in v0.12.90 

func (m *ListReposReply) GetGlobalDefaultRevision() string

func (*ListReposReply) GetRepos added in v0.10.0 

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

func (*ListReposReply) Marshal added in v0.10.0 

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

func (*ListReposReply) MarshalTo added in v0.10.0 

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

func (*ListReposReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*ListReposReply) ProtoMessage added in v0.10.0 

func (*ListReposReply) ProtoMessage()

func (*ListReposReply) Reset added in v0.10.0 

func (m *ListReposReply) Reset()

func (*ListReposReply) Size added in v0.10.0 

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

func (*ListReposReply) String added in v0.10.0 

func (m *ListReposReply) String() string

func (*ListReposReply) Unmarshal added in v0.10.0 

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

func (*ListReposReply) XXX_DiscardUnknown added in v0.10.0 

func (m *ListReposReply) XXX_DiscardUnknown()

func (*ListReposReply) XXX_Marshal added in v0.10.0 

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

func (*ListReposReply) XXX_Merge added in v0.10.0 

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

func (*ListReposReply) XXX_Size added in v0.10.0 

func (m *ListReposReply) XXX_Size() int

func (*ListReposReply) XXX_Unmarshal added in v0.10.0 

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

type ListReposRequest added in v0.10.0 

type ListReposRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListReposRequest) Descriptor added in v0.10.0 

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

func (*ListReposRequest) Marshal added in v0.10.0 

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

func (*ListReposRequest) MarshalTo added in v0.10.0 

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

func (*ListReposRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*ListReposRequest) ProtoMessage added in v0.10.0 

func (*ListReposRequest) ProtoMessage()

func (*ListReposRequest) Reset added in v0.10.0 

func (m *ListReposRequest) Reset()

func (*ListReposRequest) Size added in v0.10.0 

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

func (*ListReposRequest) String added in v0.10.0 

func (m *ListReposRequest) String() string

func (*ListReposRequest) Unmarshal added in v0.10.0 

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

func (*ListReposRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *ListReposRequest) XXX_DiscardUnknown()

func (*ListReposRequest) XXX_Marshal added in v0.10.0 

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

func (*ListReposRequest) XXX_Merge added in v0.10.0 

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

func (*ListReposRequest) XXX_Size added in v0.10.0 

func (m *ListReposRequest) XXX_Size() int

func (*ListReposRequest) XXX_Unmarshal added in v0.10.0 

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

type ModifyEnvironmentReply 

type ModifyEnvironmentReply struct {
	FailedOperations     []*EnvironmentOperation `protobuf:"bytes,1,rep,name=failedOperations,proto3" json:"failedOperations,omitempty"`
	Id                   string                  `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	State                string                  `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ModifyEnvironmentReply) Descriptor 

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

func (*ModifyEnvironmentReply) GetFailedOperations 

func (m *ModifyEnvironmentReply) GetFailedOperations() []*EnvironmentOperation

func (*ModifyEnvironmentReply) GetId 

func (m *ModifyEnvironmentReply) GetId() string

func (*ModifyEnvironmentReply) GetState 

func (m *ModifyEnvironmentReply) GetState() string

func (*ModifyEnvironmentReply) Marshal 

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

func (*ModifyEnvironmentReply) MarshalTo 

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

func (*ModifyEnvironmentReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*ModifyEnvironmentReply) ProtoMessage 

func (*ModifyEnvironmentReply) ProtoMessage()

func (*ModifyEnvironmentReply) Reset 

func (m *ModifyEnvironmentReply) Reset()

func (*ModifyEnvironmentReply) Size 

func (m *ModifyEnvironmentReply) Size() (n int)

func (*ModifyEnvironmentReply) String 

func (m *ModifyEnvironmentReply) String() string

func (*ModifyEnvironmentReply) Unmarshal 

func (m *ModifyEnvironmentReply) Unmarshal(dAtA []byte) error

func (*ModifyEnvironmentReply) XXX_DiscardUnknown 

func (m *ModifyEnvironmentReply) XXX_DiscardUnknown()

func (*ModifyEnvironmentReply) XXX_Marshal 

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

func (*ModifyEnvironmentReply) XXX_Merge 

func (m *ModifyEnvironmentReply) XXX_Merge(src proto.Message)

func (*ModifyEnvironmentReply) XXX_Size 

func (m *ModifyEnvironmentReply) XXX_Size() int

func (*ModifyEnvironmentReply) XXX_Unmarshal 

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

type ModifyEnvironmentRequest 

type ModifyEnvironmentRequest struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Operations           []*EnvironmentOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	ReconfigureAll       bool                    `protobuf:"varint,3,opt,name=reconfigureAll,proto3" json:"reconfigureAll,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ModifyEnvironmentRequest) Descriptor 

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

func (*ModifyEnvironmentRequest) GetId 

func (m *ModifyEnvironmentRequest) GetId() string

func (*ModifyEnvironmentRequest) GetOperations 

func (m *ModifyEnvironmentRequest) GetOperations() []*EnvironmentOperation

func (*ModifyEnvironmentRequest) GetReconfigureAll 

func (m *ModifyEnvironmentRequest) GetReconfigureAll() bool

func (*ModifyEnvironmentRequest) Marshal 

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

func (*ModifyEnvironmentRequest) MarshalTo 

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

func (*ModifyEnvironmentRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*ModifyEnvironmentRequest) ProtoMessage 

func (*ModifyEnvironmentRequest) ProtoMessage()

func (*ModifyEnvironmentRequest) Reset 

func (m *ModifyEnvironmentRequest) Reset()

func (*ModifyEnvironmentRequest) Size 

func (m *ModifyEnvironmentRequest) Size() (n int)

func (*ModifyEnvironmentRequest) String 

func (m *ModifyEnvironmentRequest) String() string

func (*ModifyEnvironmentRequest) Unmarshal 

func (m *ModifyEnvironmentRequest) Unmarshal(dAtA []byte) error

func (*ModifyEnvironmentRequest) XXX_DiscardUnknown 

func (m *ModifyEnvironmentRequest) XXX_DiscardUnknown()

func (*ModifyEnvironmentRequest) XXX_Marshal 

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

func (*ModifyEnvironmentRequest) XXX_Merge 

func (m *ModifyEnvironmentRequest) XXX_Merge(src proto.Message)

func (*ModifyEnvironmentRequest) XXX_Size 

func (m *ModifyEnvironmentRequest) XXX_Size() int

func (*ModifyEnvironmentRequest) XXX_Unmarshal 

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

type NewEnvironmentReply 

type NewEnvironmentReply struct {
	Environment          *EnvironmentInfo `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*NewEnvironmentReply) Descriptor 

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

func (*NewEnvironmentReply) GetEnvironment 

func (m *NewEnvironmentReply) GetEnvironment() *EnvironmentInfo

func (*NewEnvironmentReply) Marshal 

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

func (*NewEnvironmentReply) MarshalTo 

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

func (*NewEnvironmentReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*NewEnvironmentReply) ProtoMessage 

func (*NewEnvironmentReply) ProtoMessage()

func (*NewEnvironmentReply) Reset 

func (m *NewEnvironmentReply) Reset()

func (*NewEnvironmentReply) Size 

func (m *NewEnvironmentReply) Size() (n int)

func (*NewEnvironmentReply) String 

func (m *NewEnvironmentReply) String() string

func (*NewEnvironmentReply) Unmarshal 

func (m *NewEnvironmentReply) Unmarshal(dAtA []byte) error

func (*NewEnvironmentReply) XXX_DiscardUnknown 

func (m *NewEnvironmentReply) XXX_DiscardUnknown()

func (*NewEnvironmentReply) XXX_Marshal 

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

func (*NewEnvironmentReply) XXX_Merge 

func (m *NewEnvironmentReply) XXX_Merge(src proto.Message)

func (*NewEnvironmentReply) XXX_Size 

func (m *NewEnvironmentReply) XXX_Size() int

func (*NewEnvironmentReply) XXX_Unmarshal 

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

type NewEnvironmentRequest 

type NewEnvironmentRequest struct {
	WorkflowTemplate     string            `protobuf:"bytes,1,opt,name=workflowTemplate,proto3" json:"workflowTemplate,omitempty"`
	Vars                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*NewEnvironmentRequest) Descriptor 

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

func (*NewEnvironmentRequest) GetVars added in v0.12.90 

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

func (*NewEnvironmentRequest) GetWorkflowTemplate 

func (m *NewEnvironmentRequest) GetWorkflowTemplate() string

func (*NewEnvironmentRequest) Marshal 

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

func (*NewEnvironmentRequest) MarshalTo 

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

func (*NewEnvironmentRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*NewEnvironmentRequest) ProtoMessage 

func (*NewEnvironmentRequest) ProtoMessage()

func (*NewEnvironmentRequest) Reset 

func (m *NewEnvironmentRequest) Reset()

func (*NewEnvironmentRequest) Size 

func (m *NewEnvironmentRequest) Size() (n int)

func (*NewEnvironmentRequest) String 

func (m *NewEnvironmentRequest) String() string

func (*NewEnvironmentRequest) Unmarshal 

func (m *NewEnvironmentRequest) Unmarshal(dAtA []byte) error

func (*NewEnvironmentRequest) XXX_DiscardUnknown 

func (m *NewEnvironmentRequest) XXX_DiscardUnknown()

func (*NewEnvironmentRequest) XXX_Marshal 

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

func (*NewEnvironmentRequest) XXX_Merge 

func (m *NewEnvironmentRequest) XXX_Merge(src proto.Message)

func (*NewEnvironmentRequest) XXX_Size 

func (m *NewEnvironmentRequest) XXX_Size() int

func (*NewEnvironmentRequest) XXX_Unmarshal 

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

type RefreshReposRequest added in v0.10.0 

type RefreshReposRequest struct {
	Index                int32    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RefreshReposRequest) Descriptor added in v0.10.0 

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

func (*RefreshReposRequest) GetIndex added in v0.10.0 

func (m *RefreshReposRequest) GetIndex() int32

func (*RefreshReposRequest) Marshal added in v0.10.0 

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

func (*RefreshReposRequest) MarshalTo added in v0.10.0 

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

func (*RefreshReposRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*RefreshReposRequest) ProtoMessage added in v0.10.0 

func (*RefreshReposRequest) ProtoMessage()

func (*RefreshReposRequest) Reset added in v0.10.0 

func (m *RefreshReposRequest) Reset()

func (*RefreshReposRequest) Size added in v0.10.0 

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

func (*RefreshReposRequest) String added in v0.10.0 

func (m *RefreshReposRequest) String() string

func (*RefreshReposRequest) Unmarshal added in v0.10.0 

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

func (*RefreshReposRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *RefreshReposRequest) XXX_DiscardUnknown()

func (*RefreshReposRequest) XXX_Marshal added in v0.10.0 

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

func (*RefreshReposRequest) XXX_Merge added in v0.10.0 

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

func (*RefreshReposRequest) XXX_Size added in v0.10.0 

func (m *RefreshReposRequest) XXX_Size() int

func (*RefreshReposRequest) XXX_Unmarshal added in v0.10.0 

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

type RemoveRepoReply added in v0.10.0 

type RemoveRepoReply struct {
	NewDefaultRepo       string   `protobuf:"bytes,1,opt,name=newDefaultRepo,proto3" json:"newDefaultRepo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRepoReply) Descriptor added in v0.10.0 

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

func (*RemoveRepoReply) GetNewDefaultRepo added in v0.10.0 

func (m *RemoveRepoReply) GetNewDefaultRepo() string

func (*RemoveRepoReply) Marshal added in v0.10.0 

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

func (*RemoveRepoReply) MarshalTo added in v0.10.0 

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

func (*RemoveRepoReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*RemoveRepoReply) ProtoMessage added in v0.10.0 

func (*RemoveRepoReply) ProtoMessage()

func (*RemoveRepoReply) Reset added in v0.10.0 

func (m *RemoveRepoReply) Reset()

func (*RemoveRepoReply) Size added in v0.10.0 

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

func (*RemoveRepoReply) String added in v0.10.0 

func (m *RemoveRepoReply) String() string

func (*RemoveRepoReply) Unmarshal added in v0.10.0 

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

func (*RemoveRepoReply) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveRepoReply) XXX_DiscardUnknown()

func (*RemoveRepoReply) XXX_Marshal added in v0.10.0 

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

func (*RemoveRepoReply) XXX_Merge added in v0.10.0 

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

func (*RemoveRepoReply) XXX_Size added in v0.10.0 

func (m *RemoveRepoReply) XXX_Size() int

func (*RemoveRepoReply) XXX_Unmarshal added in v0.10.0 

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

type RemoveRepoRequest added in v0.10.0 

type RemoveRepoRequest struct {
	Index                int32    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRepoRequest) Descriptor added in v0.10.0 

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

func (*RemoveRepoRequest) GetIndex added in v0.10.0 

func (m *RemoveRepoRequest) GetIndex() int32

func (*RemoveRepoRequest) Marshal added in v0.10.0 

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

func (*RemoveRepoRequest) MarshalTo added in v0.10.0 

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

func (*RemoveRepoRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*RemoveRepoRequest) ProtoMessage added in v0.10.0 

func (*RemoveRepoRequest) ProtoMessage()

func (*RemoveRepoRequest) Reset added in v0.10.0 

func (m *RemoveRepoRequest) Reset()

func (*RemoveRepoRequest) Size added in v0.10.0 

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

func (*RemoveRepoRequest) String added in v0.10.0 

func (m *RemoveRepoRequest) String() string

func (*RemoveRepoRequest) Unmarshal added in v0.10.0 

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

func (*RemoveRepoRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *RemoveRepoRequest) XXX_DiscardUnknown()

func (*RemoveRepoRequest) XXX_Marshal added in v0.10.0 

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

func (*RemoveRepoRequest) XXX_Merge added in v0.10.0 

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

func (*RemoveRepoRequest) XXX_Size added in v0.10.0 

func (m *RemoveRepoRequest) XXX_Size() int

func (*RemoveRepoRequest) XXX_Unmarshal added in v0.10.0 

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

type RepoInfo added in v0.10.0 

type RepoInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Default              bool     `protobuf:"varint,2,opt,name=default,proto3" json:"default,omitempty"`
	DefaultRevision      string   `protobuf:"bytes,3,opt,name=defaultRevision,proto3" json:"defaultRevision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepoInfo) Descriptor added in v0.10.0 

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

func (*RepoInfo) GetDefault added in v0.10.0 

func (m *RepoInfo) GetDefault() bool

func (*RepoInfo) GetDefaultRevision added in v0.12.90 

func (m *RepoInfo) GetDefaultRevision() string

func (*RepoInfo) GetName added in v0.10.0 

func (m *RepoInfo) GetName() string

func (*RepoInfo) Marshal added in v0.10.0 

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

func (*RepoInfo) MarshalTo added in v0.10.0 

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

func (*RepoInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*RepoInfo) ProtoMessage added in v0.10.0 

func (*RepoInfo) ProtoMessage()

func (*RepoInfo) Reset added in v0.10.0 

func (m *RepoInfo) Reset()

func (*RepoInfo) Size added in v0.10.0 

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

func (*RepoInfo) String added in v0.10.0 

func (m *RepoInfo) String() string

func (*RepoInfo) Unmarshal added in v0.10.0 

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

func (*RepoInfo) XXX_DiscardUnknown added in v0.10.0 

func (m *RepoInfo) XXX_DiscardUnknown()

func (*RepoInfo) XXX_Marshal added in v0.10.0 

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

func (*RepoInfo) XXX_Merge added in v0.10.0 

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

func (*RepoInfo) XXX_Size added in v0.10.0 

func (m *RepoInfo) XXX_Size() int

func (*RepoInfo) XXX_Unmarshal added in v0.10.0 

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

type RoleInfo 

type RoleInfo struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status               string            `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	State                string            `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	FullPath             string            `protobuf:"bytes,4,opt,name=fullPath,proto3" json:"fullPath,omitempty"`
	TaskIds              []string          `protobuf:"bytes,5,rep,name=taskIds,proto3" json:"taskIds,omitempty"`
	Roles                []*RoleInfo       `protobuf:"bytes,6,rep,name=roles,proto3" json:"roles,omitempty"`
	Defaults             map[string]string `` /* 157-byte string literal not displayed */
	Vars                 map[string]string `` /* 149-byte string literal not displayed */
	UserVars             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RoleInfo) Descriptor 

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

func (*RoleInfo) GetDefaults added in v0.12.90 

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

func (*RoleInfo) GetFullPath 

func (m *RoleInfo) GetFullPath() string

func (*RoleInfo) GetName 

func (m *RoleInfo) GetName() string

func (*RoleInfo) GetRoles 

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

func (*RoleInfo) GetState 

func (m *RoleInfo) GetState() string

func (*RoleInfo) GetStatus 

func (m *RoleInfo) GetStatus() string

func (*RoleInfo) GetTaskIds 

func (m *RoleInfo) GetTaskIds() []string

func (*RoleInfo) GetUserVars added in v0.12.90 

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

func (*RoleInfo) GetVars added in v0.12.90 

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

func (*RoleInfo) Marshal 

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

func (*RoleInfo) MarshalTo 

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

func (*RoleInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*RoleInfo) ProtoMessage 

func (*RoleInfo) ProtoMessage()

func (*RoleInfo) Reset 

func (m *RoleInfo) Reset()

func (*RoleInfo) Size 

func (m *RoleInfo) Size() (n int)

func (*RoleInfo) String 

func (m *RoleInfo) String() string

func (*RoleInfo) Unmarshal 

func (m *RoleInfo) Unmarshal(dAtA []byte) error

func (*RoleInfo) XXX_DiscardUnknown 

func (m *RoleInfo) XXX_DiscardUnknown()

func (*RoleInfo) XXX_Marshal 

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

func (*RoleInfo) XXX_Merge 

func (m *RoleInfo) XXX_Merge(src proto.Message)

func (*RoleInfo) XXX_Size 

func (m *RoleInfo) XXX_Size() int

func (*RoleInfo) XXX_Unmarshal 

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

type SetDefaultRepoRequest added in v0.10.0 

type SetDefaultRepoRequest struct {
	Index                int32    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDefaultRepoRequest) Descriptor added in v0.10.0 

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

func (*SetDefaultRepoRequest) GetIndex added in v0.10.0 

func (m *SetDefaultRepoRequest) GetIndex() int32

func (*SetDefaultRepoRequest) Marshal added in v0.10.0 

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

func (*SetDefaultRepoRequest) MarshalTo added in v0.10.0 

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

func (*SetDefaultRepoRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*SetDefaultRepoRequest) ProtoMessage added in v0.10.0 

func (*SetDefaultRepoRequest) ProtoMessage()

func (*SetDefaultRepoRequest) Reset added in v0.10.0 

func (m *SetDefaultRepoRequest) Reset()

func (*SetDefaultRepoRequest) Size added in v0.10.0 

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

func (*SetDefaultRepoRequest) String added in v0.10.0 

func (m *SetDefaultRepoRequest) String() string

func (*SetDefaultRepoRequest) Unmarshal added in v0.10.0 

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

func (*SetDefaultRepoRequest) XXX_DiscardUnknown added in v0.10.0 

func (m *SetDefaultRepoRequest) XXX_DiscardUnknown()

func (*SetDefaultRepoRequest) XXX_Marshal added in v0.10.0 

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

func (*SetDefaultRepoRequest) XXX_Merge added in v0.10.0 

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

func (*SetDefaultRepoRequest) XXX_Size added in v0.10.0 

func (m *SetDefaultRepoRequest) XXX_Size() int

func (*SetDefaultRepoRequest) XXX_Unmarshal added in v0.10.0 

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

type SetEnvironmentPropertiesReply added in v0.12.90 

type SetEnvironmentPropertiesReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetEnvironmentPropertiesReply) Descriptor added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) Marshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) MarshalTo added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) MarshalToSizedBuffer added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) ProtoMessage added in v0.12.90 

func (*SetEnvironmentPropertiesReply) ProtoMessage()

func (*SetEnvironmentPropertiesReply) Reset added in v0.12.90 

func (m *SetEnvironmentPropertiesReply) Reset()

func (*SetEnvironmentPropertiesReply) Size added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) String added in v0.12.90 

func (m *SetEnvironmentPropertiesReply) String() string

func (*SetEnvironmentPropertiesReply) Unmarshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) XXX_DiscardUnknown added in v0.12.90 

func (m *SetEnvironmentPropertiesReply) XXX_DiscardUnknown()

func (*SetEnvironmentPropertiesReply) XXX_Marshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) XXX_Merge added in v0.12.90 

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

func (*SetEnvironmentPropertiesReply) XXX_Size added in v0.12.90 

func (m *SetEnvironmentPropertiesReply) XXX_Size() int

func (*SetEnvironmentPropertiesReply) XXX_Unmarshal added in v0.12.90 

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

type SetEnvironmentPropertiesRequest added in v0.12.90 

type SetEnvironmentPropertiesRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// If properties == nil, the core sets nothing
	// and reply ok
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

////////////////////////////////////// Environment, GET/SET properties //////////////////////////////////////

func (*SetEnvironmentPropertiesRequest) Descriptor added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) GetId added in v0.12.90 

func (m *SetEnvironmentPropertiesRequest) GetId() string

func (*SetEnvironmentPropertiesRequest) GetProperties added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) Marshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) MarshalTo added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) MarshalToSizedBuffer added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) ProtoMessage added in v0.12.90 

func (*SetEnvironmentPropertiesRequest) ProtoMessage()

func (*SetEnvironmentPropertiesRequest) Reset added in v0.12.90 

func (m *SetEnvironmentPropertiesRequest) Reset()

func (*SetEnvironmentPropertiesRequest) Size added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) String added in v0.12.90 

func (m *SetEnvironmentPropertiesRequest) String() string

func (*SetEnvironmentPropertiesRequest) Unmarshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) XXX_DiscardUnknown added in v0.12.90 

func (m *SetEnvironmentPropertiesRequest) XXX_DiscardUnknown()

func (*SetEnvironmentPropertiesRequest) XXX_Marshal added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) XXX_Merge added in v0.12.90 

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

func (*SetEnvironmentPropertiesRequest) XXX_Size added in v0.12.90 

func (m *SetEnvironmentPropertiesRequest) XXX_Size() int

func (*SetEnvironmentPropertiesRequest) XXX_Unmarshal added in v0.12.90 

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

type SetGlobalDefaultRevisionRequest added in v0.12.90 

type SetGlobalDefaultRevisionRequest struct {
	Revision             string   `protobuf:"bytes,1,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetGlobalDefaultRevisionRequest) Descriptor added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) GetRevision added in v0.12.90 

func (m *SetGlobalDefaultRevisionRequest) GetRevision() string

func (*SetGlobalDefaultRevisionRequest) Marshal added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) MarshalTo added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) MarshalToSizedBuffer added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) ProtoMessage added in v0.12.90 

func (*SetGlobalDefaultRevisionRequest) ProtoMessage()

func (*SetGlobalDefaultRevisionRequest) Reset added in v0.12.90 

func (m *SetGlobalDefaultRevisionRequest) Reset()

func (*SetGlobalDefaultRevisionRequest) Size added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) String added in v0.12.90 

func (m *SetGlobalDefaultRevisionRequest) String() string

func (*SetGlobalDefaultRevisionRequest) Unmarshal added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) XXX_DiscardUnknown added in v0.12.90 

func (m *SetGlobalDefaultRevisionRequest) XXX_DiscardUnknown()

func (*SetGlobalDefaultRevisionRequest) XXX_Marshal added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) XXX_Merge added in v0.12.90 

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

func (*SetGlobalDefaultRevisionRequest) XXX_Size added in v0.12.90 

func (m *SetGlobalDefaultRevisionRequest) XXX_Size() int

func (*SetGlobalDefaultRevisionRequest) XXX_Unmarshal added in v0.12.90 

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

type SetRepoDefaultRevisionReply added in v0.12.90 

type SetRepoDefaultRevisionReply struct {
	Info                 string   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRepoDefaultRevisionReply) Descriptor added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) GetInfo added in v0.12.90 

func (m *SetRepoDefaultRevisionReply) GetInfo() string

func (*SetRepoDefaultRevisionReply) Marshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) MarshalTo added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) MarshalToSizedBuffer added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) ProtoMessage added in v0.12.90 

func (*SetRepoDefaultRevisionReply) ProtoMessage()

func (*SetRepoDefaultRevisionReply) Reset added in v0.12.90 

func (m *SetRepoDefaultRevisionReply) Reset()

func (*SetRepoDefaultRevisionReply) Size added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) String added in v0.12.90 

func (m *SetRepoDefaultRevisionReply) String() string

func (*SetRepoDefaultRevisionReply) Unmarshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) XXX_DiscardUnknown added in v0.12.90 

func (m *SetRepoDefaultRevisionReply) XXX_DiscardUnknown()

func (*SetRepoDefaultRevisionReply) XXX_Marshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) XXX_Merge added in v0.12.90 

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

func (*SetRepoDefaultRevisionReply) XXX_Size added in v0.12.90 

func (m *SetRepoDefaultRevisionReply) XXX_Size() int

func (*SetRepoDefaultRevisionReply) XXX_Unmarshal added in v0.12.90 

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

type SetRepoDefaultRevisionRequest added in v0.12.90 

type SetRepoDefaultRevisionRequest struct {
	Index                int32    `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Revision             string   `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRepoDefaultRevisionRequest) Descriptor added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) GetIndex added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) GetIndex() int32

func (*SetRepoDefaultRevisionRequest) GetRevision added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) GetRevision() string

func (*SetRepoDefaultRevisionRequest) Marshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) MarshalTo added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) MarshalToSizedBuffer added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) ProtoMessage added in v0.12.90 

func (*SetRepoDefaultRevisionRequest) ProtoMessage()

func (*SetRepoDefaultRevisionRequest) Reset added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) Reset()

func (*SetRepoDefaultRevisionRequest) Size added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) String added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) String() string

func (*SetRepoDefaultRevisionRequest) Unmarshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) XXX_DiscardUnknown added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) XXX_DiscardUnknown()

func (*SetRepoDefaultRevisionRequest) XXX_Marshal added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) XXX_Merge added in v0.12.90 

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

func (*SetRepoDefaultRevisionRequest) XXX_Size added in v0.12.90 

func (m *SetRepoDefaultRevisionRequest) XXX_Size() int

func (*SetRepoDefaultRevisionRequest) XXX_Unmarshal added in v0.12.90 

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

type ShortTaskInfo 

type ShortTaskInfo struct {
	Name                 string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Locked               bool                `protobuf:"varint,2,opt,name=locked,proto3" json:"locked,omitempty"`
	TaskId               string              `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Status               string              `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	State                string              `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	ClassName            string              `protobuf:"bytes,6,opt,name=className,proto3" json:"className,omitempty"`
	DeploymentInfo       *TaskDeploymentInfo `protobuf:"bytes,7,opt,name=deploymentInfo,proto3" json:"deploymentInfo,omitempty"`
	Pid                  string              `protobuf:"bytes,8,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

////////////////////////////////////// Tasks //////////////////////////////////////

func (*ShortTaskInfo) Descriptor 

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

func (*ShortTaskInfo) GetClassName 

func (m *ShortTaskInfo) GetClassName() string

func (*ShortTaskInfo) GetDeploymentInfo 

func (m *ShortTaskInfo) GetDeploymentInfo() *TaskDeploymentInfo

func (*ShortTaskInfo) GetLocked 

func (m *ShortTaskInfo) GetLocked() bool

func (*ShortTaskInfo) GetName 

func (m *ShortTaskInfo) GetName() string

func (*ShortTaskInfo) GetPid added in v0.14.91 

func (m *ShortTaskInfo) GetPid() string

func (*ShortTaskInfo) GetState 

func (m *ShortTaskInfo) GetState() string

func (*ShortTaskInfo) GetStatus 

func (m *ShortTaskInfo) GetStatus() string

func (*ShortTaskInfo) GetTaskId 

func (m *ShortTaskInfo) GetTaskId() string

func (*ShortTaskInfo) Marshal 

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

func (*ShortTaskInfo) MarshalTo 

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

func (*ShortTaskInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*ShortTaskInfo) ProtoMessage 

func (*ShortTaskInfo) ProtoMessage()

func (*ShortTaskInfo) Reset 

func (m *ShortTaskInfo) Reset()

func (*ShortTaskInfo) Size 

func (m *ShortTaskInfo) Size() (n int)

func (*ShortTaskInfo) String 

func (m *ShortTaskInfo) String() string

func (*ShortTaskInfo) Unmarshal 

func (m *ShortTaskInfo) Unmarshal(dAtA []byte) error

func (*ShortTaskInfo) XXX_DiscardUnknown 

func (m *ShortTaskInfo) XXX_DiscardUnknown()

func (*ShortTaskInfo) XXX_Marshal 

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

func (*ShortTaskInfo) XXX_Merge 

func (m *ShortTaskInfo) XXX_Merge(src proto.Message)

func (*ShortTaskInfo) XXX_Size 

func (m *ShortTaskInfo) XXX_Size() int

func (*ShortTaskInfo) XXX_Unmarshal 

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

type StatusReply 

type StatusReply struct {
	State                string          `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	StatusUpdates        []*StatusUpdate `protobuf:"bytes,2,rep,name=statusUpdates,proto3" json:"statusUpdates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StatusReply) Descriptor 

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

func (*StatusReply) GetState 

func (m *StatusReply) GetState() string

func (*StatusReply) GetStatusUpdates 

func (m *StatusReply) GetStatusUpdates() []*StatusUpdate

func (*StatusReply) Marshal 

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

func (*StatusReply) MarshalTo 

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

func (*StatusReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*StatusReply) ProtoMessage 

func (*StatusReply) ProtoMessage()

func (*StatusReply) Reset 

func (m *StatusReply) Reset()

func (*StatusReply) Size 

func (m *StatusReply) Size() (n int)

func (*StatusReply) String 

func (m *StatusReply) String() string

func (*StatusReply) Unmarshal 

func (m *StatusReply) Unmarshal(dAtA []byte) error

func (*StatusReply) XXX_DiscardUnknown 

func (m *StatusReply) XXX_DiscardUnknown()

func (*StatusReply) XXX_Marshal 

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

func (*StatusReply) XXX_Merge 

func (m *StatusReply) XXX_Merge(src proto.Message)

func (*StatusReply) XXX_Size 

func (m *StatusReply) XXX_Size() int

func (*StatusReply) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

////////////////////////////////////// Global status //////////////////////////////////////

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) Marshal 

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

func (*StatusRequest) MarshalTo 

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

func (*StatusRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

func (m *StatusRequest) Size() (n int)

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

func (m *StatusRequest) Unmarshal(dAtA []byte) error

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

func (m *StatusRequest) XXX_Merge(src proto.Message)

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusUpdate 

type StatusUpdate struct {
	Level StatusUpdate_Level `protobuf:"varint,1,opt,name=level,proto3,enum=o2control.StatusUpdate_Level" json:"level,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*StatusUpdate_MesosHeartbeat
	Event                isStatusUpdate_Event `protobuf_oneof:"Event"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StatusUpdate) Descriptor 

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

func (*StatusUpdate) GetEvent 

func (m *StatusUpdate) GetEvent() isStatusUpdate_Event

func (*StatusUpdate) GetLevel 

func (m *StatusUpdate) GetLevel() StatusUpdate_Level

func (*StatusUpdate) GetMesosHeartbeat 

func (m *StatusUpdate) GetMesosHeartbeat() *Event_MesosHeartbeat

func (*StatusUpdate) Marshal 

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

func (*StatusUpdate) MarshalTo 

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

func (*StatusUpdate) MarshalToSizedBuffer added in v0.11.0 

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

func (*StatusUpdate) ProtoMessage 

func (*StatusUpdate) ProtoMessage()

func (*StatusUpdate) Reset 

func (m *StatusUpdate) Reset()

func (*StatusUpdate) Size 

func (m *StatusUpdate) Size() (n int)

func (*StatusUpdate) String 

func (m *StatusUpdate) String() string

func (*StatusUpdate) Unmarshal 

func (m *StatusUpdate) Unmarshal(dAtA []byte) error

func (*StatusUpdate) XXX_DiscardUnknown 

func (m *StatusUpdate) XXX_DiscardUnknown()

func (*StatusUpdate) XXX_Marshal 

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

func (*StatusUpdate) XXX_Merge 

func (m *StatusUpdate) XXX_Merge(src proto.Message)

func (*StatusUpdate) XXX_OneofWrappers added in v0.11.0 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StatusUpdate) XXX_Size 

func (m *StatusUpdate) XXX_Size() int

func (*StatusUpdate) XXX_Unmarshal 

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

type StatusUpdate_Level 

type StatusUpdate_Level int32
const (
	StatusUpdate_DEBUG   StatusUpdate_Level = 0
	StatusUpdate_INFO    StatusUpdate_Level = 1
	StatusUpdate_WARNING StatusUpdate_Level = 2
	StatusUpdate_ERROR   StatusUpdate_Level = 3
)

func (StatusUpdate_Level) EnumDescriptor 

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

func (StatusUpdate_Level) String 

func (x StatusUpdate_Level) String() string

type StatusUpdate_MesosHeartbeat 

type StatusUpdate_MesosHeartbeat struct {
	MesosHeartbeat *Event_MesosHeartbeat `protobuf:"bytes,2,opt,name=mesosHeartbeat,proto3,oneof" json:"mesosHeartbeat,omitempty"`
}

func (*StatusUpdate_MesosHeartbeat) MarshalTo 

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

func (*StatusUpdate_MesosHeartbeat) MarshalToSizedBuffer added in v0.11.0 

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

func (*StatusUpdate_MesosHeartbeat) Size 

func (m *StatusUpdate_MesosHeartbeat) Size() (n int)

type SubscribeRequest added in v0.14.4 

type SubscribeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeRequest) Descriptor added in v0.14.4 

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

func (*SubscribeRequest) Marshal added in v0.14.4 

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

func (*SubscribeRequest) MarshalTo added in v0.14.4 

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

func (*SubscribeRequest) MarshalToSizedBuffer added in v0.14.4 

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

func (*SubscribeRequest) ProtoMessage added in v0.14.4 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset added in v0.14.4 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size added in v0.14.4 

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

func (*SubscribeRequest) String added in v0.14.4 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal added in v0.14.4 

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

func (*SubscribeRequest) XXX_DiscardUnknown added in v0.14.4 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal added in v0.14.4 

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

func (*SubscribeRequest) XXX_Merge added in v0.14.4 

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

func (*SubscribeRequest) XXX_Size added in v0.14.4 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal added in v0.14.4 

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

type TaskClassInfo 

type TaskClassInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ControlMode          string   `protobuf:"bytes,2,opt,name=controlMode,proto3" json:"controlMode,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskClassInfo) Descriptor 

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

func (*TaskClassInfo) GetControlMode 

func (m *TaskClassInfo) GetControlMode() string

func (*TaskClassInfo) GetName 

func (m *TaskClassInfo) GetName() string

func (*TaskClassInfo) Marshal 

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

func (*TaskClassInfo) MarshalTo 

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

func (*TaskClassInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*TaskClassInfo) ProtoMessage 

func (*TaskClassInfo) ProtoMessage()

func (*TaskClassInfo) Reset 

func (m *TaskClassInfo) Reset()

func (*TaskClassInfo) Size 

func (m *TaskClassInfo) Size() (n int)

func (*TaskClassInfo) String 

func (m *TaskClassInfo) String() string

func (*TaskClassInfo) Unmarshal 

func (m *TaskClassInfo) Unmarshal(dAtA []byte) error

func (*TaskClassInfo) XXX_DiscardUnknown 

func (m *TaskClassInfo) XXX_DiscardUnknown()

func (*TaskClassInfo) XXX_Marshal 

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

func (*TaskClassInfo) XXX_Merge 

func (m *TaskClassInfo) XXX_Merge(src proto.Message)

func (*TaskClassInfo) XXX_Size 

func (m *TaskClassInfo) XXX_Size() int

func (*TaskClassInfo) XXX_Unmarshal 

func (m *TaskClassInfo) XXX_Unmarshal(b []byte) error

type TaskDeploymentInfo 

type TaskDeploymentInfo struct {
	Hostname             string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	AgentId              string   `protobuf:"bytes,2,opt,name=agentId,proto3" json:"agentId,omitempty"`
	OfferId              string   `protobuf:"bytes,3,opt,name=offerId,proto3" json:"offerId,omitempty"`
	ExecutorId           string   `protobuf:"bytes,4,opt,name=executorId,proto3" json:"executorId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskDeploymentInfo) Descriptor 

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

func (*TaskDeploymentInfo) GetAgentId 

func (m *TaskDeploymentInfo) GetAgentId() string

func (*TaskDeploymentInfo) GetExecutorId 

func (m *TaskDeploymentInfo) GetExecutorId() string

func (*TaskDeploymentInfo) GetHostname 

func (m *TaskDeploymentInfo) GetHostname() string

func (*TaskDeploymentInfo) GetOfferId 

func (m *TaskDeploymentInfo) GetOfferId() string

func (*TaskDeploymentInfo) Marshal 

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

func (*TaskDeploymentInfo) MarshalTo 

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

func (*TaskDeploymentInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*TaskDeploymentInfo) ProtoMessage 

func (*TaskDeploymentInfo) ProtoMessage()

func (*TaskDeploymentInfo) Reset 

func (m *TaskDeploymentInfo) Reset()

func (*TaskDeploymentInfo) Size 

func (m *TaskDeploymentInfo) Size() (n int)

func (*TaskDeploymentInfo) String 

func (m *TaskDeploymentInfo) String() string

func (*TaskDeploymentInfo) Unmarshal 

func (m *TaskDeploymentInfo) Unmarshal(dAtA []byte) error

func (*TaskDeploymentInfo) XXX_DiscardUnknown 

func (m *TaskDeploymentInfo) XXX_DiscardUnknown()

func (*TaskDeploymentInfo) XXX_Marshal 

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

func (*TaskDeploymentInfo) XXX_Merge 

func (m *TaskDeploymentInfo) XXX_Merge(src proto.Message)

func (*TaskDeploymentInfo) XXX_Size 

func (m *TaskDeploymentInfo) XXX_Size() int

func (*TaskDeploymentInfo) XXX_Unmarshal 

func (m *TaskDeploymentInfo) XXX_Unmarshal(b []byte) error

type TaskInfo 

type TaskInfo struct {
	ShortInfo            *ShortTaskInfo    `protobuf:"bytes,1,opt,name=shortInfo,proto3" json:"shortInfo,omitempty"`
	ClassInfo            *TaskClassInfo    `protobuf:"bytes,2,opt,name=classInfo,proto3" json:"classInfo,omitempty"`
	InboundChannels      []*ChannelInfo    `protobuf:"bytes,3,rep,name=inboundChannels,proto3" json:"inboundChannels,omitempty"`
	OutboundChannels     []*ChannelInfo    `protobuf:"bytes,4,rep,name=outboundChannels,proto3" json:"outboundChannels,omitempty"`
	CommandInfo          *CommandInfo      `protobuf:"bytes,5,opt,name=commandInfo,proto3" json:"commandInfo,omitempty"`
	TaskPath             string            `protobuf:"bytes,6,opt,name=taskPath,proto3" json:"taskPath,omitempty"`
	EnvId                string            `protobuf:"bytes,7,opt,name=envId,proto3" json:"envId,omitempty"`
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TaskInfo) Descriptor 

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

func (*TaskInfo) GetClassInfo 

func (m *TaskInfo) GetClassInfo() *TaskClassInfo

func (*TaskInfo) GetCommandInfo 

func (m *TaskInfo) GetCommandInfo() *CommandInfo

func (*TaskInfo) GetEnvId 

func (m *TaskInfo) GetEnvId() string

func (*TaskInfo) GetInboundChannels 

func (m *TaskInfo) GetInboundChannels() []*ChannelInfo

func (*TaskInfo) GetOutboundChannels 

func (m *TaskInfo) GetOutboundChannels() []*ChannelInfo

func (*TaskInfo) GetProperties added in v0.12.90 

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

func (*TaskInfo) GetShortInfo 

func (m *TaskInfo) GetShortInfo() *ShortTaskInfo

func (*TaskInfo) GetTaskPath 

func (m *TaskInfo) GetTaskPath() string

func (*TaskInfo) Marshal 

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

func (*TaskInfo) MarshalTo 

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

func (*TaskInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) Size 

func (m *TaskInfo) Size() (n int)

func (*TaskInfo) String 

func (m *TaskInfo) String() string

func (*TaskInfo) Unmarshal 

func (m *TaskInfo) Unmarshal(dAtA []byte) error

func (*TaskInfo) XXX_DiscardUnknown 

func (m *TaskInfo) XXX_DiscardUnknown()

func (*TaskInfo) XXX_Marshal 

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

func (*TaskInfo) XXX_Merge 

func (m *TaskInfo) XXX_Merge(src proto.Message)

func (*TaskInfo) XXX_Size 

func (m *TaskInfo) XXX_Size() int

func (*TaskInfo) XXX_Unmarshal 

func (m *TaskInfo) XXX_Unmarshal(b []byte) error

type TeardownReply 

type TeardownReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TeardownReply) Descriptor 

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

func (*TeardownReply) Marshal 

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

func (*TeardownReply) MarshalTo 

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

func (*TeardownReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*TeardownReply) ProtoMessage 

func (*TeardownReply) ProtoMessage()

func (*TeardownReply) Reset 

func (m *TeardownReply) Reset()

func (*TeardownReply) Size 

func (m *TeardownReply) Size() (n int)

func (*TeardownReply) String 

func (m *TeardownReply) String() string

func (*TeardownReply) Unmarshal 

func (m *TeardownReply) Unmarshal(dAtA []byte) error

func (*TeardownReply) XXX_DiscardUnknown 

func (m *TeardownReply) XXX_DiscardUnknown()

func (*TeardownReply) XXX_Marshal 

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

func (*TeardownReply) XXX_Merge 

func (m *TeardownReply) XXX_Merge(src proto.Message)

func (*TeardownReply) XXX_Size 

func (m *TeardownReply) XXX_Size() int

func (*TeardownReply) XXX_Unmarshal 

func (m *TeardownReply) XXX_Unmarshal(b []byte) error

type TeardownRequest 

type TeardownRequest struct {
	Reason               string   `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Not implemented yet

func (*TeardownRequest) Descriptor 

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

func (*TeardownRequest) GetReason 

func (m *TeardownRequest) GetReason() string

func (*TeardownRequest) Marshal 

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

func (*TeardownRequest) MarshalTo 

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

func (*TeardownRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*TeardownRequest) ProtoMessage 

func (*TeardownRequest) ProtoMessage()

func (*TeardownRequest) Reset 

func (m *TeardownRequest) Reset()

func (*TeardownRequest) Size 

func (m *TeardownRequest) Size() (n int)

func (*TeardownRequest) String 

func (m *TeardownRequest) String() string

func (*TeardownRequest) Unmarshal 

func (m *TeardownRequest) Unmarshal(dAtA []byte) error

func (*TeardownRequest) XXX_DiscardUnknown 

func (m *TeardownRequest) XXX_DiscardUnknown()

func (*TeardownRequest) XXX_Marshal 

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

func (*TeardownRequest) XXX_Merge 

func (m *TeardownRequest) XXX_Merge(src proto.Message)

func (*TeardownRequest) XXX_Size 

func (m *TeardownRequest) XXX_Size() int

func (*TeardownRequest) XXX_Unmarshal 

func (m *TeardownRequest) XXX_Unmarshal(b []byte) error

type UnimplementedControlServer added in v0.11.0 

type UnimplementedControlServer struct {
}

UnimplementedControlServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlServer) AddRepo added in v0.11.0 

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

func (*UnimplementedControlServer) CleanupTasks added in v0.11.0 

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

func (*UnimplementedControlServer) ControlEnvironment added in v0.11.0 

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

func (*UnimplementedControlServer) DestroyEnvironment added in v0.11.0 

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

func (*UnimplementedControlServer) GetEnvironment added in v0.11.0 

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

func (*UnimplementedControlServer) GetEnvironments added in v0.11.0 

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

func (*UnimplementedControlServer) GetFrameworkInfo added in v0.11.0 

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

func (*UnimplementedControlServer) GetRoles added in v0.11.0 

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

func (*UnimplementedControlServer) GetTask added in v0.11.0 

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

func (*UnimplementedControlServer) GetTasks added in v0.11.0 

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

func (*UnimplementedControlServer) GetWorkflowTemplates added in v0.11.0 

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

func (*UnimplementedControlServer) ListRepos added in v0.11.0 

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

func (*UnimplementedControlServer) ModifyEnvironment added in v0.11.0 

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

func (*UnimplementedControlServer) NewEnvironment added in v0.11.0 

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

func (*UnimplementedControlServer) RefreshRepos added in v0.11.0 

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

func (*UnimplementedControlServer) RemoveRepo added in v0.11.0 

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

func (*UnimplementedControlServer) SetDefaultRepo added in v0.11.0 

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

func (*UnimplementedControlServer) SetGlobalDefaultRevision added in v0.12.90 

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

func (*UnimplementedControlServer) SetRepoDefaultRevision added in v0.12.90 

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

func (*UnimplementedControlServer) Subscribe added in v0.14.4 

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

func (*UnimplementedControlServer) Teardown added in v0.11.0 

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

func (*UnimplementedControlServer) TrackStatus added in v0.11.0 

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

type Version added in v0.7.0 

type Version struct {
	Major                int32    `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor                int32    `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch                int32    `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	Build                string   `protobuf:"bytes,4,opt,name=build,proto3" json:"build,omitempty"`
	ProductName          string   `protobuf:"bytes,5,opt,name=productName,proto3" json:"productName,omitempty"`
	VersionStr           string   `protobuf:"bytes,6,opt,name=versionStr,proto3" json:"versionStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Version) Descriptor added in v0.7.0 

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

func (*Version) GetBuild added in v0.7.0 

func (m *Version) GetBuild() string

func (*Version) GetMajor added in v0.7.0 

func (m *Version) GetMajor() int32

func (*Version) GetMinor added in v0.7.0 

func (m *Version) GetMinor() int32

func (*Version) GetPatch added in v0.7.0 

func (m *Version) GetPatch() int32

func (*Version) GetProductName added in v0.7.0 

func (m *Version) GetProductName() string

func (*Version) GetVersionStr added in v0.7.0 

func (m *Version) GetVersionStr() string

func (*Version) Marshal added in v0.7.0 

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

func (*Version) MarshalTo added in v0.7.0 

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

func (*Version) MarshalToSizedBuffer added in v0.11.0 

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

func (*Version) ProtoMessage added in v0.7.0 

func (*Version) ProtoMessage()

func (*Version) Reset added in v0.7.0 

func (m *Version) Reset()

func (*Version) Size added in v0.7.0 

func (m *Version) Size() (n int)

func (*Version) String added in v0.7.0 

func (m *Version) String() string

func (*Version) Unmarshal added in v0.7.0 

func (m *Version) Unmarshal(dAtA []byte) error

func (*Version) XXX_DiscardUnknown added in v0.7.0 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal added in v0.7.0 

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

func (*Version) XXX_Merge added in v0.7.0 

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size added in v0.7.0 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal added in v0.7.0 

func (m *Version) XXX_Unmarshal(b []byte) error

type WorkflowTemplateInfo added in v0.10.0 

type WorkflowTemplateInfo struct {
	Repo                 string   `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Template             string   `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	Revision             string   `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowTemplateInfo) Descriptor added in v0.10.0 

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

func (*WorkflowTemplateInfo) GetRepo added in v0.10.0 

func (m *WorkflowTemplateInfo) GetRepo() string

func (*WorkflowTemplateInfo) GetRevision added in v0.11.0 

func (m *WorkflowTemplateInfo) GetRevision() string

func (*WorkflowTemplateInfo) GetTemplate added in v0.10.0 

func (m *WorkflowTemplateInfo) GetTemplate() string

func (*WorkflowTemplateInfo) Marshal added in v0.10.0 

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

func (*WorkflowTemplateInfo) MarshalTo added in v0.10.0 

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

func (*WorkflowTemplateInfo) MarshalToSizedBuffer added in v0.11.0 

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

func (*WorkflowTemplateInfo) ProtoMessage added in v0.10.0 

func (*WorkflowTemplateInfo) ProtoMessage()

func (*WorkflowTemplateInfo) Reset added in v0.10.0 

func (m *WorkflowTemplateInfo) Reset()

func (*WorkflowTemplateInfo) Size added in v0.10.0 

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

func (*WorkflowTemplateInfo) String added in v0.10.0 

func (m *WorkflowTemplateInfo) String() string

func (*WorkflowTemplateInfo) Unmarshal added in v0.10.0 

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

func (*WorkflowTemplateInfo) XXX_DiscardUnknown added in v0.10.0 

func (m *WorkflowTemplateInfo) XXX_DiscardUnknown()

func (*WorkflowTemplateInfo) XXX_Marshal added in v0.10.0 

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

func (*WorkflowTemplateInfo) XXX_Merge added in v0.10.0 

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

func (*WorkflowTemplateInfo) XXX_Size added in v0.10.0 

func (m *WorkflowTemplateInfo) XXX_Size() int

func (*WorkflowTemplateInfo) XXX_Unmarshal added in v0.10.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.