Class StreamConfig.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
io.envoyproxy.envoy.extensions.filters.http.file_system_buffer.v3.StreamConfig.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,StreamConfigOrBuilder,Cloneable
- Enclosing class:
- StreamConfig
public static final class StreamConfig.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
implements StreamConfigOrBuilder
The configuration for one direction of the filter behavior.Protobuf type
envoy.extensions.filters.http.file_system_buffer.v3.StreamConfig-
Method Summary
Modifier and TypeMethodDescriptionaddRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) build()clear()Whether to bypass / stream / fully buffer / etc.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) The amount stored in the memory buffer before buffering to disk.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) The maximum storage (excluding memory) to be buffered in this filter.The maximum amount that can be queued for writing to storage, above which the source is requested to pause.clone()Whether to bypass / stream / fully buffer / etc.Whether to bypass / stream / fully buffer / etc.Whether to bypass / stream / fully buffer / etc.static final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.Descriptorcom.google.protobuf.UInt64ValueThe amount stored in the memory buffer before buffering to disk.com.google.protobuf.UInt64Value.BuilderThe amount stored in the memory buffer before buffering to disk.com.google.protobuf.UInt64ValueOrBuilderThe amount stored in the memory buffer before buffering to disk.com.google.protobuf.UInt64ValueThe maximum storage (excluding memory) to be buffered in this filter.com.google.protobuf.UInt64Value.BuilderThe maximum storage (excluding memory) to be buffered in this filter.com.google.protobuf.UInt64ValueOrBuilderThe maximum storage (excluding memory) to be buffered in this filter.com.google.protobuf.UInt64ValueThe maximum amount that can be queued for writing to storage, above which the source is requested to pause.com.google.protobuf.UInt64Value.BuilderThe maximum amount that can be queued for writing to storage, above which the source is requested to pause.com.google.protobuf.UInt64ValueOrBuilderThe maximum amount that can be queued for writing to storage, above which the source is requested to pause.booleanWhether to bypass / stream / fully buffer / etc.booleanThe amount stored in the memory buffer before buffering to disk.booleanThe maximum storage (excluding memory) to be buffered in this filter.booleanThe maximum amount that can be queued for writing to storage, above which the source is requested to pause.protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTablefinal booleanmergeBehavior(BufferBehavior value) Whether to bypass / stream / fully buffer / etc.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) mergeFrom(StreamConfig other) mergeMemoryBufferBytesLimit(com.google.protobuf.UInt64Value value) The amount stored in the memory buffer before buffering to disk.mergeStorageBufferBytesLimit(com.google.protobuf.UInt64Value value) The maximum storage (excluding memory) to be buffered in this filter.mergeStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value value) The maximum amount that can be queued for writing to storage, above which the source is requested to pause.final StreamConfig.BuildermergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) setBehavior(BufferBehavior value) Whether to bypass / stream / fully buffer / etc.setBehavior(BufferBehavior.Builder builderForValue) Whether to bypass / stream / fully buffer / etc.setMemoryBufferBytesLimit(com.google.protobuf.UInt64Value value) The amount stored in the memory buffer before buffering to disk.setMemoryBufferBytesLimit(com.google.protobuf.UInt64Value.Builder builderForValue) The amount stored in the memory buffer before buffering to disk.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) setStorageBufferBytesLimit(com.google.protobuf.UInt64Value value) The maximum storage (excluding memory) to be buffered in this filter.setStorageBufferBytesLimit(com.google.protobuf.UInt64Value.Builder builderForValue) The maximum storage (excluding memory) to be buffered in this filter.setStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value value) The maximum amount that can be queued for writing to storage, above which the source is requested to pause.setStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value.Builder builderForValue) The maximum amount that can be queued for writing to storage, above which the source is requested to pause.final StreamConfig.BuildersetUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder
getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, isClean, markClean, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
clear
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
clone
- Specified by:
clonein interfacecom.google.protobuf.Message.Builder- Specified by:
clonein interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clonein classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
setField
public StreamConfig.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
setFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
clearField
- Specified by:
clearFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
clearFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
clearOneof
- Specified by:
clearOneofin interfacecom.google.protobuf.Message.Builder- Overrides:
clearOneofin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
setRepeatedField
public StreamConfig.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value) - Specified by:
setRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
setRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
addRepeatedField
public StreamConfig.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value) - Specified by:
addRepeatedFieldin interfacecom.google.protobuf.Message.Builder- Overrides:
addRepeatedFieldin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StreamConfig.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
mergeFrom
public StreamConfig.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<StreamConfig.Builder>- Throws:
IOException
-
hasBehavior
public boolean hasBehavior()Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1;- Specified by:
hasBehaviorin interfaceStreamConfigOrBuilder- Returns:
- Whether the behavior field is set.
-
getBehavior
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1;- Specified by:
getBehaviorin interfaceStreamConfigOrBuilder- Returns:
- The behavior.
-
setBehavior
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1; -
setBehavior
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1; -
mergeBehavior
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1; -
clearBehavior
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1; -
getBehaviorBuilder
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1; -
getBehaviorOrBuilder
Whether to bypass / stream / fully buffer / etc. If unset in route, vhost and listener config, the default is ``stream_when_possible``.
.envoy.extensions.filters.http.file_system_buffer.v3.BufferBehavior behavior = 1;- Specified by:
getBehaviorOrBuilderin interfaceStreamConfigOrBuilder
-
hasMemoryBufferBytesLimit
public boolean hasMemoryBufferBytesLimit()The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... }- Specified by:
hasMemoryBufferBytesLimitin interfaceStreamConfigOrBuilder- Returns:
- Whether the memoryBufferBytesLimit field is set.
-
getMemoryBufferBytesLimit
public com.google.protobuf.UInt64Value getMemoryBufferBytesLimit()The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... }- Specified by:
getMemoryBufferBytesLimitin interfaceStreamConfigOrBuilder- Returns:
- The memoryBufferBytesLimit.
-
setMemoryBufferBytesLimit
The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... } -
setMemoryBufferBytesLimit
public StreamConfig.Builder setMemoryBufferBytesLimit(com.google.protobuf.UInt64Value.Builder builderForValue) The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... } -
mergeMemoryBufferBytesLimit
The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... } -
clearMemoryBufferBytesLimit
The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... } -
getMemoryBufferBytesLimitBuilder
public com.google.protobuf.UInt64Value.Builder getMemoryBufferBytesLimitBuilder()The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... } -
getMemoryBufferBytesLimitOrBuilder
public com.google.protobuf.UInt64ValueOrBuilder getMemoryBufferBytesLimitOrBuilder()The amount stored in the memory buffer before buffering to disk. If unset in route, vhost and listener config, defaults to a hardcoded value of 1MiB
.google.protobuf.UInt64Value memory_buffer_bytes_limit = 2 [(.validate.rules) = { ... }- Specified by:
getMemoryBufferBytesLimitOrBuilderin interfaceStreamConfigOrBuilder
-
hasStorageBufferBytesLimit
public boolean hasStorageBufferBytesLimit()The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3;- Specified by:
hasStorageBufferBytesLimitin interfaceStreamConfigOrBuilder- Returns:
- Whether the storageBufferBytesLimit field is set.
-
getStorageBufferBytesLimit
public com.google.protobuf.UInt64Value getStorageBufferBytesLimit()The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3;- Specified by:
getStorageBufferBytesLimitin interfaceStreamConfigOrBuilder- Returns:
- The storageBufferBytesLimit.
-
setStorageBufferBytesLimit
The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3; -
setStorageBufferBytesLimit
public StreamConfig.Builder setStorageBufferBytesLimit(com.google.protobuf.UInt64Value.Builder builderForValue) The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3; -
mergeStorageBufferBytesLimit
The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3; -
clearStorageBufferBytesLimit
The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3; -
getStorageBufferBytesLimitBuilder
public com.google.protobuf.UInt64Value.Builder getStorageBufferBytesLimitBuilder()The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3; -
getStorageBufferBytesLimitOrBuilder
public com.google.protobuf.UInt64ValueOrBuilder getStorageBufferBytesLimitOrBuilder()The maximum storage (excluding memory) to be buffered in this filter. If unset in route, vhost and listener config, defaults to a hardcoded value of 32MiB
.google.protobuf.UInt64Value storage_buffer_bytes_limit = 3;- Specified by:
getStorageBufferBytesLimitOrBuilderin interfaceStreamConfigOrBuilder
-
hasStorageBufferQueueHighWatermarkBytes
public boolean hasStorageBufferQueueHighWatermarkBytes()The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4;- Specified by:
hasStorageBufferQueueHighWatermarkBytesin interfaceStreamConfigOrBuilder- Returns:
- Whether the storageBufferQueueHighWatermarkBytes field is set.
-
getStorageBufferQueueHighWatermarkBytes
public com.google.protobuf.UInt64Value getStorageBufferQueueHighWatermarkBytes()The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4;- Specified by:
getStorageBufferQueueHighWatermarkBytesin interfaceStreamConfigOrBuilder- Returns:
- The storageBufferQueueHighWatermarkBytes.
-
setStorageBufferQueueHighWatermarkBytes
public StreamConfig.Builder setStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value value) The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4; -
setStorageBufferQueueHighWatermarkBytes
public StreamConfig.Builder setStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value.Builder builderForValue) The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4; -
mergeStorageBufferQueueHighWatermarkBytes
public StreamConfig.Builder mergeStorageBufferQueueHighWatermarkBytes(com.google.protobuf.UInt64Value value) The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4; -
clearStorageBufferQueueHighWatermarkBytes
The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4; -
getStorageBufferQueueHighWatermarkBytesBuilder
public com.google.protobuf.UInt64Value.Builder getStorageBufferQueueHighWatermarkBytesBuilder()The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4; -
getStorageBufferQueueHighWatermarkBytesOrBuilder
public com.google.protobuf.UInt64ValueOrBuilder getStorageBufferQueueHighWatermarkBytesOrBuilder()The maximum amount that can be queued for writing to storage, above which the source is requested to pause. If unset, defaults to the same value as ``memory_buffer_bytes_limit``. For example, assuming the recipient is not consuming data at all, if ``memory_buffer_bytes_limit`` was 32MiB, and ``storage_buffer_queue_high_watermark_bytes`` was 64MiB, and the filesystem is backed up so writes are not occurring promptly, then: * Any request less than 32MiB will eventually pass through without ever attempting to write to disk. * Any request with over 32MiB buffered will start trying to write to disk. If it reaches (32+64)MiB buffered in memory (write to disk isn't keeping up), a high watermark signal is sent to the source. * Any stream whose total size exceeds ``memory_buffer_bytes_limit + storage_buffer_bytes_limit`` will provoke an error. (Note, if the recipient *is* consuming data then it is possible for such an oversized request to pass through the buffer filter, provided the recipient isn't consuming data too slowly.) The low watermark signal is sent when the memory buffer is at size ``memory_buffer_bytes_limit + (storage_buffer_queue_high_watermark_bytes / 2)``.
.google.protobuf.UInt64Value storage_buffer_queue_high_watermark_bytes = 4;- Specified by:
getStorageBufferQueueHighWatermarkBytesOrBuilderin interfaceStreamConfigOrBuilder
-
setUnknownFields
public final StreamConfig.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
setUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
setUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-
mergeUnknownFields
public final StreamConfig.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) - Specified by:
mergeUnknownFieldsin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeUnknownFieldsin classcom.google.protobuf.GeneratedMessageV3.Builder<StreamConfig.Builder>
-