Documentation
¶
Index ¶
- type Config
- func (_m *Config) AutoCommitInterval() time.Duration
- func (_m *Config) BaseHostName() string
- func (_m *Config) ClientDiscoveryPort() int
- func (_m *Config) ConsumerAddDelay() time.Duration
- func (_m *Config) ConsumerPort() int
- func (_m *Config) ConsumerRanges() int
- func (_m *Config) ConsumerReadThreshold() int
- func (_m *Config) ConsumerReadTimeout() time.Duration
- func (_m *Config) CreateAllDirs() error
- func (_m *Config) DatalogPath(topicDataId *types.TopicDataId) string
- func (_m *Config) DatalogSegmentsPath() string
- func (_m *Config) DevMode() bool
- func (_m *Config) FixedTopologyFilePollDelay() time.Duration
- func (_m *Config) GossipDataPort() int
- func (_m *Config) GossipPort() int
- func (_m *Config) HomePath() string
- func (_m *Config) IndexFilePeriodBytes() int
- func (_m *Config) Init() error
- func (_m *Config) ListenOnAllAddresses() bool
- func (_m *Config) LocalDbPath() string
- func (_m *Config) LogRetentionDuration() *time.Duration
- func (_m *Config) MaxDataBodyLength() int
- func (_m *Config) MaxGroupSize() int
- func (_m *Config) MaxMessageSize() int
- func (_m *Config) MaxSegmentSize() int
- func (_m *Config) MetricsPort() int
- func (_m *Config) Ordinal() int
- func (_m *Config) PodName() string
- func (_m *Config) PodNamespace() string
- func (_m *Config) ProducerBinaryPort() int
- func (_m *Config) ProducerBufferPoolSize() int
- func (_m *Config) ProducerPort() int
- func (_m *Config) ReadAheadSize() int
- func (_m *Config) ReplicationTimeout() time.Duration
- func (_m *Config) ReplicationWriteTimeout() time.Duration
- func (_m *Config) SegmentBufferSize() int
- func (_m *Config) SegmentFlushInterval() time.Duration
- func (_m *Config) ServiceName() string
- func (_m *Config) ShutdownDelay() time.Duration
- func (_m *Config) StreamBufferSize() int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
Config is an autogenerated mock type for the Config type
func NewConfig ¶
func NewConfig(t mockConstructorTestingTNewConfig) *Config
NewConfig creates a new instance of Config. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Config) AutoCommitInterval ¶
AutoCommitInterval provides a mock function with given fields:
func (*Config) BaseHostName ¶
BaseHostName provides a mock function with given fields:
func (*Config) ClientDiscoveryPort ¶
ClientDiscoveryPort provides a mock function with given fields:
func (*Config) ConsumerAddDelay ¶
ConsumerAddDelay provides a mock function with given fields:
func (*Config) ConsumerPort ¶
ConsumerPort provides a mock function with given fields:
func (*Config) ConsumerRanges ¶
ConsumerRanges provides a mock function with given fields:
func (*Config) ConsumerReadThreshold ¶
ConsumerReadThreshold provides a mock function with given fields:
func (*Config) ConsumerReadTimeout ¶
ConsumerReadTimeout provides a mock function with given fields:
func (*Config) CreateAllDirs ¶
CreateAllDirs provides a mock function with given fields:
func (*Config) DatalogPath ¶
func (_m *Config) DatalogPath(topicDataId *types.TopicDataId) string
DatalogPath provides a mock function with given fields: topicDataId
func (*Config) DatalogSegmentsPath ¶
DatalogSegmentsPath provides a mock function with given fields:
func (*Config) FixedTopologyFilePollDelay ¶
FixedTopologyFilePollDelay provides a mock function with given fields:
func (*Config) GossipDataPort ¶
GossipDataPort provides a mock function with given fields:
func (*Config) GossipPort ¶
GossipPort provides a mock function with given fields:
func (*Config) IndexFilePeriodBytes ¶
IndexFilePeriodBytes provides a mock function with given fields:
func (*Config) ListenOnAllAddresses ¶
ListenOnAllAddresses provides a mock function with given fields:
func (*Config) LocalDbPath ¶
LocalDbPath provides a mock function with given fields:
func (*Config) LogRetentionDuration ¶
LogRetentionDuration provides a mock function with given fields:
func (*Config) MaxDataBodyLength ¶
MaxDataBodyLength provides a mock function with given fields:
func (*Config) MaxGroupSize ¶
MaxGroupSize provides a mock function with given fields:
func (*Config) MaxMessageSize ¶
MaxMessageSize provides a mock function with given fields:
func (*Config) MaxSegmentSize ¶
MaxSegmentSize provides a mock function with given fields:
func (*Config) MetricsPort ¶
MetricsPort provides a mock function with given fields:
func (*Config) PodNamespace ¶
PodNamespace provides a mock function with given fields:
func (*Config) ProducerBinaryPort ¶ added in v0.7.0
ProducerBinaryPort provides a mock function with given fields:
func (*Config) ProducerBufferPoolSize ¶
ProducerBufferPoolSize provides a mock function with given fields:
func (*Config) ProducerPort ¶
ProducerPort provides a mock function with given fields:
func (*Config) ReadAheadSize ¶
ReadAheadSize provides a mock function with given fields:
func (*Config) ReplicationTimeout ¶
ReplicationTimeout provides a mock function with given fields:
func (*Config) ReplicationWriteTimeout ¶
ReplicationWriteTimeout provides a mock function with given fields:
func (*Config) SegmentBufferSize ¶
SegmentBufferSize provides a mock function with given fields:
func (*Config) SegmentFlushInterval ¶
SegmentFlushInterval provides a mock function with given fields:
func (*Config) ServiceName ¶
ServiceName provides a mock function with given fields:
func (*Config) ShutdownDelay ¶
ShutdownDelay provides a mock function with given fields:
func (*Config) StreamBufferSize ¶
StreamBufferSize provides a mock function with given fields:
Source Files