allocator

package

v0.0.11 Latest Latest Go to latest Published: May 15, 2020 License: Apache-2.0 Imports: 11 Imported by: 8

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mesos/mesos-go

Links

Open Source Insights

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
type InverseOfferStatus_Status

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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

View Source

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

Functions ¶

This section is empty.

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 ¶ added in v0.0.11

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

Source Files ¶

View all Source files

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