Documentation
¶
Index ¶
- type AutoMarkUnhealthyDelegate
- func (d *AutoMarkUnhealthyDelegate) OnRingInstanceHeartbeat(lifecycler *ring.BasicLifecycler, ringDesc *ring.Desc, ...)
- func (d *AutoMarkUnhealthyDelegate) OnRingInstanceRegister(lifecycler *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, ...) (ring.InstanceState, ring.Tokens)
- func (d *AutoMarkUnhealthyDelegate) OnRingInstanceStopping(lifecycler *ring.BasicLifecycler)
- func (d *AutoMarkUnhealthyDelegate) OnRingInstanceTokens(lifecycler *ring.BasicLifecycler, tokens ring.Tokens)
- type ClientConfig
- type CommonKVConfig
- type CommonKVStoreConfig
- type CommonRingConfig
- type ConsulConfig
- type EtcdConfig
- type HealthyInstanceDelegate
- func (d *HealthyInstanceDelegate) OnRingInstanceHeartbeat(lifecycler *ring.BasicLifecycler, ringDesc *ring.Desc, ...)
- func (d *HealthyInstanceDelegate) OnRingInstanceRegister(lifecycler *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, ...) (ring.InstanceState, ring.Tokens)
- func (d *HealthyInstanceDelegate) OnRingInstanceStopping(lifecycler *ring.BasicLifecycler)
- func (d *HealthyInstanceDelegate) OnRingInstanceTokens(lifecycler *ring.BasicLifecycler, tokens ring.Tokens)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AutoMarkUnhealthyDelegate ¶
type AutoMarkUnhealthyDelegate struct {
// contains filtered or unexported fields
}
Auto mark unhealthy delegate stuff
func NewAutoMarkUnhealthyDelegate ¶
func NewAutoMarkUnhealthyDelegate(forgetPeriod time.Duration, next ring.BasicLifecyclerDelegate, log log.Logger) *AutoMarkUnhealthyDelegate
func (*AutoMarkUnhealthyDelegate) OnRingInstanceHeartbeat ¶
func (d *AutoMarkUnhealthyDelegate) OnRingInstanceHeartbeat(lifecycler *ring.BasicLifecycler, ringDesc *ring.Desc, instanceDesc *ring.InstanceDesc)
func (*AutoMarkUnhealthyDelegate) OnRingInstanceRegister ¶
func (d *AutoMarkUnhealthyDelegate) OnRingInstanceRegister(lifecycler *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, instanceID string, instanceDesc ring.InstanceDesc) (ring.InstanceState, ring.Tokens)
func (*AutoMarkUnhealthyDelegate) OnRingInstanceStopping ¶
func (d *AutoMarkUnhealthyDelegate) OnRingInstanceStopping(lifecycler *ring.BasicLifecycler)
func (*AutoMarkUnhealthyDelegate) OnRingInstanceTokens ¶
func (d *AutoMarkUnhealthyDelegate) OnRingInstanceTokens(lifecycler *ring.BasicLifecycler, tokens ring.Tokens)
type ClientConfig ¶
type ClientConfig struct {
CertPath string `mapstructure:"tls_cert_path" category:"advanced"`
KeyPath string `mapstructure:"tls_key_path" category:"advanced"`
CAPath string `mapstructure:"tls_ca_path" category:"advanced"`
ServerName string `mapstructure:"tls_server_name" category:"advanced"`
InsecureSkipVerify bool `mapstructure:"tls_insecure_skip_verify" category:"advanced"`
CipherSuites string `mapstructure:"tls_cipher_suites" category:"advanced" doc:"description_method=GetTLSCipherSuitesLongDescription"`
MinVersion string `mapstructure:"tls_min_version" category:"advanced"`
}
func (*ClientConfig) RegisterFlagsWithPrefix ¶
func (cfg *ClientConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
type CommonKVConfig ¶
type CommonKVConfig struct {
Store string `mapstructure:"store"`
Prefix string `mapstructure:"prefix"`
CommonKVStoreConfig `mapstructure:",squash"`
}
func (*CommonKVConfig) RegisterFlagsWithPrefix ¶
func (cfg *CommonKVConfig) RegisterFlagsWithPrefix(flagsPrefix, defaultPrefix string, f *flag.FlagSet)
func (*CommonKVConfig) ToKVConfig ¶
func (c *CommonKVConfig) ToKVConfig() kv.Config
type CommonKVStoreConfig ¶
type CommonKVStoreConfig struct {
Consul ConsulConfig `mapstructure:"consul"`
Etcd EtcdConfig `mapstructure:"etcd"`
MemberlistKV func() (*memberlist.KV, error) `mapstructure:"-"`
}
type CommonRingConfig ¶
type CommonRingConfig struct {
Key string `mapstructure:"key"`
HeartbeatPeriod time.Duration `mapstructure:"heartbeat_period"`
HeartbeatTimeout time.Duration `mapstructure:"heartbeat_timeout"`
InstanceID string `mapstructure:"instance_id"`
KVStore CommonKVConfig `mapstructure:"kvstore"`
}
func (*CommonRingConfig) RegisterFlags ¶
type ConsulConfig ¶
type ConsulConfig struct {
Host string `mapstructure:"host"`
ACLToken string `mapstructure:"acl_token" category:"advanced"`
HTTPClientTimeout time.Duration `mapstructure:"http_client_timeout" category:"advanced"`
ConsistentReads bool `mapstructure:"consistent_reads" category:"advanced"`
WatchKeyRateLimit float64 `mapstructure:"watch_rate_limit" category:"advanced"`
WatchKeyBurstSize int `mapstructure:"watch_burst_size" category:"advanced"`
CasRetryDelay time.Duration `mapstructure:"cas_retry_delay" category:"advanced"`
}
Consul config
func (*ConsulConfig) RegisterFlags ¶
func (cfg *ConsulConfig) RegisterFlags(f *flag.FlagSet, prefix string)
type EtcdConfig ¶
type EtcdConfig struct {
Endpoints []string `mapstructure:"endpoints"`
DialTimeout time.Duration `mapstructure:"dial_timeout" category:"advanced"`
MaxRetries int `mapstructure:"max_retries" category:"advanced"`
EnableTLS bool `mapstructure:"tls_enabled" category:"advanced"`
TLS ClientConfig `mapstructure:",inline"`
UserName string `mapstructure:"username"`
Password string `mapstructure:"password"`
}
Etcd configs
func (*EtcdConfig) RegisterFlagsWithPrefix ¶
func (cfg *EtcdConfig) RegisterFlagsWithPrefix(f *flag.FlagSet, prefix string)
type HealthyInstanceDelegate ¶
type HealthyInstanceDelegate struct {
// contains filtered or unexported fields
}
Healthy instance delegate stuff
func NewHealthyInstanceDelegate ¶
func NewHealthyInstanceDelegate(count *atomic.Uint32, heartbeatTimeout time.Duration, next ring.BasicLifecyclerDelegate) *HealthyInstanceDelegate
func (*HealthyInstanceDelegate) OnRingInstanceHeartbeat ¶
func (d *HealthyInstanceDelegate) OnRingInstanceHeartbeat(lifecycler *ring.BasicLifecycler, ringDesc *ring.Desc, instanceDesc *ring.InstanceDesc)
func (*HealthyInstanceDelegate) OnRingInstanceRegister ¶
func (d *HealthyInstanceDelegate) OnRingInstanceRegister(lifecycler *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, instanceID string, instanceDesc ring.InstanceDesc) (ring.InstanceState, ring.Tokens)
func (*HealthyInstanceDelegate) OnRingInstanceStopping ¶
func (d *HealthyInstanceDelegate) OnRingInstanceStopping(lifecycler *ring.BasicLifecycler)
func (*HealthyInstanceDelegate) OnRingInstanceTokens ¶
func (d *HealthyInstanceDelegate) OnRingInstanceTokens(lifecycler *ring.BasicLifecycler, tokens ring.Tokens)
Click to show internal directories.
Click to hide internal directories.