compat

Documentation

Index

• func ToTagsLabelsRules(d *model.KVPair) (t, l, r *model.KVPair)
• type ModelAdaptor
  • func NewAdaptor(c api.Client) *ModelAdaptor
  • func (c *ModelAdaptor) Apply(d *model.KVPair) (*model.KVPair, error)
  • func (c *ModelAdaptor) Create(d *model.KVPair) (*model.KVPair, error)
  • func (c *ModelAdaptor) Delete(d *model.KVPair) error
  • func (c *ModelAdaptor) EnsureCalicoNodeInitialized(node string) error
  • func (c *ModelAdaptor) EnsureInitialized() error
  • func (c *ModelAdaptor) Get(k model.Key) (*model.KVPair, error)
  • func (c *ModelAdaptor) List(l model.ListInterface) ([]*model.KVPair, error)
  • func (c *ModelAdaptor) Syncer(callbacks api.SyncerCallbacks) api.Syncer
  • func (c *ModelAdaptor) Update(d *model.KVPair) (*model.KVPair, error)

Functions

func ToTagsLabelsRules

func ToTagsLabelsRules(d *model.KVPair) (t, l, r *model.KVPair)

ToTagsLabelsRules converts a Profile KVPair to separate KVPair types for Keys, Labels and Rules. These separate KVPairs are used to write three separate objects that make up a single profile.

Types

type ModelAdaptor

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

func NewAdaptor

func NewAdaptor(c api.Client) *ModelAdaptor

func (*ModelAdaptor) Apply

func (c *ModelAdaptor) Apply(d *model.KVPair) (*model.KVPair, error)

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

func (*ModelAdaptor) Create

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

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

func (*ModelAdaptor) Delete

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

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

func (*ModelAdaptor) EnsureCalicoNodeInitialized

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

func (*ModelAdaptor) EnsureInitialized

func (c *ModelAdaptor) EnsureInitialized() error

func (*ModelAdaptor) Get

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

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

func (*ModelAdaptor) List

func (c *ModelAdaptor) 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 (*ModelAdaptor) Syncer

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

func (*ModelAdaptor) Update

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

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