public static final class Protos.RateLimit extends com.google.protobuf.GeneratedMessageV3 implements Protos.RateLimitOrBuilder
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.Protobuf type
mesos.RateLimit
Modifier and Type | Class and Description |
---|---|
static class |
Protos.RateLimit.Builder
Rate (queries per second, QPS) limit for messages from a framework to master.
|
Modifier and Type | Field and Description |
---|---|
static int |
CAPACITY_FIELD_NUMBER |
static <any> |
PARSER
Deprecated.
|
static int |
PRINCIPAL_FIELD_NUMBER |
static int |
QPS_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
long |
getCapacity()
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.
|
static Protos.RateLimit |
getDefaultInstance() |
Protos.RateLimit |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
<any> |
getParserForType() |
java.lang.String |
getPrincipal()
Principal of framework(s) to be throttled.
|
com.google.protobuf.ByteString |
getPrincipalBytes()
Principal of framework(s) to be throttled.
|
double |
getQps()
Leaving QPS unset gives it unlimited rate (i.e., not throttled),
which also implies unlimited capacity.
|
int |
getSerializedSize() |
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
boolean |
hasCapacity()
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.
|
int |
hashCode() |
boolean |
hasPrincipal()
Principal of framework(s) to be throttled.
|
boolean |
hasQps()
Leaving QPS unset gives it unlimited rate (i.e., not throttled),
which also implies unlimited capacity.
|
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable |
internalGetFieldAccessorTable() |
boolean |
isInitialized() |
static Protos.RateLimit.Builder |
newBuilder() |
static Protos.RateLimit.Builder |
newBuilder(Protos.RateLimit prototype) |
Protos.RateLimit.Builder |
newBuilderForType() |
protected Protos.RateLimit.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
static Protos.RateLimit |
parseDelimitedFrom(java.io.InputStream input) |
static Protos.RateLimit |
parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protos.RateLimit |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protos.RateLimit |
parseFrom(java.nio.ByteBuffer data) |
static Protos.RateLimit |
parseFrom(java.nio.ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protos.RateLimit |
parseFrom(com.google.protobuf.ByteString data) |
static Protos.RateLimit |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protos.RateLimit |
parseFrom(com.google.protobuf.CodedInputStream input) |
static Protos.RateLimit |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Protos.RateLimit |
parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static <any> |
parser() |
Protos.RateLimit.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
public static final int QPS_FIELD_NUMBER
public static final int PRINCIPAL_FIELD_NUMBER
public static final int CAPACITY_FIELD_NUMBER
@Deprecated public static final <any> PARSER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
public boolean hasQps()
Leaving QPS unset gives it unlimited rate (i.e., not throttled), which also implies unlimited capacity.
optional double qps = 1;
hasQps
in interface Protos.RateLimitOrBuilder
public double getQps()
Leaving QPS unset gives it unlimited rate (i.e., not throttled), which also implies unlimited capacity.
optional double qps = 1;
getQps
in interface Protos.RateLimitOrBuilder
public boolean hasPrincipal()
Principal of framework(s) to be throttled. Should match FrameworkInfo.principal and Credential.principal (if using authentication).
required string principal = 2;
hasPrincipal
in interface Protos.RateLimitOrBuilder
public java.lang.String getPrincipal()
Principal of framework(s) to be throttled. Should match FrameworkInfo.principal and Credential.principal (if using authentication).
required string principal = 2;
getPrincipal
in interface Protos.RateLimitOrBuilder
public com.google.protobuf.ByteString getPrincipalBytes()
Principal of framework(s) to be throttled. Should match FrameworkInfo.principal and Credential.principal (if using authentication).
required string principal = 2;
getPrincipalBytes
in interface Protos.RateLimitOrBuilder
public boolean hasCapacity()
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.
optional uint64 capacity = 3;
hasCapacity
in interface Protos.RateLimitOrBuilder
public long getCapacity()
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.
optional uint64 capacity = 3;
getCapacity
in interface Protos.RateLimitOrBuilder
public final boolean isInitialized()
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
java.io.IOException
public int getSerializedSize()
public boolean equals(java.lang.Object obj)
public int hashCode()
public static Protos.RateLimit parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static Protos.RateLimit parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static Protos.RateLimit parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static Protos.RateLimit parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static Protos.RateLimit parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static Protos.RateLimit parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static Protos.RateLimit parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
java.io.IOException
public static Protos.RateLimit parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public static Protos.RateLimit parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
java.io.IOException
public static Protos.RateLimit parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
java.io.IOException
public Protos.RateLimit.Builder newBuilderForType()
public static Protos.RateLimit.Builder newBuilder()
public static Protos.RateLimit.Builder newBuilder(Protos.RateLimit prototype)
public Protos.RateLimit.Builder toBuilder()
protected Protos.RateLimit.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
public static Protos.RateLimit getDefaultInstance()
public static <any> parser()
public <any> getParserForType()
public Protos.RateLimit getDefaultInstanceForType()