Versions in this module Expand all Collapse all v1 v1.2.1 Nov 9, 2021 Changes in this version + type Address string + func NewAddress(host string, port int32) Address + func (a Address) Equal(b Address) bool + func (a Address) String() string + type CloudConfig struct + Enabled bool + Token string + func (h CloudConfig) Clone() CloudConfig + func (h CloudConfig) Validate() error + type Config struct + Cloud CloudConfig + ConnectionStrategy ConnectionStrategyConfig + Discovery DiscoveryConfig + HeartbeatInterval types.Duration + HeartbeatTimeout types.Duration + InvocationTimeout types.Duration + Name string + Network NetworkConfig + RedoOperation bool + Security SecurityConfig + Unisocket bool + func (c *Config) Clone() Config + func (c *Config) LoadBalancer() LoadBalancer + func (c *Config) SetLoadBalancer(lb LoadBalancer) + func (c *Config) Validate() error + type ConnectionRetryConfig struct + InitialBackoff types.Duration + Jitter float64 + MaxBackoff types.Duration + Multiplier float64 + func (c *ConnectionRetryConfig) Validate() error + func (c ConnectionRetryConfig) Clone() ConnectionRetryConfig + type ConnectionStrategyConfig struct + ReconnectMode ReconnectMode + Retry ConnectionRetryConfig + Timeout types.Duration + func (c *ConnectionStrategyConfig) Validate() error + func (c ConnectionStrategyConfig) Clone() ConnectionStrategyConfig + type CredentialsConfig struct + Password string + Username string + func (c CredentialsConfig) Clone() CredentialsConfig + func (c CredentialsConfig) Validate() error + type DiscoveryConfig struct + UsePublicIP bool + func (c DiscoveryConfig) Clone() DiscoveryConfig + func (c DiscoveryConfig) Validate() error + type EndpointQualifier struct + Identifier string + Type EndpointQualifierType + type EndpointQualifierType int32 + const EndpointQualifierTypeClient + const EndpointQualifierTypeMemCache + const EndpointQualifierTypeMember + const EndpointQualifierTypeRest + const EndpointQualifierTypeWan + func (t EndpointQualifierType) String() string + type FailoverConfig struct + Configs []Config + Enabled bool + TryCount int + func (c *FailoverConfig) Clone() FailoverConfig + func (c *FailoverConfig) SetConfigs(configs ...Config) + func (c *FailoverConfig) Validate(root Config) error + type LoadBalancer interface + OneOf func(addrs []Address) Address + type MemberInfo struct + Address Address + AddressMap map[EndpointQualifier]Address + Attributes map[string]string + LiteMember bool + UUID types.UUID + Version MemberVersion + func (mi *MemberInfo) PublicAddress() (addr Address, ok bool) + func (mi MemberInfo) String() string + type MemberVersion struct + Major byte + Minor byte + Patch byte + type MembershipState int + const MembershipStateAdded + const MembershipStateRemoved + func (m MembershipState) String() string + type MembershipStateChangeHandler func(event MembershipStateChanged) + type MembershipStateChanged struct + Member MemberInfo + State MembershipState + func (e *MembershipStateChanged) EventName() string + type NetworkConfig struct + Addresses []string + ConnectionTimeout types.Duration + PortRange PortRange + SSL SSLConfig + func (c *NetworkConfig) Clone() NetworkConfig + func (c *NetworkConfig) SetAddresses(addrs ...string) + func (c *NetworkConfig) SetPortRange(min int, max int) + func (c *NetworkConfig) Validate() error + type PortRange struct + Max int + Min int + func (pr *PortRange) Clone() PortRange + type RandomLoadBalancer rand.Rand + func NewRandomLoadBalancer() *RandomLoadBalancer + func (lb *RandomLoadBalancer) OneOf(addrs []Address) Address + type ReconnectMode int + const ReconnectModeOff + const ReconnectModeOn + func (rm *ReconnectMode) UnmarshalText(b []byte) error + func (rm ReconnectMode) MarshalText() ([]byte, error) + type RoundRobinLoadBalancer int + func NewRoundRobinLoadBalancer() *RoundRobinLoadBalancer + func (r *RoundRobinLoadBalancer) OneOf(addrs []Address) Address + type SSLConfig struct + Enabled bool + func (c *SSLConfig) AddClientCertAndEncryptedKeyPath(certPath string, privateKeyPath string, password string) error + func (c *SSLConfig) AddClientCertAndKeyPath(clientCertPath string, clientPrivateKeyPath string) error + func (c *SSLConfig) Clone() SSLConfig + func (c *SSLConfig) SetCAPath(path string) error + func (c *SSLConfig) SetTLSConfig(tlsConfig *tls.Config) + func (c *SSLConfig) TLSConfig() *tls.Config + func (c *SSLConfig) Validate() error + type SecurityConfig struct + Credentials CredentialsConfig + func (c *SecurityConfig) Validate() error + func (c SecurityConfig) Clone() SecurityConfig