source

Documentation

Index

• func StartManifestWorkSourceClient(ctx context.Context, sourceID string, config any) (*work.ClientHolder, workv1informers.ManifestWorkInformer, error)
• func StartResourceSourceClient(ctx context.Context, options *options.CloudEventsSourceOptions, ...) (generic.CloudEventsClient[*store.Resource], error)
• func StatusHashGetter(obj *store.Resource) (string, error)
• type ResourceCodec
  • func (c *ResourceCodec) Decode(evt *cloudevents.Event) (*store.Resource, error)
  • func (c *ResourceCodec) Encode(source string, eventType types.CloudEventsType, resource *store.Resource) (*cloudevents.Event, error)
  • func (c *ResourceCodec) EventDataType() types.CloudEventsDataType
• type ResourceLister
  • func NewResourceLister(store *store.MemoryStore) *ResourceLister
  • func (l *ResourceLister) List(listOpts types.ListOptions) ([]*store.Resource, error)

Functions

func StartManifestWorkSourceClient

func StartManifestWorkSourceClient(
	ctx context.Context,
	sourceID string,
	config any,
) (*work.ClientHolder, workv1informers.ManifestWorkInformer, error)

func StartResourceSourceClient

func StartResourceSourceClient(
	ctx context.Context,
	options *options.CloudEventsSourceOptions,
	sourceID string,
	lister *ResourceLister,
) (generic.CloudEventsClient[*store.Resource], error)

func StatusHashGetter

func StatusHashGetter(obj *store.Resource) (string, error)

Types

type ResourceCodec

type ResourceCodec struct{}

func (*ResourceCodec) Decode

func (c *ResourceCodec) Decode(evt *cloudevents.Event) (*store.Resource, error)

func (*ResourceCodec) Encode

func (c *ResourceCodec) Encode(source string, eventType types.CloudEventsType, resource *store.Resource) (*cloudevents.Event, error)

func (*ResourceCodec) EventDataType

func (c *ResourceCodec) EventDataType() types.CloudEventsDataType

type ResourceLister

type ResourceLister struct {
	Store *store.MemoryStore
}

func NewResourceLister

func NewResourceLister(store *store.MemoryStore) *ResourceLister

func (*ResourceLister) List

func (l *ResourceLister) List(listOpts types.ListOptions) ([]*store.Resource, error)