Documentation
¶
Index ¶
- func Register(constructor func(*kong.Client) Handler)
- type ConsumerInstanceGetter
- type Handler
- type Info
- type Manager
- func (sm *Manager) GetSubscriptionInfo(plugins map[string]*kong.Plugin) Info
- func (sm *Manager) ProcessSubscribe(subscription apic.Subscription)
- func (sm *Manager) ProcessUnsubscribe(subscription apic.Subscription)
- func (sm *Manager) Schemas() []apic.SubscriptionSchema
- func (sm *Manager) ValidateSubscription(subscription apic.Subscription) bool
- type SubscriptionGetter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConsumerInstanceGetter ¶
type ConsumerInstanceGetter interface {
GetConsumerInstanceByID(id string) (*v1alpha1.ConsumerInstance, error)
}
ConsumerInstanceGetter gets a consumer instance by id.
type Handler ¶
type Handler interface {
Schema() apic.SubscriptionSchema
Name() string
APICPolicy() string
IsApplicable(map[string]*kong.Plugin) bool
Subscribe(log logrus.FieldLogger, subs apic.Subscription)
Unsubscribe(log logrus.FieldLogger, subs apic.Subscription)
}
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager handles the subscription aspects
func New ¶
func New(log logrus.FieldLogger, cig ConsumerInstanceGetter, sg SubscriptionGetter, kc *kong.Client) *Manager
func (*Manager) GetSubscriptionInfo ¶
GetSubscriptionInfo returns the appropriate Info for the given set of plugins
func (*Manager) ProcessSubscribe ¶
func (sm *Manager) ProcessSubscribe(subscription apic.Subscription)
func (*Manager) ProcessUnsubscribe ¶
func (sm *Manager) ProcessUnsubscribe(subscription apic.Subscription)
func (*Manager) Schemas ¶
func (sm *Manager) Schemas() []apic.SubscriptionSchema
func (*Manager) ValidateSubscription ¶
func (sm *Manager) ValidateSubscription(subscription apic.Subscription) bool
type SubscriptionGetter ¶
type SubscriptionGetter interface {
GetSubscriptionsForCatalogItem(states []string, id string) ([]apic.CentralSubscription, error)
}
SubscriptionGetter gets the all the subscription in any of the states for the catalog item with id
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.