quota

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2018 License: Apache-2.0 Imports: 11 Imported by: 10

Documentation

Overview

Package quota is a generated protocol buffer package.

It is generated from these files: 

quota/quota.proto

It has these top-level messages: 

QuotaInfo
QuotaRequest
QuotaStatus

Index

Constants

View Source 
const Default_QuotaRequest_Force bool = false

Variables

View Source 
var (
	ErrInvalidLengthQuota = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuota   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type QuotaInfo 

type QuotaInfo struct {
	// Quota is granted per role and not per framework, similar to
	// dynamic reservations.
	Role *string `protobuf:"bytes,1,opt,name=role" json:"role,omitempty"`
	// Principal which set the quota. Currently only operators can set quotas.
	Principal *string `protobuf:"bytes,2,opt,name=principal" json:"principal,omitempty"`
	// The guarantee that these resources are allocatable for the above role.
	// NOTE: `guarantee.role` should not specify any role except '*',
	// because quota does not reserve specific resources.
	Guarantee []mesos.Resource `protobuf:"bytes,3,rep,name=guarantee" json:"guarantee"`
}

TODO(joerg84): Add limits, i.e. upper bounds of resources that a role is allowed to use.

func NewPopulatedQuotaInfo 

func NewPopulatedQuotaInfo(r randyQuota, easy bool) *QuotaInfo

func (*QuotaInfo) Descriptor 

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

func (*QuotaInfo) Equal 

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

func (*QuotaInfo) GetGuarantee 

func (m *QuotaInfo) GetGuarantee() []mesos.Resource

func (*QuotaInfo) GetPrincipal 

func (m *QuotaInfo) GetPrincipal() string

func (*QuotaInfo) GetRole 

func (m *QuotaInfo) GetRole() string

func (*QuotaInfo) GoString 

func (this *QuotaInfo) GoString() string

func (*QuotaInfo) Marshal 

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

func (*QuotaInfo) MarshalJSON 

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

func (*QuotaInfo) MarshalJSONBuf 

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

func (*QuotaInfo) MarshalTo 

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

func (*QuotaInfo) ProtoMessage 

func (*QuotaInfo) ProtoMessage()

func (*QuotaInfo) ProtoSize 

func (m *QuotaInfo) ProtoSize() (n int)

func (*QuotaInfo) Reset 

func (m *QuotaInfo) Reset()

func (*QuotaInfo) String 

func (this *QuotaInfo) String() string

func (*QuotaInfo) Unmarshal 

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

func (*QuotaInfo) UnmarshalJSON 

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

func (*QuotaInfo) UnmarshalJSONFFLexer 

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

func (*QuotaInfo) VerboseEqual 

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

type QuotaRequest 

type QuotaRequest struct {
	// Disables the capacity heuristic check if set to `true`.
	Force *bool `protobuf:"varint,1,opt,name=force,def=0" json:"force,omitempty"`
	// The role for which to set quota.
	Role *string `protobuf:"bytes,2,opt,name=role" json:"role,omitempty"`
	// The requested guarantee that these resources will be allocatable for
	// the above role.
	Guarantee []mesos.Resource `protobuf:"bytes,3,rep,name=guarantee" json:"guarantee"`
}

* `QuotaRequest` provides a schema for set quota JSON requests.

func NewPopulatedQuotaRequest 

func NewPopulatedQuotaRequest(r randyQuota, easy bool) *QuotaRequest

func (*QuotaRequest) Descriptor 

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

func (*QuotaRequest) Equal 

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

func (*QuotaRequest) GetForce 

func (m *QuotaRequest) GetForce() bool

func (*QuotaRequest) GetGuarantee 

func (m *QuotaRequest) GetGuarantee() []mesos.Resource

func (*QuotaRequest) GetRole 

func (m *QuotaRequest) GetRole() string

func (*QuotaRequest) GoString 

func (this *QuotaRequest) GoString() string

func (*QuotaRequest) Marshal 

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

func (*QuotaRequest) MarshalJSON 

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

func (*QuotaRequest) MarshalJSONBuf 

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

func (*QuotaRequest) MarshalTo 

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

func (*QuotaRequest) ProtoMessage 

func (*QuotaRequest) ProtoMessage()

func (*QuotaRequest) ProtoSize 

func (m *QuotaRequest) ProtoSize() (n int)

func (*QuotaRequest) Reset 

func (m *QuotaRequest) Reset()

func (*QuotaRequest) String 

func (this *QuotaRequest) String() string

func (*QuotaRequest) Unmarshal 

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

func (*QuotaRequest) UnmarshalJSON 

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

func (*QuotaRequest) UnmarshalJSONFFLexer 

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

func (*QuotaRequest) VerboseEqual 

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

type QuotaStatus 

type QuotaStatus struct {
	// Quotas which are currently set, i.e. known to the master.
	Infos []QuotaInfo `protobuf:"bytes,1,rep,name=infos" json:"infos"`
}

* `QuotaStatus` describes the internal representation for the /quota/status response.

func NewPopulatedQuotaStatus 

func NewPopulatedQuotaStatus(r randyQuota, easy bool) *QuotaStatus

func (*QuotaStatus) Descriptor 

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

func (*QuotaStatus) Equal 

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

func (*QuotaStatus) GetInfos 

func (m *QuotaStatus) GetInfos() []QuotaInfo

func (*QuotaStatus) GoString 

func (this *QuotaStatus) GoString() string

func (*QuotaStatus) Marshal 

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

func (*QuotaStatus) MarshalJSON 

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

func (*QuotaStatus) MarshalJSONBuf 

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

func (*QuotaStatus) MarshalTo 

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

func (*QuotaStatus) ProtoMessage 

func (*QuotaStatus) ProtoMessage()

func (*QuotaStatus) ProtoSize 

func (m *QuotaStatus) ProtoSize() (n int)

func (*QuotaStatus) Reset 

func (m *QuotaStatus) Reset()

func (*QuotaStatus) String 

func (this *QuotaStatus) String() string

func (*QuotaStatus) Unmarshal 

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

func (*QuotaStatus) UnmarshalJSON 

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

func (*QuotaStatus) UnmarshalJSONFFLexer 

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

func (*QuotaStatus) VerboseEqual 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.