mesosproto

package
v0.20.0 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 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) ProtoMessage

func (*DeactivateFrameworkMessage) ProtoMessage()

func (*DeactivateFrameworkMessage) Reset

func (m *DeactivateFrameworkMessage) Reset()

func (*DeactivateFrameworkMessage) String

func (m *DeactivateFrameworkMessage) String() string

type Destroy

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

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

func (*Destroy) GetContainerId

func (m *Destroy) GetContainerId() *ContainerID

func (*Destroy) ProtoMessage

func (*Destroy) ProtoMessage()

func (*Destroy) Reset

func (m *Destroy) Reset()

func (*Destroy) String

func (m *Destroy) String() string

type Entry

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

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

func NewPopulatedEntry

func NewPopulatedEntry(r randyState, easy bool) *Entry

func (*Entry) Equal

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

func (*Entry) GetName

func (m *Entry) GetName() string

func (*Entry) GetUuid

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

func (*Entry) GetValue

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

func (*Entry) GoString

func (this *Entry) GoString() string

func (*Entry) Marshal

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

func (*Entry) MarshalTo

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

func (*Entry) ProtoMessage

func (*Entry) ProtoMessage()

func (*Entry) Reset

func (m *Entry) Reset()

func (*Entry) Size

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

func (*Entry) String

func (this *Entry) String() string

func (*Entry) Unmarshal

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

func (*Entry) VerboseEqual

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

type Environment

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

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

func NewPopulatedEnvironment

func NewPopulatedEnvironment(r randyMesos, easy bool) *Environment

func (*Environment) Equal

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

func (*Environment) GetVariables

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

func (*Environment) GoString

func (this *Environment) GoString() string

func (*Environment) Marshal

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

func (*Environment) MarshalTo

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

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) Reset

func (m *Environment) Reset()

func (*Environment) Size

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

func (*Environment) String

func (this *Environment) String() string

func (*Environment) Unmarshal

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

func (*Environment) VerboseEqual

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

type Environment_Variable

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

func NewPopulatedEnvironment_Variable

func NewPopulatedEnvironment_Variable(r randyMesos, easy bool) *Environment_Variable

func (*Environment_Variable) Equal

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

func (*Environment_Variable) GetName

func (m *Environment_Variable) GetName() string

func (*Environment_Variable) GetValue

func (m *Environment_Variable) GetValue() string

func (*Environment_Variable) GoString

func (this *Environment_Variable) GoString() string

func (*Environment_Variable) Marshal

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

func (*Environment_Variable) MarshalTo

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

func (*Environment_Variable) ProtoMessage

func (*Environment_Variable) ProtoMessage()

func (*Environment_Variable) Reset

func (m *Environment_Variable) Reset()

func (*Environment_Variable) Size

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

func (*Environment_Variable) String

func (this *Environment_Variable) String() string

func (*Environment_Variable) Unmarshal

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

func (*Environment_Variable) VerboseEqual

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

type Event

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

* Low-level scheduler event API.

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

func (*Event) GetError

func (m *Event) GetError() *Event_Error

func (*Event) GetFailure

func (m *Event) GetFailure() *Event_Failure

func (*Event) GetMessage

func (m *Event) GetMessage() *Event_Message

func (*Event) GetOffers

func (m *Event) GetOffers() *Event_Offers

func (*Event) GetRegistered

func (m *Event) GetRegistered() *Event_Registered

func (*Event) GetReregistered

func (m *Event) GetReregistered() *Event_Reregistered

func (*Event) GetRescind

func (m *Event) GetRescind() *Event_Rescind

func (*Event) GetType

func (m *Event) GetType() Event_Type

func (*Event) GetUpdate

func (m *Event) GetUpdate() *Event_Update

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

type Event_Error

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

func (*Event_Error) GetMessage

func (m *Event_Error) GetMessage() string

func (*Event_Error) ProtoMessage

func (*Event_Error) ProtoMessage()

func (*Event_Error) Reset

func (m *Event_Error) Reset()

func (*Event_Error) String

func (m *Event_Error) String() string

type Event_Failure

type Event_Failure struct {
	SlaveId *SlaveID `protobuf:"bytes,1,opt,name=slave_id" json:"slave_id,omitempty"`
	// If this was just a failure of an executor on a slave then
	// 'executor_id' will be set and possibly 'status' (if we were
	// able to determine the exit status).
	ExecutorId       *ExecutorID `protobuf:"bytes,2,opt,name=executor_id" json:"executor_id,omitempty"`
	Status           *int32      `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Event_Failure) GetExecutorId

func (m *Event_Failure) GetExecutorId() *ExecutorID

func (*Event_Failure) GetSlaveId

func (m *Event_Failure) GetSlaveId() *SlaveID

func (*Event_Failure) GetStatus

func (m *Event_Failure) GetStatus() int32

func (*Event_Failure) ProtoMessage

func (*Event_Failure) ProtoMessage()

func (*Event_Failure) Reset

func (m *Event_Failure) Reset()

func (*Event_Failure) String

func (m *Event_Failure) String() string

type Event_Message

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

func (*Event_Message) GetData

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

func (*Event_Message) GetExecutorId

func (m *Event_Message) GetExecutorId() *ExecutorID

func (*Event_Message) GetSlaveId

func (m *Event_Message) GetSlaveId() *SlaveID

func (*Event_Message) ProtoMessage

func (*Event_Message) ProtoMessage()

func (*Event_Message) Reset

func (m *Event_Message) Reset()

func (*Event_Message) String

func (m *Event_Message) String() string

type Event_Offers

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

func (*Event_Offers) GetOffers

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

func (*Event_Offers) ProtoMessage

func (*Event_Offers) ProtoMessage()

func (*Event_Offers) Reset

func (m *Event_Offers) Reset()

func (*Event_Offers) String

func (m *Event_Offers) String() string

type Event_Registered

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

func (*Event_Registered) GetFrameworkId

func (m *Event_Registered) GetFrameworkId() *FrameworkID

func (*Event_Registered) GetMasterInfo

func (m *Event_Registered) GetMasterInfo() *MasterInfo

func (*Event_Registered) ProtoMessage

func (*Event_Registered) ProtoMessage()

func (*Event_Registered) Reset

func (m *Event_Registered) Reset()

func (*Event_Registered) String

func (m *Event_Registered) String() string

type Event_Reregistered

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

func (*Event_Reregistered) GetFrameworkId

func (m *Event_Reregistered) GetFrameworkId() *FrameworkID

func (*Event_Reregistered) GetMasterInfo

func (m *Event_Reregistered) GetMasterInfo() *MasterInfo

func (*Event_Reregistered) ProtoMessage

func (*Event_Reregistered) ProtoMessage()

func (*Event_Reregistered) Reset

func (m *Event_Reregistered) Reset()

func (*Event_Reregistered) String

func (m *Event_Reregistered) String() string

type Event_Rescind

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

func (*Event_Rescind) GetOfferId

func (m *Event_Rescind) GetOfferId() *OfferID

func (*Event_Rescind) ProtoMessage

func (*Event_Rescind) ProtoMessage()

func (*Event_Rescind) Reset

func (m *Event_Rescind) Reset()

func (*Event_Rescind) String

func (m *Event_Rescind) String() string

type Event_Type

type Event_Type int32

Possible event types, followed by message definitions if applicable.

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

func (Event_Type) Enum

func (x Event_Type) Enum() *Event_Type

func (Event_Type) String

func (x Event_Type) String() string

func (*Event_Type) UnmarshalJSON

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

type Event_Update

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

func (*Event_Update) GetStatus

func (m *Event_Update) GetStatus() *TaskStatus

func (*Event_Update) GetUuid

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

func (*Event_Update) ProtoMessage

func (*Event_Update) ProtoMessage()

func (*Event_Update) Reset

func (m *Event_Update) Reset()

func (*Event_Update) String

func (m *Event_Update) String() string

type ExecutorID

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

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

func NewPopulatedExecutorID

func NewPopulatedExecutorID(r randyMesos, easy bool) *ExecutorID

func (*ExecutorID) Equal

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

func (*ExecutorID) GetValue

func (m *ExecutorID) GetValue() string

func (*ExecutorID) GoString

func (this *ExecutorID) GoString() string

func (*ExecutorID) Marshal

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

func (*ExecutorID) MarshalTo

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

func (*ExecutorID) ProtoMessage

func (*ExecutorID) ProtoMessage()

func (*ExecutorID) Reset

func (m *ExecutorID) Reset()

func (*ExecutorID) Size

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

func (*ExecutorID) String

func (this *ExecutorID) String() string

func (*ExecutorID) Unmarshal

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

func (*ExecutorID) VerboseEqual

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

type ExecutorInfo

type ExecutorInfo struct {
	ExecutorId  *ExecutorID  `protobuf:"bytes,1,req,name=executor_id" json:"executor_id,omitempty"`
	FrameworkId *FrameworkID `protobuf:"bytes,8,opt,name=framework_id" json:"framework_id,omitempty"`
	Command     *CommandInfo `protobuf:"bytes,7,req,name=command" json:"command,omitempty"`
	// Executor provided with a container will launch the container
	// with the executor's CommandInfo and we expect the container to
	// act as a Mesos executor.
	Container *ContainerInfo `protobuf:"bytes,11,opt,name=container" json:"container,omitempty"`
	Resources []*Resource    `protobuf:"bytes,5,rep,name=resources" json:"resources,omitempty"`
	Name      *string        `protobuf:"bytes,9,opt,name=name" json:"name,omitempty"`
	// Source is an identifier style string used by frameworks to track
	// the source of an executor. This is useful when it's possible for
	// different executor ids to be related semantically.
	// NOTE: Source is exposed alongside the resource usage of the
	// executor via JSON on the slave. This allows users to import
	// usage information into a time series database for monitoring.
	Source           *string `protobuf:"bytes,10,opt,name=source" json:"source,omitempty"`
	Data             []byte  `protobuf:"bytes,4,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

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

func NewPopulatedExecutorInfo

func NewPopulatedExecutorInfo(r randyMesos, easy bool) *ExecutorInfo

func (*ExecutorInfo) Equal

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

func (*ExecutorInfo) GetCommand

func (m *ExecutorInfo) GetCommand() *CommandInfo

func (*ExecutorInfo) GetContainer

func (m *ExecutorInfo) GetContainer() *ContainerInfo

func (*ExecutorInfo) GetData

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

func (*ExecutorInfo) GetExecutorId

func (m *ExecutorInfo) GetExecutorId() *ExecutorID

func (*ExecutorInfo) GetFrameworkId

func (m *ExecutorInfo) GetFrameworkId() *FrameworkID

func (*ExecutorInfo) GetName

func (m *ExecutorInfo) GetName() string

func (*ExecutorInfo) GetResources

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

func (*ExecutorInfo) GetSource

func (m *ExecutorInfo) GetSource() string

func (*ExecutorInfo) GoString

func (this *ExecutorInfo) GoString() string

func (*ExecutorInfo) Marshal

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

func (*ExecutorInfo) MarshalTo

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

func (*ExecutorInfo) ProtoMessage

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) Reset

func (m *ExecutorInfo) Reset()

func (*ExecutorInfo) Size

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

func (*ExecutorInfo) String

func (this *ExecutorInfo) String() string

func (*ExecutorInfo) Unmarshal

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

func (*ExecutorInfo) VerboseEqual

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

type ExecutorRegisteredMessage

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

func (*ExecutorRegisteredMessage) GetExecutorInfo

func (m *ExecutorRegisteredMessage) GetExecutorInfo() *ExecutorInfo

func (*ExecutorRegisteredMessage) GetFrameworkId

func (m *ExecutorRegisteredMessage) GetFrameworkId() *FrameworkID

func (*ExecutorRegisteredMessage) GetFrameworkInfo

func (m *ExecutorRegisteredMessage) GetFrameworkInfo() *FrameworkInfo

func (*ExecutorRegisteredMessage) GetSlaveId

func (m *ExecutorRegisteredMessage) GetSlaveId() *SlaveID

func (*ExecutorRegisteredMessage) GetSlaveInfo

func (m *ExecutorRegisteredMessage) GetSlaveInfo() *SlaveInfo

func (*ExecutorRegisteredMessage) ProtoMessage

func (*ExecutorRegisteredMessage) ProtoMessage()

func (*ExecutorRegisteredMessage) Reset

func (m *ExecutorRegisteredMessage) Reset()

func (*ExecutorRegisteredMessage) String

func (m *ExecutorRegisteredMessage) String() string

type ExecutorReregisteredMessage

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

func (*ExecutorReregisteredMessage) GetSlaveId

func (m *ExecutorReregisteredMessage) GetSlaveId() *SlaveID

func (*ExecutorReregisteredMessage) GetSlaveInfo

func (m *ExecutorReregisteredMessage) GetSlaveInfo() *SlaveInfo

func (*ExecutorReregisteredMessage) ProtoMessage

func (*ExecutorReregisteredMessage) ProtoMessage()

func (*ExecutorReregisteredMessage) Reset

func (m *ExecutorReregisteredMessage) Reset()

func (*ExecutorReregisteredMessage) String

func (m *ExecutorReregisteredMessage) String() string

type ExecutorToFrameworkMessage

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

func (*ExecutorToFrameworkMessage) GetData

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

func (*ExecutorToFrameworkMessage) GetExecutorId

func (m *ExecutorToFrameworkMessage) GetExecutorId() *ExecutorID

func (*ExecutorToFrameworkMessage) GetFrameworkId

func (m *ExecutorToFrameworkMessage) GetFrameworkId() *FrameworkID

func (*ExecutorToFrameworkMessage) GetSlaveId

func (m *ExecutorToFrameworkMessage) GetSlaveId() *SlaveID

func (*ExecutorToFrameworkMessage) ProtoMessage

func (*ExecutorToFrameworkMessage) ProtoMessage()

func (*ExecutorToFrameworkMessage) Reset

func (m *ExecutorToFrameworkMessage) Reset()

func (*ExecutorToFrameworkMessage) String

func (m *ExecutorToFrameworkMessage) String() string

type ExitedExecutorMessage

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

func (*ExitedExecutorMessage) GetExecutorId

func (m *ExitedExecutorMessage) GetExecutorId() *ExecutorID

func (*ExitedExecutorMessage) GetFrameworkId

func (m *ExitedExecutorMessage) GetFrameworkId() *FrameworkID

func (*ExitedExecutorMessage) GetSlaveId

func (m *ExitedExecutorMessage) GetSlaveId() *SlaveID

func (*ExitedExecutorMessage) GetStatus

func (m *ExitedExecutorMessage) GetStatus() int32

func (*ExitedExecutorMessage) ProtoMessage

func (*ExitedExecutorMessage) ProtoMessage()

func (*ExitedExecutorMessage) Reset

func (m *ExitedExecutorMessage) Reset()

func (*ExitedExecutorMessage) String

func (m *ExitedExecutorMessage) String() string

type Filters

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

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

func NewPopulatedFilters

func NewPopulatedFilters(r randyMesos, easy bool) *Filters

func (*Filters) Equal

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

func (*Filters) GetRefuseSeconds

func (m *Filters) GetRefuseSeconds() float64

func (*Filters) GoString

func (this *Filters) GoString() string

func (*Filters) Marshal

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

func (*Filters) MarshalTo

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

func (*Filters) ProtoMessage

func (*Filters) ProtoMessage()

func (*Filters) Reset

func (m *Filters) Reset()

func (*Filters) Size

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

func (*Filters) String

func (this *Filters) String() string

func (*Filters) Unmarshal

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

func (*Filters) VerboseEqual

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

type FrameworkErrorMessage

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

func (*FrameworkErrorMessage) GetMessage

func (m *FrameworkErrorMessage) GetMessage() string

func (*FrameworkErrorMessage) ProtoMessage

func (*FrameworkErrorMessage) ProtoMessage()

func (*FrameworkErrorMessage) Reset

func (m *FrameworkErrorMessage) Reset()

func (*FrameworkErrorMessage) String

func (m *FrameworkErrorMessage) String() string

type FrameworkID

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

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

func NewPopulatedFrameworkID

func NewPopulatedFrameworkID(r randyMesos, easy bool) *FrameworkID

func (*FrameworkID) Equal

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

func (*FrameworkID) GetValue

func (m *FrameworkID) GetValue() string

func (*FrameworkID) GoString

func (this *FrameworkID) GoString() string

func (*FrameworkID) Marshal

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

func (*FrameworkID) MarshalTo

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

func (*FrameworkID) ProtoMessage

func (*FrameworkID) ProtoMessage()

func (*FrameworkID) Reset

func (m *FrameworkID) Reset()

func (*FrameworkID) Size

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

func (*FrameworkID) String

func (this *FrameworkID) String() string

func (*FrameworkID) Unmarshal

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

func (*FrameworkID) VerboseEqual

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

type FrameworkInfo

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

* Describes a framework. The user field is used to determine the Unix user that an executor/task should be launched as. If the user field is set to an empty string Mesos will automagically set it to the current user. Note that the ID is only available after a framework has registered, however, it is included here in order to facilitate scheduler failover (i.e., if it is set then the MesosSchedulerDriver expects the scheduler is performing failover). The amount of time that the master will wait for the scheduler to failover before removing the framework is specified by failover_timeout. If checkpoint is set, framework pid, executor pids and status updates are checkpointed to disk by the slaves. Checkpointing allows a restarted slave to reconnect with old executors and recover status updates, at the cost of disk I/O. The role field is used to group frameworks for allocation decisions, depending on the allocation policy being used. If the hostname field is set to an empty string Mesos will automagically set it to the current hostname. The principal field should match the credential the framework uses in authentication. This field is used for framework API rate exporting and limiting and should be set even if authentication is not enabled if these features are desired. The webui_url field allows a framework to advertise its web UI, so that the Mesos web UI can link to it. It is expected to be a full URL, for example http://my-scheduler.example.com:8080/.

func NewPopulatedFrameworkInfo

func NewPopulatedFrameworkInfo(r randyMesos, easy bool) *FrameworkInfo

func (*FrameworkInfo) Equal

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

func (*FrameworkInfo) GetCheckpoint

func (m *FrameworkInfo) GetCheckpoint() bool

func (*FrameworkInfo) GetFailoverTimeout

func (m *FrameworkInfo) GetFailoverTimeout() float64

func (*FrameworkInfo) GetHostname

func (m *FrameworkInfo) GetHostname() string

func (*FrameworkInfo) GetId

func (m *FrameworkInfo) GetId() *FrameworkID

func (*FrameworkInfo) GetName

func (m *FrameworkInfo) GetName() string

func (*FrameworkInfo) GetPrincipal

func (m *FrameworkInfo) GetPrincipal() string

func (*FrameworkInfo) GetRole

func (m *FrameworkInfo) GetRole() string

func (*FrameworkInfo) GetUser

func (m *FrameworkInfo) GetUser() string

func (*FrameworkInfo) GetWebuiUrl

func (m *FrameworkInfo) GetWebuiUrl() string

func (*FrameworkInfo) GoString

func (this *FrameworkInfo) GoString() string

func (*FrameworkInfo) Marshal

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

func (*FrameworkInfo) MarshalTo

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

func (*FrameworkInfo) ProtoMessage

func (*FrameworkInfo) ProtoMessage()

func (*FrameworkInfo) Reset

func (m *FrameworkInfo) Reset()

func (*FrameworkInfo) Size

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

func (*FrameworkInfo) String

func (this *FrameworkInfo) String() string

func (*FrameworkInfo) Unmarshal

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

func (*FrameworkInfo) VerboseEqual

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

type FrameworkRegisteredMessage

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

func (*FrameworkRegisteredMessage) GetFrameworkId

func (m *FrameworkRegisteredMessage) GetFrameworkId() *FrameworkID

func (*FrameworkRegisteredMessage) GetMasterInfo

func (m *FrameworkRegisteredMessage) GetMasterInfo() *MasterInfo

func (*FrameworkRegisteredMessage) ProtoMessage

func (*FrameworkRegisteredMessage) ProtoMessage()

func (*FrameworkRegisteredMessage) Reset

func (m *FrameworkRegisteredMessage) Reset()

func (*FrameworkRegisteredMessage) String

func (m *FrameworkRegisteredMessage) String() string

type FrameworkReregisteredMessage

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

func (*FrameworkReregisteredMessage) GetFrameworkId

func (m *FrameworkReregisteredMessage) GetFrameworkId() *FrameworkID

func (*FrameworkReregisteredMessage) GetMasterInfo

func (m *FrameworkReregisteredMessage) GetMasterInfo() *MasterInfo

func (*FrameworkReregisteredMessage) ProtoMessage

func (*FrameworkReregisteredMessage) ProtoMessage()

func (*FrameworkReregisteredMessage) Reset

func (m *FrameworkReregisteredMessage) Reset()

func (*FrameworkReregisteredMessage) String

type FrameworkToExecutorMessage

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

func (*FrameworkToExecutorMessage) GetData

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

func (*FrameworkToExecutorMessage) GetExecutorId

func (m *FrameworkToExecutorMessage) GetExecutorId() *ExecutorID

func (*FrameworkToExecutorMessage) GetFrameworkId

func (m *FrameworkToExecutorMessage) GetFrameworkId() *FrameworkID

func (*FrameworkToExecutorMessage) GetSlaveId

func (m *FrameworkToExecutorMessage) GetSlaveId() *SlaveID

func (*FrameworkToExecutorMessage) ProtoMessage

func (*FrameworkToExecutorMessage) ProtoMessage()

func (*FrameworkToExecutorMessage) Reset

func (m *FrameworkToExecutorMessage) Reset()

func (*FrameworkToExecutorMessage) String

func (m *FrameworkToExecutorMessage) String() string

type HealthCheck

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

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

func NewPopulatedHealthCheck

func NewPopulatedHealthCheck(r randyMesos, easy bool) *HealthCheck

func (*HealthCheck) Equal

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

func (*HealthCheck) GetCommand

func (m *HealthCheck) GetCommand() *CommandInfo

func (*HealthCheck) GetConsecutiveFailures

func (m *HealthCheck) GetConsecutiveFailures() uint32

func (*HealthCheck) GetDelaySeconds

func (m *HealthCheck) GetDelaySeconds() float64

func (*HealthCheck) GetGracePeriodSeconds

func (m *HealthCheck) GetGracePeriodSeconds() float64

func (*HealthCheck) GetHttp

func (m *HealthCheck) GetHttp() *HealthCheck_HTTP

func (*HealthCheck) GetIntervalSeconds

func (m *HealthCheck) GetIntervalSeconds() float64

func (*HealthCheck) GetTimeoutSeconds

func (m *HealthCheck) GetTimeoutSeconds() float64

func (*HealthCheck) GoString

func (this *HealthCheck) GoString() string

func (*HealthCheck) Marshal

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

func (*HealthCheck) MarshalTo

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

func (*HealthCheck) ProtoMessage

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset

func (m *HealthCheck) Reset()

func (*HealthCheck) Size

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

func (*HealthCheck) String

func (this *HealthCheck) String() string

func (*HealthCheck) Unmarshal

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

func (*HealthCheck) VerboseEqual

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

type HealthCheck_HTTP

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

Describes an HTTP health check.

func NewPopulatedHealthCheck_HTTP

func NewPopulatedHealthCheck_HTTP(r randyMesos, easy bool) *HealthCheck_HTTP

func (*HealthCheck_HTTP) Equal

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

func (*HealthCheck_HTTP) GetPath

func (m *HealthCheck_HTTP) GetPath() string

func (*HealthCheck_HTTP) GetPort

func (m *HealthCheck_HTTP) GetPort() uint32

func (*HealthCheck_HTTP) GetStatuses

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

func (*HealthCheck_HTTP) GoString

func (this *HealthCheck_HTTP) GoString() string

func (*HealthCheck_HTTP) Marshal

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

func (*HealthCheck_HTTP) MarshalTo

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

func (*HealthCheck_HTTP) ProtoMessage

func (*HealthCheck_HTTP) ProtoMessage()

func (*HealthCheck_HTTP) Reset

func (m *HealthCheck_HTTP) Reset()

func (*HealthCheck_HTTP) Size

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

func (*HealthCheck_HTTP) String

func (this *HealthCheck_HTTP) String() string

func (*HealthCheck_HTTP) Unmarshal

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

func (*HealthCheck_HTTP) VerboseEqual

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

type InternalAuthenticationResult

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

func (*InternalAuthenticationResult) GetCompleted

func (m *InternalAuthenticationResult) GetCompleted() bool

func (*InternalAuthenticationResult) GetPid

func (*InternalAuthenticationResult) GetSuccess

func (m *InternalAuthenticationResult) GetSuccess() bool

func (*InternalAuthenticationResult) ProtoMessage

func (*InternalAuthenticationResult) ProtoMessage()

func (*InternalAuthenticationResult) Reset

func (m *InternalAuthenticationResult) Reset()

func (*InternalAuthenticationResult) String

type InternalMasterChangeDetected

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

For use with detector callbacks

func (*InternalMasterChangeDetected) GetMaster

func (m *InternalMasterChangeDetected) GetMaster() *MasterInfo

func (*InternalMasterChangeDetected) ProtoMessage

func (*InternalMasterChangeDetected) ProtoMessage()

func (*InternalMasterChangeDetected) Reset

func (m *InternalMasterChangeDetected) Reset()

func (*InternalMasterChangeDetected) String

type InternalTryAuthentication

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

func (*InternalTryAuthentication) ProtoMessage

func (*InternalTryAuthentication) ProtoMessage()

func (*InternalTryAuthentication) Reset

func (m *InternalTryAuthentication) Reset()

func (*InternalTryAuthentication) String

func (m *InternalTryAuthentication) String() string

type KillTaskMessage

type KillTaskMessage struct {
	// TODO(bmahler): Include the SlaveID here to improve the Master's
	// ability to respond for non-activated slaves.
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	TaskId           *TaskID      `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*KillTaskMessage) GetFrameworkId

func (m *KillTaskMessage) GetFrameworkId() *FrameworkID

func (*KillTaskMessage) GetTaskId

func (m *KillTaskMessage) GetTaskId() *TaskID

func (*KillTaskMessage) ProtoMessage

func (*KillTaskMessage) ProtoMessage()

func (*KillTaskMessage) Reset

func (m *KillTaskMessage) Reset()

func (*KillTaskMessage) String

func (m *KillTaskMessage) String() string

type Launch

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

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

func (*Launch) GetCheckpoint

func (m *Launch) GetCheckpoint() bool

func (*Launch) GetContainerId

func (m *Launch) GetContainerId() *ContainerID

func (*Launch) GetDirectory

func (m *Launch) GetDirectory() string

func (*Launch) GetExecutorInfo

func (m *Launch) GetExecutorInfo() *ExecutorInfo

func (*Launch) GetSlaveId

func (m *Launch) GetSlaveId() *SlaveID

func (*Launch) GetSlavePid

func (m *Launch) GetSlavePid() string

func (*Launch) GetTaskInfo

func (m *Launch) GetTaskInfo() *TaskInfo

func (*Launch) GetUser

func (m *Launch) GetUser() string

func (*Launch) ProtoMessage

func (*Launch) ProtoMessage()

func (*Launch) Reset

func (m *Launch) Reset()

func (*Launch) String

func (m *Launch) String() string

type LaunchTasksMessage

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

func (*LaunchTasksMessage) GetFilters

func (m *LaunchTasksMessage) GetFilters() *Filters

func (*LaunchTasksMessage) GetFrameworkId

func (m *LaunchTasksMessage) GetFrameworkId() *FrameworkID

func (*LaunchTasksMessage) GetOfferIds

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

func (*LaunchTasksMessage) GetTasks

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

func (*LaunchTasksMessage) ProtoMessage

func (*LaunchTasksMessage) ProtoMessage()

func (*LaunchTasksMessage) Reset

func (m *LaunchTasksMessage) Reset()

func (*LaunchTasksMessage) String

func (m *LaunchTasksMessage) String() string

type LearnedMessage

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

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

func NewPopulatedLearnedMessage

func NewPopulatedLearnedMessage(r randyLog, easy bool) *LearnedMessage

func (*LearnedMessage) Equal

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

func (*LearnedMessage) GetAction

func (m *LearnedMessage) GetAction() *Action

func (*LearnedMessage) GoString

func (this *LearnedMessage) GoString() string

func (*LearnedMessage) Marshal

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

func (*LearnedMessage) MarshalTo

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

func (*LearnedMessage) ProtoMessage

func (*LearnedMessage) ProtoMessage()

func (*LearnedMessage) Reset

func (m *LearnedMessage) Reset()

func (*LearnedMessage) Size

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

func (*LearnedMessage) String

func (this *LearnedMessage) String() string

func (*LearnedMessage) Unmarshal

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

func (*LearnedMessage) VerboseEqual

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

type LostSlaveMessage

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

func (*LostSlaveMessage) GetSlaveId

func (m *LostSlaveMessage) GetSlaveId() *SlaveID

func (*LostSlaveMessage) ProtoMessage

func (*LostSlaveMessage) ProtoMessage()

func (*LostSlaveMessage) Reset

func (m *LostSlaveMessage) Reset()

func (*LostSlaveMessage) String

func (m *LostSlaveMessage) String() string

type MasterInfo

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

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

func NewPopulatedMasterInfo

func NewPopulatedMasterInfo(r randyMesos, easy bool) *MasterInfo

func (*MasterInfo) Equal

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

func (*MasterInfo) GetHostname

func (m *MasterInfo) GetHostname() string

func (*MasterInfo) GetId

func (m *MasterInfo) GetId() string

func (*MasterInfo) GetIp

func (m *MasterInfo) GetIp() uint32

func (*MasterInfo) GetPid

func (m *MasterInfo) GetPid() string

func (*MasterInfo) GetPort

func (m *MasterInfo) GetPort() uint32

func (*MasterInfo) GoString

func (this *MasterInfo) GoString() string

func (*MasterInfo) Marshal

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

func (*MasterInfo) MarshalTo

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

func (*MasterInfo) ProtoMessage

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset

func (m *MasterInfo) Reset()

func (*MasterInfo) Size

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

func (*MasterInfo) String

func (this *MasterInfo) String() string

func (*MasterInfo) Unmarshal

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

func (*MasterInfo) VerboseEqual

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

type Metadata

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

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

func NewPopulatedMetadata

func NewPopulatedMetadata(r randyLog, easy bool) *Metadata

func (*Metadata) Equal

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

func (*Metadata) GetPromised

func (m *Metadata) GetPromised() uint64

func (*Metadata) GetStatus

func (m *Metadata) GetStatus() Metadata_Status

func (*Metadata) GoString

func (this *Metadata) GoString() string

func (*Metadata) Marshal

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

func (*Metadata) MarshalTo

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

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) Size

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

func (*Metadata) String

func (this *Metadata) String() string

func (*Metadata) Unmarshal

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

func (*Metadata) VerboseEqual

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

type Metadata_Status

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

func (Metadata_Status) Enum

func (x Metadata_Status) Enum() *Metadata_Status

func (Metadata_Status) String

func (x Metadata_Status) String() string

func (*Metadata_Status) UnmarshalJSON

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

type Modules

type Modules struct {
	Libraries        []*Modules_Library `protobuf:"bytes,1,rep,name=libraries" json:"libraries,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

Collection of Modules.

func (*Modules) GetLibraries

func (m *Modules) GetLibraries() []*Modules_Library

func (*Modules) ProtoMessage

func (*Modules) ProtoMessage()

func (*Modules) Reset

func (m *Modules) Reset()

func (*Modules) String

func (m *Modules) String() string

type Modules_Library

type Modules_Library struct {
	// If "file" contains a slash ("/"), then it is interpreted as a
	// (relative or absolute) pathname.  Otherwise a standard library
	// search is performed.
	File *string `protobuf:"bytes,1,opt,name=file" json:"file,omitempty"`
	// We will add the proper prefix ("lib") and suffix (".so" for
	// Linux and ".dylib" for OS X) to the "name".
	Name             *string                   `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Modules          []*Modules_Library_Module `protobuf:"bytes,3,rep,name=modules" json:"modules,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*Modules_Library) GetFile

func (m *Modules_Library) GetFile() string

func (*Modules_Library) GetModules

func (m *Modules_Library) GetModules() []*Modules_Library_Module

func (*Modules_Library) GetName

func (m *Modules_Library) GetName() string

func (*Modules_Library) ProtoMessage

func (*Modules_Library) ProtoMessage()

func (*Modules_Library) Reset

func (m *Modules_Library) Reset()

func (*Modules_Library) String

func (m *Modules_Library) String() string

type Modules_Library_Module

type Modules_Library_Module struct {
	// Module name.
	Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// Module-specific parameters.
	Parameters       []*Parameter `protobuf:"bytes,2,rep,name=parameters" json:"parameters,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*Modules_Library_Module) GetName

func (m *Modules_Library_Module) GetName() string

func (*Modules_Library_Module) GetParameters

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

func (*Modules_Library_Module) ProtoMessage

func (*Modules_Library_Module) ProtoMessage()

func (*Modules_Library_Module) Reset

func (m *Modules_Library_Module) Reset()

func (*Modules_Library_Module) String

func (m *Modules_Library_Module) String() string

type Offer

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

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

func NewPopulatedOffer

func NewPopulatedOffer(r randyMesos, easy bool) *Offer

func (*Offer) Equal

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

func (*Offer) GetAttributes

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

func (*Offer) GetExecutorIds

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

func (*Offer) GetFrameworkId

func (m *Offer) GetFrameworkId() *FrameworkID

func (*Offer) GetHostname

func (m *Offer) GetHostname() string

func (*Offer) GetId

func (m *Offer) GetId() *OfferID

func (*Offer) GetResources

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

func (*Offer) GetSlaveId

func (m *Offer) GetSlaveId() *SlaveID

func (*Offer) GoString

func (this *Offer) GoString() string

func (*Offer) Marshal

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

func (*Offer) MarshalTo

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

func (*Offer) ProtoMessage

func (*Offer) ProtoMessage()

func (*Offer) Reset

func (m *Offer) Reset()

func (*Offer) Size

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

func (*Offer) String

func (this *Offer) String() string

func (*Offer) Unmarshal

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

func (*Offer) VerboseEqual

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

type OfferID

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

* A unique ID assigned to an offer.

func NewPopulatedOfferID

func NewPopulatedOfferID(r randyMesos, easy bool) *OfferID

func (*OfferID) Equal

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

func (*OfferID) GetValue

func (m *OfferID) GetValue() string

func (*OfferID) GoString

func (this *OfferID) GoString() string

func (*OfferID) Marshal

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

func (*OfferID) MarshalTo

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

func (*OfferID) ProtoMessage

func (*OfferID) ProtoMessage()

func (*OfferID) Reset

func (m *OfferID) Reset()

func (*OfferID) Size

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

func (*OfferID) String

func (this *OfferID) String() string

func (*OfferID) Unmarshal

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

func (*OfferID) VerboseEqual

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

type Operation

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

Describes an operation used in the log storage implementation.

func NewPopulatedOperation

func NewPopulatedOperation(r randyState, easy bool) *Operation

func (*Operation) Equal

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

func (*Operation) GetDiff

func (m *Operation) GetDiff() *Operation_Diff

func (*Operation) GetExpunge

func (m *Operation) GetExpunge() *Operation_Expunge

func (*Operation) GetSnapshot

func (m *Operation) GetSnapshot() *Operation_Snapshot

func (*Operation) GetType

func (m *Operation) GetType() Operation_Type

func (*Operation) GoString

func (this *Operation) GoString() string

func (*Operation) Marshal

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

func (*Operation) MarshalTo

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

func (*Operation) ProtoMessage

func (*Operation) ProtoMessage()

func (*Operation) Reset

func (m *Operation) Reset()

func (*Operation) Size

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

func (*Operation) String

func (this *Operation) String() string

func (*Operation) Unmarshal

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

func (*Operation) VerboseEqual

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

type Operation_Diff

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

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

func NewPopulatedOperation_Diff

func NewPopulatedOperation_Diff(r randyState, easy bool) *Operation_Diff

func (*Operation_Diff) Equal

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

func (*Operation_Diff) GetEntry

func (m *Operation_Diff) GetEntry() *Entry

func (*Operation_Diff) GoString

func (this *Operation_Diff) GoString() string

func (*Operation_Diff) Marshal

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

func (*Operation_Diff) MarshalTo

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

func (*Operation_Diff) ProtoMessage

func (*Operation_Diff) ProtoMessage()

func (*Operation_Diff) Reset

func (m *Operation_Diff) Reset()

func (*Operation_Diff) Size

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

func (*Operation_Diff) String

func (this *Operation_Diff) String() string

func (*Operation_Diff) Unmarshal

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

func (*Operation_Diff) VerboseEqual

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

type Operation_Expunge

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

Describes an "expunge" operation.

func NewPopulatedOperation_Expunge

func NewPopulatedOperation_Expunge(r randyState, easy bool) *Operation_Expunge

func (*Operation_Expunge) Equal

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

func (*Operation_Expunge) GetName

func (m *Operation_Expunge) GetName() string

func (*Operation_Expunge) GoString

func (this *Operation_Expunge) GoString() string

func (*Operation_Expunge) Marshal

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

func (*Operation_Expunge) MarshalTo

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

func (*Operation_Expunge) ProtoMessage

func (*Operation_Expunge) ProtoMessage()

func (*Operation_Expunge) Reset

func (m *Operation_Expunge) Reset()

func (*Operation_Expunge) Size

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

func (*Operation_Expunge) String

func (this *Operation_Expunge) String() string

func (*Operation_Expunge) Unmarshal

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

func (*Operation_Expunge) VerboseEqual

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

type Operation_Snapshot

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

Describes a "snapshot" operation.

func NewPopulatedOperation_Snapshot

func NewPopulatedOperation_Snapshot(r randyState, easy bool) *Operation_Snapshot

func (*Operation_Snapshot) Equal

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

func (*Operation_Snapshot) GetEntry

func (m *Operation_Snapshot) GetEntry() *Entry

func (*Operation_Snapshot) GoString

func (this *Operation_Snapshot) GoString() string

func (*Operation_Snapshot) Marshal

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

func (*Operation_Snapshot) MarshalTo

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

func (*Operation_Snapshot) ProtoMessage

func (*Operation_Snapshot) ProtoMessage()

func (*Operation_Snapshot) Reset

func (m *Operation_Snapshot) Reset()

func (*Operation_Snapshot) Size

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

func (*Operation_Snapshot) String

func (this *Operation_Snapshot) String() string

func (*Operation_Snapshot) Unmarshal

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

func (*Operation_Snapshot) VerboseEqual

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

type Operation_Type

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

func (Operation_Type) Enum

func (x Operation_Type) Enum() *Operation_Type

func (Operation_Type) String

func (x Operation_Type) String() string

func (*Operation_Type) UnmarshalJSON

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

type Parameter

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

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

func NewPopulatedParameter

func NewPopulatedParameter(r randyMesos, easy bool) *Parameter

func (*Parameter) Equal

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

func (*Parameter) GetKey

func (m *Parameter) GetKey() string

func (*Parameter) GetValue

func (m *Parameter) GetValue() string

func (*Parameter) GoString

func (this *Parameter) GoString() string

func (*Parameter) Marshal

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

func (*Parameter) MarshalTo

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

func (*Parameter) ProtoMessage

func (*Parameter) ProtoMessage()

func (*Parameter) Reset

func (m *Parameter) Reset()

func (*Parameter) Size

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

func (*Parameter) String

func (this *Parameter) String() string

func (*Parameter) Unmarshal

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

func (*Parameter) VerboseEqual

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

type Parameters

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

* Collection of Parameter.

func NewPopulatedParameters

func NewPopulatedParameters(r randyMesos, easy bool) *Parameters

func (*Parameters) Equal

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

func (*Parameters) GetParameter

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

func (*Parameters) GoString

func (this *Parameters) GoString() string

func (*Parameters) Marshal

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

func (*Parameters) MarshalTo

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

func (*Parameters) ProtoMessage

func (*Parameters) ProtoMessage()

func (*Parameters) Reset

func (m *Parameters) Reset()

func (*Parameters) Size

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

func (*Parameters) String

func (this *Parameters) String() string

func (*Parameters) Unmarshal

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

func (*Parameters) VerboseEqual

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

type PerfStatistics

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

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

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

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

func NewPopulatedPerfStatistics

func NewPopulatedPerfStatistics(r randyMesos, easy bool) *PerfStatistics

func (*PerfStatistics) Equal

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

func (*PerfStatistics) GetAlignmentFaults

func (m *PerfStatistics) GetAlignmentFaults() uint64

func (*PerfStatistics) GetBranchLoadMisses

func (m *PerfStatistics) GetBranchLoadMisses() uint64

func (*PerfStatistics) GetBranchLoads

func (m *PerfStatistics) GetBranchLoads() uint64

func (*PerfStatistics) GetBranchMisses

func (m *PerfStatistics) GetBranchMisses() uint64

func (*PerfStatistics) GetBranches

func (m *PerfStatistics) GetBranches() uint64

func (*PerfStatistics) GetBusCycles

func (m *PerfStatistics) GetBusCycles() uint64

func (*PerfStatistics) GetCacheMisses

func (m *PerfStatistics) GetCacheMisses() uint64

func (*PerfStatistics) GetCacheReferences

func (m *PerfStatistics) GetCacheReferences() uint64

func (*PerfStatistics) GetContextSwitches

func (m *PerfStatistics) GetContextSwitches() uint64

func (*PerfStatistics) GetCpuClock

func (m *PerfStatistics) GetCpuClock() float64

func (*PerfStatistics) GetCpuMigrations

func (m *PerfStatistics) GetCpuMigrations() uint64

func (*PerfStatistics) GetCycles

func (m *PerfStatistics) GetCycles() uint64

func (*PerfStatistics) GetDtlbLoadMisses

func (m *PerfStatistics) GetDtlbLoadMisses() uint64

func (*PerfStatistics) GetDtlbLoads

func (m *PerfStatistics) GetDtlbLoads() uint64

func (*PerfStatistics) GetDtlbPrefetchMisses

func (m *PerfStatistics) GetDtlbPrefetchMisses() uint64

func (*PerfStatistics) GetDtlbPrefetches

func (m *PerfStatistics) GetDtlbPrefetches() uint64

func (*PerfStatistics) GetDtlbStoreMisses

func (m *PerfStatistics) GetDtlbStoreMisses() uint64

func (*PerfStatistics) GetDtlbStores

func (m *PerfStatistics) GetDtlbStores() uint64

func (*PerfStatistics) GetDuration

func (m *PerfStatistics) GetDuration() float64

func (*PerfStatistics) GetEmulationFaults

func (m *PerfStatistics) GetEmulationFaults() uint64

func (*PerfStatistics) GetInstructions

func (m *PerfStatistics) GetInstructions() uint64

func (*PerfStatistics) GetItlbLoadMisses

func (m *PerfStatistics) GetItlbLoadMisses() uint64

func (*PerfStatistics) GetItlbLoads

func (m *PerfStatistics) GetItlbLoads() uint64

func (*PerfStatistics) GetL1DcacheLoadMisses

func (m *PerfStatistics) GetL1DcacheLoadMisses() uint64

func (*PerfStatistics) GetL1DcacheLoads

func (m *PerfStatistics) GetL1DcacheLoads() uint64

func (*PerfStatistics) GetL1DcachePrefetchMisses

func (m *PerfStatistics) GetL1DcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1DcachePrefetches

func (m *PerfStatistics) GetL1DcachePrefetches() uint64

func (*PerfStatistics) GetL1DcacheStoreMisses

func (m *PerfStatistics) GetL1DcacheStoreMisses() uint64

func (*PerfStatistics) GetL1DcacheStores

func (m *PerfStatistics) GetL1DcacheStores() uint64

func (*PerfStatistics) GetL1IcacheLoadMisses

func (m *PerfStatistics) GetL1IcacheLoadMisses() uint64

func (*PerfStatistics) GetL1IcacheLoads

func (m *PerfStatistics) GetL1IcacheLoads() uint64

func (*PerfStatistics) GetL1IcachePrefetchMisses

func (m *PerfStatistics) GetL1IcachePrefetchMisses() uint64

func (*PerfStatistics) GetL1IcachePrefetches

func (m *PerfStatistics) GetL1IcachePrefetches() uint64

func (*PerfStatistics) GetLlcLoadMisses

func (m *PerfStatistics) GetLlcLoadMisses() uint64

func (*PerfStatistics) GetLlcLoads

func (m *PerfStatistics) GetLlcLoads() uint64

func (*PerfStatistics) GetLlcPrefetchMisses

func (m *PerfStatistics) GetLlcPrefetchMisses() uint64

func (*PerfStatistics) GetLlcPrefetches

func (m *PerfStatistics) GetLlcPrefetches() uint64

func (*PerfStatistics) GetLlcStoreMisses

func (m *PerfStatistics) GetLlcStoreMisses() uint64

func (*PerfStatistics) GetLlcStores

func (m *PerfStatistics) GetLlcStores() uint64

func (*PerfStatistics) GetMajorFaults

func (m *PerfStatistics) GetMajorFaults() uint64

func (*PerfStatistics) GetMinorFaults

func (m *PerfStatistics) GetMinorFaults() uint64

func (*PerfStatistics) GetNodeLoadMisses

func (m *PerfStatistics) GetNodeLoadMisses() uint64

func (*PerfStatistics) GetNodeLoads

func (m *PerfStatistics) GetNodeLoads() uint64

func (*PerfStatistics) GetNodePrefetchMisses

func (m *PerfStatistics) GetNodePrefetchMisses() uint64

func (*PerfStatistics) GetNodePrefetches

func (m *PerfStatistics) GetNodePrefetches() uint64

func (*PerfStatistics) GetNodeStoreMisses

func (m *PerfStatistics) GetNodeStoreMisses() uint64

func (*PerfStatistics) GetNodeStores

func (m *PerfStatistics) GetNodeStores() uint64

func (*PerfStatistics) GetPageFaults

func (m *PerfStatistics) GetPageFaults() uint64

func (*PerfStatistics) GetRefCycles

func (m *PerfStatistics) GetRefCycles() uint64

func (*PerfStatistics) GetStalledCyclesBackend

func (m *PerfStatistics) GetStalledCyclesBackend() uint64

func (*PerfStatistics) GetStalledCyclesFrontend

func (m *PerfStatistics) GetStalledCyclesFrontend() uint64

func (*PerfStatistics) GetTaskClock

func (m *PerfStatistics) GetTaskClock() float64

func (*PerfStatistics) GetTimestamp

func (m *PerfStatistics) GetTimestamp() float64

func (*PerfStatistics) GoString

func (this *PerfStatistics) GoString() string

func (*PerfStatistics) Marshal

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

func (*PerfStatistics) MarshalTo

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

func (*PerfStatistics) ProtoMessage

func (*PerfStatistics) ProtoMessage()

func (*PerfStatistics) Reset

func (m *PerfStatistics) Reset()

func (*PerfStatistics) Size

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

func (*PerfStatistics) String

func (this *PerfStatistics) String() string

func (*PerfStatistics) Unmarshal

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

func (*PerfStatistics) VerboseEqual

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

type PingSlaveMessage

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

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

func (*PingSlaveMessage) GetConnected

func (m *PingSlaveMessage) GetConnected() bool

func (*PingSlaveMessage) ProtoMessage

func (*PingSlaveMessage) ProtoMessage()

func (*PingSlaveMessage) Reset

func (m *PingSlaveMessage) Reset()

func (*PingSlaveMessage) String

func (m *PingSlaveMessage) String() string

type PongSlaveMessage

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

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

func (*PongSlaveMessage) ProtoMessage

func (*PongSlaveMessage) ProtoMessage()

func (*PongSlaveMessage) Reset

func (m *PongSlaveMessage) Reset()

func (*PongSlaveMessage) String

func (m *PongSlaveMessage) String() string

type Promise

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

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

func NewPopulatedPromise

func NewPopulatedPromise(r randyLog, easy bool) *Promise

func (*Promise) Equal

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

func (*Promise) GetProposal

func (m *Promise) GetProposal() uint64

func (*Promise) GoString

func (this *Promise) GoString() string

func (*Promise) Marshal

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

func (*Promise) MarshalTo

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

func (*Promise) ProtoMessage

func (*Promise) ProtoMessage()

func (*Promise) Reset

func (m *Promise) Reset()

func (*Promise) Size

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

func (*Promise) String

func (this *Promise) String() string

func (*Promise) Unmarshal

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

func (*Promise) VerboseEqual

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

type PromiseRequest

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

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

func NewPopulatedPromiseRequest

func NewPopulatedPromiseRequest(r randyLog, easy bool) *PromiseRequest

func (*PromiseRequest) Equal

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

func (*PromiseRequest) GetPosition

func (m *PromiseRequest) GetPosition() uint64

func (*PromiseRequest) GetProposal

func (m *PromiseRequest) GetProposal() uint64

func (*PromiseRequest) GoString

func (this *PromiseRequest) GoString() string

func (*PromiseRequest) Marshal

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

func (*PromiseRequest) MarshalTo

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

func (*PromiseRequest) ProtoMessage

func (*PromiseRequest) ProtoMessage()

func (*PromiseRequest) Reset

func (m *PromiseRequest) Reset()

func (*PromiseRequest) Size

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

func (*PromiseRequest) String

func (this *PromiseRequest) String() string

func (*PromiseRequest) Unmarshal

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

func (*PromiseRequest) VerboseEqual

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

type PromiseResponse

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

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

func NewPopulatedPromiseResponse

func NewPopulatedPromiseResponse(r randyLog, easy bool) *PromiseResponse

func (*PromiseResponse) Equal

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

func (*PromiseResponse) GetAction

func (m *PromiseResponse) GetAction() *Action

func (*PromiseResponse) GetOkay

func (m *PromiseResponse) GetOkay() bool

func (*PromiseResponse) GetPosition

func (m *PromiseResponse) GetPosition() uint64

func (*PromiseResponse) GetProposal

func (m *PromiseResponse) GetProposal() uint64

func (*PromiseResponse) GoString

func (this *PromiseResponse) GoString() string

func (*PromiseResponse) Marshal

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

func (*PromiseResponse) MarshalTo

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

func (*PromiseResponse) ProtoMessage

func (*PromiseResponse) ProtoMessage()

func (*PromiseResponse) Reset

func (m *PromiseResponse) Reset()

func (*PromiseResponse) Size

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

func (*PromiseResponse) String

func (this *PromiseResponse) String() string

func (*PromiseResponse) Unmarshal

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

func (*PromiseResponse) VerboseEqual

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

type RateLimit

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

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

func NewPopulatedRateLimit

func NewPopulatedRateLimit(r randyMesos, easy bool) *RateLimit

func (*RateLimit) Equal

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

func (*RateLimit) GetCapacity

func (m *RateLimit) GetCapacity() uint64

func (*RateLimit) GetPrincipal

func (m *RateLimit) GetPrincipal() string

func (*RateLimit) GetQps

func (m *RateLimit) GetQps() float64

func (*RateLimit) GoString

func (this *RateLimit) GoString() string

func (*RateLimit) Marshal

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

func (*RateLimit) MarshalTo

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

func (*RateLimit) ProtoMessage

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset

func (m *RateLimit) Reset()

func (*RateLimit) Size

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

func (*RateLimit) String

func (this *RateLimit) String() string

func (*RateLimit) Unmarshal

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

func (*RateLimit) VerboseEqual

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

type RateLimits

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

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

func NewPopulatedRateLimits

func NewPopulatedRateLimits(r randyMesos, easy bool) *RateLimits

func (*RateLimits) Equal

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

func (*RateLimits) GetAggregateDefaultCapacity

func (m *RateLimits) GetAggregateDefaultCapacity() uint64

func (*RateLimits) GetAggregateDefaultQps

func (m *RateLimits) GetAggregateDefaultQps() float64

func (*RateLimits) GetLimits

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

func (*RateLimits) GoString

func (this *RateLimits) GoString() string

func (*RateLimits) Marshal

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

func (*RateLimits) MarshalTo

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

func (*RateLimits) ProtoMessage

func (*RateLimits) ProtoMessage()

func (*RateLimits) Reset

func (m *RateLimits) Reset()

func (*RateLimits) Size

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

func (*RateLimits) String

func (this *RateLimits) String() string

func (*RateLimits) Unmarshal

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

func (*RateLimits) VerboseEqual

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

type ReconcileTasksMessage

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

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

func (*ReconcileTasksMessage) GetFrameworkId

func (m *ReconcileTasksMessage) GetFrameworkId() *FrameworkID

func (*ReconcileTasksMessage) GetStatuses

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

func (*ReconcileTasksMessage) ProtoMessage

func (*ReconcileTasksMessage) ProtoMessage()

func (*ReconcileTasksMessage) Reset

func (m *ReconcileTasksMessage) Reset()

func (*ReconcileTasksMessage) String

func (m *ReconcileTasksMessage) String() string

type ReconnectExecutorMessage

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

func (*ReconnectExecutorMessage) GetSlaveId

func (m *ReconnectExecutorMessage) GetSlaveId() *SlaveID

func (*ReconnectExecutorMessage) ProtoMessage

func (*ReconnectExecutorMessage) ProtoMessage()

func (*ReconnectExecutorMessage) Reset

func (m *ReconnectExecutorMessage) Reset()

func (*ReconnectExecutorMessage) String

func (m *ReconnectExecutorMessage) String() string

type Record

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

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

func NewPopulatedRecord

func NewPopulatedRecord(r randyLog, easy bool) *Record

func (*Record) Equal

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

func (*Record) GetAction

func (m *Record) GetAction() *Action

func (*Record) GetMetadata

func (m *Record) GetMetadata() *Metadata

func (*Record) GetPromise

func (m *Record) GetPromise() *Promise

func (*Record) GetType

func (m *Record) GetType() Record_Type

func (*Record) GoString

func (this *Record) GoString() string

func (*Record) Marshal

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

func (*Record) MarshalTo

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

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) Reset

func (m *Record) Reset()

func (*Record) Size

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

func (*Record) String

func (this *Record) String() string

func (*Record) Unmarshal

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

func (*Record) VerboseEqual

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

type Record_Type

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

func (Record_Type) Enum

func (x Record_Type) Enum() *Record_Type

func (Record_Type) String

func (x Record_Type) String() string

func (*Record_Type) UnmarshalJSON

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

type RecoverRequest

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

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

func NewPopulatedRecoverRequest

func NewPopulatedRecoverRequest(r randyLog, easy bool) *RecoverRequest

func (*RecoverRequest) Equal

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

func (*RecoverRequest) GoString

func (this *RecoverRequest) GoString() string

func (*RecoverRequest) Marshal

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

func (*RecoverRequest) MarshalTo

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

func (*RecoverRequest) ProtoMessage

func (*RecoverRequest) ProtoMessage()

func (*RecoverRequest) Reset

func (m *RecoverRequest) Reset()

func (*RecoverRequest) Size

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

func (*RecoverRequest) String

func (this *RecoverRequest) String() string

func (*RecoverRequest) Unmarshal

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

func (*RecoverRequest) VerboseEqual

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

type RecoverResponse

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

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

func NewPopulatedRecoverResponse

func NewPopulatedRecoverResponse(r randyLog, easy bool) *RecoverResponse

func (*RecoverResponse) Equal

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

func (*RecoverResponse) GetBegin

func (m *RecoverResponse) GetBegin() uint64

func (*RecoverResponse) GetEnd

func (m *RecoverResponse) GetEnd() uint64

func (*RecoverResponse) GetStatus

func (m *RecoverResponse) GetStatus() Metadata_Status

func (*RecoverResponse) GoString

func (this *RecoverResponse) GoString() string

func (*RecoverResponse) Marshal

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

func (*RecoverResponse) MarshalTo

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

func (*RecoverResponse) ProtoMessage

func (*RecoverResponse) ProtoMessage()

func (*RecoverResponse) Reset

func (m *RecoverResponse) Reset()

func (*RecoverResponse) Size

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

func (*RecoverResponse) String

func (this *RecoverResponse) String() string

func (*RecoverResponse) Unmarshal

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

func (*RecoverResponse) VerboseEqual

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

type RegisterExecutorMessage

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

func (*RegisterExecutorMessage) GetExecutorId

func (m *RegisterExecutorMessage) GetExecutorId() *ExecutorID

func (*RegisterExecutorMessage) GetFrameworkId

func (m *RegisterExecutorMessage) GetFrameworkId() *FrameworkID

func (*RegisterExecutorMessage) ProtoMessage

func (*RegisterExecutorMessage) ProtoMessage()

func (*RegisterExecutorMessage) Reset

func (m *RegisterExecutorMessage) Reset()

func (*RegisterExecutorMessage) String

func (m *RegisterExecutorMessage) String() string

type RegisterFrameworkMessage

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

func (*RegisterFrameworkMessage) GetFramework

func (m *RegisterFrameworkMessage) GetFramework() *FrameworkInfo

func (*RegisterFrameworkMessage) ProtoMessage

func (*RegisterFrameworkMessage) ProtoMessage()

func (*RegisterFrameworkMessage) Reset

func (m *RegisterFrameworkMessage) Reset()

func (*RegisterFrameworkMessage) String

func (m *RegisterFrameworkMessage) String() string

type RegisterSlaveMessage

type RegisterSlaveMessage struct {
	Slave *SlaveInfo `protobuf:"bytes,1,req,name=slave" json:"slave,omitempty"`
	// NOTE: This is a hack for the master to detect the slave's
	// version. If unset the slave is < 0.21.0.
	// TODO(bmahler): Do proper versioning: MESOS-986.
	Version          *string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RegisterSlaveMessage) GetSlave

func (m *RegisterSlaveMessage) GetSlave() *SlaveInfo

func (*RegisterSlaveMessage) GetVersion

func (m *RegisterSlaveMessage) GetVersion() string

func (*RegisterSlaveMessage) ProtoMessage

func (*RegisterSlaveMessage) ProtoMessage()

func (*RegisterSlaveMessage) Reset

func (m *RegisterSlaveMessage) Reset()

func (*RegisterSlaveMessage) String

func (m *RegisterSlaveMessage) String() string

type Registry

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

func (*Registry) GetMaster

func (m *Registry) GetMaster() *Registry_Master

func (*Registry) GetSlaves

func (m *Registry) GetSlaves() *Registry_Slaves

func (*Registry) ProtoMessage

func (*Registry) ProtoMessage()

func (*Registry) Reset

func (m *Registry) Reset()

func (*Registry) String

func (m *Registry) String() string

type Registry_Master

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

func (*Registry_Master) GetInfo

func (m *Registry_Master) GetInfo() *MasterInfo

func (*Registry_Master) ProtoMessage

func (*Registry_Master) ProtoMessage()

func (*Registry_Master) Reset

func (m *Registry_Master) Reset()

func (*Registry_Master) String

func (m *Registry_Master) String() string

type Registry_Slave

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

func (*Registry_Slave) GetInfo

func (m *Registry_Slave) GetInfo() *SlaveInfo

func (*Registry_Slave) ProtoMessage

func (*Registry_Slave) ProtoMessage()

func (*Registry_Slave) Reset

func (m *Registry_Slave) Reset()

func (*Registry_Slave) String

func (m *Registry_Slave) String() string

type Registry_Slaves

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

func (*Registry_Slaves) GetSlaves

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

func (*Registry_Slaves) ProtoMessage

func (*Registry_Slaves) ProtoMessage()

func (*Registry_Slaves) Reset

func (m *Registry_Slaves) Reset()

func (*Registry_Slaves) String

func (m *Registry_Slaves) String() string

type Request

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

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

func NewPopulatedRequest

func NewPopulatedRequest(r randyMesos, easy bool) *Request

func (*Request) Equal

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

func (*Request) GetResources

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

func (*Request) GetSlaveId

func (m *Request) GetSlaveId() *SlaveID

func (*Request) GoString

func (this *Request) GoString() string

func (*Request) Marshal

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

func (*Request) MarshalTo

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (this *Request) String() string

func (*Request) Unmarshal

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

func (*Request) VerboseEqual

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

type ReregisterExecutorMessage

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

func (*ReregisterExecutorMessage) GetExecutorId

func (m *ReregisterExecutorMessage) GetExecutorId() *ExecutorID

func (*ReregisterExecutorMessage) GetFrameworkId

func (m *ReregisterExecutorMessage) GetFrameworkId() *FrameworkID

func (*ReregisterExecutorMessage) GetTasks

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

func (*ReregisterExecutorMessage) GetUpdates

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

func (*ReregisterExecutorMessage) ProtoMessage

func (*ReregisterExecutorMessage) ProtoMessage()

func (*ReregisterExecutorMessage) Reset

func (m *ReregisterExecutorMessage) Reset()

func (*ReregisterExecutorMessage) String

func (m *ReregisterExecutorMessage) String() string

type ReregisterFrameworkMessage

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

func (*ReregisterFrameworkMessage) GetFailover

func (m *ReregisterFrameworkMessage) GetFailover() bool

func (*ReregisterFrameworkMessage) GetFramework

func (m *ReregisterFrameworkMessage) GetFramework() *FrameworkInfo

func (*ReregisterFrameworkMessage) ProtoMessage

func (*ReregisterFrameworkMessage) ProtoMessage()

func (*ReregisterFrameworkMessage) Reset

func (m *ReregisterFrameworkMessage) Reset()

func (*ReregisterFrameworkMessage) String

func (m *ReregisterFrameworkMessage) String() string

type ReregisterSlaveMessage

type ReregisterSlaveMessage struct {
	// TODO(bmahler): slave_id is deprecated.
	// 0.21.0: Now an optional field. Always written, never read.
	// 0.22.0: Remove this field.
	SlaveId             *SlaveID             `protobuf:"bytes,1,opt,name=slave_id" json:"slave_id,omitempty"`
	Slave               *SlaveInfo           `protobuf:"bytes,2,req,name=slave" json:"slave,omitempty"`
	ExecutorInfos       []*ExecutorInfo      `protobuf:"bytes,4,rep,name=executor_infos" json:"executor_infos,omitempty"`
	Tasks               []*Task              `protobuf:"bytes,3,rep,name=tasks" json:"tasks,omitempty"`
	CompletedFrameworks []*Archive_Framework `protobuf:"bytes,5,rep,name=completed_frameworks" json:"completed_frameworks,omitempty"`
	// NOTE: This is a hack for the master to detect the slave's
	// version. If unset the slave is < 0.21.0.
	// TODO(bmahler): Do proper versioning: MESOS-986.
	Version          *string `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReregisterSlaveMessage) GetCompletedFrameworks

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

func (*ReregisterSlaveMessage) GetExecutorInfos

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

func (*ReregisterSlaveMessage) GetSlave

func (m *ReregisterSlaveMessage) GetSlave() *SlaveInfo

func (*ReregisterSlaveMessage) GetSlaveId

func (m *ReregisterSlaveMessage) GetSlaveId() *SlaveID

func (*ReregisterSlaveMessage) GetTasks

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

func (*ReregisterSlaveMessage) GetVersion

func (m *ReregisterSlaveMessage) GetVersion() string

func (*ReregisterSlaveMessage) ProtoMessage

func (*ReregisterSlaveMessage) ProtoMessage()

func (*ReregisterSlaveMessage) Reset

func (m *ReregisterSlaveMessage) Reset()

func (*ReregisterSlaveMessage) String

func (m *ReregisterSlaveMessage) String() string

type RescindResourceOfferMessage

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

func (*RescindResourceOfferMessage) GetOfferId

func (m *RescindResourceOfferMessage) GetOfferId() *OfferID

func (*RescindResourceOfferMessage) ProtoMessage

func (*RescindResourceOfferMessage) ProtoMessage()

func (*RescindResourceOfferMessage) Reset

func (m *RescindResourceOfferMessage) Reset()

func (*RescindResourceOfferMessage) String

func (m *RescindResourceOfferMessage) String() string

type Resource

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

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

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

func NewPopulatedResource

func NewPopulatedResource(r randyMesos, easy bool) *Resource

func (*Resource) Equal

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

func (*Resource) GetName

func (m *Resource) GetName() string

func (*Resource) GetRanges

func (m *Resource) GetRanges() *Value_Ranges

func (*Resource) GetRole

func (m *Resource) GetRole() string

func (*Resource) GetScalar

func (m *Resource) GetScalar() *Value_Scalar

func (*Resource) GetSet

func (m *Resource) GetSet() *Value_Set

func (*Resource) GetType

func (m *Resource) GetType() Value_Type

func (*Resource) GoString

func (this *Resource) GoString() string

func (*Resource) Marshal

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

func (*Resource) MarshalTo

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

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) Reset

func (m *Resource) Reset()

func (*Resource) Size

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

func (*Resource) String

func (this *Resource) String() string

func (*Resource) Unmarshal

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

func (*Resource) VerboseEqual

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

type ResourceOffersMessage

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

func (*ResourceOffersMessage) GetOffers

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

func (*ResourceOffersMessage) GetPids

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

func (*ResourceOffersMessage) ProtoMessage

func (*ResourceOffersMessage) ProtoMessage()

func (*ResourceOffersMessage) Reset

func (m *ResourceOffersMessage) Reset()

func (*ResourceOffersMessage) String

func (m *ResourceOffersMessage) String() string

type ResourceRequestMessage

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

func (*ResourceRequestMessage) GetFrameworkId

func (m *ResourceRequestMessage) GetFrameworkId() *FrameworkID

func (*ResourceRequestMessage) GetRequests

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

func (*ResourceRequestMessage) ProtoMessage

func (*ResourceRequestMessage) ProtoMessage()

func (*ResourceRequestMessage) Reset

func (m *ResourceRequestMessage) Reset()

func (*ResourceRequestMessage) String

func (m *ResourceRequestMessage) String() string

type ResourceStatistics

type ResourceStatistics struct {
	Timestamp *float64 `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	// CPU Usage Information:
	// Total CPU time spent in user mode, and kernel mode.
	CpusUserTimeSecs   *float64 `protobuf:"fixed64,2,opt,name=cpus_user_time_secs" json:"cpus_user_time_secs,omitempty"`
	CpusSystemTimeSecs *float64 `protobuf:"fixed64,3,opt,name=cpus_system_time_secs" json:"cpus_system_time_secs,omitempty"`
	// Number of CPUs allocated.
	CpusLimit *float64 `protobuf:"fixed64,4,opt,name=cpus_limit" json:"cpus_limit,omitempty"`
	// cpu.stat on process throttling (for contention issues).
	CpusNrPeriods         *uint32  `protobuf:"varint,7,opt,name=cpus_nr_periods" json:"cpus_nr_periods,omitempty"`
	CpusNrThrottled       *uint32  `protobuf:"varint,8,opt,name=cpus_nr_throttled" json:"cpus_nr_throttled,omitempty"`
	CpusThrottledTimeSecs *float64 `protobuf:"fixed64,9,opt,name=cpus_throttled_time_secs" json:"cpus_throttled_time_secs,omitempty"`
	// Memory Usage Information:
	MemRssBytes *uint64 `protobuf:"varint,5,opt,name=mem_rss_bytes" json:"mem_rss_bytes,omitempty"`
	// Amount of memory resources allocated.
	MemLimitBytes *uint64 `protobuf:"varint,6,opt,name=mem_limit_bytes" json:"mem_limit_bytes,omitempty"`
	// Broken out memory usage information (files, anonymous, and mmaped files)
	MemFileBytes       *uint64 `protobuf:"varint,10,opt,name=mem_file_bytes" json:"mem_file_bytes,omitempty"`
	MemAnonBytes       *uint64 `protobuf:"varint,11,opt,name=mem_anon_bytes" json:"mem_anon_bytes,omitempty"`
	MemMappedFileBytes *uint64 `protobuf:"varint,12,opt,name=mem_mapped_file_bytes" json:"mem_mapped_file_bytes,omitempty"`
	// Perf statistics.
	Perf *PerfStatistics `protobuf:"bytes,13,opt,name=perf" json:"perf,omitempty"`
	// Network Usage Information:
	NetRxPackets *uint64 `protobuf:"varint,14,opt,name=net_rx_packets" json:"net_rx_packets,omitempty"`
	NetRxBytes   *uint64 `protobuf:"varint,15,opt,name=net_rx_bytes" json:"net_rx_bytes,omitempty"`
	NetRxErrors  *uint64 `protobuf:"varint,16,opt,name=net_rx_errors" json:"net_rx_errors,omitempty"`
	NetRxDropped *uint64 `protobuf:"varint,17,opt,name=net_rx_dropped" json:"net_rx_dropped,omitempty"`
	NetTxPackets *uint64 `protobuf:"varint,18,opt,name=net_tx_packets" json:"net_tx_packets,omitempty"`
	NetTxBytes   *uint64 `protobuf:"varint,19,opt,name=net_tx_bytes" json:"net_tx_bytes,omitempty"`
	NetTxErrors  *uint64 `protobuf:"varint,20,opt,name=net_tx_errors" json:"net_tx_errors,omitempty"`
	NetTxDropped *uint64 `protobuf:"varint,21,opt,name=net_tx_dropped" json:"net_tx_dropped,omitempty"`
	// The kernel keeps track of RTT (round-trip time) for its TCP
	// sockets. RTT is a way to tell the latency of a container.
	NetTcpRttMicrosecsP50 *float64 `protobuf:"fixed64,22,opt,name=net_tcp_rtt_microsecs_p50" json:"net_tcp_rtt_microsecs_p50,omitempty"`
	NetTcpRttMicrosecsP90 *float64 `protobuf:"fixed64,23,opt,name=net_tcp_rtt_microsecs_p90" json:"net_tcp_rtt_microsecs_p90,omitempty"`
	NetTcpRttMicrosecsP95 *float64 `protobuf:"fixed64,24,opt,name=net_tcp_rtt_microsecs_p95" json:"net_tcp_rtt_microsecs_p95,omitempty"`
	NetTcpRttMicrosecsP99 *float64 `protobuf:"fixed64,25,opt,name=net_tcp_rtt_microsecs_p99" json:"net_tcp_rtt_microsecs_p99,omitempty"`
	XXX_unrecognized      []byte   `json:"-"`
}

A snapshot of resource usage statistics.

func NewPopulatedResourceStatistics

func NewPopulatedResourceStatistics(r randyMesos, easy bool) *ResourceStatistics

func (*ResourceStatistics) Equal

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

func (*ResourceStatistics) GetCpusLimit

func (m *ResourceStatistics) GetCpusLimit() float64

func (*ResourceStatistics) GetCpusNrPeriods

func (m *ResourceStatistics) GetCpusNrPeriods() uint32

func (*ResourceStatistics) GetCpusNrThrottled

func (m *ResourceStatistics) GetCpusNrThrottled() uint32

func (*ResourceStatistics) GetCpusSystemTimeSecs

func (m *ResourceStatistics) GetCpusSystemTimeSecs() float64

func (*ResourceStatistics) GetCpusThrottledTimeSecs

func (m *ResourceStatistics) GetCpusThrottledTimeSecs() float64

func (*ResourceStatistics) GetCpusUserTimeSecs

func (m *ResourceStatistics) GetCpusUserTimeSecs() float64

func (*ResourceStatistics) GetMemAnonBytes

func (m *ResourceStatistics) GetMemAnonBytes() uint64

func (*ResourceStatistics) GetMemFileBytes

func (m *ResourceStatistics) GetMemFileBytes() uint64

func (*ResourceStatistics) GetMemLimitBytes

func (m *ResourceStatistics) GetMemLimitBytes() uint64

func (*ResourceStatistics) GetMemMappedFileBytes

func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

func (*ResourceStatistics) GetMemRssBytes

func (m *ResourceStatistics) GetMemRssBytes() uint64

func (*ResourceStatistics) GetNetRxBytes

func (m *ResourceStatistics) GetNetRxBytes() uint64

func (*ResourceStatistics) GetNetRxDropped

func (m *ResourceStatistics) GetNetRxDropped() uint64

func (*ResourceStatistics) GetNetRxErrors

func (m *ResourceStatistics) GetNetRxErrors() uint64

func (*ResourceStatistics) GetNetRxPackets

func (m *ResourceStatistics) GetNetRxPackets() uint64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP50

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP90

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP95

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP99

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

func (*ResourceStatistics) GetNetTxBytes

func (m *ResourceStatistics) GetNetTxBytes() uint64

func (*ResourceStatistics) GetNetTxDropped

func (m *ResourceStatistics) GetNetTxDropped() uint64

func (*ResourceStatistics) GetNetTxErrors

func (m *ResourceStatistics) GetNetTxErrors() uint64

func (*ResourceStatistics) GetNetTxPackets

func (m *ResourceStatistics) GetNetTxPackets() uint64

func (*ResourceStatistics) GetPerf

func (m *ResourceStatistics) GetPerf() *PerfStatistics

func (*ResourceStatistics) GetTimestamp

func (m *ResourceStatistics) GetTimestamp() float64

func (*ResourceStatistics) GoString

func (this *ResourceStatistics) GoString() string

func (*ResourceStatistics) Marshal

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

func (*ResourceStatistics) MarshalTo

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

func (*ResourceStatistics) ProtoMessage

func (*ResourceStatistics) ProtoMessage()

func (*ResourceStatistics) Reset

func (m *ResourceStatistics) Reset()

func (*ResourceStatistics) Size

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

func (*ResourceStatistics) String

func (this *ResourceStatistics) String() string

func (*ResourceStatistics) Unmarshal

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

func (*ResourceStatistics) VerboseEqual

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

type ResourceUsage

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

* Describes a snapshot of the resource usage for an executor.

TODO(bmahler): Note that we want to be sending this information to the master, and subsequently to the relevant scheduler. So this proto is designed to be easy for the scheduler to use, this is why we provide the slave id, executor info / task info.

func NewPopulatedResourceUsage

func NewPopulatedResourceUsage(r randyMesos, easy bool) *ResourceUsage

func (*ResourceUsage) Equal

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

func (*ResourceUsage) GetExecutorId

func (m *ResourceUsage) GetExecutorId() *ExecutorID

func (*ResourceUsage) GetExecutorName

func (m *ResourceUsage) GetExecutorName() string

func (*ResourceUsage) GetFrameworkId

func (m *ResourceUsage) GetFrameworkId() *FrameworkID

func (*ResourceUsage) GetSlaveId

func (m *ResourceUsage) GetSlaveId() *SlaveID

func (*ResourceUsage) GetStatistics

func (m *ResourceUsage) GetStatistics() *ResourceStatistics

func (*ResourceUsage) GetTaskId

func (m *ResourceUsage) GetTaskId() *TaskID

func (*ResourceUsage) GoString

func (this *ResourceUsage) GoString() string

func (*ResourceUsage) Marshal

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

func (*ResourceUsage) MarshalTo

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

func (*ResourceUsage) ProtoMessage

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset

func (m *ResourceUsage) Reset()

func (*ResourceUsage) Size

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

func (*ResourceUsage) String

func (this *ResourceUsage) String() string

func (*ResourceUsage) Unmarshal

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

func (*ResourceUsage) VerboseEqual

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

type ReviveOffersMessage

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

func (*ReviveOffersMessage) GetFrameworkId

func (m *ReviveOffersMessage) GetFrameworkId() *FrameworkID

func (*ReviveOffersMessage) ProtoMessage

func (*ReviveOffersMessage) ProtoMessage()

func (*ReviveOffersMessage) Reset

func (m *ReviveOffersMessage) Reset()

func (*ReviveOffersMessage) String

func (m *ReviveOffersMessage) String() string

type RoleInfo

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

Describes a role, which are used to group frameworks for allocation decisions, depending on the allocation policy being used. The weight field can be used to indicate forms of priority.

func (*RoleInfo) GetName

func (m *RoleInfo) GetName() string

func (*RoleInfo) GetWeight

func (m *RoleInfo) GetWeight() float64

func (*RoleInfo) ProtoMessage

func (*RoleInfo) ProtoMessage()

func (*RoleInfo) Reset

func (m *RoleInfo) Reset()

func (*RoleInfo) String

func (m *RoleInfo) String() string

type RunTaskMessage

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

func (*RunTaskMessage) GetFramework

func (m *RunTaskMessage) GetFramework() *FrameworkInfo

func (*RunTaskMessage) GetFrameworkId

func (m *RunTaskMessage) GetFrameworkId() *FrameworkID

func (*RunTaskMessage) GetPid

func (m *RunTaskMessage) GetPid() string

func (*RunTaskMessage) GetTask

func (m *RunTaskMessage) GetTask() *TaskInfo

func (*RunTaskMessage) ProtoMessage

func (*RunTaskMessage) ProtoMessage()

func (*RunTaskMessage) Reset

func (m *RunTaskMessage) Reset()

func (*RunTaskMessage) String

func (m *RunTaskMessage) String() string

type ShutdownExecutorMessage

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

Tells the executor to initiate a shut down by invoking Executor::shutdown.

func (*ShutdownExecutorMessage) ProtoMessage

func (*ShutdownExecutorMessage) ProtoMessage()

func (*ShutdownExecutorMessage) Reset

func (m *ShutdownExecutorMessage) Reset()

func (*ShutdownExecutorMessage) String

func (m *ShutdownExecutorMessage) String() string

type ShutdownFrameworkMessage

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

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

func (*ShutdownFrameworkMessage) GetFrameworkId

func (m *ShutdownFrameworkMessage) GetFrameworkId() *FrameworkID

func (*ShutdownFrameworkMessage) ProtoMessage

func (*ShutdownFrameworkMessage) ProtoMessage()

func (*ShutdownFrameworkMessage) Reset

func (m *ShutdownFrameworkMessage) Reset()

func (*ShutdownFrameworkMessage) String

func (m *ShutdownFrameworkMessage) String() string

type ShutdownMessage

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

func (*ShutdownMessage) GetMessage

func (m *ShutdownMessage) GetMessage() string

func (*ShutdownMessage) ProtoMessage

func (*ShutdownMessage) ProtoMessage()

func (*ShutdownMessage) Reset

func (m *ShutdownMessage) Reset()

func (*ShutdownMessage) String

func (m *ShutdownMessage) String() string

type SlaveID

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

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

func NewPopulatedSlaveID

func NewPopulatedSlaveID(r randyMesos, easy bool) *SlaveID

func (*SlaveID) Equal

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

func (*SlaveID) GetValue

func (m *SlaveID) GetValue() string

func (*SlaveID) GoString

func (this *SlaveID) GoString() string

func (*SlaveID) Marshal

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

func (*SlaveID) MarshalTo

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

func (*SlaveID) ProtoMessage

func (*SlaveID) ProtoMessage()

func (*SlaveID) Reset

func (m *SlaveID) Reset()

func (*SlaveID) Size

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

func (*SlaveID) String

func (this *SlaveID) String() string

func (*SlaveID) Unmarshal

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

func (*SlaveID) VerboseEqual

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

type SlaveInfo

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

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

func NewPopulatedSlaveInfo

func NewPopulatedSlaveInfo(r randyMesos, easy bool) *SlaveInfo

func (*SlaveInfo) Equal

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

func (*SlaveInfo) GetAttributes

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

func (*SlaveInfo) GetCheckpoint

func (m *SlaveInfo) GetCheckpoint() bool

func (*SlaveInfo) GetHostname

func (m *SlaveInfo) GetHostname() string

func (*SlaveInfo) GetId

func (m *SlaveInfo) GetId() *SlaveID

func (*SlaveInfo) GetPort

func (m *SlaveInfo) GetPort() int32

func (*SlaveInfo) GetResources

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

func (*SlaveInfo) GoString

func (this *SlaveInfo) GoString() string

func (*SlaveInfo) Marshal

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

func (*SlaveInfo) MarshalTo

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

func (*SlaveInfo) ProtoMessage

func (*SlaveInfo) ProtoMessage()

func (*SlaveInfo) Reset

func (m *SlaveInfo) Reset()

func (*SlaveInfo) Size

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

func (*SlaveInfo) String

func (this *SlaveInfo) String() string

func (*SlaveInfo) Unmarshal

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

func (*SlaveInfo) VerboseEqual

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

type SlaveRegisteredMessage

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

func (*SlaveRegisteredMessage) GetSlaveId

func (m *SlaveRegisteredMessage) GetSlaveId() *SlaveID

func (*SlaveRegisteredMessage) ProtoMessage

func (*SlaveRegisteredMessage) ProtoMessage()

func (*SlaveRegisteredMessage) Reset

func (m *SlaveRegisteredMessage) Reset()

func (*SlaveRegisteredMessage) String

func (m *SlaveRegisteredMessage) String() string

type SlaveReregisteredMessage

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

func (*SlaveReregisteredMessage) GetReconciliations

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

func (*SlaveReregisteredMessage) GetSlaveId

func (m *SlaveReregisteredMessage) GetSlaveId() *SlaveID

func (*SlaveReregisteredMessage) ProtoMessage

func (*SlaveReregisteredMessage) ProtoMessage()

func (*SlaveReregisteredMessage) Reset

func (m *SlaveReregisteredMessage) Reset()

func (*SlaveReregisteredMessage) String

func (m *SlaveReregisteredMessage) String() string

type Status

type Status int32

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

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

func (Status) Enum

func (x Status) Enum() *Status

func (Status) String

func (x Status) String() string

func (*Status) UnmarshalJSON

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

type StatusUpdate

type StatusUpdate struct {
	FrameworkId *FrameworkID `protobuf:"bytes,1,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId  *ExecutorID  `protobuf:"bytes,2,opt,name=executor_id" json:"executor_id,omitempty"`
	SlaveId     *SlaveID     `protobuf:"bytes,3,opt,name=slave_id" json:"slave_id,omitempty"`
	Status      *TaskStatus  `protobuf:"bytes,4,req,name=status" json:"status,omitempty"`
	Timestamp   *float64     `protobuf:"fixed64,5,req,name=timestamp" json:"timestamp,omitempty"`
	Uuid        []byte       `protobuf:"bytes,6,req,name=uuid" json:"uuid,omitempty"`
	// This corresponds to the latest state of the task according to the
	// slave. Note that this state might be different than the state in
	// 'status' because status update manager queues updates. In other
	// words, 'status' corresponds to the update at top of the queue and
	// 'latest_state' corresponds to the update at bottom of the queue.
	LatestState      *TaskState `protobuf:"varint,7,opt,name=latest_state,enum=mesosproto.TaskState" json:"latest_state,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

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

func (*StatusUpdate) GetExecutorId

func (m *StatusUpdate) GetExecutorId() *ExecutorID

func (*StatusUpdate) GetFrameworkId

func (m *StatusUpdate) GetFrameworkId() *FrameworkID

func (*StatusUpdate) GetLatestState

func (m *StatusUpdate) GetLatestState() TaskState

func (*StatusUpdate) GetSlaveId

func (m *StatusUpdate) GetSlaveId() *SlaveID

func (*StatusUpdate) GetStatus

func (m *StatusUpdate) GetStatus() *TaskStatus

func (*StatusUpdate) GetTimestamp

func (m *StatusUpdate) GetTimestamp() float64

func (*StatusUpdate) GetUuid

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

func (*StatusUpdate) ProtoMessage

func (*StatusUpdate) ProtoMessage()

func (*StatusUpdate) Reset

func (m *StatusUpdate) Reset()

func (*StatusUpdate) String

func (m *StatusUpdate) String() string

type StatusUpdateAcknowledgementMessage

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

func (*StatusUpdateAcknowledgementMessage) GetFrameworkId

func (m *StatusUpdateAcknowledgementMessage) GetFrameworkId() *FrameworkID

func (*StatusUpdateAcknowledgementMessage) GetSlaveId

func (*StatusUpdateAcknowledgementMessage) GetTaskId

func (*StatusUpdateAcknowledgementMessage) GetUuid

func (*StatusUpdateAcknowledgementMessage) ProtoMessage

func (*StatusUpdateAcknowledgementMessage) ProtoMessage()

func (*StatusUpdateAcknowledgementMessage) Reset

func (*StatusUpdateAcknowledgementMessage) String

type StatusUpdateMessage

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

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

func (*StatusUpdateMessage) GetPid

func (m *StatusUpdateMessage) GetPid() string

func (*StatusUpdateMessage) GetUpdate

func (m *StatusUpdateMessage) GetUpdate() *StatusUpdate

func (*StatusUpdateMessage) ProtoMessage

func (*StatusUpdateMessage) ProtoMessage()

func (*StatusUpdateMessage) Reset

func (m *StatusUpdateMessage) Reset()

func (*StatusUpdateMessage) String

func (m *StatusUpdateMessage) String() string

type StatusUpdateRecord

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

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

func (*StatusUpdateRecord) GetType

func (*StatusUpdateRecord) GetUpdate

func (m *StatusUpdateRecord) GetUpdate() *StatusUpdate

func (*StatusUpdateRecord) GetUuid

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

func (*StatusUpdateRecord) ProtoMessage

func (*StatusUpdateRecord) ProtoMessage()

func (*StatusUpdateRecord) Reset

func (m *StatusUpdateRecord) Reset()

func (*StatusUpdateRecord) String

func (m *StatusUpdateRecord) String() string

type StatusUpdateRecord_Type

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

func (StatusUpdateRecord_Type) Enum

func (StatusUpdateRecord_Type) String

func (x StatusUpdateRecord_Type) String() string

func (*StatusUpdateRecord_Type) UnmarshalJSON

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

type SubmitSchedulerRequest

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

func (*SubmitSchedulerRequest) GetName

func (m *SubmitSchedulerRequest) GetName() string

func (*SubmitSchedulerRequest) ProtoMessage

func (*SubmitSchedulerRequest) ProtoMessage()

func (*SubmitSchedulerRequest) Reset

func (m *SubmitSchedulerRequest) Reset()

func (*SubmitSchedulerRequest) String

func (m *SubmitSchedulerRequest) String() string

type SubmitSchedulerResponse

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

func (*SubmitSchedulerResponse) GetOkay

func (m *SubmitSchedulerResponse) GetOkay() bool

func (*SubmitSchedulerResponse) ProtoMessage

func (*SubmitSchedulerResponse) ProtoMessage()

func (*SubmitSchedulerResponse) Reset

func (m *SubmitSchedulerResponse) Reset()

func (*SubmitSchedulerResponse) String

func (m *SubmitSchedulerResponse) String() string

type Task

type Task struct {
	Name        *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId      *TaskID       `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	FrameworkId *FrameworkID  `protobuf:"bytes,3,req,name=framework_id" json:"framework_id,omitempty"`
	ExecutorId  *ExecutorID   `protobuf:"bytes,4,opt,name=executor_id" json:"executor_id,omitempty"`
	SlaveId     *SlaveID      `protobuf:"bytes,5,req,name=slave_id" json:"slave_id,omitempty"`
	State       *TaskState    `protobuf:"varint,6,req,name=state,enum=mesosproto.TaskState" json:"state,omitempty"`
	Resources   []*Resource   `protobuf:"bytes,7,rep,name=resources" json:"resources,omitempty"`
	Statuses    []*TaskStatus `protobuf:"bytes,8,rep,name=statuses" json:"statuses,omitempty"`
	// These fields correspond to the state and uuid of the latest
	// status update forwarded to the master.
	// NOTE: Either both the fields must be set or both must be unset.
	StatusUpdateState *TaskState `protobuf:"varint,9,opt,name=status_update_state,enum=mesosproto.TaskState" json:"status_update_state,omitempty"`
	StatusUpdateUuid  []byte     `protobuf:"bytes,10,opt,name=status_update_uuid" json:"status_update_uuid,omitempty"`
	XXX_unrecognized  []byte     `json:"-"`
}

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

func (*Task) GetExecutorId

func (m *Task) GetExecutorId() *ExecutorID

func (*Task) GetFrameworkId

func (m *Task) GetFrameworkId() *FrameworkID

func (*Task) GetName

func (m *Task) GetName() string

func (*Task) GetResources

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

func (*Task) GetSlaveId

func (m *Task) GetSlaveId() *SlaveID

func (*Task) GetState

func (m *Task) GetState() TaskState

func (*Task) GetStatusUpdateState

func (m *Task) GetStatusUpdateState() TaskState

func (*Task) GetStatusUpdateUuid

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

func (*Task) GetStatuses

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

func (*Task) GetTaskId

func (m *Task) GetTaskId() *TaskID

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

type TaskHealthStatus

type TaskHealthStatus struct {
	TaskId  *TaskID `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	Healthy *bool   `protobuf:"varint,2,req,name=healthy" json:"healthy,omitempty"`
	// Flag to initiate task kill.
	KillTask *bool `protobuf:"varint,3,opt,name=kill_task,def=0" json:"kill_task,omitempty"`
	// Number of consecutive counts in current status.
	// This will not be populated if task is healthy.
	ConsecutiveFailures *int32 `protobuf:"varint,4,opt,name=consecutive_failures" json:"consecutive_failures,omitempty"`
	XXX_unrecognized    []byte `json:"-"`
}

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

func (*TaskHealthStatus) GetConsecutiveFailures

func (m *TaskHealthStatus) GetConsecutiveFailures() int32

func (*TaskHealthStatus) GetHealthy

func (m *TaskHealthStatus) GetHealthy() bool

func (*TaskHealthStatus) GetKillTask

func (m *TaskHealthStatus) GetKillTask() bool

func (*TaskHealthStatus) GetTaskId

func (m *TaskHealthStatus) GetTaskId() *TaskID

func (*TaskHealthStatus) ProtoMessage

func (*TaskHealthStatus) ProtoMessage()

func (*TaskHealthStatus) Reset

func (m *TaskHealthStatus) Reset()

func (*TaskHealthStatus) String

func (m *TaskHealthStatus) String() string

type TaskID

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

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

func NewPopulatedTaskID

func NewPopulatedTaskID(r randyMesos, easy bool) *TaskID

func (*TaskID) Equal

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

func (*TaskID) GetValue

func (m *TaskID) GetValue() string

func (*TaskID) GoString

func (this *TaskID) GoString() string

func (*TaskID) Marshal

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

func (*TaskID) MarshalTo

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

func (*TaskID) ProtoMessage

func (*TaskID) ProtoMessage()

func (*TaskID) Reset

func (m *TaskID) Reset()

func (*TaskID) Size

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

func (*TaskID) String

func (this *TaskID) String() string

func (*TaskID) Unmarshal

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

func (*TaskID) VerboseEqual

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

type TaskInfo

type TaskInfo struct {
	Name      *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId    *TaskID       `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	SlaveId   *SlaveID      `protobuf:"bytes,3,req,name=slave_id" json:"slave_id,omitempty"`
	Resources []*Resource   `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"`
	Executor  *ExecutorInfo `protobuf:"bytes,5,opt,name=executor" json:"executor,omitempty"`
	Command   *CommandInfo  `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	// Task provided with a container will launch the container as part
	// of this task paired with the task's CommandInfo.
	Container *ContainerInfo `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	Data      []byte         `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	// A health check for the task (currently in *alpha* and initial
	// support will only be for TaskInfo's that have a CommandInfo).
	HealthCheck      *HealthCheck `protobuf:"bytes,8,opt,name=health_check" json:"health_check,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

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

func NewPopulatedTaskInfo

func NewPopulatedTaskInfo(r randyMesos, easy bool) *TaskInfo

func (*TaskInfo) Equal

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

func (*TaskInfo) GetCommand

func (m *TaskInfo) GetCommand() *CommandInfo

func (*TaskInfo) GetContainer

func (m *TaskInfo) GetContainer() *ContainerInfo

func (*TaskInfo) GetData

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

func (*TaskInfo) GetExecutor

func (m *TaskInfo) GetExecutor() *ExecutorInfo

func (*TaskInfo) GetHealthCheck

func (m *TaskInfo) GetHealthCheck() *HealthCheck

func (*TaskInfo) GetName

func (m *TaskInfo) GetName() string

func (*TaskInfo) GetResources

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

func (*TaskInfo) GetSlaveId

func (m *TaskInfo) GetSlaveId() *SlaveID

func (*TaskInfo) GetTaskId

func (m *TaskInfo) GetTaskId() *TaskID

func (*TaskInfo) GoString

func (this *TaskInfo) GoString() string

func (*TaskInfo) Marshal

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

func (*TaskInfo) MarshalTo

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

func (*TaskInfo) ProtoMessage

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset

func (m *TaskInfo) Reset()

func (*TaskInfo) Size

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

func (*TaskInfo) String

func (this *TaskInfo) String() string

func (*TaskInfo) Unmarshal

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

func (*TaskInfo) VerboseEqual

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

type TaskState

type TaskState int32

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

const (
	TaskState_TASK_STAGING  TaskState = 6
	TaskState_TASK_STARTING TaskState = 0
	TaskState_TASK_RUNNING  TaskState = 1
	TaskState_TASK_FINISHED TaskState = 2
	TaskState_TASK_FAILED   TaskState = 3
	TaskState_TASK_KILLED   TaskState = 4
	TaskState_TASK_LOST     TaskState = 5
	// TASK_ERROR is currently unused but will be introduced in 0.22.0.
	// TODO(dhamon): Start using TASK_ERROR.
	TaskState_TASK_ERROR TaskState = 7
)

func (TaskState) Enum

func (x TaskState) Enum() *TaskState

func (TaskState) String

func (x TaskState) String() string

func (*TaskState) UnmarshalJSON

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

type TaskStatus

type TaskStatus struct {
	TaskId     *TaskID            `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	State      *TaskState         `protobuf:"varint,2,req,name=state,enum=mesosproto.TaskState" json:"state,omitempty"`
	Message    *string            `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Source     *TaskStatus_Source `protobuf:"varint,9,opt,name=source,enum=mesosproto.TaskStatus_Source" json:"source,omitempty"`
	Reason     *TaskStatus_Reason `protobuf:"varint,10,opt,name=reason,enum=mesosproto.TaskStatus_Reason" json:"reason,omitempty"`
	Data       []byte             `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	SlaveId    *SlaveID           `protobuf:"bytes,5,opt,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId *ExecutorID        `protobuf:"bytes,7,opt,name=executor_id" json:"executor_id,omitempty"`
	Timestamp  *float64           `protobuf:"fixed64,6,opt,name=timestamp" json:"timestamp,omitempty"`
	// Describes whether the task has been determined to be healthy
	// (true) or unhealthy (false) according to the HealthCheck field in
	// the command info.
	Healthy          *bool  `protobuf:"varint,8,opt,name=healthy" json:"healthy,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Describes the current status of a task.

func NewPopulatedTaskStatus

func NewPopulatedTaskStatus(r randyMesos, easy bool) *TaskStatus

func (*TaskStatus) Equal

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

func (*TaskStatus) GetData

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

func (*TaskStatus) GetExecutorId

func (m *TaskStatus) GetExecutorId() *ExecutorID

func (*TaskStatus) GetHealthy

func (m *TaskStatus) GetHealthy() bool

func (*TaskStatus) GetMessage

func (m *TaskStatus) GetMessage() string

func (*TaskStatus) GetReason

func (m *TaskStatus) GetReason() TaskStatus_Reason

func (*TaskStatus) GetSlaveId

func (m *TaskStatus) GetSlaveId() *SlaveID

func (*TaskStatus) GetSource

func (m *TaskStatus) GetSource() TaskStatus_Source

func (*TaskStatus) GetState

func (m *TaskStatus) GetState() TaskState

func (*TaskStatus) GetTaskId

func (m *TaskStatus) GetTaskId() *TaskID

func (*TaskStatus) GetTimestamp

func (m *TaskStatus) GetTimestamp() float64

func (*TaskStatus) GoString

func (this *TaskStatus) GoString() string

func (*TaskStatus) Marshal

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

func (*TaskStatus) MarshalTo

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

func (*TaskStatus) ProtoMessage

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset

func (m *TaskStatus) Reset()

func (*TaskStatus) Size

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

func (*TaskStatus) String

func (this *TaskStatus) String() string

func (*TaskStatus) Unmarshal

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

func (*TaskStatus) VerboseEqual

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

type TaskStatus_Reason

type TaskStatus_Reason int32

* Detailed reason for the task status update.

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

func (TaskStatus_Reason) Enum

func (TaskStatus_Reason) String

func (x TaskStatus_Reason) String() string

func (*TaskStatus_Reason) UnmarshalJSON

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

type TaskStatus_Source

type TaskStatus_Source int32

* Describes the source of the task status update.

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

func (TaskStatus_Source) Enum

func (TaskStatus_Source) String

func (x TaskStatus_Source) String() string

func (*TaskStatus_Source) UnmarshalJSON

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

type Termination

type Termination struct {
	// A container may be killed if it exceeds its resources; this will
	// be indicated by killed=true and described by the message string.
	Killed  *bool   `protobuf:"varint,1,req,name=killed" json:"killed,omitempty"`
	Message *string `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	// Exit status of the process.
	Status           *int32 `protobuf:"varint,3,opt,name=status" json:"status,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

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

func (*Termination) GetKilled

func (m *Termination) GetKilled() bool

func (*Termination) GetMessage

func (m *Termination) GetMessage() string

func (*Termination) GetStatus

func (m *Termination) GetStatus() int32

func (*Termination) ProtoMessage

func (*Termination) ProtoMessage()

func (*Termination) Reset

func (m *Termination) Reset()

func (*Termination) String

func (m *Termination) String() string

type UnregisterFrameworkMessage

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

func (*UnregisterFrameworkMessage) GetFrameworkId

func (m *UnregisterFrameworkMessage) GetFrameworkId() *FrameworkID

func (*UnregisterFrameworkMessage) ProtoMessage

func (*UnregisterFrameworkMessage) ProtoMessage()

func (*UnregisterFrameworkMessage) Reset

func (m *UnregisterFrameworkMessage) Reset()

func (*UnregisterFrameworkMessage) String

func (m *UnregisterFrameworkMessage) String() string

type UnregisterSlaveMessage

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

func (*UnregisterSlaveMessage) GetSlaveId

func (m *UnregisterSlaveMessage) GetSlaveId() *SlaveID

func (*UnregisterSlaveMessage) ProtoMessage

func (*UnregisterSlaveMessage) ProtoMessage()

func (*UnregisterSlaveMessage) Reset

func (m *UnregisterSlaveMessage) Reset()

func (*UnregisterSlaveMessage) String

func (m *UnregisterSlaveMessage) String() string

type Update

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

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

func (*Update) GetContainerId

func (m *Update) GetContainerId() *ContainerID

func (*Update) GetResources

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

func (*Update) ProtoMessage

func (*Update) ProtoMessage()

func (*Update) Reset

func (m *Update) Reset()

func (*Update) String

func (m *Update) String() string

type UpdateFrameworkMessage

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

func (*UpdateFrameworkMessage) GetFrameworkId

func (m *UpdateFrameworkMessage) GetFrameworkId() *FrameworkID

func (*UpdateFrameworkMessage) GetPid

func (m *UpdateFrameworkMessage) GetPid() string

func (*UpdateFrameworkMessage) ProtoMessage

func (*UpdateFrameworkMessage) ProtoMessage()

func (*UpdateFrameworkMessage) Reset

func (m *UpdateFrameworkMessage) Reset()

func (*UpdateFrameworkMessage) String

func (m *UpdateFrameworkMessage) String() string

type Usage

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

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

func (*Usage) GetContainerId

func (m *Usage) GetContainerId() *ContainerID

func (*Usage) ProtoMessage

func (*Usage) ProtoMessage()

func (*Usage) Reset

func (m *Usage) Reset()

func (*Usage) String

func (m *Usage) String() string

type Value

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

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

func NewPopulatedValue

func NewPopulatedValue(r randyMesos, easy bool) *Value

func (*Value) Equal

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

func (*Value) GetRanges

func (m *Value) GetRanges() *Value_Ranges

func (*Value) GetScalar

func (m *Value) GetScalar() *Value_Scalar

func (*Value) GetSet

func (m *Value) GetSet() *Value_Set

func (*Value) GetText

func (m *Value) GetText() *Value_Text

func (*Value) GetType

func (m *Value) GetType() Value_Type

func (*Value) GoString

func (this *Value) GoString() string

func (*Value) Marshal

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

func (*Value) MarshalTo

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

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

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

func (*Value) String

func (this *Value) String() string

func (*Value) Unmarshal

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

func (*Value) VerboseEqual

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

type Value_Range

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

func NewPopulatedValue_Range

func NewPopulatedValue_Range(r randyMesos, easy bool) *Value_Range

func (*Value_Range) Equal

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

func (*Value_Range) GetBegin

func (m *Value_Range) GetBegin() uint64

func (*Value_Range) GetEnd

func (m *Value_Range) GetEnd() uint64

func (*Value_Range) GoString

func (this *Value_Range) GoString() string

func (*Value_Range) Marshal

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

func (*Value_Range) MarshalTo

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

func (*Value_Range) ProtoMessage

func (*Value_Range) ProtoMessage()

func (*Value_Range) Reset

func (m *Value_Range) Reset()

func (*Value_Range) Size

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

func (*Value_Range) String

func (this *Value_Range) String() string

func (*Value_Range) Unmarshal

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

func (*Value_Range) VerboseEqual

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

type Value_Ranges

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

func NewPopulatedValue_Ranges

func NewPopulatedValue_Ranges(r randyMesos, easy bool) *Value_Ranges

func (*Value_Ranges) Equal

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

func (*Value_Ranges) GetRange

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

func (*Value_Ranges) GoString

func (this *Value_Ranges) GoString() string

func (*Value_Ranges) Marshal

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

func (*Value_Ranges) MarshalTo

func (m *Value_Ranges) MarshalTo(data []byte) (n int, err error)

func (*Value_Ranges) ProtoMessage

func (*Value_Ranges) ProtoMessage()

func (*Value_Ranges) Reset

func (m *Value_Ranges) Reset()

func (*Value_Ranges) Size

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

func (*Value_Ranges) String

func (this *Value_Ranges) String() string

func (*Value_Ranges) Unmarshal

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

func (*Value_Ranges) VerboseEqual

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

type Value_Scalar

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

func NewPopulatedValue_Scalar

func NewPopulatedValue_Scalar(r randyMesos, easy bool) *Value_Scalar

func (*Value_Scalar) Equal

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

func (*Value_Scalar) GetValue

func (m *Value_Scalar) GetValue() float64

func (*Value_Scalar) GoString

func (this *Value_Scalar) GoString() string

func (*Value_Scalar) Marshal

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

func (*Value_Scalar) MarshalTo

func (m *Value_Scalar) MarshalTo(data []byte) (n int, err error)

func (*Value_Scalar) ProtoMessage

func (*Value_Scalar) ProtoMessage()

func (*Value_Scalar) Reset

func (m *Value_Scalar) Reset()

func (*Value_Scalar) Size

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

func (*Value_Scalar) String

func (this *Value_Scalar) String() string

func (*Value_Scalar) Unmarshal

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

func (*Value_Scalar) VerboseEqual

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

type Value_Set

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

func NewPopulatedValue_Set

func NewPopulatedValue_Set(r randyMesos, easy bool) *Value_Set

func (*Value_Set) Equal

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

func (*Value_Set) GetItem

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

func (*Value_Set) GoString

func (this *Value_Set) GoString() string

func (*Value_Set) Marshal

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

func (*Value_Set) MarshalTo

func (m *Value_Set) MarshalTo(data []byte) (n int, err error)

func (*Value_Set) ProtoMessage

func (*Value_Set) ProtoMessage()

func (*Value_Set) Reset

func (m *Value_Set) Reset()

func (*Value_Set) Size

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

func (*Value_Set) String

func (this *Value_Set) String() string

func (*Value_Set) Unmarshal

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

func (*Value_Set) VerboseEqual

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

type Value_Text

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

func NewPopulatedValue_Text

func NewPopulatedValue_Text(r randyMesos, easy bool) *Value_Text

func (*Value_Text) Equal

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

func (*Value_Text) GetValue

func (m *Value_Text) GetValue() string

func (*Value_Text) GoString

func (this *Value_Text) GoString() string

func (*Value_Text) Marshal

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

func (*Value_Text) MarshalTo

func (m *Value_Text) MarshalTo(data []byte) (n int, err error)

func (*Value_Text) ProtoMessage

func (*Value_Text) ProtoMessage()

func (*Value_Text) Reset

func (m *Value_Text) Reset()

func (*Value_Text) Size

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

func (*Value_Text) String

func (this *Value_Text) String() string

func (*Value_Text) Unmarshal

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

func (*Value_Text) VerboseEqual

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

type Value_Type

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

func (Value_Type) Enum

func (x Value_Type) Enum() *Value_Type

func (Value_Type) String

func (x Value_Type) String() string

func (*Value_Type) UnmarshalJSON

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

type Volume

type Volume struct {
	// Absolute path pointing to a directory or file in the container.
	ContainerPath *string `protobuf:"bytes,1,req,name=container_path" json:"container_path,omitempty"`
	// Absolute path pointing to a directory or file on the host or a path
	// relative to the container work directory.
	HostPath         *string      `protobuf:"bytes,2,opt,name=host_path" json:"host_path,omitempty"`
	Mode             *Volume_Mode `protobuf:"varint,3,req,name=mode,enum=mesosproto.Volume_Mode" json:"mode,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

* Describes a volume mapping either from host to container or vice versa. Both paths can either refer to a directory or a file.

func NewPopulatedVolume

func NewPopulatedVolume(r randyMesos, easy bool) *Volume

func (*Volume) Equal

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

func (*Volume) GetContainerPath

func (m *Volume) GetContainerPath() string

func (*Volume) GetHostPath

func (m *Volume) GetHostPath() string

func (*Volume) GetMode

func (m *Volume) GetMode() Volume_Mode

func (*Volume) GoString

func (this *Volume) GoString() string

func (*Volume) Marshal

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

func (*Volume) MarshalTo

func (m *Volume) MarshalTo(data []byte) (n int, err error)

func (*Volume) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) Reset

func (m *Volume) Reset()

func (*Volume) Size

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

func (*Volume) String

func (this *Volume) String() string

func (*Volume) Unmarshal

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

func (*Volume) VerboseEqual

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

type Volume_Mode

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

func (Volume_Mode) Enum

func (x Volume_Mode) Enum() *Volume_Mode

func (Volume_Mode) String

func (x Volume_Mode) String() string

func (*Volume_Mode) UnmarshalJSON

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

type Wait

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

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

func (*Wait) GetContainerId

func (m *Wait) GetContainerId() *ContainerID

func (*Wait) ProtoMessage

func (*Wait) ProtoMessage()

func (*Wait) Reset

func (m *Wait) Reset()

func (*Wait) String

func (m *Wait) String() string

type WriteRequest

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

Represents a write request for a specific type of action. Note that we deliberately do not include the entire Action as it contains fields that are not relevant to a write request (e.g., promised, performed) and rather than ignore them we exclude them for safety.

func NewPopulatedWriteRequest

func NewPopulatedWriteRequest(r randyLog, easy bool) *WriteRequest

func (*WriteRequest) Equal

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

func (*WriteRequest) GetAppend

func (m *WriteRequest) GetAppend() *Action_Append

func (*WriteRequest) GetLearned

func (m *WriteRequest) GetLearned() bool

func (*WriteRequest) GetNop

func (m *WriteRequest) GetNop() *Action_Nop

func (*WriteRequest) GetPosition

func (m *WriteRequest) GetPosition() uint64

func (*WriteRequest) GetProposal

func (m *WriteRequest) GetProposal() uint64

func (*WriteRequest) GetTruncate

func (m *WriteRequest) GetTruncate() *Action_Truncate

func (*WriteRequest) GetType

func (m *WriteRequest) GetType() Action_Type

func (*WriteRequest) GoString

func (this *WriteRequest) GoString() string

func (*WriteRequest) Marshal

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

func (*WriteRequest) MarshalTo

func (m *WriteRequest) MarshalTo(data []byte) (n int, err error)

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset

func (m *WriteRequest) Reset()

func (*WriteRequest) Size

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

func (*WriteRequest) String

func (this *WriteRequest) String() string

func (*WriteRequest) Unmarshal

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

func (*WriteRequest) VerboseEqual

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

type WriteResponse

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

Represents a write response corresponding to a write request. A replica represents a NACK (because it has promised a proposer with a higher proposal number) by setting the okay field to false. If the proposer is a coordinator, then it has been demoted. The 'position' should always correspond to the position set in the request. The 'proposal' is either the same proposal number set in the request in the case of an ACK, or the higher proposal number this position has been promised to in the case of a NACK.

func NewPopulatedWriteResponse

func NewPopulatedWriteResponse(r randyLog, easy bool) *WriteResponse

func (*WriteResponse) Equal

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

func (*WriteResponse) GetOkay

func (m *WriteResponse) GetOkay() bool

func (*WriteResponse) GetPosition

func (m *WriteResponse) GetPosition() uint64

func (*WriteResponse) GetProposal

func (m *WriteResponse) GetProposal() uint64

func (*WriteResponse) GoString

func (this *WriteResponse) GoString() string

func (*WriteResponse) Marshal

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

func (*WriteResponse) MarshalTo

func (m *WriteResponse) MarshalTo(data []byte) (n int, err error)

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset

func (m *WriteResponse) Reset()

func (*WriteResponse) Size

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

func (*WriteResponse) String

func (this *WriteResponse) String() string

func (*WriteResponse) Unmarshal

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

func (*WriteResponse) VerboseEqual

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL