etcd

Documentation

Index

• type EtcdClient
  • func NewEtcdClient(config *v1.EtcdConfig) (*EtcdClient, error)
  • func (c *EtcdClient) Apply(ctx context.Context, d *model.KVPair) (*model.KVPair, error)
  • func (c *EtcdClient) Create(d *model.KVPair) (*model.KVPair, error)
  • func (c *EtcdClient) Delete(d *model.KVPair) error
  • func (c *EtcdClient) EnsureCalicoNodeInitialized(node string) error
  • func (c *EtcdClient) EnsureInitialized() error
  • func (c *EtcdClient) Get(k model.Key) (*model.KVPair, error)
  • func (c *EtcdClient) List(l model.ListInterface) ([]*model.KVPair, error)
  • func (c *EtcdClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer
  • func (c *EtcdClient) Update(d *model.KVPair) (*model.KVPair, error)

Types

type EtcdClient

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

func NewEtcdClient

func NewEtcdClient(config *v1.EtcdConfig) (*EtcdClient, error)

func (*EtcdClient) Apply

func (c *EtcdClient) Apply(ctx context.Context, d *model.KVPair) (*model.KVPair, error)

Set an existing entry in the datastore. This ignores whether an entry already exists.

func (*EtcdClient) Create

func (c *EtcdClient) Create(d *model.KVPair) (*model.KVPair, error)

Create an entry in the datastore. This errors if the entry already exists.

func (*EtcdClient) Delete

func (c *EtcdClient) Delete(d *model.KVPair) error

Delete an entry in the datastore. This errors if the entry does not exists.

func (*EtcdClient) EnsureCalicoNodeInitialized

func (c *EtcdClient) EnsureCalicoNodeInitialized(node string) error

EnsureCalicoNodeInitialized performs additional initialization required by the calico/node components startup/ipip-allocation/confd. This is a temporary requirement until the calico/node components are updated to not require special etcd setup, or until the global and per-node config is reworked to allow the node to perform the necessary updates.

func (*EtcdClient) EnsureInitialized

func (c *EtcdClient) EnsureInitialized() error

EnsureInitialized makes sure that the etcd data is initialized for use by Calico.

func (*EtcdClient) Get

func (c *EtcdClient) Get(k model.Key) (*model.KVPair, error)

Get an entry from the datastore. This errors if the entry does not exist.

func (*EtcdClient) List

func (c *EtcdClient) List(l model.ListInterface) ([]*model.KVPair, error)

List entries in the datastore. This may return an empty list of there are no entries matching the request in the ListInterface.

func (*EtcdClient) Syncer

func (c *EtcdClient) Syncer(callbacks api.SyncerCallbacks) api.Syncer

func (*EtcdClient) Update

func (c *EtcdClient) Update(d *model.KVPair) (*model.KVPair, error)

Update an existing entry in the datastore. This errors if the entry does not exist.