incluster

package
v0.0.72 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 31, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Adapter 

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

func NewInClusterAdapter 

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

func (*Adapter) Batch added in v0.0.47 

func (a *Adapter) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, items domain.BatchItems) error

func (*Adapter) Callbacks added in v0.0.5 

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 added in v0.0.23 

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

func (*Adapter) GetClientByKind added in v0.0.47 

func (a *Adapter) GetClientByKind(kind domain.Kind) adapters.Client

func (*Adapter) GetObject 

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

func (*Adapter) IsRelated added in v0.0.38 

func (a *Adapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool

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) Stop added in v0.0.38 

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

func (*Adapter) VerifyObject 

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

type BatchProcessingFunc added in v0.0.47 

type BatchProcessingFunc func(context.Context, *Client, domain.BatchItems) 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, cfg config.InCluster, r config.Resource) *Client

func (*Client) Batch added in v0.0.47 

func (c *Client) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, items domain.BatchItems) error

func (*Client) Callbacks added in v0.0.5 

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) IsRelated added in v0.0.38 

func (c *Client) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool

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) Stop added in v0.0.38 

func (c *Client) Stop(_ context.Context) error

func (*Client) VerifyObject 

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

type NoOpDynamicClient added in v0.0.67 

type NoOpDynamicClient struct {
}

func (*NoOpDynamicClient) Resource added in v0.0.67 

func (n *NoOpDynamicClient) Resource(gvr schema.GroupVersionResource) dynamic.NamespaceableResourceInterface

type NoOpDynamicResource added in v0.0.67 

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

func (*NoOpDynamicResource) Apply added in v0.0.67 

func (n *NoOpDynamicResource) Apply(ctx context.Context, name string, obj *unstructured.Unstructured, options metav1.ApplyOptions, subresources ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) ApplyStatus added in v0.0.67 

func (n *NoOpDynamicResource) ApplyStatus(ctx context.Context, name string, obj *unstructured.Unstructured, options metav1.ApplyOptions) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) Create added in v0.0.67 

func (n *NoOpDynamicResource) Create(ctx context.Context, obj *unstructured.Unstructured, options metav1.CreateOptions, subresources ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) Delete added in v0.0.67 

func (n *NoOpDynamicResource) Delete(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error

func (*NoOpDynamicResource) DeleteCollection added in v0.0.67 

func (n *NoOpDynamicResource) DeleteCollection(ctx context.Context, options metav1.DeleteOptions, listOptions metav1.ListOptions) error

func (*NoOpDynamicResource) Get added in v0.0.67 

func (n *NoOpDynamicResource) Get(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) List added in v0.0.67 

func (n *NoOpDynamicResource) List(ctx context.Context, opts metav1.ListOptions) (*unstructured.UnstructuredList, error)

func (*NoOpDynamicResource) Namespace added in v0.0.67 

func (n *NoOpDynamicResource) Namespace(namespace string) dynamic.ResourceInterface

func (*NoOpDynamicResource) Patch added in v0.0.67 

func (n *NoOpDynamicResource) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) Update added in v0.0.67 

func (n *NoOpDynamicResource) Update(ctx context.Context, obj *unstructured.Unstructured, options metav1.UpdateOptions, subresources ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) UpdateStatus added in v0.0.67 

func (n *NoOpDynamicResource) UpdateStatus(ctx context.Context, obj *unstructured.Unstructured, options metav1.UpdateOptions) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) Watch added in v0.0.67 

func (n *NoOpDynamicResource) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)

type NoOpWatch added in v0.0.67 

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

watch.Interface

func (*NoOpWatch) ResultChan added in v0.0.67 

func (n *NoOpWatch) ResultChan() <-chan watch.Event

func (*NoOpWatch) Stop added in v0.0.67 

func (n *NoOpWatch) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.