allocator

Documentation

Overview

Package allocator is a generated protocol buffer package.

It is generated from these files:

allocator/allocator.proto

It has these top-level messages:

InverseOfferStatus

Index

• Variables
• type InverseOfferStatus
  • func NewPopulatedInverseOfferStatus(r randyAllocator, easy bool) *InverseOfferStatus
  • func (*InverseOfferStatus) Descriptor() ([]byte, []int)
  • func (this *InverseOfferStatus) Equal(that interface{}) bool
  • func (m *InverseOfferStatus) GetFrameworkID() mesos.FrameworkID
  • func (m *InverseOfferStatus) GetStatus() InverseOfferStatus_Status
  • func (m *InverseOfferStatus) GetTimestamp() mesos.TimeInfo
  • func (this *InverseOfferStatus) GoString() string
  • func (m *InverseOfferStatus) Marshal() (dAtA []byte, err error)
  • func (mj *InverseOfferStatus) MarshalJSON() ([]byte, error)
  • func (mj *InverseOfferStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error
  • func (m *InverseOfferStatus) MarshalTo(dAtA []byte) (int, error)
  • func (*InverseOfferStatus) ProtoMessage()
  • func (m *InverseOfferStatus) Reset()
  • func (m *InverseOfferStatus) Size() (n int)
  • func (this *InverseOfferStatus) String() string
  • func (m *InverseOfferStatus) Unmarshal(dAtA []byte) error
  • func (uj *InverseOfferStatus) UnmarshalJSON(input []byte) error
  • func (uj *InverseOfferStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
  • func (this *InverseOfferStatus) VerboseEqual(that interface{}) error
• type InverseOfferStatus_Status
  • func (x InverseOfferStatus_Status) Enum() *InverseOfferStatus_Status
  • func (InverseOfferStatus_Status) EnumDescriptor() ([]byte, []int)
  • func (x InverseOfferStatus_Status) MarshalJSON() ([]byte, error)
  • func (x InverseOfferStatus_Status) String() string
  • func (x *InverseOfferStatus_Status) UnmarshalJSON(data []byte) error

Variables

var (
	ErrInvalidLengthAllocator = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAllocator   = fmt.Errorf("proto: integer overflow")
)

var InverseOfferStatus_Status_name = map[int32]string{
	1: "UNKNOWN",
	2: "ACCEPT",
	3: "DECLINE",
}

var InverseOfferStatus_Status_value = map[string]int32{
	"UNKNOWN": 1,
	"ACCEPT":  2,
	"DECLINE": 3,
}

Types

type InverseOfferStatus

type InverseOfferStatus struct {
	Status      *InverseOfferStatus_Status `protobuf:"varint,1,req,name=status,enum=mesos.allocator.InverseOfferStatus_Status" json:"status,omitempty"`
	FrameworkID mesos.FrameworkID          `protobuf:"bytes,2,req,name=framework_id,json=frameworkId" json:"framework_id"`
	// Time, since the epoch, when this status was last updated.
	Timestamp mesos.TimeInfo `protobuf:"bytes,3,req,name=timestamp" json:"timestamp"`
}

* Describes the status of an inverse offer.

This is a protobuf so as to be able to share the status to inverse offers through endpoints such as the maintenance status endpoint.

func NewPopulatedInverseOfferStatus

func NewPopulatedInverseOfferStatus(r randyAllocator, easy bool) *InverseOfferStatus

func (*InverseOfferStatus) Descriptor

func (*InverseOfferStatus) Descriptor() ([]byte, []int)

func (*InverseOfferStatus) Equal

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

func (*InverseOfferStatus) GetFrameworkID

func (m *InverseOfferStatus) GetFrameworkID() mesos.FrameworkID

func (*InverseOfferStatus) GetStatus

func (m *InverseOfferStatus) GetStatus() InverseOfferStatus_Status

func (*InverseOfferStatus) GetTimestamp

func (m *InverseOfferStatus) GetTimestamp() mesos.TimeInfo

func (*InverseOfferStatus) GoString

func (this *InverseOfferStatus) GoString() string

func (*InverseOfferStatus) Marshal

func (m *InverseOfferStatus) Marshal() (dAtA []byte, err error)

func (*InverseOfferStatus) MarshalJSON

func (mj *InverseOfferStatus) MarshalJSON() ([]byte, error)

func (*InverseOfferStatus) MarshalJSONBuf

func (mj *InverseOfferStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*InverseOfferStatus) MarshalTo

func (m *InverseOfferStatus) MarshalTo(dAtA []byte) (int, error)

func (*InverseOfferStatus) ProtoMessage

func (*InverseOfferStatus) ProtoMessage()

func (*InverseOfferStatus) Reset

func (m *InverseOfferStatus) Reset()

func (*InverseOfferStatus) Size

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

func (*InverseOfferStatus) String

func (this *InverseOfferStatus) String() string

func (*InverseOfferStatus) Unmarshal

func (m *InverseOfferStatus) Unmarshal(dAtA []byte) error

func (*InverseOfferStatus) UnmarshalJSON

func (uj *InverseOfferStatus) UnmarshalJSON(input []byte) error

func (*InverseOfferStatus) UnmarshalJSONFFLexer

func (uj *InverseOfferStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

func (*InverseOfferStatus) VerboseEqual

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

type InverseOfferStatus_Status

type InverseOfferStatus_Status int32

const (
	// We have not received a response yet. This is the default state before
	// receiving a response.
	InverseOfferStatus_UNKNOWN InverseOfferStatus_Status = 1
	// The framework is ok with the inverse offer. This means it will not
	// violate any SLAs and will attempt to evacuate any tasks running on the
	// agent. If the tasks are not evacuated by the framework, the operator can
	// manually shut down the slave knowing that the framework will not have
	// violated its SLAs.
	InverseOfferStatus_ACCEPT InverseOfferStatus_Status = 2
	// The framework wants to block the maintenance operation from happening. An
	// example would be that it cannot meet its SLA by losing resources.
	InverseOfferStatus_DECLINE InverseOfferStatus_Status = 3
)

func (InverseOfferStatus_Status) Enum

func (x InverseOfferStatus_Status) Enum() *InverseOfferStatus_Status

func (InverseOfferStatus_Status) EnumDescriptor

func (InverseOfferStatus_Status) EnumDescriptor() ([]byte, []int)

func (InverseOfferStatus_Status) MarshalJSON

func (x InverseOfferStatus_Status) MarshalJSON() ([]byte, error)

func (InverseOfferStatus_Status) String

func (x InverseOfferStatus_Status) String() string

func (*InverseOfferStatus_Status) UnmarshalJSON

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