mesosproto

package
v1.1.0 Latest Latest
Warning

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

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

Documentation

Overview

Package mesosproto is a generated protocol buffer package.

It is generated from these files: 

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

It has these top-level messages: 

AuthenticateMessage
AuthenticationMechanismsMessage
AuthenticationStartMessage
AuthenticationStepMessage
AuthenticationCompletedMessage
AuthenticationFailedMessage
AuthenticationErrorMessage
Launch
Update
Wait
Destroy
Usage
Termination
Containers
InternalMasterChangeDetected
InternalTryAuthentication
InternalAuthenticationResult
Promise
Action
Metadata
Record
PromiseRequest
PromiseResponse
WriteRequest
WriteResponse
LearnedMessage
RecoverRequest
RecoverResponse
FrameworkID
OfferID
SlaveID
TaskID
ExecutorID
ContainerID
FrameworkInfo
HealthCheck
CommandInfo
ExecutorInfo
MasterInfo
SlaveInfo
Value
Attribute
Resource
TrafficControlStatistics
ResourceStatistics
ResourceUsage
PerfStatistics
Request
Offer
TaskInfo
TaskStatus
Filters
Environment
Parameter
Parameters
Credential
Credentials
ACL
ACLs
RateLimit
RateLimits
Volume
ContainerInfo
Labels
Label
Port
Ports
DiscoveryInfo
Task
StatusUpdate
StatusUpdateRecord
SubmitSchedulerRequest
SubmitSchedulerResponse
ExecutorToFrameworkMessage
FrameworkToExecutorMessage
RegisterFrameworkMessage
ReregisterFrameworkMessage
FrameworkRegisteredMessage
FrameworkReregisteredMessage
UnregisterFrameworkMessage
DeactivateFrameworkMessage
ResourceRequestMessage
ResourceOffersMessage
LaunchTasksMessage
RescindResourceOfferMessage
ReviveOffersMessage
RunTaskMessage
KillTaskMessage
StatusUpdateMessage
StatusUpdateAcknowledgementMessage
LostSlaveMessage
ReconcileTasksMessage
FrameworkErrorMessage
RegisterSlaveMessage
ReregisterSlaveMessage
SlaveRegisteredMessage
SlaveReregisteredMessage
UnregisterSlaveMessage
MasterSlaveConnection
PingSlaveMessage
PongSlaveMessage
ShutdownFrameworkMessage
ShutdownExecutorMessage
UpdateFrameworkMessage
CheckpointResourcesMessage
UpdateSlaveMessage
RegisterExecutorMessage
ExecutorRegisteredMessage
ExecutorReregisteredMessage
ExitedExecutorMessage
ReconnectExecutorMessage
ReregisterExecutorMessage
ShutdownMessage
Archive
TaskHealthStatus
HookExecuted
Registry
Event
Call
Entry
Operation

Index

Constants

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

Variables

View Source 
var ACL_Entity_Type_name = map[int32]string{
	0: "SOME",
	1: "ANY",
	2: "NONE",
}
View Source 
var ACL_Entity_Type_value = map[string]int32{
	"SOME": 0,
	"ANY":  1,
	"NONE": 2,
}
View Source 
var Action_Type_name = map[int32]string{
	1: "NOP",
	2: "APPEND",
	3: "TRUNCATE",
}
View Source 
var Action_Type_value = map[string]int32{
	"NOP":      1,
	"APPEND":   2,
	"TRUNCATE": 3,
}
View Source 
var Call_Type_name = map[int32]string{
	1:  "SUBSCRIBE",
	2:  "TEARDOWN",
	3:  "ACCEPT",
	4:  "DECLINE",
	5:  "REVIVE",
	6:  "KILL",
	7:  "SHUTDOWN",
	8:  "ACKNOWLEDGE",
	9:  "RECONCILE",
	10: "MESSAGE",
}
View Source 
var Call_Type_value = map[string]int32{
	"SUBSCRIBE":   1,
	"TEARDOWN":    2,
	"ACCEPT":      3,
	"DECLINE":     4,
	"REVIVE":      5,
	"KILL":        6,
	"SHUTDOWN":    7,
	"ACKNOWLEDGE": 8,
	"RECONCILE":   9,
	"MESSAGE":     10,
}
View Source 
var ContainerInfo_DockerInfo_Network_name = map[int32]string{
	1: "HOST",
	2: "BRIDGE",
	3: "NONE",
}
View Source 
var ContainerInfo_DockerInfo_Network_value = map[string]int32{
	"HOST":   1,
	"BRIDGE": 2,
	"NONE":   3,
}
View Source 
var ContainerInfo_Type_name = map[int32]string{
	1: "DOCKER",
	2: "MESOS",
}
View Source 
var ContainerInfo_Type_value = map[string]int32{
	"DOCKER": 1,
	"MESOS":  2,
}
View Source 
var DiscoveryInfo_Visibility_name = map[int32]string{
	0: "FRAMEWORK",
	1: "CLUSTER",
	2: "EXTERNAL",
}
View Source 
var DiscoveryInfo_Visibility_value = map[string]int32{
	"FRAMEWORK": 0,
	"CLUSTER":   1,
	"EXTERNAL":  2,
}
View Source 
var (
	ErrInvalidLengthLog = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthMesos = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var (
	ErrInvalidLengthState = fmt.Errorf("proto: negative length found during unmarshaling")
)
View Source 
var Event_Type_name = map[int32]string{
	1: "SUBSCRIBED",
	2: "OFFERS",
	3: "RESCIND",
	4: "UPDATE",
	5: "MESSAGE",
	6: "FAILURE",
	7: "ERROR",
}
View Source 
var Event_Type_value = map[string]int32{
	"SUBSCRIBED": 1,
	"OFFERS":     2,
	"RESCIND":    3,
	"UPDATE":     4,
	"MESSAGE":    5,
	"FAILURE":    6,
	"ERROR":      7,
}
View Source 
var FrameworkInfo_Capability_Type_name = map[int32]string{
	1: "REVOCABLE_RESOURCES",
}
View Source 
var FrameworkInfo_Capability_Type_value = map[string]int32{
	"REVOCABLE_RESOURCES": 1,
}
View Source 
var Metadata_Status_name = map[int32]string{
	1: "VOTING",
	2: "RECOVERING",
	3: "STARTING",
	4: "EMPTY",
}
View Source 
var Metadata_Status_value = map[string]int32{
	"VOTING":     1,
	"RECOVERING": 2,
	"STARTING":   3,
	"EMPTY":      4,
}
View Source 
var Offer_Operation_Type_name = map[int32]string{
	1: "LAUNCH",
	2: "RESERVE",
	3: "UNRESERVE",
	4: "CREATE",
	5: "DESTROY",
}
View Source 
var Offer_Operation_Type_value = map[string]int32{
	"LAUNCH":    1,
	"RESERVE":   2,
	"UNRESERVE": 3,
	"CREATE":    4,
	"DESTROY":   5,
}
View Source 
var Operation_Type_name = map[int32]string{
	1: "SNAPSHOT",
	3: "DIFF",
	2: "EXPUNGE",
}
View Source 
var Operation_Type_value = map[string]int32{
	"SNAPSHOT": 1,
	"DIFF":     3,
	"EXPUNGE":  2,
}
View Source 
var Record_Type_name = map[int32]string{
	1: "PROMISE",
	2: "ACTION",
	3: "METADATA",
}
View Source 
var Record_Type_value = map[string]int32{
	"PROMISE":  1,
	"ACTION":   2,
	"METADATA": 3,
}
View Source 
var StatusUpdateRecord_Type_name = map[int32]string{
	0: "UPDATE",
	1: "ACK",
}
View Source 
var StatusUpdateRecord_Type_value = map[string]int32{
	"UPDATE": 0,
	"ACK":    1,
}
View Source 
var Status_name = map[int32]string{
	1: "DRIVER_NOT_STARTED",
	2: "DRIVER_RUNNING",
	3: "DRIVER_ABORTED",
	4: "DRIVER_STOPPED",
}
View Source 
var Status_value = map[string]int32{
	"DRIVER_NOT_STARTED": 1,
	"DRIVER_RUNNING":     2,
	"DRIVER_ABORTED":     3,
	"DRIVER_STOPPED":     4,
}
View Source 
var TaskState_name = map[int32]string{
	6: "TASK_STAGING",
	0: "TASK_STARTING",
	1: "TASK_RUNNING",
	2: "TASK_FINISHED",
	3: "TASK_FAILED",
	4: "TASK_KILLED",
	5: "TASK_LOST",
	7: "TASK_ERROR",
}
View Source 
var TaskState_value = map[string]int32{
	"TASK_STAGING":  6,
	"TASK_STARTING": 0,
	"TASK_RUNNING":  1,
	"TASK_FINISHED": 2,
	"TASK_FAILED":   3,
	"TASK_KILLED":   4,
	"TASK_LOST":     5,
	"TASK_ERROR":    7,
}
View Source 
var TaskStatus_Reason_name = map[int32]string{
	0:  "REASON_COMMAND_EXECUTOR_FAILED",
	17: "REASON_EXECUTOR_PREEMPTED",
	1:  "REASON_EXECUTOR_TERMINATED",
	2:  "REASON_EXECUTOR_UNREGISTERED",
	3:  "REASON_FRAMEWORK_REMOVED",
	4:  "REASON_GC_ERROR",
	5:  "REASON_INVALID_FRAMEWORKID",
	6:  "REASON_INVALID_OFFERS",
	7:  "REASON_MASTER_DISCONNECTED",
	8:  "REASON_MEMORY_LIMIT",
	9:  "REASON_RECONCILIATION",
	18: "REASON_RESOURCES_UNKNOWN",
	10: "REASON_SLAVE_DISCONNECTED",
	11: "REASON_SLAVE_REMOVED",
	12: "REASON_SLAVE_RESTARTED",
	13: "REASON_SLAVE_UNKNOWN",
	14: "REASON_TASK_INVALID",
	15: "REASON_TASK_UNAUTHORIZED",
	16: "REASON_TASK_UNKNOWN",
}
View Source 
var TaskStatus_Reason_value = map[string]int32{
	"REASON_COMMAND_EXECUTOR_FAILED": 0,
	"REASON_EXECUTOR_PREEMPTED":      17,
	"REASON_EXECUTOR_TERMINATED":     1,
	"REASON_EXECUTOR_UNREGISTERED":   2,
	"REASON_FRAMEWORK_REMOVED":       3,
	"REASON_GC_ERROR":                4,
	"REASON_INVALID_FRAMEWORKID":     5,
	"REASON_INVALID_OFFERS":          6,
	"REASON_MASTER_DISCONNECTED":     7,
	"REASON_MEMORY_LIMIT":            8,
	"REASON_RECONCILIATION":          9,
	"REASON_RESOURCES_UNKNOWN":       18,
	"REASON_SLAVE_DISCONNECTED":      10,
	"REASON_SLAVE_REMOVED":           11,
	"REASON_SLAVE_RESTARTED":         12,
	"REASON_SLAVE_UNKNOWN":           13,
	"REASON_TASK_INVALID":            14,
	"REASON_TASK_UNAUTHORIZED":       15,
	"REASON_TASK_UNKNOWN":            16,
}
View Source 
var TaskStatus_Source_name = map[int32]string{
	0: "SOURCE_MASTER",
	1: "SOURCE_SLAVE",
	2: "SOURCE_EXECUTOR",
}
View Source 
var TaskStatus_Source_value = map[string]int32{
	"SOURCE_MASTER":   0,
	"SOURCE_SLAVE":    1,
	"SOURCE_EXECUTOR": 2,
}
View Source 
var Value_Type_name = map[int32]string{
	0: "SCALAR",
	1: "RANGES",
	2: "SET",
	3: "TEXT",
}
View Source 
var Value_Type_value = map[string]int32{
	"SCALAR": 0,
	"RANGES": 1,
	"SET":    2,
	"TEXT":   3,
}
View Source 
var Volume_Mode_name = map[int32]string{
	1: "RW",
	2: "RO",
}
View Source 
var Volume_Mode_value = map[string]int32{
	"RW": 1,
	"RO": 2,
}

Functions

This section is empty.

Types

type ACL 

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

* ACLs used for authorization.

func NewPopulatedACL 

func NewPopulatedACL(r randyMesos, easy bool) *ACL

func (*ACL) Equal 

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

func (*ACL) GoString 

func (this *ACL) GoString() string

func (*ACL) Marshal 

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

func (*ACL) MarshalTo 

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

func (*ACL) ProtoMessage 

func (*ACL) ProtoMessage()

func (*ACL) Reset 

func (m *ACL) Reset()

func (*ACL) Size 

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

func (*ACL) String 

func (this *ACL) String() string

func (*ACL) Unmarshal 

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

func (*ACL) VerboseEqual 

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

type ACL_Entity 

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

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

func NewPopulatedACL_Entity 

func NewPopulatedACL_Entity(r randyMesos, easy bool) *ACL_Entity

func (*ACL_Entity) Equal 

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

func (*ACL_Entity) GetType 

func (m *ACL_Entity) GetType() ACL_Entity_Type

func (*ACL_Entity) GetValues 

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

func (*ACL_Entity) GoString 

func (this *ACL_Entity) GoString() string

func (*ACL_Entity) Marshal 

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

func (*ACL_Entity) MarshalTo 

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

func (*ACL_Entity) ProtoMessage 

func (*ACL_Entity) ProtoMessage()

func (*ACL_Entity) Reset 

func (m *ACL_Entity) Reset()

func (*ACL_Entity) Size 

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

func (*ACL_Entity) String 

func (this *ACL_Entity) String() string

func (*ACL_Entity) Unmarshal 

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

func (*ACL_Entity) VerboseEqual 

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

type ACL_Entity_Type 

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

func (ACL_Entity_Type) Enum 

func (x ACL_Entity_Type) Enum() *ACL_Entity_Type

func (ACL_Entity_Type) String 

func (x ACL_Entity_Type) String() string

func (*ACL_Entity_Type) UnmarshalJSON 

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

type ACL_RegisterFramework 

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

ACLs.

func NewPopulatedACL_RegisterFramework 

func NewPopulatedACL_RegisterFramework(r randyMesos, easy bool) *ACL_RegisterFramework

func (*ACL_RegisterFramework) Equal 

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

func (*ACL_RegisterFramework) GetPrincipals 

func (m *ACL_RegisterFramework) GetPrincipals() *ACL_Entity

func (*ACL_RegisterFramework) GetRoles 

func (m *ACL_RegisterFramework) GetRoles() *ACL_Entity

func (*ACL_RegisterFramework) GoString 

func (this *ACL_RegisterFramework) GoString() string

func (*ACL_RegisterFramework) Marshal 

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

func (*ACL_RegisterFramework) MarshalTo 

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

func (*ACL_RegisterFramework) ProtoMessage 

func (*ACL_RegisterFramework) ProtoMessage()

func (*ACL_RegisterFramework) Reset 

func (m *ACL_RegisterFramework) Reset()

func (*ACL_RegisterFramework) Size 

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

func (*ACL_RegisterFramework) String 

func (this *ACL_RegisterFramework) String() string

func (*ACL_RegisterFramework) Unmarshal 

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

func (*ACL_RegisterFramework) VerboseEqual 

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

type ACL_RunTask 

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

func NewPopulatedACL_RunTask 

func NewPopulatedACL_RunTask(r randyMesos, easy bool) *ACL_RunTask

func (*ACL_RunTask) Equal 

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

func (*ACL_RunTask) GetPrincipals 

func (m *ACL_RunTask) GetPrincipals() *ACL_Entity

func (*ACL_RunTask) GetUsers 

func (m *ACL_RunTask) GetUsers() *ACL_Entity

func (*ACL_RunTask) GoString 

func (this *ACL_RunTask) GoString() string

func (*ACL_RunTask) Marshal 

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

func (*ACL_RunTask) MarshalTo 

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

func (*ACL_RunTask) ProtoMessage 

func (*ACL_RunTask) ProtoMessage()

func (*ACL_RunTask) Reset 

func (m *ACL_RunTask) Reset()

func (*ACL_RunTask) Size 

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

func (*ACL_RunTask) String 

func (this *ACL_RunTask) String() string

func (*ACL_RunTask) Unmarshal 

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

func (*ACL_RunTask) VerboseEqual 

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

type ACL_ShutdownFramework 

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

Which principals are authorized to shutdown frameworks of other principals.

func NewPopulatedACL_ShutdownFramework 

func NewPopulatedACL_ShutdownFramework(r randyMesos, easy bool) *ACL_ShutdownFramework

func (*ACL_ShutdownFramework) Equal 

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

func (*ACL_ShutdownFramework) GetFrameworkPrincipals 

func (m *ACL_ShutdownFramework) GetFrameworkPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) GetPrincipals 

func (m *ACL_ShutdownFramework) GetPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) GoString 

func (this *ACL_ShutdownFramework) GoString() string

func (*ACL_ShutdownFramework) Marshal 

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

func (*ACL_ShutdownFramework) MarshalTo 

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

func (*ACL_ShutdownFramework) ProtoMessage 

func (*ACL_ShutdownFramework) ProtoMessage()

func (*ACL_ShutdownFramework) Reset 

func (m *ACL_ShutdownFramework) Reset()

func (*ACL_ShutdownFramework) Size 

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

func (*ACL_ShutdownFramework) String 

func (this *ACL_ShutdownFramework) String() string

func (*ACL_ShutdownFramework) Unmarshal 

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

func (*ACL_ShutdownFramework) VerboseEqual 

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

type ACLs 

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

* Collection of ACL.

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

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

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

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

func NewPopulatedACLs 

func NewPopulatedACLs(r randyMesos, easy bool) *ACLs

func (*ACLs) Equal 

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

func (*ACLs) GetPermissive 

func (m *ACLs) GetPermissive() bool

func (*ACLs) GetRegisterFrameworks 

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

func (*ACLs) GetRunTasks 

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

func (*ACLs) GetShutdownFrameworks 

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

func (*ACLs) GoString 

func (this *ACLs) GoString() string

func (*ACLs) Marshal 

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

func (*ACLs) MarshalTo 

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

func (*ACLs) ProtoMessage 

func (*ACLs) ProtoMessage()

func (*ACLs) Reset 

func (m *ACLs) Reset()

func (*ACLs) Size 

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

func (*ACLs) String 

func (this *ACLs) String() string

func (*ACLs) Unmarshal 

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

func (*ACLs) VerboseEqual 

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

type Action 

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

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

func NewPopulatedAction 

func NewPopulatedAction(r randyLog, easy bool) *Action

func (*Action) Equal 

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

func (*Action) GetAppend 

func (m *Action) GetAppend() *Action_Append

func (*Action) GetLearned 

func (m *Action) GetLearned() bool

func (*Action) GetNop 

func (m *Action) GetNop() *Action_Nop

func (*Action) GetPerformed 

func (m *Action) GetPerformed() uint64

func (*Action) GetPosition 

func (m *Action) GetPosition() uint64

func (*Action) GetPromised 

func (m *Action) GetPromised() uint64

func (*Action) GetTruncate 

func (m *Action) GetTruncate() *Action_Truncate

func (*Action) GetType 

func (m *Action) GetType() Action_Type

func (*Action) GoString 

func (this *Action) GoString() string

func (*Action) Marshal 

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

func (*Action) MarshalTo 

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

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) Reset 

func (m *Action) Reset()

func (*Action) Size 

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

func (*Action) String 

func (this *Action) String() string

func (*Action) Unmarshal 

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

func (*Action) VerboseEqual 

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

type Action_Append 

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

func NewPopulatedAction_Append 

func NewPopulatedAction_Append(r randyLog, easy bool) *Action_Append

func (*Action_Append) Equal 

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

func (*Action_Append) GetBytes 

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

func (*Action_Append) GetCksum 

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

func (*Action_Append) GoString 

func (this *Action_Append) GoString() string

func (*Action_Append) Marshal 

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

func (*Action_Append) MarshalTo 

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

func (*Action_Append) ProtoMessage 

func (*Action_Append) ProtoMessage()

func (*Action_Append) Reset 

func (m *Action_Append) Reset()

func (*Action_Append) Size 

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

func (*Action_Append) String 

func (this *Action_Append) String() string

func (*Action_Append) Unmarshal 

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

func (*Action_Append) VerboseEqual 

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

type Action_Nop 

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

func NewPopulatedAction_Nop 

func NewPopulatedAction_Nop(r randyLog, easy bool) *Action_Nop

func (*Action_Nop) Equal 

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

func (*Action_Nop) GoString 

func (this *Action_Nop) GoString() string

func (*Action_Nop) Marshal 

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

func (*Action_Nop) MarshalTo 

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

func (*Action_Nop) ProtoMessage 

func (*Action_Nop) ProtoMessage()

func (*Action_Nop) Reset 

func (m *Action_Nop) Reset()

func (*Action_Nop) Size 

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

func (*Action_Nop) String 

func (this *Action_Nop) String() string

func (*Action_Nop) Unmarshal 

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

func (*Action_Nop) VerboseEqual 

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

type Action_Truncate 

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

func NewPopulatedAction_Truncate 

func NewPopulatedAction_Truncate(r randyLog, easy bool) *Action_Truncate

func (*Action_Truncate) Equal 

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

func (*Action_Truncate) GetTo 

func (m *Action_Truncate) GetTo() uint64

func (*Action_Truncate) GoString 

func (this *Action_Truncate) GoString() string

func (*Action_Truncate) Marshal 

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

func (*Action_Truncate) MarshalTo 

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

func (*Action_Truncate) ProtoMessage 

func (*Action_Truncate) ProtoMessage()

func (*Action_Truncate) Reset 

func (m *Action_Truncate) Reset()

func (*Action_Truncate) Size 

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

func (*Action_Truncate) String 

func (this *Action_Truncate) String() string

func (*Action_Truncate) Unmarshal 

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

func (*Action_Truncate) VerboseEqual 

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

type Action_Type 

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

func (Action_Type) Enum 

func (x Action_Type) Enum() *Action_Type

func (Action_Type) String 

func (x Action_Type) String() string

func (*Action_Type) UnmarshalJSON 

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

type Archive 

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

* Describes Completed Frameworks, etc. for archival.

func (*Archive) GetFrameworks 

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

func (*Archive) ProtoMessage 

func (*Archive) ProtoMessage()

func (*Archive) Reset 

func (m *Archive) Reset()

func (*Archive) String 

func (m *Archive) String() string

type Archive_Framework 

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

func (*Archive_Framework) GetFrameworkInfo 

func (m *Archive_Framework) GetFrameworkInfo() *FrameworkInfo

func (*Archive_Framework) GetPid 

func (m *Archive_Framework) GetPid() string

func (*Archive_Framework) GetTasks 

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

func (*Archive_Framework) ProtoMessage 

func (*Archive_Framework) ProtoMessage()

func (*Archive_Framework) Reset 

func (m *Archive_Framework) Reset()

func (*Archive_Framework) String 

func (m *Archive_Framework) String() string

type Attribute 

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

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

func NewPopulatedAttribute 

func NewPopulatedAttribute(r randyMesos, easy bool) *Attribute

func (*Attribute) Equal 

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

func (*Attribute) GetName 

func (m *Attribute) GetName() string

func (*Attribute) GetRanges 

func (m *Attribute) GetRanges() *Value_Ranges

func (*Attribute) GetScalar 

func (m *Attribute) GetScalar() *Value_Scalar

func (*Attribute) GetSet 

func (m *Attribute) GetSet() *Value_Set

func (*Attribute) GetText 

func (m *Attribute) GetText() *Value_Text

func (*Attribute) GetType 

func (m *Attribute) GetType() Value_Type

func (*Attribute) GoString 

func (this *Attribute) GoString() string

func (*Attribute) Marshal 

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

func (*Attribute) MarshalTo 

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

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) Size 

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

func (*Attribute) String 

func (this *Attribute) String() string

func (*Attribute) Unmarshal 

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

func (*Attribute) VerboseEqual 

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

type AuthenticateMessage 

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

func (*AuthenticateMessage) GetPid 

func (m *AuthenticateMessage) GetPid() string

func (*AuthenticateMessage) ProtoMessage 

func (*AuthenticateMessage) ProtoMessage()

func (*AuthenticateMessage) Reset 

func (m *AuthenticateMessage) Reset()

func (*AuthenticateMessage) String 

func (m *AuthenticateMessage) String() string

type AuthenticationCompletedMessage 

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

func (*AuthenticationCompletedMessage) ProtoMessage 

func (*AuthenticationCompletedMessage) ProtoMessage()

func (*AuthenticationCompletedMessage) Reset 

func (m *AuthenticationCompletedMessage) Reset()

func (*AuthenticationCompletedMessage) String 

func (m *AuthenticationCompletedMessage) String() string

type AuthenticationErrorMessage 

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

func (*AuthenticationErrorMessage) GetError 

func (m *AuthenticationErrorMessage) GetError() string

func (*AuthenticationErrorMessage) ProtoMessage 

func (*AuthenticationErrorMessage) ProtoMessage()

func (*AuthenticationErrorMessage) Reset 

func (m *AuthenticationErrorMessage) Reset()

func (*AuthenticationErrorMessage) String 

func (m *AuthenticationErrorMessage) String() string

type AuthenticationFailedMessage 

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

func (*AuthenticationFailedMessage) ProtoMessage 

func (*AuthenticationFailedMessage) ProtoMessage()

func (*AuthenticationFailedMessage) Reset 

func (m *AuthenticationFailedMessage) Reset()

func (*AuthenticationFailedMessage) String 

func (m *AuthenticationFailedMessage) String() string

type AuthenticationMechanismsMessage 

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

func (*AuthenticationMechanismsMessage) GetMechanisms 

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

func (*AuthenticationMechanismsMessage) ProtoMessage 

func (*AuthenticationMechanismsMessage) ProtoMessage()

func (*AuthenticationMechanismsMessage) Reset 

func (m *AuthenticationMechanismsMessage) Reset()

func (*AuthenticationMechanismsMessage) String 

func (m *AuthenticationMechanismsMessage) String() string

type AuthenticationStartMessage 

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

func (*AuthenticationStartMessage) GetData 

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

func (*AuthenticationStartMessage) GetMechanism 

func (m *AuthenticationStartMessage) GetMechanism() string

func (*AuthenticationStartMessage) ProtoMessage 

func (*AuthenticationStartMessage) ProtoMessage()

func (*AuthenticationStartMessage) Reset 

func (m *AuthenticationStartMessage) Reset()

func (*AuthenticationStartMessage) String 

func (m *AuthenticationStartMessage) String() string

type AuthenticationStepMessage 

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

func (*AuthenticationStepMessage) GetData 

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

func (*AuthenticationStepMessage) ProtoMessage 

func (*AuthenticationStepMessage) ProtoMessage()

func (*AuthenticationStepMessage) Reset 

func (m *AuthenticationStepMessage) Reset()

func (*AuthenticationStepMessage) String 

func (m *AuthenticationStepMessage) String() string

type Call 

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

* Scheduler call API.

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

func (*Call) GetAccept added in v1.1.0 

func (m *Call) GetAccept() *Call_Accept

func (*Call) GetAcknowledge 

func (m *Call) GetAcknowledge() *Call_Acknowledge

func (*Call) GetDecline 

func (m *Call) GetDecline() *Call_Decline

func (*Call) GetFrameworkId added in v1.1.0 

func (m *Call) GetFrameworkId() *FrameworkID

func (*Call) GetKill 

func (m *Call) GetKill() *Call_Kill

func (*Call) GetMessage 

func (m *Call) GetMessage() *Call_Message

func (*Call) GetReconcile 

func (m *Call) GetReconcile() *Call_Reconcile

func (*Call) GetShutdown added in v1.1.0 

func (m *Call) GetShutdown() *Call_Shutdown

func (*Call) GetSubscribe added in v1.1.0 

func (m *Call) GetSubscribe() *Call_Subscribe

func (*Call) GetType 

func (m *Call) GetType() Call_Type

func (*Call) ProtoMessage