etcdio

Documentation

Overview

The etcdio package provides utilities to manage etcd I/O.

Index

• Variables
• type Client
  • func NewClient(log *slog.Logger) *Client
  • func (c *Client) PrioritizeIO()

Variables

var (
	// ErrNoEtcdProcess is returned when no etcd process is found on the node.
	ErrNoEtcdProcess = errors.New("no etcd process found on node")
	// ErrMultipleEtcdProcesses is returned when multiple etcd processes are found on the node.
	ErrMultipleEtcdProcesses = errors.New("multiple etcd processes found on node")
)

Types

type Client

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

Client is a client for managing etcd I/O.

func NewClient

func NewClient(log *slog.Logger) *Client

NewClient creates a new etcd I/O management client.

func (*Client) PrioritizeIO

func (c *Client) PrioritizeIO()

PrioritizeIO tries to prioritize the I/O of the etcd process. Since it might be possible that the process just started (if this method is called right after the kubelet started), it retries to do its work each second until it succeeds or the timeout of 10 seconds is reached.