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 QuotaConfig QuotaStatus
Index ¶
- Constants
- Variables
- type QuotaConfig
- func (*QuotaConfig) Descriptor() ([]byte, []int)
- func (this *QuotaConfig) Equal(that interface{}) bool
- func (m *QuotaConfig) GetGuarantees() map[string]mesos.Value_Scalar
- func (m *QuotaConfig) GetLimits() map[string]mesos.Value_Scalar
- func (m *QuotaConfig) GetRole() string
- func (this *QuotaConfig) GoString() string
- func (m *QuotaConfig) Marshal() (dAtA []byte, err error)
- func (mj *QuotaConfig) MarshalJSON() ([]byte, error)
- func (mj *QuotaConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (m *QuotaConfig) MarshalTo(dAtA []byte) (int, error)
- func (*QuotaConfig) ProtoMessage()
- func (m *QuotaConfig) ProtoSize() (n int)
- func (m *QuotaConfig) Reset()
- func (this *QuotaConfig) String() string
- func (m *QuotaConfig) Unmarshal(dAtA []byte) error
- func (uj *QuotaConfig) UnmarshalJSON(input []byte) error
- func (uj *QuotaConfig) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (this *QuotaConfig) VerboseEqual(that interface{}) error
- type QuotaInfo
- func (*QuotaInfo) Descriptor() ([]byte, []int)
- func (this *QuotaInfo) Equal(that interface{}) bool
- func (m *QuotaInfo) GetGuarantee() []mesos.Resource
- func (m *QuotaInfo) GetPrincipal() string
- func (m *QuotaInfo) GetRole() string
- func (this *QuotaInfo) GoString() string
- func (m *QuotaInfo) Marshal() (dAtA []byte, err error)
- func (mj *QuotaInfo) MarshalJSON() ([]byte, error)
- func (mj *QuotaInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (m *QuotaInfo) MarshalTo(dAtA []byte) (int, error)
- func (*QuotaInfo) ProtoMessage()
- func (m *QuotaInfo) ProtoSize() (n int)
- func (m *QuotaInfo) Reset()
- func (this *QuotaInfo) String() string
- func (m *QuotaInfo) Unmarshal(dAtA []byte) error
- func (uj *QuotaInfo) UnmarshalJSON(input []byte) error
- func (uj *QuotaInfo) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (this *QuotaInfo) VerboseEqual(that interface{}) error
- type QuotaRequest
- func (*QuotaRequest) Descriptor() ([]byte, []int)
- func (this *QuotaRequest) Equal(that interface{}) bool
- func (m *QuotaRequest) GetForce() bool
- func (m *QuotaRequest) GetGuarantee() []mesos.Resource
- func (m *QuotaRequest) GetRole() string
- func (this *QuotaRequest) GoString() string
- func (m *QuotaRequest) Marshal() (dAtA []byte, err error)
- func (mj *QuotaRequest) MarshalJSON() ([]byte, error)
- func (mj *QuotaRequest) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (m *QuotaRequest) MarshalTo(dAtA []byte) (int, error)
- func (*QuotaRequest) ProtoMessage()
- func (m *QuotaRequest) ProtoSize() (n int)
- func (m *QuotaRequest) Reset()
- func (this *QuotaRequest) String() string
- func (m *QuotaRequest) Unmarshal(dAtA []byte) error
- func (uj *QuotaRequest) UnmarshalJSON(input []byte) error
- func (uj *QuotaRequest) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (this *QuotaRequest) VerboseEqual(that interface{}) error
- type QuotaStatus
- func (*QuotaStatus) Descriptor() ([]byte, []int)
- func (this *QuotaStatus) Equal(that interface{}) bool
- func (m *QuotaStatus) GetInfos() []QuotaInfo
- func (this *QuotaStatus) GoString() string
- func (m *QuotaStatus) Marshal() (dAtA []byte, err error)
- func (mj *QuotaStatus) MarshalJSON() ([]byte, error)
- func (mj *QuotaStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error
- func (m *QuotaStatus) MarshalTo(dAtA []byte) (int, error)
- func (*QuotaStatus) ProtoMessage()
- func (m *QuotaStatus) ProtoSize() (n int)
- func (m *QuotaStatus) Reset()
- func (this *QuotaStatus) String() string
- func (m *QuotaStatus) Unmarshal(dAtA []byte) error
- func (uj *QuotaStatus) UnmarshalJSON(input []byte) error
- func (uj *QuotaStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
- func (this *QuotaStatus) VerboseEqual(that interface{}) error
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 QuotaConfig ¶ added in v0.0.10
type QuotaConfig struct {
Role string `protobuf:"bytes,1,req,name=role" json:"role"`
// Name-value pairs that define the resource guarantees.
// Only scalar resources are currently supported.
//
// Mesos will try its best to ensure that the role can be
// allocated at least as many resources as the guarantee.
// Despite this, it's possible for the guarantee to not be
// satisfiable, if:
// (1) The operator has overcommitted guarantees.
// (2) There is a loss of agents that such that the
// guarantees overcommit the cluster.
// (3) The scheduler is pickier than mesos knows about,
// e.g. the scheduler needs resources from agents
// with specific attributes.
//
// The provided guarantees will be validated to ensure it
// is not overcommitting the cluster. The operator can
// disable this via `UpdateQuota.force`.
//
// If the guarantee is omitted, there is no guarantee.
//
// Operators may want to set up alerting to let them know
// when a guarantee cannot be satisfied.
Guarantees map[string]mesos.Value_Scalar `` /* 130-byte string literal not displayed */
// Name-value pairs that define the resource limits.
// Only scalar resources are currently supported.
//
// Imposes a limit on the amount of resources allocated to the
// role. Mesos will try its best to ensure that the role does
// not exceed this limit. Despite this, the limit can be exceeded
// when:
// (1) The limit is lowered below the allocation.
// (2) Some agents are partitioned and re-connect with
// resources allocated to the role.
//
// The provided limits will be validated to ensure it does not
// exceed the total cluster size. The operator can disable
// this check via `UpdateQuota.force`.
//
// If the limit is omitted, there is no limit.
//
// Operators may want to set up alerting to let them know
// when the limit is exceeded.
Limits map[string]mesos.Value_Scalar `protobuf:"bytes,3,rep,name=limits" json:"limits" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}
* Describes a role's quota configuration.
func NewPopulatedQuotaConfig ¶ added in v0.0.10
func NewPopulatedQuotaConfig(r randyQuota, easy bool) *QuotaConfig
func (*QuotaConfig) Descriptor ¶ added in v0.0.10
func (*QuotaConfig) Descriptor() ([]byte, []int)
func (*QuotaConfig) Equal ¶ added in v0.0.10
func (this *QuotaConfig) Equal(that interface{}) bool
func (*QuotaConfig) GetGuarantees ¶ added in v0.0.10
func (m *QuotaConfig) GetGuarantees() map[string]mesos.Value_Scalar
func (*QuotaConfig) GetLimits ¶ added in v0.0.10
func (m *QuotaConfig) GetLimits() map[string]mesos.Value_Scalar
func (*QuotaConfig) GetRole ¶ added in v0.0.10
func (m *QuotaConfig) GetRole() string
func (*QuotaConfig) GoString ¶ added in v0.0.10
func (this *QuotaConfig) GoString() string
func (*QuotaConfig) Marshal ¶ added in v0.0.10
func (m *QuotaConfig) Marshal() (dAtA []byte, err error)
func (*QuotaConfig) MarshalJSON ¶ added in v0.0.10
func (mj *QuotaConfig) MarshalJSON() ([]byte, error)
func (*QuotaConfig) MarshalJSONBuf ¶ added in v0.0.10
func (mj *QuotaConfig) MarshalJSONBuf(buf fflib.EncodingBuffer) error
func (*QuotaConfig) MarshalTo ¶ added in v0.0.10
func (m *QuotaConfig) MarshalTo(dAtA []byte) (int, error)
func (*QuotaConfig) ProtoMessage ¶ added in v0.0.10
func (*QuotaConfig) ProtoMessage()
func (*QuotaConfig) ProtoSize ¶ added in v0.0.10
func (m *QuotaConfig) ProtoSize() (n int)
func (*QuotaConfig) Reset ¶ added in v0.0.10
func (m *QuotaConfig) Reset()
func (*QuotaConfig) String ¶ added in v0.0.10
func (this *QuotaConfig) String() string
func (*QuotaConfig) Unmarshal ¶ added in v0.0.10
func (m *QuotaConfig) Unmarshal(dAtA []byte) error
func (*QuotaConfig) UnmarshalJSON ¶ added in v0.0.10
func (uj *QuotaConfig) UnmarshalJSON(input []byte) error
func (*QuotaConfig) UnmarshalJSONFFLexer ¶ added in v0.0.10
func (uj *QuotaConfig) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error
func (*QuotaConfig) VerboseEqual ¶ added in v0.0.10
func (this *QuotaConfig) VerboseEqual(that interface{}) error
type QuotaInfo ¶
type QuotaInfo struct {
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"`
Guarantee []mesos.Resource `protobuf:"bytes,3,rep,name=guarantee" json:"guarantee"`
}
* Describes the resource guarantees for a role. Persisted in the registry.
func NewPopulatedQuotaInfo ¶
func (*QuotaInfo) Descriptor ¶
func (*QuotaInfo) GetGuarantee ¶
func (*QuotaInfo) GetPrincipal ¶
func (*QuotaInfo) MarshalJSON ¶
func (*QuotaInfo) MarshalJSONBuf ¶
func (mj *QuotaInfo) MarshalJSONBuf(buf fflib.EncodingBuffer) error
func (*QuotaInfo) ProtoMessage ¶
func (*QuotaInfo) ProtoMessage()
func (*QuotaInfo) UnmarshalJSON ¶
func (*QuotaInfo) UnmarshalJSONFFLexer ¶
func (*QuotaInfo) VerboseEqual ¶
type QuotaRequest ¶
type QuotaRequest struct {
// See `guarantee` for the behavior of `force`.
Force *bool `protobuf:"varint,1,opt,name=force,def=0" json:"force,omitempty"`
Role *string `protobuf:"bytes,2,opt,name=role" json:"role,omitempty"`
// Mesos will try its best to ensure that the role can be
// allocated at least as many resources as the guarantee.
// Despite this, it's possible for the guarantee to not be
// satisfiable, if:
// (1) The operator has overcommitted guarantees.
// (2) There is a loss of agents that such that the
// guarantees overcommit the cluster.
// (3) The scheduler is pickier than mesos knows about,
// e.g. the scheduler needs resources from agents
// with specific attributes.
//
// The provided guarantee will be validated to ensure it
// is not overcommitting the cluster. The operator can
// disable this via `QuotaRequest.force`.
//
// If the guarantee is omitted, there is no guarantee.
//
// Operators may want to set up alerting to let them know
// when a guarantee cannot be satisfied.
//
// NOTE: The resources must be scalars without additional
// metadata like reservations, disk information, etc.
Guarantee []mesos.Resource `protobuf:"bytes,3,rep,name=guarantee" json:"guarantee"`
}
* Describes an update to a role's quota. This is a copy of `QuotaInfo` which omits the principal since it is determined during authentication. Also allows the user to force the update in the case of a guarantee overcommit.
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) 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 {
// Returns all non-default quotas. Those ommitted from this
// list have the default of: no guarantee and no limit.
Infos []QuotaInfo `protobuf:"bytes,1,rep,name=infos" json:"infos"`
}
* `QuotaStatus` describes the internal representation for the /quota/status response and `GET_QUOTA` `master::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) 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
Click to show internal directories.
Click to hide internal directories.