etcd

Documentation

Index

• Variables
• func DefaultTLSConfig() *tls.Config
• func NextKey(key []byte) []byte
• func TLSConfigWithCertPool(roots *x509.CertPool) *tls.Config
• func TLSConfigWithRoot(cert string) (*tls.Config, error)
• type Client
  • func NewClient(cfg Config) *Client
  • func (c *Client) KV() etcdserverpbconnect.KVClient
  • func (c *Client) Lease() etcdserverpbconnect.LeaseClient
  • func (c *Client) Logger() *zap.Logger
  • func (c *Client) Watch() etcdserverpbconnect.WatchClient
• type Config
• type RetryOptions

Variables

var NoRetry = &RetryOptions{UnaryAttempts: 0}

Functions

func DefaultTLSConfig

func DefaultTLSConfig() *tls.Config

func NextKey

func NextKey(key []byte) []byte

func TLSConfigWithCertPool

func TLSConfigWithCertPool(roots *x509.CertPool) *tls.Config

func TLSConfigWithRoot

func TLSConfigWithRoot(cert string) (*tls.Config, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cfg Config) *Client

func (*Client) KV

func (c *Client) KV() etcdserverpbconnect.KVClient

func (*Client) Lease

func (c *Client) Lease() etcdserverpbconnect.LeaseClient

func (*Client) Logger

func (c *Client) Logger() *zap.Logger

func (*Client) Watch

func (c *Client) Watch() etcdserverpbconnect.WatchClient

type Config

type Config struct {
	Endpoints    []string
	TLSConfig    *tls.Config
	Logger       *zap.Logger
	RetryOptions *RetryOptions
	DialContext  func(context.Context, string, string) (net.Conn, error)
}

type RetryOptions

type RetryOptions struct {
	UnaryAttempts int
	Interval      time.Duration
	Jitter        float64
}