mesosproto

package
Version: 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

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 (*AuthenticationMechanismsMessage) 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 (*ContainerInfo_DockerInfo) GetParameters

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

func (*ContainerInfo_DockerInfo) GetPortMappings

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

func (ContainerInfo_DockerInfo_Network) 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 (*ContainerInfo_DockerInfo_PortMapping) GetProtocol

func (*ContainerInfo_DockerInfo_PortMapping) GoString

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) (n int, err error)

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage()

func (*ContainerInfo_DockerInfo_PortMapping) Reset

func (*ContainerInfo_DockerInfo_PortMapping) Size

func (*ContainerInfo_DockerInfo_PortMapping) 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 (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) (n int, err 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) (n int, err 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)