mesosproto

package
v0.3.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 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: 

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

It has these top-level messages: 

Launch
Update
Wait
Destroy
Usage
Termination
Containers

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_RoleInfo_Weight float64 = 1
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:  "REGISTER",
	2:  "REREGISTER",
	3:  "UNREGISTER",
	4:  "REQUEST",
	5:  "DECLINE",
	6:  "REVIVE",
	7:  "LAUNCH",
	8:  "KILL",
	9:  "ACKNOWLEDGE",
	10: "RECONCILE",
	11: "MESSAGE",
}
View Source 
var Call_Type_value = map[string]int32{
	"REGISTER":    1,
	"REREGISTER":  2,
	"UNREGISTER":  3,
	"REQUEST":     4,
	"DECLINE":     5,
	"REVIVE":      6,
	"LAUNCH":      7,
	"KILL":        8,
	"ACKNOWLEDGE": 9,
	"RECONCILE":   10,
	"MESSAGE":     11,
}
View Source 
var ContainerInfo_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 Event_Type_name = map[int32]string{
	1: "REGISTERED",
	2: "REREGISTERED",
	3: "OFFERS",
	4: "RESCIND",
	5: "UPDATE",
	6: "MESSAGE",
	7: "FAILURE",
	8: "ERROR",
}
View Source 
var Event_Type_value = map[string]int32{
	"REGISTERED":   1,
	"REREGISTERED": 2,
	"OFFERS":       3,
	"RESCIND":      4,
	"UPDATE":       5,
	"MESSAGE":      6,
	"FAILURE":      7,
	"ERROR":        8,
}
View Source 
var 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 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",
	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",
	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_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_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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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) (n int, err 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             *string `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AuthenticationStartMessage) GetData 

func (m *AuthenticationStartMessage) GetData() string

func (*AuthenticationStartMessage) GetMechanism 

func (m *AuthenticationStartMessage) GetMechanism() string

func (*AuthenticationStartMessage) ProtoMessage 

func (*AuthenticationStartMessage) ProtoMessage()

func (*AuthenticationStartMessage) Reset 

func (m *AuthenticationStartMessage) Reset()

func (*AuthenticationStartMessage) String 

func (m *AuthenticationStartMessage) String() string

type AuthenticationStepMessage 

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

func (*AuthenticationStepMessage) GetData 

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

func (*AuthenticationStepMessage) ProtoMessage 

func (*AuthenticationStepMessage) ProtoMessage()

func (*AuthenticationStepMessage) Reset 

func (m *AuthenticationStepMessage) Reset()

func (*AuthenticationStepMessage) String 

func (m *AuthenticationStepMessage) String() string

type Call 

type Call struct {
	// Identifies who generated this call. Always necessary, but the
	// only thing that needs to be set for certain calls, e.g.,
	// REGISTER, REREGISTER, and UNREGISTER.
	FrameworkInfo *FrameworkInfo `protobuf:"bytes,1,req,name=framework_info" json:"framework_info,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"`
	Request          *Call_Request     `protobuf:"bytes,3,opt,name=request" json:"request,omitempty"`
	Decline          *Call_Decline     `protobuf:"bytes,4,opt,name=decline" json:"decline,omitempty"`
	Launch           *Call_Launch      `protobuf:"bytes,5,opt,name=launch" json:"launch,omitempty"`
	Kill             *Call_Kill        `protobuf:"bytes,6,opt,name=kill" json:"kill,omitempty"`
	Acknowledge      *Call_Acknowledge `protobuf:"bytes,7,opt,name=acknowledge" json:"acknowledge,omitempty"`
	Reconcile        *Call_Reconcile   `protobuf:"bytes,8,opt,name=reconcile" json:"reconcile,omitempty"`
	Message          *Call_Message     `protobuf:"bytes,9,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Low-level scheduler call API.

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

func (*Call) GetAcknowledge 

func (m *Call) GetAcknowledge() *Call_Acknowledge

func (*Call) GetDecline 

func (m *Call) GetDecline() *Call_Decline

func (*Call) GetFrameworkInfo 

func (m *Call) GetFrameworkInfo() *FrameworkInfo

func (*Call) GetKill 

func (m *Call) GetKill() *Call_Kill

func (*Call) GetLaunch 

func (m *Call) GetLaunch() *Call_Launch

func (*Call) GetMessage 

func (m *Call) GetMessage() *Call_Message

func (*Call) GetReconcile 

func (m *Call) GetReconcile() *Call_Reconcile

func (*Call) GetRequest 

func (m *Call) GetRequest() *Call_Request

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) ProtoMessage 

func (*Call) ProtoMessage()

func (*Call) Reset 

func (m *Call) Reset()

func (*Call) String 

func (m *Call) String() string

type Call_Acknowledge 

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

func (*Call_Acknowledge) GetSlaveId 

func (m *Call_Acknowledge) GetSlaveId() *SlaveID

func (*Call_Acknowledge) GetTaskId 

func (m *Call_Acknowledge) GetTaskId() *TaskID

func (*Call_Acknowledge) GetUuid 

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

func (*Call_Acknowledge) ProtoMessage 

func (*Call_Acknowledge) ProtoMessage()

func (*Call_Acknowledge) Reset 

func (m *Call_Acknowledge) Reset()

func (*Call_Acknowledge) String 

func (m *Call_Acknowledge) String() string

type Call_Decline 

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

func (*Call_Decline) GetFilters 

func (m *Call_Decline) GetFilters() *Filters

func (*Call_Decline) GetOfferIds 

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

func (*Call_Decline) ProtoMessage 

func (*Call_Decline) ProtoMessage()

func (*Call_Decline) Reset 

func (m *Call_Decline) Reset()

func (*Call_Decline) String 

func (m *Call_Decline) String() string

type Call_Kill 

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

func (*Call_Kill) GetTaskId 

func (m *Call_Kill) GetTaskId() *TaskID

func (*Call_Kill) ProtoMessage 

func (*Call_Kill) ProtoMessage()

func (*Call_Kill) Reset 

func (m *Call_Kill) Reset()

func (*Call_Kill) String 

func (m *Call_Kill) String() string

type Call_Launch 

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

func (*Call_Launch) GetFilters 

func (m *Call_Launch) GetFilters() *Filters

func (*Call_Launch) GetOfferIds 

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

func (*Call_Launch) GetTaskInfos 

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

func (*Call_Launch) ProtoMessage 

func (*Call_Launch) ProtoMessage()

func (*Call_Launch) Reset 

func (m *Call_Launch) Reset()

func (*Call_Launch) String 

func (m *Call_Launch) String() string

type Call_Message 

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

func (*Call_Message) GetData 

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

func (*Call_Message) GetExecutorId 

func (m *Call_Message) GetExecutorId() *ExecutorID

func (*Call_Message) GetSlaveId 

func (m *Call_Message) GetSlaveId() *SlaveID

func (*Call_Message) ProtoMessage 

func (*Call_Message) ProtoMessage()

func (*Call_Message) Reset 

func (m *Call_Message) Reset()

func (*Call_Message) String 

func (m *Call_Message) String() string

type Call_Reconcile 

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

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. TODO(bmahler): Add a guiding document for reconciliation or document reconciliation in-depth here.

func (*Call_Reconcile) GetStatuses 

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

func (*Call_Reconcile) ProtoMessage 

func (*Call_Reconcile) ProtoMessage()

func (*Call_Reconcile) Reset 

func (m *Call_Reconcile) Reset()

func (*Call_Reconcile) String 

func (m *Call_Reconcile) String() string

type Call_Request 

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

func (*Call_Request) GetRequests 

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

func (*Call_Request) ProtoMessage 

func (*Call_Request) ProtoMessage()

func (*Call_Request) Reset 

func (m *Call_Request) Reset()

func (*Call_Request) String 

func (m *Call_Request) String() string

type Call_Type 

type Call_Type int32

Possible call types, followed by message definitions if applicable. 

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

func (Call_Type) Enum 

func (x Call_Type) Enum() *Call_Type

func (Call_Type) String 

func (x Call_Type) String() string

func (*Call_Type) UnmarshalJSON 

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

type CommandInfo 

type CommandInfo struct {
	// 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) (n int, err error)

func (*CommandInfo) ProtoMessage 

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset 

func (m *CommandInfo) Reset()

func (*CommandInfo) Size 

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

func (*CommandInfo) String 

func (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) (n int, err 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"`
	Extract          *bool   `protobuf:"varint,3,opt,name=extract,def=1" json:"extract,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) 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) (n int, err 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) (n int, err 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) (n int, err 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 guranteed
	// 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"`
	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) 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) (n int, err 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