incluster

Documentation

Index

• type Adapter
  • func NewInClusterAdapter(cfg config.InCluster, k8sclient dynamic.Interface) *Adapter
  • func (a *Adapter) Callbacks(_ context.Context) (domain.Callbacks, error)
  • func (a *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error
  • func (a *Adapter) GetClient(id domain.KindName) (adapters.Client, error)
  • func (a *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
  • func (a *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
  • func (a *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error
  • func (a *Adapter) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
  • func (a *Adapter) Start(ctx context.Context) error
  • func (a *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
• type Client
  • func NewClient(client dynamic.Interface, account, cluster string, r config.Resource) *Client
  • func (c *Client) Callbacks(_ context.Context) (domain.Callbacks, error)
  • func (c *Client) DeleteObject(_ context.Context, id domain.KindName) error
  • func (c *Client) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
  • func (c *Client) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
  • func (c *Client) PutObject(_ context.Context, id domain.KindName, object []byte) error
  • func (c *Client) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, newChecksum string) error

Types

type Adapter

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

func NewInClusterAdapter

func NewInClusterAdapter(cfg config.InCluster, k8sclient dynamic.Interface) *Adapter

func (*Adapter) Callbacks

func (a *Adapter) Callbacks(_ context.Context) (domain.Callbacks, error)

func (*Adapter) DeleteObject

func (a *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error

func (*Adapter) GetClient

func (a *Adapter) GetClient(id domain.KindName) (adapters.Client, error)

func (*Adapter) GetObject

func (a *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error

func (*Adapter) PatchObject

func (a *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error

func (*Adapter) PutObject

func (a *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error

func (*Adapter) RegisterCallbacks

func (a *Adapter) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context) error

func (*Adapter) VerifyObject

func (a *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error

type Client

type Client struct {
	ShadowObjects map[string][]byte
	Strategy      domain.Strategy
	// contains filtered or unexported fields
}

func NewClient

func NewClient(client dynamic.Interface, account, cluster string, r config.Resource) *Client

func (*Client) Callbacks

func (c *Client) Callbacks(_ context.Context) (domain.Callbacks, error)

func (*Client) DeleteObject

func (c *Client) DeleteObject(_ context.Context, id domain.KindName) error

func (*Client) GetObject

func (c *Client) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error

func (*Client) PatchObject

func (c *Client) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error

func (*Client) PutObject

func (c *Client) PutObject(_ context.Context, id domain.KindName, object []byte) error

func (*Client) RegisterCallbacks

func (c *Client) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) VerifyObject

func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, newChecksum string) error