lib

package
v0.0.50 Latest Latest
Warning

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

Go to latest
Published: Feb 24, 2026 License: Apache-2.0 Imports: 45 Imported by: 170

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewConnection

func NewConnection(licenseID string, natscred NatsCredential) (nc *nats.Conn, err error)

NewConnection creates a new NATS connection

Types

type AuditEventCreator

type AuditEventCreator struct {
	Mapper discovery.ResourceMapper
}

func (*AuditEventCreator) CreateEvent

func (p *AuditEventCreator) CreateEvent(obj client.Object) (*api.Event, error)

type BillingEventCreator

type BillingEventCreator struct {
	Mapper          discovery.ResourceMapper
	ClusterMetadata *kmapi.ClusterMetadata
	ClientBilling   bool
	NamespaceLister client.Reader
	PodLister       client.Reader
	PVCLister       client.Reader
}

func (*BillingEventCreator) CreateEvent

func (p *BillingEventCreator) CreateEvent(obj client.Object) (*api.Event, error)

type EventCreator

type EventCreator func(obj client.Object) (*api.Event, error)

type EventPublisher

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

func NewEventPublisher

func NewEventPublisher(
	c *NatsClient,
	mapper discovery.ResourceMapper,
	fn EventCreator,
) *EventPublisher

func (*EventPublisher) ForGVK added in v0.0.3

func (p *EventPublisher) ForGVK(informer Informer, gvk schema.GroupVersionKind)

func (*EventPublisher) Publish

func (p *EventPublisher) Publish(ev *api.Event, et api.EventType) error

func (*EventPublisher) SetupSiteInfoPublisher added in v0.0.8

func (p *EventPublisher) SetupSiteInfoPublisher(cfg *rest.Config, kc kubernetes.Interface, factory informers.SharedInformerFactory) error

func (*EventPublisher) SetupSiteInfoPublisherWithManager added in v0.0.11

func (p *EventPublisher) SetupSiteInfoPublisherWithManager(mgr manager.Manager) error

func (*EventPublisher) SetupWithManager

func (p *EventPublisher) SetupWithManager(ctx context.Context, mgr manager.Manager, obj client.Object) error

func (*EventPublisher) SetupWithManagerForKind

func (p *EventPublisher) SetupWithManagerForKind(ctx context.Context, mgr manager.Manager, gvk schema.GroupVersionKind) error

type Informer added in v0.0.28

type Informer interface {
	// AddEventHandlerWithResyncPeriod adds an event handler to the shared informer using the
	// specified resync period.  Events to a single handler are delivered sequentially, but there is
	// no coordination between different handlers.
	AddEventHandlerWithResyncPeriod(handler cache.ResourceEventHandler, resyncPeriod time.Duration) (cache.ResourceEventHandlerRegistration, error)
}

Informer - informer allows you interact with the underlying informer.

type NamespaceReader added in v0.0.42

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

func NewNamespaceReader added in v0.0.42

func NewNamespaceReader(delegate corelisters.NamespaceLister) NamespaceReader

func (NamespaceReader) Get added in v0.0.42

func (NamespaceReader) List added in v0.0.42

type NatsClient added in v0.0.40

type NatsClient struct {
	LicenseFile string

	Subject string
	Server  string
	// contains filtered or unexported fields
}

func NewNatsClient added in v0.0.40

func NewNatsClient(cfg *rest.Config, clusterID string, LicenseFile string) *NatsClient

func (*NatsClient) Connect added in v0.0.46

func (c *NatsClient) Connect() (*nats.Conn, error)

func (*NatsClient) GetLicenseID added in v0.0.40

func (c *NatsClient) GetLicenseID() (string, error)

func (*NatsClient) Request added in v0.0.40

func (c *NatsClient) Request(data []byte, timeout time.Duration) (*nats.Msg, error)

type NatsConfig

type NatsConfig struct {
	Subject string `json:"natsSubject"`
	Server  string `json:"natsServer"`
}

type NatsCredential

type NatsCredential struct {
	NatsConfig `json:",inline"`
	Credential []byte `json:"credential"`
}

NatsCredential represents the api response of the register licensed user api

type PersistentVolumeClaimReader added in v0.0.40

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

func NewPersistentVolumeClaimReader added in v0.0.40

func NewPersistentVolumeClaimReader(delegate corelisters.PersistentVolumeClaimLister) PersistentVolumeClaimReader

func (PersistentVolumeClaimReader) Get added in v0.0.40

func (PersistentVolumeClaimReader) List added in v0.0.40

type PodReader added in v0.0.40

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

func NewPodReader added in v0.0.40

func NewPodReader(delegate corelisters.PodLister) PodReader

func (PodReader) Get added in v0.0.40

func (PodReader) List added in v0.0.40

func (r PodReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

type Resource added in v0.0.40

type Resource interface {
	OffshootSelectors() map[string]string
}

type ResourceEventPublisher added in v0.0.3

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

func (*ResourceEventPublisher) OnAdd added in v0.0.3

func (p *ResourceEventPublisher) OnAdd(o any, isInInitialList bool)

func (*ResourceEventPublisher) OnDelete added in v0.0.3

func (p *ResourceEventPublisher) OnDelete(obj any)

func (*ResourceEventPublisher) OnUpdate added in v0.0.3

func (p *ResourceEventPublisher) OnUpdate(oldObj, newObj any)

type ResourceExtra added in v0.0.44

type ResourceExtra interface {
	OffshootSelectors(extraSelectors ...map[string]string) map[string]string
}

type SiteInfoPublisher added in v0.0.31

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

func (*SiteInfoPublisher) OnAdd added in v0.0.31

func (p *SiteInfoPublisher) OnAdd(o any, isInInitialList bool)

func (*SiteInfoPublisher) OnDelete added in v0.0.31

func (p *SiteInfoPublisher) OnDelete(obj any)

func (*SiteInfoPublisher) OnUpdate added in v0.0.31

func (p *SiteInfoPublisher) OnUpdate(oldObj, newObj any)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL