util

package
v0.0.0-...-9b27197 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

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

func (cfg *CommonRingConfig) RegisterFlags(flagPrefix, kvStorePrefix, defaultRingKey, componentPlural string, f *flag.FlagSet, log log.Logger)

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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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