You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2021/05/27 07:23:53 UTC
[incubator-inlong] 04/04: Fix comments
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch INLONG-25
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit 24b3c990db8fe065aa95c6471aefd0e39eee7d6a
Author: Zijie Lu <ws...@gmail.com>
AuthorDate: Wed May 26 14:43:01 2021 +0800
Fix comments
Signed-off-by: Zijie Lu <ws...@gmail.com>
---
.../tubemq-client-go/config/config.go | 55 +++++++++++-----------
1 file changed, 28 insertions(+), 27 deletions(-)
diff --git a/tubemq-client-twins/tubemq-client-go/config/config.go b/tubemq-client-twins/tubemq-client-go/config/config.go
index d867d0c..47a360a 100644
--- a/tubemq-client-twins/tubemq-client-go/config/config.go
+++ b/tubemq-client-twins/tubemq-client-go/config/config.go
@@ -31,11 +31,11 @@ import (
type Config struct {
// Net is the namespace for network-level properties used by Broker and Master.
Net struct {
- // How long to wait for a response.
+ // ReadTimeout represents how long to wait for a response.
ReadTimeout time.Duration
// TLS based authentication with broker and master.
TLS struct {
- // Whether or not to use TLS.
+ // Enable represents whether or not to use TLS.
Enable bool
// CACertFile for TLS.
CACertFile string
@@ -46,13 +46,13 @@ type Config struct {
// TTSServerName for TLS.
TLSServerName string
}
- // Account based authentication with broker and master.
+ // Auth represents the account based authentication with broker and master.
Auth struct {
- // Whether or not to use authentication.
+ // Enable represents whether or not to use authentication.
Enable bool
- // Username of authentication.
+ // Username for authentication.
UserName string
- // Password of authentication.
+ // Password for authentication.
Password string
}
}
@@ -60,53 +60,54 @@ type Config struct {
// Consumer is the namespace for configuration related to consume messages,
// used by the consumer
Consumer struct {
- // The addresses of master.
+ // Masters is the addresses of master.
Masters []string
- // The consumption topic.
+ // Topic of the consumption.
Topic string
- // The initial offset to use if no offset was previously committed.
+ // ConsumerPosition is the initial offset to use if no offset was previously committed.
ConsumePosition int
- // The consumer group name.
+ // Group is the consumer group name.
Group string
- // Whether or not to specify the offset.
+ // BoundConsume represents whether or not to specify the offset.
BoundConsume bool
// SessionKey is defined by the client.
// The session key will be the same in a batch.
SessionKey string
- // The number of consumers in a batch.
+ // SourceCount is the number of consumers in a batch.
SourceCount int
- // If multiple consumers want to reset the offset of the same partition,
- // whether the server or not to use the biggest offset
- // the server will use the biggest offset if set.
- // Otherwise the server will use the smallest offset.
+ // SelectBig specifies if multiple consumers want to reset the offset of the same partition,
+ // whether or not to use the biggest offset.
+ // The server will use the biggest offset if set, otherwise the server will use the smallest offset.
SelectBig bool
- // If the confirm request timeouts, whether this batch of data should be considered as successful.
+ // RollbackIfConfirmTimeout represents if the confirm request timeouts,
+ // whether or not this batch of data should be considered as successful.
// This batch of data will not be considered as successful if set.
RollbackIfConfirmTimeout bool
- // The maximum interval for the client to report subscription information.
+ // MaxSubInfoReportInterval is maximum interval for the client to report subscription information.
MaxSubInfoReportInterval int
- // The maximum interval to check the partition.
+ // MaxPartCheckPeriod is the maximum interval to check the partition.
MaxPartCheckPeriod time.Duration
- // The interval to check the partition.
+ // PartCheckSlice is the interval to check the partition.
PartCheckSlice time.Duration
- // The maximum wait time the offset of a partition has reached the maximum offset.
+ // MsgNotFoundWait is the maximum wait time the offset of a partition has reached the maximum offset.
MsgNotFoundWait time.Duration
- // How long to wait when the server is rebalancing and the partition is being occupied by the client.
+ // RebConfirmWait represents how long to wait
+ // when the server is rebalancing and the partition is being occupied by the client.
RebConfirmWait time.Duration
- // The maximum wait time a partition consumption command is released.
+ // MaxConfirmWait is the maximum wait time a partition consumption command is released.
MaxConfirmWait time.Duration
- // How long to wait when shutdown is called and the server is rebalancing.
+ // ShutdownRebWait represents how long to wait when shutdown is called and the server is rebalancing.
ShutdownRebWait time.Duration
}
// Heartbeat is the namespace for configuration related to heartbeat messages,
// used by the consumer
Heartbeat struct {
- // How frequently to send heartbeat.
+ // Interval represents how frequently to send heartbeat.
Interval time.Duration
- // The total number of times to retry sending heartbeat.
+ // MaxRetryTimes is the total number of times to retry sending heartbeat.
MaxRetryTimes int
- // The heartbeat timeout after a heartbeat failure.
+ // AfterFail is the heartbeat timeout after a heartbeat failure.
AfterFail time.Duration
}
}