incluster

package
v0.0.80 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2024 License: Apache-2.0 Imports: 32 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, dynamicClient dynamic.Interface, storageClient spdxv1beta1.SpdxV1beta1Interface) *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(_ 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(_ 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(dynamicClient dynamic.Interface, storageClient spdxv1beta1.SpdxV1beta1Interface, cfg config.InCluster, r config.Resource) *Client

func (*Client) Batch added in v0.0.47 

func (c *Client) Batch(ctx context.Context, _ 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(_ 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(_ context.Context, _ string, obj *unstructured.Unstructured, _ metav1.ApplyOptions, _ ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) ApplyStatus added in v0.0.67 

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

func (*NoOpDynamicResource) Create added in v0.0.67 

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

func (*NoOpDynamicResource) Delete added in v0.0.67 

func (n *NoOpDynamicResource) Delete(_ context.Context, _ string, _ metav1.DeleteOptions, _ ...string) error

func (*NoOpDynamicResource) DeleteCollection added in v0.0.67 

func (n *NoOpDynamicResource) DeleteCollection(_ context.Context, _ metav1.DeleteOptions, _ metav1.ListOptions) error

func (*NoOpDynamicResource) Get added in v0.0.67 

func (n *NoOpDynamicResource) Get(_ context.Context, _ string, _ metav1.GetOptions, _ ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) List added in v0.0.67 

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

func (*NoOpDynamicResource) Namespace added in v0.0.67 

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

func (*NoOpDynamicResource) Patch added in v0.0.67 

func (n *NoOpDynamicResource) Patch(_ context.Context, _ string, _ types.PatchType, _ []byte, _ metav1.PatchOptions, _ ...string) (*unstructured.Unstructured, error)

func (*NoOpDynamicResource) Update added in v0.0.67 

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

func (*NoOpDynamicResource) UpdateStatus added in v0.0.67 

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

func (*NoOpDynamicResource) Watch added in v0.0.67 

func (n *NoOpDynamicResource) Watch(_ context.Context, _ 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.