Versions in this module Expand all Collapse all v0 v0.6.0 Mar 9, 2020 v0.5.0 Mar 20, 2019 Changes in this version + const DefaultPrefetchCount + const DefaultPrefetchValidityMillis + const MaximumPrefetchCount + type CloudConfig struct + func NewCloudConfig() *CloudConfig + func (cc *CloudConfig) DiscoveryToken() string + func (cc *CloudConfig) IsEnabled() bool + func (cc *CloudConfig) SetDiscoveryToken(discoveryToken string) + func (cc *CloudConfig) SetEnabled(enabled bool) + type Config struct + func New() *Config + func (c *Config) AddFlakeIDGeneratorConfig(config *FlakeIDGeneratorConfig) + func (c *Config) AddLifecycleListener(listener interface{}) + func (c *Config) AddMembershipListener(listener interface{}) + func (c *Config) AddReliableTopicConfig(config *ReliableTopicConfig) + func (c *Config) ClientName() string + func (c *Config) GetFlakeIDGeneratorConfig(name string) *FlakeIDGeneratorConfig + func (c *Config) GetReliableTopicConfig(name string) *ReliableTopicConfig + func (c *Config) GroupConfig() *GroupConfig + func (c *Config) LifecycleListeners() []interface{} + func (c *Config) LoadBalancer() core.LoadBalancer + func (c *Config) LoggerConfig() *LoggerConfig + func (c *Config) MembershipListeners() []interface{} + func (c *Config) NetworkConfig() *NetworkConfig + func (c *Config) Properties() Properties + func (c *Config) SecurityConfig() *SecurityConfig + func (c *Config) SerializationConfig() *serialization.Config + func (c *Config) SetClientName(name string) + func (c *Config) SetGroupConfig(groupConfig *GroupConfig) + func (c *Config) SetLoadBalancer(loadBalancer core.LoadBalancer) + func (c *Config) SetNetworkConfig(networkConfig *NetworkConfig) + func (c *Config) SetProperty(name string, value string) + func (c *Config) SetSecurityConfig(securityConfig *SecurityConfig) + func (c *Config) SetSerializationConfig(serializationConfig *serialization.Config) + type FlakeIDGeneratorConfig struct + func NewFlakeIDGeneratorConfig(name string) *FlakeIDGeneratorConfig + func NewFlakeIDGeneratorConfigWithParameters(name string, prefetchCount int32, prefetchValidityMillis int64) *FlakeIDGeneratorConfig + func (igc *FlakeIDGeneratorConfig) Name() string + func (igc *FlakeIDGeneratorConfig) PrefetchCount() int32 + func (igc *FlakeIDGeneratorConfig) PrefetchValidityMillis() int64 + func (igc *FlakeIDGeneratorConfig) SetName(name string) + func (igc *FlakeIDGeneratorConfig) SetPrefetchCount(prefetchCount int32) + func (igc *FlakeIDGeneratorConfig) SetPrefetchValidityMillis(prefetchValidityMillis int64) + type GroupConfig struct + func NewGroupConfig() *GroupConfig + func (gc *GroupConfig) Name() string + func (gc *GroupConfig) Password() string + func (gc *GroupConfig) SetName(name string) + func (gc *GroupConfig) SetPassword(password string) *GroupConfig + type LoggerConfig struct + func NewLoggerConfig() *LoggerConfig + func (l *LoggerConfig) Logger() logger.Logger + func (l *LoggerConfig) SetLogger(logger logger.Logger) + type NetworkConfig struct + func NewNetworkConfig() *NetworkConfig + func (nc *NetworkConfig) AddAddress(addresses ...string) + func (nc *NetworkConfig) Addresses() []string + func (nc *NetworkConfig) CloudConfig() *CloudConfig + func (nc *NetworkConfig) ConnectionAttemptLimit() int32 + func (nc *NetworkConfig) ConnectionAttemptPeriod() time.Duration + func (nc *NetworkConfig) ConnectionTimeout() time.Duration + func (nc *NetworkConfig) IsRedoOperation() bool + func (nc *NetworkConfig) IsSmartRouting() bool + func (nc *NetworkConfig) SSLConfig() *SSLConfig + func (nc *NetworkConfig) SetAddresses(addresses []string) + func (nc *NetworkConfig) SetCloudConfig(cloudConfig *CloudConfig) + func (nc *NetworkConfig) SetConnectionAttemptLimit(connectionAttemptLimit int32) + func (nc *NetworkConfig) SetConnectionAttemptPeriod(connectionAttemptPeriod time.Duration) + func (nc *NetworkConfig) SetConnectionTimeout(connectionTimeout time.Duration) + func (nc *NetworkConfig) SetRedoOperation(redoOperation bool) + func (nc *NetworkConfig) SetSmartRouting(smartRouting bool) + type Properties map[string]string + type ReliableTopicConfig struct + func NewReliableTopicConfig(name string) *ReliableTopicConfig + func (r *ReliableTopicConfig) Name() string + func (r *ReliableTopicConfig) ReadBatchSize() int32 + func (r *ReliableTopicConfig) SetReadBatchSize(readBatchSize int32) + func (r *ReliableTopicConfig) SetTopicOverloadPolicy(policy core.TopicOverloadPolicy) + func (r *ReliableTopicConfig) TopicOverloadPolicy() core.TopicOverloadPolicy + type SSLConfig struct + func NewSSLConfig() *SSLConfig + func (sc *SSLConfig) AddClientCertAndEncryptedKeyPath(clientCertPath string, clientPrivateKeyPath string, password string) error + func (sc *SSLConfig) AddClientCertAndKeyPath(clientCertPath string, clientPrivateKeyPath string) error + func (sc *SSLConfig) Enabled() bool + func (sc *SSLConfig) SetCaPath(path string) error + func (sc *SSLConfig) SetEnabled(enabled bool) + type SecurityConfig struct + func (csc *SecurityConfig) Credentials() security.Credentials + func (csc *SecurityConfig) SetCredentials(credentials security.Credentials)