synchro

Documentation

Index

• type Client
  • func NewClient(cfg config.Config, client dynamic.Interface, outPool *ants.PoolWithFunc, ...) *Client
  • func (c *Client) HandleSyncAdd(key string, newObject []byte) error
  • func (c *Client) HandleSyncDelete(key string) error
  • func (c *Client) HandleSyncRetrieve(key string) error
  • func (c *Client) HandleSyncUpdateShadow(key string, newObject []byte) error
  • func (c *Client) Run()

Types

type Client

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

func NewClient

func NewClient(cfg config.Config, client dynamic.Interface, outPool *ants.PoolWithFunc, r config.Resource) *Client

func (*Client) HandleSyncAdd

func (c *Client) HandleSyncAdd(key string, newObject []byte) error

func (*Client) HandleSyncDelete

func (c *Client) HandleSyncDelete(key string) error

func (*Client) HandleSyncRetrieve

func (c *Client) HandleSyncRetrieve(key string) error

func (*Client) HandleSyncUpdateShadow

func (c *Client) HandleSyncUpdateShadow(key string, newObject []byte) error

func (*Client) Run

func (c *Client) Run()