Documentation
¶
Index ¶
- func NewConnection(licenseID string, natscred NatsCredential) (nc *nats.Conn, err error)
- type AuditEventCreator
- type BillingEventCreator
- type EventCreator
- type EventPublisher
- func (p *EventPublisher) ForGVK(informer Informer, gvk schema.GroupVersionKind)
- func (p *EventPublisher) Publish(ev *api.Event, et api.EventType) error
- func (p *EventPublisher) SetupSiteInfoPublisher(cfg *rest.Config, kc kubernetes.Interface, ...) error
- func (p *EventPublisher) SetupSiteInfoPublisherWithManager(mgr manager.Manager) error
- func (p *EventPublisher) SetupWithManager(ctx context.Context, mgr manager.Manager, obj client.Object) error
- func (p *EventPublisher) SetupWithManagerForKind(ctx context.Context, mgr manager.Manager, gvk schema.GroupVersionKind) error
- type Informer
- type NamespaceReader
- type NatsClient
- type NatsConfig
- type NatsCredential
- type PersistentVolumeClaimReader
- type PodReader
- type Resource
- type ResourceEventPublisher
- type ResourceExtra
- type SiteInfoPublisher
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 ¶
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 ¶
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) 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 (*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) List ¶ added in v0.0.42
func (r NamespaceReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
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) GetLicenseID ¶ added in v0.0.40
func (c *NatsClient) GetLicenseID() (string, error)
type NatsConfig ¶
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) List ¶ added in v0.0.40
func (r PersistentVolumeClaimReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
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) List ¶ added in v0.0.40
func (r PodReader) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
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 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)
Click to show internal directories.
Click to hide internal directories.