mesosproto

package
v1.1.1-beta.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2015 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package mesosproto is a generated protocol buffer package.

It is generated from these files: 

authentication.proto
containerizer.proto
internal.proto
log.proto
mesos.proto
messages.proto
registry.proto
scheduler.proto
state.proto

It has these top-level messages: 

AuthenticateMessage
AuthenticationMechanismsMessage
AuthenticationStartMessage
AuthenticationStepMessage
AuthenticationCompletedMessage
AuthenticationFailedMessage
AuthenticationErrorMessage
Launch
Update
Wait
Destroy
Usage
Termination
Containers
InternalMasterChangeDetected
InternalTryAuthentication
InternalAuthenticationResult
Promise
Action
Metadata
Record
PromiseRequest
PromiseResponse
WriteRequest
WriteResponse
LearnedMessage
RecoverRequest
RecoverResponse
FrameworkID
OfferID
SlaveID
TaskID
ExecutorID
ContainerID
FrameworkInfo
HealthCheck
CommandInfo
ExecutorInfo
MasterInfo
SlaveInfo
Value
Attribute
Resource
TrafficControlStatistics
ResourceStatistics
ResourceUsage
PerfStatistics
Request
Offer
TaskInfo
TaskStatus
Filters
Environment
Parameter
Parameters
Credential
Credentials
ACL
ACLs
RateLimit
RateLimits
Volume
ContainerInfo
Labels
Label
Port
Ports
DiscoveryInfo
Task
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
MasterSlaveConnection
PingSlaveMessage
PongSlaveMessage
ShutdownFrameworkMessage
ShutdownExecutorMessage
UpdateFrameworkMessage
CheckpointResourcesMessage
UpdateSlaveMessage
RegisterExecutorMessage
ExecutorRegisteredMessage
ExecutorReregisteredMessage
ExitedExecutorMessage
ReconnectExecutorMessage
ReregisterExecutorMessage
ShutdownMessage
Archive
TaskHealthStatus
HookExecuted
Registry
Event
Call
Entry
Operation

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_ContainerInfo_DockerInfo_Privileged bool = false
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_Metadata_Promised uint64 = 0
View Source 
const Default_Resource_Role string = "*"
View Source 
const Default_SlaveInfo_Checkpoint bool = false
View Source 
const Default_SlaveInfo_Port int32 = 5051
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 Action_Type_name = map[int32]string{
	1: "NOP",
	2: "APPEND",
	3: "TRUNCATE",
}
View Source 
var Action_Type_value = map[string]int32{
	"NOP":      1,
	"APPEND":   2,
	"TRUNCATE": 3,
}
View Source 
var Call_Type_name = map[int32]string{
	1:  "SUBSCRIBE",
	2:  "TEARDOWN",
	3:  "ACCEPT",
	4:  "DECLINE",
	5:  "REVIVE",
	6:  "KILL",
	7:  "SHUTDOWN",
	8:  "ACKNOWLEDGE",
	9:  "RECONCILE",
	10: "MESSAGE",
}
View Source 
var Call_Type_value = map[string]int32{
	"SUBSCRIBE":   1,
	"TEARDOWN":    2,
	"ACCEPT":      3,
	"DECLINE":     4,
	"REVIVE":      5,
	"KILL":        6,
	"SHUTDOWN":    7,
	"ACKNOWLEDGE": 8,
	"RECONCILE":   9,
	"MESSAGE":     10,
}
View Source 
var ContainerInfo_DockerInfo_Network_name = map[int32]string{
	1: "HOST",
	2: "BRIDGE",
	3: "NONE",
}
View Source 
var ContainerInfo_DockerInfo_Network_value = map[string]int32{
	"HOST":   1,
	"BRIDGE": 2,
	"NONE":   3,
}
View Source 
var ContainerInfo_Type_name = map[int32]string{
	1: "DOCKER",
	2: "MESOS",
}
View Source 
var ContainerInfo_Type_value = map[string]int32{
	"DOCKER": 1,
	"MESOS":  2,
}
View Source 
var DiscoveryInfo_Visibility_name = map[int32]string{
	0: "FRAMEWORK",
	1: "CLUSTER",
	2: "EXTERNAL",
}
View Source 
var DiscoveryInfo_Visibility_value = map[string]int32{
	"FRAMEWORK": 0,
	"CLUSTER":   1,
	"EXTERNAL":  2,
}
View Source 
var (
	ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthMesos = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var Event_Type_name = map[int32]string{
	1: "SUBSCRIBED",
	2: "OFFERS",
	3: "RESCIND",
	4: "UPDATE",
	5: "MESSAGE",
	6: "FAILURE",
	7: "ERROR",
}
View Source 
var Event_Type_value = map[string]int32{
	"SUBSCRIBED": 1,
	"OFFERS":     2,
	"RESCIND":    3,
	"UPDATE":     4,
	"MESSAGE":    5,
	"FAILURE":    6,
	"ERROR":      7,
}
View Source 
var FrameworkInfo_Capability_Type_name = map[int32]string{
	1: "REVOCABLE_RESOURCES",
}
View Source 
var FrameworkInfo_Capability_Type_value = map[string]int32{
	"REVOCABLE_RESOURCES": 1,
}
View Source 
var Metadata_Status_name = map[int32]string{
	1: "VOTING",
	2: "RECOVERING",
	3: "STARTING",
	4: "EMPTY",
}
View Source 
var Metadata_Status_value = map[string]int32{
	"VOTING":     1,
	"RECOVERING": 2,
	"STARTING":   3,
	"EMPTY":      4,
}
View Source 
var Offer_Operation_Type_name = map[int32]string{
	1: "LAUNCH",
	2: "RESERVE",
	3: "UNRESERVE",
	4: "CREATE",
	5: "DESTROY",
}
View Source 
var Offer_Operation_Type_value = map[string]int32{
	"LAUNCH":    1,
	"RESERVE":   2,
	"UNRESERVE": 3,
	"CREATE":    4,
	"DESTROY":   5,
}
View Source 
var Operation_Type_name = map[int32]string{
	1: "SNAPSHOT",
	3: "DIFF",
	2: "EXPUNGE",
}
View Source 
var Operation_Type_value = map[string]int32{
	"SNAPSHOT": 1,
	"DIFF":     3,
	"EXPUNGE":  2,
}
View Source 
var Record_Type_name = map[int32]string{
	1: "PROMISE",
	2: "ACTION",
	3: "METADATA",
}
View Source 
var Record_Type_value = map[string]int32{
	"PROMISE":  1,
	"ACTION":   2,
	"METADATA": 3,
}
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",
	7: "TASK_ERROR",
}
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,
	"TASK_ERROR":    7,
}
View Source 
var TaskStatus_Reason_name = map[int32]string{
	0:  "REASON_COMMAND_EXECUTOR_FAILED",
	17: "REASON_EXECUTOR_PREEMPTED",
	1:  "REASON_EXECUTOR_TERMINATED",
	2:  "REASON_EXECUTOR_UNREGISTERED",
	3:  "REASON_FRAMEWORK_REMOVED",
	4:  "REASON_GC_ERROR",
	5:  "REASON_INVALID_FRAMEWORKID",
	6:  "REASON_INVALID_OFFERS",
	7:  "REASON_MASTER_DISCONNECTED",
	8:  "REASON_MEMORY_LIMIT",
	9:  "REASON_RECONCILIATION",
	18: "REASON_RESOURCES_UNKNOWN",
	10: "REASON_SLAVE_DISCONNECTED",
	11: "REASON_SLAVE_REMOVED",
	12: "REASON_SLAVE_RESTARTED",
	13: "REASON_SLAVE_UNKNOWN",
	14: "REASON_TASK_INVALID",
	15: "REASON_TASK_UNAUTHORIZED",
	16: "REASON_TASK_UNKNOWN",
}
View Source 
var TaskStatus_Reason_value = map[string]int32{
	"REASON_COMMAND_EXECUTOR_FAILED": 0,
	"REASON_EXECUTOR_PREEMPTED":      17,
	"REASON_EXECUTOR_TERMINATED":     1,
	"REASON_EXECUTOR_UNREGISTERED":   2,
	"REASON_FRAMEWORK_REMOVED":       3,
	"REASON_GC_ERROR":                4,
	"REASON_INVALID_FRAMEWORKID":     5,
	"REASON_INVALID_OFFERS":          6,
	"REASON_MASTER_DISCONNECTED":     7,
	"REASON_MEMORY_LIMIT":            8,
	"REASON_RECONCILIATION":          9,
	"REASON_RESOURCES_UNKNOWN":       18,
	"REASON_SLAVE_DISCONNECTED":      10,
	"REASON_SLAVE_REMOVED":           11,
	"REASON_SLAVE_RESTARTED":         12,
	"REASON_SLAVE_UNKNOWN":           13,
	"REASON_TASK_INVALID":            14,
	"REASON_TASK_UNAUTHORIZED":       15,
	"REASON_TASK_UNKNOWN":            16,
}
View Source 
var TaskStatus_Source_name = map[int32]string{
	0: "SOURCE_MASTER",
	1: "SOURCE_SLAVE",
	2: "SOURCE_EXECUTOR",
}
View Source 
var TaskStatus_Source_value = map[string]int32{
	"SOURCE_MASTER":   0,
	"SOURCE_SLAVE":    1,
	"SOURCE_EXECUTOR": 2,
}
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:"-"`
}

* ACLs used for authorization.

func NewPopulatedACL 

func NewPopulatedACL(r randyMesos, easy bool) *ACL

func (*ACL) Equal 

func (this *ACL) Equal(that interface{}) bool

func (*ACL) GoString 

func (this *ACL) GoString() string

func (*ACL) Marshal 

func (m *ACL) Marshal() (data []byte, err error)

func (*ACL) MarshalTo 

func (m *ACL) MarshalTo(data []byte) (int, error)

func (*ACL) ProtoMessage 

func (*ACL) ProtoMessage()

func (*ACL) Reset 

func (m *ACL) Reset()

func (*ACL) Size 

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

func (*ACL) String 

func (this *ACL) String() string

func (*ACL) Unmarshal 

func (m *ACL) Unmarshal(data []byte) error

func (*ACL) VerboseEqual 

func (this *ACL) VerboseEqual(that interface{}) error

type ACL_Entity 

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

Entity is used to describe a subject(s) or an object(s) of an ACL. NOTE: To allow everyone access to an Entity set its type to 'ANY'. To deny access to an Entity set its type to 'NONE'.

func NewPopulatedACL_Entity 

func NewPopulatedACL_Entity(r randyMesos, easy bool) *ACL_Entity

func (*ACL_Entity) Equal 

func (this *ACL_Entity) Equal(that interface{}) bool

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) GoString 

func (this *ACL_Entity) GoString() string

func (*ACL_Entity) Marshal 

func (m *ACL_Entity) Marshal() (data []byte, err error)

func (*ACL_Entity) MarshalTo 

func (m *ACL_Entity) MarshalTo(data []byte) (int, error)

func (*ACL_Entity) ProtoMessage 

func (*ACL_Entity) ProtoMessage()

func (*ACL_Entity) Reset 

func (m *ACL_Entity) Reset()

func (*ACL_Entity) Size 

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

func (*ACL_Entity) String 

func (this *ACL_Entity) String() string

func (*ACL_Entity) Unmarshal 

func (m *ACL_Entity) Unmarshal(data []byte) error

func (*ACL_Entity) VerboseEqual 

func (this *ACL_Entity) VerboseEqual(that interface{}) error

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 {
	// Subjects.
	Principals *ACL_Entity `protobuf:"bytes,1,req,name=principals" json:"principals,omitempty"`
	// Objects.
	Roles            *ACL_Entity `protobuf:"bytes,2,req,name=roles" json:"roles,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

ACLs.

func NewPopulatedACL_RegisterFramework 

func NewPopulatedACL_RegisterFramework(r randyMesos, easy bool) *ACL_RegisterFramework

func (*ACL_RegisterFramework) Equal 

func (this *ACL_RegisterFramework) Equal(that interface{}) bool

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) GoString 

func (this *ACL_RegisterFramework) GoString() string

func (*ACL_RegisterFramework) Marshal 

func (m *ACL_RegisterFramework) Marshal() (data []byte, err error)

func (*ACL_RegisterFramework) MarshalTo 

func (m *ACL_RegisterFramework) MarshalTo(data []byte) (int, error)

func (*ACL_RegisterFramework) ProtoMessage 

func (*ACL_RegisterFramework) ProtoMessage()

func (*ACL_RegisterFramework) Reset 

func (m *ACL_RegisterFramework) Reset()

func (*ACL_RegisterFramework) Size 

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

func (*ACL_RegisterFramework) String 

func (this *ACL_RegisterFramework) String() string

func (*ACL_RegisterFramework) Unmarshal 

func (m *ACL_RegisterFramework) Unmarshal(data []byte) error

func (*ACL_RegisterFramework) VerboseEqual 

func (this *ACL_RegisterFramework) VerboseEqual(that interface{}) error

type ACL_RunTask 

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

func NewPopulatedACL_RunTask 

func NewPopulatedACL_RunTask(r randyMesos, easy bool) *ACL_RunTask

func (*ACL_RunTask) Equal 

func (this *ACL_RunTask) Equal(that interface{}) bool

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) GoString 

func (this *ACL_RunTask) GoString() string

func (*ACL_RunTask) Marshal 

func (m *ACL_RunTask) Marshal() (data []byte, err error)

func (*ACL_RunTask) MarshalTo 

func (m *ACL_RunTask) MarshalTo(data []byte) (int, error)

func (*ACL_RunTask) ProtoMessage 

func (*ACL_RunTask) ProtoMessage()

func (*ACL_RunTask) Reset 

func (m *ACL_RunTask) Reset()

func (*ACL_RunTask) Size 

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

func (*ACL_RunTask) String 

func (this *ACL_RunTask) String() string

func (*ACL_RunTask) Unmarshal 

func (m *ACL_RunTask) Unmarshal(data []byte) error

func (*ACL_RunTask) VerboseEqual 

func (this *ACL_RunTask) VerboseEqual(that interface{}) error

type ACL_ShutdownFramework 

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

Which principals are authorized to shutdown frameworks of other principals.

func NewPopulatedACL_ShutdownFramework 

func NewPopulatedACL_ShutdownFramework(r randyMesos, easy bool) *ACL_ShutdownFramework

func (*ACL_ShutdownFramework) Equal 

func (this *ACL_ShutdownFramework) Equal(that interface{}) bool

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) GoString 

func (this *ACL_ShutdownFramework) GoString() string

func (*ACL_ShutdownFramework) Marshal 

func (m *ACL_ShutdownFramework) Marshal() (data []byte, err error)

func (*ACL_ShutdownFramework) MarshalTo 

func (m *ACL_ShutdownFramework) MarshalTo(data []byte) (int, error)

func (*ACL_ShutdownFramework) ProtoMessage 

func (*ACL_ShutdownFramework) ProtoMessage()

func (*ACL_ShutdownFramework) Reset 

func (m *ACL_ShutdownFramework) Reset()

func (*ACL_ShutdownFramework) Size 

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

func (*ACL_ShutdownFramework) String 

func (this *ACL_ShutdownFramework) String() string

func (*ACL_ShutdownFramework) Unmarshal 

func (m *ACL_ShutdownFramework) Unmarshal(data []byte) error

func (*ACL_ShutdownFramework) VerboseEqual 

func (this *ACL_ShutdownFramework) VerboseEqual(that interface{}) error

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:"-"`
}

* Collection of ACL.

Each authorization request is evaluated against the ACLs in the order they are defined.

For simplicity, the ACLs for a given action are not aggregated even when they have the same subjects or objects. The first ACL that matches the request determines whether that request should be permitted or not. An ACL matches iff both the subjects (e.g., clients, principals) and the objects (e.g., urls, users, roles) of the ACL match the request.

If none of the ACLs match the request, the 'permissive' field determines whether the request should be permitted or not.

TODO(vinod): Do aggregation of ACLs when possible.

func NewPopulatedACLs 

func NewPopulatedACLs(r randyMesos, easy bool) *ACLs

func (*ACLs) Equal 

func (this *ACLs) Equal(that interface{}) bool

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) GoString 

func (this *ACLs) GoString() string

func (*ACLs) Marshal 

func (m *ACLs) Marshal() (data []byte, err error)

func (*ACLs) MarshalTo 

func (m *ACLs) MarshalTo(data []byte) (int, error)

func (*ACLs) ProtoMessage 

func (*ACLs) ProtoMessage()

func (*ACLs) Reset 

func (m *ACLs) Reset()

func (*ACLs) Size 

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

func (*ACLs) String 

func (this *ACLs) String() string

func (*ACLs) Unmarshal 

func (m *ACLs) Unmarshal(data []byte) error

func (*ACLs) VerboseEqual 

func (this *ACLs) VerboseEqual(that interface{}) error

type Action 

type Action struct {
	Position         *uint64          `protobuf:"varint,1,req,name=position" json:"position,omitempty"`
	Promised         *uint64          `protobuf:"varint,2,req,name=promised" json:"promised,omitempty"`
	Performed        *uint64          `protobuf:"varint,3,opt,name=performed" json:"performed,omitempty"`
	Learned          *bool            `protobuf:"varint,4,opt,name=learned" json:"learned,omitempty"`
	Type             *Action_Type     `protobuf:"varint,5,opt,name=type,enum=mesosproto.Action_Type" json:"type,omitempty"`
	Nop              *Action_Nop      `protobuf:"bytes,6,opt,name=nop" json:"nop,omitempty"`
	Append           *Action_Append   `protobuf:"bytes,7,opt,name=append" json:"append,omitempty"`
	Truncate         *Action_Truncate `protobuf:"bytes,8,opt,name=truncate" json:"truncate,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

Represents an "action" performed on the log. Each action has an associated position in the log. In addition, each action (i.e., position) will have been "promised" to a specific proposer (implicitly or explicitly) and may have been "performed" from a specific proposer. An action may also be "learned" to have reached consensus. There are three types of possible actions that can be performed on the log: nop (no action), append, and truncate.

func NewPopulatedAction 

func NewPopulatedAction(r randyLog, easy bool) *Action

func (*Action) Equal 

func (this *Action) Equal(that interface{}) bool

func (*Action) GetAppend 

func (m *Action) GetAppend() *Action_Append

func (*Action) GetLearned 

func (m *Action) GetLearned() bool

func (*Action) GetNop 

func (m *Action) GetNop() *Action_Nop

func (*Action) GetPerformed 

func (m *Action) GetPerformed() uint64

func (*Action) GetPosition 

func (m *Action) GetPosition() uint64

func (*Action) GetPromised 

func (m *Action) GetPromised() uint64

func (*Action) GetTruncate 

func (m *Action) GetTruncate() *Action_Truncate

func (*Action) GetType 

func (m *Action) GetType() Action_Type

func (*Action) GoString 

func (this *Action) GoString() string

func (*Action) Marshal 

func (m *Action) Marshal() (data []byte, err error)

func (*Action) MarshalTo 

func (m *Action) MarshalTo(data []byte) (int, error)

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) Size 

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

func (*Action) String 

func (this *Action) String() string

func (*Action) Unmarshal 

func (m *Action) Unmarshal(data []byte) error

func (*Action) VerboseEqual 

func (this *Action) VerboseEqual(that interface{}) error

type Action_Append 

type Action_Append struct {
	Bytes            []byte `protobuf:"bytes,1,req,name=bytes" json:"bytes,omitempty"`
	Cksum            []byte `protobuf:"bytes,2,opt,name=cksum" json:"cksum,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func NewPopulatedAction_Append 

func NewPopulatedAction_Append(r randyLog, easy bool) *Action_Append

func (*Action_Append) Equal 

func (this *Action_Append) Equal(that interface{}) bool

func (*Action_Append) GetBytes 

func (m *Action_Append) GetBytes() []byte

func (*Action_Append) GetCksum 

func (m *Action_Append) GetCksum() []byte

func (*Action_Append) GoString 

func (this *Action_Append) GoString() string

func (*Action_Append) Marshal 

func (m *Action_Append) Marshal() (data []byte, err error)

func (*Action_Append) MarshalTo 

func (m *Action_Append) MarshalTo(data []byte) (int, error)

func (*Action_Append) ProtoMessage 

func (*Action_Append) ProtoMessage()

func (*Action_Append) Reset 

func (m *Action_Append) Reset()

func (*Action_Append) Size 

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

func (*Action_Append) String 

func (this *Action_Append) String() string

func (*Action_Append) Unmarshal 

func (m *Action_Append) Unmarshal(data []byte) error

func (*Action_Append) VerboseEqual 

func (this *Action_Append) VerboseEqual(that interface{}) error

type Action_Nop 

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

func NewPopulatedAction_Nop 

func NewPopulatedAction_Nop(r randyLog, easy bool) *Action_Nop

func (*Action_Nop) Equal 

func (this *Action_Nop) Equal(that interface{}) bool

func (*Action_Nop) GoString 

func (this *Action_Nop) GoString() string

func (*Action_Nop) Marshal 

func (m *Action_Nop) Marshal() (data []byte, err error)

func (*Action_Nop) MarshalTo 

func (m *Action_Nop) MarshalTo(data []byte) (int, error)

func (*Action_Nop) ProtoMessage 

func (*Action_Nop) ProtoMessage()

func (*Action_Nop) Reset 

func (m *Action_Nop) Reset()

func (*Action_Nop) Size 

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

func (*Action_Nop) String 

func (this *Action_Nop) String() string

func (*Action_Nop) Unmarshal 

func (m *Action_Nop) Unmarshal(data []byte) error

func (*Action_Nop) VerboseEqual 

func (this *Action_Nop) VerboseEqual(that interface{}) error

type Action_Truncate 

type Action_Truncate struct {
	To               *uint64 `protobuf:"varint,1,req,name=to" json:"to,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func NewPopulatedAction_Truncate 

func NewPopulatedAction_Truncate(r randyLog, easy bool) *Action_Truncate

func (*Action_Truncate) Equal 

func (this *Action_Truncate) Equal(that interface{}) bool

func (*Action_Truncate) GetTo 

func (m *Action_Truncate) GetTo() uint64

func (*Action_Truncate) GoString 

func (this *Action_Truncate) GoString() string

func (*Action_Truncate) Marshal 

func (m *Action_Truncate) Marshal() (data []byte, err error)

func (*Action_Truncate) MarshalTo 

func (m *Action_Truncate) MarshalTo(data []byte) (int, error)

func (*Action_Truncate) ProtoMessage 

func (*Action_Truncate) ProtoMessage()

func (*Action_Truncate) Reset 

func (m *Action_Truncate) Reset()

func (*Action_Truncate) Size 

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

func (*Action_Truncate) String 

func (this *Action_Truncate) String() string

func (*Action_Truncate) Unmarshal 

func (m *Action_Truncate) Unmarshal(data []byte) error

func (*Action_Truncate) VerboseEqual 

func (this *Action_Truncate) VerboseEqual(that interface{}) error

type Action_Type 

type Action_Type int32
const (
	Action_NOP      Action_Type = 1
	Action_APPEND   Action_Type = 2
	Action_TRUNCATE Action_Type = 3
)

func (Action_Type) Enum 

func (x Action_Type) Enum() *Action_Type

func (Action_Type) String 

func (x Action_Type) String() string

func (*Action_Type) UnmarshalJSON 

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

type Archive 

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

* Describes Completed Frameworks, etc. for archival.

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=mesosproto.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:"-"`
}

* Describes an attribute that can be set on a machine. For now, attributes and resources share the same "value" type, but this may change in the future and attributes may only be string based.

func NewPopulatedAttribute 

func NewPopulatedAttribute(r randyMesos, easy bool) *Attribute

func (*Attribute) Equal 

func (this *Attribute) Equal(that interface{}) bool

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) GoString 

func (this *Attribute) GoString() string

func (*Attribute) Marshal 

func (m *Attribute) Marshal() (data []byte, err error)

func (*Attribute) MarshalTo 

func (m *Attribute) MarshalTo(data []byte) (int, error)

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) Size 

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

func (*Attribute) String 

func (this *Attribute) String() string

func (*Attribute) Unmarshal 

func (m *Attribute) Unmarshal(data []byte) error

func (*Attribute) VerboseEqual 

func (this *Attribute) VerboseEqual(that interface{}) error

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             []byte  `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AuthenticationStartMessage) GetData 

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

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 {
	// Identifies who generated this call. Master assigns a framework id
	// when a new scheduler subscribes for the first time. Once assigned,
	// the scheduler must set the 'framework_id' here and within its
	// FrameworkInfo (in any further 'Subscribe' calls). This allows the
	// master to identify a scheduler correctly across disconnections,
	// failovers, etc.
	FrameworkId *FrameworkID `protobuf:"bytes,1,opt,name=framework_id" json:"framework_id,omitempty"`
	// Type of the call, indicates which optional field below should be
	// present if that type has a nested message definition.
	Type             *Call_Type        `protobuf:"varint,2,req,name=type,enum=mesosproto.Call_Type" json:"type,omitempty"`
	Subscribe        *Call_Subscribe   `protobuf:"bytes,3,opt,name=subscribe" json:"subscribe,omitempty"`
	Accept           *Call_Accept      `protobuf:"bytes,4,opt,name=accept" json:"accept,omitempty"`
	Decline          *Call_Decline     `protobuf:"bytes,5,opt,name=decline" json:"decline,omitempty"`
	Kill             *Call_Kill        `protobuf:"bytes,6,opt,name=kill" json:"kill,omitempty"`
	Shutdown         *Call_Shutdown    `protobuf:"bytes,7,opt,name=shutdown" json:"shutdown,omitempty"`
	Acknowledge      *Call_Acknowledge `protobuf:"bytes,8,opt,name=acknowledge" json:"acknowledge,omitempty"`
	Reconcile        *Call_Reconcile   `protobuf:"bytes,9,opt,name=reconcile" json:"reconcile,omitempty"`
	Message          *Call_Message     `protobuf:"bytes,10,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Scheduler call API.

Like Event, a Call is described using the standard protocol buffer "union" trick (see above).

func (*Call) GetAccept added in v1.1.0 

func (m *Call) GetAccept() *Call_Accept

func (*Call) GetAcknowledge 

func (m *Call) GetAcknowledge() *Call_Acknowledge

func (*Call) GetDecline 

func (m *Call) GetDecline() *Call_Decline

func (*Call) GetFrameworkId added in v1.1.0 

func (m *Call) GetFrameworkId() *FrameworkID

func (*Call) GetKill 

func (m *Call) GetKill() *Call_Kill

func (*Call) GetMessage 

func (m *Call) GetMessage() *Call_Message

func (*Call) GetReconcile 

func (m *Call) GetReconcile() *Call_Reconcile

func (*Call) GetShutdown added in v1.1.0 

func (m *Call) GetShutdown() *Call_Shutdown

func (*Call) GetSubscribe added in v1.1.0 

func (m *Call) GetSubscribe() *Call_Subscribe

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_Accept added in v1.1.0 

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

Accepts an offer, performing the specified operations in a sequential manner.

E.g. Launch a task with a newly reserved persistent volume: 

Accept {
  offer_ids: [ ... ]
  operations: [
    { type: RESERVE,
      reserve: { resources: [ disk(role):2 ] } }
    { type: CREATE,
      create: { volumes: [ disk(role):1+persistence ] } }
    { type: LAUNCH,
      launch: { task_infos ... disk(role):1;disk(role):1+persistence } }
  ]
}

Note that any of the offer’s resources not used in the 'Accept' call (e.g., to launch a task) are considered unused and might be reoffered to other frameworks. In other words, the same OfferID cannot be used in more than one 'Accept' call.

func (*Call_Accept) GetFilters added in v1.1.0 

func (m *Call_Accept) GetFilters() *Filters

func (*Call_Accept) GetOfferIds added in v1.1.0 

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

func (*Call_Accept) GetOperations added in v1.1.0 

func (m *Call_Accept) GetOperations() []*Offer_Operation

func (*Call_Accept) ProtoMessage added in v1.1.0 

func (*Call_Accept) ProtoMessage()

func (*Call_Accept) Reset added in v1.1.0 

func (m *Call_Accept) Reset()

func (*Call_Accept) String added in v1.1.0 

func (m *Call_Accept) 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:"-"`
}

Acknowledges the receipt of status update. Schedulers are responsible for explicitly acknowledging the receipt of status updates that have 'Update.status().uuid()' field set. Such status updates are retried by the slave until they are acknowledged by the scheduler.

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:"-"`
}

Declines an offer, signaling the master to potentially reoffer the resources to a different framework. Note that this is same as sending an Accept call with no operations. See comments on top of 'Accept' for semantics.

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"`
	SlaveId          *SlaveID `protobuf:"bytes,2,opt,name=slave_id" json:"slave_id,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Kills a specific task. If the scheduler has a custom executor, the kill is forwarded to the executor and it is up to the executor to kill the task and send a TASK_KILLED (or TASK_FAILED) update. Note that Mesos releases the resources for a task once it receives a terminal update (See TaskState in mesos.proto) for it. If the task is unknown to the master, a TASK_LOST update is generated.

func (*Call_Kill) GetSlaveId added in v1.1.0 

func (m *Call_Kill) GetSlaveId() *SlaveID

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_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:"-"`
}

Sends arbitrary binary data to the executor. Note that Mesos neither interprets this data nor makes any guarantees about the delivery of this message to the executor.

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 {
	Tasks            []*Call_Reconcile_Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

Allows the scheduler to query the status for non-terminal tasks. This causes the master to send back the latest task status for each task in 'tasks', if possible. Tasks that are no longer known will result in a TASK_LOST update. If 'statuses' is empty, then the master will send the latest status for each task currently known.

func (*Call_Reconcile) GetTasks added in v1.1.0 

func (m *Call_Reconcile) GetTasks() []*Call_Reconcile_Task

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_Reconcile_Task added in v1.1.0 

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

TODO(vinod): Support arbitrary queries than just state of tasks.

func (*Call_Reconcile_Task) GetSlaveId added in v1.1.0 

func (m *Call_Reconcile_Task) GetSlaveId() *SlaveID

func (*Call_Reconcile_Task) GetTaskId added in v1.1.0 

func (m *Call_Reconcile_Task) GetTaskId() *TaskID

func (*Call_Reconcile_Task) ProtoMessage added in v1.1.0 

func (*Call_Reconcile_Task) ProtoMessage()

func (*Call_Reconcile_Task) Reset added in v1.1.0 

func (m *Call_Reconcile_Task) Reset()

func (*Call_Reconcile_Task) String added in v1.1.0 

func (m *Call_Reconcile_Task) String() string

type Call_Shutdown added in v1.1.0 

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

Shuts down a custom executor. When the executor gets a shutdown event, it is expected to kill all its tasks (and send TASK_KILLED updates) and terminate. If the executor doesn’t terminate within a certain timeout (configurable via '--executor_shutdown_grace_period' slave flag), the slave will forcefully destroy the container (executor and its tasks) and transition its active tasks to TASK_LOST.

func (*Call_Shutdown) GetExecutorId added in v1.1.0 

func (m *Call_Shutdown) GetExecutorId() *ExecutorID

func (*Call_Shutdown) GetSlaveId added in v1.1.0 

func (m *Call_Shutdown) GetSlaveId() *SlaveID

func (*Call_Shutdown) ProtoMessage added in v1.1.0 

func (*Call_Shutdown) ProtoMessage()

func (*Call_Shutdown) Reset added in v1.1.0 

func (m *Call_Shutdown) Reset()

func (*Call_Shutdown) String added in v1.1.0 

func (m *Call_Shutdown) String() string

type Call_Subscribe added in v1.1.0 

type Call_Subscribe struct {
	// See the comments below on 'framework_id' on the semantics for
	// 'framework_info.id'.
	FrameworkInfo *FrameworkInfo `protobuf:"bytes,1,req,name=framework_info" json:"framework_info,omitempty"`
	// 'force' field is only relevant when 'framework_info.id' is set.
	// It tells the master what to do in case an instance of the
	// scheduler attempts to subscribe when another instance of it is
	// already connected (e.g., split brain due to network partition).
	// If 'force' is true, this scheduler instance is allowed and the
	// old connected scheduler instance is disconnected. If false,
	// this scheduler instance is disallowed subscription in favor of
	// the already connected scheduler instance.
	//
	// It is recommended to set this to true only when a newly elected
	// scheduler instance is attempting to subscribe but not when a
	// scheduler is retrying subscription (e.g., disconnection or
	// master failover; see sched/sched.cpp for an example).
	Force            *bool  `protobuf:"varint,2,opt,name=force" json:"force,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Subscribes the scheduler with the master to receive events. A scheduler must send other calls only after it has received the SUBCRIBED event.

func (*Call_Subscribe) GetForce added in v1.1.0 

func (m *Call_Subscribe) GetForce() bool

func (*Call_Subscribe) GetFrameworkInfo added in v1.1.0 

func (m *Call_Subscribe) GetFrameworkInfo() *FrameworkInfo

func (*Call_Subscribe) ProtoMessage added in v1.1.0 

func (*Call_Subscribe) ProtoMessage()

func (*Call_Subscribe) Reset added in v1.1.0 

func (m *Call_Subscribe) Reset()

func (*Call_Subscribe) String added in v1.1.0 

func (m *Call_Subscribe) String() string

type Call_Type 

type Call_Type int32

Possible call types, followed by message definitions if applicable. 

const (
	Call_SUBSCRIBE   Call_Type = 1
	Call_TEARDOWN    Call_Type = 2
	Call_ACCEPT      Call_Type = 3
	Call_DECLINE     Call_Type = 4
	Call_REVIVE      Call_Type = 5
	Call_KILL        Call_Type = 6
	Call_SHUTDOWN    Call_Type = 7
	Call_ACKNOWLEDGE Call_Type = 8
	Call_RECONCILE   Call_Type = 9
	Call_MESSAGE     Call_Type = 10
)

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 CheckpointResourcesMessage added in v1.1.0 

type CheckpointResourcesMessage struct {
	Resources        []*Resource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

This message is sent to the slave whenever there is an update of the resources that need to be checkpointed (e.g., persistent volume or dynamic reservation).

func (*CheckpointResourcesMessage) GetResources added in v1.1.0 

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

func (*CheckpointResourcesMessage) ProtoMessage added in v1.1.0 

func (*CheckpointResourcesMessage) ProtoMessage()

func (*CheckpointResourcesMessage) Reset added in v1.1.0 

func (m *CheckpointResourcesMessage) Reset()

func (*CheckpointResourcesMessage) String added in v1.1.0 

func (m *CheckpointResourcesMessage) String() string

type CommandInfo 

type CommandInfo struct {
	// NOTE: MesosContainerizer does currently not support this
	// attribute and tasks supplying a 'container' will fail.
	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"`
	// There are two ways to specify the command:
	// 1) If 'shell == true', the command will be launched via shell
	// 		(i.e., /bin/sh -c 'value'). The 'value' specified will be
	// 		treated as the shell command. The 'arguments' will be ignored.
	// 2) If 'shell == false', the command will be launched by passing
	// 		arguments to an executable. The 'value' specified will be
	// 		treated as the filename of the executable. The 'arguments'
	// 		will be treated as the arguments to the executable. This is
	// 		similar to how POSIX exec families launch processes (i.e.,
	// 		execlp(value, arguments(0), arguments(1), ...)).
	// NOTE: The field 'value' is changed from 'required' to 'optional'
	// in 0.20.0. It will only cause issues if a new framework is
	// connecting to an old master.
	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"`
	// Enables executor and tasks to run as a specific user. If the user
	// field is present both in FrameworkInfo and here, the CommandInfo
	// user value takes precedence.
	User             *string `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a command, executed via: '/bin/sh -c value'. Any URIs specified are fetched before executing the command. If the executable field for an uri is set, executable file permission is set on the downloaded file. Otherwise, if the downloaded file has a recognized archive extension (currently [compressed] tar and zip) it is extracted into the executor's working directory. This extraction can be disabled by setting `extract` to false. In addition, any environment variables are set before executing the command (so they can be used to "parameterize" your command).

func NewPopulatedCommandInfo 

func NewPopulatedCommandInfo(r randyMesos, easy bool) *CommandInfo

func (*CommandInfo) Equal 

func (this *CommandInfo) Equal(that interface{}) bool

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) GoString 

func (this *CommandInfo) GoString() string

func (*CommandInfo) Marshal 

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

func (*CommandInfo) MarshalTo 

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

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset 

func (m *CommandInfo) Reset()

func (*CommandInfo) Size 

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

func (*CommandInfo) String 

func (this *CommandInfo) String() string

func (*CommandInfo) Unmarshal 

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

func (*CommandInfo) VerboseEqual 

func (this *CommandInfo) VerboseEqual(that interface{}) error

type CommandInfo_ContainerInfo 

type CommandInfo_ContainerInfo struct {
	// URI describing the container image name.
	Image *string `protobuf:"bytes,1,req,name=image" json:"image,omitempty"`
	// Describes additional options passed to the containerizer.
	Options          []string `protobuf:"bytes,2,rep,name=options" json:"options,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Describes a container. Not all containerizers currently implement ContainerInfo, so it is possible that a launched task will fail due to supplying this attribute. NOTE: The containerizer API is currently in an early beta or even alpha state. Some details, like the exact semantics of an "image" or "options" are not yet hardened. TODO(tillt): Describe the exact scheme and semantics of "image" and "options".

func NewPopulatedCommandInfo_ContainerInfo 

func NewPopulatedCommandInfo_ContainerInfo(r randyMesos, easy bool) *CommandInfo_ContainerInfo

func (*CommandInfo_ContainerInfo) Equal 

func (this *CommandInfo_ContainerInfo) Equal(that interface{}) bool

func (*CommandInfo_ContainerInfo) GetImage 

func (m *CommandInfo_ContainerInfo) GetImage() string

func (*CommandInfo_ContainerInfo) GetOptions 

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

func (*CommandInfo_ContainerInfo) GoString 

func (this *CommandInfo_ContainerInfo) GoString() string

func (*CommandInfo_ContainerInfo) Marshal 

func (m *CommandInfo_ContainerInfo) Marshal() (data []byte, err error)

func (*CommandInfo_ContainerInfo) MarshalTo 

func (m *CommandInfo_ContainerInfo) MarshalTo(data []byte) (int, error)

func (*CommandInfo_ContainerInfo) ProtoMessage 

func (*CommandInfo_ContainerInfo) ProtoMessage()

func (*CommandInfo_ContainerInfo) Reset 

func (m *CommandInfo_ContainerInfo) Reset()

func (*CommandInfo_ContainerInfo) Size 

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

func (*CommandInfo_ContainerInfo) String 

func (this *CommandInfo_ContainerInfo) String() string

func (*CommandInfo_ContainerInfo) Unmarshal 

func (m *CommandInfo_ContainerInfo) Unmarshal(data []byte) error

func (*CommandInfo_ContainerInfo) VerboseEqual 

func (this *CommandInfo_ContainerInfo) VerboseEqual(that interface{}) error

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"`
	// In case the fetched file is recognized as an archive, extract
	// its contents into the sandbox. Note that a cached archive is
	// not copied from the cache to the sandbox in case extraction
	// originates from an archive in the cache.
	Extract *bool `protobuf:"varint,3,opt,name=extract,def=1" json:"extract,omitempty"`
	// If this field is "true", the fetcher cache will be used. If not,
	// fetching bypasses the cache and downloads directly into the
	// sandbox directory, no matter whether a suitable cache file is
	// available or not. The former directs the fetcher to download to
	// the file cache, then copy from there to the sandbox. Subsequent
	// fetch attempts with the same URI will omit downloading and copy
	// from the cache as long as the file is resident there. Cache files
	// may get evicted at any time, which then leads to renewed
	// downloading. See also "docs/fetcher.md" and
	// "docs/fetcher-cache-internals.md".
	Cache            *bool  `protobuf:"varint,4,opt,name=cache" json:"cache,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func NewPopulatedCommandInfo_URI 

func NewPopulatedCommandInfo_URI(r randyMesos, easy bool) *CommandInfo_URI

func (*CommandInfo_URI) Equal 

func (this *CommandInfo_URI) Equal(that interface{}) bool

func (*CommandInfo_URI) GetCache added in v1.1.0 

func (m *CommandInfo_URI) GetCache() bool

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) GoString 

func (this *CommandInfo_URI) GoString() string

func (*CommandInfo_URI) Marshal 

func (m *CommandInfo_URI) Marshal() (data []byte, err error)

func (*CommandInfo_URI) MarshalTo 

func (m *CommandInfo_URI) MarshalTo(data []byte) (int, error)

func (*CommandInfo_URI) ProtoMessage 

func (*CommandInfo_URI) ProtoMessage()

func (*CommandInfo_URI) Reset 

func (m *CommandInfo_URI) Reset()

func (*CommandInfo_URI) Size 

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

func (*CommandInfo_URI) String 

func (this *CommandInfo_URI) String() string

func (*CommandInfo_URI) Unmarshal 

func (m *CommandInfo_URI) Unmarshal(data []byte) error

func (*CommandInfo_URI) VerboseEqual 

func (this *CommandInfo_URI) VerboseEqual(that interface{}) error

type ContainerID 

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

* A slave generated ID to distinguish a container. The ID must be unique between any active or completed containers on the slave. In particular, containers for different runs of the same (framework, executor) pair must be unique.

func NewPopulatedContainerID 

func NewPopulatedContainerID(r randyMesos, easy bool) *ContainerID

func (*ContainerID) Equal 

func (this *ContainerID) Equal(that interface{}) bool

func (*ContainerID) GetValue 

func (m *ContainerID) GetValue() string

func (*ContainerID) GoString 

func (this *ContainerID) GoString() string

func (*ContainerID) Marshal 

func (m *ContainerID) Marshal() (data []byte, err error)

func (*ContainerID) MarshalTo 

func (m *ContainerID) MarshalTo(data []byte) (int, error)

func (*ContainerID) ProtoMessage 

func (*ContainerID) ProtoMessage()

func (*ContainerID) Reset 

func (m *ContainerID) Reset()

func (*ContainerID) Size 

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

func (*ContainerID) String 

func (this *ContainerID) String() string

func (*ContainerID) Unmarshal 

func (m *ContainerID) Unmarshal(data []byte) error

func (*ContainerID) VerboseEqual 

func (this *ContainerID) VerboseEqual(that interface{}) error

type ContainerInfo 

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

* Describes a container configuration and allows extensible configurations for different container implementations.

func NewPopulatedContainerInfo 

func NewPopulatedContainerInfo(r randyMesos, easy bool) *ContainerInfo

func (*ContainerInfo) Equal 

func (this *ContainerInfo) Equal(that interface{}) bool

func (*ContainerInfo) GetDocker 

func (m *ContainerInfo) GetDocker() *ContainerInfo_DockerInfo

func (*ContainerInfo) GetHostname 

func (m *ContainerInfo) GetHostname() string

func (*ContainerInfo) GetType 

func (m *ContainerInfo) GetType() ContainerInfo_Type

func (*ContainerInfo) GetVolumes 

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

func (*ContainerInfo) GoString 

func (this *ContainerInfo) GoString() string

func (*ContainerInfo) Marshal 

func (m *ContainerInfo) Marshal() (data []byte, err error)

func (*ContainerInfo) MarshalTo 

func (m *ContainerInfo) MarshalTo(data []byte) (int, error)

func (*ContainerInfo) ProtoMessage 

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) Reset 

func (m *ContainerInfo) Reset()

func (*ContainerInfo) Size 

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

func (*ContainerInfo) String 

func (this *ContainerInfo) String() string

func (*ContainerInfo) Unmarshal 

func (m *ContainerInfo) Unmarshal(data []byte) error

func (*ContainerInfo) VerboseEqual 

func (this *ContainerInfo) VerboseEqual(that interface{}) error

type ContainerInfo_DockerInfo 

type ContainerInfo_DockerInfo struct {
	// The docker image that is going to be passed to the registry.
	Image        *string                                 `protobuf:"bytes,1,req,name=image" json:"image,omitempty"`
	Network      *ContainerInfo_DockerInfo_Network       `protobuf:"varint,2,opt,name=network,enum=mesosproto.ContainerInfo_DockerInfo_Network,def=1" json:"network,omitempty"`
	PortMappings []*ContainerInfo_DockerInfo_PortMapping `protobuf:"bytes,3,rep,name=port_mappings" json:"port_mappings,omitempty"`
	Privileged   *bool                                   `protobuf:"varint,4,opt,name=privileged,def=0" json:"privileged,omitempty"`
	// Allowing arbitrary parameters to be passed to docker CLI.
	// Note that anything passed to this field is not guaranteed
	// to be supported moving forward, as we might move away from
	// the docker CLI.
	Parameters []*Parameter `protobuf:"bytes,5,rep,name=parameters" json:"parameters,omitempty"`
	// With this flag set to true, the docker containerizer will
	// pull the docker image from the registry even if the image
	// is already downloaded on the slave.
	ForcePullImage   *bool  `protobuf:"varint,6,opt,name=force_pull_image" json:"force_pull_image,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func NewPopulatedContainerInfo_DockerInfo 

func NewPopulatedContainerInfo_DockerInfo(r randyMesos, easy bool) *ContainerInfo_DockerInfo

func (*ContainerInfo_DockerInfo) Equal 

func (this *ContainerInfo_DockerInfo) Equal(that interface{}) bool

func (*ContainerInfo_DockerInfo) GetForcePullImage added in v1.1.0 

func (m *ContainerInfo_DockerInfo) GetForcePullImage() bool

func (*ContainerInfo_DockerInfo) GetImage 

func (m *ContainerInfo_DockerInfo) GetImage() string

func (*ContainerInfo_DockerInfo) GetNetwork 

func (m *ContainerInfo_DockerInfo) GetNetwork() ContainerInfo_DockerInfo_Network

func (*ContainerInfo_DockerInfo) GetParameters 

func (m *ContainerInfo_DockerInfo) GetParameters() []*Parameter

func (*ContainerInfo_DockerInfo) GetPortMappings 

func (m *ContainerInfo_DockerInfo) GetPortMappings() []*ContainerInfo_DockerInfo_PortMapping

func (*ContainerInfo_DockerInfo) GetPrivileged 

func (m *ContainerInfo_DockerInfo) GetPrivileged() bool

func (*ContainerInfo_DockerInfo) GoString 

func (this *ContainerInfo_DockerInfo) GoString() string

func (*ContainerInfo_DockerInfo) Marshal 

func (m *ContainerInfo_DockerInfo) Marshal() (data []byte, err error)

func (*ContainerInfo_DockerInfo) MarshalTo 

func (m *ContainerInfo_DockerInfo) MarshalTo(data []byte) (int, error)

func (*ContainerInfo_DockerInfo) ProtoMessage 

func (*ContainerInfo_DockerInfo) ProtoMessage()

func (*ContainerInfo_DockerInfo) Reset 

func (m *ContainerInfo_DockerInfo) Reset()

func (*ContainerInfo_DockerInfo) Size 

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

func (*ContainerInfo_DockerInfo) String 

func (this *ContainerInfo_DockerInfo) String() string

func (*ContainerInfo_DockerInfo) Unmarshal 

func (m *ContainerInfo_DockerInfo) Unmarshal(data []byte) error

func (*ContainerInfo_DockerInfo) VerboseEqual 

func (this *ContainerInfo_DockerInfo) VerboseEqual(that interface{}) error

type ContainerInfo_DockerInfo_Network 

type ContainerInfo_DockerInfo_Network int32

Network options. 

const (
	ContainerInfo_DockerInfo_HOST   ContainerInfo_DockerInfo_Network = 1
	ContainerInfo_DockerInfo_BRIDGE ContainerInfo_DockerInfo_Network = 2
	ContainerInfo_DockerInfo_NONE   ContainerInfo_DockerInfo_Network = 3
)
const Default_ContainerInfo_DockerInfo_Network ContainerInfo_DockerInfo_Network = ContainerInfo_DockerInfo_HOST

func (ContainerInfo_DockerInfo_Network) Enum 

func (x ContainerInfo_DockerInfo_Network) Enum() *ContainerInfo_DockerInfo_Network

func (ContainerInfo_DockerInfo_Network) String 

func (x ContainerInfo_DockerInfo_Network) String() string

func (*ContainerInfo_DockerInfo_Network) UnmarshalJSON 

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

type ContainerInfo_DockerInfo_PortMapping 

type ContainerInfo_DockerInfo_PortMapping struct {
	HostPort      *uint32 `protobuf:"varint,1,req,name=host_port" json:"host_port,omitempty"`
	ContainerPort *uint32 `protobuf:"varint,2,req,name=container_port" json:"container_port,omitempty"`
	// Protocol to expose as (ie: tcp, udp).
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func NewPopulatedContainerInfo_DockerInfo_PortMapping 

func NewPopulatedContainerInfo_DockerInfo_PortMapping(r randyMesos, easy bool) *ContainerInfo_DockerInfo_PortMapping

func (*ContainerInfo_DockerInfo_PortMapping) Equal 

func (this *ContainerInfo_DockerInfo_PortMapping) Equal(that interface{}) bool

func (*ContainerInfo_DockerInfo_PortMapping) GetContainerPort 

func (m *ContainerInfo_DockerInfo_PortMapping) GetContainerPort() uint32

func (*ContainerInfo_DockerInfo_PortMapping) GetHostPort 

func (m *ContainerInfo_DockerInfo_PortMapping) GetHostPort() uint32

func (*ContainerInfo_DockerInfo_PortMapping) GetProtocol 

func (m *ContainerInfo_DockerInfo_PortMapping) GetProtocol() string

func (*ContainerInfo_DockerInfo_PortMapping) GoString 

func (this *ContainerInfo_DockerInfo_PortMapping) GoString() string

func (*ContainerInfo_DockerInfo_PortMapping) Marshal 

func (m *ContainerInfo_DockerInfo_PortMapping) Marshal() (data []byte, err error)

func (*ContainerInfo_DockerInfo_PortMapping) MarshalTo 

func (m *ContainerInfo_DockerInfo_PortMapping) MarshalTo(data []byte) (int, error)

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage 

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage()

func (*ContainerInfo_DockerInfo_PortMapping) Reset 

func (m *ContainerInfo_DockerInfo_PortMapping) Reset()

func (*ContainerInfo_DockerInfo_PortMapping) Size 

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

func (*ContainerInfo_DockerInfo_PortMapping) String 

func (this *ContainerInfo_DockerInfo_PortMapping) String() string

func (*ContainerInfo_DockerInfo_PortMapping) Unmarshal 

func (m *ContainerInfo_DockerInfo_PortMapping) Unmarshal(data []byte) error

func (*ContainerInfo_DockerInfo_PortMapping) VerboseEqual 

func (this *ContainerInfo_DockerInfo_PortMapping) VerboseEqual(that interface{}) error

type ContainerInfo_Type 

type ContainerInfo_Type int32

All container implementation types. 

const (
	ContainerInfo_DOCKER ContainerInfo_Type = 1
	ContainerInfo_MESOS  ContainerInfo_Type = 2
)

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 Containers 

type Containers struct {
	Containers       []*ContainerID `protobuf:"bytes,1,rep,name=containers" json:"containers,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Information on all active containers returned by the containerizer to the slave.

func (*Containers) GetContainers 

func (m *Containers) GetContainers() []*ContainerID

func (*Containers) ProtoMessage 

func (*Containers) ProtoMessage()

func (*Containers) Reset 

func (m *Containers) Reset()

func (*Containers) String 

func (m *Containers) String() string

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:"-"`
}

* Credential used in various places for authentication and authorization.

NOTE: A 'principal' is different from 'FrameworkInfo.user'. The former is used for authentication and authorization while the latter is used to determine the default user under which the framework's executors/tasks are run.

func NewPopulatedCredential 

func NewPopulatedCredential(r randyMesos, easy bool) *Credential

func (*Credential) Equal 

func (this *Credential) Equal(that interface{}) bool

func (*Credential) GetPrincipal 

func (m *Credential) GetPrincipal() string

func (*Credential) GetSecret 

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

func (*Credential) GoString 

func (this *Credential) GoString() string

func (*Credential) Marshal 

func (m *Credential) Marshal() (data []byte, err error)

func (*Credential) MarshalTo 

func (m *Credential) MarshalTo(data []byte) (int, error)

func (*Credential) ProtoMessage 

func (*Credential) ProtoMessage()

func (*Credential) Reset 

func (m *Credential) Reset()

func (*Credential) Size 

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

func (*Credential) String 

func (this *Credential) String() string

func (*Credential) Unmarshal 

func (m *Credential) Unmarshal(data []byte) error

func (*Credential) VerboseEqual 

func (this *Credential) VerboseEqual(that interface{}) error

type Credentials 

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

* Credentials used for framework authentication, HTTP authentication (where the common 'username' and 'password' are captured as 'principal' and 'secret' respectively), etc.

func NewPopulatedCredentials 

func NewPopulatedCredentials(r randyMesos, easy bool) *Credentials

func (*Credentials) Equal 

func (this *Credentials) Equal(that interface{}) bool

func (*Credentials) GetCredentials 

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

func (*Credentials) GoString 

func (this *Credentials) GoString() string

func (*Credentials) Marshal 

func (m *Credentials) Marshal() (data []byte, err error)

func (*Credentials) MarshalTo 

func (m *Credentials) MarshalTo(data []byte) (int, error)

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) Size 

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

func (*Credentials) String 

func (this *Credentials) String() string

func (*Credentials) Unmarshal 

func (m *Credentials) Unmarshal(data []byte) error

func (*Credentials) VerboseEqual 

func (this *Credentials) VerboseEqual(that interface{}) error

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 Destroy 

type Destroy struct {
	ContainerId      *ContainerID `protobuf:"bytes,1,req,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Encodes the destroy command sent to the external containerizer program.

func (*Destroy) GetContainerId 

func (m *Destroy) GetContainerId() *ContainerID

func (*Destroy) ProtoMessage 

func (*Destroy) ProtoMessage()

func (*Destroy) Reset 

func (m *Destroy) Reset()

func (*Destroy) String 

func (m *Destroy) String() string

type DiscoveryInfo added in v1.1.0 

type DiscoveryInfo struct {
	Visibility       *DiscoveryInfo_Visibility `protobuf:"varint,1,req,name=visibility,enum=mesosproto.DiscoveryInfo_Visibility" json:"visibility,omitempty"`
	Name             *string                   `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Environment      *string                   `protobuf:"bytes,3,opt,name=environment" json:"environment,omitempty"`
	Location         *string                   `protobuf:"bytes,4,opt,name=location" json:"location,omitempty"`
	Version          *string                   `protobuf:"bytes,5,opt,name=version" json:"version,omitempty"`
	Ports            *Ports                    `protobuf:"bytes,6,opt,name=ports" json:"ports,omitempty"`
	Labels           *Labels                   `protobuf:"bytes,7,opt,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* Service discovery information. The visibility field restricts discovery within a framework (FRAMEWORK), within a Mesos cluster (CLUSTER), or places no restrictions (EXTERNAL). The environment, location, and version fields provide first class support for common attributes used to differentiate between similar services. The environment may receive values such as PROD/QA/DEV, the location field may receive values like EAST-US/WEST-US/EUROPE/AMEA, and the version field may receive values like v2.0/v0.9. The exact use of these fields is up to each service discovery system.

func NewPopulatedDiscoveryInfo added in v1.1.0 

func NewPopulatedDiscoveryInfo(r randyMesos, easy bool) *DiscoveryInfo

func (*DiscoveryInfo) Equal added in v1.1.0 

func (this *DiscoveryInfo) Equal(that interface{}) bool

func (*DiscoveryInfo) GetEnvironment added in v1.1.0 

func (m *DiscoveryInfo) GetEnvironment() string

func (*DiscoveryInfo) GetLabels added in v1.1.0 

func (m *DiscoveryInfo) GetLabels() *Labels

func (*DiscoveryInfo) GetLocation added in v1.1.0 

func (m *DiscoveryInfo) GetLocation() string

func (*DiscoveryInfo) GetName added in v1.1.0 

func (m *DiscoveryInfo) GetName() string

func (*DiscoveryInfo) GetPorts added in v1.1.0 

func (m *DiscoveryInfo) GetPorts() *Ports

func (*DiscoveryInfo) GetVersion added in v1.1.0 

func (m *DiscoveryInfo) GetVersion() string

func (*DiscoveryInfo) GetVisibility added in v1.1.0 

func (m *DiscoveryInfo) GetVisibility() DiscoveryInfo_Visibility

func (*DiscoveryInfo) GoString added in v1.1.0 

func (this *DiscoveryInfo) GoString() string

func (*DiscoveryInfo) Marshal added in v1.1.0 

func (m *DiscoveryInfo) Marshal() (data []byte, err error)

func (*DiscoveryInfo) MarshalTo added in v1.1.0 

func (m *DiscoveryInfo) MarshalTo(data []byte) (int, error)

func (*DiscoveryInfo) ProtoMessage added in v1.1.0 

func (*DiscoveryInfo) ProtoMessage()

func (*DiscoveryInfo) Reset added in v1.1.0 

func (m *DiscoveryInfo) Reset()

func (*DiscoveryInfo) Size added in v1.1.0 

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

func (*DiscoveryInfo) String added in v1.1.0 

func (this *DiscoveryInfo) String() string

func (*DiscoveryInfo) Unmarshal added in v1.1.0 

func (m *DiscoveryInfo) Unmarshal(data []byte) error

func (*DiscoveryInfo) VerboseEqual added in v1.1.0 

func (this *DiscoveryInfo) VerboseEqual(that interface{}) error

type DiscoveryInfo_Visibility added in v1.1.0 

type DiscoveryInfo_Visibility int32
const (
	DiscoveryInfo_FRAMEWORK DiscoveryInfo_Visibility = 0
	DiscoveryInfo_CLUSTER   DiscoveryInfo_Visibility = 1
	DiscoveryInfo_EXTERNAL  DiscoveryInfo_Visibility = 2
)

func (DiscoveryInfo_Visibility) Enum added in v1.1.0 

func (x DiscoveryInfo_Visibility) Enum() *DiscoveryInfo_Visibility

func (DiscoveryInfo_Visibility) String added in v1.1.0 

func (x DiscoveryInfo_Visibility) String() string

func (*DiscoveryInfo_Visibility) UnmarshalJSON added in v1.1.0 

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

type Entry 

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

Describes a state entry, a versioned (via a UUID) key/value pair.

func NewPopulatedEntry 

func NewPopulatedEntry(r randyState, easy bool) *Entry

func (*Entry) Equal 

func (this *Entry) Equal(that interface{}) bool

func (*Entry) GetName 

func (m *Entry) GetName() string

func (*Entry) GetUuid 

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

func (*Entry) GetValue 

func (m *Entry) GetValue() []byte

func (*Entry) GoString 

func (this *Entry) GoString() string

func (*Entry) Marshal 

func (m *Entry) Marshal() (data []byte, err error)

func (*Entry) MarshalTo 

func (m *Entry) MarshalTo(data []byte) (int, error)

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

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

func (*Entry) String 

func (this *Entry) String() string

func (*Entry) Unmarshal 

func (m *Entry) Unmarshal(data []byte) error

func (*Entry) VerboseEqual 

func (this *Entry) VerboseEqual(that interface{}) error

type Environment 

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

* Describes a collection of environment variables. This is used with CommandInfo in order to set environment variables before running a command.

func NewPopulatedEnvironment 

func NewPopulatedEnvironment(r randyMesos, easy bool) *Environment

func (*Environment) Equal 

func (this *Environment) Equal(that interface{}) bool

func (*Environment) GetVariables 

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

func (*Environment) GoString 

func (this *Environment) GoString() string

func (*Environment) Marshal 

func (m *Environment) Marshal() (data []byte, err error)

func (*Environment) MarshalTo 

func (m *Environment) MarshalTo(data []byte) (int, error)

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) Reset 

func (m *Environment) Reset()

func (*Environment) Size 

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

func (*Environment) String 

func (this *Environment) String() string

func (*Environment) Unmarshal 

func (m *Environment) Unmarshal(data []byte) error

func (*Environment) VerboseEqual 

func (this *Environment) VerboseEqual(that interface{}) error

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 NewPopulatedEnvironment_Variable 

func NewPopulatedEnvironment_Variable(r randyMesos, easy bool) *Environment_Variable

func (*Environment_Variable) Equal 

func (this *Environment_Variable) Equal(that interface{}) bool

func (*Environment_Variable) GetName 

func (m *Environment_Variable) GetName() string

func (*Environment_Variable) GetValue 

func (m *Environment_Variable) GetValue() string

func (*Environment_Variable) GoString 

func (this *Environment_Variable) GoString() string

func (*Environment_Variable) Marshal 

func (m *Environment_Variable) Marshal() (data []byte, err error)

func (*Environment_Variable) MarshalTo 

func (m *Environment_Variable) MarshalTo(data []byte) (int, error)

func (*Environment_Variable) ProtoMessage 

func (*Environment_Variable) ProtoMessage()

func (*Environment_Variable) Reset 

func (m *Environment_Variable) Reset()

func (*Environment_Variable) Size 

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

func (*Environment_Variable) String 

func (this *Environment_Variable) String() string

func (*Environment_Variable) Unmarshal 

func (m *Environment_Variable) Unmarshal(data []byte) error

func (*Environment_Variable) VerboseEqual 

func (this *Environment_Variable) VerboseEqual(that interface{}) error

type Event 

type Event struct {
	// Type of the event, indicates which optional field below should be
	// present if that type has a nested message definition.
	Type             *Event_Type       `protobuf:"varint,1,req,name=type,enum=mesosproto.Event_Type" json:"type,omitempty"`
	Subscribed       *Event_Subscribed `protobuf:"bytes,2,opt,name=subscribed" json:"subscribed,omitempty"`
	Offers           *Event_Offers     `protobuf:"bytes,3,opt,name=offers" json:"offers,omitempty"`
	Rescind          *Event_Rescind    `protobuf:"bytes,4,opt,name=rescind" json:"rescind,omitempty"`
	Update           *Event_Update     `protobuf:"bytes,5,opt,name=update" json:"update,omitempty"`
	Message          *Event_Message    `protobuf:"bytes,6,opt,name=message" json:"message,omitempty"`
	Failure          *Event_Failure    `protobuf:"bytes,7,opt,name=failure" json:"failure,omitempty"`
	Error            *Event_Error      `protobuf:"bytes,8,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Scheduler event API.

An event is described using the standard protocol buffer "union" trick, see: https://developers.google.com/protocol-buffers/docs/techniques#union.

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) GetRescind 

func (m *Event) GetRescind() *Event_Rescind

func (*Event) GetSubscribed added in v1.1.0 

func (m *Event) GetSubscribed() *Event_Subscribed

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:"-"`
}

Received when an invalid framework (e.g., unauthenticated, unauthorized) attempts to subscribe with the master. Error can also be received if scheduler sends invalid Calls (e.g., not properly initialized). TODO(vinod): Remove this once the old scheduler driver is no longer supported. With HTTP API all errors will be signaled via HTTP response codes.

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"`
	// If this was just a failure of an executor on a slave then
	// 'executor_id' will be set and possibly 'status' (if we were
	// able to determine the exit status).
	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:"-"`
}

Received when a slave is removed from the cluster (e.g., failed health checks) or when an executor is terminated. Note that, this event coincides with receipt of terminal UPDATE events for any active tasks belonging to the slave or executor and receipt of 'Rescind' events for any outstanding offers belonging to the slave. Note that there is no guaranteed order between the 'Failure', 'Update' and 'Rescind' events when a slave or executor is removed. TODO(vinod): Consider splitting the lost slave and terminated executor into separate events and ensure it's reliably generated.

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:"-"`
}

Received when a custom message generated by the executor is forwarded by the master. Note that this message is not interpreted by Mesos and is only forwarded (without reliability guarantees) to the scheduler. It is up to the executor to retry if the message is dropped for any reason.

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:"-"`
}

Received whenever there are new resources that are offered to the scheduler. Each offer corresponds to a set of resources on a slave. Until the scheduler accepts or declines an offer the resources are considered allocated to the scheduler.

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_Rescind 

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

Received when a particular offer is no longer valid (e.g., the slave corresponding to the offer has been removed) and hence needs to be rescinded. Any future calls ('Accept' / 'Decline') made by the scheduler regarding this offer will be invalid.

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_Subscribed added in v1.1.0 

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

First event received when the scheduler subscribes.

func (*Event_Subscribed) GetFrameworkId added in v1.1.0 

func (m *Event_Subscribed) GetFrameworkId() *FrameworkID

func (*Event_Subscribed) ProtoMessage added in v1.1.0 

func (*Event_Subscribed) ProtoMessage()

func (*Event_Subscribed) Reset added in v1.1.0 

func (m *Event_Subscribed) Reset()

func (*Event_Subscribed) String added in v1.1.0 

func (m *Event_Subscribed) String() string

type Event_Type 

type Event_Type int32

Possible event types, followed by message definitions if applicable. 

const (
	Event_SUBSCRIBED Event_Type = 1
	Event_OFFERS     Event_Type = 2
	Event_RESCIND    Event_Type = 3
	Event_UPDATE     Event_Type = 4
	Event_MESSAGE    Event_Type = 5
	Event_FAILURE    Event_Type = 6
	Event_ERROR      Event_Type = 7
)

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 {
	Status           *TaskStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

Received whenever there is a status update that is generated by the executor or slave or master. Status updates should be used by executors to reliably communicate the status of the tasks that they manage. It is crucial that a terminal update (see TaskState in mesos.proto) is sent by the executor as soon as the task terminates, in order for Mesos to release the resources allocated to the task. It is also the responsibility of the scheduler to explicitly acknowledge the receipt of a status update. See 'Acknowledge' in the 'Call' section below for the semantics.

func (*Event_Update) GetStatus 

func (m *Event_Update) GetStatus() *TaskStatus

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:"-"`
}

* A framework generated ID to distinguish an executor. Only one executor with the same ID can be active on the same slave at a time.

func NewPopulatedExecutorID 

func NewPopulatedExecutorID(r randyMesos, easy bool) *ExecutorID

func (*ExecutorID) Equal 

func (this *ExecutorID) Equal(that interface{}) bool

func (*ExecutorID) GetValue 

func (m *ExecutorID) GetValue() string

func (*ExecutorID) GoString 

func (this *ExecutorID) GoString() string

func (*ExecutorID) Marshal 

func (m *ExecutorID) Marshal() (data []byte, err error)

func (*ExecutorID) MarshalTo 

func (m *ExecutorID) MarshalTo(data []byte) (int, error)

func (*ExecutorID) ProtoMessage 

func (*ExecutorID) ProtoMessage()

func (*ExecutorID) Reset 

func (m *ExecutorID) Reset()

func (*ExecutorID) Size 

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

func (*ExecutorID) String 

func (this *ExecutorID) String() string

func (*ExecutorID) Unmarshal 

func (m *ExecutorID) Unmarshal(data []byte) error

func (*ExecutorID) VerboseEqual 

func (this *ExecutorID) VerboseEqual(that interface{}) error

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"`
	// Executor provided with a container will launch the container
	// with the executor's CommandInfo and we expect the container to
	// act as a Mesos executor.
	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 is an identifier style string used by frameworks to track
	// the source of an executor. This is useful when it's possible for
	// different executor ids to be related semantically.
	// NOTE: Source is exposed alongside the resource usage of the
	// executor via JSON on the slave. This allows users to import
	// usage information into a time series database for monitoring.
	Source *string `protobuf:"bytes,10,opt,name=source" json:"source,omitempty"`
	Data   []byte  `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
	// Service discovery information for the executor. It is not
	// interpreted or acted upon by Mesos. It is up to a service
	// discovery system to use this information as needed and to handle
	// executors without service discovery information.
	Discovery        *DiscoveryInfo `protobuf:"bytes,12,opt,name=discovery" json:"discovery,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Describes information about an executor. The 'data' field can be used to pass arbitrary bytes to an executor.

func NewPopulatedExecutorInfo 

func NewPopulatedExecutorInfo(r randyMesos, easy bool) *ExecutorInfo

func (*ExecutorInfo) Equal 

func (this *ExecutorInfo) Equal(that interface{}) bool

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) GetDiscovery added in v1.1.0 

func (m *ExecutorInfo) GetDiscovery() *DiscoveryInfo

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) GoString 

func (this *ExecutorInfo) GoString() string

func (*ExecutorInfo) Marshal 

func (m *ExecutorInfo) Marshal() (data []byte, err error)

func (*ExecutorInfo) MarshalTo 

func (m *ExecutorInfo) MarshalTo(data []byte) (int, error)

func (*ExecutorInfo) ProtoMessage 

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) Reset 

func (m *ExecutorInfo) Reset()

func (*ExecutorInfo) Size 

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

func (*ExecutorInfo) String 

func (this *ExecutorInfo) String() string

func (*ExecutorInfo) Unmarshal 

func (m *ExecutorInfo) Unmarshal(data []byte) error

func (*ExecutorInfo) VerboseEqual 

func (this *ExecutorInfo) VerboseEqual(that interface{}) error

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 {
	// Time to consider unused resources refused. Note that all unused
	// resources will be considered refused and use the default value
	// (below) regardless of whether Filters was passed to
	// SchedulerDriver::launchTasks. You MUST pass Filters with this
	// field set to change this behavior (i.e., get another offer which
	// includes unused resources sooner or later than the default).
	RefuseSeconds    *float64 `protobuf:"fixed64,1,opt,name=refuse_seconds,def=5" json:"refuse_seconds,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Describes possible filters that can be applied to unused resources (see SchedulerDriver::launchTasks) to influence the allocator.

func NewPopulatedFilters 

func NewPopulatedFilters(r randyMesos, easy bool) *Filters

func (*Filters) Equal 

func (this *Filters) Equal(that interface{}) bool

func (*Filters) GetRefuseSeconds 

func (m *Filters) GetRefuseSeconds() float64

func (*Filters) GoString 

func (this *Filters) GoString() string

func (*Filters) Marshal 

func (m *Filters) Marshal() (data []byte, err error)

func (*Filters) MarshalTo 

func (m *Filters) MarshalTo(data []byte) (int, error)

func (*Filters) ProtoMessage 

func (*Filters) ProtoMessage()

func (*Filters) Reset 

func (m *Filters) Reset()

func (*Filters) Size 

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

func (*Filters) String 

func (this *Filters) String() string

func (*Filters) Unmarshal 

func (m *Filters) Unmarshal(data []byte) error

func (*Filters) VerboseEqual 

func (this *Filters) VerboseEqual(that interface{}) error

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 FrameworkID 

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

* A unique ID assigned to a framework. A framework can reuse this ID in order to do failover (see MesosSchedulerDriver).

func NewPopulatedFrameworkID 

func NewPopulatedFrameworkID(r randyMesos, easy bool) *FrameworkID

func (*FrameworkID) Equal 

func (this *FrameworkID) Equal(that interface{}) bool

func (*FrameworkID) GetValue 

func (m *FrameworkID) GetValue() string

func (*FrameworkID) GoString 

func (this *FrameworkID) GoString() string

func (*FrameworkID) Marshal 

func (m *FrameworkID) Marshal() (data []byte, err error)

func (*FrameworkID) MarshalTo 

func (m *FrameworkID) MarshalTo(data []byte) (int, error)

func (*FrameworkID) ProtoMessage 

func (*FrameworkID) ProtoMessage()

func (*FrameworkID) Reset 

func (m *FrameworkID) Reset()

func (*FrameworkID) Size 

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

func (*FrameworkID) String 

func (this *FrameworkID) String() string

func (*FrameworkID) Unmarshal 

func (m *FrameworkID) Unmarshal(data []byte) error

func (*FrameworkID) VerboseEqual 

func (this *FrameworkID) VerboseEqual(that interface{}) error

type FrameworkInfo 

type FrameworkInfo struct {
	// Used to determine the Unix user that an executor or task should
	// be launched as. If the user field is set to an empty string Mesos
	// will automagically set it to the current user.
	User *string `protobuf:"bytes,1,req,name=user" json:"user,omitempty"`
	// Name of the framework that shows up in the Mesos Web UI.
	Name *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	// Note that 'id' is only available after a framework has
	// registered, however, it is included here in order to facilitate
	// scheduler failover (i.e., if it is set then the
	// MesosSchedulerDriver expects the scheduler is performing
	// failover).
	Id *FrameworkID `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
	// The amount of time that the master will wait for the scheduler to
	// failover before it tears down the framework by killing all its
	// tasks/executors. This should be non-zero if a framework expects
	// to reconnect after a failover and not lose its tasks/executors.
	FailoverTimeout *float64 `protobuf:"fixed64,4,opt,name=failover_timeout,def=0" json:"failover_timeout,omitempty"`
	// If set, framework pid, executor pids and status updates are
	// checkpointed to disk by the slaves. Checkpointing allows a
	// restarted slave to reconnect with old executors and recover
	// status updates, at the cost of disk I/O.
	Checkpoint *bool `protobuf:"varint,5,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	// Used to group frameworks for allocation decisions, depending on
	// the allocation policy being used.
	Role *string `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	// Used to indicate the current host from which the scheduler is
	// registered in the Mesos Web UI. If set to an empty string Mesos
	// will automagically set it to the current hostname.
	Hostname *string `protobuf:"bytes,7,opt,name=hostname" json:"hostname,omitempty"`
	// This field should match the credential's principal the framework
	// uses for authentication. This field is used for framework API
	// rate limiting and dynamic reservations. It should be set even
	// if authentication is not enabled if these features are desired.
	Principal *string `protobuf:"bytes,8,opt,name=principal" json:"principal,omitempty"`
	// This field allows a framework to advertise its web UI, so that
	// the Mesos web UI can link to it. It is expected to be a full URL,
	// for example http://my-scheduler.example.com:8080/.
	WebuiUrl *string `protobuf:"bytes,9,opt,name=webui_url" json:"webui_url,omitempty"`
	// This field allows a framework to advertise its set of
	// capabilities (e.g., ability to receive offers for revocable
	// resources).
	Capabilities     []*FrameworkInfo_Capability `protobuf:"bytes,10,rep,name=capabilities" json:"capabilities,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* Describes a framework.

func NewPopulatedFrameworkInfo 

func NewPopulatedFrameworkInfo(r randyMesos, easy bool) *FrameworkInfo

func (*FrameworkInfo) Equal 

func (this *FrameworkInfo) Equal(that interface{}) bool

func (*FrameworkInfo) GetCapabilities added in v1.1.0 

func (m *FrameworkInfo) GetCapabilities() []*FrameworkInfo_Capability

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) GetWebuiUrl 

func (m *FrameworkInfo) GetWebuiUrl() string

func (*FrameworkInfo) GoString 

func (this *FrameworkInfo) GoString() string

func (*FrameworkInfo) Marshal 

func (m *FrameworkInfo) Marshal() (data []byte, err error)

func (*FrameworkInfo) MarshalTo 

func (m *FrameworkInfo) MarshalTo(data []byte) (int, error)

func (*FrameworkInfo) ProtoMessage 

func (*FrameworkInfo) ProtoMessage()

func (*FrameworkInfo) Reset 

func (m *FrameworkInfo) Reset()

func (*FrameworkInfo) Size 

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

func (*FrameworkInfo) String 

func (this *FrameworkInfo) String() string

func (*FrameworkInfo) Unmarshal 

func (m *FrameworkInfo) Unmarshal(data []byte) error

func (*FrameworkInfo) VerboseEqual 

func (this *FrameworkInfo) VerboseEqual(that interface{}) error

type FrameworkInfo_Capability added in v1.1.0 

type FrameworkInfo_Capability struct {
	Type             *FrameworkInfo_Capability_Type `protobuf:"varint,1,req,name=type,enum=mesosproto.FrameworkInfo_Capability_Type" json:"type,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

func NewPopulatedFrameworkInfo_Capability added in v1.1.0 

func NewPopulatedFrameworkInfo_Capability(r randyMesos, easy bool) *FrameworkInfo_Capability

func (*FrameworkInfo_Capability) Equal added in v1.1.0 

func (this *FrameworkInfo_Capability) Equal(that interface{}) bool

func (*FrameworkInfo_Capability) GetType added in v1.1.0 

func (m *FrameworkInfo_Capability) GetType() FrameworkInfo_Capability_Type

func (*FrameworkInfo_Capability) GoString added in v1.1.0 

func (this *FrameworkInfo_Capability) GoString() string

func (*FrameworkInfo_Capability) Marshal added in v1.1.0 

func (m *FrameworkInfo_Capability) Marshal() (data []byte, err error)

func (*FrameworkInfo_Capability) MarshalTo added in v1.1.0 

func (m *FrameworkInfo_Capability) MarshalTo(data []byte) (int, error)

func (*FrameworkInfo_Capability) ProtoMessage added in v1.1.0 

func (*FrameworkInfo_Capability) ProtoMessage()

func (*FrameworkInfo_Capability) Reset added in v1.1.0 

func (m *FrameworkInfo_Capability) Reset()

func (*FrameworkInfo_Capability) Size added in v1.1.0 

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

func (*FrameworkInfo_Capability) String added in v1.1.0 

func (this *FrameworkInfo_Capability) String() string

func (*FrameworkInfo_Capability) Unmarshal added in v1.1.0 

func (m *FrameworkInfo_Capability) Unmarshal(data []byte) error

func (*FrameworkInfo_Capability) VerboseEqual added in v1.1.0 

func (this *FrameworkInfo_Capability) VerboseEqual(that interface{}) error

type FrameworkInfo_Capability_Type added in v1.1.0 

type FrameworkInfo_Capability_Type int32
const (
	// Receive offers with revocable resources. See 'Resource'
	// message for details.
	// TODO(vinod): This is currently a no-op.
	FrameworkInfo_Capability_REVOCABLE_RESOURCES FrameworkInfo_Capability_Type = 1
)

func (FrameworkInfo_Capability_Type) Enum added in v1.1.0 

func (x FrameworkInfo_Capability_Type) Enum() *FrameworkInfo_Capability_Type

func (FrameworkInfo_Capability_Type) String added in v1.1.0 

func (x FrameworkInfo_Capability_Type) String() string

func (*FrameworkInfo_Capability_Type) UnmarshalJSON added in v1.1.0 

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

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 health check - not yet recommended for use, see MESOS-2533.
	Http *HealthCheck_HTTP `protobuf:"bytes,1,opt,name=http" json:"http,omitempty"`
	// Amount of time to wait until starting the health checks.
	DelaySeconds *float64 `protobuf:"fixed64,2,opt,name=delay_seconds,def=15" json:"delay_seconds,omitempty"`
	// Interval between health checks.
	IntervalSeconds *float64 `protobuf:"fixed64,3,opt,name=interval_seconds,def=10" json:"interval_seconds,omitempty"`
	// Amount of time to wait for the health check to complete.
	TimeoutSeconds *float64 `protobuf:"fixed64,4,opt,name=timeout_seconds,def=20" json:"timeout_seconds,omitempty"`
	// Number of consecutive failures until considered unhealthy.
	ConsecutiveFailures *uint32 `protobuf:"varint,5,opt,name=consecutive_failures,def=3" json:"consecutive_failures,omitempty"`
	// Amount of time to allow failed health checks since launch.
	GracePeriodSeconds *float64 `protobuf:"fixed64,6,opt,name=grace_period_seconds,def=10" json:"grace_period_seconds,omitempty"`
	// Command health check.
	Command          *CommandInfo `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Describes a health check for a task or executor (or any arbitrary process/command). A "strategy" is picked by specifying one of the optional fields; currently only 'command' is supported. Specifying more than one strategy is an error.

func NewPopulatedHealthCheck 

func NewPopulatedHealthCheck(r randyMesos, easy bool) *HealthCheck

func (*HealthCheck) Equal 

func (this *HealthCheck) Equal(that interface{}) bool

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) GoString 

func (this *HealthCheck) GoString() string

func (*HealthCheck) Marshal 

func (m *HealthCheck) Marshal() (data []byte, err error)

func (*HealthCheck) MarshalTo 

func (m *HealthCheck) MarshalTo(data []byte) (int, error)

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) Size 

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

func (*HealthCheck) String 

func (this *HealthCheck) String() string

func (*HealthCheck) Unmarshal 

func (m *HealthCheck) Unmarshal(data []byte) error

func (*HealthCheck) VerboseEqual 

func (this *HealthCheck) VerboseEqual(that interface{}) error

type HealthCheck_HTTP 

type HealthCheck_HTTP struct {
	// Port to send the HTTP request.
	Port *uint32 `protobuf:"varint,1,req,name=port" json:"port,omitempty"`
	// HTTP request path.
	Path *string `protobuf:"bytes,2,opt,name=path,def=/" json:"path,omitempty"`
	// Expected response statuses. Not specifying any statuses implies
	// that any returned status is acceptable.
	Statuses         []uint32 `protobuf:"varint,4,rep,name=statuses" json:"statuses,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Describes an HTTP health check. This is not fully implemented and not recommended for use - see MESOS-2533.

func NewPopulatedHealthCheck_HTTP 

func NewPopulatedHealthCheck_HTTP(r randyMesos, easy bool) *HealthCheck_HTTP

func (*HealthCheck_HTTP) Equal 

func (this *HealthCheck_HTTP) Equal(that interface{}) bool

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) GoString 

func (this *HealthCheck_HTTP) GoString() string

func (*HealthCheck_HTTP) Marshal 

func (m *HealthCheck_HTTP) Marshal() (data []byte, err error)

func (*HealthCheck_HTTP) MarshalTo 

func (m *HealthCheck_HTTP) MarshalTo(data []byte) (int, error)

func (*HealthCheck_HTTP) ProtoMessage 

func (*HealthCheck_HTTP) ProtoMessage()

func (*HealthCheck_HTTP) Reset 

func (m *HealthCheck_HTTP) Reset()

func (*HealthCheck_HTTP) Size 

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

func (*HealthCheck_HTTP) String 

func (this *HealthCheck_HTTP) String() string

func (*HealthCheck_HTTP) Unmarshal 

func (m *HealthCheck_HTTP) Unmarshal(data []byte) error

func (*HealthCheck_HTTP) VerboseEqual 

func (this *HealthCheck_HTTP) VerboseEqual(that interface{}) error

type HookExecuted added in v1.1.0 

type HookExecuted struct {
	Module           *string `protobuf:"bytes,1,opt,name=module" json:"module,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Message to signal completion of an event within a module.

func (*HookExecuted) GetModule added in v1.1.0 

func (m *HookExecuted) GetModule() string

func (*HookExecuted) ProtoMessage added in v1.1.0 

func (*HookExecuted) ProtoMessage()

func (*HookExecuted) Reset added in v1.1.0 

func (m *HookExecuted) Reset()

func (*HookExecuted) String added in v1.1.0 

func (m *HookExecuted) String() string

type InternalAuthenticationResult 

type InternalAuthenticationResult struct {
	// true only if the authentication process completed and login was successful
	Success *bool `protobuf:"varint,1,req,name=success" json:"success,omitempty"`
	// true if the authentication process completed, successfully or not
	Completed *bool `protobuf:"varint,2,req,name=completed" json:"completed,omitempty"`
	// master pid that this result pertains to
	Pid              *string `protobuf:"bytes,3,req,name=pid" json:"pid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*InternalAuthenticationResult) GetCompleted 

func (m *InternalAuthenticationResult) GetCompleted() bool

func (*InternalAuthenticationResult) GetPid 

func (m *InternalAuthenticationResult) GetPid() string

func (*InternalAuthenticationResult) GetSuccess 

func (m *InternalAuthenticationResult) GetSuccess() bool

func (*InternalAuthenticationResult) ProtoMessage 

func (*InternalAuthenticationResult) ProtoMessage()

func (*InternalAuthenticationResult) Reset 

func (m *InternalAuthenticationResult) Reset()

func (*InternalAuthenticationResult) String 

func (m *InternalAuthenticationResult) String() string

type InternalMasterChangeDetected 

type InternalMasterChangeDetected struct {
	// will be present if there's a new master, otherwise nil
	Master           *MasterInfo `protobuf:"bytes,1,opt,name=master" json:"master,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

For use with detector callbacks

func (*InternalMasterChangeDetected) GetMaster 

func (m *InternalMasterChangeDetected) GetMaster() *MasterInfo

func (*InternalMasterChangeDetected) ProtoMessage 

func (*InternalMasterChangeDetected) ProtoMessage()

func (*InternalMasterChangeDetected) Reset 

func (m *InternalMasterChangeDetected) Reset()

func (*InternalMasterChangeDetected) String 

func (m *InternalMasterChangeDetected) String() string

type InternalTryAuthentication 

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

func (*InternalTryAuthentication) ProtoMessage 

func (*InternalTryAuthentication) ProtoMessage()

func (*InternalTryAuthentication) Reset 

func (m *InternalTryAuthentication) Reset()

func (*InternalTryAuthentication) String 

func (m *InternalTryAuthentication) String() string

type KillTaskMessage 

type KillTaskMessage struct {
	// TODO(bmahler): Include the SlaveID here to improve the Master's
	// ability to respond for non-activated slaves.
	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 Label added in v1.1.0 

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

* Key, value pair used to store free form user-data.

func NewPopulatedLabel added in v1.1.0 

func NewPopulatedLabel(r randyMesos, easy bool) *Label

func (*Label) Equal added in v1.1.0 

func (this *Label) Equal(that interface{}) bool

func (*Label) GetKey added in v1.1.0 

func (m *Label) GetKey() string

func (*Label) GetValue added in v1.1.0 

func (m *Label) GetValue() string

func (*Label) GoString added in v1.1.0 

func (this *Label) GoString() string

func (*Label) Marshal added in v1.1.0 

func (m *Label) Marshal() (data []byte, err error)

func (*Label) MarshalTo added in v1.1.0 

func (m *Label) MarshalTo(data []byte) (int, error)

func (*Label) ProtoMessage added in v1.1.0 

func (*Label) ProtoMessage()

func (*Label) Reset added in v1.1.0 

func (m *Label) Reset()

func (*Label) Size added in v1.1.0 

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

func (*Label) String added in v1.1.0 

func (this *Label) String() string

func (*Label) Unmarshal added in v1.1.0 

func (m *Label) Unmarshal(data []byte) error

func (*Label) VerboseEqual added in v1.1.0 

func (this *Label) VerboseEqual(that interface{}) error

type Labels added in v1.1.0 

type Labels struct {
	Labels           []*Label `protobuf:"bytes,1,rep,name=labels" json:"labels,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Collection of labels.

func NewPopulatedLabels added in v1.1.0 

func NewPopulatedLabels(r randyMesos, easy bool) *Labels

func (*Labels) Equal added in v1.1.0 

func (this *Labels) Equal(that interface{}) bool

func (*Labels) GetLabels added in v1.1.0 

func (m *Labels) GetLabels() []*Label

func (*Labels) GoString added in v1.1.0 

func (this *Labels) GoString() string

func (*Labels) Marshal added in v1.1.0 

func (m *Labels) Marshal() (data []byte, err error)

func (*Labels) MarshalTo added in v1.1.0 

func (m *Labels) MarshalTo(data []byte) (int, error)

func (*Labels) ProtoMessage added in v1.1.0 

func (*Labels) ProtoMessage()

func (*Labels) Reset added in v1.1.0 

func (m *Labels) Reset()

func (*Labels) Size added in v1.1.0 

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

func (*Labels) String added in v1.1.0 

func (this *Labels) String() string

func (*Labels) Unmarshal added in v1.1.0 

func (m *Labels) Unmarshal(data []byte) error

func (*Labels) VerboseEqual added in v1.1.0 

func (this *Labels) VerboseEqual(that interface{}) error

type Launch 

type Launch struct {
	ContainerId      *ContainerID  `protobuf:"bytes,1,req,name=container_id" json:"container_id,omitempty"`
	TaskInfo         *TaskInfo     `protobuf:"bytes,2,opt,name=task_info" json:"task_info,omitempty"`
	ExecutorInfo     *ExecutorInfo `protobuf:"bytes,3,opt,name=executor_info" json:"executor_info,omitempty"`
	Directory        *string       `protobuf:"bytes,4,opt,name=directory" json:"directory,omitempty"`
	User             *string       `protobuf:"bytes,5,opt,name=user" json:"user,omitempty"`
	SlaveId          *SlaveID      `protobuf:"bytes,6,opt,name=slave_id" json:"slave_id,omitempty"`
	SlavePid         *string       `protobuf:"bytes,7,opt,name=slave_pid" json:"slave_pid,omitempty"`
	Checkpoint       *bool         `protobuf:"varint,8,opt,name=checkpoint" json:"checkpoint,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

* Encodes the launch command sent to the external containerizer program.

func (*Launch) GetCheckpoint 

func (m *Launch) GetCheckpoint() bool

func (*Launch) GetContainerId 

func (m *Launch) GetContainerId() *ContainerID

func (*Launch) GetDirectory 

func (m *Launch) GetDirectory() string

func (*Launch) GetExecutorInfo 

func (m *Launch) GetExecutorInfo() *ExecutorInfo

func (*Launch) GetSlaveId 

func (m *Launch) GetSlaveId() *SlaveID

func (*Launch) GetSlavePid 

func (m *Launch) GetSlavePid() string

func (*Launch) GetTaskInfo 

func (m *Launch) GetTaskInfo() *TaskInfo

func (*Launch) GetUser 

func (m *Launch) GetUser() string

func (*Launch) ProtoMessage 

func (*Launch) ProtoMessage()

func (*Launch) Reset 

func (m *Launch) Reset()

func (*Launch) String 

func (m *Launch) 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 LearnedMessage 

type LearnedMessage struct {
	Action           *Action `protobuf:"bytes,1,req,name=action" json:"action,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Represents a "learned" event, that is, when a particular action has been agreed upon (reached consensus).

func NewPopulatedLearnedMessage 

func NewPopulatedLearnedMessage(r randyLog, easy bool) *LearnedMessage

func (*LearnedMessage) Equal 

func (this *LearnedMessage) Equal(that interface{}) bool

func (*LearnedMessage) GetAction 

func (m *LearnedMessage) GetAction() *Action

func (*LearnedMessage) GoString 

func (this *LearnedMessage) GoString() string

func (*LearnedMessage) Marshal 

func (m *LearnedMessage) Marshal() (data []byte, err error)

func (*LearnedMessage) MarshalTo 

func (m *LearnedMessage) MarshalTo(data []byte) (int, error)

func (*LearnedMessage) ProtoMessage 

func (*LearnedMessage) ProtoMessage()

func (*LearnedMessage) Reset 

func (m *LearnedMessage) Reset()

func (*LearnedMessage) Size 

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

func (*LearnedMessage) String 

func (this *LearnedMessage) String() string

func (*LearnedMessage) Unmarshal 

func (m *LearnedMessage) Unmarshal(data []byte) error

func (*LearnedMessage) VerboseEqual 

func (this *LearnedMessage) VerboseEqual(that interface{}) error

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"`
	Version          *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Describes a master. This will probably have more fields in the future which might be used, for example, to link a framework webui to a master webui.

func NewPopulatedMasterInfo 

func NewPopulatedMasterInfo(r randyMesos, easy bool) *MasterInfo

func (*MasterInfo) Equal 

func (this *MasterInfo) Equal(that interface{}) bool

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) GetVersion added in v1.1.0 

func (m *MasterInfo) GetVersion() string

func (*MasterInfo) GoString 

func (this *MasterInfo) GoString() string

func (*MasterInfo) Marshal 

func (m *MasterInfo) Marshal() (data []byte, err error)

func (*MasterInfo) MarshalTo 

func (m *MasterInfo) MarshalTo(data []byte) (int, error)

func (*MasterInfo) ProtoMessage 

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset 

func (m *MasterInfo) Reset()

func (*MasterInfo) Size 

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

func (*MasterInfo) String 

func (this *MasterInfo) String() string

func (*MasterInfo) Unmarshal 

func (m *MasterInfo) Unmarshal(data []byte) error

func (*MasterInfo) VerboseEqual 

func (this *MasterInfo) VerboseEqual(that interface{}) error

type MasterSlaveConnection added in v1.1.0 

type MasterSlaveConnection struct {
	// Product of max_slave_ping_timeouts * slave_ping_timeout.
	// If no pings are received within the total timeout,
	// the master will remove the slave.
	TotalPingTimeoutSeconds *float64 `protobuf:"fixed64,1,opt,name=total_ping_timeout_seconds" json:"total_ping_timeout_seconds,omitempty"`
	XXX_unrecognized        []byte   `json:"-"`
}

func (*MasterSlaveConnection) GetTotalPingTimeoutSeconds added in v1.1.0 

func (m *MasterSlaveConnection) GetTotalPingTimeoutSeconds() float64

func (*MasterSlaveConnection) ProtoMessage added in v1.1.0 

func (*MasterSlaveConnection) ProtoMessage()

func (*MasterSlaveConnection) Reset added in v1.1.0 

func (m *MasterSlaveConnection) Reset()

func (*MasterSlaveConnection) String added in v1.1.0 

func (m *MasterSlaveConnection) String() string

type Metadata 

type Metadata struct {
	Status           *Metadata_Status `protobuf:"varint,1,req,name=status,enum=mesosproto.Metadata_Status,def=4" json:"status,omitempty"`
	Promised         *uint64          `protobuf:"varint,2,req,name=promised,def=0" json:"promised,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

The metadata of a replica. It has to be persisted on the disk. We store the current status of the replica as well as the implicit promise that a replica has made. This message is intended to replace the old Promise message to support catch-up.

func NewPopulatedMetadata 

func NewPopulatedMetadata(r randyLog, easy bool) *Metadata

func (*Metadata) Equal 

func (this *Metadata) Equal(that interface{}) bool

func (*Metadata) GetPromised 

func (m *Metadata) GetPromised() uint64

func (*Metadata) GetStatus 

func (m *Metadata) GetStatus() Metadata_Status

func (*Metadata) GoString 

func (this *Metadata) GoString() string

func (*Metadata) Marshal 

func (m *Metadata) Marshal() (data []byte, err error)

func (*Metadata) MarshalTo 

func (m *Metadata) MarshalTo(data []byte) (int, error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (this *Metadata) String() string

func (*Metadata) Unmarshal 

func (m *Metadata) Unmarshal(data []byte) error

func (*Metadata) VerboseEqual 

func (this *Metadata) VerboseEqual(that interface{}) error

type Metadata_Status 

type Metadata_Status int32
const (
	Metadata_VOTING     Metadata_Status = 1
	Metadata_RECOVERING Metadata_Status = 2
	Metadata_STARTING   Metadata_Status = 3
	Metadata_EMPTY      Metadata_Status = 4
)
const Default_Metadata_Status Metadata_Status = Metadata_EMPTY

func (Metadata_Status) Enum 

func (x Metadata_Status) Enum() *Metadata_Status

func (Metadata_Status) String 

func (x Metadata_Status) String() string

func (*Metadata_Status) UnmarshalJSON 

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

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:"-"`
}

* Describes some resources available on a slave. An offer only contains resources from a single slave.

func NewPopulatedOffer 

func NewPopulatedOffer(r randyMesos, easy bool) *Offer

func (*Offer) Equal 

func (this *Offer) Equal(that interface{}) bool

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) GoString 

func (this *Offer) GoString() string

func (*Offer) Marshal 

func (m *Offer) Marshal() (data []byte, err error)

func (*Offer) MarshalTo 

func (m *Offer) MarshalTo(data []byte) (int, error)

func (*Offer) ProtoMessage 

func (*Offer) ProtoMessage()

func (*Offer) Reset 

func (m *Offer) Reset()

func (*Offer) Size 

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

func (*Offer) String 

func (this *Offer) String() string

func (*Offer) Unmarshal 

func (m *Offer) Unmarshal(data []byte) error

func (*Offer) VerboseEqual 

func (this *Offer) VerboseEqual(that interface{}) error

type OfferID 

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

* A unique ID assigned to an offer.

func NewPopulatedOfferID 

func NewPopulatedOfferID(r randyMesos, easy bool) *OfferID

func (*OfferID) Equal 

func (this *OfferID) Equal(that interface{}) bool

func (*OfferID) GetValue 

func (m *OfferID) GetValue() string

func (*OfferID) GoString 

func (this *OfferID) GoString() string

func (*OfferID) Marshal 

func (m *OfferID) Marshal() (data []byte, err error)

func (*OfferID) MarshalTo 

func (m *OfferID) MarshalTo(data []byte) (int, error)

func (*OfferID) ProtoMessage 

func (*OfferID) ProtoMessage()

func (*OfferID) Reset 

func (m *OfferID) Reset()

func (*OfferID) Size 

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

func (*OfferID) String 

func (this *OfferID) String() string

func (*OfferID) Unmarshal 

func (m *OfferID) Unmarshal(data []byte) error

func (*OfferID) VerboseEqual 

func (this *OfferID) VerboseEqual(that interface{}) error

type Offer_Operation added in v1.1.0 

type Offer_Operation struct {
	Type             *Offer_Operation_Type      `protobuf:"varint,1,req,name=type,enum=mesosproto.Offer_Operation_Type" json:"type,omitempty"`
	Launch           *Offer_Operation_Launch    `protobuf:"bytes,2,opt,name=launch" json:"launch,omitempty"`
	Reserve          *Offer_Operation_Reserve   `protobuf:"bytes,3,opt,name=reserve" json:"reserve,omitempty"`
	Unreserve        *Offer_Operation_Unreserve `protobuf:"bytes,4,opt,name=unreserve" json:"unreserve,omitempty"`
	Create           *Offer_Operation_Create    `protobuf:"bytes,5,opt,name=create" json:"create,omitempty"`
	Destroy          *Offer_Operation_Destroy   `protobuf:"bytes,6,opt,name=destroy" json:"destroy,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

Defines an operation that can be performed against offers.

func NewPopulatedOffer_Operation added in v1.1.0 

func NewPopulatedOffer_Operation(r randyMesos, easy bool) *Offer_Operation

func (*Offer_Operation) Equal added in v1.1.0 

func (this *Offer_Operation) Equal(that interface{}) bool

func (*Offer_Operation) GetCreate added in v1.1.0 

func (m *Offer_Operation) GetCreate() *Offer_Operation_Create

func (*Offer_Operation) GetDestroy added in v1.1.0 

func (m *Offer_Operation) GetDestroy() *Offer_Operation_Destroy

func (*Offer_Operation) GetLaunch added in v1.1.0 

func (m *Offer_Operation) GetLaunch() *Offer_Operation_Launch

func (*Offer_Operation) GetReserve added in v1.1.0 

func (m *Offer_Operation) GetReserve() *Offer_Operation_Reserve

func (*Offer_Operation) GetType added in v1.1.0 

func (m *Offer_Operation) GetType() Offer_Operation_Type

func (*Offer_Operation) GetUnreserve added in v1.1.0 

func (m *Offer_Operation) GetUnreserve() *Offer_Operation_Unreserve

func (*Offer_Operation) GoString added in v1.1.0 

func (this *Offer_Operation) GoString() string

func (*Offer_Operation) Marshal added in v1.1.0 

func (m *Offer_Operation) Marshal() (data []byte, err error)

func (*Offer_Operation) MarshalTo added in v1.1.0 

func (m *Offer_Operation) MarshalTo(data []byte) (int, error)

func (*Offer_Operation) ProtoMessage added in v1.1.0 

func (*Offer_Operation) ProtoMessage()

func (*Offer_Operation) Reset added in v1.1.0 

func (m *Offer_Operation) Reset()

func (*Offer_Operation) Size added in v1.1.0 

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

func (*Offer_Operation) String added in v1.1.0 

func (this *Offer_Operation) String() string

func (*Offer_Operation) Unmarshal added in v1.1.0 

func (m *Offer_Operation) Unmarshal(data []byte) error

func (*Offer_Operation) VerboseEqual added in v1.1.0 

func (this *Offer_Operation) VerboseEqual(that interface{}) error

type Offer_Operation_Create added in v1.1.0 

type Offer_Operation_Create struct {
	Volumes          []*Resource `protobuf:"bytes,1,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func NewPopulatedOffer_Operation_Create added in v1.1.0 

func NewPopulatedOffer_Operation_Create(r randyMesos, easy bool) *Offer_Operation_Create

func (*Offer_Operation_Create) Equal added in v1.1.0 

func (this *Offer_Operation_Create) Equal(that interface{}) bool

func (*Offer_Operation_Create) GetVolumes added in v1.1.0 

func (m *Offer_Operation_Create) GetVolumes() []*Resource

func (*Offer_Operation_Create) GoString added in v1.1.0 

func (this *Offer_Operation_Create) GoString() string

func (*Offer_Operation_Create) Marshal added in v1.1.0 

func (m *Offer_Operation_Create) Marshal() (data []byte, err error)

func (*Offer_Operation_Create) MarshalTo added in v1.1.0 

func (m *Offer_Operation_Create) MarshalTo(data []byte) (int, error)

func (*Offer_Operation_Create) ProtoMessage added in v1.1.0 

func (*Offer_Operation_Create) ProtoMessage()

func (*Offer_Operation_Create) Reset added in v1.1.0 

func (m *Offer_Operation_Create) Reset()

func (*Offer_Operation_Create) Size added in v1.1.0 

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

func (*Offer_Operation_Create) String added in v1.1.0 

func (this *Offer_Operation_Create) String() string

func (*Offer_Operation_Create) Unmarshal added in v1.1.0 

func (m *Offer_Operation_Create) Unmarshal(data []byte) error

func (*Offer_Operation_Create) VerboseEqual added in v1.1.0 

func (this *Offer_Operation_Create) VerboseEqual(that interface{}) error

type Offer_Operation_Destroy added in v1.1.0 

type Offer_Operation_Destroy struct {
	Volumes          []*Resource `protobuf:"bytes,1,rep,name=volumes" json:"volumes,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func NewPopulatedOffer_Operation_Destroy added in v1.1.0 

func NewPopulatedOffer_Operation_Destroy(r randyMesos, easy bool) *Offer_Operation_Destroy

func (*Offer_Operation_Destroy) Equal added in v1.1.0 

func (this *Offer_Operation_Destroy) Equal(that interface{}) bool

func (*Offer_Operation_Destroy) GetVolumes added in v1.1.0 

func (m *Offer_Operation_Destroy) GetVolumes() []*Resource

func (*Offer_Operation_Destroy) GoString added in v1.1.0 

func (this *Offer_Operation_Destroy) GoString() string

func (*Offer_Operation_Destroy) Marshal added in v1.1.0 

func (m *Offer_Operation_Destroy) Marshal() (data []byte, err error)

func (*Offer_Operation_Destroy) MarshalTo added in v1.1.0 

func (m *Offer_Operation_Destroy) MarshalTo(data []byte) (int, error)

func (*Offer_Operation_Destroy) ProtoMessage added in v1.1.0 

func (*Offer_Operation_Destroy) ProtoMessage()

func (*Offer_Operation_Destroy) Reset added in v1.1.0 

func (m *Offer_Operation_Destroy) Reset()

func (*Offer_Operation_Destroy) Size added in v1.1.0 

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

func (*Offer_Operation_Destroy) String added in v1.1.0 

func (this *Offer_Operation_Destroy) String() string

func (*Offer_Operation_Destroy) Unmarshal added in v1.1.0 

func (m *Offer_Operation_Destroy) Unmarshal(data []byte) error

func (*Offer_Operation_Destroy) VerboseEqual added in v1.1.0 

func (this *Offer_Operation_Destroy) VerboseEqual(that interface{}) error

type Offer_Operation_Launch added in v1.1.0 

type Offer_Operation_Launch struct {
	TaskInfos        []*TaskInfo `protobuf:"bytes,1,rep,name=task_infos" json:"task_infos,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func NewPopulatedOffer_Operation_Launch added in v1.1.0 

func NewPopulatedOffer_Operation_Launch(r randyMesos, easy bool) *Offer_Operation_Launch

func (*Offer_Operation_Launch) Equal added in v1.1.0 

func (this *Offer_Operation_Launch) Equal(that interface{}) bool

func (*Offer_Operation_Launch) GetTaskInfos added in v1.1.0 

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

func (*Offer_Operation_Launch) GoString added in v1.1.0 

func (this *Offer_Operation_Launch) GoString() string

func (*Offer_Operation_Launch) Marshal added in v1.1.0 

func (m *Offer_Operation_Launch) Marshal() (data []byte, err error)

func (*Offer_Operation_Launch) MarshalTo added in v1.1.0 

func (m *Offer_Operation_Launch) MarshalTo(data []byte) (int, error)

func (*Offer_Operation_Launch) ProtoMessage added in v1.1.0 

func (*Offer_Operation_Launch) ProtoMessage()

func (*Offer_Operation_Launch) Reset added in v1.1.0 

func (m *Offer_Operation_Launch) Reset()

func (*Offer_Operation_Launch) Size added in v1.1.0 

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

func (*Offer_Operation_Launch) String added in v1.1.0 

func (this *Offer_Operation_Launch) String() string

func (*Offer_Operation_Launch) Unmarshal added in v1.1.0 

func (m *Offer_Operation_Launch) Unmarshal(data []byte) error

func (*Offer_Operation_Launch) VerboseEqual added in v1.1.0 

func (this *Offer_Operation_Launch) VerboseEqual(that interface{}) error

type Offer_Operation_Reserve added in v1.1.0 

type Offer_Operation_Reserve struct {
	Resources        []*Resource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func NewPopulatedOffer_Operation_Reserve added in v1.1.0 

func NewPopulatedOffer_Operation_Reserve(r randyMesos, easy bool) *Offer_Operation_Reserve

func (*Offer_Operation_Reserve) Equal added in v1.1.0 

func (this *Offer_Operation_Reserve) Equal(that interface{}) bool

func (*Offer_Operation_Reserve) GetResources added in v1.1.0 

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

func (*Offer_Operation_Reserve) GoString added in v1.1.0 

func (this *Offer_Operation_Reserve) GoString() string

func (*Offer_Operation_Reserve) Marshal added in v1.1.0 

func (m *Offer_Operation_Reserve) Marshal() (data []byte, err error)

func (*Offer_Operation_Reserve) MarshalTo added in v1.1.0 

func (m *Offer_Operation_Reserve) MarshalTo(data []byte) (int, error)

func (*Offer_Operation_Reserve) ProtoMessage added in v1.1.0 

func (*Offer_Operation_Reserve) ProtoMessage()

func (*Offer_Operation_Reserve) Reset added in v1.1.0 

func (m *Offer_Operation_Reserve) Reset()

func (*Offer_Operation_Reserve) Size added in v1.1.0 

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

func (*Offer_Operation_Reserve) String added in v1.1.0 

func (this *Offer_Operation_Reserve) String() string

func (*Offer_Operation_Reserve) Unmarshal added in v1.1.0 

func (m *Offer_Operation_Reserve) Unmarshal(data []byte) error

func (*Offer_Operation_Reserve) VerboseEqual added in v1.1.0 

func (this *Offer_Operation_Reserve) VerboseEqual(that interface{}) error

type Offer_Operation_Type added in v1.1.0 

type Offer_Operation_Type int32
const (
	Offer_Operation_LAUNCH    Offer_Operation_Type = 1
	Offer_Operation_RESERVE   Offer_Operation_Type = 2
	Offer_Operation_UNRESERVE Offer_Operation_Type = 3
	Offer_Operation_CREATE    Offer_Operation_Type = 4
	Offer_Operation_DESTROY   Offer_Operation_Type = 5
)

func (Offer_Operation_Type) Enum added in v1.1.0 

func (x Offer_Operation_Type) Enum() *Offer_Operation_Type

func (Offer_Operation_Type) String added in v1.1.0 

func (x Offer_Operation_Type) String() string

func (*Offer_Operation_Type) UnmarshalJSON added in v1.1.0 

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

type Offer_Operation_Unreserve added in v1.1.0 

type Offer_Operation_Unreserve struct {
	Resources        []*Resource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func NewPopulatedOffer_Operation_Unreserve added in v1.1.0 

func NewPopulatedOffer_Operation_Unreserve(r randyMesos, easy bool) *Offer_Operation_Unreserve

func (*Offer_Operation_Unreserve) Equal added in v1.1.0 

func (this *Offer_Operation_Unreserve) Equal(that interface{}) bool

func (*Offer_Operation_Unreserve) GetResources added in v1.1.0 

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

func (*Offer_Operation_Unreserve) GoString added in v1.1.0 

func (this *Offer_Operation_Unreserve) GoString() string

func (*Offer_Operation_Unreserve) Marshal added in v1.1.0 

func (m *Offer_Operation_Unreserve) Marshal() (data []byte, err error)

func (*Offer_Operation_Unreserve) MarshalTo added in v1.1.0 

func (m *Offer_Operation_Unreserve) MarshalTo(data []byte) (int, error)

func (*Offer_Operation_Unreserve) ProtoMessage added in v1.1.0 

func (*Offer_Operation_Unreserve) ProtoMessage()

func (*Offer_Operation_Unreserve) Reset added in v1.1.0 

func (m *Offer_Operation_Unreserve) Reset()

func (*Offer_Operation_Unreserve) Size added in v1.1.0 

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

func (*Offer_Operation_Unreserve) String added in v1.1.0 

func (this *Offer_Operation_Unreserve) String() string

func (*Offer_Operation_Unreserve) Unmarshal added in v1.1.0 

func (m *Offer_Operation_Unreserve) Unmarshal(data []byte) error

func (*Offer_Operation_Unreserve) VerboseEqual added in v1.1.0 

func (this *Offer_Operation_Unreserve) VerboseEqual(that interface{}) error

type Operation 

type Operation struct {
	Type             *Operation_Type     `protobuf:"varint,1,req,name=type,enum=mesosproto.Operation_Type" json:"type,omitempty"`
	Snapshot         *Operation_Snapshot `protobuf:"bytes,2,opt,name=snapshot" json:"snapshot,omitempty"`
	Diff             *Operation_Diff     `protobuf:"bytes,4,opt,name=diff" json:"diff,omitempty"`
	Expunge          *Operation_Expunge  `protobuf:"bytes,3,opt,name=expunge" json:"expunge,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

Describes an operation used in the log storage implementation.

func NewPopulatedOperation 

func NewPopulatedOperation(r randyState, easy bool) *Operation

func (*Operation) Equal 

func (this *Operation) Equal(that interface{}) bool

func (*Operation) GetDiff 

func (m *Operation) GetDiff() *Operation_Diff

func (*Operation) GetExpunge 

func (m *Operation) GetExpunge() *Operation_Expunge

func (*Operation) GetSnapshot 

func (m *Operation) GetSnapshot() *Operation_Snapshot

func (*Operation) GetType 

func (m *Operation) GetType() Operation_Type

func (*Operation) GoString 

func (this *Operation) GoString() string

func (*Operation) Marshal 

func (m *Operation) Marshal() (data []byte, err error)

func (*Operation) MarshalTo 

func (m *Operation) MarshalTo(data []byte) (int, error)

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) Reset 

func (m *Operation) Reset()

func (*Operation) Size 

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

func (*Operation) String 

func (this *Operation) String() string

func (*Operation) Unmarshal 

func (m *Operation) Unmarshal(data []byte) error

func (*Operation) VerboseEqual 

func (this *Operation) VerboseEqual(that interface{}) error

type Operation_Diff 

type Operation_Diff struct {
	Entry            *Entry `protobuf:"bytes,1,req,name=entry" json:"entry,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Describes a "diff" operation where the 'value' of the entry is just the diff itself, but the 'uuid' represents the UUID of the entry after applying this diff.

func NewPopulatedOperation_Diff 

func NewPopulatedOperation_Diff(r randyState, easy bool) *Operation_Diff

func (*Operation_Diff) Equal 

func (this *Operation_Diff) Equal(that interface{}) bool

func (*Operation_Diff) GetEntry 

func (m *Operation_Diff) GetEntry() *Entry

func (*Operation_Diff) GoString 

func (this *Operation_Diff) GoString() string

func (*Operation_Diff) Marshal 

func (m *Operation_Diff) Marshal() (data []byte, err error)

func (*Operation_Diff) MarshalTo 

func (m *Operation_Diff) MarshalTo(data []byte) (int, error)

func (*Operation_Diff) ProtoMessage 

func (*Operation_Diff) ProtoMessage()

func (*Operation_Diff) Reset 

func (m *Operation_Diff) Reset()

func (*Operation_Diff) Size 

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

func (*Operation_Diff) String 

func (this *Operation_Diff) String() string

func (*Operation_Diff) Unmarshal 

func (m *Operation_Diff) Unmarshal(data []byte) error

func (*Operation_Diff) VerboseEqual 

func (this *Operation_Diff) VerboseEqual(that interface{}) error

type Operation_Expunge 

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

Describes an "expunge" operation.

func NewPopulatedOperation_Expunge 

func NewPopulatedOperation_Expunge(r randyState, easy bool) *Operation_Expunge

func (*Operation_Expunge) Equal 

func (this *Operation_Expunge) Equal(that interface{}) bool

func (*Operation_Expunge) GetName 

func (m *Operation_Expunge) GetName() string

func (*Operation_Expunge) GoString 

func (this *Operation_Expunge) GoString() string

func (*Operation_Expunge) Marshal 

func (m *Operation_Expunge) Marshal() (data []byte, err error)

func (*Operation_Expunge) MarshalTo 

func (m *Operation_Expunge) MarshalTo(data []byte) (int, error)

func (*Operation_Expunge) ProtoMessage 

func (*Operation_Expunge) ProtoMessage()

func (*Operation_Expunge) Reset 

func (m *Operation_Expunge) Reset()

func (*Operation_Expunge) Size 

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

func (*Operation_Expunge) String 

func (this *Operation_Expunge) String() string

func (*Operation_Expunge) Unmarshal 

func (m *Operation_Expunge) Unmarshal(data []byte) error

func (*Operation_Expunge) VerboseEqual 

func (this *Operation_Expunge) VerboseEqual(that interface{}) error

type Operation_Snapshot 

type Operation_Snapshot struct {
	Entry            *Entry `protobuf:"bytes,1,req,name=entry" json:"entry,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

Describes a "snapshot" operation.

func NewPopulatedOperation_Snapshot 

func NewPopulatedOperation_Snapshot(r randyState, easy bool) *Operation_Snapshot

func (*Operation_Snapshot) Equal 

func (this *Operation_Snapshot) Equal(that interface{}) bool

func (*Operation_Snapshot) GetEntry 

func (m *Operation_Snapshot) GetEntry() *Entry

func (*Operation_Snapshot) GoString 

func (this *Operation_Snapshot) GoString() string

func (*Operation_Snapshot) Marshal 

func (m *Operation_Snapshot) Marshal() (data []byte, err error)

func (*Operation_Snapshot) MarshalTo 

func (m *Operation_Snapshot) MarshalTo(data []byte) (int, error)

func (*Operation_Snapshot) ProtoMessage 

func (*Operation_Snapshot) ProtoMessage()

func (*Operation_Snapshot) Reset 

func (m *Operation_Snapshot) Reset()

func (*Operation_Snapshot) Size 

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

func (*Operation_Snapshot) String 

func (this *Operation_Snapshot) String() string

func (*Operation_Snapshot) Unmarshal 

func (m *Operation_Snapshot) Unmarshal(data []byte) error

func (*Operation_Snapshot) VerboseEqual 

func (this *Operation_Snapshot) VerboseEqual(that interface{}) error

type Operation_Type 

type Operation_Type int32
const (
	Operation_SNAPSHOT Operation_Type = 1
	Operation_DIFF     Operation_Type = 3
	Operation_EXPUNGE  Operation_Type = 2
)

func (Operation_Type) Enum 

func (x Operation_Type) Enum() *Operation_Type

func (Operation_Type) String 

func (x Operation_Type) String() string

func (*Operation_Type) UnmarshalJSON 

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

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:"-"`
}

* A generic (key, value) pair used in various places for parameters.

func NewPopulatedParameter 

func NewPopulatedParameter(r randyMesos, easy bool) *Parameter

func (*Parameter) Equal 

func (this *Parameter) Equal(that interface{}) bool

func (*Parameter) GetKey 

func (m *Parameter) GetKey() string

func (*Parameter) GetValue 

func (m *Parameter) GetValue() string

func (*Parameter) GoString 

func (this *Parameter) GoString() string

func (*Parameter) Marshal 

func (m *Parameter) Marshal() (data []byte, err error)

func (*Parameter) MarshalTo 

func (m *Parameter) MarshalTo(data []byte) (int, error)

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) Size 

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

func (*Parameter) String 

func (this *Parameter) String() string

func (*Parameter) Unmarshal 

func (m *Parameter) Unmarshal(data []byte) error

func (*Parameter) VerboseEqual 

func (this *Parameter) VerboseEqual(that interface{}) error

type Parameters 

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

* Collection of Parameter.

func NewPopulatedParameters 

func NewPopulatedParameters(r randyMesos, easy bool) *Parameters

func (*Parameters) Equal 

func (this *Parameters) Equal(that interface{}) bool

func (*Parameters) GetParameter 

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

func (*Parameters) GoString 

func (this *Parameters) GoString() string

func (*Parameters) Marshal 

func (m *Parameters) Marshal() (data []byte, err error)

func (*Parameters) MarshalTo 

func (m *Parameters) MarshalTo(data []byte) (int, error)

func (*Parameters) ProtoMessage 

func (*Parameters) ProtoMessage()

func (*Parameters) Reset 

func (m *Parameters) Reset()

func (*Parameters) Size 

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

func (*Parameters) String 

func (this *Parameters) String() string

func (*Parameters) Unmarshal 

func (m *Parameters) Unmarshal(data []byte) error

func (*Parameters) VerboseEqual 

func (this *Parameters) VerboseEqual(that interface{}) error

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"`
	// Hardware event.
	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"`
	// Software event.
	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"`
	// Hardware cache event.
	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:"-"`
}

* Describes a sample of events from "perf stat". Only available on Linux.

NOTE: Each optional field matches the name of a perf event (see "perf list") with the following changes:

  1. Names are downcased.
  2. Hyphens ('-') are replaced with underscores ('_').
  3. Events with alternate names use the name "perf stat" returns, e.g., for the event "cycles OR cpu-cycles" perf always returns cycles.

func NewPopulatedPerfStatistics 

func NewPopulatedPerfStatistics(r randyMesos, easy bool) *PerfStatistics

func (*PerfStatistics) Equal 

func (this *PerfStatistics) Equal(that interface{}) bool

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) GoString 

func (this *PerfStatistics) GoString() string

func (*PerfStatistics) Marshal 

func (m *PerfStatistics) Marshal() (data []byte, err error)

func (*PerfStatistics) MarshalTo 

func (m *PerfStatistics) MarshalTo(data []byte) (int, error)

func (*PerfStatistics) ProtoMessage 

func (*PerfStatistics) ProtoMessage()

func (*PerfStatistics) Reset 

func (m *PerfStatistics) Reset()

func (*PerfStatistics) Size 

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

func (*PerfStatistics) String 

func (this *PerfStatistics) String() string

func (*PerfStatistics) Unmarshal 

func (m *PerfStatistics) Unmarshal(data []byte) error

func (*PerfStatistics) VerboseEqual 

func (this *PerfStatistics) VerboseEqual(that interface{}) error

type PingSlaveMessage 

type PingSlaveMessage struct {
	Connected        *bool  `protobuf:"varint,1,req,name=connected" json:"connected,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

This message is periodically sent by the master to the slave. If the slave is connected to the master, "connected" is true.

func (*PingSlaveMessage) GetConnected 

func (m *PingSlaveMessage) GetConnected() bool

func (*PingSlaveMessage) ProtoMessage 

func (*PingSlaveMessage) ProtoMessage()

func (*PingSlaveMessage) Reset 

func (m *PingSlaveMessage) Reset()

func (*PingSlaveMessage) String 

func (m *PingSlaveMessage) String() string

type PongSlaveMessage 

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

This message is sent by the slave to the master in response to the PingSlaveMessage.

func (*PongSlaveMessage) ProtoMessage 

func (*PongSlaveMessage) ProtoMessage()

func (*PongSlaveMessage) Reset 

func (m *PongSlaveMessage) Reset()

func (*PongSlaveMessage) String 

func (m *PongSlaveMessage) String() string

type Port added in v1.1.0 

type Port struct {
	Number           *uint32 `protobuf:"varint,1,req,name=number" json:"number,omitempty"`
	Name             *string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Protocol         *string `protobuf:"bytes,3,opt,name=protocol" json:"protocol,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Named port used for service discovery.

func NewPopulatedPort added in v1.1.0 

func NewPopulatedPort(r randyMesos, easy bool) *Port

func (*Port) Equal added in v1.1.0 

func (this *Port) Equal(that interface{}) bool

func (*Port) GetName added in v1.1.0 

func (m *Port) GetName() string

func (*Port) GetNumber added in v1.1.0 

func (m *Port) GetNumber() uint32

func (*Port) GetProtocol added in v1.1.0 

func (m *Port) GetProtocol() string

func (*Port) GoString added in v1.1.0 

func (this *Port) GoString() string

func (*Port) Marshal added in v1.1.0 

func (m *Port) Marshal() (data []byte, err error)

func (*Port) MarshalTo added in v1.1.0 

func (m *Port) MarshalTo(data []byte) (int, error)

func (*Port) ProtoMessage added in v1.1.0 

func (*Port) ProtoMessage()

func (*Port) Reset added in v1.1.0 

func (m *Port) Reset()

func (*Port) Size added in v1.1.0 

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

func (*Port) String added in v1.1.0 

func (this *Port) String() string

func (*Port) Unmarshal added in v1.1.0 

func (m *Port) Unmarshal(data []byte) error

func (*Port) VerboseEqual added in v1.1.0 

func (this *Port) VerboseEqual(that interface{}) error

type Ports added in v1.1.0 

type Ports struct {
	Ports            []*Port `protobuf:"bytes,1,rep,name=ports" json:"ports,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Collection of ports.

func NewPopulatedPorts added in v1.1.0 

func NewPopulatedPorts(r randyMesos, easy bool) *Ports

func (*Ports) Equal added in v1.1.0 

func (this *Ports) Equal(that interface{}) bool

func (*Ports) GetPorts added in v1.1.0 

func (m *Ports) GetPorts() []*Port

func (*Ports) GoString added in v1.1.0 

func (this *Ports) GoString() string

func (*Ports) Marshal added in v1.1.0 

func (m *Ports) Marshal() (data []byte, err error)

func (*Ports) MarshalTo added in v1.1.0 

func (m *Ports) MarshalTo(data []byte) (int, error)

func (*Ports) ProtoMessage added in v1.1.0 

func (*Ports) ProtoMessage()

func (*Ports) Reset added in v1.1.0 

func (m *Ports) Reset()

func (*Ports) Size added in v1.1.0 

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

func (*Ports) String added in v1.1.0 

func (this *Ports) String() string

func (*Ports) Unmarshal added in v1.1.0 

func (m *Ports) Unmarshal(data []byte) error

func (*Ports) VerboseEqual added in v1.1.0 

func (this *Ports) VerboseEqual(that interface{}) error

type Promise 

type Promise struct {
	Proposal         *uint64 `protobuf:"varint,1,req,name=proposal" json:"proposal,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Represents a "promise" that a replica has made. A promise is *implicitly* valid for _all_ future actions that get performed on the replicated log (provided the action comes from the same proposer), until a new promise is made to a proposer with a higher proposal number. Each replica writes every promise it makes as a log record so that it can recover this information after a failure. TODO(benh): Does the promise actually need to be written to stable storage? Can we get away with looking at the last written action and using it's promised value? In this case, what happens if we make a promise but don't receive an action from that coordinator?

func NewPopulatedPromise 

func NewPopulatedPromise(r randyLog, easy bool) *Promise

func (*Promise) Equal 

func (this *Promise) Equal(that interface{}) bool

func (*Promise) GetProposal 

func (m *Promise) GetProposal() uint64

func (*Promise) GoString 

func (this *Promise) GoString() string

func (*Promise) Marshal 

func (m *Promise) Marshal() (data []byte, err error)

func (*Promise) MarshalTo 

func (m *Promise) MarshalTo(data []byte) (int, error)

func (*Promise) ProtoMessage 

func (*Promise) ProtoMessage()

func (*Promise) Reset 

func (m *Promise) Reset()

func (*Promise) Size 

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

func (*Promise) String 

func (this *Promise) String() string

func (*Promise) Unmarshal 

func (m *Promise) Unmarshal(data []byte) error

func (*Promise) VerboseEqual 

func (this *Promise) VerboseEqual(that interface{}) error

type PromiseRequest 

type PromiseRequest struct {
	Proposal         *uint64 `protobuf:"varint,1,req,name=proposal" json:"proposal,omitempty"`
	Position         *uint64 `protobuf:"varint,2,opt,name=position" json:"position,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Represents a "promise" request from a proposer with the specified 'proposal' to a replica. If the proposer is a coordinator, most such requests will occur after a coordinator has failed and a new coordinator is elected. In such a case, the position that the coordinator is asking the replica to promise is implicitly *all* positions that the replica has made no promises (thus the position field is not be used). In other instances, however, a proposer might be explicitly trying to request that a replica promise a specific position in the log (such as when trying to fill holes discovered during a client read), and then the 'position' field will be present.

func NewPopulatedPromiseRequest 

func NewPopulatedPromiseRequest(r randyLog, easy bool) *PromiseRequest

func (*PromiseRequest) Equal 

func (this *PromiseRequest) Equal(that interface{}) bool

func (*PromiseRequest) GetPosition 

func (m *PromiseRequest) GetPosition() uint64

func (*PromiseRequest) GetProposal 

func (m *PromiseRequest) GetProposal() uint64

func (*PromiseRequest) GoString 

func (this *PromiseRequest) GoString() string

func (*PromiseRequest) Marshal 

func (m *PromiseRequest) Marshal() (data []byte, err error)

func (*PromiseRequest) MarshalTo 

func (m *PromiseRequest) MarshalTo(data []byte) (int, error)

func (*PromiseRequest) ProtoMessage 

func (*PromiseRequest) ProtoMessage()

func (*PromiseRequest) Reset 

func (m *PromiseRequest) Reset()

func (*PromiseRequest) Size 

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

func (*PromiseRequest) String 

func (this *PromiseRequest) String() string

func (*PromiseRequest) Unmarshal 

func (m *PromiseRequest) Unmarshal(data []byte) error

func (*PromiseRequest) VerboseEqual 

func (this *PromiseRequest) VerboseEqual(that interface{}) error

type PromiseResponse 

type PromiseResponse struct {
	Okay             *bool   `protobuf:"varint,1,req,name=okay" json:"okay,omitempty"`
	Proposal         *uint64 `protobuf:"varint,2,req,name=proposal" json:"proposal,omitempty"`
	Position         *uint64 `protobuf:"varint,4,opt,name=position" json:"position,omitempty"`
	Action           *Action `protobuf:"bytes,3,opt,name=action" json:"action,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Represents a "promise" response from a replica back to a proposer. A replica represents a NACK (because it has promised a proposer with a higher proposal number) by setting the okay field to false. The 'proposal' is either the aforementioned higher proposal number when the response is a NACK, or the corresponding request's proposal number if it is an ACK. The replica either sends back the highest position it has recorded in the log (using the 'position' field) or the specific action (if any) it has at the position requested in PromiseRequest (using the 'action' field).

func NewPopulatedPromiseResponse 

func NewPopulatedPromiseResponse(r randyLog, easy bool) *PromiseResponse

func (*PromiseResponse) Equal 

func (this *PromiseResponse) Equal(that interface{}) bool

func (*PromiseResponse) GetAction 

func (m *PromiseResponse) GetAction() *Action

func (*PromiseResponse) GetOkay 

func (m *PromiseResponse) GetOkay() bool

func (*PromiseResponse) GetPosition 

func (m *PromiseResponse) GetPosition() uint64

func (*PromiseResponse) GetProposal 

func (m *PromiseResponse) GetProposal() uint64

func (*PromiseResponse) GoString 

func (this *PromiseResponse) GoString() string

func (*PromiseResponse) Marshal 

func (m *PromiseResponse) Marshal() (data []byte, err error)

func (*PromiseResponse) MarshalTo 

func (m *PromiseResponse) MarshalTo(data []byte) (int, error)

func (*PromiseResponse) ProtoMessage 

func (*PromiseResponse) ProtoMessage()

func (*PromiseResponse) Reset 

func (m *PromiseResponse) Reset()

func (*PromiseResponse) Size 

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

func (*PromiseResponse) String 

func (this *PromiseResponse) String() string

func (*PromiseResponse) Unmarshal 

func (m *PromiseResponse) Unmarshal(data []byte) error

func (*PromiseResponse) VerboseEqual 

func (this *PromiseResponse) VerboseEqual(that interface{}) error

type RateLimit 

type RateLimit struct {
	// Leaving QPS unset gives it unlimited rate (i.e., not throttled),
	// which also implies unlimited capacity.
	Qps *float64 `protobuf:"fixed64,1,opt,name=qps" json:"qps,omitempty"`
	// Principal of framework(s) to be throttled. Should match
	// FrameworkInfo.princpal and Credential.principal (if using authentication).
	Principal *string `protobuf:"bytes,2,req,name=principal" json:"principal,omitempty"`
	// Max number of outstanding messages from frameworks of this principal
	// allowed by master before the next message is dropped and an error is sent
	// back to the sender. Messages received before the capacity is reached are
	// still going to be processed after the error is sent.
	// If unspecified, this principal is assigned unlimited capacity.
	// NOTE: This value is ignored if 'qps' is not set.
	Capacity         *uint64 `protobuf:"varint,3,opt,name=capacity" json:"capacity,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Rate (queries per second, QPS) limit for messages from a framework to master. Strictly speaking they are the combined rate from all frameworks of the same principal.

func NewPopulatedRateLimit 

func NewPopulatedRateLimit(r randyMesos, easy bool) *RateLimit

func (*RateLimit) Equal 

func (this *RateLimit) Equal(that interface{}) bool

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) GoString 

func (this *RateLimit) GoString() string

func (*RateLimit) Marshal 

func (m *RateLimit) Marshal() (data []byte, err error)

func (*RateLimit) MarshalTo 

func (m *RateLimit) MarshalTo(data []byte) (int, error)

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) Size 

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

func (*RateLimit) String 

func (this *RateLimit) String() string

func (*RateLimit) Unmarshal 

func (m *RateLimit) Unmarshal(data []byte) error

func (*RateLimit) VerboseEqual 

func (this *RateLimit) VerboseEqual(that interface{}) error

type RateLimits 

type RateLimits struct {
	// Items should have unique principals.
	Limits []*RateLimit `protobuf:"bytes,1,rep,name=limits" json:"limits,omitempty"`
	// All the frameworks not specified in 'limits' get this default rate.
	// This rate is an aggregate rate for all of them, i.e., their combined
	// traffic is throttled together at this rate.
	AggregateDefaultQps *float64 `protobuf:"fixed64,2,opt,name=aggregate_default_qps" json:"aggregate_default_qps,omitempty"`
	// All the frameworks not specified in 'limits' get this default capacity.
	// This is an aggregate value similar to 'aggregate_default_qps'.
	AggregateDefaultCapacity *uint64 `protobuf:"varint,3,opt,name=aggregate_default_capacity" json:"aggregate_default_capacity,omitempty"`
	XXX_unrecognized         []byte  `json:"-"`
}

* Collection of RateLimit. Frameworks without rate limits defined here are not throttled unless 'aggregate_default_qps' is specified.

func NewPopulatedRateLimits 

func NewPopulatedRateLimits(r randyMesos, easy bool) *RateLimits

func (*RateLimits) Equal 

func (this *RateLimits) Equal(that interface{}) bool

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) GoString 

func (this *RateLimits) GoString() string

func (*RateLimits) Marshal 

func (m *RateLimits) Marshal() (data []byte, err error)

func (*RateLimits) MarshalTo 

func (m *RateLimits) MarshalTo(data []byte) (int, error)

func (*RateLimits) ProtoMessage 

func (*RateLimits) ProtoMessage()

func (*RateLimits) Reset 

func (m *RateLimits) Reset()

func (*RateLimits) Size 

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

func (*RateLimits) String 

func (this *RateLimits) String() string

func (*RateLimits) Unmarshal 

func (m *RateLimits) Unmarshal(data []byte) error

func (*RateLimits) VerboseEqual 

func (this *RateLimits) VerboseEqual(that interface{}) error

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:"-"`
}

Allows the framework to query the status for non-terminal tasks. This causes the master to send back the latest task status for each task in 'statuses', if possible. Tasks that are no longer known will result in a TASK_LOST update. If statuses is empty, then the master will send the latest status for each task currently known.

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 Record 

type Record struct {
	Type             *Record_Type `protobuf:"varint,1,req,name=type,enum=mesosproto.Record_Type" json:"type,omitempty"`
	Promise          *Promise     `protobuf:"bytes,2,opt,name=promise" json:"promise,omitempty"`
	Action           *Action      `protobuf:"bytes,3,opt,name=action" json:"action,omitempty"`
	Metadata         *Metadata    `protobuf:"bytes,4,opt,name=metadata" json:"metadata,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

Represents a log record written to the local filesystem by a replica. A log record may store a promise (DEPRECATED), an action or metadata (defined above).

func NewPopulatedRecord 

func NewPopulatedRecord(r randyLog, easy bool) *Record

func (*Record) Equal 

func (this *Record) Equal(that interface{}) bool

func (*Record) GetAction 

func (m *Record) GetAction() *Action

func (*Record) GetMetadata 

func (m *Record) GetMetadata() *Metadata

func (*Record) GetPromise 

func (m *Record) GetPromise() *Promise

func (*Record) GetType 

func (m *Record) GetType() Record_Type

func (*Record) GoString 

func (this *Record) GoString() string

func (*Record) Marshal 

func (m *Record) Marshal() (data []byte, err error)

func (*Record) MarshalTo 

func (m *Record) MarshalTo(data []byte) (int, error)

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) Size 

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

func (*Record) String 

func (this *Record) String() string

func (*Record) Unmarshal 

func (m *Record) Unmarshal(data []byte) error

func (*Record) VerboseEqual 

func (this *Record) VerboseEqual(that interface{}) error

type Record_Type 

type Record_Type int32
const (
	Record_PROMISE  Record_Type = 1
	Record_ACTION   Record_Type = 2
	Record_METADATA Record_Type = 3
)

func (Record_Type) Enum 

func (x Record_Type) Enum() *Record_Type

func (Record_Type) String 

func (x Record_Type) String() string

func (*Record_Type) UnmarshalJSON 

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

type RecoverRequest 

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

Represents a recover request. A recover request is used to initiate the recovery (by broadcasting it).

func NewPopulatedRecoverRequest 

func NewPopulatedRecoverRequest(r randyLog, easy bool) *RecoverRequest

func (*RecoverRequest) Equal 

func (this *RecoverRequest) Equal(that interface{}) bool

func (*RecoverRequest) GoString 

func (this *RecoverRequest) GoString() string

func (*RecoverRequest) Marshal 

func (m *RecoverRequest) Marshal() (data []byte, err error)

func (*RecoverRequest) MarshalTo 

func (m *RecoverRequest) MarshalTo(data []byte) (int, error)

func (*RecoverRequest) ProtoMessage 

func (*RecoverRequest) ProtoMessage()

func (*RecoverRequest) Reset 

func (m *RecoverRequest) Reset()

func (*RecoverRequest) Size 

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

func (*RecoverRequest) String 

func (this *RecoverRequest) String() string

func (*RecoverRequest) Unmarshal 

func (m *RecoverRequest) Unmarshal(data []byte) error

func (*RecoverRequest) VerboseEqual 

func (this *RecoverRequest) VerboseEqual(that interface{}) error

type RecoverResponse 

type RecoverResponse struct {
	Status           *Metadata_Status `protobuf:"varint,1,req,name=status,enum=mesosproto.Metadata_Status" json:"status,omitempty"`
	Begin            *uint64          `protobuf:"varint,2,opt,name=begin" json:"begin,omitempty"`
	End              *uint64          `protobuf:"varint,3,opt,name=end" json:"end,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

When a replica receives a RecoverRequest, it will reply with its current status, and the begin and the end of its current log.

func NewPopulatedRecoverResponse 

func NewPopulatedRecoverResponse(r randyLog, easy bool) *RecoverResponse

func (*RecoverResponse) Equal 

func (this *RecoverResponse) Equal(that interface{}) bool

func (*RecoverResponse) GetBegin 

func (m *RecoverResponse) GetBegin() uint64

func (*RecoverResponse) GetEnd 

func (m *RecoverResponse) GetEnd() uint64

func (*RecoverResponse) GetStatus 

func (m *RecoverResponse) GetStatus() Metadata_Status

func (*RecoverResponse) GoString 

func (this *RecoverResponse) GoString() string

func (*RecoverResponse) Marshal 

func (m *RecoverResponse) Marshal() (data []byte, err error)

func (*RecoverResponse) MarshalTo 

func (m *RecoverResponse) MarshalTo(data []byte) (int, error)

func (*RecoverResponse) ProtoMessage 

func (*RecoverResponse) ProtoMessage()

func (*RecoverResponse) Reset 

func (m *RecoverResponse) Reset()

func (*RecoverResponse) Size 

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

func (*RecoverResponse) String 

func (this *RecoverResponse) String() string

func (*RecoverResponse) Unmarshal 

func (m *RecoverResponse) Unmarshal(data []byte) error

func (*RecoverResponse) VerboseEqual 

func (this *RecoverResponse) VerboseEqual(that interface{}) error

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 RegisterSlaveMessage 

type RegisterSlaveMessage struct {
	Slave *SlaveInfo `protobuf:"bytes,1,req,name=slave" json:"slave,omitempty"`
	// Resources that are checkpointed by the slave (e.g., persistent
	// volume or dynamic reservation). Frameworks need to release
	// checkpointed resources explicitly.
	CheckpointedResources []*Resource `protobuf:"bytes,3,rep,name=checkpointed_resources" json:"checkpointed_resources,omitempty"`
	// NOTE: This is a hack for the master to detect the slave's
	// version. If unset the slave is < 0.21.0.
	// TODO(bmahler): Do proper versioning: MESOS-986.
	Version          *string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RegisterSlaveMessage) GetCheckpointedResources added in v1.1.0 

func (m *RegisterSlaveMessage) GetCheckpointedResources() []*Resource

func (*RegisterSlaveMessage) GetSlave 

func (m *RegisterSlaveMessage) GetSlave() *SlaveInfo

func (*RegisterSlaveMessage) GetVersion 

func (m *RegisterSlaveMessage) GetVersion() string

func (*RegisterSlaveMessage) ProtoMessage 

func (*RegisterSlaveMessage) ProtoMessage()

func (*RegisterSlaveMessage) Reset 

func (m *RegisterSlaveMessage) Reset()

func (*RegisterSlaveMessage) String 

func (m *RegisterSlaveMessage) String() string

type Registry 

type Registry struct {
	// Most recent leading master.
	Master *Registry_Master `protobuf:"bytes,1,opt,name=master" json:"master,omitempty"`
	// All admitted slaves.
	Slaves           *Registry_Slaves `protobuf:"bytes,2,opt,name=slaves" json:"slaves,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*Registry) GetMaster 

func (m *Registry) GetMaster() *Registry_Master

func (*Registry) GetSlaves 

func (m *Registry) GetSlaves() *Registry_Slaves

func (*Registry) ProtoMessage 

func (*Registry) ProtoMessage()

func (*Registry) Reset 

func (m *Registry) Reset()

func (*Registry) String 

func (m *Registry) String() string

type Registry_Master 

type Registry_Master struct {
	Info             *MasterInfo `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Registry_Master) GetInfo 

func (m *Registry_Master) GetInfo() *MasterInfo

func (*Registry_Master) ProtoMessage 

func (*Registry_Master) ProtoMessage()

func (*Registry_Master) Reset 

func (m *Registry_Master) Reset()

func (*Registry_Master) String 

func (m *Registry_Master) String() string

type Registry_Slave 

type Registry_Slave struct {
	Info             *SlaveInfo `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*Registry_Slave) GetInfo 

func (m *Registry_Slave) GetInfo() *SlaveInfo

func (*Registry_Slave) ProtoMessage 

func (*Registry_Slave) ProtoMessage()

func (*Registry_Slave) Reset 

func (m *Registry_Slave) Reset()

func (*Registry_Slave) String 

func (m *Registry_Slave) String() string

type Registry_Slaves 

type Registry_Slaves struct {
	Slaves           []*Registry_Slave `protobuf:"bytes,1,rep,name=slaves" json:"slaves,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*Registry_Slaves) GetSlaves 

func (m *Registry_Slaves) GetSlaves() []*Registry_Slave

func (*Registry_Slaves) ProtoMessage 

func (*Registry_Slaves) ProtoMessage()

func (*Registry_Slaves) Reset 

func (m *Registry_Slaves) Reset()

func (*Registry_Slaves) String 

func (m *Registry_Slaves) 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:"-"`
}

* Describes a request for resources that can be used by a framework to proactively influence the allocator. If 'slave_id' is provided then this request is assumed to only apply to resources on that slave.

TODO(vinod): Remove this once the old driver is removed.

func NewPopulatedRequest 

func NewPopulatedRequest(r randyMesos, easy bool) *Request

func (*Request) Equal 

func (this *Request) Equal(that interface{}) bool

func (*Request) GetResources 

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

func (*Request) GetSlaveId 

func (m *Request) GetSlaveId() *SlaveID

func (*Request) GoString 

func (this *Request) GoString() string

func (*Request) Marshal 

func (m *Request) Marshal() (data []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(data []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (this *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(data []byte) error

func (*Request) VerboseEqual 

func (this *Request) VerboseEqual(that interface{}) error

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 {
	Slave *SlaveInfo `protobuf:"bytes,2,req,name=slave" json:"slave,omitempty"`
	// Resources that are checkpointed by the slave (e.g., persistent
	// volume or dynamic reservation). Frameworks need to release
	// checkpointed resources explicitly.
	CheckpointedResources []*Resource          `protobuf:"bytes,7,rep,name=checkpointed_resources" json:"checkpointed_resources,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"`
	// NOTE: This is a hack for the master to detect the slave's
	// version. If unset the slave is < 0.21.0.
	// TODO(bmahler): Do proper versioning: MESOS-986.
	Version          *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReregisterSlaveMessage) GetCheckpointedResources added in v1.1.0 

func (m *ReregisterSlaveMessage) GetCheckpointedResources() []*Resource

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) GetTasks 

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

func (*ReregisterSlaveMessage) GetVersion 

func (m *ReregisterSlaveMessage) GetVersion() string

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=mesosproto.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"`
	// If this is set, this resource was dynamically reserved by an
	// operator or a framework. Otherwise, this resource is either unreserved
	// or statically reserved by an operator via the --resources flag.
	Reservation *Resource_ReservationInfo `protobuf:"bytes,8,opt,name=reservation" json:"reservation,omitempty"`
	Disk        *Resource_DiskInfo        `protobuf:"bytes,7,opt,name=disk" json:"disk,omitempty"`
	// If this is set, the resources are revocable, i.e., any tasks or
	// executors launched using these resources could get preempted or
	// throttled at any time. This could be used by frameworks to run
	// best effort tasks that do not need strict uptime or performance
	// guarantees. Note that if this is set, 'disk' or 'reservation'
	// cannot be set.
	Revocable        *Resource_RevocableInfo `protobuf:"bytes,9,opt,name=revocable" json:"revocable,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* Describes a resource on a machine. A resource can take on one of three types: scalar (double), a list of finite and discrete ranges (e.g., [1-10, 20-30]), or a set of items. A resource is described using the standard protocol buffer "union" trick.

TODO(benh): Add better support for "expected" resources (e.g., cpus, memory, disk, network).

func NewPopulatedResource 

func NewPopulatedResource(r randyMesos, easy bool) *Resource

func (*Resource) Equal 

func (this *Resource) Equal(that interface{}) bool

func (*Resource) GetDisk added in v1.1.0 

func (m *Resource) GetDisk() *Resource_DiskInfo

func (*Resource) GetName 

func (m *Resource) GetName() string

func (*Resource) GetRanges 

func (m *Resource) GetRanges() *Value_Ranges

func (*Resource) GetReservation added in v1.1.0 

func (m *Resource) GetReservation() *Resource_ReservationInfo

func (*Resource) GetRevocable added in v1.1.0 

func (m *Resource) GetRevocable() *Resource_RevocableInfo

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) GoString 

func (this *Resource) GoString() string

func (*Resource) Marshal 

func (m *Resource) Marshal() (data []byte, err error)

func (*Resource) MarshalTo 

func (m *Resource) MarshalTo(data []byte) (int, error)

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) Size 

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

func (*Resource) String 

func (this *Resource) String() string

func (*Resource) Unmarshal 

func (m *Resource) Unmarshal(data []byte) error

func (*Resource) VerboseEqual 

func (this *Resource) VerboseEqual(that interface{}) error

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"`
	Processes *uint32  `protobuf:"varint,30,opt,name=processes" json:"processes,omitempty"`
	Threads   *uint32  `protobuf:"varint,31,opt,name=threads" json:"threads,omitempty"`
	// CPU Usage Information:
	// Total CPU time spent in user mode, and kernel mode.
	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"`
	// Number of CPUs allocated.
	CpusLimit *float64 `protobuf:"fixed64,4,opt,name=cpus_limit" json:"cpus_limit,omitempty"`
	// cpu.stat on process throttling (for contention issues).
	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"`
	// mem_total_bytes was added in 0.23.0 to represent the total memory
	// of a process in RAM (as opposed to in Swap). This was previously
	// reported as mem_rss_bytes, which was also changed in 0.23.0 to
	// represent only the anonymous memory usage, to keep in sync with
	// Linux kernel's (arguably erroneous) use of terminology.
	MemTotalBytes *uint64 `protobuf:"varint,36,opt,name=mem_total_bytes" json:"mem_total_bytes,omitempty"`
	// Total memory + swap usage. This is set if swap is enabled.
	MemTotalMemswBytes *uint64 `protobuf:"varint,37,opt,name=mem_total_memsw_bytes" json:"mem_total_memsw_bytes,omitempty"`
	// Hard memory limit for a container.
	MemLimitBytes *uint64 `protobuf:"varint,6,opt,name=mem_limit_bytes" json:"mem_limit_bytes,omitempty"`
	// Soft memory limit for a container.
	MemSoftLimitBytes *uint64 `protobuf:"varint,38,opt,name=mem_soft_limit_bytes" json:"mem_soft_limit_bytes,omitempty"`
	// TODO(chzhcn) mem_file_bytes and mem_anon_bytes are deprecated in
	// 0.23.0 and will be removed in 0.24.0.
	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"`
	// mem_cache_bytes is added in 0.23.0 to represent page cache usage.
	MemCacheBytes *uint64 `protobuf:"varint,39,opt,name=mem_cache_bytes" json:"mem_cache_bytes,omitempty"`
	// Since 0.23.0, mem_rss_bytes is changed to represent only
	// anonymous memory usage. Note that neither its requiredness, type,
	// name nor numeric tag has been changed.
	MemRssBytes        *uint64 `protobuf:"varint,5,opt,name=mem_rss_bytes" json:"mem_rss_bytes,omitempty"`
	MemMappedFileBytes *uint64 `protobuf:"varint,12,opt,name=mem_mapped_file_bytes" json:"mem_mapped_file_bytes,omitempty"`
	// This is only set if swap is enabled.
	MemSwapBytes *uint64 `protobuf:"varint,40,opt,name=mem_swap_bytes" json:"mem_swap_bytes,omitempty"`
	// Number of occurrences of different levels of memory pressure
	// events reported by memory cgroup. Pressure listening (re)starts
	// with these values set to 0 when slave (re)starts. See
	// https://www.kernel.org/doc/Documentation/cgroups/memory.txt for
	// more details.
	MemLowPressureCounter      *uint64 `protobuf:"varint,32,opt,name=mem_low_pressure_counter" json:"mem_low_pressure_counter,omitempty"`
	MemMediumPressureCounter   *uint64 `protobuf:"varint,33,opt,name=mem_medium_pressure_counter" json:"mem_medium_pressure_counter,omitempty"`
	MemCriticalPressureCounter *uint64 `protobuf:"varint,34,opt,name=mem_critical_pressure_counter" json:"mem_critical_pressure_counter,omitempty"`
	// Disk Usage Information for executor working directory.
	DiskLimitBytes *uint64 `protobuf:"varint,26,opt,name=disk_limit_bytes" json:"disk_limit_bytes,omitempty"`
	DiskUsedBytes  *uint64 `protobuf:"varint,27,opt,name=disk_used_bytes" json:"disk_used_bytes,omitempty"`
	// Perf statistics.
	Perf *PerfStatistics `protobuf:"bytes,13,opt,name=perf" json:"perf,omitempty"`
	// Network Usage Information:
	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"`
	// The kernel keeps track of RTT (round-trip time) for its TCP
	// sockets. RTT is a way to tell the latency of a container.
	NetTcpRttMicrosecsP50     *float64 `protobuf:"fixed64,22,opt,name=net_tcp_rtt_microsecs_p50" json:"net_tcp_rtt_microsecs_p50,omitempty"`
	NetTcpRttMicrosecsP90     *float64 `protobuf:"fixed64,23,opt,name=net_tcp_rtt_microsecs_p90" json:"net_tcp_rtt_microsecs_p90,omitempty"`
	NetTcpRttMicrosecsP95     *float64 `protobuf:"fixed64,24,opt,name=net_tcp_rtt_microsecs_p95" json:"net_tcp_rtt_microsecs_p95,omitempty"`
	NetTcpRttMicrosecsP99     *float64 `protobuf:"fixed64,25,opt,name=net_tcp_rtt_microsecs_p99" json:"net_tcp_rtt_microsecs_p99,omitempty"`
	NetTcpActiveConnections   *float64 `protobuf:"fixed64,28,opt,name=net_tcp_active_connections" json:"net_tcp_active_connections,omitempty"`
	NetTcpTimeWaitConnections *float64 `protobuf:"fixed64,29,opt,name=net_tcp_time_wait_connections" json:"net_tcp_time_wait_connections,omitempty"`
	// Network traffic flowing into or out of a container can be delayed
	// or dropped due to congestion or policy inside and outside the
	// container.
	NetTrafficControlStatistics []*TrafficControlStatistics `protobuf:"bytes,35,rep,name=net_traffic_control_statistics" json:"net_traffic_control_statistics,omitempty"`
	XXX_unrecognized            []byte                      `json:"-"`
}

* A snapshot of resource usage statistics.

func NewPopulatedResourceStatistics 

func NewPopulatedResourceStatistics(r randyMesos, easy bool) *ResourceStatistics

func (*ResourceStatistics) Equal 

func (this *ResourceStatistics) Equal(that interface{}) bool

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) GetDiskLimitBytes added in v1.1.0 

func (m *ResourceStatistics) GetDiskLimitBytes() uint64

func (*ResourceStatistics) GetDiskUsedBytes added in v1.1.0 

func (m *ResourceStatistics) GetDiskUsedBytes() uint64

func (*ResourceStatistics) GetMemAnonBytes 

func (m *ResourceStatistics) GetMemAnonBytes() uint64

func (*ResourceStatistics) GetMemCacheBytes added in v1.1.0 

func (m *ResourceStatistics) GetMemCacheBytes() uint64

func (*ResourceStatistics) GetMemCriticalPressureCounter added in v1.1.0 

func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

func (*ResourceStatistics) GetMemFileBytes 

func (m *ResourceStatistics) GetMemFileBytes() uint64

func (*ResourceStatistics) GetMemLimitBytes 

func (m *ResourceStatistics) GetMemLimitBytes() uint64

func (*ResourceStatistics) GetMemLowPressureCounter added in v1.1.0 

func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

func (*ResourceStatistics) GetMemMappedFileBytes 

func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

func (*ResourceStatistics) GetMemMediumPressureCounter added in v1.1.0 

func (m *ResourceStatistics) GetMemMediumPressureCounter() uint64

func (*ResourceStatistics) GetMemRssBytes 

func (m *ResourceStatistics) GetMemRssBytes() uint64

func (*ResourceStatistics) GetMemSoftLimitBytes added in v1.1.0 

func (m *ResourceStatistics) GetMemSoftLimitBytes() uint64

func (*ResourceStatistics) GetMemSwapBytes added in v1.1.0 

func (m *ResourceStatistics) GetMemSwapBytes() uint64

func (*ResourceStatistics) GetMemTotalBytes added in v1.1.0 

func (m *ResourceStatistics) GetMemTotalBytes() uint64

func (*ResourceStatistics) GetMemTotalMemswBytes added in v1.1.0 

func (m *ResourceStatistics) GetMemTotalMemswBytes() 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) GetNetTcpActiveConnections added in v1.1.0 

func (m *ResourceStatistics) GetNetTcpActiveConnections() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP50 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP90 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP95 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP99 

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

func (*ResourceStatistics) GetNetTcpTimeWaitConnections added in v1.1.0 

func (m *ResourceStatistics) GetNetTcpTimeWaitConnections() float64

func (*ResourceStatistics) GetNetTrafficControlStatistics added in v1.1.0 

func (m *ResourceStatistics) GetNetTrafficControlStatistics() []*TrafficControlStatistics

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) GetProcesses added in v1.1.0 

func (m *ResourceStatistics) GetProcesses() uint32

func (*ResourceStatistics) GetThreads added in v1.1.0 

func (m *ResourceStatistics) GetThreads() uint32

func (*ResourceStatistics) GetTimestamp 

func (m *ResourceStatistics) GetTimestamp() float64

func (*ResourceStatistics) GoString 

func (this *ResourceStatistics) GoString() string

func (*ResourceStatistics) Marshal 

func (m *ResourceStatistics) Marshal() (data []byte, err error)

func (*ResourceStatistics) MarshalTo 

func (m *ResourceStatistics) MarshalTo(data []byte) (int, error)

func (*ResourceStatistics) ProtoMessage 

func (*ResourceStatistics) ProtoMessage()

func (*ResourceStatistics) Reset 

func (m *ResourceStatistics) Reset()

func (*ResourceStatistics) Size 

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

func (*ResourceStatistics) String 

func (this *ResourceStatistics) String() string

func (*ResourceStatistics) Unmarshal 

func (m *ResourceStatistics) Unmarshal(data []byte) error

func (*ResourceStatistics) VerboseEqual 

func (this *ResourceStatistics) VerboseEqual(that interface{}) error

type ResourceUsage 

type ResourceUsage struct {
	Executors        []*ResourceUsage_Executor `protobuf:"bytes,1,rep,name=executors" json:"executors,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* Describes a snapshot of the resource usage for executors.

func NewPopulatedResourceUsage 

func NewPopulatedResourceUsage(r randyMesos, easy bool) *ResourceUsage

func (*ResourceUsage) Equal 

func (this *ResourceUsage) Equal(that interface{}) bool

func (*ResourceUsage) GetExecutors added in v1.1.0 

func (m *ResourceUsage) GetExecutors() []*ResourceUsage_Executor

func (*ResourceUsage) GoString 

func (this *ResourceUsage) GoString() string

func (*ResourceUsage) Marshal 

func (m *ResourceUsage) Marshal() (data []byte, err error)

func (*ResourceUsage) MarshalTo 

func (m *ResourceUsage) MarshalTo(data []byte) (int, error)

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset 

func (m *ResourceUsage) Reset()

func (*ResourceUsage) Size 

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

func (*ResourceUsage) String 

func (this *ResourceUsage) String() string

func (*ResourceUsage) Unmarshal 

func (m *ResourceUsage) Unmarshal(data []byte) error

func (*ResourceUsage) VerboseEqual 

func (this *ResourceUsage) VerboseEqual(that interface{}) error

type ResourceUsage_Executor added in v1.1.0 

type ResourceUsage_Executor struct {
	ExecutorInfo *ExecutorInfo `protobuf:"bytes,1,req,name=executor_info" json:"executor_info,omitempty"`
	// This includes resources used by the executor itself
	// as well as its active tasks.
	Allocated []*Resource `protobuf:"bytes,2,rep,name=allocated" json:"allocated,omitempty"`
	// Current resource usage. If absent, the containerizer
	// cannot provide resource usage.
	Statistics       *ResourceStatistics `protobuf:"bytes,3,opt,name=statistics" json:"statistics,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func NewPopulatedResourceUsage_Executor added in v1.1.0 

func NewPopulatedResourceUsage_Executor(r randyMesos, easy bool) *ResourceUsage_Executor

func (*ResourceUsage_Executor) Equal added in v1.1.0 

func (this *ResourceUsage_Executor) Equal(that interface{}) bool

func (*ResourceUsage_Executor) GetAllocated added in v1.1.0 

func (m *ResourceUsage_Executor) GetAllocated() []*Resource

func (*ResourceUsage_Executor) GetExecutorInfo added in v1.1.0 

func (m *ResourceUsage_Executor) GetExecutorInfo() *ExecutorInfo

func (*ResourceUsage_Executor) GetStatistics added in v1.1.0 

func (m *ResourceUsage_Executor) GetStatistics() *ResourceStatistics

func (*ResourceUsage_Executor) GoString added in v1.1.0 

func (this *ResourceUsage_Executor) GoString() string

func (*ResourceUsage_Executor) Marshal added in v1.1.0 

func (m *ResourceUsage_Executor) Marshal() (data []byte, err error)

func (*ResourceUsage_Executor) MarshalTo added in v1.1.0 

func (m *ResourceUsage_Executor) MarshalTo(data []byte) (int, error)

func (*ResourceUsage_Executor) ProtoMessage added in v1.1.0 

func (*ResourceUsage_Executor) ProtoMessage()

func (*ResourceUsage_Executor) Reset added in v1.1.0 

func (m *ResourceUsage_Executor) Reset()

func (*ResourceUsage_Executor) Size added in v1.1.0 

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

func (*ResourceUsage_Executor) String added in v1.1.0 

func (this *ResourceUsage_Executor) String() string

func (*ResourceUsage_Executor) Unmarshal added in v1.1.0 

func (m *ResourceUsage_Executor) Unmarshal(data []byte) error

func (*ResourceUsage_Executor) VerboseEqual added in v1.1.0 

func (this *ResourceUsage_Executor) VerboseEqual(that interface{}) error

type Resource_DiskInfo added in v1.1.0 

type Resource_DiskInfo struct {
	Persistence *Resource_DiskInfo_Persistence `protobuf:"bytes,1,opt,name=persistence" json:"persistence,omitempty"`
	// Describes how this disk resource will be mounted in the
	// container. If not set, the disk resource will be used as the
	// sandbox. Otherwise, it will be mounted according to the
	// 'container_path' inside 'volume'. The 'host_path' inside
	// 'volume' is ignored.
	// NOTE: If 'volume' is set but 'persistence' is not set, the
	// volume will be automatically garbage collected after
	// task/executor terminates. Currently, if 'persistence' is set,
	// 'volume' must be set.
	Volume           *Volume `protobuf:"bytes,2,opt,name=volume" json:"volume,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func NewPopulatedResource_DiskInfo added in v1.1.0 

func NewPopulatedResource_DiskInfo(r randyMesos, easy bool) *Resource_DiskInfo

func (*Resource_DiskInfo) Equal added in v1.1.0 

func (this *Resource_DiskInfo) Equal(that interface{}) bool

func (*Resource_DiskInfo) GetPersistence added in v1.1.0 

func (m *Resource_DiskInfo) GetPersistence() *Resource_DiskInfo_Persistence

func (*Resource_DiskInfo) GetVolume added in v1.1.0 

func (m *Resource_DiskInfo) GetVolume() *Volume

func (*Resource_DiskInfo) GoString added in v1.1.0 

func (this *Resource_DiskInfo) GoString() string

func (*Resource_DiskInfo) Marshal added in v1.1.0 

func (m *Resource_DiskInfo) Marshal() (data []byte, err error)

func (*Resource_DiskInfo) MarshalTo added in v1.1.0 

func (m *Resource_DiskInfo) MarshalTo(data []byte) (int, error)

func (*Resource_DiskInfo) ProtoMessage added in v1.1.0 

func (*Resource_DiskInfo) ProtoMessage()

func (*Resource_DiskInfo) Reset added in v1.1.0 

func (m *Resource_DiskInfo) Reset()

func (*Resource_DiskInfo) Size added in v1.1.0 

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

func (*Resource_DiskInfo) String added in v1.1.0 

func (this *Resource_DiskInfo) String() string

func (*Resource_DiskInfo) Unmarshal added in v1.1.0 

func (m *Resource_DiskInfo) Unmarshal(data []byte) error

func (*Resource_DiskInfo) VerboseEqual added in v1.1.0 

func (this *Resource_DiskInfo) VerboseEqual(that interface{}) error

type Resource_DiskInfo_Persistence added in v1.1.0 

type Resource_DiskInfo_Persistence struct {
	// A unique ID for the persistent disk volume.
	// NOTE: The ID needs to be unique per role on each slave.
	Id               *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Describes a persistent disk volume. A persistent disk volume will not be automatically garbage collected if the task/executor/slave terminates, but is re-offered to the framework(s) belonging to the 'role'. A framework can set the ID (if it is not set yet) to express the intention to create a new persistent disk volume from a regular disk resource. To reuse a previously created volume, a framework can launch a task/executor when it receives an offer with a persistent volume, i.e., ID is set. NOTE: Currently, we do not allow a persistent disk volume without a reservation (i.e., 'role' should not be '*').

func NewPopulatedResource_DiskInfo_Persistence added in v1.1.0 

func NewPopulatedResource_DiskInfo_Persistence(r randyMesos, easy bool) *Resource_DiskInfo_Persistence

func (*Resource_DiskInfo_Persistence) Equal added in v1.1.0 

func (this *Resource_DiskInfo_Persistence) Equal(that interface{}) bool

func (*Resource_DiskInfo_Persistence) GetId added in v1.1.0 

func (m *Resource_DiskInfo_Persistence) GetId() string

func (*Resource_DiskInfo_Persistence) GoString added in v1.1.0 

func (this *Resource_DiskInfo_Persistence) GoString() string

func (*Resource_DiskInfo_Persistence) Marshal added in v1.1.0 

func (m *Resource_DiskInfo_Persistence) Marshal() (data []byte, err error)

func (*Resource_DiskInfo_Persistence) MarshalTo added in v1.1.0 

func (m *Resource_DiskInfo_Persistence) MarshalTo(data []byte) (int, error)

func (*Resource_DiskInfo_Persistence) ProtoMessage added in v1.1.0 

func (*Resource_DiskInfo_Persistence) ProtoMessage()

func (*Resource_DiskInfo_Persistence) Reset added in v1.1.0 

func (m *Resource_DiskInfo_Persistence) Reset()

func (*Resource_DiskInfo_Persistence) Size added in v1.1.0 

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

func (*Resource_DiskInfo_Persistence) String added in v1.1.0 

func (this *Resource_DiskInfo_Persistence) String() string

func (*Resource_DiskInfo_Persistence) Unmarshal added in v1.1.0 

func (m *Resource_DiskInfo_Persistence) Unmarshal(data []byte) error

func (*Resource_DiskInfo_Persistence) VerboseEqual added in v1.1.0 

func (this *Resource_DiskInfo_Persistence) VerboseEqual(that interface{}) error

type Resource_ReservationInfo added in v1.1.0 

type Resource_ReservationInfo struct {
	// This field indicates the principal of the operator or framework
	// that reserved this resource. It is used in conjunction with the
	// "unreserve" ACL to determine whether the entity attempting to
	// unreserve this resource is permitted to do so.
	// NOTE: This field should match the FrameworkInfo.principal of
	// the framework that reserved this resource.
	Principal        *string `protobuf:"bytes,1,req,name=principal" json:"principal,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func NewPopulatedResource_ReservationInfo added in v1.1.0 

func NewPopulatedResource_ReservationInfo(r randyMesos, easy bool) *Resource_ReservationInfo

func (*Resource_ReservationInfo) Equal added in v1.1.0 

func (this *Resource_ReservationInfo) Equal(that interface{}) bool

func (*Resource_ReservationInfo) GetPrincipal added in v1.1.0 

func (m *Resource_ReservationInfo) GetPrincipal() string

func (*Resource_ReservationInfo) GoString added in v1.1.0 

func (this *Resource_ReservationInfo) GoString() string

func (*Resource_ReservationInfo) Marshal added in v1.1.0 

func (m *Resource_ReservationInfo) Marshal() (data []byte, err error)

func (*Resource_ReservationInfo) MarshalTo added in v1.1.0 

func (m *Resource_ReservationInfo) MarshalTo(data []byte) (int, error)

func (*Resource_ReservationInfo) ProtoMessage added in v1.1.0 

func (*Resource_ReservationInfo) ProtoMessage()

func (*Resource_ReservationInfo) Reset added in v1.1.0 

func (m *Resource_ReservationInfo) Reset()

func (*Resource_ReservationInfo) Size added in v1.1.0 

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

func (*Resource_ReservationInfo) String added in v1.1.0 

func (this *Resource_ReservationInfo) String() string

func (*Resource_ReservationInfo) Unmarshal added in v1.1.0 

func (m *Resource_ReservationInfo) Unmarshal(data []byte) error

func (*Resource_ReservationInfo) VerboseEqual added in v1.1.0 

func (this *Resource_ReservationInfo) VerboseEqual(that interface{}) error

type Resource_RevocableInfo added in v1.1.0 

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

func NewPopulatedResource_RevocableInfo added in v1.1.0 

func NewPopulatedResource_RevocableInfo(r randyMesos, easy bool) *Resource_RevocableInfo

func (*Resource_RevocableInfo) Equal added in v1.1.0 

func (this *Resource_RevocableInfo) Equal(that interface{}) bool

func (*Resource_RevocableInfo) GoString added in v1.1.0 

func (this *Resource_RevocableInfo) GoString() string

func (*Resource_RevocableInfo) Marshal added in v1.1.0 

func (m *Resource_RevocableInfo) Marshal() (data []byte, err error)

func (*Resource_RevocableInfo) MarshalTo added in v1.1.0 

func (m *Resource_RevocableInfo) MarshalTo(data []byte) (int, error)

func (*Resource_RevocableInfo) ProtoMessage added in v1.1.0 

func (*Resource_RevocableInfo) ProtoMessage()

func (*Resource_RevocableInfo) Reset added in v1.1.0 

func (m *Resource_RevocableInfo) Reset()

func (*Resource_RevocableInfo) Size added in v1.1.0 

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

func (*Resource_RevocableInfo) String added in v1.1.0 

func (this *Resource_RevocableInfo) String() string

func (*Resource_RevocableInfo) Unmarshal added in v1.1.0 

func (m *Resource_RevocableInfo) Unmarshal(data []byte) error

func (*Resource_RevocableInfo) VerboseEqual added in v1.1.0 

func (this *Resource_RevocableInfo) VerboseEqual(that interface{}) error

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 RunTaskMessage 

type RunTaskMessage struct {
	// TODO(karya): Remove framework_id after MESOS-2559 has shipped.
	FrameworkId      *FrameworkID   `protobuf:"bytes,1,opt,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 {
	// TODO(vinod): Make these fields required. These are made optional
	// for backwards compatibility between 0.23.0 slave and pre 0.23.0
	// executor driver.
	ExecutorId       *ExecutorID  `protobuf:"bytes,1,opt,name=executor_id" json:"executor_id,omitempty"`
	FrameworkId      *FrameworkID `protobuf:"bytes,2,opt,name=framework_id" json:"framework_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

Tells a slave (and consequently executor) to shutdown an executor.

func (*ShutdownExecutorMessage) GetExecutorId added in v1.1.0 

func (m *ShutdownExecutorMessage) GetExecutorId() *ExecutorID

func (*ShutdownExecutorMessage) GetFrameworkId added in v1.1.0 

func (m *ShutdownExecutorMessage) GetFrameworkId() *FrameworkID

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:"-"`
}

Tells a slave to shut down all executors of the given framework.

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:"-"`
}

* A unique ID assigned to a slave. Currently, a slave gets a new ID whenever it (re)registers with Mesos. Framework writers shouldn't assume any binding between a slave ID and and a hostname.

func NewPopulatedSlaveID 

func NewPopulatedSlaveID(r randyMesos, easy bool) *SlaveID

func (*SlaveID) Equal 

func (this *SlaveID) Equal(that interface{}) bool

func (*SlaveID) GetValue 

func (m *SlaveID) GetValue() string

func (*SlaveID) GoString 

func (this *SlaveID) GoString() string

func (*SlaveID) Marshal 

func (m *SlaveID) Marshal() (data []byte, err error)

func (*SlaveID) MarshalTo 

func (m *SlaveID) MarshalTo(data []byte) (int, error)

func (*SlaveID) ProtoMessage 

func (*SlaveID) ProtoMessage()

func (*SlaveID) Reset 

func (m *SlaveID) Reset()

func (*SlaveID) Size 

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

func (*SlaveID) String 

func (this *SlaveID) String() string

func (*SlaveID) Unmarshal 

func (m *SlaveID) Unmarshal(data []byte) error

func (*SlaveID) VerboseEqual 

func (this *SlaveID) VerboseEqual(that interface{}) error

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"`
	// TODO(joerg84): Remove checkpoint field as with 0.22.0
	// slave checkpointing is enabled for all slaves (MESOS-2317).
	Checkpoint       *bool  `protobuf:"varint,7,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Describes a slave. Note that the 'id' field is only available after a slave is registered with the master, and is made available here to facilitate re-registration. If checkpoint is set, the slave is checkpointing its own information and potentially frameworks' information (if a framework has checkpointing enabled).

func NewPopulatedSlaveInfo 

func NewPopulatedSlaveInfo(r randyMesos, easy bool) *SlaveInfo

func (*SlaveInfo) Equal 

func (this *SlaveInfo) Equal(that interface{}) bool

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) GoString 

func (this *SlaveInfo) GoString() string

func (*SlaveInfo) Marshal 

func (m *SlaveInfo) Marshal() (data []byte, err error)

func (*SlaveInfo) MarshalTo 

func (m *SlaveInfo) MarshalTo(data []byte) (int, error)

func (*SlaveInfo) ProtoMessage 

func (*SlaveInfo) ProtoMessage()

func (*SlaveInfo) Reset 

func (m *SlaveInfo) Reset()

func (*SlaveInfo) Size 

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

func (*SlaveInfo) String 

func (this *SlaveInfo) String() string

func (*SlaveInfo) Unmarshal 

func (m *SlaveInfo) Unmarshal(data []byte) error

func (*SlaveInfo) VerboseEqual 

func (this *SlaveInfo) VerboseEqual(that interface{}) error

type SlaveRegisteredMessage 

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

func (*SlaveRegisteredMessage) GetConnection added in v1.1.0 

func (m *SlaveRegisteredMessage) GetConnection() *MasterSlaveConnection

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"`
	Reconciliations  []*ReconcileTasksMessage `protobuf:"bytes,2,rep,name=reconciliations" json:"reconciliations,omitempty"`
	Connection       *MasterSlaveConnection   `protobuf:"bytes,3,opt,name=connection" json:"connection,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*SlaveReregisteredMessage) GetConnection added in v1.1.0 

func (m *SlaveReregisteredMessage) GetConnection() *MasterSlaveConnection

func (*SlaveReregisteredMessage) GetReconciliations 

func (m *SlaveReregisteredMessage) GetReconciliations() []*ReconcileTasksMessage

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

* Status is used to indicate the state of the scheduler and executor driver after function calls. 

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"`
	// This is being deprecated in favor of TaskStatus.uuid. In 0.23.0,
	// we set the TaskStatus 'uuid' in the executor driver for all
	// retryable status updates.
	Uuid []byte `protobuf:"bytes,6,opt,name=uuid" json:"uuid,omitempty"`
	// This corresponds to the latest state of the task according to the
	// slave. Note that this state might be different than the state in
	// 'status' because status update manager queues updates. In other
	// words, 'status' corresponds to the update at top of the queue and
	// 'latest_state' corresponds to the update at bottom of the queue.
	LatestState      *TaskState `protobuf:"varint,7,opt,name=latest_state,enum=mesosproto.TaskState" json:"latest_state,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

TODO(vinod): Create a new UUID message type.

func (*StatusUpdate) GetExecutorId 

func (m *StatusUpdate) GetExecutorId() *ExecutorID

func (*StatusUpdate) GetFrameworkId 

func (m *StatusUpdate) GetFrameworkId() *FrameworkID

func (*StatusUpdate) GetLatestState 

func (m *StatusUpdate) GetLatestState() TaskState

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:"-"`
}

NOTE: If 'pid' is present, scheduler driver sends an acknowledgement to the pid.

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=mesosproto.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:"-"`
}

This message encapsulates how we checkpoint a status update to disk. NOTE: If type == UPDATE, the 'update' field is required. NOTE: If type == ACK, the 'uuid' field is required.

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=mesosproto.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"`
	// These fields correspond to the state and uuid of the latest
	// status update forwarded to the master.
	// NOTE: Either both the fields must be set or both must be unset.
	StatusUpdateState *TaskState `protobuf:"varint,9,opt,name=status_update_state,enum=mesosproto.TaskState" json:"status_update_state,omitempty"`
	StatusUpdateUuid  []byte     `protobuf:"bytes,10,opt,name=status_update_uuid" json:"status_update_uuid,omitempty"`
	Labels            *Labels    `protobuf:"bytes,11,opt,name=labels" json:"labels,omitempty"`
	// Service discovery information for the task. It is not interpreted
	// or acted upon by Mesos. It is up to a service discovery system
	// to use this information as needed and to handle tasks without
	// service discovery information.
	Discovery        *DiscoveryInfo `protobuf:"bytes,12,opt,name=discovery" json:"discovery,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

TODO(benh): It would be great if this could just be a TaskInfo wherever it gets used! However, doing so would require adding the framework_id field, the executor_id field, and the state field into TaskInfo though (or send them another way). Also, one performance reason why we don't do that now is because storing whatever data is coupled with a TaskInfo could be large and unnecessary. TODO(bmahler): Add executor_uuid here, and send it to the master. This will allow us to expose executor work directories for tasks in the webui when looking from the master level. Currently only the slave knows which run the task belongs to.

func (*Task) GetDiscovery added in v1.1.0 

func (m *Task) GetDiscovery() *DiscoveryInfo

func (*Task) GetExecutorId 

func (m *Task) GetExecutorId() *ExecutorID

func (*Task) GetFrameworkId 

func (m *Task) GetFrameworkId() *FrameworkID

func (*Task) GetLabels added in v1.1.0 

func (m *Task) GetLabels() *Labels

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) GetStatusUpdateState 

func (m *Task) GetStatusUpdateState() TaskState

func (*Task) GetStatusUpdateUuid 

func (m *Task) GetStatusUpdateUuid() []byte

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"`
	// Flag to initiate task kill.
	KillTask *bool `protobuf:"varint,3,opt,name=kill_task,def=0" json:"kill_task,omitempty"`
	// Number of consecutive counts in current status.
	// This will not be populated if task is healthy.
	ConsecutiveFailures *int32 `protobuf:"varint,4,opt,name=consecutive_failures" json:"consecutive_failures,omitempty"`
	XXX_unrecognized    []byte `json:"-"`
}

Message describing task current health status that is sent by the task health checker to the command executor. The command executor reports the task status back to the on each receive. If the health checker configured faiure condition meets, then kill_task flag will be set to true which the executor on message receive will kill the task.

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:"-"`
}

* A framework generated ID to distinguish a task. The ID must remain unique while the task is active. However, a framework can reuse an ID _only_ if a previous task with the same ID has reached a terminal state (e.g., TASK_FINISHED, TASK_LOST, TASK_KILLED, etc.).

func NewPopulatedTaskID 

func NewPopulatedTaskID(r randyMesos, easy bool) *TaskID

func (*TaskID) Equal 

func (this *TaskID) Equal(that interface{}) bool

func (*TaskID) GetValue 

func (m *TaskID) GetValue() string

func (*TaskID) GoString 

func (this *TaskID) GoString() string

func (*TaskID) Marshal 

func (m *TaskID) Marshal() (data []byte, err error)

func (*TaskID) MarshalTo 

func (m *TaskID) MarshalTo(data []byte) (int, error)

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) Reset 

func (m *TaskID) Reset()

func (*TaskID) Size 

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

func (*TaskID) String 

func (this *TaskID) String() string

func (*TaskID) Unmarshal 

func (m *TaskID) Unmarshal(data []byte) error

func (*TaskID) VerboseEqual 

func (this *TaskID) VerboseEqual(that interface{}) error

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"`
	// Task provided with a container will launch the container as part
	// of this task paired with the task's CommandInfo.
	Container *ContainerInfo `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	Data      []byte         `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	// A health check for the task (currently in *alpha* and initial
	// support will only be for TaskInfo's that have a CommandInfo).
	HealthCheck *HealthCheck `protobuf:"bytes,8,opt,name=health_check" json:"health_check,omitempty"`
	// Labels are free-form key value pairs which are exposed through
	// master and slave endpoints. Labels will not be interpreted or
	// acted upon by Mesos itself. As opposed to the data field, labels
	// will be kept in memory on master and slave processes. Therefore,
	// labels should be used to tag tasks with light-weight meta-data.
	Labels *Labels `protobuf:"bytes,10,opt,name=labels" json:"labels,omitempty"`
	// Service discovery information for the task. It is not interpreted
	// or acted upon by Mesos. It is up to a service discovery system
	// to use this information as needed and to handle tasks without
	// service discovery information.
	Discovery        *DiscoveryInfo `protobuf:"bytes,11,opt,name=discovery" json:"discovery,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

* Describes a task. Passed from the scheduler all the way to an executor (see SchedulerDriver::launchTasks and Executor::launchTask). Either ExecutorInfo or CommandInfo should be set. A different executor can be used to launch this task, and subsequent tasks meant for the same executor can reuse the same ExecutorInfo struct.

func NewPopulatedTaskInfo 

func NewPopulatedTaskInfo(r randyMesos, easy bool) *TaskInfo

func (*TaskInfo) Equal 

func (this *TaskInfo) Equal(that interface{}) bool

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) GetDiscovery added in v1.1.0 

func (m *TaskInfo) GetDiscovery() *DiscoveryInfo

func (*TaskInfo) GetExecutor 

func (m *TaskInfo) GetExecutor() *ExecutorInfo

func (*TaskInfo) GetHealthCheck 

func (m *TaskInfo) GetHealthCheck() *HealthCheck

func (*TaskInfo) GetLabels added in v1.1.0 

func (m *TaskInfo) GetLabels() *Labels

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) GoString 

func (this *TaskInfo) GoString() string

func (*TaskInfo) Marshal 

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

func (*TaskInfo) MarshalTo 

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

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset 

func (m *TaskInfo) Reset()

func (*TaskInfo) Size 

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

func (*TaskInfo) String 

func (this *TaskInfo) String() string

func (*TaskInfo) Unmarshal 

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

func (*TaskInfo) VerboseEqual 

func (this *TaskInfo) VerboseEqual(that interface{}) error

type TaskState 

type TaskState int32

* Describes possible task states. IMPORTANT: Mesos assumes tasks that enter terminal states (see below) imply the task is no longer running and thus clean up any thing associated with the task (ultimately offering any resources being consumed by that task to another task). 

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
	TaskState_TASK_ERROR    TaskState = 7
)

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=mesosproto.TaskState" json:"state,omitempty"`
	Message    *string            `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Source     *TaskStatus_Source `protobuf:"varint,9,opt,name=source,enum=mesosproto.TaskStatus_Source" json:"source,omitempty"`
	Reason     *TaskStatus_Reason `protobuf:"varint,10,opt,name=reason,enum=mesosproto.TaskStatus_Reason" json:"reason,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"`
	// Statuses that are delivered reliably to the scheduler will
	// include a 'uuid'. The status is considered delivered once
	// it is acknowledged by the scheduler. Schedulers can choose
	// to either explicitly acknowledge statuses or let the scheduler
	// driver implicitly acknowledge (default).
	//
	// TODO(bmahler): This is currently overwritten in the scheduler
	// driver and executor driver, but executors will need to set this
	// to a valid RFC-4122 UUID if using the HTTP API.
	Uuid []byte `protobuf:"bytes,11,opt,name=uuid" json:"uuid,omitempty"`
	// Describes whether the task has been determined to be healthy
	// (true) or unhealthy (false) according to the HealthCheck field in
	// the command info.
	Healthy          *bool  `protobuf:"varint,8,opt,name=healthy" json:"healthy,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Describes the current status of a task.

func NewPopulatedTaskStatus 

func NewPopulatedTaskStatus(r randyMesos, easy bool) *TaskStatus

func (*TaskStatus) Equal 

func (this *TaskStatus) Equal(that interface{}) bool

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) GetReason 

func (m *TaskStatus) GetReason() TaskStatus_Reason

func (*TaskStatus) GetSlaveId 

func (m *TaskStatus) GetSlaveId() *SlaveID

func (*TaskStatus) GetSource 

func (m *TaskStatus) GetSource() TaskStatus_Source

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) GetUuid added in v1.1.0 

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

func (*TaskStatus) GoString 

func (this *TaskStatus) GoString() string

func (*TaskStatus) Marshal 

func (m *TaskStatus) Marshal() (data []byte, err error)

func (*TaskStatus) MarshalTo 

func (m *TaskStatus) MarshalTo(data []byte) (int, error)

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) Size 

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

func (*TaskStatus) String 

func (this *TaskStatus) String() string

func (*TaskStatus) Unmarshal 

func (m *TaskStatus) Unmarshal(data []byte) error

func (*TaskStatus) VerboseEqual 

func (this *TaskStatus) VerboseEqual(that interface{}) error

type TaskStatus_Reason 

type TaskStatus_Reason int32

Detailed reason for the task status update.

TODO(bmahler): Differentiate between slave removal reasons (e.g. unhealthy vs. unregistered for maintenance). 

const (
	TaskStatus_REASON_COMMAND_EXECUTOR_FAILED TaskStatus_Reason = 0
	TaskStatus_REASON_EXECUTOR_PREEMPTED      TaskStatus_Reason = 17
	TaskStatus_REASON_EXECUTOR_TERMINATED     TaskStatus_Reason = 1
	TaskStatus_REASON_EXECUTOR_UNREGISTERED   TaskStatus_Reason = 2
	TaskStatus_REASON_FRAMEWORK_REMOVED       TaskStatus_Reason = 3
	TaskStatus_REASON_GC_ERROR                TaskStatus_Reason = 4
	TaskStatus_REASON_INVALID_FRAMEWORKID     TaskStatus_Reason = 5
	TaskStatus_REASON_INVALID_OFFERS          TaskStatus_Reason = 6
	TaskStatus_REASON_MASTER_DISCONNECTED     TaskStatus_Reason = 7
	TaskStatus_REASON_MEMORY_LIMIT            TaskStatus_Reason = 8
	TaskStatus_REASON_RECONCILIATION          TaskStatus_Reason = 9
	TaskStatus_REASON_RESOURCES_UNKNOWN       TaskStatus_Reason = 18
	TaskStatus_REASON_SLAVE_DISCONNECTED      TaskStatus_Reason = 10
	TaskStatus_REASON_SLAVE_REMOVED           TaskStatus_Reason = 11
	TaskStatus_REASON_SLAVE_RESTARTED         TaskStatus_Reason = 12
	TaskStatus_REASON_SLAVE_UNKNOWN           TaskStatus_Reason = 13
	TaskStatus_REASON_TASK_INVALID            TaskStatus_Reason = 14
	TaskStatus_REASON_TASK_UNAUTHORIZED       TaskStatus_Reason = 15
	TaskStatus_REASON_TASK_UNKNOWN            TaskStatus_Reason = 16
)

func (TaskStatus_Reason) Enum 

func (x TaskStatus_Reason) Enum() *TaskStatus_Reason

func (TaskStatus_Reason) String 

func (x TaskStatus_Reason) String() string

func (*TaskStatus_Reason) UnmarshalJSON 

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

type TaskStatus_Source 

type TaskStatus_Source int32

Describes the source of the task status update. 

const (
	TaskStatus_SOURCE_MASTER   TaskStatus_Source = 0
	TaskStatus_SOURCE_SLAVE    TaskStatus_Source = 1
	TaskStatus_SOURCE_EXECUTOR TaskStatus_Source = 2
)

func (TaskStatus_Source) Enum 

func (x TaskStatus_Source) Enum() *TaskStatus_Source

func (TaskStatus_Source) String 

func (x TaskStatus_Source) String() string

func (*TaskStatus_Source) UnmarshalJSON 

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

type Termination 

type Termination struct {
	// A container may be killed if it exceeds its resources; this will
	// be indicated by killed=true and described by the message string.
	// TODO(jaybuff): As part of MESOS-2035 we should remove killed and
	// replace it with a TaskStatus::Reason.
	Killed  *bool   `protobuf:"varint,1,req,name=killed" json:"killed,omitempty"`
	Message *string `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	// Exit status of the process.
	Status           *int32 `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Information about a container termination, returned by the containerizer to the slave.

func (*Termination) GetKilled 

func (m *Termination) GetKilled() bool

func (*Termination) GetMessage 

func (m *Termination) GetMessage() string

func (*Termination) GetStatus 

func (m *Termination) GetStatus() int32

func (*Termination) ProtoMessage 

func (*Termination) ProtoMessage()

func (*Termination) Reset 

func (m *Termination) Reset()

func (*Termination) String 

func (m *Termination) String() string

type TrafficControlStatistics added in v1.1.0 

type TrafficControlStatistics struct {
	Id               *string `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Backlog          *uint64 `protobuf:"varint,2,opt,name=backlog" json:"backlog,omitempty"`
	Bytes            *uint64 `protobuf:"varint,3,opt,name=bytes" json:"bytes,omitempty"`
	Drops            *uint64 `protobuf:"varint,4,opt,name=drops" json:"drops,omitempty"`
	Overlimits       *uint64 `protobuf:"varint,5,opt,name=overlimits" json:"overlimits,omitempty"`
	Packets          *uint64 `protobuf:"varint,6,opt,name=packets" json:"packets,omitempty"`
	Qlen             *uint64 `protobuf:"varint,7,opt,name=qlen" json:"qlen,omitempty"`
	Ratebps          *uint64 `protobuf:"varint,8,opt,name=ratebps" json:"ratebps,omitempty"`
	Ratepps          *uint64 `protobuf:"varint,9,opt,name=ratepps" json:"ratepps,omitempty"`
	Requeues         *uint64 `protobuf:"varint,10,opt,name=requeues" json:"requeues,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* When the network bandwidth caps are enabled and the container is over its limit, outbound packets may be either delayed or dropped completely either because it exceeds the maximum bandwidth allocation for a single container (the cap) or because the combined network traffic of multiple containers on the host exceeds the transmit capacity of the host (the share). We can report the following statistics for each of these conditions exported directly from the Linux Traffic Control Queueing Discipline.

id : name of the limiter, e.g. 'tx_bw_cap' backlog : number of packets currently delayed bytes : total bytes seen drops : number of packets dropped in total overlimits : number of packets which exceeded allocation packets : total packets seen qlen : number of packets currently queued rate_bps : throughput in bytes/sec rate_pps : throughput in packets/sec requeues : number of times a packet has been delayed due to 

locking or device contention issues

More information on the operation of Linux Traffic Control can be found at http://www.lartc.org/lartc.html.

func NewPopulatedTrafficControlStatistics added in v1.1.0 

func NewPopulatedTrafficControlStatistics(r randyMesos, easy bool) *TrafficControlStatistics

func (*TrafficControlStatistics) Equal added in v1.1.0 

func (this *TrafficControlStatistics) Equal(that interface{}) bool

func (*TrafficControlStatistics) GetBacklog added in v1.1.0 

func (m *TrafficControlStatistics) GetBacklog() uint64

func (*TrafficControlStatistics) GetBytes added in v1.1.0 

func (m *TrafficControlStatistics) GetBytes() uint64

func (*TrafficControlStatistics) GetDrops added in v1.1.0 

func (m *TrafficControlStatistics) GetDrops() uint64

func (*TrafficControlStatistics) GetId added in v1.1.0 

func (m *TrafficControlStatistics) GetId() string

func (*TrafficControlStatistics) GetOverlimits added in v1.1.0 

func (m *TrafficControlStatistics) GetOverlimits() uint64

func (*TrafficControlStatistics) GetPackets added in v1.1.0 

func (m *TrafficControlStatistics) GetPackets() uint64

func (*TrafficControlStatistics) GetQlen added in v1.1.0 

func (m *TrafficControlStatistics) GetQlen() uint64

func (*TrafficControlStatistics) GetRatebps added in v1.1.0 

func (m *TrafficControlStatistics) GetRatebps() uint64

func (*TrafficControlStatistics) GetRatepps added in v1.1.0 

func (m *TrafficControlStatistics) GetRatepps() uint64

func (*TrafficControlStatistics) GetRequeues added in v1.1.0 

func (m *TrafficControlStatistics) GetRequeues() uint64

func (*TrafficControlStatistics) GoString added in v1.1.0 

func (this *TrafficControlStatistics) GoString() string

func (*TrafficControlStatistics) Marshal added in v1.1.0 

func (m *TrafficControlStatistics) Marshal() (data []byte, err error)

func (*TrafficControlStatistics) MarshalTo added in v1.1.0 

func (m *TrafficControlStatistics) MarshalTo(data []byte) (int, error)

func (*TrafficControlStatistics) ProtoMessage added in v1.1.0 

func (*TrafficControlStatistics) ProtoMessage()

func (*TrafficControlStatistics) Reset added in v1.1.0 

func (m *TrafficControlStatistics) Reset()

func (*TrafficControlStatistics) Size added in v1.1.0 

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

func (*TrafficControlStatistics) String added in v1.1.0 

func (this *TrafficControlStatistics) String() string

func (*TrafficControlStatistics) Unmarshal added in v1.1.0 

func (m *TrafficControlStatistics) Unmarshal(data []byte) error

func (*TrafficControlStatistics) VerboseEqual added in v1.1.0 

func (this *TrafficControlStatistics) VerboseEqual(that interface{}) error

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 Update 

type Update struct {
	ContainerId      *ContainerID `protobuf:"bytes,1,req,name=container_id" json:"container_id,omitempty"`
	Resources        []*Resource  `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Encodes the update command sent to the external containerizer program.

func (*Update) GetContainerId 

func (m *Update) GetContainerId() *ContainerID

func (*Update) GetResources 

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

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) String 

func (m *Update) 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 UpdateSlaveMessage added in v1.1.0 

type UpdateSlaveMessage struct {
	SlaveId                 *SlaveID    `protobuf:"bytes,1,req,name=slave_id" json:"slave_id,omitempty"`
	OversubscribedResources []*Resource `protobuf:"bytes,2,rep,name=oversubscribed_resources" json:"oversubscribed_resources,omitempty"`
	XXX_unrecognized        []byte      `json:"-"`
}

This message is sent by the slave to the master to inform the master about the total amount of oversubscribed (allocated and allocatable) resources.

func (*UpdateSlaveMessage) GetOversubscribedResources added in v1.1.0 

func (m *UpdateSlaveMessage) GetOversubscribedResources() []*Resource

func (*UpdateSlaveMessage) GetSlaveId added in v1.1.0 

func (m *UpdateSlaveMessage) GetSlaveId() *SlaveID

func (*UpdateSlaveMessage) ProtoMessage added in v1.1.0 

func (*UpdateSlaveMessage) ProtoMessage()

func (*UpdateSlaveMessage) Reset added in v1.1.0 

func (m *UpdateSlaveMessage) Reset()

func (*UpdateSlaveMessage) String added in v1.1.0 

func (m *UpdateSlaveMessage) String() string

type Usage 

type Usage struct {
	ContainerId      *ContainerID `protobuf:"bytes,1,req,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Encodes the usage command sent to the external containerizer program.

func (*Usage) GetContainerId 

func (m *Usage) GetContainerId() *ContainerID

func (*Usage) ProtoMessage 

func (*Usage) ProtoMessage()

func (*Usage) Reset 

func (m *Usage) Reset()

func (*Usage) String 

func (m *Usage) String() string

type Value 

type Value struct {
	Type             *Value_Type   `protobuf:"varint,1,req,name=type,enum=mesosproto.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:"-"`
}

* Describes an Attribute or Resource "value". A value is described using the standard protocol buffer "union" trick.

func NewPopulatedValue 

func NewPopulatedValue(r randyMesos, easy bool) *Value

func (*Value) Equal 

func (this *Value) Equal(that interface{}) bool

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) GoString 

func (this *Value) GoString() string

func (*Value) Marshal 

func (m *Value) Marshal() (data []byte, err error)

func (*Value) MarshalTo 

func (m *Value) MarshalTo(data []byte) (int, error)

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

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

func (*Value) String 

func (this *Value) String() string

func (*Value) Unmarshal 

func (m *Value) Unmarshal(data []byte) error

func (*Value) VerboseEqual 

func (this *Value) VerboseEqual(that interface{}) error

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 NewPopulatedValue_Range 

func NewPopulatedValue_Range(r randyMesos, easy bool) *Value_Range

func (*Value_Range) Equal 

func (this *Value_Range) Equal(that interface{}) bool

func (*Value_Range) GetBegin 

func (m *Value_Range) GetBegin() uint64

func (*Value_Range) GetEnd 

func (m *Value_Range) GetEnd() uint64

func (*Value_Range) GoString 

func (this *Value_Range) GoString() string

func (*Value_Range) Marshal 

func (m *Value_Range) Marshal() (data []byte, err error)

func (*Value_Range) MarshalTo 

func (m *Value_Range) MarshalTo(data []byte) (int, error)

func (*Value_Range) ProtoMessage 

func (*Value_Range) ProtoMessage()

func (*Value_Range) Reset 

func (m *Value_Range) Reset()

func (*Value_Range) Size 

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

func (*Value_Range) String 

func (this *Value_Range) String() string

func (*Value_Range) Unmarshal 

func (m *Value_Range) Unmarshal(data []byte) error

func (*Value_Range) VerboseEqual 

func (this *Value_Range) VerboseEqual(that interface{}) error

type Value_Ranges 

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

func NewPopulatedValue_Ranges 

func NewPopulatedValue_Ranges(r randyMesos, easy bool) *Value_Ranges

func (*Value_Ranges) Equal 

func (this *Value_Ranges) Equal(that interface{}) bool

func (*Value_Ranges) GetRange 

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

func (*Value_Ranges) GoString 

func (this *Value_Ranges) GoString() string

func (*Value_Ranges) Marshal 

func (m *Value_Ranges) Marshal() (data []byte, err error)

func (*Value_Ranges) MarshalTo 

func (m *Value_Ranges) MarshalTo(data []byte) (int, error)

func (*Value_Ranges) ProtoMessage 

func (*Value_Ranges) ProtoMessage()

func (*Value_Ranges) Reset 

func (m *Value_Ranges) Reset()

func (*Value_Ranges) Size 

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

func (*Value_Ranges) String 

func (this *Value_Ranges) String() string

func (*Value_Ranges) Unmarshal 

func (m *Value_Ranges) Unmarshal(data []byte) error

func (*Value_Ranges) VerboseEqual 

func (this *Value_Ranges) VerboseEqual(that interface{}) error

type Value_Scalar 

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

func NewPopulatedValue_Scalar 

func NewPopulatedValue_Scalar(r randyMesos, easy bool) *Value_Scalar

func (*Value_Scalar) Equal 

func (this *Value_Scalar) Equal(that interface{}) bool

func (*Value_Scalar) GetValue 

func (m *Value_Scalar) GetValue() float64

func (*Value_Scalar) GoString 

func (this *Value_Scalar) GoString() string

func (*Value_Scalar) Marshal 

func (m *Value_Scalar) Marshal() (data []byte, err error)

func (*Value_Scalar) MarshalTo 

func (m *Value_Scalar) MarshalTo(data []byte) (int, error)

func (*Value_Scalar) ProtoMessage 

func (*Value_Scalar) ProtoMessage()

func (*Value_Scalar) Reset 

func (m *Value_Scalar) Reset()

func (*Value_Scalar) Size 

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

func (*Value_Scalar) String 

func (this *Value_Scalar) String() string

func (*Value_Scalar) Unmarshal 

func (m *Value_Scalar) Unmarshal(data []byte) error

func (*Value_Scalar) VerboseEqual 

func (this *Value_Scalar) VerboseEqual(that interface{}) error

type Value_Set 

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

func NewPopulatedValue_Set 

func NewPopulatedValue_Set(r randyMesos, easy bool) *Value_Set

func (*Value_Set) Equal 

func (this *Value_Set) Equal(that interface{}) bool

func (*Value_Set) GetItem 

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

func (*Value_Set) GoString 

func (this *Value_Set) GoString() string

func (*Value_Set) Marshal 

func (m *Value_Set) Marshal() (data []byte, err error)

func (*Value_Set) MarshalTo 

func (m *Value_Set) MarshalTo(data []byte) (int, error)

func (*Value_Set) ProtoMessage 

func (*Value_Set) ProtoMessage()

func (*Value_Set) Reset 

func (m *Value_Set) Reset()

func (*Value_Set) Size 

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

func (*Value_Set) String 

func (this *Value_Set) String() string

func (*Value_Set) Unmarshal 

func (m *Value_Set) Unmarshal(data []byte) error

func (*Value_Set) VerboseEqual 

func (this *Value_Set) VerboseEqual(that interface{}) error

type Value_Text 

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

func NewPopulatedValue_Text 

func NewPopulatedValue_Text(r randyMesos, easy bool) *Value_Text

func (*Value_Text) Equal 

func (this *Value_Text) Equal(that interface{}) bool

func (*Value_Text) GetValue 

func (m *Value_Text) GetValue() string

func (*Value_Text) GoString 

func (this *Value_Text) GoString() string

func (*Value_Text) Marshal 

func (m *Value_Text) Marshal() (data []byte, err error)

func (*Value_Text) MarshalTo 

func (m *Value_Text) MarshalTo(data []byte) (int, error)

func (*Value_Text) ProtoMessage 

func (*Value_Text) ProtoMessage()

func (*Value_Text) Reset 

func (m *Value_Text) Reset()

func (*Value_Text) Size 

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

func (*Value_Text) String 

func (this *Value_Text) String() string

func (*Value_Text) Unmarshal 

func (m *Value_Text) Unmarshal(data []byte) error

func (*Value_Text) VerboseEqual 

func (this *Value_Text) VerboseEqual(that interface{}) error

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 {
	// Absolute path pointing to a directory or file in the container.
	ContainerPath *string `protobuf:"bytes,1,req,name=container_path" json:"container_path,omitempty"`
	// Absolute path pointing to a directory or file on the host or a path
	// relative to the container work directory.
	HostPath         *string      `protobuf:"bytes,2,opt,name=host_path" json:"host_path,omitempty"`
	Mode             *Volume_Mode `protobuf:"varint,3,req,name=mode,enum=mesosproto.Volume_Mode" json:"mode,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Describes a volume mapping either from host to container or vice versa. Both paths can either refer to a directory or a file.

func NewPopulatedVolume 

func NewPopulatedVolume(r randyMesos, easy bool) *Volume

func (*Volume) Equal 

func (this *Volume) Equal(that interface{}) bool

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) GoString 

func (this *Volume) GoString() string

func (*Volume) Marshal 

func (m *Volume) Marshal() (data []byte, err error)

func (*Volume) MarshalTo 

func (m *Volume) MarshalTo(data []byte) (int, error)

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) Size 

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

func (*Volume) String 

func (this *Volume) String() string

func (*Volume) Unmarshal 

func (m *Volume) Unmarshal(data []byte) error

func (*Volume) VerboseEqual 

func (this *Volume) VerboseEqual(that interface{}) error

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

type Wait 

type Wait struct {
	ContainerId      *ContainerID `protobuf:"bytes,1,req,name=container_id" json:"container_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Encodes the wait command sent to the external containerizer program.

func (*Wait) GetContainerId 

func (m *Wait) GetContainerId() *ContainerID

func (*Wait) ProtoMessage 

func (*Wait) ProtoMessage()

func (*Wait) Reset 

func (m *Wait) Reset()

func (*Wait) String 

func (m *Wait) String() string

type WriteRequest 

type WriteRequest struct {
	Proposal         *uint64          `protobuf:"varint,1,req,name=proposal" json:"proposal,omitempty"`
	Position         *uint64          `protobuf:"varint,2,req,name=position" json:"position,omitempty"`
	Learned          *bool            `protobuf:"varint,3,opt,name=learned" json:"learned,omitempty"`
	Type             *Action_Type     `protobuf:"varint,4,req,name=type,enum=mesosproto.Action_Type" json:"type,omitempty"`
	Nop              *Action_Nop      `protobuf:"bytes,5,opt,name=nop" json:"nop,omitempty"`
	Append           *Action_Append   `protobuf:"bytes,6,opt,name=append" json:"append,omitempty"`
	Truncate         *Action_Truncate `protobuf:"bytes,7,opt,name=truncate" json:"truncate,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

Represents a write request for a specific type of action. Note that we deliberately do not include the entire Action as it contains fields that are not relevant to a write request (e.g., promised, performed) and rather than ignore them we exclude them for safety.

func NewPopulatedWriteRequest 

func NewPopulatedWriteRequest(r randyLog, easy bool) *WriteRequest

func (*WriteRequest) Equal 

func (this *WriteRequest) Equal(that interface{}) bool

func (*WriteRequest) GetAppend 

func (m *WriteRequest) GetAppend() *Action_Append

func (*WriteRequest) GetLearned 

func (m *WriteRequest) GetLearned() bool

func (*WriteRequest) GetNop 

func (m *WriteRequest) GetNop() *Action_Nop

func (*WriteRequest) GetPosition 

func (m *WriteRequest) GetPosition() uint64

func (*WriteRequest) GetProposal 

func (m *WriteRequest) GetProposal() uint64

func (*WriteRequest) GetTruncate 

func (m *WriteRequest) GetTruncate() *Action_Truncate

func (*WriteRequest) GetType 

func (m *WriteRequest) GetType() Action_Type

func (*WriteRequest) GoString 

func (this *WriteRequest) GoString() string

func (*WriteRequest) Marshal 

func (m *WriteRequest) Marshal() (data []byte, err error)

func (*WriteRequest) MarshalTo 

func (m *WriteRequest) MarshalTo(data []byte) (int, error)

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (this *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

func (m *WriteRequest) Unmarshal(data []byte) error

func (*WriteRequest) VerboseEqual 

func (this *WriteRequest) VerboseEqual(that interface{}) error

type WriteResponse 

type WriteResponse struct {
	Okay             *bool   `protobuf:"varint,1,req,name=okay" json:"okay,omitempty"`
	Proposal         *uint64 `protobuf:"varint,2,req,name=proposal" json:"proposal,omitempty"`
	Position         *uint64 `protobuf:"varint,3,req,name=position" json:"position,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

Represents a write response corresponding to a write request. A replica represents a NACK (because it has promised a proposer with a higher proposal number) by setting the okay field to false. If the proposer is a coordinator, then it has been demoted. The 'position' should always correspond to the position set in the request. The 'proposal' is either the same proposal number set in the request in the case of an ACK, or the higher proposal number this position has been promised to in the case of a NACK.

func NewPopulatedWriteResponse 

func NewPopulatedWriteResponse(r randyLog, easy bool) *WriteResponse

func (*WriteResponse) Equal 

func (this *WriteResponse) Equal(that interface{}) bool

func (*WriteResponse) GetOkay 

func (m *WriteResponse) GetOkay() bool

func (*WriteResponse) GetPosition 

func (m *WriteResponse) GetPosition() uint64

func (*WriteResponse) GetProposal 

func (m *WriteResponse) GetProposal() uint64

func (*WriteResponse) GoString 

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal 

func (m *WriteResponse) Marshal() (data []byte, err error)

func (*WriteResponse) MarshalTo 

func (m *WriteResponse) MarshalTo(data []byte) (int, error)

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

func (m *WriteResponse) Unmarshal(data []byte) error

func (*WriteResponse) VerboseEqual 

func (this *WriteResponse) VerboseEqual(that interface{}) 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.