cluster

package

Go to main page

Versions in this module

v1

v1.4.1

Aug 22, 2023

Changes in this version

type CloudConfig

+ ExperimentalAPIBaseURL string

v1.4.0

Mar 17, 2023

Changes in this version

type DiscoveryConfig

+ Strategy discovery.Strategy

type SSLConfig

+ ServerName string

v1.3.2

Feb 9, 2023

v1.3.1

Oct 5, 2022

v1.3.0

Jul 21, 2022

v1.2.1

Jul 7, 2022

v1.2.0

Apr 13, 2022

Changes in this version

type MemberVersion

+ func (m MemberVersion) MajorMinor() uint16

+ func (m MemberVersion) String() string

v1.1.1

Nov 9, 2021

v1.1.0

Sep 14, 2021

Changes in this version

+ 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 NetworkConfig

+ PortRange PortRange

+ func (c *NetworkConfig) SetPortRange(min int, max int)

+ type PortRange struct

+ Max int

+ Min int

+ func (pr *PortRange) Clone() PortRange

v1.0.0

Jul 13, 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 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

+ SSL SSLConfig

+ func (c *NetworkConfig) Clone() NetworkConfig

+ func (c *NetworkConfig) SetAddresses(addrs ...string)

+ func (c *NetworkConfig) Validate() error

+ 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

v1.0.0-preview.4

Jun 18, 2021

v1.0.0-preview.3

Jun 8, 2021

v1.0.0-preview.2

May 21, 2021

v1.0.0-preview.1

May 7, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL