golligator

package module
v0.0.0-...-c644590 Latest Latest
Warning

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

Go to latest
Published: Jun 12, 2015 License: Apache-2.0 Imports: 10 Imported by: 0

README

golligator

Serving and sending protobufs from/to mesos via HTTP.

Usage

package main

import "github.com/stealthly/golligator"

func main() {
  // Create config first, specify port to serve and url of remote server to respond
  config := &golligator.Config{Port: 8081, ServerUrl: "http://remote.server.com"}
  // Create Golligator from config
  g := golligator.NewGolligator(config)
  // Start server and get channel with incoming events
  events := g.Listen()
  for {
    event := <-events // Get event from channel
    // ...
    // Do actual work here
    // ...
    g.Send(event) // Send event back to the server
  }
}

Reference

type Config
type Config struct {
	Port      int    // port to listen
	ServerUrl string // server url to send events
}
type Event
type Event struct {
	Type    string
	Message proto.Message
}
type Golligator
type Golligator struct {
}
func NewGolligator
func NewGolligator(config *Config) *Golligator

NewGolligator creates new server with specified config

func (*Golligator) Listen
func (g *Golligator) Listen() chan *Event

Listen creates new http listener and returns channel of incoming events

func (*Golligator) Send
func (g *Golligator) Send(event *Event)

Send event back to the server

Documentation

Overview

Package golligator is a generated protocol buffer package.

It is generated from these files:

allocator.proto
mesos.proto

It has these top-level messages:

SlaveResources
FrameworkResources
AddFramework
RemoveFramework
ActivateFramework
DeactivateFramework
AddSlave
RemoveSlave
UpdateSlave
ActivateSlave
DeactivateSlave
UpdateWhitelist
RequestResources
UpdateAllocation
RecoverResources
ReviveOffers

Package golligator provides server and client for mesos protobuf events

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_Resource_Role string = "*"
View Source
const Default_SlaveInfo_Checkpoint bool = false
View Source
const Default_SlaveInfo_Port int32 = 5051

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 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 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 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 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 (*ACL) ProtoMessage

func (*ACL) ProtoMessage()

func (*ACL) Reset

func (m *ACL) Reset()

func (*ACL) String

func (m *ACL) String() string

type ACL_Entity

type ACL_Entity struct {
	Type             *ACL_Entity_Type `protobuf:"varint,1,opt,name=type,enum=golligator.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 (*ACL_Entity) GetType

func (m *ACL_Entity) GetType() ACL_Entity_Type

func (*ACL_Entity) GetValues

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

func (*ACL_Entity) ProtoMessage

func (*ACL_Entity) ProtoMessage()

func (*ACL_Entity) Reset

func (m *ACL_Entity) Reset()

func (*ACL_Entity) String

func (m *ACL_Entity) String() string

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 (*ACL_RegisterFramework) GetPrincipals

func (m *ACL_RegisterFramework) GetPrincipals() *ACL_Entity

func (*ACL_RegisterFramework) GetRoles

func (m *ACL_RegisterFramework) GetRoles() *ACL_Entity

func (*ACL_RegisterFramework) ProtoMessage

func (*ACL_RegisterFramework) ProtoMessage()

func (*ACL_RegisterFramework) Reset

func (m *ACL_RegisterFramework) Reset()

func (*ACL_RegisterFramework) String

func (m *ACL_RegisterFramework) String() string

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 (*ACL_RunTask) GetPrincipals

func (m *ACL_RunTask) GetPrincipals() *ACL_Entity

func (*ACL_RunTask) GetUsers

func (m *ACL_RunTask) GetUsers() *ACL_Entity

func (*ACL_RunTask) ProtoMessage

func (*ACL_RunTask) ProtoMessage()

func (*ACL_RunTask) Reset

func (m *ACL_RunTask) Reset()

func (*ACL_RunTask) String

func (m *ACL_RunTask) String() string

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 (*ACL_ShutdownFramework) GetFrameworkPrincipals

func (m *ACL_ShutdownFramework) GetFrameworkPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) GetPrincipals

func (m *ACL_ShutdownFramework) GetPrincipals() *ACL_Entity

func (*ACL_ShutdownFramework) ProtoMessage

func (*ACL_ShutdownFramework) ProtoMessage()

func (*ACL_ShutdownFramework) Reset

func (m *ACL_ShutdownFramework) Reset()

func (*ACL_ShutdownFramework) String

func (m *ACL_ShutdownFramework) String() string

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 (*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) ProtoMessage

func (*ACLs) ProtoMessage()

func (*ACLs) Reset

func (m *ACLs) Reset()

func (*ACLs) String

func (m *ACLs) String() string

type ActivateFramework

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

func (*ActivateFramework) GetFrameworkId

func (m *ActivateFramework) GetFrameworkId() *FrameworkID

func (*ActivateFramework) ProtoMessage

func (*ActivateFramework) ProtoMessage()

func (*ActivateFramework) Reset

func (m *ActivateFramework) Reset()

func (*ActivateFramework) String

func (m *ActivateFramework) String() string

type ActivateSlave

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

func (*ActivateSlave) GetSlaveId

func (m *ActivateSlave) GetSlaveId() *SlaveID

func (*ActivateSlave) ProtoMessage

func (*ActivateSlave) ProtoMessage()

func (*ActivateSlave) Reset

func (m *ActivateSlave) Reset()

func (*ActivateSlave) String

func (m *ActivateSlave) String() string

type AddFramework

type AddFramework struct {
	FrameworkId      *FrameworkID      `protobuf:"bytes,1,req,name=frameworkId" json:"frameworkId,omitempty"`
	FrameworkInfo    *FrameworkInfo    `protobuf:"bytes,2,req,name=frameworkInfo" json:"frameworkInfo,omitempty"`
	SlaveResources   []*SlaveResources `protobuf:"bytes,3,rep,name=slaveResources" json:"slaveResources,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*AddFramework) GetFrameworkId

func (m *AddFramework) GetFrameworkId() *FrameworkID

func (*AddFramework) GetFrameworkInfo

func (m *AddFramework) GetFrameworkInfo() *FrameworkInfo

func (*AddFramework) GetSlaveResources

func (m *AddFramework) GetSlaveResources() []*SlaveResources

func (*AddFramework) ProtoMessage

func (*AddFramework) ProtoMessage()

func (*AddFramework) Reset

func (m *AddFramework) Reset()

func (*AddFramework) String

func (m *AddFramework) String() string

type AddSlave

type AddSlave struct {
	SlaveId            *SlaveID              `protobuf:"bytes,1,req,name=slaveId" json:"slaveId,omitempty"`
	SlaveInfo          *SlaveInfo            `protobuf:"bytes,2,req,name=slaveInfo" json:"slaveInfo,omitempty"`
	Total              []*Resource           `protobuf:"bytes,3,rep,name=total" json:"total,omitempty"`
	FrameworkResources []*FrameworkResources `protobuf:"bytes,4,rep,name=frameworkResources" json:"frameworkResources,omitempty"`
	XXX_unrecognized   []byte                `json:"-"`
}

func (*AddSlave) GetFrameworkResources

func (m *AddSlave) GetFrameworkResources() []*FrameworkResources

func (*AddSlave) GetSlaveId

func (m *AddSlave) GetSlaveId() *SlaveID

func (*AddSlave) GetSlaveInfo

func (m *AddSlave) GetSlaveInfo() *SlaveInfo

func (*AddSlave) GetTotal

func (m *AddSlave) GetTotal() []*Resource

func (*AddSlave) ProtoMessage

func (*AddSlave) ProtoMessage()

func (*AddSlave) Reset

func (m *AddSlave) Reset()

func (*AddSlave) String

func (m *AddSlave) 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=golligator.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 (*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) ProtoMessage

func (*Attribute) ProtoMessage()

func (*Attribute) Reset

func (m *Attribute) Reset()

func (*Attribute) String

func (m *Attribute) String() string

type CommandInfo

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

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

func (*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) ProtoMessage

func (*CommandInfo) ProtoMessage()

func (*CommandInfo) Reset

func (m *CommandInfo) Reset()

func (*CommandInfo) String

func (m *CommandInfo) String() string

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 (*CommandInfo_ContainerInfo) GetImage

func (m *CommandInfo_ContainerInfo) GetImage() string

func (*CommandInfo_ContainerInfo) GetOptions

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

func (*CommandInfo_ContainerInfo) ProtoMessage

func (*CommandInfo_ContainerInfo) ProtoMessage()

func (*CommandInfo_ContainerInfo) Reset

func (m *CommandInfo_ContainerInfo) Reset()

func (*CommandInfo_ContainerInfo) String

func (m *CommandInfo_ContainerInfo) String() string

type CommandInfo_URI

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

func (*CommandInfo_URI) GetCache

func (m *CommandInfo_URI) GetCache() bool

func (*CommandInfo_URI) GetExecutable

func (m *CommandInfo_URI) GetExecutable() bool

func (*CommandInfo_URI) GetExtract

func (m *CommandInfo_URI) GetExtract() bool

func (*CommandInfo_URI) GetValue

func (m *CommandInfo_URI) GetValue() string

func (*CommandInfo_URI) ProtoMessage

func (*CommandInfo_URI) ProtoMessage()

func (*CommandInfo_URI) Reset

func (m *CommandInfo_URI) Reset()

func (*CommandInfo_URI) String

func (m *CommandInfo_URI) String() string

type Config

type Config struct {
	Port      int    // port to listen
	ServerUrl string // server url to send events
}

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 (*ContainerID) GetValue

func (m *ContainerID) GetValue() string

func (*ContainerID) ProtoMessage

func (*ContainerID) ProtoMessage()

func (*ContainerID) Reset

func (m *ContainerID) Reset()

func (*ContainerID) String

func (m *ContainerID) String() string

type ContainerInfo

type ContainerInfo struct {
	Type             *ContainerInfo_Type       `protobuf:"varint,1,req,name=type,enum=golligator.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 (*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) ProtoMessage

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) Reset

func (m *ContainerInfo) Reset()

func (*ContainerInfo) String

func (m *ContainerInfo) String() string

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=golligator.ContainerInfo_DockerInfo_Network,def=1" json:"network,omitempty"`
	PortMappings []*ContainerInfo_DockerInfo_PortMapping `protobuf:"bytes,3,rep,name=port_mappings" json:"port_mappings,omitempty"`
	Privileged   *bool                                   `protobuf:"varint,4,opt,name=privileged,def=0" json:"privileged,omitempty"`
	// Allowing arbitrary parameters to be passed to docker CLI.
	// Note that anything passed to this field is not guaranteed
	// to be supported moving forward, as we might move away from
	// the docker CLI.
	Parameters []*Parameter `protobuf:"bytes,5,rep,name=parameters" json:"parameters,omitempty"`
	// With this flag set to true, the docker containerizer will
	// pull the docker image from the registry even if the image
	// is already downloaded on the slave.
	ForcePullImage   *bool  `protobuf:"varint,6,opt,name=force_pull_image" json:"force_pull_image,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*ContainerInfo_DockerInfo) GetForcePullImage

func (m *ContainerInfo_DockerInfo) GetForcePullImage() 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) ProtoMessage

func (*ContainerInfo_DockerInfo) ProtoMessage()

func (*ContainerInfo_DockerInfo) Reset

func (m *ContainerInfo_DockerInfo) Reset()

func (*ContainerInfo_DockerInfo) String

func (m *ContainerInfo_DockerInfo) String() string

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 (*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) ProtoMessage

func (*ContainerInfo_DockerInfo_PortMapping) ProtoMessage()

func (*ContainerInfo_DockerInfo_PortMapping) Reset

func (*ContainerInfo_DockerInfo_PortMapping) String

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 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 (*Credential) GetPrincipal

func (m *Credential) GetPrincipal() string

func (*Credential) GetSecret

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

func (*Credential) ProtoMessage

func (*Credential) ProtoMessage()

func (*Credential) Reset

func (m *Credential) Reset()

func (*Credential) String

func (m *Credential) String() string

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 (*Credentials) GetCredentials

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

func (*Credentials) ProtoMessage

func (*Credentials) ProtoMessage()

func (*Credentials) Reset

func (m *Credentials) Reset()

func (*Credentials) String

func (m *Credentials) String() string

type DeactivateFramework

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

func (*DeactivateFramework) GetFrameworkId

func (m *DeactivateFramework) GetFrameworkId() *FrameworkID

func (*DeactivateFramework) ProtoMessage

func (*DeactivateFramework) ProtoMessage()

func (*DeactivateFramework) Reset

func (m *DeactivateFramework) Reset()

func (*DeactivateFramework) String

func (m *DeactivateFramework) String() string

type DeactivateSlave

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

func (*DeactivateSlave) GetSlaveId

func (m *DeactivateSlave) GetSlaveId() *SlaveID

func (*DeactivateSlave) ProtoMessage

func (*DeactivateSlave) ProtoMessage()

func (*DeactivateSlave) Reset

func (m *DeactivateSlave) Reset()

func (*DeactivateSlave) String

func (m *DeactivateSlave) String() string

type DiscoveryInfo

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

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

func (*DiscoveryInfo) GetEnvironment

func (m *DiscoveryInfo) GetEnvironment() string

func (*DiscoveryInfo) GetLabels

func (m *DiscoveryInfo) GetLabels() *Labels

func (*DiscoveryInfo) GetLocation

func (m *DiscoveryInfo) GetLocation() string

func (*DiscoveryInfo) GetName

func (m *DiscoveryInfo) GetName() string

func (*DiscoveryInfo) GetPorts

func (m *DiscoveryInfo) GetPorts() *Ports

func (*DiscoveryInfo) GetVersion

func (m *DiscoveryInfo) GetVersion() string

func (*DiscoveryInfo) GetVisibility

func (m *DiscoveryInfo) GetVisibility() DiscoveryInfo_Visibility

func (*DiscoveryInfo) ProtoMessage

func (*DiscoveryInfo) ProtoMessage()

func (*DiscoveryInfo) Reset

func (m *DiscoveryInfo) Reset()

func (*DiscoveryInfo) String

func (m *DiscoveryInfo) String() string

type DiscoveryInfo_Visibility

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

func (DiscoveryInfo_Visibility) Enum

func (DiscoveryInfo_Visibility) String

func (x DiscoveryInfo_Visibility) String() string

func (*DiscoveryInfo_Visibility) UnmarshalJSON

func (x *DiscoveryInfo_Visibility) UnmarshalJSON(data []byte) 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 (*Environment) GetVariables

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

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) Reset

func (m *Environment) Reset()

func (*Environment) String

func (m *Environment) String() string

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 (*Environment_Variable) GetName

func (m *Environment_Variable) GetName() string

func (*Environment_Variable) GetValue

func (m *Environment_Variable) GetValue() string

func (*Environment_Variable) ProtoMessage

func (*Environment_Variable) ProtoMessage()

func (*Environment_Variable) Reset

func (m *Environment_Variable) Reset()

func (*Environment_Variable) String

func (m *Environment_Variable) String() string

type Event

type Event struct {
	Type    string
	Message proto.Message
}

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 (*ExecutorID) GetValue

func (m *ExecutorID) GetValue() string

func (*ExecutorID) ProtoMessage

func (*ExecutorID) ProtoMessage()

func (*ExecutorID) Reset

func (m *ExecutorID) Reset()

func (*ExecutorID) String

func (m *ExecutorID) String() string

type ExecutorInfo

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

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

func (*ExecutorInfo) GetCommand

func (m *ExecutorInfo) GetCommand() *CommandInfo

func (*ExecutorInfo) GetContainer

func (m *ExecutorInfo) GetContainer() *ContainerInfo

func (*ExecutorInfo) GetData

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

func (*ExecutorInfo) GetDiscovery

func (m *ExecutorInfo) GetDiscovery() *DiscoveryInfo

func (*ExecutorInfo) GetExecutorId

func (m *ExecutorInfo) GetExecutorId() *ExecutorID

func (*ExecutorInfo) GetFrameworkId

func (m *ExecutorInfo) GetFrameworkId() *FrameworkID

func (*ExecutorInfo) GetName

func (m *ExecutorInfo) GetName() string

func (*ExecutorInfo) GetResources

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

func (*ExecutorInfo) GetSource

func (m *ExecutorInfo) GetSource() string

func (*ExecutorInfo) ProtoMessage

func (*ExecutorInfo) ProtoMessage()

func (*ExecutorInfo) Reset

func (m *ExecutorInfo) Reset()

func (*ExecutorInfo) String

func (m *ExecutorInfo) 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 (*Filters) GetRefuseSeconds

func (m *Filters) GetRefuseSeconds() float64

func (*Filters) ProtoMessage

func (*Filters) ProtoMessage()

func (*Filters) Reset

func (m *Filters) Reset()

func (*Filters) String

func (m *Filters) 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 (*FrameworkID) GetValue

func (m *FrameworkID) GetValue() string

func (*FrameworkID) ProtoMessage

func (*FrameworkID) ProtoMessage()

func (*FrameworkID) Reset

func (m *FrameworkID) Reset()

func (*FrameworkID) String

func (m *FrameworkID) String() string

type FrameworkInfo

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

* Describes a framework.

func (*FrameworkInfo) GetCapabilities

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

func (*FrameworkInfo) GetCheckpoint

func (m *FrameworkInfo) GetCheckpoint() bool

func (*FrameworkInfo) GetFailoverTimeout

func (m *FrameworkInfo) GetFailoverTimeout() float64

func (*FrameworkInfo) GetHostname

func (m *FrameworkInfo) GetHostname() string

func (*FrameworkInfo) GetId

func (m *FrameworkInfo) GetId() *FrameworkID

func (*FrameworkInfo) GetName

func (m *FrameworkInfo) GetName() string

func (*FrameworkInfo) GetPrincipal

func (m *FrameworkInfo) GetPrincipal() string

func (*FrameworkInfo) GetRole

func (m *FrameworkInfo) GetRole() string

func (*FrameworkInfo) GetUser

func (m *FrameworkInfo) GetUser() string

func (*FrameworkInfo) GetWebuiUrl

func (m *FrameworkInfo) GetWebuiUrl() string

func (*FrameworkInfo) ProtoMessage

func (*FrameworkInfo) ProtoMessage()

func (*FrameworkInfo) Reset

func (m *FrameworkInfo) Reset()

func (*FrameworkInfo) String

func (m *FrameworkInfo) String() string

type FrameworkInfo_Capability

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

func (*FrameworkInfo_Capability) GetType

func (*FrameworkInfo_Capability) ProtoMessage

func (*FrameworkInfo_Capability) ProtoMessage()

func (*FrameworkInfo_Capability) Reset

func (m *FrameworkInfo_Capability) Reset()

func (*FrameworkInfo_Capability) String

func (m *FrameworkInfo_Capability) String() string

type FrameworkInfo_Capability_Type

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

func (FrameworkInfo_Capability_Type) Enum

func (FrameworkInfo_Capability_Type) String

func (*FrameworkInfo_Capability_Type) UnmarshalJSON

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

type FrameworkResources

type FrameworkResources struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=frameworkId" json:"frameworkId,omitempty"`
	Resources        []*Resource  `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*FrameworkResources) GetFrameworkId

func (m *FrameworkResources) GetFrameworkId() *FrameworkID

func (*FrameworkResources) GetResources

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

func (*FrameworkResources) ProtoMessage

func (*FrameworkResources) ProtoMessage()

func (*FrameworkResources) Reset

func (m *FrameworkResources) Reset()

func (*FrameworkResources) String

func (m *FrameworkResources) String() string

type Golligator

type Golligator struct {
	// contains filtered or unexported fields
}

func NewGolligator

func NewGolligator(config *Config) *Golligator

NewGolligator creates new server with specified config

func (*Golligator) Listen

func (g *Golligator) Listen() chan *Event

Listen creates new http listener and returns channel of incoming events

func (*Golligator) Send

func (g *Golligator) Send(event *Event)

Send event back to the server

type HealthCheck

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

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

func (*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) ProtoMessage

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset

func (m *HealthCheck) Reset()

func (*HealthCheck) String

func (m *HealthCheck) String() string

type HealthCheck_HTTP

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

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

func (*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) ProtoMessage

func (*HealthCheck_HTTP) ProtoMessage()

func (*HealthCheck_HTTP) Reset

func (m *HealthCheck_HTTP) Reset()

func (*HealthCheck_HTTP) String

func (m *HealthCheck_HTTP) String() string

type Label

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

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

func (*Label) GetKey

func (m *Label) GetKey() string

func (*Label) GetValue

func (m *Label) GetValue() string

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) Reset

func (m *Label) Reset()

func (*Label) String

func (m *Label) String() string

type Labels

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

* Collection of labels.

func (*Labels) GetLabels

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

func (*Labels) ProtoMessage

func (*Labels) ProtoMessage()

func (*Labels) Reset

func (m *Labels) Reset()

func (*Labels) String

func (m *Labels) 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 (*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) ProtoMessage

func (*MasterInfo) ProtoMessage()

func (*MasterInfo) Reset

func (m *MasterInfo) Reset()

func (*MasterInfo) String

func (m *MasterInfo) 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 (*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) ProtoMessage

func (*Offer) ProtoMessage()

func (*Offer) Reset

func (m *Offer) Reset()

func (*Offer) String

func (m *Offer) String() string

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 (*OfferID) GetValue

func (m *OfferID) GetValue() string

func (*OfferID) ProtoMessage

func (*OfferID) ProtoMessage()

func (*OfferID) Reset

func (m *OfferID) Reset()

func (*OfferID) String

func (m *OfferID) String() string

type Offer_Operation

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

Defines an operation that can be performed against offers.

func (*Offer_Operation) GetCreate

func (m *Offer_Operation) GetCreate() *Offer_Operation_Create

func (*Offer_Operation) GetDestroy

func (m *Offer_Operation) GetDestroy() *Offer_Operation_Destroy

func (*Offer_Operation) GetLaunch

func (m *Offer_Operation) GetLaunch() *Offer_Operation_Launch

func (*Offer_Operation) GetReserve

func (m *Offer_Operation) GetReserve() *Offer_Operation_Reserve

func (*Offer_Operation) GetType

func (*Offer_Operation) GetUnreserve

func (m *Offer_Operation) GetUnreserve() *Offer_Operation_Unreserve

func (*Offer_Operation) ProtoMessage

func (*Offer_Operation) ProtoMessage()

func (*Offer_Operation) Reset

func (m *Offer_Operation) Reset()

func (*Offer_Operation) String

func (m *Offer_Operation) String() string

type Offer_Operation_Create

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

func (*Offer_Operation_Create) GetVolumes

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

func (*Offer_Operation_Create) ProtoMessage

func (*Offer_Operation_Create) ProtoMessage()

func (*Offer_Operation_Create) Reset

func (m *Offer_Operation_Create) Reset()

func (*Offer_Operation_Create) String

func (m *Offer_Operation_Create) String() string

type Offer_Operation_Destroy

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

func (*Offer_Operation_Destroy) GetVolumes

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

func (*Offer_Operation_Destroy) ProtoMessage

func (*Offer_Operation_Destroy) ProtoMessage()

func (*Offer_Operation_Destroy) Reset

func (m *Offer_Operation_Destroy) Reset()

func (*Offer_Operation_Destroy) String

func (m *Offer_Operation_Destroy) String() string

type Offer_Operation_Launch

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

func (*Offer_Operation_Launch) GetTaskInfos

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

func (*Offer_Operation_Launch) ProtoMessage

func (*Offer_Operation_Launch) ProtoMessage()

func (*Offer_Operation_Launch) Reset

func (m *Offer_Operation_Launch) Reset()

func (*Offer_Operation_Launch) String

func (m *Offer_Operation_Launch) String() string

type Offer_Operation_Reserve

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

func (*Offer_Operation_Reserve) GetResources

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

func (*Offer_Operation_Reserve) ProtoMessage

func (*Offer_Operation_Reserve) ProtoMessage()

func (*Offer_Operation_Reserve) Reset

func (m *Offer_Operation_Reserve) Reset()

func (*Offer_Operation_Reserve) String

func (m *Offer_Operation_Reserve) String() string

type Offer_Operation_Type

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

func (Offer_Operation_Type) Enum

func (Offer_Operation_Type) String

func (x Offer_Operation_Type) String() string

func (*Offer_Operation_Type) UnmarshalJSON

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

type Offer_Operation_Unreserve

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

func (*Offer_Operation_Unreserve) GetResources

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

func (*Offer_Operation_Unreserve) ProtoMessage

func (*Offer_Operation_Unreserve) ProtoMessage()

func (*Offer_Operation_Unreserve) Reset

func (m *Offer_Operation_Unreserve) Reset()

func (*Offer_Operation_Unreserve) String

func (m *Offer_Operation_Unreserve) String() string

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 (*Parameter) GetKey

func (m *Parameter) GetKey() string

func (*Parameter) GetValue

func (m *Parameter) GetValue() string

func (*Parameter) ProtoMessage

func (*Parameter) ProtoMessage()

func (*Parameter) Reset

func (m *Parameter) Reset()

func (*Parameter) String

func (m *Parameter) String() string

type Parameters

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

* Collection of Parameter.

func (*Parameters) GetParameter

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

func (*Parameters) ProtoMessage

func (*Parameters) ProtoMessage()

func (*Parameters) Reset

func (m *Parameters) Reset()

func (*Parameters) String

func (m *Parameters) String() string

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 (*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) ProtoMessage

func (*PerfStatistics) ProtoMessage()

func (*PerfStatistics) Reset

func (m *PerfStatistics) Reset()

func (*PerfStatistics) String

func (m *PerfStatistics) String() string

type Port

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

* Named port used for service discovery.

func (*Port) GetName

func (m *Port) GetName() string

func (*Port) GetNumber

func (m *Port) GetNumber() uint32

func (*Port) GetProtocol

func (m *Port) GetProtocol() string

func (*Port) ProtoMessage

func (*Port) ProtoMessage()

func (*Port) Reset

func (m *Port) Reset()

func (*Port) String

func (m *Port) String() string

type Ports

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

* Collection of ports.

func (*Ports) GetPorts

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

func (*Ports) ProtoMessage

func (*Ports) ProtoMessage()

func (*Ports) Reset

func (m *Ports) Reset()

func (*Ports) String

func (m *Ports) String() string

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 (*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) ProtoMessage

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset

func (m *RateLimit) Reset()

func (*RateLimit) String

func (m *RateLimit) String() string

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 (*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) ProtoMessage

func (*RateLimits) ProtoMessage()

func (*RateLimits) Reset

func (m *RateLimits) Reset()

func (*RateLimits) String

func (m *RateLimits) String() string

type RecoverResources

type RecoverResources struct {
	FrameworkId      *FrameworkID `protobuf:"bytes,1,req,name=frameworkId" json:"frameworkId,omitempty"`
	SlaveId          *SlaveID     `protobuf:"bytes,2,req,name=slaveId" json:"slaveId,omitempty"`
	Filters          *Filters     `protobuf:"bytes,3,opt,name=filters" json:"filters,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

func (*RecoverResources) GetFilters

func (m *RecoverResources) GetFilters() *Filters

func (*RecoverResources) GetFrameworkId

func (m *RecoverResources) GetFrameworkId() *FrameworkID

func (*RecoverResources) GetSlaveId

func (m *RecoverResources) GetSlaveId() *SlaveID

func (*RecoverResources) ProtoMessage

func (*RecoverResources) ProtoMessage()

func (*RecoverResources) Reset

func (m *RecoverResources) Reset()

func (*RecoverResources) String

func (m *RecoverResources) String() string

type RemoveFramework

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

func (*RemoveFramework) GetFrameworkId

func (m *RemoveFramework) GetFrameworkId() *FrameworkID

func (*RemoveFramework) ProtoMessage

func (*RemoveFramework) ProtoMessage()

func (*RemoveFramework) Reset

func (m *RemoveFramework) Reset()

func (*RemoveFramework) String

func (m *RemoveFramework) String() string

type RemoveSlave

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

func (*RemoveSlave) GetSlaveId

func (m *RemoveSlave) GetSlaveId() *SlaveID

func (*RemoveSlave) ProtoMessage

func (*RemoveSlave) ProtoMessage()

func (*RemoveSlave) Reset

func (m *RemoveSlave) Reset()

func (*RemoveSlave) String

func (m *RemoveSlave) String() string

type Request

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

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

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

func (*Request) GetResources

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

func (*Request) GetSlaveId

func (m *Request) GetSlaveId() *SlaveID

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

type RequestResources

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

func (*RequestResources) GetFrameworkId

func (m *RequestResources) GetFrameworkId() *FrameworkID

func (*RequestResources) GetRequests

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

func (*RequestResources) ProtoMessage

func (*RequestResources) ProtoMessage()

func (*RequestResources) Reset

func (m *RequestResources) Reset()

func (*RequestResources) String

func (m *RequestResources) 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=golligator.Value_Type" json:"type,omitempty"`
	Scalar *Value_Scalar `protobuf:"bytes,3,opt,name=scalar" json:"scalar,omitempty"`
	Ranges *Value_Ranges `protobuf:"bytes,4,opt,name=ranges" json:"ranges,omitempty"`
	Set    *Value_Set    `protobuf:"bytes,5,opt,name=set" json:"set,omitempty"`
	Role   *string       `protobuf:"bytes,6,opt,name=role,def=*" json:"role,omitempty"`
	// If this is set, this resource was dynamically reserved by an
	// operator or a framework. Otherwise, this resource is either unreserved
	// or statically reserved by an operator via the --resources flag.
	Reservation *Resource_ReservationInfo `protobuf:"bytes,8,opt,name=reservation" json:"reservation,omitempty"`
	Disk        *Resource_DiskInfo        `protobuf:"bytes,7,opt,name=disk" json:"disk,omitempty"`
	// If this is set, the resources are revocable, i.e., any tasks or
	// executors launched using these resources could get preempted or
	// throttled at any time. This could be used by frameworks to run
	// best effort tasks that do not need strict uptime or performance
	// guarantees. Note that if this is set, 'disk' or 'reservation'
	// cannot be set.
	Revocable        *Resource_RevocableInfo `protobuf:"bytes,9,opt,name=revocable" json:"revocable,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

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

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

func (*Resource) GetDisk

func (m *Resource) GetDisk() *Resource_DiskInfo

func (*Resource) GetName

func (m *Resource) GetName() string

func (*Resource) GetRanges

func (m *Resource) GetRanges() *Value_Ranges

func (*Resource) GetReservation

func (m *Resource) GetReservation() *Resource_ReservationInfo

func (*Resource) GetRevocable

func (m *Resource) GetRevocable() *Resource_RevocableInfo

func (*Resource) GetRole

func (m *Resource) GetRole() string

func (*Resource) GetScalar

func (m *Resource) GetScalar() *Value_Scalar

func (*Resource) GetSet

func (m *Resource) GetSet() *Value_Set

func (*Resource) GetType

func (m *Resource) GetType() Value_Type

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) Reset

func (m *Resource) Reset()

func (*Resource) String

func (m *Resource) String() string

type ResourceStatistics

type ResourceStatistics struct {
	Timestamp *float64 `protobuf:"fixed64,1,req,name=timestamp" json:"timestamp,omitempty"`
	Processes *uint32  `protobuf:"varint,30,opt,name=processes" json:"processes,omitempty"`
	Threads   *uint32  `protobuf:"varint,31,opt,name=threads" json:"threads,omitempty"`
	// CPU Usage Information:
	// Total CPU time spent in user mode, and kernel mode.
	CpusUserTimeSecs   *float64 `protobuf:"fixed64,2,opt,name=cpus_user_time_secs" json:"cpus_user_time_secs,omitempty"`
	CpusSystemTimeSecs *float64 `protobuf:"fixed64,3,opt,name=cpus_system_time_secs" json:"cpus_system_time_secs,omitempty"`
	// Number of CPUs allocated.
	CpusLimit *float64 `protobuf:"fixed64,4,opt,name=cpus_limit" json:"cpus_limit,omitempty"`
	// cpu.stat on process throttling (for contention issues).
	CpusNrPeriods         *uint32  `protobuf:"varint,7,opt,name=cpus_nr_periods" json:"cpus_nr_periods,omitempty"`
	CpusNrThrottled       *uint32  `protobuf:"varint,8,opt,name=cpus_nr_throttled" json:"cpus_nr_throttled,omitempty"`
	CpusThrottledTimeSecs *float64 `protobuf:"fixed64,9,opt,name=cpus_throttled_time_secs" json:"cpus_throttled_time_secs,omitempty"`
	// 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"`
	// Number of occurrences of different levels of memory pressure
	// events reported by memory cgroup. Pressure listening (re)starts
	// with these values set to 0 when slave (re)starts. See
	// https://www.kernel.org/doc/Documentation/cgroups/memory.txt for
	// more details.
	MemLowPressureCounter      *uint64 `protobuf:"varint,32,opt,name=mem_low_pressure_counter" json:"mem_low_pressure_counter,omitempty"`
	MemMediumPressureCounter   *uint64 `protobuf:"varint,33,opt,name=mem_medium_pressure_counter" json:"mem_medium_pressure_counter,omitempty"`
	MemCriticalPressureCounter *uint64 `protobuf:"varint,34,opt,name=mem_critical_pressure_counter" json:"mem_critical_pressure_counter,omitempty"`
	// Disk Usage Information for executor working directory.
	DiskLimitBytes *uint64 `protobuf:"varint,26,opt,name=disk_limit_bytes" json:"disk_limit_bytes,omitempty"`
	DiskUsedBytes  *uint64 `protobuf:"varint,27,opt,name=disk_used_bytes" json:"disk_used_bytes,omitempty"`
	// Perf statistics.
	Perf *PerfStatistics `protobuf:"bytes,13,opt,name=perf" json:"perf,omitempty"`
	// Network Usage Information:
	NetRxPackets *uint64 `protobuf:"varint,14,opt,name=net_rx_packets" json:"net_rx_packets,omitempty"`
	NetRxBytes   *uint64 `protobuf:"varint,15,opt,name=net_rx_bytes" json:"net_rx_bytes,omitempty"`
	NetRxErrors  *uint64 `protobuf:"varint,16,opt,name=net_rx_errors" json:"net_rx_errors,omitempty"`
	NetRxDropped *uint64 `protobuf:"varint,17,opt,name=net_rx_dropped" json:"net_rx_dropped,omitempty"`
	NetTxPackets *uint64 `protobuf:"varint,18,opt,name=net_tx_packets" json:"net_tx_packets,omitempty"`
	NetTxBytes   *uint64 `protobuf:"varint,19,opt,name=net_tx_bytes" json:"net_tx_bytes,omitempty"`
	NetTxErrors  *uint64 `protobuf:"varint,20,opt,name=net_tx_errors" json:"net_tx_errors,omitempty"`
	NetTxDropped *uint64 `protobuf:"varint,21,opt,name=net_tx_dropped" json:"net_tx_dropped,omitempty"`
	// The kernel keeps track of RTT (round-trip time) for its TCP
	// sockets. RTT is a way to tell the latency of a container.
	NetTcpRttMicrosecsP50     *float64 `protobuf:"fixed64,22,opt,name=net_tcp_rtt_microsecs_p50" json:"net_tcp_rtt_microsecs_p50,omitempty"`
	NetTcpRttMicrosecsP90     *float64 `protobuf:"fixed64,23,opt,name=net_tcp_rtt_microsecs_p90" json:"net_tcp_rtt_microsecs_p90,omitempty"`
	NetTcpRttMicrosecsP95     *float64 `protobuf:"fixed64,24,opt,name=net_tcp_rtt_microsecs_p95" json:"net_tcp_rtt_microsecs_p95,omitempty"`
	NetTcpRttMicrosecsP99     *float64 `protobuf:"fixed64,25,opt,name=net_tcp_rtt_microsecs_p99" json:"net_tcp_rtt_microsecs_p99,omitempty"`
	NetTcpActiveConnections   *float64 `protobuf:"fixed64,28,opt,name=net_tcp_active_connections" json:"net_tcp_active_connections,omitempty"`
	NetTcpTimeWaitConnections *float64 `protobuf:"fixed64,29,opt,name=net_tcp_time_wait_connections" json:"net_tcp_time_wait_connections,omitempty"`
	// Network traffic flowing into or out of a container can be delayed
	// or dropped due to congestion or policy inside and outside the
	// container.
	NetTrafficControlStatistics []*TrafficControlStatistics `protobuf:"bytes,35,rep,name=net_traffic_control_statistics" json:"net_traffic_control_statistics,omitempty"`
	XXX_unrecognized            []byte                      `json:"-"`
}

A snapshot of resource usage statistics.

func (*ResourceStatistics) GetCpusLimit

func (m *ResourceStatistics) GetCpusLimit() float64

func (*ResourceStatistics) GetCpusNrPeriods

func (m *ResourceStatistics) GetCpusNrPeriods() uint32

func (*ResourceStatistics) GetCpusNrThrottled

func (m *ResourceStatistics) GetCpusNrThrottled() uint32

func (*ResourceStatistics) GetCpusSystemTimeSecs

func (m *ResourceStatistics) GetCpusSystemTimeSecs() float64

func (*ResourceStatistics) GetCpusThrottledTimeSecs

func (m *ResourceStatistics) GetCpusThrottledTimeSecs() float64

func (*ResourceStatistics) GetCpusUserTimeSecs

func (m *ResourceStatistics) GetCpusUserTimeSecs() float64

func (*ResourceStatistics) GetDiskLimitBytes

func (m *ResourceStatistics) GetDiskLimitBytes() uint64

func (*ResourceStatistics) GetDiskUsedBytes

func (m *ResourceStatistics) GetDiskUsedBytes() uint64

func (*ResourceStatistics) GetMemAnonBytes

func (m *ResourceStatistics) GetMemAnonBytes() uint64

func (*ResourceStatistics) GetMemCriticalPressureCounter

func (m *ResourceStatistics) GetMemCriticalPressureCounter() uint64

func (*ResourceStatistics) GetMemFileBytes

func (m *ResourceStatistics) GetMemFileBytes() uint64

func (*ResourceStatistics) GetMemLimitBytes

func (m *ResourceStatistics) GetMemLimitBytes() uint64

func (*ResourceStatistics) GetMemLowPressureCounter

func (m *ResourceStatistics) GetMemLowPressureCounter() uint64

func (*ResourceStatistics) GetMemMappedFileBytes

func (m *ResourceStatistics) GetMemMappedFileBytes() uint64

func (*ResourceStatistics) GetMemMediumPressureCounter

func (m *ResourceStatistics) GetMemMediumPressureCounter() 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) GetNetTcpActiveConnections

func (m *ResourceStatistics) GetNetTcpActiveConnections() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP50

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP50() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP90

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP90() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP95

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP95() float64

func (*ResourceStatistics) GetNetTcpRttMicrosecsP99

func (m *ResourceStatistics) GetNetTcpRttMicrosecsP99() float64

func (*ResourceStatistics) GetNetTcpTimeWaitConnections

func (m *ResourceStatistics) GetNetTcpTimeWaitConnections() float64

func (*ResourceStatistics) GetNetTrafficControlStatistics

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

func (*ResourceStatistics) GetNetTxBytes

func (m *ResourceStatistics) GetNetTxBytes() uint64

func (*ResourceStatistics) GetNetTxDropped

func (m *ResourceStatistics) GetNetTxDropped() uint64

func (*ResourceStatistics) GetNetTxErrors

func (m *ResourceStatistics) GetNetTxErrors() uint64

func (*ResourceStatistics) GetNetTxPackets

func (m *ResourceStatistics) GetNetTxPackets() uint64

func (*ResourceStatistics) GetPerf

func (m *ResourceStatistics) GetPerf() *PerfStatistics

func (*ResourceStatistics) GetProcesses

func (m *ResourceStatistics) GetProcesses() uint32

func (*ResourceStatistics) GetThreads

func (m *ResourceStatistics) GetThreads() uint32

func (*ResourceStatistics) GetTimestamp

func (m *ResourceStatistics) GetTimestamp() float64

func (*ResourceStatistics) ProtoMessage

func (*ResourceStatistics) ProtoMessage()

func (*ResourceStatistics) Reset

func (m *ResourceStatistics) Reset()

func (*ResourceStatistics) String

func (m *ResourceStatistics) String() string

type ResourceUsage

type ResourceUsage struct {
	// Source of the collected statistics.
	ExecutorInfo *ExecutorInfo `protobuf:"bytes,1,opt,name=executor_info" json:"executor_info,omitempty"`
	// Current resource usage.
	// If missing, the isolation module cannot provide resource usage.
	Statistics       *ResourceStatistics `protobuf:"bytes,2,opt,name=statistics" json:"statistics,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

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

func (*ResourceUsage) GetExecutorInfo

func (m *ResourceUsage) GetExecutorInfo() *ExecutorInfo

func (*ResourceUsage) GetStatistics

func (m *ResourceUsage) GetStatistics() *ResourceStatistics

func (*ResourceUsage) ProtoMessage

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset

func (m *ResourceUsage) Reset()

func (*ResourceUsage) String

func (m *ResourceUsage) String() string

type Resource_DiskInfo

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

func (*Resource_DiskInfo) GetPersistence

func (m *Resource_DiskInfo) GetPersistence() *Resource_DiskInfo_Persistence

func (*Resource_DiskInfo) GetVolume

func (m *Resource_DiskInfo) GetVolume() *Volume

func (*Resource_DiskInfo) ProtoMessage

func (*Resource_DiskInfo) ProtoMessage()

func (*Resource_DiskInfo) Reset

func (m *Resource_DiskInfo) Reset()

func (*Resource_DiskInfo) String

func (m *Resource_DiskInfo) String() string

type Resource_DiskInfo_Persistence

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

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

func (*Resource_DiskInfo_Persistence) GetId

func (*Resource_DiskInfo_Persistence) ProtoMessage

func (*Resource_DiskInfo_Persistence) ProtoMessage()

func (*Resource_DiskInfo_Persistence) Reset

func (m *Resource_DiskInfo_Persistence) Reset()

func (*Resource_DiskInfo_Persistence) String

type Resource_ReservationInfo

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

func (*Resource_ReservationInfo) GetPrincipal

func (m *Resource_ReservationInfo) GetPrincipal() string

func (*Resource_ReservationInfo) ProtoMessage

func (*Resource_ReservationInfo) ProtoMessage()

func (*Resource_ReservationInfo) Reset

func (m *Resource_ReservationInfo) Reset()

func (*Resource_ReservationInfo) String

func (m *Resource_ReservationInfo) String() string

type Resource_RevocableInfo

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

func (*Resource_RevocableInfo) ProtoMessage

func (*Resource_RevocableInfo) ProtoMessage()

func (*Resource_RevocableInfo) Reset

func (m *Resource_RevocableInfo) Reset()

func (*Resource_RevocableInfo) String

func (m *Resource_RevocableInfo) String() string

type ReviveOffers

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

func (*ReviveOffers) GetFrameworkId

func (m *ReviveOffers) GetFrameworkId() *FrameworkID

func (*ReviveOffers) ProtoMessage

func (*ReviveOffers) ProtoMessage()

func (*ReviveOffers) Reset

func (m *ReviveOffers) Reset()

func (*ReviveOffers) String

func (m *ReviveOffers) 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 (*SlaveID) GetValue

func (m *SlaveID) GetValue() string

func (*SlaveID) ProtoMessage

func (*SlaveID) ProtoMessage()

func (*SlaveID) Reset

func (m *SlaveID) Reset()

func (*SlaveID) String

func (m *SlaveID) String() string

type SlaveInfo

type SlaveInfo struct {
	Hostname   *string      `protobuf:"bytes,1,req,name=hostname" json:"hostname,omitempty"`
	Port       *int32       `protobuf:"varint,8,opt,name=port,def=5051" json:"port,omitempty"`
	Resources  []*Resource  `protobuf:"bytes,3,rep,name=resources" json:"resources,omitempty"`
	Attributes []*Attribute `protobuf:"bytes,5,rep,name=attributes" json:"attributes,omitempty"`
	Id         *SlaveID     `protobuf:"bytes,6,opt,name=id" json:"id,omitempty"`
	// TODO(joerg84): Remove checkpoint field as with 0.22.0
	// slave checkpointing is enabled for all slaves (MESOS-2317).
	Checkpoint       *bool  `protobuf:"varint,7,opt,name=checkpoint,def=0" json:"checkpoint,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

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

func (*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) ProtoMessage

func (*SlaveInfo) ProtoMessage()

func (*SlaveInfo) Reset

func (m *SlaveInfo) Reset()

func (*SlaveInfo) String

func (m *SlaveInfo) String() string

type SlaveResources

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

func (*SlaveResources) GetResources

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

func (*SlaveResources) GetSlaveId

func (m *SlaveResources) GetSlaveId() *SlaveID

func (*SlaveResources) ProtoMessage

func (*SlaveResources) ProtoMessage()

func (*SlaveResources) Reset

func (m *SlaveResources) Reset()

func (*SlaveResources) String

func (m *SlaveResources) 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 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 (*TaskID) GetValue

func (m *TaskID) GetValue() string

func (*TaskID) ProtoMessage

func (*TaskID) ProtoMessage()

func (*TaskID) Reset

func (m *TaskID) Reset()

func (*TaskID) String

func (m *TaskID) String() string

type TaskInfo

type TaskInfo struct {
	Name      *string       `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	TaskId    *TaskID       `protobuf:"bytes,2,req,name=task_id" json:"task_id,omitempty"`
	SlaveId   *SlaveID      `protobuf:"bytes,3,req,name=slave_id" json:"slave_id,omitempty"`
	Resources []*Resource   `protobuf:"bytes,4,rep,name=resources" json:"resources,omitempty"`
	Executor  *ExecutorInfo `protobuf:"bytes,5,opt,name=executor" json:"executor,omitempty"`
	Command   *CommandInfo  `protobuf:"bytes,7,opt,name=command" json:"command,omitempty"`
	// Task provided with a container will launch the container as part
	// of this task paired with the task's CommandInfo.
	Container *ContainerInfo `protobuf:"bytes,9,opt,name=container" json:"container,omitempty"`
	Data      []byte         `protobuf:"bytes,6,opt,name=data" json:"data,omitempty"`
	// A health check for the task (currently in *alpha* and initial
	// support will only be for TaskInfo's that have a CommandInfo).
	HealthCheck *HealthCheck `protobuf:"bytes,8,opt,name=health_check" json:"health_check,omitempty"`
	// Labels are free-form key value pairs which are exposed through
	// master and slave endpoints. Labels will not be interpreted or
	// acted upon by Mesos itself. As opposed to the data field, labels
	// will be kept in memory on master and slave processes. Therefore,
	// labels should be used to tag tasks with light-weight meta-data.
	Labels *Labels `protobuf:"bytes,10,opt,name=labels" json:"labels,omitempty"`
	// Service discovery information for the task. It is not interpreted
	// or acted upon by Mesos. It is up to a service discovery system
	// to use this information as needed and to handle tasks without
	// service discovery information.
	Discovery        *DiscoveryInfo `protobuf:"bytes,11,opt,name=discovery" json:"discovery,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

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

func (*TaskInfo) GetCommand

func (m *TaskInfo) GetCommand() *CommandInfo

func (*TaskInfo) GetContainer

func (m *TaskInfo) GetContainer() *ContainerInfo

func (*TaskInfo) GetData

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

func (*TaskInfo) GetDiscovery

func (m *TaskInfo) GetDiscovery() *DiscoveryInfo

func (*TaskInfo) GetExecutor

func (m *TaskInfo) GetExecutor() *ExecutorInfo

func (*TaskInfo) GetHealthCheck

func (m *TaskInfo) GetHealthCheck() *HealthCheck

func (*TaskInfo) GetLabels

func (m *TaskInfo) GetLabels() *Labels

func (*TaskInfo) GetName

func (m *TaskInfo) GetName() string

func (*TaskInfo) GetResources

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

func (*TaskInfo) GetSlaveId

func (m *TaskInfo) GetSlaveId() *SlaveID

func (*TaskInfo) GetTaskId

func (m *TaskInfo) GetTaskId() *TaskID

func (*TaskInfo) ProtoMessage

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset

func (m *TaskInfo) Reset()

func (*TaskInfo) String

func (m *TaskInfo) String() string

type TaskState

type TaskState int32

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

const (
	TaskState_TASK_STAGING  TaskState = 6
	TaskState_TASK_STARTING TaskState = 0
	TaskState_TASK_RUNNING  TaskState = 1
	TaskState_TASK_FINISHED TaskState = 2
	TaskState_TASK_FAILED   TaskState = 3
	TaskState_TASK_KILLED   TaskState = 4
	TaskState_TASK_LOST     TaskState = 5
	TaskState_TASK_ERROR    TaskState = 7
)

func (TaskState) Enum

func (x TaskState) Enum() *TaskState

func (TaskState) String

func (x TaskState) String() string

func (*TaskState) UnmarshalJSON

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

type TaskStatus

type TaskStatus struct {
	TaskId     *TaskID            `protobuf:"bytes,1,req,name=task_id" json:"task_id,omitempty"`
	State      *TaskState         `protobuf:"varint,2,req,name=state,enum=golligator.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=golligator.TaskStatus_Source" json:"source,omitempty"`
	Reason     *TaskStatus_Reason `protobuf:"varint,10,opt,name=reason,enum=golligator.TaskStatus_Reason" json:"reason,omitempty"`
	Data       []byte             `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	SlaveId    *SlaveID           `protobuf:"bytes,5,opt,name=slave_id" json:"slave_id,omitempty"`
	ExecutorId *ExecutorID        `protobuf:"bytes,7,opt,name=executor_id" json:"executor_id,omitempty"`
	Timestamp  *float64           `protobuf:"fixed64,6,opt,name=timestamp" json:"timestamp,omitempty"`
	// Statuses that are delivered reliably to the scheduler will
	// include a 'uuid'. The status is considered delivered once
	// it is acknowledged by the scheduler. Schedulers can choose
	// to either explicitly acknowledge statuses or let the scheduler
	// driver implicitly acknowledge (default).
	//
	// TODO(bmahler): This is currently overwritten in the scheduler
	// driver, even if executors set this.
	Uuid []byte `protobuf:"bytes,11,opt,name=uuid" json:"uuid,omitempty"`
	// Describes whether the task has been determined to be healthy
	// (true) or unhealthy (false) according to the HealthCheck field in
	// the command info.
	Healthy          *bool  `protobuf:"varint,8,opt,name=healthy" json:"healthy,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* Describes the current status of a task.

func (*TaskStatus) GetData

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

func (*TaskStatus) GetExecutorId

func (m *TaskStatus) GetExecutorId() *ExecutorID

func (*TaskStatus) GetHealthy

func (m *TaskStatus) GetHealthy() bool

func (*TaskStatus) GetMessage

func (m *TaskStatus) GetMessage() string

func (*TaskStatus) GetReason

func (m *TaskStatus) GetReason() TaskStatus_Reason

func (*TaskStatus) GetSlaveId

func (m *TaskStatus) GetSlaveId() *SlaveID

func (*TaskStatus) GetSource

func (m *TaskStatus) GetSource() TaskStatus_Source

func (*TaskStatus) GetState

func (m *TaskStatus) GetState() TaskState

func (*TaskStatus) GetTaskId

func (m *TaskStatus) GetTaskId() *TaskID

func (*TaskStatus) GetTimestamp

func (m *TaskStatus) GetTimestamp() float64

func (*TaskStatus) GetUuid

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

func (*TaskStatus) ProtoMessage

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset

func (m *TaskStatus) Reset()

func (*TaskStatus) String

func (m *TaskStatus) String() string

type TaskStatus_Reason

type TaskStatus_Reason int32

Detailed reason for the task status update.

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

const (
	TaskStatus_REASON_COMMAND_EXECUTOR_FAILED TaskStatus_Reason = 0
	TaskStatus_REASON_EXECUTOR_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 TrafficControlStatistics

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

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

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

locking or device contention issues

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

func (*TrafficControlStatistics) GetBacklog

func (m *TrafficControlStatistics) GetBacklog() uint64

func (*TrafficControlStatistics) GetBytes

func (m *TrafficControlStatistics) GetBytes() uint64

func (*TrafficControlStatistics) GetDrops

func (m *TrafficControlStatistics) GetDrops() uint64

func (*TrafficControlStatistics) GetId

func (m *TrafficControlStatistics) GetId() string

func (*TrafficControlStatistics) GetOverlimits

func (m *TrafficControlStatistics) GetOverlimits() uint64

func (*TrafficControlStatistics) GetPackets

func (m *TrafficControlStatistics) GetPackets() uint64

func (*TrafficControlStatistics) GetQlen

func (m *TrafficControlStatistics) GetQlen() uint64

func (*TrafficControlStatistics) GetRatebps

func (m *TrafficControlStatistics) GetRatebps() uint64

func (*TrafficControlStatistics) GetRatepps

func (m *TrafficControlStatistics) GetRatepps() uint64

func (*TrafficControlStatistics) GetRequeues

func (m *TrafficControlStatistics) GetRequeues() uint64

func (*TrafficControlStatistics) ProtoMessage

func (*TrafficControlStatistics) ProtoMessage()

func (*TrafficControlStatistics) Reset

func (m *TrafficControlStatistics) Reset()

func (*TrafficControlStatistics) String

func (m *TrafficControlStatistics) String() string

type UpdateAllocation

type UpdateAllocation struct {
	FrameworkId      *FrameworkID       `protobuf:"bytes,1,req,name=frameworkId" json:"frameworkId,omitempty"`
	SlaveId          *SlaveID           `protobuf:"bytes,2,req,name=slaveId" json:"slaveId,omitempty"`
	Operations       []*Offer_Operation `protobuf:"bytes,3,rep,name=operations" json:"operations,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*UpdateAllocation) GetFrameworkId

func (m *UpdateAllocation) GetFrameworkId() *FrameworkID

func (*UpdateAllocation) GetOperations

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

func (*UpdateAllocation) GetSlaveId

func (m *UpdateAllocation) GetSlaveId() *SlaveID

func (*UpdateAllocation) ProtoMessage

func (*UpdateAllocation) ProtoMessage()

func (*UpdateAllocation) Reset

func (m *UpdateAllocation) Reset()

func (*UpdateAllocation) String

func (m *UpdateAllocation) String() string

type UpdateSlave

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

func (*UpdateSlave) GetResources

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

func (*UpdateSlave) GetSlaveId

func (m *UpdateSlave) GetSlaveId() *SlaveID

func (*UpdateSlave) ProtoMessage

func (*UpdateSlave) ProtoMessage()

func (*UpdateSlave) Reset

func (m *UpdateSlave) Reset()

func (*UpdateSlave) String

func (m *UpdateSlave) String() string

type UpdateWhitelist

type UpdateWhitelist struct {
	Whitelist        []string `protobuf:"bytes,1,rep,name=whitelist" json:"whitelist,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*UpdateWhitelist) GetWhitelist

func (m *UpdateWhitelist) GetWhitelist() []string

func (*UpdateWhitelist) ProtoMessage

func (*UpdateWhitelist) ProtoMessage()

func (*UpdateWhitelist) Reset

func (m *UpdateWhitelist) Reset()

func (*UpdateWhitelist) String

func (m *UpdateWhitelist) String() string

type Value

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

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) String

func (m *Value) String() string

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 (*Value_Range) GetBegin

func (m *Value_Range) GetBegin() uint64

func (*Value_Range) GetEnd

func (m *Value_Range) GetEnd() uint64

func (*Value_Range) ProtoMessage

func (*Value_Range) ProtoMessage()

func (*Value_Range) Reset

func (m *Value_Range) Reset()

func (*Value_Range) String

func (m *Value_Range) String() string

type Value_Ranges

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

func (*Value_Ranges) GetRange

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

func (*Value_Ranges) ProtoMessage

func (*Value_Ranges) ProtoMessage()

func (*Value_Ranges) Reset

func (m *Value_Ranges) Reset()

func (*Value_Ranges) String

func (m *Value_Ranges) String() string

type Value_Scalar

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

func (*Value_Scalar) GetValue

func (m *Value_Scalar) GetValue() float64

func (*Value_Scalar) ProtoMessage

func (*Value_Scalar) ProtoMessage()

func (*Value_Scalar) Reset

func (m *Value_Scalar) Reset()

func (*Value_Scalar) String

func (m *Value_Scalar) String() string

type Value_Set

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

func (*Value_Set) GetItem

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

func (*Value_Set) ProtoMessage

func (*Value_Set) ProtoMessage()

func (*Value_Set) Reset

func (m *Value_Set) Reset()

func (*Value_Set) String

func (m *Value_Set) String() string

type Value_Text

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

func (*Value_Text) GetValue

func (m *Value_Text) GetValue() string

func (*Value_Text) ProtoMessage

func (*Value_Text) ProtoMessage()

func (*Value_Text) Reset

func (m *Value_Text) Reset()

func (*Value_Text) String

func (m *Value_Text) String() string

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=golligator.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 (*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) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) Reset

func (m *Volume) Reset()

func (*Volume) String

func (m *Volume) String() string

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

Jump to

Keyboard shortcuts

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