public static interface ServiceConfig.WorkerConfigOrBuilder
extends com.google.protobuf.MessageOrBuilder
Modifier and Type | Method and Description |
---|---|
String |
getDataTransferAddress()
The data transfer address of the worker server.
|
com.google.protobuf.ByteString |
getDataTransferAddressBytes()
The data transfer address of the worker server.
|
String |
getDataTransferProtocol()
The protocol for the worker to use when transferring data to clients.
|
com.google.protobuf.ByteString |
getDataTransferProtocolBytes()
The protocol for the worker to use when transferring data to clients.
|
String |
getDispatcherAddress()
The address of the dispatcher to register with.
|
com.google.protobuf.ByteString |
getDispatcherAddressBytes()
The address of the dispatcher to register with.
|
long |
getDispatcherTimeoutMs()
How long to retry requests to the dispatcher before giving up and reporting
an error.
|
long |
getHeartbeatIntervalMs()
How often the worker should heartbeat to the master.
|
long |
getPort()
The port for the worker to bind to.
|
String |
getProtocol()
The protocol for the worker to use when connecting to the dispatcher.
|
com.google.protobuf.ByteString |
getProtocolBytes()
The protocol for the worker to use when connecting to the dispatcher.
|
long |
getShutdownQuietPeriodMs()
When shutting down a worker, how long to wait for the gRPC server to
process the final requests.
|
String |
getWorkerAddress()
The address of the worker server.
|
com.google.protobuf.ByteString |
getWorkerAddressBytes()
The address of the worker server.
|
String |
getWorkerTags(int index)
Tags attached to the worker.
|
com.google.protobuf.ByteString |
getWorkerTagsBytes(int index)
Tags attached to the worker.
|
int |
getWorkerTagsCount()
Tags attached to the worker.
|
List<String> |
getWorkerTagsList()
Tags attached to the worker.
|
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
long getPort()
The port for the worker to bind to. A value of 0 indicates that the worker may bind to any available port.
int64 port = 1;
String getProtocol()
The protocol for the worker to use when connecting to the dispatcher.
string protocol = 2;
com.google.protobuf.ByteString getProtocolBytes()
The protocol for the worker to use when connecting to the dispatcher.
string protocol = 2;
String getDispatcherAddress()
The address of the dispatcher to register with.
string dispatcher_address = 3;
com.google.protobuf.ByteString getDispatcherAddressBytes()
The address of the dispatcher to register with.
string dispatcher_address = 3;
String getWorkerAddress()
The address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string worker_address = 4;
com.google.protobuf.ByteString getWorkerAddressBytes()
The address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string worker_address = 4;
List<String> getWorkerTagsList()
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
int getWorkerTagsCount()
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
String getWorkerTags(int index)
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
com.google.protobuf.ByteString getWorkerTagsBytes(int index)
Tags attached to the worker. This allows reading from selected workers. For example, by applying a "COLOCATED" tag, tf.data service is able to read from the local tf.data worker if one exists, then from off-TF-host workers, to avoid cross-TF-host reads.
repeated string worker_tags = 10;
long getHeartbeatIntervalMs()
How often the worker should heartbeat to the master. A value of 0 indicates that the decision should be left up to the runtime.
int64 heartbeat_interval_ms = 5;
long getDispatcherTimeoutMs()
How long to retry requests to the dispatcher before giving up and reporting an error. A value of 0 indicates that the decision should be left up to the runtime.
int64 dispatcher_timeout_ms = 6;
String getDataTransferProtocol()
The protocol for the worker to use when transferring data to clients.
string data_transfer_protocol = 7;
com.google.protobuf.ByteString getDataTransferProtocolBytes()
The protocol for the worker to use when transferring data to clients.
string data_transfer_protocol = 7;
String getDataTransferAddress()
The data transfer address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string data_transfer_address = 8;
com.google.protobuf.ByteString getDataTransferAddressBytes()
The data transfer address of the worker server. The substring "%port%", if specified, will be replaced with the worker's bound port. This is useful when the port is set to `0`.
string data_transfer_address = 8;
long getShutdownQuietPeriodMs()
When shutting down a worker, how long to wait for the gRPC server to process the final requests. This is used to achieve clean shutdown in unit tests.
int64 shutdown_quiet_period_ms = 9;
Copyright © 2015–2022. All rights reserved.