lib

Documentation

Index

• func NewConnection(natscred NatsCredential) (nc *nats.Conn, err error)
• type AuditEventCreator
  • func (p *AuditEventCreator) CreateEvent(obj client.Object) (*api.Event, error)
• type BillingEventCreator
  • func (p *BillingEventCreator) CreateEvent(obj client.Object) (*api.Event, error)
• type EventCreator
• type EventPublisher
  • func NewEventPublisher(nats *NatsConfig, mapper discovery.ResourceMapper, fn EventCreator) *EventPublisher
  • func NewResilientEventPublisher(fnConnect func() (*NatsConfig, error), mapper discovery.ResourceMapper, ...) *EventPublisher
  • func (p *EventPublisher) ForGVK(gvk schema.GroupVersionKind) cache.ResourceEventHandler
  • func (p *EventPublisher) NatsClient() (*nats.Conn, error)
  • 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 NatsConfig
  • func NewNatsConfig(clusterID string, LicenseFile string) (*NatsConfig, error)
• type NatsCredential
• type ResourceEventPublisher
  • func (p *ResourceEventPublisher) OnAdd(o interface{})
  • func (p *ResourceEventPublisher) OnDelete(obj interface{})
  • func (p *ResourceEventPublisher) OnUpdate(oldObj, newObj interface{})

Functions

func NewConnection

func NewConnection(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
}

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(
	nats *NatsConfig,
	mapper discovery.ResourceMapper,
	fn EventCreator,
) *EventPublisher

func NewResilientEventPublisher

func NewResilientEventPublisher(
	fnConnect func() (*NatsConfig, error),
	mapper discovery.ResourceMapper,
	fnCreateEvent EventCreator,
) *EventPublisher

func (*EventPublisher) ForGVK

func (p *EventPublisher) ForGVK(gvk schema.GroupVersionKind) cache.ResourceEventHandler

func (*EventPublisher) NatsClient

func (p *EventPublisher) NatsClient() (*nats.Conn, error)

func (*EventPublisher) Publish

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

func (*EventPublisher) SetupSiteInfoPublisher

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

func (*EventPublisher) SetupSiteInfoPublisherWithManager

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 NatsConfig

type NatsConfig struct {
	LicenseID string     `json:"licenseID"`
	Subject   string     `json:"natsSubject"`
	Server    string     `json:"natsServer"`
	Client    *nats.Conn `json:"-"`
}

func NewNatsConfig

func NewNatsConfig(clusterID string, LicenseFile string) (*NatsConfig, error)

type NatsCredential

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

NatsCredential represents the api response of the register licensed user api

type ResourceEventPublisher

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

func (*ResourceEventPublisher) OnAdd

func (p *ResourceEventPublisher) OnAdd(o interface{})

func (*ResourceEventPublisher) OnDelete

func (p *ResourceEventPublisher) OnDelete(obj interface{})

func (*ResourceEventPublisher) OnUpdate

func (p *ResourceEventPublisher) OnUpdate(oldObj, newObj interface{})