mesosproto

package
v1.0.0-alpha Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2014 License: Apache-2.0 Imports: 2 Imported by: 3

Documentation

Overview

Package mesos is a generated protocol buffer package.

It is generated from these files: 

mesos.proto

It has these top-level messages: 

FrameworkID
OfferID
SlaveID
TaskID
ExecutorID
ContainerID
FrameworkInfo
HealthCheck
CommandInfo
ExecutorInfo
MasterInfo
SlaveInfo
Value
Attribute
Resource
ResourceStatistics
ResourceUsage
PerfStatistics
Request
Offer
TaskInfo
TaskStatus
Filters
Environment
Parameter
Parameters
Credential
Credentials
ACL
ACLs
RateLimit
RateLimits
Volume
ContainerInfo

Package mesos_internal is a generated protocol buffer package.

It is generated from these files: 

messages.proto

It has these top-level messages: 

Task
RoleInfo
StatusUpdate
StatusUpdateRecord
SubmitSchedulerRequest
SubmitSchedulerResponse
ExecutorToFrameworkMessage
FrameworkToExecutorMessage
RegisterFrameworkMessage
ReregisterFrameworkMessage
FrameworkRegisteredMessage
FrameworkReregisteredMessage
UnregisterFrameworkMessage
DeactivateFrameworkMessage
ResourceRequestMessage
ResourceOffersMessage
LaunchTasksMessage
RescindResourceOfferMessage
ReviveOffersMessage
RunTaskMessage
KillTaskMessage
StatusUpdateMessage
StatusUpdateAcknowledgementMessage
LostSlaveMessage
ReconcileTasksMessage
FrameworkErrorMessage
RegisterSlaveMessage
ReregisterSlaveMessage
SlaveRegisteredMessage
SlaveReregisteredMessage
UnregisterSlaveMessage
HeartbeatMessage
ShutdownFrameworkMessage
ShutdownExecutorMessage
UpdateFrameworkMessage
RegisterExecutorMessage
ExecutorRegisteredMessage
ExecutorReregisteredMessage
ExitedExecutorMessage
ReconnectExecutorMessage
ReregisterExecutorMessage
RegisterProjdMessage
ProjdReadyMessage
ProjdUpdateResourcesMessage
FrameworkExpiredMessage
ShutdownMessage
AuthenticateMessage
AuthenticationMechanismsMessage
AuthenticationStartMessage
AuthenticationStepMessage
AuthenticationCompletedMessage
AuthenticationFailedMessage
AuthenticationErrorMessage
Archive
TaskHealthStatus

Package mesos_scheduler is a generated protocol buffer package.

It is generated from these files: 

scheduler.proto

It has these top-level messages: 

Event
Call

Index

Constants

View Source 
const Default_ACLs_Permissive bool = true
View Source 
const Default_CommandInfo_Shell bool = true
View Source 
const Default_CommandInfo_URI_Extract bool = true
View Source 
const Default_Filters_RefuseSeconds float64 = 5
View Source 
const Default_FrameworkInfo_Checkpoint bool = false
View Source 
const Default_FrameworkInfo_FailoverTimeout float64 = 0
View Source 
const Default_FrameworkInfo_Role string = "*"
View Source 
const Default_HealthCheck_ConsecutiveFailures uint32 = 3
View Source 
const Default_HealthCheck_DelaySeconds float64 = 15
View Source 
const Default_HealthCheck_GracePeriodSeconds float64 = 10
View Source 
const Default_HealthCheck_HTTP_Path string = "/"
View Source 
const Default_HealthCheck_IntervalSeconds float64 = 10
View Source 
const Default_HealthCheck_TimeoutSeconds float64 = 20
View Source 
const Default_MasterInfo_Port uint32 = 5050
View Source 
const Default_Resource_Role string = "*"
View Source 
const Default_RoleInfo_Weight float64 = 1
View Source 
const Default_SlaveInfo_Checkpoint bool = false
View Source 
const Default_SlaveInfo_Port int32 = 5051
View Source 
const Default_SlaveInfo_WebuiPort int32 = 8081
View Source 
const Default_TaskHealthStatus_KillTask bool = false

Variables

View Source 
var ACL_Entity_Type_name = map[int32]string{
	0: "SOME",
	1: "ANY",
	2: "NONE",
}
View Source 
var ACL_Entity_Type_value = map[string]int32{
	"SOME": 0,
	"ANY":  1,
	"NONE": 2,
}
View Source 
var Call_Type_name = map[int32]string{
	1:  "REGISTER",
	2:  "REREGISTER",
	3:  "UNREGISTER",
	4:  "REQUEST",
	5:  "DECLINE",
	6:  "REVIVE",
	7:  "LAUNCH",
	8:  "KILL",
	9:  "ACKNOWLEDGE",
	10: "RECONCILE",
	11: "MESSAGE",
}
View Source 
var Call_Type_value = map[string]int32{
	"REGISTER":    1,
	"REREGISTER":  2,
	"UNREGISTER":  3,
	"REQUEST":     4,
	"DECLINE":     5,
	"REVIVE":      6,
	"LAUNCH":      7,
	"KILL":        8,
	"ACKNOWLEDGE": 9,
	"RECONCILE":   10,
	"MESSAGE":     11,
}
View Source 
var ContainerInfo_Type_name = map[int32]string{
	1: "DOCKER",
}
View Source 
var ContainerInfo_Type_value = map[string]int32{
	"DOCKER": 1,
}
View Source 
var Event_Type_name = map[int32]string{
	1: "REGISTERED",
	2: "REREGISTERED",
	3: "OFFERS",
	4: "RESCIND",
	5: "UPDATE",
	6: "MESSAGE",
	7: "FAILURE",
	8: "ERROR",
}
View Source 
var Event_Type_value = map[string]int32{
	"REGISTERED":   1,
	"REREGISTERED": 2,
	"OFFERS":       3,
	"RESCIND":      4,
	"UPDATE":       5,
	"MESSAGE":      6,
	"FAILURE":      7,
	"ERROR":        8,
}
View Source 
var StatusUpdateRecord_Type_name = map[int32]string{
	0: "UPDATE",
	1: "ACK",
}
View Source 
var StatusUpdateRecord_Type_value = map[string]int32{
	"UPDATE": 0,
	"ACK":    1,
}
View Source 
var Status_name = map[int32]string{
	1: "DRIVER_NOT_STARTED",
	2: "DRIVER_RUNNING",
	3: "DRIVER_ABORTED",
	4: "DRIVER_STOPPED",
}
View Source 
var Status_value = map[string]int32{
	"DRIVER_NOT_STARTED": 1,
	"DRIVER_RUNNING":     2,
	"DRIVER_ABORTED":     3,
	"DRIVER_STOPPED":     4,
}
View Source 
var TaskState_name = map[int32]string{
	6: "TASK_STAGING",
	0: "TASK_STARTING",
	1: "TASK_RUNNING",
	2: "TASK_FINISHED",
	3: "TASK_FAILED",
	4: "TASK_KILLED",
	5: "TASK_LOST",
}
View Source 
var TaskState_value = map[string]int32{
	"TASK_STAGING":  6,
	"TASK_STARTING": 0,
	"TASK_RUNNING":  1,
	"TASK_FINISHED": 2,
	"TASK_FAILED":   3,
	"TASK_KILLED":   4,
	"TASK_LOST":     5,
}
View Source 
var Value_Type_name = map[int32]string{
	0: "SCALAR",
	1: "RANGES",
	2: "SET",
	3: "TEXT",
}
View Source 
var Value_Type_value = map[string]int32{
	"SCALAR": 0,
	"RANGES": 1,
	"SET":    2,
	"TEXT":   3,
}
View Source 
var Volume_Mode_name = map[int32]string{
	1: "RW",
	2: "RO",
}
View Source 
var Volume_Mode_value = map[string]int32{
	"RW": 1,
	"RO": 2,
}

Functions

This section is empty.

Types

type ACL 

type ACL struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ACL) ProtoMessage 

func (*ACL) ProtoMessage()

func (*ACL) Reset 

func (m *ACL) Reset()

func (*ACL) String 

func (m *ACL) String() string

type ACL_Entity 

type ACL_Entity struct {
	Type             *ACL_Entity_Type `protobuf:"varint,1,opt,name=type,enum=mesos.ACL_Entity_Type,def=0" json:"type,omitempty"`
	Values           []string         `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*ACL_Entity) GetType 

func (m *ACL_Entity) GetType() ACL_Entity_Type

func (*ACL_Entity) GetValues 

func (m *ACL_Entity) GetValues() []string

func (*ACL_Entity) ProtoMessage 

func (*ACL_Entity) ProtoMessage()

func (*ACL_Entity) Reset 

func (m *ACL_Entity) Reset()

func (*ACL_Entity) String 

func (m *ACL_Entity) String() string

type ACL_Entity_Type 

type ACL_Entity_Type int32
const (
	ACL_Entity_SOME ACL_Entity_Type = 0
	ACL_Entity_ANY  ACL_Entity_Type = 1
	ACL_Entity_NONE ACL_Entity_Type = 2
)
const Default_ACL_Entity_Type ACL_Entity_Type = ACL_Entity_SOME

func (ACL_Entity_Type) Enum 

func (x ACL_Entity_Type) Enum() *ACL_Entity_Type

func (ACL_Entity_Type) String 

func (x ACL_Entity_Type) String() string

func (*ACL_Entity_Type) UnmarshalJSON 

func (x *ACL_Entity_Type) UnmarshalJSON(data []byte) error

type ACL_RegisterFramework 

type ACL_RegisterFramework struct {
	Principals       *ACL_Entity `protobuf:"bytes,1,req,name=principals" json:"principals,omitempty"`
	Roles            *ACL_Entity `protobuf:"bytes,2,req,name=roles" json:"roles,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ACL_RegisterFramework) GetPrincipals 

func (m *ACL_RegisterFramework) GetPrincipals() *ACL_Entity

func (*ACL_RegisterFramework) GetRoles 

func (m *ACL_RegisterFramework) GetRoles() *ACL_Entity

func (*ACL_RegisterFramework) ProtoMessage 

func (*ACL_RegisterFramework) ProtoMessage()

func (*ACL_RegisterFramework) Reset 

func (m *ACL_RegisterFramework) Reset()

func (*ACL_RegisterFramework) String 

func (m *ACL_RegisterFramework) String() string

type ACL_RunTask 

type ACL_RunTask struct {
	Principals       *ACL_Entity `protobuf:"bytes,1,req,name=principals" json:"principals,omitempty"`
	Users            *ACL_Entity `protobuf:"bytes,2,req,name=users" json:"users,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ACL_RunTask) GetPrincipals 

func (m *ACL_RunTask) GetPrincipals() *ACL_Entity

func (*ACL_RunTask) GetUsers 

func (m *ACL_RunTask) GetUsers() *ACL_Entity

func (*ACL_RunTask) ProtoMessage 

func (*ACL_RunTask) ProtoMessage()

func (*ACL_RunTask) Reset 

func (m *ACL_RunTask) Reset()

func (*ACL_RunTask) String 

func (m *ACL_RunTask) String() string

type ACL_ShutdownFramework 

type ACL_ShutdownFramework struct {
	Principals          *ACL_Entity `protobuf:"bytes,1,req,name=principals" json:"principals,omitempty"`
	FrameworkPrincipals *ACL_Entity `protobuf:"bytes,2,req,name=framework_principals" json:"framework_principals,omitempty"`
	XXX_unrecognized    []byte      `json:"-"`
}

func (*ACL_ShutdownFramework) GetFrameworkPrincipals 

func (m *ACL_ShutdownFramework) GetFrameworkPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) GetPrincipals 

func (m *ACL_ShutdownFramework) GetPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) ProtoMessage 

func (*ACL_ShutdownFramework) ProtoMessage()

func (*ACL_ShutdownFramework) Reset 

func (m *ACL_ShutdownFramework) Reset()

func (*ACL_ShutdownFramework) String 

func (m *ACL_ShutdownFramework) String() string

type ACLs 

type ACLs struct {
	Permissive         *bool                    `protobuf:"varint,1,opt,name=permissive,def=1" json:"permissive,omitempty"`
	RegisterFrameworks []*ACL_RegisterFramework `protobuf:"bytes,2,rep,name=register_frameworks" json:"register_frameworks,omitempty"`
	RunTasks           []*ACL_RunTask           `protobuf:"bytes,3,rep,name=run_tasks" json:"run_tasks,omitempty"`
	ShutdownFrameworks []*ACL_ShutdownFramework `protobuf:"bytes,4,rep,name=shutdown_frameworks" json:"shutdown_frameworks,omitempty"`
	XXX_unrecognized   []byte                   `json:"-"`
}

func (*ACLs) GetPermissive 

func (m *ACLs) GetPermissive() bool

func (*ACLs) GetRegisterFrameworks 

func (m *ACLs) GetRegisterFrameworks() []*ACL_RegisterFramework

func (*ACLs) GetRunTasks 

func (m *ACLs) GetRunTasks() []*ACL_RunTask

func (*ACLs) GetShutdownFrameworks 

func (m *ACLs) GetShutdownFrameworks() []*ACL_ShutdownFramework

func (*ACLs) ProtoMessage 

func (*ACLs) ProtoMessage()

func (*ACLs) Reset 

func (m *ACLs) Reset()

func (*ACLs) String 

func (m *ACLs) String() string

type Archive 

type Archive struct {
	Frameworks       []*Archive_Framework `protobuf:"bytes,1,rep,name=frameworks" json:"frameworks,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*Archive) GetFrameworks 

func (m *Archive) GetFrameworks() []*Archive_Framework

func (*Archive) ProtoMessage 

func (*Archive) ProtoMessage()

func (*Archive) Reset 

func (m *Archive) Reset()

func (*Archive) String 

func (m *Archive) String() string

type Archive_Framework 

type Archive_Framework struct {
	FrameworkInfo    *FrameworkInfo `protobuf:"bytes,1,req,name=framework_info" json:"framework_info,omitempty"`
	Pid              *string        `protobuf:"bytes,2,opt,name=pid" json:"pid,omitempty"`
	Tasks            []*Task        `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*Archive_Framework) GetFrameworkInfo 

func (m *Archive_Framework) GetFrameworkInfo() *FrameworkInfo

func (*Archive_Framework) GetPid 

func (m *Archive_Framework) GetPid() string

func (*Archive_Framework) GetTasks 

func (m *Archive_Framework) GetTasks() []*Task

func (*Archive_Framework) ProtoMessage 

func (*Archive_Framework) ProtoMessage()

func (*Archive_Framework) Reset 

func (m *Archive_Framework) Reset()

func (*Archive_Framework) String 

func (m *Archive_Framework) String() string

type Attribute 

type Attribute struct {
	Name             *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *Value_Type   `protobuf:"varint,2,req,name=type,enum=mesos.Value_Type" json:"type,omitempty"`
	Scalar           *Value_Scalar `protobuf:"bytes,3,opt,name=scalar" json:"scalar,omitempty"`
	Ranges           *Value_Ranges `protobuf:"bytes,4,opt,name=ranges" json:"ranges,omitempty"`
	Set              *Value_Set    `protobuf:"bytes,6,opt,name=set" json:"set,omitempty"`
	Text             *Value_Text   `protobuf:"bytes,5,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Attribute) GetName 

func (m *Attribute) GetName() string

func (*Attribute) GetRanges 

func (m *Attribute) GetRanges() *Value_Ranges

func (*Attribute) GetScalar 

func (m *Attribute) GetScalar() *Value_Scalar

func (*Attribute) GetSet 

func (m *Attribute) GetSet() *Value_Set

func (*Attribute) GetText 

func (m *Attribute) GetText() *Value_Text

func (*Attribute) GetType 

func (m *Attribute) GetType() Value_Type

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) String 

func (m *Attribute) String() string

type AuthenticateMessage 

type AuthenticateMessage struct {
	Pid              *string `protobuf:"bytes,1,req,name=pid" json:"pid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AuthenticateMessage) GetPid 

func (m *AuthenticateMessage) GetPid() string

func (*AuthenticateMessage) ProtoMessage 

func (*AuthenticateMessage) ProtoMessage()

func (*AuthenticateMessage) Reset 

func (m *AuthenticateMessage) Reset()

func (*AuthenticateMessage) String 

func (m *AuthenticateMessage) String() string

type AuthenticationCompletedMessage 

type AuthenticationCompletedMessage struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AuthenticationCompletedMessage) ProtoMessage 

func (*AuthenticationCompletedMessage) ProtoMessage()

func (*AuthenticationCompletedMessage) Reset 

func (m *AuthenticationCompletedMessage) Reset()

func (*AuthenticationCompletedMessage) String 

func (m *AuthenticationCompletedMessage) String() string

type AuthenticationErrorMessage 

type AuthenticationErrorMessage struct {
	Error            *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AuthenticationErrorMessage) GetError 

func (m *AuthenticationErrorMessage) GetError() string

func (*AuthenticationErrorMessage) ProtoMessage 

func (*AuthenticationErrorMessage) ProtoMessage()

func (*AuthenticationErrorMessage) Reset 

func (m *AuthenticationErrorMessage) Reset()

func (*AuthenticationErrorMessage) String 

func (m *AuthenticationErrorMessage) String() string

type AuthenticationFailedMessage 

type AuthenticationFailedMessage struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AuthenticationFailedMessage) ProtoMessage 

func (*AuthenticationFailedMessage) ProtoMessage()

func (*AuthenticationFailedMessage) Reset 

func (m *AuthenticationFailedMessage) Reset()

func (*AuthenticationFailedMessage) String 

func (m *AuthenticationFailedMessage) String() string

type AuthenticationMechanismsMessage 

type AuthenticationMechanismsMessage struct {
	Mechanisms       []string `protobuf:"bytes,1,rep,name=mechanisms" json:"mechanisms,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*AuthenticationMechanismsMessage) GetMechanisms 

func (m *AuthenticationMechanismsMessage) GetMechanisms() []string

func (*AuthenticationMechanismsMessage) ProtoMessage 

func (*AuthenticationMechanismsMessage) ProtoMessage()

func (*AuthenticationMechanismsMessage) Reset 

func (m *AuthenticationMechanismsMessage) Reset()

func (*AuthenticationMechanismsMessage) String 

func (m *AuthenticationMechanismsMessage) String() string

type AuthenticationStartMessage 

type AuthenticationStartMessage struct {
	Mechanism        *string `protobuf:"bytes,1,req,name=mechanism" json:"mechanism,omitempty"`
	Data             *string `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AuthenticationStartMessage) GetData 

func (m *AuthenticationStartMessage) GetData() string

func (*AuthenticationStartMessage) GetMechanism 

func (m *AuthenticationStartMessage) GetMechanism() string

func (*AuthenticationStartMessage) ProtoMessage 

func (*AuthenticationStartMessage) ProtoMessage()

func (*AuthenticationStartMessage) Reset 

func (m *AuthenticationStartMessage) Reset()

func (*AuthenticationStartMessage) String 

func (m *AuthenticationStartMessage) String() string

type AuthenticationStepMessage 

type AuthenticationStepMessage struct {
	Data             []byte `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AuthenticationStepMessage) GetData 

func (m *AuthenticationStepMessage) GetData() []byte

func (*AuthenticationStepMessage) ProtoMessage 

func (*AuthenticationStepMessage) ProtoMessage()

func (*AuthenticationStepMessage) Reset 

func (m *AuthenticationStepMessage) Reset()

func (*AuthenticationStepMessage) String 

func (m *AuthenticationStepMessage) String() string

type Call 

type Call struct {
	FrameworkInfo    *FrameworkInfo    `protobuf:"bytes,1,req,name=framework_info" json:"framework_info,omitempty"`
	Type             *Call_Type        `protobuf:"varint,2,req,name=type,enum=mesos.scheduler.Call_Type" json:"type,omitempty"`
	Request          *Call_Request     `protobuf:"bytes,3,opt,name=request" json:"request,omitempty"`
	Decline          *Call_Decline     `protobuf:"bytes,4,opt,name=decline" json:"decline,omitempty"`
	Launch           *Call_Launch      `protobuf:"bytes,5,opt,name=launch" json:"launch,omitempty"`
	Kill             *Call_Kill        `protobuf:"bytes,6,opt,name=kill" json:"kill,omitempty"`
	Acknowledge      *Call_Acknowledge `protobuf:"bytes,7,opt,name=acknowledge" json:"acknowledge,omitempty"`
	Reconcile        *Call_Reconcile   `protobuf:"bytes,8,opt,name=reconcile" json:"reconcile,omitempty"`
	Message          *Call_Message     `protobuf:"bytes,9,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*Call) GetAcknowledge 

func (m *Call) GetAcknowledge() *Call_Acknowledge

func (*Call) GetDecline 

func (m *Call) GetDecline() *Call_Decline

func (*Call) GetFrameworkInfo 

func (m *Call) GetFrameworkInfo() *FrameworkInfo

func (*Call) GetKill 

func (m *Call) GetKill() *Call_Kill

func (*Call) GetLaunch 

func (m *Call) GetLaunch() *Call_Launch

func (*Call) GetMessage 

func (m *Call) GetMessage() *Call_Message

func (*Call) GetReconcile 

func (m *Call) GetReconcile() *Call_Reconcile

func (*Call) GetRequest 

func (m *Call) GetRequest() *Call_Request

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) Reset 

func (m *Call) Reset()

func (*Call) String 

func (m *Call) String() string

type Call_Acknowledge 

type Call_Acknowledge struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	TaskId           *TaskID  `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	Uuid             []byte   `protobuf:"bytes,3,req,name=uuid" json:"uuid,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Call_Acknowledge) GetSlaveId 

func (m *Call_Acknowledge) GetSlaveId() *SlaveID

func (*Call_Acknowledge) GetTaskId 

func (m *Call_Acknowledge) GetTaskId() *TaskID

func (*Call_Acknowledge) GetUuid 

func (m *Call_Acknowledge) GetUuid() []byte

func (*Call_Acknowledge) ProtoMessage 

func (*Call_Acknowledge) ProtoMessage()

func (*Call_Acknowledge) Reset 

func (m *Call_Acknowledge) Reset()

func (*Call_Acknowledge) String 

func (m *Call_Acknowledge) String() string

type Call_Decline 

type Call_Decline struct {
	OfferIds         []*OfferID `protobuf:"bytes,1,rep,name=offer_ids" json:"offer_ids,omitempty"`
	Filters          *Filters   `protobuf:"bytes,2,opt,name=filters" json:"filters,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Call_Decline) GetFilters 

func (m *Call_Decline) GetFilters() *Filters

func (*Call_Decline) GetOfferIds 

func (m *Call_Decline) GetOfferIds() []*OfferID

func (*Call_Decline) ProtoMessage 

func (*Call_Decline) ProtoMessage()

func (*Call_Decline) Reset 

func (m *Call_Decline) Reset()

func (*Call_Decline) String 

func (m *Call_Decline) String() string

type Call_Kill 

type Call_Kill struct {
	TaskId           *TaskID `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Call_Kill) GetTaskId 

func (m *Call_Kill) GetTaskId() *TaskID

func (*Call_Kill) ProtoMessage 

func (*Call_Kill) ProtoMessage()

func (*Call_Kill) Reset 

func (m *Call_Kill) Reset()

func (*Call_Kill) String 

func (m *Call_Kill) String() string

type Call_Launch 

type Call_Launch struct {
	TaskInfos        []*TaskInfo `protobuf:"bytes,1,rep,name=task_infos" json:"task_infos,omitempty"`
	OfferIds         []*OfferID  `protobuf:"bytes,2,rep,name=offer_ids" json:"offer_ids,omitempty"`
	Filters          *Filters    `protobuf:"bytes,3,opt,name=filters" json:"filters,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Call_Launch) GetFilters 

func (m *Call_Launch) GetFilters() *Filters

func (*Call_Launch) GetOfferIds 

func (m *Call_Launch) GetOfferIds() []*OfferID

func (*Call_Launch) GetTaskInfos 

func (m *Call_Launch) GetTaskInfos() []*TaskInfo

func (*Call_Launch) ProtoMessage 

func (*Call_Launch) ProtoMessage()

func (*Call_Launch) Reset 

func (m *Call_Launch) Reset()

func (*Call_Launch) String 

func (m *Call_Launch) String() string

type Call_Message 

type Call_Message struct {
	SlaveId          *SlaveID    `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId       *ExecutorID `protobuf:"bytes,2,req,name=executor_id" json:"executor_id,omitempty"`
	Data             []byte      `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Call_Message) GetData 

func (m *Call_Message) GetData() []byte

func (*Call_Message) GetExecutorId 

func (m *Call_Message) GetExecutorId() *ExecutorID

func (*Call_Message) GetSlaveId 

func (m *Call_Message) GetSlaveId() *SlaveID

func (*Call_Message) ProtoMessage 

func (*Call_Message) ProtoMessage()

func (*Call_Message) Reset 

func (m *Call_Message) Reset()

func (*Call_Message) String 

func (m *Call_Message) String() string

type Call_Reconcile 

type Call_Reconcile struct {
	Statuses         []*TaskStatus `protobuf:"bytes,1,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Call_Reconcile) GetStatuses 

func (m *Call_Reconcile) GetStatuses() []*TaskStatus

func (*Call_Reconcile) ProtoMessage 

func (*Call_Reconcile) ProtoMessage()

func (*Call_Reconcile) Reset 

func (m *Call_Reconcile) Reset()

func (*Call_Reconcile) String 

func (m *Call_Reconcile) String() string

type Call_Request 

type Call_Request struct {
	Requests         []*Request `protobuf:"bytes,1,rep,name=requests" json:"requests,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Call_Request) GetRequests 

func (m *Call_Request) GetRequests() []*Request

func (*Call_Request) ProtoMessage 

func (*Call_Request) ProtoMessage()

func (*Call_Request) Reset 

func (m *Call_Request) Reset()

func (*Call_Request) String 

func (m *Call_Request) String() string

type Call_Type 

type Call_Type int32
const (
	Call_REGISTER    Call_Type = 1
	Call_REREGISTER  Call_Type = 2
	Call_UNREGISTER  Call_Type = 3
	Call_REQUEST     Call_Type = 4
	Call_DECLINE     Call_Type = 5
	Call_REVIVE      Call_Type = 6
	Call_LAUNCH      Call_Type = 7
	Call_KILL        Call_Type = 8
	Call_ACKNOWLEDGE Call_Type = 9
	Call_RECONCILE   Call_Type = 10
	Call_MESSAGE     Call_Type = 11
)

func (Call_Type) Enum 

func (x Call_Type) Enum() *Call_Type

func (Call_Type) String 

func (x Call_Type) String() string

func (*Call_Type) UnmarshalJSON 

func (x *Call_Type) UnmarshalJSON(data []byte) error

type CommandInfo 

type CommandInfo struct {
	Container        *CommandInfo_ContainerInfo `protobuf:"bytes,4,opt,name=container" json:"container,omitempty"`
	Uris             []*CommandInfo_URI         `protobuf:"bytes,1,rep,name=uris" json:"uris,omitempty"`
	Environment      *Environment               `protobuf:"bytes,2,opt,name=environment" json:"environment,omitempty"`
	Shell            *bool                      `protobuf:"varint,6,opt,name=shell,def=1" json:"shell,omitempty"`
	Value            *string                    `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	Arguments        []string                   `protobuf:"bytes,7,rep,name=arguments" json:"arguments,omitempty"`
	User             *string                    `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*CommandInfo) GetArguments 

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

func (*CommandInfo) GetContainer 

func (m *CommandInfo) GetContainer() *CommandInfo_ContainerInfo

func (*CommandInfo) GetEnvironment 

func (m *CommandInfo) GetEnvironment() *Environment

func (*CommandInfo) GetShell 

func (m *CommandInfo) GetShell() bool

func (*CommandInfo) GetUris 

func (m *CommandInfo) GetUris() []*CommandInfo_URI

func (*CommandInfo) GetUser 

func (m *CommandInfo) GetUser() string

func (*CommandInfo) GetValue 

func (m *CommandInfo) GetValue() string

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset 

func (m *CommandInfo) Reset()

func (*CommandInfo) String 

func (m *CommandInfo) String() string

type CommandInfo_ContainerInfo 

type CommandInfo_ContainerInfo struct {
	Image            *string  `protobuf:"bytes,1,req,name=image" json:"image,omitempty"`
	Options          []string `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*CommandInfo_ContainerInfo) GetImage 

func (m *CommandInfo_ContainerInfo) GetImage() string

func (*CommandInfo_ContainerInfo) GetOptions 

func (m *CommandInfo_ContainerInfo) GetOptions() []string

func (*CommandInfo_ContainerInfo) ProtoMessage 

func (*CommandInfo_ContainerInfo) ProtoMessage()

func (*CommandInfo_ContainerInfo) Reset 

func (m *CommandInfo_ContainerInfo) Reset()

func (*CommandInfo_ContainerInfo) String 

func (m *CommandInfo_ContainerInfo) String() string

type CommandInfo_URI 

type CommandInfo_URI struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	Executable       *bool   `protobuf:"varint,2,opt,name=executable" json:"executable,omitempty"`
	Extract          *bool   `protobuf:"varint,3,opt,name=extract,def=1" json:"extract,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CommandInfo_URI) GetExecutable 

func (m *CommandInfo_URI) GetExecutable() bool

func (*CommandInfo_URI) GetExtract 

func (m *CommandInfo_URI) GetExtract() bool

func (*CommandInfo_URI) GetValue 

func (m *CommandInfo_URI) GetValue() string

func (*CommandInfo_URI) ProtoMessage 

func (*CommandInfo_URI) ProtoMessage()

func (*CommandInfo_URI) Reset 

func (m *CommandInfo_URI) Reset()

func (*CommandInfo_URI) String 

func (m *CommandInfo_URI) String() string

type ContainerID 

type ContainerID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ContainerID) GetValue 

func (m *ContainerID) GetValue() string

func (*ContainerID) ProtoMessage 

func (*ContainerID) ProtoMessage()

func (*ContainerID) Reset 

func (m *ContainerID) Reset()

func (*ContainerID) String 

func (m *ContainerID) String() string

type ContainerInfo 

type ContainerInfo struct {
	Type             *ContainerInfo_Type       `protobuf:"varint,1,req,name=type,enum=mesos.ContainerInfo_Type" json:"type,omitempty"`
	Volumes          []*Volume                 `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"`
	Docker           *ContainerInfo_DockerInfo `protobuf:"bytes,3,opt,name=docker" json:"docker,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ContainerInfo) GetDocker 

func (m *ContainerInfo) GetDocker() *ContainerInfo_DockerInfo

func (*ContainerInfo) GetType 

func (m *ContainerInfo) GetType() ContainerInfo_Type

func (*ContainerInfo) GetVolumes 

func (m *ContainerInfo) GetVolumes() []*Volume

func (*ContainerInfo) ProtoMessage 

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) Reset 

func (m *ContainerInfo) Reset()

func (*ContainerInfo) String 

func (m *ContainerInfo) String() string

type ContainerInfo_DockerInfo 

type ContainerInfo_DockerInfo struct {
	Image            *string `protobuf:"bytes,1,req,name=image" json:"image,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ContainerInfo_DockerInfo) GetImage 

func (m *ContainerInfo_DockerInfo) GetImage() string

func (*ContainerInfo_DockerInfo) ProtoMessage 

func (*ContainerInfo_DockerInfo) ProtoMessage()

func (*ContainerInfo_DockerInfo) Reset 

func (m *ContainerInfo_DockerInfo) Reset()

func (*ContainerInfo_DockerInfo) String 

func (m *ContainerInfo_DockerInfo) String() string

type ContainerInfo_Type 

type ContainerInfo_Type int32
const (
	ContainerInfo_DOCKER ContainerInfo_Type = 1
)

func (ContainerInfo_Type) Enum 

func (x ContainerInfo_Type) Enum() *ContainerInfo_Type

func (ContainerInfo_Type) String 

func (x ContainerInfo_Type) String() string

func (*ContainerInfo_Type) UnmarshalJSON 

func (x *ContainerInfo_Type) UnmarshalJSON(data []byte) error

type Credential 

type Credential struct {
	Principal        *string `protobuf:"bytes,1,req,name=principal" json:"principal,omitempty"`
	Secret           []byte  `protobuf:"bytes,2,opt,name=secret" json:"secret,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Credential) GetPrincipal 

func (m *Credential) GetPrincipal() string

func (*Credential) GetSecret 

func (m *Credential) GetSecret() []byte

func (*Credential) ProtoMessage 

func (*Credential) ProtoMessage()

func (*Credential) Reset 

func (m *Credential) Reset()

func (*Credential) String 

func (m *Credential) String() string

type Credentials 

type Credentials struct {
	Credentials      []*Credential `protobuf:"bytes,1,rep,name=credentials" json:"credentials,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Credentials) GetCredentials 

func (m *Credentials) GetCredentials() []*Credential

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) String 

func (m *Credentials) String() string

type DeactivateFrameworkMessage 

type DeactivateFrameworkMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*DeactivateFrameworkMessage) GetFrameworkId 

func (m *DeactivateFrameworkMessage) GetFrameworkId() *FrameworkID

func (*DeactivateFrameworkMessage) ProtoMessage 

func (*DeactivateFrameworkMessage) ProtoMessage()

func (*DeactivateFrameworkMessage) Reset 

func (m *DeactivateFrameworkMessage) Reset()

func (*DeactivateFrameworkMessage) String 

func (m *DeactivateFrameworkMessage) String() string

type Environment 

type Environment struct {
	Variables        []*Environment_Variable `protobuf:"bytes,1,rep,name=variables" json:"variables,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*Environment) GetVariables 

func (m *Environment) GetVariables() []*Environment_Variable

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) Reset 

func (m *Environment) Reset()

func (*Environment) String 

func (m *Environment) String() string

type Environment_Variable 

type Environment_Variable struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Environment_Variable) GetName 

func (m *Environment_Variable) GetName() string

func (*Environment_Variable) GetValue 

func (m *Environment_Variable) GetValue() string

func (*Environment_Variable) ProtoMessage 

func (*Environment_Variable) ProtoMessage()

func (*Environment_Variable) Reset 

func (m *Environment_Variable) Reset()

func (*Environment_Variable) String 

func (m *Environment_Variable) String() string

type Event 

type Event struct {
	Type             *Event_Type         `protobuf:"varint,1,req,name=type,enum=mesos.scheduler.Event_Type" json:"type,omitempty"`
	Registered       *Event_Registered   `protobuf:"bytes,2,opt,name=registered" json:"registered,omitempty"`
	Reregistered     *Event_Reregistered `protobuf:"bytes,3,opt,name=reregistered" json:"reregistered,omitempty"`
	Offers           *Event_Offers       `protobuf:"bytes,4,opt,name=offers" json:"offers,omitempty"`
	Rescind          *Event_Rescind      `protobuf:"bytes,5,opt,name=rescind" json:"rescind,omitempty"`
	Update           *Event_Update       `protobuf:"bytes,6,opt,name=update" json:"update,omitempty"`
	Message          *Event_Message      `protobuf:"bytes,7,opt,name=message" json:"message,omitempty"`
	Failure          *Event_Failure      `protobuf:"bytes,8,opt,name=failure" json:"failure,omitempty"`
	Error            *Event_Error        `protobuf:"bytes,9,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*Event) GetError 

func (m *Event) GetError() *Event_Error

func (*Event) GetFailure 

func (m *Event) GetFailure() *Event_Failure

func (*Event) GetMessage 

func (m *Event) GetMessage() *Event_Message

func (*Event) GetOffers 

func (m *Event) GetOffers() *Event_Offers

func (*Event) GetRegistered 

func (m *Event) GetRegistered() *Event_Registered

func (*Event) GetReregistered 

func (m *Event) GetReregistered() *Event_Reregistered

func (*Event) GetRescind 

func (m *Event) GetRescind() *Event_Rescind

func (*Event) GetType 

func (m *Event) GetType() Event_Type

func (*Event) GetUpdate 

func (m *Event) GetUpdate() *Event_Update

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

type Event_Error 

type Event_Error struct {
	Message          *string `protobuf:"bytes,1,req,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Event_Error) GetMessage 

func (m *Event_Error) GetMessage() string

func (*Event_Error) ProtoMessage 

func (*Event_Error) ProtoMessage()

func (*Event_Error) Reset 

func (m *Event_Error) Reset()

func (*Event_Error) String 

func (m *Event_Error) String() string

type Event_Failure 

type Event_Failure struct {
	SlaveId          *SlaveID    `protobuf:"bytes,1,opt,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId       *ExecutorID `protobuf:"bytes,2,opt,name=executor_id" json:"executor_id,omitempty"`
	Status           *int32      `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Event_Failure) GetExecutorId 

func (m *Event_Failure) GetExecutorId() *ExecutorID

func (*Event_Failure) GetSlaveId 

func (m *Event_Failure) GetSlaveId() *SlaveID

func (*Event_Failure) GetStatus 

func (m *Event_Failure) GetStatus() int32

func (*Event_Failure) ProtoMessage 

func (*Event_Failure) ProtoMessage()

func (*Event_Failure) Reset 

func (m *Event_Failure) Reset()

func (*Event_Failure) String 

func (m *Event_Failure) String() string

type Event_Message 

type Event_Message struct {
	SlaveId          *SlaveID    `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId       *ExecutorID `protobuf:"bytes,2,req,name=executor_id" json:"executor_id,omitempty"`
	Data             []byte      `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Event_Message) GetData 

func (m *Event_Message) GetData() []byte

func (*Event_Message) GetExecutorId 

func (m *Event_Message) GetExecutorId() *ExecutorID

func (*Event_Message) GetSlaveId 

func (m *Event_Message) GetSlaveId() *SlaveID

func (*Event_Message) ProtoMessage 

func (*Event_Message) ProtoMessage()

func (*Event_Message) Reset 

func (m *Event_Message) Reset()

func (*Event_Message) String 

func (m *Event_Message) String() string

type Event_Offers 

type Event_Offers struct {
	Offers           []*Offer `protobuf:"bytes,1,rep,name=offers" json:"offers,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Event_Offers) GetOffers 

func (m *Event_Offers) GetOffers() []*Offer

func (*Event_Offers) ProtoMessage 

func (*Event_Offers) ProtoMessage()

func (*Event_Offers) Reset 

func (m *Event_Offers) Reset()

func (*Event_Offers) String 

func (m *Event_Offers) String() string

type Event_Registered 

type Event_Registered struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	MasterInfo       *MasterInfo  `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Event_Registered) GetFrameworkId 

func (m *Event_Registered) GetFrameworkId() *FrameworkID

func (*Event_Registered) GetMasterInfo 

func (m *Event_Registered) GetMasterInfo() *MasterInfo

func (*Event_Registered) ProtoMessage 

func (*Event_Registered) ProtoMessage()

func (*Event_Registered) Reset 

func (m *Event_Registered) Reset()

func (*Event_Registered) String 

func (m *Event_Registered) String() string

type Event_Reregistered 

type Event_Reregistered struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	MasterInfo       *MasterInfo  `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Event_Reregistered) GetFrameworkId 

func (m *Event_Reregistered) GetFrameworkId() *FrameworkID

func (*Event_Reregistered) GetMasterInfo 

func (m *Event_Reregistered) GetMasterInfo() *MasterInfo

func (*Event_Reregistered) ProtoMessage 

func (*Event_Reregistered) ProtoMessage()

func (*Event_Reregistered) Reset 

func (m *Event_Reregistered) Reset()

func (*Event_Reregistered) String 

func (m *Event_Reregistered) String() string

type Event_Rescind 

type Event_Rescind struct {
	OfferId          *OfferID `protobuf:"bytes,1,req,name=offer_id" json:"offer_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Event_Rescind) GetOfferId 

func (m *Event_Rescind) GetOfferId() *OfferID

func (*Event_Rescind) ProtoMessage 

func (*Event_Rescind) ProtoMessage()

func (*Event_Rescind) Reset 

func (m *Event_Rescind) Reset()

func (*Event_Rescind) String 

func (m *Event_Rescind) String() string

type Event_Type 

type Event_Type int32
const (
	Event_REGISTERED   Event_Type = 1
	Event_REREGISTERED Event_Type = 2
	Event_OFFERS       Event_Type = 3
	Event_RESCIND      Event_Type = 4
	Event_UPDATE       Event_Type = 5
	Event_MESSAGE      Event_Type = 6
	Event_FAILURE      Event_Type = 7
	Event_ERROR        Event_Type = 8
)

func (Event_Type) Enum 

func (x Event_Type) Enum() *Event_Type

func (Event_Type) String 

func (x Event_Type) String() string

func (*Event_Type) UnmarshalJSON 

func (x *Event_Type) UnmarshalJSON(data []byte) error

type Event_Update 

type Event_Update struct {
	Uuid             []byte      `protobuf:"bytes,1,req,name=uuid" json:"uuid,omitempty"`
	Status           *TaskStatus `protobuf:"bytes,2,req,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Event_Update) GetStatus 

func (m *Event_Update) GetStatus() *TaskStatus

func (*Event_Update) GetUuid 

func (m *Event_Update) GetUuid() []byte

func (*Event_Update) ProtoMessage 

func (*Event_Update) ProtoMessage()

func (*Event_Update) Reset 

func (m *Event_Update) Reset()

func (*Event_Update) String 

func (m *Event_Update) String() string

type ExecutorID 

type ExecutorID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ExecutorID) GetValue 

func (m *ExecutorID) GetValue() string

func (*ExecutorID) ProtoMessage 

func (*ExecutorID) ProtoMessage()

func (*ExecutorID) Reset 

func (m *ExecutorID) Reset()

func (*ExecutorID) String 

func (m *ExecutorID) String() string

type ExecutorInfo 

type ExecutorInfo struct {
	ExecutorId       *ExecutorID    `protobuf:"bytes,1,req,name=executor_id" json:"executor_id,omitempty"`
	FrameworkId      *FrameworkID   `protobuf:"bytes,8,opt,name=framework_id" json:"framework_id,omitempty"`
	Command          *CommandInfo   `protobuf:"bytes,7,req,name=command" json:"command,omitempty"`
	Container        *ContainerInfo `protobuf:"bytes,11,opt,name=container" json:"container,omitempty"`
	Resources        []*Resource    `protobuf:"bytes,5,rep,name=resources" json:"resources,omitempty"`
	Name             *string        `protobuf:"bytes,9,opt,name=name" json:"name,omitempty"`
	Source           *string        `protobuf:"bytes,10,opt,name=source" json:"source,omitempty"`
	Data             []byte         `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ExecutorInfo) GetCommand 

func (m *ExecutorInfo) GetCommand() *CommandInfo

func (*ExecutorInfo) GetContainer 

func (m *ExecutorInfo) GetContainer() *ContainerInfo

func (*ExecutorInfo) GetData 

func (m *ExecutorInfo) GetData() []byte

func (*ExecutorInfo) GetExecutorId 

func (m *ExecutorInfo) GetExecutorId() *ExecutorID

func (*ExecutorInfo) GetFrameworkId 

func (m *ExecutorInfo) GetFrameworkId() *FrameworkID

func (*ExecutorInfo) GetName 

func (m *ExecutorInfo) GetName() string

func (*ExecutorInfo) GetResources 

func (m *ExecutorInfo) GetResources() []*Resource

func (*ExecutorInfo) GetSource 

func (m *ExecutorInfo) GetSource() string

func (*ExecutorInfo) ProtoMessage 

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) Reset 

func (m *ExecutorInfo) Reset()

func (*ExecutorInfo) String 

func (m *ExecutorInfo) String() string

type ExecutorRegisteredMessage 

type ExecutorRegisteredMessage struct {
	ExecutorInfo     *ExecutorInfo  `protobuf:"bytes,2,req,name=executor_info" json:"executor_info,omitempty"`
	FrameworkId      *FrameworkID   `protobuf:"bytes,3,req,name=framework_id" json:"framework_id,omitempty"`
	FrameworkInfo    *FrameworkInfo `protobuf:"bytes,4,req,name=framework_info" json:"framework_info,omitempty"`
	SlaveId          *SlaveID       `protobuf:"bytes,5,req,name=slave_id" json:"slave_id,omitempty"`
	SlaveInfo        *SlaveInfo     `protobuf:"bytes,6,req,name=slave_info" json:"slave_info,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ExecutorRegisteredMessage) GetExecutorInfo 

func (m *ExecutorRegisteredMessage) GetExecutorInfo() *ExecutorInfo

func (*ExecutorRegisteredMessage) GetFrameworkId 

func (m *ExecutorRegisteredMessage) GetFrameworkId() *FrameworkID

func (*ExecutorRegisteredMessage) GetFrameworkInfo 

func (m *ExecutorRegisteredMessage) GetFrameworkInfo() *FrameworkInfo

func (*ExecutorRegisteredMessage) GetSlaveId 

func (m *ExecutorRegisteredMessage) GetSlaveId() *SlaveID

func (*ExecutorRegisteredMessage) GetSlaveInfo 

func (m *ExecutorRegisteredMessage) GetSlaveInfo() *SlaveInfo

func (*ExecutorRegisteredMessage) ProtoMessage 

func (*ExecutorRegisteredMessage) ProtoMessage()

func (*ExecutorRegisteredMessage) Reset 

func (m *ExecutorRegisteredMessage) Reset()

func (*ExecutorRegisteredMessage) String 

func (m *ExecutorRegisteredMessage) String() string

type ExecutorReregisteredMessage 

type ExecutorReregisteredMessage struct {
	SlaveId          *SlaveID   `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	SlaveInfo        *SlaveInfo `protobuf:"bytes,2,req,name=slave_info" json:"slave_info,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*ExecutorReregisteredMessage) GetSlaveId 

func (m *ExecutorReregisteredMessage) GetSlaveId() *SlaveID

func (*ExecutorReregisteredMessage) GetSlaveInfo 

func (m *ExecutorReregisteredMessage) GetSlaveInfo() *SlaveInfo

func (*ExecutorReregisteredMessage) ProtoMessage 

func (*ExecutorReregisteredMessage) ProtoMessage()

func (*ExecutorReregisteredMessage) Reset 

func (m *ExecutorReregisteredMessage) Reset()

func (*ExecutorReregisteredMessage) String 

func (m *ExecutorReregisteredMessage) String() string

type ExecutorToFrameworkMessage 

type ExecutorToFrameworkMessage struct {
	SlaveId          *SlaveID     `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	FrameworkId      *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID  `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
	Data             []byte       `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ExecutorToFrameworkMessage) GetData 

func (m *ExecutorToFrameworkMessage) GetData() []byte

func (*ExecutorToFrameworkMessage) GetExecutorId 

func (m *ExecutorToFrameworkMessage) GetExecutorId() *ExecutorID

func (*ExecutorToFrameworkMessage) GetFrameworkId 

func (m *ExecutorToFrameworkMessage) GetFrameworkId() *FrameworkID

func (*ExecutorToFrameworkMessage) GetSlaveId 

func (m *ExecutorToFrameworkMessage) GetSlaveId() *SlaveID

func (*ExecutorToFrameworkMessage) ProtoMessage 

func (*ExecutorToFrameworkMessage) ProtoMessage()

func (*ExecutorToFrameworkMessage) Reset 

func (m *ExecutorToFrameworkMessage) Reset()

func (*ExecutorToFrameworkMessage) String 

func (m *ExecutorToFrameworkMessage) String() string

type ExitedExecutorMessage 

type ExitedExecutorMessage struct {
	SlaveId          *SlaveID     `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	FrameworkId      *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID  `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
	Status           *int32       `protobuf:"varint,4,req,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ExitedExecutorMessage) GetExecutorId 

func (m *ExitedExecutorMessage) GetExecutorId() *ExecutorID

func (*ExitedExecutorMessage) GetFrameworkId 

func (m *ExitedExecutorMessage) GetFrameworkId() *FrameworkID

func (*ExitedExecutorMessage) GetSlaveId 

func (m *ExitedExecutorMessage) GetSlaveId() *SlaveID

func (*ExitedExecutorMessage) GetStatus 

func (m *ExitedExecutorMessage) GetStatus() int32

func (*ExitedExecutorMessage) ProtoMessage 

func (*ExitedExecutorMessage) ProtoMessage()

func (*ExitedExecutorMessage) Reset 

func (m *ExitedExecutorMessage) Reset()

func (*ExitedExecutorMessage) String 

func (m *ExitedExecutorMessage) String() string

type Filters 

type Filters struct {
	RefuseSeconds    *float64 `protobuf:"fixed64,1,opt,name=refuse_seconds,def=5" json:"refuse_seconds,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Filters) GetRefuseSeconds 

func (m *Filters) GetRefuseSeconds() float64

func (*Filters) ProtoMessage 

func (*Filters) ProtoMessage()

func (*Filters) Reset 

func (m *Filters) Reset()

func (*Filters) String 

func (m *Filters) String() string

type FrameworkErrorMessage 

type FrameworkErrorMessage struct {
	Message          *string `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FrameworkErrorMessage) GetMessage 

func (m *FrameworkErrorMessage) GetMessage() string

func (*FrameworkErrorMessage) ProtoMessage 

func (*FrameworkErrorMessage) ProtoMessage()

func (*FrameworkErrorMessage) Reset 

func (m *FrameworkErrorMessage) Reset()

func (*FrameworkErrorMessage) String 

func (m *FrameworkErrorMessage) String() string

type FrameworkExpiredMessage 

type FrameworkExpiredMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkExpiredMessage) GetFrameworkId 

func (m *FrameworkExpiredMessage) GetFrameworkId() *FrameworkID

func (*FrameworkExpiredMessage) ProtoMessage 

func (*FrameworkExpiredMessage) ProtoMessage()

func (*FrameworkExpiredMessage) Reset 

func (m *FrameworkExpiredMessage) Reset()

func (*FrameworkExpiredMessage) String 

func (m *FrameworkExpiredMessage) String() string

type FrameworkID 

type FrameworkID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FrameworkID) GetValue 

func (m *FrameworkID) GetValue() string

func (*FrameworkID) ProtoMessage 

func (*FrameworkID) ProtoMessage()

func (*FrameworkID) Reset 

func (m *FrameworkID) Reset()

func (*FrameworkID) String 

func (m *FrameworkID) String() string

type FrameworkInfo 

type FrameworkInfo struct {
	User             *string      `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	Name             *string      `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	Id               *FrameworkID `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
	FailoverTimeout  *float64     `protobuf:"fixed64,4,opt,name=failover_timeout,def=0" json:"failover_timeout,omitempty"`
	Checkpoint       *bool        `protobuf:"varint,5,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	Role             *string      `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	Hostname         *string      `protobuf:"bytes,7,opt,name=hostname" json:"hostname,omitempty"`
	Principal        *string      `protobuf:"bytes,8,opt,name=principal" json:"principal,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkInfo) GetCheckpoint 

func (m *FrameworkInfo) GetCheckpoint() bool

func (*FrameworkInfo) GetFailoverTimeout 

func (m *FrameworkInfo) GetFailoverTimeout() float64

func (*FrameworkInfo) GetHostname 

func (m *FrameworkInfo) GetHostname() string

func (*FrameworkInfo) GetId 

func (m *FrameworkInfo) GetId() *FrameworkID

func (*FrameworkInfo) GetName 

func (m *FrameworkInfo) GetName() string

func (*FrameworkInfo) GetPrincipal 

func (m *FrameworkInfo) GetPrincipal() string

func (*FrameworkInfo) GetRole 

func (m *FrameworkInfo) GetRole() string

func (*FrameworkInfo) GetUser 

func (m *FrameworkInfo) GetUser() string

func (*FrameworkInfo) ProtoMessage 

func (*FrameworkInfo) ProtoMessage()

func (*FrameworkInfo) Reset 

func (m *FrameworkInfo) Reset()

func (*FrameworkInfo) String 

func (m *FrameworkInfo) String() string

type FrameworkRegisteredMessage 

type FrameworkRegisteredMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	MasterInfo       *MasterInfo  `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkRegisteredMessage) GetFrameworkId 

func (m *FrameworkRegisteredMessage) GetFrameworkId() *FrameworkID

func (*FrameworkRegisteredMessage) GetMasterInfo 

func (m *FrameworkRegisteredMessage) GetMasterInfo() *MasterInfo

func (*FrameworkRegisteredMessage) ProtoMessage 

func (*FrameworkRegisteredMessage) ProtoMessage()

func (*FrameworkRegisteredMessage) Reset 

func (m *FrameworkRegisteredMessage) Reset()

func (*FrameworkRegisteredMessage) String 

func (m *FrameworkRegisteredMessage) String() string

type FrameworkReregisteredMessage 

type FrameworkReregisteredMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	MasterInfo       *MasterInfo  `protobuf:"bytes,2,req,name=master_info" json:"master_info,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkReregisteredMessage) GetFrameworkId 

func (m *FrameworkReregisteredMessage) GetFrameworkId() *FrameworkID

func (*FrameworkReregisteredMessage) GetMasterInfo 

func (m *FrameworkReregisteredMessage) GetMasterInfo() *MasterInfo

func (*FrameworkReregisteredMessage) ProtoMessage 

func (*FrameworkReregisteredMessage) ProtoMessage()

func (*FrameworkReregisteredMessage) Reset 

func (m *FrameworkReregisteredMessage) Reset()

func (*FrameworkReregisteredMessage) String 

func (m *FrameworkReregisteredMessage) String() string

type FrameworkToExecutorMessage 

type FrameworkToExecutorMessage struct {
	SlaveId          *SlaveID     `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	FrameworkId      *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID  `protobuf:"bytes,3,req,name=executor_id" json:"executor_id,omitempty"`
	Data             []byte       `protobuf:"bytes,4,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkToExecutorMessage) GetData 

func (m *FrameworkToExecutorMessage) GetData() []byte

func (*FrameworkToExecutorMessage) GetExecutorId 

func (m *FrameworkToExecutorMessage) GetExecutorId() *ExecutorID

func (*FrameworkToExecutorMessage) GetFrameworkId 

func (m *FrameworkToExecutorMessage) GetFrameworkId() *FrameworkID

func (*FrameworkToExecutorMessage) GetSlaveId 

func (m *FrameworkToExecutorMessage) GetSlaveId() *SlaveID

func (*FrameworkToExecutorMessage) ProtoMessage 

func (*FrameworkToExecutorMessage) ProtoMessage()

func (*FrameworkToExecutorMessage) Reset 

func (m *FrameworkToExecutorMessage) Reset()

func (*FrameworkToExecutorMessage) String 

func (m *FrameworkToExecutorMessage) String() string

type HealthCheck 

type HealthCheck struct {
	Http                *HealthCheck_HTTP `protobuf:"bytes,1,opt,name=http" json:"http,omitempty"`
	DelaySeconds        *float64          `protobuf:"fixed64,2,opt,name=delay_seconds,def=15" json:"delay_seconds,omitempty"`
	IntervalSeconds     *float64          `protobuf:"fixed64,3,opt,name=interval_seconds,def=10" json:"interval_seconds,omitempty"`
	TimeoutSeconds      *float64          `protobuf:"fixed64,4,opt,name=timeout_seconds,def=20" json:"timeout_seconds,omitempty"`
	ConsecutiveFailures *uint32           `protobuf:"varint,5,opt,name=consecutive_failures,def=3" json:"consecutive_failures,omitempty"`
	GracePeriodSeconds  *float64          `protobuf:"fixed64,6,opt,name=grace_period_seconds,def=10" json:"grace_period_seconds,omitempty"`
	Command             *CommandInfo      `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	XXX_unrecognized    []byte            `json:"-"`
}

func (*HealthCheck) GetCommand 

func (m *HealthCheck) GetCommand() *CommandInfo

func (*HealthCheck) GetConsecutiveFailures 

func (m *HealthCheck) GetConsecutiveFailures() uint32

func (*HealthCheck) GetDelaySeconds 

func (m *HealthCheck) GetDelaySeconds() float64

func (*HealthCheck) GetGracePeriodSeconds 

func (m *HealthCheck) GetGracePeriodSeconds() float64

func (*HealthCheck) GetHttp 

func (m *HealthCheck) GetHttp() *HealthCheck_HTTP

func (*HealthCheck) GetIntervalSeconds 

func (m *HealthCheck) GetIntervalSeconds() float64

func (*HealthCheck) GetTimeoutSeconds 

func (m *HealthCheck) GetTimeoutSeconds() float64

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

type HealthCheck_HTTP 

type HealthCheck_HTTP struct {
	Port             *uint32  `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	Path             *string  `protobuf:"bytes,2,opt,name=path,def=/" json:"path,omitempty"`
	Statuses         []uint32 `protobuf:"varint,4,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*HealthCheck_HTTP) GetPath 

func (m *HealthCheck_HTTP) GetPath() string

func (*HealthCheck_HTTP) GetPort 

func (m *HealthCheck_HTTP) GetPort() uint32

func (*HealthCheck_HTTP) GetStatuses 

func (m *HealthCheck_HTTP) GetStatuses() []uint32

func (*HealthCheck_HTTP) ProtoMessage 

func (*HealthCheck_HTTP) ProtoMessage()

func (*HealthCheck_HTTP) Reset 

func (m *HealthCheck_HTTP) Reset()

func (*HealthCheck_HTTP) String 

func (m *HealthCheck_HTTP) String() string

type HeartbeatMessage 

type HeartbeatMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*HeartbeatMessage) GetSlaveId 

func (m *HeartbeatMessage) GetSlaveId() *SlaveID

func (*HeartbeatMessage) ProtoMessage 

func (*HeartbeatMessage) ProtoMessage()

func (*HeartbeatMessage) Reset 

func (m *HeartbeatMessage) Reset()

func (*HeartbeatMessage) String 

func (m *HeartbeatMessage) String() string

type KillTaskMessage 

type KillTaskMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	TaskId           *TaskID      `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*KillTaskMessage) GetFrameworkId 

func (m *KillTaskMessage) GetFrameworkId() *FrameworkID

func (*KillTaskMessage) GetTaskId 

func (m *KillTaskMessage) GetTaskId() *TaskID

func (*KillTaskMessage) ProtoMessage 

func (*KillTaskMessage) ProtoMessage()

func (*KillTaskMessage) Reset 

func (m *KillTaskMessage) Reset()

func (*KillTaskMessage) String 

func (m *KillTaskMessage) String() string

type LaunchTasksMessage 

type LaunchTasksMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	Tasks            []*TaskInfo  `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
	Filters          *Filters     `protobuf:"bytes,5,req,name=filters" json:"filters,omitempty"`
	OfferIds         []*OfferID   `protobuf:"bytes,6,rep,name=offer_ids" json:"offer_ids,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*LaunchTasksMessage) GetFilters 

func (m *LaunchTasksMessage) GetFilters() *Filters

func (*LaunchTasksMessage) GetFrameworkId 

func (m *LaunchTasksMessage) GetFrameworkId() *FrameworkID

func (*LaunchTasksMessage) GetOfferIds 

func (m *LaunchTasksMessage) GetOfferIds() []*OfferID

func (*LaunchTasksMessage) GetTasks 

func (m *LaunchTasksMessage) GetTasks() []*TaskInfo

func (*LaunchTasksMessage) ProtoMessage 

func (*LaunchTasksMessage) ProtoMessage()

func (*LaunchTasksMessage) Reset 

func (m *LaunchTasksMessage) Reset()

func (*LaunchTasksMessage) String 

func (m *LaunchTasksMessage) String() string

type LostSlaveMessage 

type LostSlaveMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*LostSlaveMessage) GetSlaveId 

func (m *LostSlaveMessage) GetSlaveId() *SlaveID

func (*LostSlaveMessage) ProtoMessage 

func (*LostSlaveMessage) ProtoMessage()

func (*LostSlaveMessage) Reset 

func (m *LostSlaveMessage) Reset()

func (*LostSlaveMessage) String 

func (m *LostSlaveMessage) String() string

type MasterInfo 

type MasterInfo struct {
	Id               *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Ip               *uint32 `protobuf:"varint,2,req,name=ip" json:"ip,omitempty"`
	Port             *uint32 `protobuf:"varint,3,req,name=port,def=5050" json:"port,omitempty"`
	Pid              *string `protobuf:"bytes,4,opt,name=pid" json:"pid,omitempty"`
	Hostname         *string `protobuf:"bytes,5,opt,name=hostname" json:"hostname,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MasterInfo) GetHostname 

func (m *MasterInfo) GetHostname() string

func (*MasterInfo) GetId 

func (m *MasterInfo) GetId() string

func (*MasterInfo) GetIp 

func (m *MasterInfo) GetIp() uint32

func (*MasterInfo) GetPid 

func (m *MasterInfo) GetPid() string

func (*MasterInfo) GetPort 

func (m *MasterInfo) GetPort() uint32

func (*MasterInfo) ProtoMessage 

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset 

func (m *MasterInfo) Reset()

func (*MasterInfo) String 

func (m *MasterInfo) String() string

type Offer 

type Offer struct {
	Id               *OfferID      `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	FrameworkId      *FrameworkID  `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	SlaveId          *SlaveID      `protobuf:"bytes,3,req,name=slave_id" json:"slave_id,omitempty"`
	Hostname         *string       `protobuf:"bytes,4,req,name=hostname" json:"hostname,omitempty"`
	Resources        []*Resource   `protobuf:"bytes,5,rep,name=resources" json:"resources,omitempty"`
	Attributes       []*Attribute  `protobuf:"bytes,7,rep,name=attributes" json:"attributes,omitempty"`
	ExecutorIds      []*ExecutorID `protobuf:"bytes,6,rep,name=executor_ids" json:"executor_ids,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Offer) GetAttributes 

func (m *Offer) GetAttributes() []*Attribute

func (*Offer) GetExecutorIds 

func (m *Offer) GetExecutorIds() []*ExecutorID

func (*Offer) GetFrameworkId 

func (m *Offer) GetFrameworkId() *FrameworkID

func (*Offer) GetHostname 

func (m *Offer) GetHostname() string

func (*Offer) GetId 

func (m *Offer) GetId() *OfferID

func (*Offer) GetResources 

func (m *Offer) GetResources() []*Resource

func (*Offer) GetSlaveId 

func (m *Offer) GetSlaveId() *SlaveID

func (*Offer) ProtoMessage 

func (*Offer) ProtoMessage()

func (*Offer) Reset 

func (m *Offer) Reset()

func (*Offer) String 

func (m *Offer) String() string

type OfferID 

type OfferID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*OfferID) GetValue 

func (m *OfferID) GetValue() string

func (*OfferID) ProtoMessage 

func (*OfferID) ProtoMessage()

func (*OfferID) Reset 

func (m *OfferID) Reset()

func (*OfferID) String 

func (m *OfferID) String() string

type Parameter 

type Parameter struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Parameter) GetKey 

func (m *Parameter) GetKey() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

type Parameters 

type Parameters struct {
	Parameter        []*Parameter `protobuf:"bytes,1,rep,name=parameter" json:"parameter,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Parameters) GetParameter 

func (m *Parameters) GetParameter() []*Parameter

func (*Parameters) ProtoMessage 

func (*Parameters) ProtoMessage()

func (*Parameters) Reset 

func (m *Parameters) Reset()

func (*Parameters) String 

func (m *Parameters) String() string

type PerfStatistics 

type PerfStatistics struct {
	Timestamp              *float64 `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	Duration               *float64 `protobuf:"fixed64,2,req,name=duration" json:"duration,omitempty"`
	Cycles                 *uint64  `protobuf:"varint,3,opt,name=cycles" json:"cycles,omitempty"`
	StalledCyclesFrontend  *uint64  `protobuf:"varint,4,opt,name=stalled_cycles_frontend" json:"stalled_cycles_frontend,omitempty"`
	StalledCyclesBackend   *uint64  `protobuf:"varint,5,opt,name=stalled_cycles_backend" json:"stalled_cycles_backend,omitempty"`
	Instructions           *uint64  `protobuf:"varint,6,opt,name=instructions" json:"instructions,omitempty"`
	CacheReferences        *uint64  `protobuf:"varint,7,opt,name=cache_references" json:"cache_references,omitempty"`
	CacheMisses            *uint64  `protobuf:"varint,8,opt,name=cache_misses" json:"cache_misses,omitempty"`
	Branches               *uint64  `protobuf:"varint,9,opt,name=branches" json:"branches,omitempty"`
	BranchMisses           *uint64  `protobuf:"varint,10,opt,name=branch_misses" json:"branch_misses,omitempty"`
	BusCycles              *uint64  `protobuf:"varint,11,opt,name=bus_cycles" json:"bus_cycles,omitempty"`
	RefCycles              *uint64  `protobuf:"varint,12,opt,name=ref_cycles" json:"ref_cycles,omitempty"`
	CpuClock               *float64 `protobuf:"fixed64,13,opt,name=cpu_clock" json:"cpu_clock,omitempty"`
	TaskClock              *float64 `protobuf:"fixed64,14,opt,name=task_clock" json:"task_clock,omitempty"`
	PageFaults             *uint64  `protobuf:"varint,15,opt,name=page_faults" json:"page_faults,omitempty"`
	MinorFaults            *uint64  `protobuf:"varint,16,opt,name=minor_faults" json:"minor_faults,omitempty"`
	MajorFaults            *uint64  `protobuf:"varint,17,opt,name=major_faults" json:"major_faults,omitempty"`
	ContextSwitches        *uint64  `protobuf:"varint,18,opt,name=context_switches" json:"context_switches,omitempty"`
	CpuMigrations          *uint64  `protobuf:"varint,19,opt,name=cpu_migrations" json:"cpu_migrations,omitempty"`
	AlignmentFaults        *uint64  `protobuf:"varint,20,opt,name=alignment_faults" json:"alignment_faults,omitempty"`
	EmulationFaults        *uint64  `protobuf:"varint,21,opt,name=emulation_faults" json:"emulation_faults,omitempty"`
	L1DcacheLoads          *uint64  `protobuf:"varint,22,opt,name=l1_dcache_loads" json:"l1_dcache_loads,omitempty"`
	L1DcacheLoadMisses     *uint64  `protobuf:"varint,23,opt,name=l1_dcache_load_misses" json:"l1_dcache_load_misses,omitempty"`
	L1DcacheStores         *uint64  `protobuf:"varint,24,opt,name=l1_dcache_stores" json:"l1_dcache_stores,omitempty"`
	L1DcacheStoreMisses    *uint64  `protobuf:"varint,25,opt,name=l1_dcache_store_misses" json:"l1_dcache_store_misses,omitempty"`
	L1DcachePrefetches     *uint64  `protobuf:"varint,26,opt,name=l1_dcache_prefetches" json:"l1_dcache_prefetches,omitempty"`
	L1DcachePrefetchMisses *uint64  `protobuf:"varint,27,opt,name=l1_dcache_prefetch_misses" json:"l1_dcache_prefetch_misses,omitempty"`
	L1IcacheLoads          *uint64  `protobuf:"varint,28,opt,name=l1_icache_loads" json:"l1_icache_loads,omitempty"`
	L1IcacheLoadMisses     *uint64  `protobuf:"varint,29,opt,name=l1_icache_load_misses" json:"l1_icache_load_misses,omitempty"`
	L1IcachePrefetches     *uint64  `protobuf:"varint,30,opt,name=l1_icache_prefetches" json:"l1_icache_prefetches,omitempty"`
	L1IcachePrefetchMisses *uint64  `protobuf:"varint,31,opt,name=l1_icache_prefetch_misses" json:"l1_icache_prefetch_misses,omitempty"`
	LlcLoads               *uint64  `protobuf:"varint,32,opt,name=llc_loads" json:"llc_loads,omitempty"`
	LlcLoadMisses          *uint64  `protobuf:"varint,33,opt,name=llc_load_misses" json:"llc_load_misses,omitempty"`
	LlcStores              *uint64  `protobuf:"varint,34,opt,name=llc_stores" json:"llc_stores,omitempty"`
	LlcStoreMisses         *uint64  `protobuf:"varint,35,opt,name=llc_store_misses" json:"llc_store_misses,omitempty"`
	LlcPrefetches          *uint64  `protobuf:"varint,36,opt,name=llc_prefetches" json:"llc_prefetches,omitempty"`
	LlcPrefetchMisses      *uint64  `protobuf:"varint,37,opt,name=llc_prefetch_misses" json:"llc_prefetch_misses,omitempty"`
	DtlbLoads              *uint64  `protobuf:"varint,38,opt,name=dtlb_loads" json:"dtlb_loads,omitempty"`
	DtlbLoadMisses         *uint64  `protobuf:"varint,39,opt,name=dtlb_load_misses" json:"dtlb_load_misses,omitempty"`
	DtlbStores             *uint64  `protobuf:"varint,40,opt,name=dtlb_stores" json:"dtlb_stores,omitempty"`
	DtlbStoreMisses        *uint64  `protobuf:"varint,41,opt,name=dtlb_store_misses" json:"dtlb_store_misses,omitempty"`
	DtlbPrefetches         *uint64  `protobuf:"varint,42,opt,name=dtlb_prefetches" json:"dtlb_prefetches,omitempty"`
	DtlbPrefetchMisses     *uint64  `protobuf:"varint,43,opt,name=dtlb_prefetch_misses" json:"dtlb_prefetch_misses,omitempty"`
	ItlbLoads              *uint64  `protobuf:"varint,44,opt,name=itlb_loads" json:"itlb_loads,omitempty"`
	ItlbLoadMisses         *uint64  `protobuf:"varint,45,opt,name=itlb_load_misses" json:"itlb_load_misses,omitempty"`
	BranchLoads            *uint64  `protobuf:"varint,46,opt,name=branch_loads" json:"branch_loads,omitempty"`
	BranchLoadMisses       *uint64  `protobuf:"varint,47,opt,name=branch_load_misses" json:"branch_load_misses,omitempty"`
	NodeLoads              *uint64  `protobuf:"varint,48,opt,name=node_loads" json:"node_loads,omitempty"`
	NodeLoadMisses         *uint64  `protobuf:"varint,49,opt,name=node_load_misses" json:"node_load_misses,omitempty"`
	NodeStores             *uint64  `protobuf:"varint,50,opt,name=node_stores" json:"node_stores,omitempty"`
	NodeStoreMisses        *uint64  `protobuf:"varint,51,opt,name=node_store_misses" json:"node_store_misses,omitempty"`
	NodePrefetches         *uint64  `protobuf:"varint,52,opt,name=node_prefetches" json:"node_prefetches,omitempty"`
	NodePrefetchMisses     *uint64  `protobuf:"varint,53,opt,name=node_prefetch_misses" json:"node_prefetch_misses,omitempty"`
	XXX_unrecognized       []byte   `json:"-"`
}

func (*PerfStatistics) GetAlignmentFaults 

func (m *PerfStatistics) GetAlignmentFaults() uint64

func (*PerfStatistics) GetBranchLoadMisses 

func (m *PerfStatistics) GetBranchLoadMisses() uint64

func (*PerfStatistics) GetBranchLoads 

func (m *PerfStatistics) GetBranchLoads() uint64

func (*PerfStatistics) GetBranchMisses 

func (m *PerfStatistics) GetBranchMisses() uint64

func (*PerfStatistics) GetBranches 

func (m *PerfStatistics) GetBranches() uint64

func (*PerfStatistics) GetBusCycles 

func (m *PerfStatistics) GetBusCycles() uint64

func (*PerfStatistics) GetCacheMisses 

func (m *PerfStatistics) GetCacheMisses() uint64

func (*PerfStatistics) GetCacheReferences 

func (m *PerfStatistics) GetCacheReferences() uint64

func (*PerfStatistics) GetContextSwitches 

func (m *PerfStatistics) GetContextSwitches() uint64

func (*PerfStatistics) GetCpuClock 

func (m *PerfStatistics) GetCpuClock() float64

func (*PerfStatistics) GetCpuMigrations 

func (m *PerfStatistics) GetCpuMigrations() uint64

func (*PerfStatistics) GetCycles 

func (m *PerfStatistics) GetCycles() uint64

func (*PerfStatistics) GetDtlbLoadMisses 

func (m *PerfStatistics) GetDtlbLoadMisses() uint64

func (*PerfStatistics) GetDtlbLoads 

func (m *PerfStatistics) GetDtlbLoads() uint64

func (*PerfStatistics) GetDtlbPrefetchMisses 

func (m *PerfStatistics) GetDtlbPrefetchMisses() uint64

func (*PerfStatistics) GetDtlbPrefetches 

func (m *PerfStatistics) GetDtlbPrefetches() uint64

func (*PerfStatistics) GetDtlbStoreMisses 

func (m *PerfStatistics) GetDtlbStoreMisses() uint64

func (*PerfStatistics) GetDtlbStores 

func (m *PerfStatistics) GetDtlbStores() uint64

func (*PerfStatistics) GetDuration 

func (m *PerfStatistics) GetDuration() float64

func (*PerfStatistics) GetEmulationFaults 

func (m *PerfStatistics) GetEmulationFaults() uint64

func (*PerfStatistics) GetInstructions 

func (m *PerfStatistics) GetInstructions() uint64

func (*PerfStatistics) GetItlbLoadMisses 

func (m *PerfStatistics) GetItlbLoadMisses() uint64

func (*PerfStatistics) GetItlbLoads 

func (m *PerfStatistics) GetItlbLoads() uint64

func (*PerfStatistics) GetL1DcacheLoadMisses 

func (m *PerfStatistics) GetL1DcacheLoadMisses() uint64

func (*PerfStatistics) GetL1DcacheLoads 

func (m *PerfStatistics) GetL1DcacheLoads() uint64

func (*PerfStatistics) GetL1DcachePrefetchMisses 

func (m *PerfStatistics) GetL1DcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1DcachePrefetches 

func (m *PerfStatistics) GetL1DcachePrefetches() uint64

func (*PerfStatistics) GetL1DcacheStoreMisses 

func (m *PerfStatistics) GetL1DcacheStoreMisses() uint64

func (*PerfStatistics) GetL1DcacheStores 

func (m *PerfStatistics) GetL1DcacheStores() uint64

func (*PerfStatistics) GetL1IcacheLoadMisses 

func (m *PerfStatistics) GetL1IcacheLoadMisses() uint64

func (*PerfStatistics) GetL1IcacheLoads 

func (m *PerfStatistics) GetL1IcacheLoads() uint64

func (*PerfStatistics) GetL1IcachePrefetchMisses 

func (m *PerfStatistics) GetL1IcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1IcachePrefetches 

func (m *PerfStatistics) GetL1IcachePrefetches() uint64

func (*PerfStatistics) GetLlcLoadMisses 

func (m *PerfStatistics) GetLlcLoadMisses() uint64

func (*PerfStatistics) GetLlcLoads 

func (m *PerfStatistics) GetLlcLoads() uint64

func (*PerfStatistics) GetLlcPrefetchMisses 

func (m *PerfStatistics) GetLlcPrefetchMisses() uint64

func (*PerfStatistics) GetLlcPrefetches 

func (m *PerfStatistics) GetLlcPrefetches() uint64

func (*PerfStatistics) GetLlcStoreMisses 

func (m *PerfStatistics) GetLlcStoreMisses() uint64

func (*PerfStatistics) GetLlcStores 

func (m *PerfStatistics) GetLlcStores() uint64

func (*PerfStatistics) GetMajorFaults 

func (m *PerfStatistics) GetMajorFaults() uint64

func (*PerfStatistics) GetMinorFaults 

func (m *PerfStatistics) GetMinorFaults() uint64

func (*PerfStatistics) GetNodeLoadMisses 

func (m *PerfStatistics) GetNodeLoadMisses() uint64

func (*PerfStatistics) GetNodeLoads 

func (m *PerfStatistics) GetNodeLoads() uint64

func (*PerfStatistics) GetNodePrefetchMisses 

func (m *PerfStatistics) GetNodePrefetchMisses() uint64

func (*PerfStatistics) GetNodePrefetches 

func (m *PerfStatistics) GetNodePrefetches() uint64

func (*PerfStatistics) GetNodeStoreMisses 

func (m *PerfStatistics) GetNodeStoreMisses() uint64

func (*PerfStatistics) GetNodeStores 

func (m *PerfStatistics) GetNodeStores() uint64

func (*PerfStatistics) GetPageFaults 

func (m *PerfStatistics) GetPageFaults() uint64

func (*PerfStatistics) GetRefCycles 

func (m *PerfStatistics) GetRefCycles() uint64

func (*PerfStatistics) GetStalledCyclesBackend 

func (m *PerfStatistics) GetStalledCyclesBackend() uint64

func (*PerfStatistics) GetStalledCyclesFrontend 

func (m *PerfStatistics) GetStalledCyclesFrontend() uint64

func (*PerfStatistics) GetTaskClock 

func (m *PerfStatistics) GetTaskClock() float64

func (*PerfStatistics) GetTimestamp 

func (m *PerfStatistics) GetTimestamp() float64

func (*PerfStatistics) ProtoMessage 

func (*PerfStatistics) ProtoMessage()

func (*PerfStatistics) Reset 

func (m *PerfStatistics) Reset()

func (*PerfStatistics) String 

func (m *PerfStatistics) String() string

type ProjdReadyMessage 

type ProjdReadyMessage struct {
	Project          *string `protobuf:"bytes,1,req,name=project" json:"project,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ProjdReadyMessage) GetProject 

func (m *ProjdReadyMessage) GetProject() string

func (*ProjdReadyMessage) ProtoMessage 

func (*ProjdReadyMessage) ProtoMessage()

func (*ProjdReadyMessage) Reset 

func (m *ProjdReadyMessage) Reset()

func (*ProjdReadyMessage) String 

func (m *ProjdReadyMessage) String() string

type ProjdUpdateResourcesMessage 

type ProjdUpdateResourcesMessage struct {
	Parameters       *Parameters `protobuf:"bytes,1,opt,name=parameters" json:"parameters,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*ProjdUpdateResourcesMessage) GetParameters 

func (m *ProjdUpdateResourcesMessage) GetParameters() *Parameters

func (*ProjdUpdateResourcesMessage) ProtoMessage 

func (*ProjdUpdateResourcesMessage) ProtoMessage()

func (*ProjdUpdateResourcesMessage) Reset 

func (m *ProjdUpdateResourcesMessage) Reset()

func (*ProjdUpdateResourcesMessage) String 

func (m *ProjdUpdateResourcesMessage) String() string

type RateLimit 

type RateLimit struct {
	Qps              *float64 `protobuf:"fixed64,1,opt,name=qps" json:"qps,omitempty"`
	Principal        *string  `protobuf:"bytes,2,req,name=principal" json:"principal,omitempty"`
	Capacity         *uint64  `protobuf:"varint,3,opt,name=capacity" json:"capacity,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RateLimit) GetCapacity 

func (m *RateLimit) GetCapacity() uint64

func (*RateLimit) GetPrincipal 

func (m *RateLimit) GetPrincipal() string

func (*RateLimit) GetQps 

func (m *RateLimit) GetQps() float64

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) String 

func (m *RateLimit) String() string

type RateLimits 

type RateLimits struct {
	Limits                   []*RateLimit `protobuf:"bytes,1,rep,name=limits" json:"limits,omitempty"`
	AggregateDefaultQps      *float64     `protobuf:"fixed64,2,opt,name=aggregate_default_qps" json:"aggregate_default_qps,omitempty"`
	AggregateDefaultCapacity *uint64      `protobuf:"varint,3,opt,name=aggregate_default_capacity" json:"aggregate_default_capacity,omitempty"`
	XXX_unrecognized         []byte       `json:"-"`
}

func (*RateLimits) GetAggregateDefaultCapacity 

func (m *RateLimits) GetAggregateDefaultCapacity() uint64

func (*RateLimits) GetAggregateDefaultQps 

func (m *RateLimits) GetAggregateDefaultQps() float64

func (*RateLimits) GetLimits 

func (m *RateLimits) GetLimits() []*RateLimit

func (*RateLimits) ProtoMessage 

func (*RateLimits) ProtoMessage()

func (*RateLimits) Reset 

func (m *RateLimits) Reset()

func (*RateLimits) String 

func (m *RateLimits) String() string

type ReconcileTasksMessage 

type ReconcileTasksMessage struct {
	FrameworkId      *FrameworkID  `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	Statuses         []*TaskStatus `protobuf:"bytes,2,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ReconcileTasksMessage) GetFrameworkId 

func (m *ReconcileTasksMessage) GetFrameworkId() *FrameworkID

func (*ReconcileTasksMessage) GetStatuses 

func (m *ReconcileTasksMessage) GetStatuses() []*TaskStatus

func (*ReconcileTasksMessage) ProtoMessage 

func (*ReconcileTasksMessage) ProtoMessage()

func (*ReconcileTasksMessage) Reset 

func (m *ReconcileTasksMessage) Reset()

func (*ReconcileTasksMessage) String 

func (m *ReconcileTasksMessage) String() string

type ReconnectExecutorMessage 

type ReconnectExecutorMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ReconnectExecutorMessage) GetSlaveId 

func (m *ReconnectExecutorMessage) GetSlaveId() *SlaveID

func (*ReconnectExecutorMessage) ProtoMessage 

func (*ReconnectExecutorMessage) ProtoMessage()

func (*ReconnectExecutorMessage) Reset 

func (m *ReconnectExecutorMessage) Reset()

func (*ReconnectExecutorMessage) String 

func (m *ReconnectExecutorMessage) String() string

type RegisterExecutorMessage 

type RegisterExecutorMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID  `protobuf:"bytes,2,req,name=executor_id" json:"executor_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*RegisterExecutorMessage) GetExecutorId 

func (m *RegisterExecutorMessage) GetExecutorId() *ExecutorID

func (*RegisterExecutorMessage) GetFrameworkId 

func (m *RegisterExecutorMessage) GetFrameworkId() *FrameworkID

func (*RegisterExecutorMessage) ProtoMessage 

func (*RegisterExecutorMessage) ProtoMessage()

func (*RegisterExecutorMessage) Reset 

func (m *RegisterExecutorMessage) Reset()

func (*RegisterExecutorMessage) String 

func (m *RegisterExecutorMessage) String() string

type RegisterFrameworkMessage 

type RegisterFrameworkMessage struct {
	Framework        *FrameworkInfo `protobuf:"bytes,1,req,name=framework" json:"framework,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RegisterFrameworkMessage) GetFramework 

func (m *RegisterFrameworkMessage) GetFramework() *FrameworkInfo

func (*RegisterFrameworkMessage) ProtoMessage 

func (*RegisterFrameworkMessage) ProtoMessage()

func (*RegisterFrameworkMessage) Reset 

func (m *RegisterFrameworkMessage) Reset()

func (*RegisterFrameworkMessage) String 

func (m *RegisterFrameworkMessage) String() string

type RegisterProjdMessage 

type RegisterProjdMessage struct {
	Project          *string `protobuf:"bytes,1,req,name=project" json:"project,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RegisterProjdMessage) GetProject 

func (m *RegisterProjdMessage) GetProject() string

func (*RegisterProjdMessage) ProtoMessage 

func (*RegisterProjdMessage) ProtoMessage()

func (*RegisterProjdMessage) Reset 

func (m *RegisterProjdMessage) Reset()

func (*RegisterProjdMessage) String 

func (m *RegisterProjdMessage) String() string

type RegisterSlaveMessage 

type RegisterSlaveMessage struct {
	Slave            *SlaveInfo `protobuf:"bytes,1,req,name=slave" json:"slave,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*RegisterSlaveMessage) GetSlave 

func (m *RegisterSlaveMessage) GetSlave() *SlaveInfo

func (*RegisterSlaveMessage) ProtoMessage 

func (*RegisterSlaveMessage) ProtoMessage()

func (*RegisterSlaveMessage) Reset 

func (m *RegisterSlaveMessage) Reset()

func (*RegisterSlaveMessage) String 

func (m *RegisterSlaveMessage) String() string

type Request 

type Request struct {
	SlaveId          *SlaveID    `protobuf:"bytes,1,opt,name=slave_id" json:"slave_id,omitempty"`
	Resources        []*Resource `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Request) GetResources 

func (m *Request) GetResources() []*Resource

func (*Request) GetSlaveId 

func (m *Request) GetSlaveId() *SlaveID

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

type ReregisterExecutorMessage 

type ReregisterExecutorMessage struct {
	ExecutorId       *ExecutorID     `protobuf:"bytes,1,req,name=executor_id" json:"executor_id,omitempty"`
	FrameworkId      *FrameworkID    `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	Tasks            []*TaskInfo     `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
	Updates          []*StatusUpdate `protobuf:"bytes,4,rep,name=updates" json:"updates,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*ReregisterExecutorMessage) GetExecutorId 

func (m *ReregisterExecutorMessage) GetExecutorId() *ExecutorID

func (*ReregisterExecutorMessage) GetFrameworkId 

func (m *ReregisterExecutorMessage) GetFrameworkId() *FrameworkID

func (*ReregisterExecutorMessage) GetTasks 

func (m *ReregisterExecutorMessage) GetTasks() []*TaskInfo

func (*ReregisterExecutorMessage) GetUpdates 

func (m *ReregisterExecutorMessage) GetUpdates() []*StatusUpdate

func (*ReregisterExecutorMessage) ProtoMessage 

func (*ReregisterExecutorMessage) ProtoMessage()

func (*ReregisterExecutorMessage) Reset 

func (m *ReregisterExecutorMessage) Reset()

func (*ReregisterExecutorMessage) String 

func (m *ReregisterExecutorMessage) String() string

type ReregisterFrameworkMessage 

type ReregisterFrameworkMessage struct {
	Framework        *FrameworkInfo `protobuf:"bytes,2,req,name=framework" json:"framework,omitempty"`
	Failover         *bool          `protobuf:"varint,3,req,name=failover" json:"failover,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ReregisterFrameworkMessage) GetFailover 

func (m *ReregisterFrameworkMessage) GetFailover() bool

func (*ReregisterFrameworkMessage) GetFramework 

func (m *ReregisterFrameworkMessage) GetFramework() *FrameworkInfo

func (*ReregisterFrameworkMessage) ProtoMessage 

func (*ReregisterFrameworkMessage) ProtoMessage()

func (*ReregisterFrameworkMessage) Reset 

func (m *ReregisterFrameworkMessage) Reset()

func (*ReregisterFrameworkMessage) String 

func (m *ReregisterFrameworkMessage) String() string

type ReregisterSlaveMessage 

type ReregisterSlaveMessage struct {
	SlaveId             *SlaveID             `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	Slave               *SlaveInfo           `protobuf:"bytes,2,req,name=slave" json:"slave,omitempty"`
	ExecutorInfos       []*ExecutorInfo      `protobuf:"bytes,4,rep,name=executor_infos" json:"executor_infos,omitempty"`
	Tasks               []*Task              `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
	CompletedFrameworks []*Archive_Framework `protobuf:"bytes,5,rep,name=completed_frameworks" json:"completed_frameworks,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

func (*ReregisterSlaveMessage) GetCompletedFrameworks 

func (m *ReregisterSlaveMessage) GetCompletedFrameworks() []*Archive_Framework

func (*ReregisterSlaveMessage) GetExecutorInfos 

func (m *ReregisterSlaveMessage) GetExecutorInfos() []*ExecutorInfo

func (*ReregisterSlaveMessage) GetSlave 

func (m *ReregisterSlaveMessage) GetSlave() *SlaveInfo

func (*ReregisterSlaveMessage) GetSlaveId 

func (m *ReregisterSlaveMessage) GetSlaveId() *SlaveID

func (*ReregisterSlaveMessage) GetTasks 

func (m *ReregisterSlaveMessage) GetTasks() []*Task

func (*ReregisterSlaveMessage) ProtoMessage 

func (*ReregisterSlaveMessage) ProtoMessage()

func (*ReregisterSlaveMessage) Reset 

func (m *ReregisterSlaveMessage) Reset()

func (*ReregisterSlaveMessage) String 

func (m *ReregisterSlaveMessage) String() string

type RescindResourceOfferMessage 

type RescindResourceOfferMessage struct {
	OfferId          *OfferID `protobuf:"bytes,1,req,name=offer_id" json:"offer_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RescindResourceOfferMessage) GetOfferId 

func (m *RescindResourceOfferMessage) GetOfferId() *OfferID

func (*RescindResourceOfferMessage) ProtoMessage 

func (*RescindResourceOfferMessage) ProtoMessage()

func (*RescindResourceOfferMessage) Reset 

func (m *RescindResourceOfferMessage) Reset()

func (*RescindResourceOfferMessage) String 

func (m *RescindResourceOfferMessage) String() string

type Resource 

type Resource struct {
	Name             *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Type             *Value_Type   `protobuf:"varint,2,req,name=type,enum=mesos.Value_Type" json:"type,omitempty"`
	Scalar           *Value_Scalar `protobuf:"bytes,3,opt,name=scalar" json:"scalar,omitempty"`
	Ranges           *Value_Ranges `protobuf:"bytes,4,opt,name=ranges" json:"ranges,omitempty"`
	Set              *Value_Set    `protobuf:"bytes,5,opt,name=set" json:"set,omitempty"`
	Role             *string       `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Resource) GetName 

func (m *Resource) GetName() string

func (*Resource) GetRanges 

func (m *Resource) GetRanges() *Value_Ranges

func (*Resource) GetRole 

func (m *Resource) GetRole() string

func (*Resource) GetScalar 

func (m *Resource) GetScalar() *Value_Scalar

func (*Resource) GetSet 

func (m *Resource) GetSet() *Value_Set

func (*Resource) GetType 

func (m *Resource) GetType() Value_Type

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

type ResourceOffersMessage 

type ResourceOffersMessage struct {
	Offers           []*Offer `protobuf:"bytes,1,rep,name=offers" json:"offers,omitempty"`
	Pids             []string `protobuf:"bytes,2,rep,name=pids" json:"pids,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ResourceOffersMessage) GetOffers 

func (m *ResourceOffersMessage) GetOffers() []*Offer

func (*ResourceOffersMessage) GetPids 

func (m *ResourceOffersMessage) GetPids() []string

func (*ResourceOffersMessage) ProtoMessage 

func (*ResourceOffersMessage) ProtoMessage()

func (*ResourceOffersMessage) Reset 

func (m *ResourceOffersMessage) Reset()

func (*ResourceOffersMessage) String 

func (m *ResourceOffersMessage) String() string

type ResourceRequestMessage 

type ResourceRequestMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	Requests         []*Request   `protobuf:"bytes,2,rep,name=requests" json:"requests,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ResourceRequestMessage) GetFrameworkId 

func (m *ResourceRequestMessage) GetFrameworkId() *FrameworkID

func (*ResourceRequestMessage) GetRequests 

func (m *ResourceRequestMessage) GetRequests() []*Request

func (*ResourceRequestMessage) ProtoMessage 

func (*ResourceRequestMessage) ProtoMessage()

func (*ResourceRequestMessage) Reset 

func (m *ResourceRequestMessage) Reset()

func (*ResourceRequestMessage) String 

func (m *ResourceRequestMessage) String() string

type ResourceStatistics 

type ResourceStatistics struct {
	Timestamp             *float64        `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	CpusUserTimeSecs      *float64        `protobuf:"fixed64,2,opt,name=cpus_user_time_secs" json:"cpus_user_time_secs,omitempty"`
	CpusSystemTimeSecs    *float64        `protobuf:"fixed64,3,opt,name=cpus_system_time_secs" json:"cpus_system_time_secs,omitempty"`
	CpusLimit             *float64        `protobuf:"fixed64,4,opt,name=cpus_limit" json:"cpus_limit,omitempty"`
	CpusNrPeriods         *uint32         `protobuf:"varint,7,opt,name=cpus_nr_periods" json:"cpus_nr_periods,omitempty"`
	CpusNrThrottled       *uint32         `protobuf:"varint,8,opt,name=cpus_nr_throttled" json:"cpus_nr_throttled,omitempty"`
	CpusThrottledTimeSecs *float64        `protobuf:"fixed64,9,opt,name=cpus_throttled_time_secs" json:"cpus_throttled_time_secs,omitempty"`
	MemRssBytes           *uint64         `protobuf:"varint,5,opt,name=mem_rss_bytes" json:"mem_rss_bytes,omitempty"`
	MemLimitBytes         *uint64         `protobuf:"varint,6,opt,name=mem_limit_bytes" json:"mem_limit_bytes,omitempty"`
	MemFileBytes          *uint64         `protobuf:"varint,10,opt,name=mem_file_bytes" json:"mem_file_bytes,omitempty"`
	MemAnonBytes          *uint64         `protobuf:"varint,11,opt,name=mem_anon_bytes" json:"mem_anon_bytes,omitempty"`
	MemMappedFileBytes    *uint64         `protobuf:"varint,12,opt,name=mem_mapped_file_bytes" json:"mem_mapped_file_bytes,omitempty"`
	Perf                  *PerfStatistics `protobuf:"bytes,13,opt,name=perf" json:"perf,omitempty"`
	NetRxPackets          *uint64         `protobuf:"varint,14,opt,name=net_rx_packets" json:"net_rx_packets,omitempty"`
	NetRxBytes            *uint64         `protobuf:"varint,15,opt,name=net_rx_bytes" json:"net_rx_bytes,omitempty"`
	NetRxErrors           *uint64         `protobuf:"varint,16,opt,name=net_rx_errors" json:"net_rx_errors,omitempty"`
	NetRxDropped          *uint64         `protobuf:"varint,17,opt,name=net_rx_dropped" json:"net_rx_dropped,omitempty"`
	NetTxPackets          *uint64         `protobuf:"varint,18,opt,name=net_tx_packets" json:"net_tx_packets,omitempty"`
	NetTxBytes            *uint64         `protobuf:"varint,19,opt,name=net_tx_bytes" json:"net_tx_bytes,omitempty"`
	NetTxErrors           *uint64         `protobuf:"varint,20,opt,name=net_tx_errors" json:"net_tx_errors,omitempty"`
	NetTxDropped          *uint64         `protobuf:"varint,21,opt,name=net_tx_dropped" json:"net_tx_dropped,omitempty"`
	XXX_unrecognized      []byte          `json:"-"`
}

func (*ResourceStatistics) GetCpusLimit 

func (m *ResourceStatistics) GetCpusLimit() float64

func (*ResourceStatistics) GetCpusNrPeriods 

func (m *ResourceStatistics) GetCpusNrPeriods() uint32

func (*ResourceStatistics) GetCpusNrThrottled 

func (m *ResourceStatistics) GetCpusNrThrottled() uint32

func (*ResourceStatistics) GetCpusSystemTimeSecs 

func (m *ResourceStatistics) GetCpusSystemTimeSecs() float64

func (*ResourceStatistics) GetCpusThrottledTimeSecs 

func (m *ResourceStatistics) GetCpusThrottledTimeSecs() float64

func (*ResourceStatistics) GetCpusUserTimeSecs 

func (m *ResourceStatistics) GetCpusUserTimeSecs() float64

func (*ResourceStatistics) GetMemAnonBytes 

func (m *ResourceStatistics) GetMemAnonBytes() uint64

func (*ResourceStatistics) GetMemFileBytes 

func (m *ResourceStatistics) GetMemFileBytes() uint64

func (*ResourceStatistics) GetMemLimitBytes 

func (m *ResourceStatistics) GetMemLimitBytes() uint64

func (*ResourceStatistics) GetMemMappedFileBytes 

func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

func (*ResourceStatistics) GetMemRssBytes 

func (m *ResourceStatistics) GetMemRssBytes() uint64

func (*ResourceStatistics) GetNetRxBytes 

func (m *ResourceStatistics) GetNetRxBytes() uint64

func (*ResourceStatistics) GetNetRxDropped 

func (m *ResourceStatistics) GetNetRxDropped() uint64

func (*ResourceStatistics) GetNetRxErrors 

func (m *ResourceStatistics) GetNetRxErrors() uint64

func (*ResourceStatistics) GetNetRxPackets 

func (m *ResourceStatistics) GetNetRxPackets() uint64

func (*ResourceStatistics) GetNetTxBytes 

func (m *ResourceStatistics) GetNetTxBytes() uint64

func (*ResourceStatistics) GetNetTxDropped 

func (m *ResourceStatistics) GetNetTxDropped() uint64

func (*ResourceStatistics) GetNetTxErrors 

func (m *ResourceStatistics) GetNetTxErrors() uint64

func (*ResourceStatistics) GetNetTxPackets 

func (m *ResourceStatistics) GetNetTxPackets() uint64

func (*ResourceStatistics) GetPerf 

func (m *ResourceStatistics) GetPerf() *PerfStatistics

func (*ResourceStatistics) GetTimestamp 

func (m *ResourceStatistics) GetTimestamp() float64

func (*ResourceStatistics) ProtoMessage 

func (*ResourceStatistics) ProtoMessage()

func (*ResourceStatistics) Reset 

func (m *ResourceStatistics) Reset()

func (*ResourceStatistics) String 

func (m *ResourceStatistics) String() string

type ResourceUsage 

type ResourceUsage struct {
	SlaveId          *SlaveID            `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	FrameworkId      *FrameworkID        `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID         `protobuf:"bytes,3,opt,name=executor_id" json:"executor_id,omitempty"`
	ExecutorName     *string             `protobuf:"bytes,4,opt,name=executor_name" json:"executor_name,omitempty"`
	TaskId           *TaskID             `protobuf:"bytes,5,opt,name=task_id" json:"task_id,omitempty"`
	Statistics       *ResourceStatistics `protobuf:"bytes,6,opt,name=statistics" json:"statistics,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*ResourceUsage) GetExecutorId 

func (m *ResourceUsage) GetExecutorId() *ExecutorID

func (*ResourceUsage) GetExecutorName 

func (m *ResourceUsage) GetExecutorName() string

func (*ResourceUsage) GetFrameworkId 

func (m *ResourceUsage) GetFrameworkId() *FrameworkID

func (*ResourceUsage) GetSlaveId 

func (m *ResourceUsage) GetSlaveId() *SlaveID

func (*ResourceUsage) GetStatistics 

func (m *ResourceUsage) GetStatistics() *ResourceStatistics

func (*ResourceUsage) GetTaskId 

func (m *ResourceUsage) GetTaskId() *TaskID

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset 

func (m *ResourceUsage) Reset()

func (*ResourceUsage) String 

func (m *ResourceUsage) String() string

type ReviveOffersMessage 

type ReviveOffersMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ReviveOffersMessage) GetFrameworkId 

func (m *ReviveOffersMessage) GetFrameworkId() *FrameworkID

func (*ReviveOffersMessage) ProtoMessage 

func (*ReviveOffersMessage) ProtoMessage()

func (*ReviveOffersMessage) Reset 

func (m *ReviveOffersMessage) Reset()

func (*ReviveOffersMessage) String 

func (m *ReviveOffersMessage) String() string

type RoleInfo 

type RoleInfo struct {
	Name             *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Weight           *float64 `protobuf:"fixed64,2,opt,name=weight,def=1" json:"weight,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*RoleInfo) GetName 

func (m *RoleInfo) GetName() string

func (*RoleInfo) GetWeight 

func (m *RoleInfo) GetWeight() float64

func (*RoleInfo) ProtoMessage 

func (*RoleInfo) ProtoMessage()

func (*RoleInfo) Reset 

func (m *RoleInfo) Reset()

func (*RoleInfo) String 

func (m *RoleInfo) String() string

type RunTaskMessage 

type RunTaskMessage struct {
	FrameworkId      *FrameworkID   `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	Framework        *FrameworkInfo `protobuf:"bytes,2,req,name=framework" json:"framework,omitempty"`
	Pid              *string        `protobuf:"bytes,3,req,name=pid" json:"pid,omitempty"`
	Task             *TaskInfo      `protobuf:"bytes,4,req,name=task" json:"task,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*RunTaskMessage) GetFramework 

func (m *RunTaskMessage) GetFramework() *FrameworkInfo

func (*RunTaskMessage) GetFrameworkId 

func (m *RunTaskMessage) GetFrameworkId() *FrameworkID

func (*RunTaskMessage) GetPid 

func (m *RunTaskMessage) GetPid() string

func (*RunTaskMessage) GetTask 

func (m *RunTaskMessage) GetTask() *TaskInfo

func (*RunTaskMessage) ProtoMessage 

func (*RunTaskMessage) ProtoMessage()

func (*RunTaskMessage) Reset 

func (m *RunTaskMessage) Reset()

func (*RunTaskMessage) String 

func (m *RunTaskMessage) String() string

type ShutdownExecutorMessage 

type ShutdownExecutorMessage struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ShutdownExecutorMessage) ProtoMessage 

func (*ShutdownExecutorMessage) ProtoMessage()

func (*ShutdownExecutorMessage) Reset 

func (m *ShutdownExecutorMessage) Reset()

func (*ShutdownExecutorMessage) String 

func (m *ShutdownExecutorMessage) String() string

type ShutdownFrameworkMessage 

type ShutdownFrameworkMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*ShutdownFrameworkMessage) GetFrameworkId 

func (m *ShutdownFrameworkMessage) GetFrameworkId() *FrameworkID

func (*ShutdownFrameworkMessage) ProtoMessage 

func (*ShutdownFrameworkMessage) ProtoMessage()

func (*ShutdownFrameworkMessage) Reset 

func (m *ShutdownFrameworkMessage) Reset()

func (*ShutdownFrameworkMessage) String 

func (m *ShutdownFrameworkMessage) String() string

type ShutdownMessage 

type ShutdownMessage struct {
	Message          *string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ShutdownMessage) GetMessage 

func (m *ShutdownMessage) GetMessage() string

func (*ShutdownMessage) ProtoMessage 

func (*ShutdownMessage) ProtoMessage()

func (*ShutdownMessage) Reset 

func (m *ShutdownMessage) Reset()

func (*ShutdownMessage) String 

func (m *ShutdownMessage) String() string

type SlaveID 

type SlaveID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SlaveID) GetValue 

func (m *SlaveID) GetValue() string

func (*SlaveID) ProtoMessage 

func (*SlaveID) ProtoMessage()

func (*SlaveID) Reset 

func (m *SlaveID) Reset()

func (*SlaveID) String 

func (m *SlaveID) String() string

type SlaveInfo 

type SlaveInfo struct {
	Hostname         *string      `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"`
	Port             *int32       `protobuf:"varint,8,opt,name=port,def=5051" json:"port,omitempty"`
	Resources        []*Resource  `protobuf:"bytes,3,rep,name=resources" json:"resources,omitempty"`
	Attributes       []*Attribute `protobuf:"bytes,5,rep,name=attributes" json:"attributes,omitempty"`
	Id               *SlaveID     `protobuf:"bytes,6,opt,name=id" json:"id,omitempty"`
	Checkpoint       *bool        `protobuf:"varint,7,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	WebuiHostname    *string      `protobuf:"bytes,2,opt,name=webui_hostname" json:"webui_hostname,omitempty"`
	WebuiPort        *int32       `protobuf:"varint,4,opt,name=webui_port,def=8081" json:"webui_port,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*SlaveInfo) GetAttributes 

func (m *SlaveInfo) GetAttributes() []*Attribute

func (*SlaveInfo) GetCheckpoint 

func (m *SlaveInfo) GetCheckpoint() bool

func (*SlaveInfo) GetHostname 

func (m *SlaveInfo) GetHostname() string

func (*SlaveInfo) GetId 

func (m *SlaveInfo) GetId() *SlaveID

func (*SlaveInfo) GetPort 

func (m *SlaveInfo) GetPort() int32

func (*SlaveInfo) GetResources 

func (m *SlaveInfo) GetResources() []*Resource

func (*SlaveInfo) GetWebuiHostname 

func (m *SlaveInfo) GetWebuiHostname() string

func (*SlaveInfo) GetWebuiPort 

func (m *SlaveInfo) GetWebuiPort() int32

func (*SlaveInfo) ProtoMessage 

func (*SlaveInfo) ProtoMessage()

func (*SlaveInfo) Reset 

func (m *SlaveInfo) Reset()

func (*SlaveInfo) String 

func (m *SlaveInfo) String() string

type SlaveRegisteredMessage 

type SlaveRegisteredMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SlaveRegisteredMessage) GetSlaveId 

func (m *SlaveRegisteredMessage) GetSlaveId() *SlaveID

func (*SlaveRegisteredMessage) ProtoMessage 

func (*SlaveRegisteredMessage) ProtoMessage()

func (*SlaveRegisteredMessage) Reset 

func (m *SlaveRegisteredMessage) Reset()

func (*SlaveRegisteredMessage) String 

func (m *SlaveRegisteredMessage) String() string

type SlaveReregisteredMessage 

type SlaveReregisteredMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*SlaveReregisteredMessage) GetSlaveId 

func (m *SlaveReregisteredMessage) GetSlaveId() *SlaveID

func (*SlaveReregisteredMessage) ProtoMessage 

func (*SlaveReregisteredMessage) ProtoMessage()

func (*SlaveReregisteredMessage) Reset 

func (m *SlaveReregisteredMessage) Reset()

func (*SlaveReregisteredMessage) String 

func (m *SlaveReregisteredMessage) String() string

type Status 

type Status int32
const (
	Status_DRIVER_NOT_STARTED Status = 1
	Status_DRIVER_RUNNING     Status = 2
	Status_DRIVER_ABORTED     Status = 3
	Status_DRIVER_STOPPED     Status = 4
)

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) String 

func (x Status) String() string

func (*Status) UnmarshalJSON 

func (x *Status) UnmarshalJSON(data []byte) error

type StatusUpdate 

type StatusUpdate struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID  `protobuf:"bytes,2,opt,name=executor_id" json:"executor_id,omitempty"`
	SlaveId          *SlaveID     `protobuf:"bytes,3,opt,name=slave_id" json:"slave_id,omitempty"`
	Status           *TaskStatus  `protobuf:"bytes,4,req,name=status" json:"status,omitempty"`
	Timestamp        *float64     `protobuf:"fixed64,5,req,name=timestamp" json:"timestamp,omitempty"`
	Uuid             []byte       `protobuf:"bytes,6,req,name=uuid" json:"uuid,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*StatusUpdate) GetExecutorId 

func (m *StatusUpdate) GetExecutorId() *ExecutorID

func (*StatusUpdate) GetFrameworkId 

func (m *StatusUpdate) GetFrameworkId() *FrameworkID

func (*StatusUpdate) GetSlaveId 

func (m *StatusUpdate) GetSlaveId() *SlaveID

func (*StatusUpdate) GetStatus 

func (m *StatusUpdate) GetStatus() *TaskStatus

func (*StatusUpdate) GetTimestamp 

func (m *StatusUpdate) GetTimestamp() float64

func (*StatusUpdate) GetUuid 

func (m *StatusUpdate) GetUuid() []byte

func (*StatusUpdate) ProtoMessage 

func (*StatusUpdate) ProtoMessage()

func (*StatusUpdate) Reset 

func (m *StatusUpdate) Reset()

func (*StatusUpdate) String 

func (m *StatusUpdate) String() string

type StatusUpdateAcknowledgementMessage 

type StatusUpdateAcknowledgementMessage struct {
	SlaveId          *SlaveID     `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	FrameworkId      *FrameworkID `protobuf:"bytes,2,req,name=framework_id" json:"framework_id,omitempty"`
	TaskId           *TaskID      `protobuf:"bytes,3,req,name=task_id" json:"task_id,omitempty"`
	Uuid             []byte       `protobuf:"bytes,4,req,name=uuid" json:"uuid,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*StatusUpdateAcknowledgementMessage) GetFrameworkId 

func (m *StatusUpdateAcknowledgementMessage) GetFrameworkId() *FrameworkID

func (*StatusUpdateAcknowledgementMessage) GetSlaveId 

func (m *StatusUpdateAcknowledgementMessage) GetSlaveId() *SlaveID

func (*StatusUpdateAcknowledgementMessage) GetTaskId 

func (m *StatusUpdateAcknowledgementMessage) GetTaskId() *TaskID

func (*StatusUpdateAcknowledgementMessage) GetUuid 

func (m *StatusUpdateAcknowledgementMessage) GetUuid() []byte

func (*StatusUpdateAcknowledgementMessage) ProtoMessage 

func (*StatusUpdateAcknowledgementMessage) ProtoMessage()

func (*StatusUpdateAcknowledgementMessage) Reset 

func (m *StatusUpdateAcknowledgementMessage) Reset()

func (*StatusUpdateAcknowledgementMessage) String 

func (m *StatusUpdateAcknowledgementMessage) String() string

type StatusUpdateMessage 

type StatusUpdateMessage struct {
	Update           *StatusUpdate `protobuf:"bytes,1,req,name=update" json:"update,omitempty"`
	Pid              *string       `protobuf:"bytes,2,opt,name=pid" json:"pid,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*StatusUpdateMessage) GetPid 

func (m *StatusUpdateMessage) GetPid() string

func (*StatusUpdateMessage) GetUpdate 

func (m *StatusUpdateMessage) GetUpdate() *StatusUpdate

func (*StatusUpdateMessage) ProtoMessage 

func (*StatusUpdateMessage) ProtoMessage()

func (*StatusUpdateMessage) Reset 

func (m *StatusUpdateMessage) Reset()

func (*StatusUpdateMessage) String 

func (m *StatusUpdateMessage) String() string

type StatusUpdateRecord 

type StatusUpdateRecord struct {
	Type             *StatusUpdateRecord_Type `protobuf:"varint,1,req,name=type,enum=mesos.internal.StatusUpdateRecord_Type" json:"type,omitempty"`
	Update           *StatusUpdate            `protobuf:"bytes,2,opt,name=update" json:"update,omitempty"`
	Uuid             []byte                   `protobuf:"bytes,3,opt,name=uuid" json:"uuid,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*StatusUpdateRecord) GetType 

func (m *StatusUpdateRecord) GetType() StatusUpdateRecord_Type

func (*StatusUpdateRecord) GetUpdate 

func (m *StatusUpdateRecord) GetUpdate() *StatusUpdate

func (*StatusUpdateRecord) GetUuid 

func (m *StatusUpdateRecord) GetUuid() []byte

func (*StatusUpdateRecord) ProtoMessage 

func (*StatusUpdateRecord) ProtoMessage()

func (*StatusUpdateRecord) Reset 

func (m *StatusUpdateRecord) Reset()

func (*StatusUpdateRecord) String 

func (m *StatusUpdateRecord) String() string

type StatusUpdateRecord_Type 

type StatusUpdateRecord_Type int32
const (
	StatusUpdateRecord_UPDATE StatusUpdateRecord_Type = 0
	StatusUpdateRecord_ACK    StatusUpdateRecord_Type = 1
)

func (StatusUpdateRecord_Type) Enum 

func (x StatusUpdateRecord_Type) Enum() *StatusUpdateRecord_Type

func (StatusUpdateRecord_Type) String 

func (x StatusUpdateRecord_Type) String() string

func (*StatusUpdateRecord_Type) UnmarshalJSON 

func (x *StatusUpdateRecord_Type) UnmarshalJSON(data []byte) error

type SubmitSchedulerRequest 

type SubmitSchedulerRequest struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SubmitSchedulerRequest) GetName 

func (m *SubmitSchedulerRequest) GetName() string

func (*SubmitSchedulerRequest) ProtoMessage 

func (*SubmitSchedulerRequest) ProtoMessage()

func (*SubmitSchedulerRequest) Reset 

func (m *SubmitSchedulerRequest) Reset()

func (*SubmitSchedulerRequest) String 

func (m *SubmitSchedulerRequest) String() string

type SubmitSchedulerResponse 

type SubmitSchedulerResponse struct {
	Okay             *bool  `protobuf:"varint,1,req,name=okay" json:"okay,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SubmitSchedulerResponse) GetOkay 

func (m *SubmitSchedulerResponse) GetOkay() bool

func (*SubmitSchedulerResponse) ProtoMessage 

func (*SubmitSchedulerResponse) ProtoMessage()

func (*SubmitSchedulerResponse) Reset 

func (m *SubmitSchedulerResponse) Reset()

func (*SubmitSchedulerResponse) String 

func (m *SubmitSchedulerResponse) String() string

type Task 

type Task struct {
	Name             *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId           *TaskID       `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	FrameworkId      *FrameworkID  `protobuf:"bytes,3,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId       *ExecutorID   `protobuf:"bytes,4,opt,name=executor_id" json:"executor_id,omitempty"`
	SlaveId          *SlaveID      `protobuf:"bytes,5,req,name=slave_id" json:"slave_id,omitempty"`
	State            *TaskState    `protobuf:"varint,6,req,name=state,enum=mesos.TaskState" json:"state,omitempty"`
	Resources        []*Resource   `protobuf:"bytes,7,rep,name=resources" json:"resources,omitempty"`
	Statuses         []*TaskStatus `protobuf:"bytes,8,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Task) GetExecutorId 

func (m *Task) GetExecutorId() *ExecutorID

func (*Task) GetFrameworkId 

func (m *Task) GetFrameworkId() *FrameworkID

func (*Task) GetName 

func (m *Task) GetName() string

func (*Task) GetResources 

func (m *Task) GetResources() []*Resource

func (*Task) GetSlaveId 

func (m *Task) GetSlaveId() *SlaveID

func (*Task) GetState 

func (m *Task) GetState() TaskState

func (*Task) GetStatuses 

func (m *Task) GetStatuses() []*TaskStatus

func (*Task) GetTaskId 

func (m *Task) GetTaskId() *TaskID

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

type TaskHealthStatus 

type TaskHealthStatus struct {
	TaskId              *TaskID `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	Healthy             *bool   `protobuf:"varint,2,req,name=healthy" json:"healthy,omitempty"`
	KillTask            *bool   `protobuf:"varint,3,opt,name=kill_task,def=0" json:"kill_task,omitempty"`
	ConsecutiveFailures *int32  `protobuf:"varint,4,opt,name=consecutive_failures" json:"consecutive_failures,omitempty"`
	XXX_unrecognized    []byte  `json:"-"`
}

func (*TaskHealthStatus) GetConsecutiveFailures 

func (m *TaskHealthStatus) GetConsecutiveFailures() int32

func (*TaskHealthStatus) GetHealthy 

func (m *TaskHealthStatus) GetHealthy() bool

func (*TaskHealthStatus) GetKillTask 

func (m *TaskHealthStatus) GetKillTask() bool

func (*TaskHealthStatus) GetTaskId 

func (m *TaskHealthStatus) GetTaskId() *TaskID

func (*TaskHealthStatus) ProtoMessage 

func (*TaskHealthStatus) ProtoMessage()

func (*TaskHealthStatus) Reset 

func (m *TaskHealthStatus) Reset()

func (*TaskHealthStatus) String 

func (m *TaskHealthStatus) String() string

type TaskID 

type TaskID struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TaskID) GetValue 

func (m *TaskID) GetValue() string

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) Reset 

func (m *TaskID) Reset()

func (*TaskID) String 

func (m *TaskID) String() string

type TaskInfo 

type TaskInfo struct {
	Name             *string        `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId           *TaskID        `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	SlaveId          *SlaveID       `protobuf:"bytes,3,req,name=slave_id" json:"slave_id,omitempty"`
	Resources        []*Resource    `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"`
	Executor         *ExecutorInfo  `protobuf:"bytes,5,opt,name=executor" json:"executor,omitempty"`
	Command          *CommandInfo   `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	Container        *ContainerInfo `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	Data             []byte         `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	HealthCheck      *HealthCheck   `protobuf:"bytes,8,opt,name=health_check" json:"health_check,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*TaskInfo) GetCommand 

func (m *TaskInfo) GetCommand() *CommandInfo

func (*TaskInfo) GetContainer 

func (m *TaskInfo) GetContainer() *ContainerInfo

func (*TaskInfo) GetData 

func (m *TaskInfo) GetData() []byte

func (*TaskInfo) GetExecutor 

func (m *TaskInfo) GetExecutor() *ExecutorInfo

func (*TaskInfo) GetHealthCheck 

func (m *TaskInfo) GetHealthCheck() *HealthCheck

func (*TaskInfo) GetName 

func (m *TaskInfo) GetName() string

func (*TaskInfo) GetResources 

func (m *TaskInfo) GetResources() []*Resource

func (*TaskInfo) GetSlaveId 

func (m *TaskInfo) GetSlaveId() *SlaveID

func (*TaskInfo) GetTaskId 

func (m *TaskInfo) GetTaskId() *TaskID

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) String 

func (m *TaskInfo) String() string

type TaskState 

type TaskState int32
const (
	TaskState_TASK_STAGING  TaskState = 6
	TaskState_TASK_STARTING TaskState = 0
	TaskState_TASK_RUNNING  TaskState = 1
	TaskState_TASK_FINISHED TaskState = 2
	TaskState_TASK_FAILED   TaskState = 3
	TaskState_TASK_KILLED   TaskState = 4
	TaskState_TASK_LOST     TaskState = 5
)

func (TaskState) Enum 

func (x TaskState) Enum() *TaskState

func (TaskState) String 

func (x TaskState) String() string

func (*TaskState) UnmarshalJSON 

func (x *TaskState) UnmarshalJSON(data []byte) error

type TaskStatus 

type TaskStatus struct {
	TaskId           *TaskID     `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	State            *TaskState  `protobuf:"varint,2,req,name=state,enum=mesos.TaskState" json:"state,omitempty"`
	Message          *string     `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Data             []byte      `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	SlaveId          *SlaveID    `protobuf:"bytes,5,opt,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId       *ExecutorID `protobuf:"bytes,7,opt,name=executor_id" json:"executor_id,omitempty"`
	Timestamp        *float64    `protobuf:"fixed64,6,opt,name=timestamp" json:"timestamp,omitempty"`
	Healthy          *bool       `protobuf:"varint,8,opt,name=healthy" json:"healthy,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*TaskStatus) GetData 

func (m *TaskStatus) GetData() []byte

func (*TaskStatus) GetExecutorId 

func (m *TaskStatus) GetExecutorId() *ExecutorID

func (*TaskStatus) GetHealthy 

func (m *TaskStatus) GetHealthy() bool

func (*TaskStatus) GetMessage 

func (m *TaskStatus) GetMessage() string

func (*TaskStatus) GetSlaveId 

func (m *TaskStatus) GetSlaveId() *SlaveID

func (*TaskStatus) GetState 

func (m *TaskStatus) GetState() TaskState

func (*TaskStatus) GetTaskId 

func (m *TaskStatus) GetTaskId() *TaskID

func (*TaskStatus) GetTimestamp 

func (m *TaskStatus) GetTimestamp() float64

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) String 

func (m *TaskStatus) String() string

type UnregisterFrameworkMessage 

type UnregisterFrameworkMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*UnregisterFrameworkMessage) GetFrameworkId 

func (m *UnregisterFrameworkMessage) GetFrameworkId() *FrameworkID

func (*UnregisterFrameworkMessage) ProtoMessage 

func (*UnregisterFrameworkMessage) ProtoMessage()

func (*UnregisterFrameworkMessage) Reset 

func (m *UnregisterFrameworkMessage) Reset()

func (*UnregisterFrameworkMessage) String 

func (m *UnregisterFrameworkMessage) String() string

type UnregisterSlaveMessage 

type UnregisterSlaveMessage struct {
	SlaveId          *SlaveID `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*UnregisterSlaveMessage) GetSlaveId 

func (m *UnregisterSlaveMessage) GetSlaveId() *SlaveID

func (*UnregisterSlaveMessage) ProtoMessage 

func (*UnregisterSlaveMessage) ProtoMessage()

func (*UnregisterSlaveMessage) Reset 

func (m *UnregisterSlaveMessage) Reset()

func (*UnregisterSlaveMessage) String 

func (m *UnregisterSlaveMessage) String() string

type UpdateFrameworkMessage 

type UpdateFrameworkMessage struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	Pid              *string      `protobuf:"bytes,2,req,name=pid" json:"pid,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*UpdateFrameworkMessage) GetFrameworkId 

func (m *UpdateFrameworkMessage) GetFrameworkId() *FrameworkID

func (*UpdateFrameworkMessage) GetPid 

func (m *UpdateFrameworkMessage) GetPid() string

func (*UpdateFrameworkMessage) ProtoMessage 

func (*UpdateFrameworkMessage) ProtoMessage()

func (*UpdateFrameworkMessage) Reset 

func (m *UpdateFrameworkMessage) Reset()

func (*UpdateFrameworkMessage) String 

func (m *UpdateFrameworkMessage) String() string

type Value 

type Value struct {
	Type             *Value_Type   `protobuf:"varint,1,req,name=type,enum=mesos.Value_Type" json:"type,omitempty"`
	Scalar           *Value_Scalar `protobuf:"bytes,2,opt,name=scalar" json:"scalar,omitempty"`
	Ranges           *Value_Ranges `protobuf:"bytes,3,opt,name=ranges" json:"ranges,omitempty"`
	Set              *Value_Set    `protobuf:"bytes,4,opt,name=set" json:"set,omitempty"`
	Text             *Value_Text   `protobuf:"bytes,5,opt,name=text" json:"text,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*Value) GetRanges 

func (m *Value) GetRanges() *Value_Ranges

func (*Value) GetScalar 

func (m *Value) GetScalar() *Value_Scalar

func (*Value) GetSet 

func (m *Value) GetSet() *Value_Set

func (*Value) GetText 

func (m *Value) GetText() *Value_Text

func (*Value) GetType 

func (m *Value) GetType() Value_Type

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

type Value_Range 

type Value_Range struct {
	Begin            *uint64 `protobuf:"varint,1,req,name=begin" json:"begin,omitempty"`
	End              *uint64 `protobuf:"varint,2,req,name=end" json:"end,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Value_Range) GetBegin 

func (m *Value_Range) GetBegin() uint64

func (*Value_Range) GetEnd 

func (m *Value_Range) GetEnd() uint64

func (*Value_Range) ProtoMessage 

func (*Value_Range) ProtoMessage()

func (*Value_Range) Reset 

func (m *Value_Range) Reset()

func (*Value_Range) String 

func (m *Value_Range) String() string

type Value_Ranges 

type Value_Ranges struct {
	Range            []*Value_Range `protobuf:"bytes,1,rep,name=range" json:"range,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*Value_Ranges) GetRange 

func (m *Value_Ranges) GetRange() []*Value_Range

func (*Value_Ranges) ProtoMessage 

func (*Value_Ranges) ProtoMessage()

func (*Value_Ranges) Reset 

func (m *Value_Ranges) Reset()

func (*Value_Ranges) String 

func (m *Value_Ranges) String() string

type Value_Scalar 

type Value_Scalar struct {
	Value            *float64 `protobuf:"fixed64,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Value_Scalar) GetValue 

func (m *Value_Scalar) GetValue() float64

func (*Value_Scalar) ProtoMessage 

func (*Value_Scalar) ProtoMessage()

func (*Value_Scalar) Reset 

func (m *Value_Scalar) Reset()

func (*Value_Scalar) String 

func (m *Value_Scalar) String() string

type Value_Set 

type Value_Set struct {
	Item             []string `protobuf:"bytes,1,rep,name=item" json:"item,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*Value_Set) GetItem 

func (m *Value_Set) GetItem() []string

func (*Value_Set) ProtoMessage 

func (*Value_Set) ProtoMessage()

func (*Value_Set) Reset 

func (m *Value_Set) Reset()

func (*Value_Set) String 

func (m *Value_Set) String() string

type Value_Text 

type Value_Text struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Value_Text) GetValue 

func (m *Value_Text) GetValue() string

func (*Value_Text) ProtoMessage 

func (*Value_Text) ProtoMessage()

func (*Value_Text) Reset 

func (m *Value_Text) Reset()

func (*Value_Text) String 

func (m *Value_Text) String() string

type Value_Type 

type Value_Type int32
const (
	Value_SCALAR Value_Type = 0
	Value_RANGES Value_Type = 1
	Value_SET    Value_Type = 2
	Value_TEXT   Value_Type = 3
)

func (Value_Type) Enum 

func (x Value_Type) Enum() *Value_Type

func (Value_Type) String 

func (x Value_Type) String() string

func (*Value_Type) UnmarshalJSON 

func (x *Value_Type) UnmarshalJSON(data []byte) error

type Volume 

type Volume struct {
	ContainerPath    *string      `protobuf:"bytes,1,req,name=container_path" json:"container_path,omitempty"`
	HostPath         *string      `protobuf:"bytes,2,opt,name=host_path" json:"host_path,omitempty"`
	Mode             *Volume_Mode `protobuf:"varint,3,req,name=mode,enum=mesos.Volume_Mode" json:"mode,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Volume) GetContainerPath 

func (m *Volume) GetContainerPath() string

func (*Volume) GetHostPath 

func (m *Volume) GetHostPath() string

func (*Volume) GetMode 

func (m *Volume) GetMode() Volume_Mode

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) String 

func (m *Volume) String() string

type Volume_Mode 

type Volume_Mode int32
const (
	Volume_RW Volume_Mode = 1
	Volume_RO Volume_Mode = 2
)

func (Volume_Mode) Enum 

func (x Volume_Mode) Enum() *Volume_Mode

func (Volume_Mode) String 

func (x Volume_Mode) String() string

func (*Volume_Mode) UnmarshalJSON 

func (x *Volume_Mode) UnmarshalJSON(data []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.