Documentation
¶
Index ¶
- func WithFetchInterval(interval time.Duration) func(s *UniformSubscriptionSource)
- func WithFixedSubscriptions(subscriptions ...models.EventSubscription) func(s *FixedSubscriptionSource)
- func WithLogger(logger logger.Logger) func(s *UniformSubscriptionSource)
- type FixedSubscriptionSource
- type SubscriptionSource
- type UniformSubscriptionSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithFetchInterval ¶
func WithFetchInterval(interval time.Duration) func(s *UniformSubscriptionSource)
WithFetchInterval specifies the interval the subscription source should use when polling for new subscriptions
func WithFixedSubscriptions ¶
func WithFixedSubscriptions(subscriptions ...models.EventSubscription) func(s *FixedSubscriptionSource)
WithFixedSubscriptions adds a fixed list of subscriptions to the FixedSubscriptionSource
func WithLogger ¶
func WithLogger(logger logger.Logger) func(s *UniformSubscriptionSource)
WithLogger sets the logger to use
Types ¶
type FixedSubscriptionSource ¶
type FixedSubscriptionSource struct {
// contains filtered or unexported fields
}
FixedSubscriptionSource can be used to use a fixed list of subscriptions rather than consulting the Keptn API for subscriptions. This is useful when you want to consume events from an event source, but NOT register as an Keptn integration to the control plane
func NewFixedSubscriptionSource ¶
func NewFixedSubscriptionSource(options ...func(source *FixedSubscriptionSource)) *FixedSubscriptionSource
NewFixedSubscriptionSource creates a new instance of FixedSubscriptionSource
func (FixedSubscriptionSource) Register ¶
func (s FixedSubscriptionSource) Register(integration models.Integration) (string, error)
func (FixedSubscriptionSource) Start ¶
func (s FixedSubscriptionSource) Start(ctx context.Context, data types.RegistrationData, c chan []models.EventSubscription, errC chan error, wg *sync.WaitGroup) error
func (FixedSubscriptionSource) Stop ¶
func (s FixedSubscriptionSource) Stop() error
type SubscriptionSource ¶
type SubscriptionSource interface {
Start(context.Context, types.RegistrationData, chan []models.EventSubscription, chan error, *sync.WaitGroup) error
Register(integration models.Integration) (string, error)
Stop() error
}
type UniformSubscriptionSource ¶
type UniformSubscriptionSource struct {
// contains filtered or unexported fields
}
UniformSubscriptionSource represents a source for uniform subscriptions
func New ¶
func New(uniformAPI api.UniformV1Interface, options ...func(source *UniformSubscriptionSource)) *UniformSubscriptionSource
New creates a new UniformSubscriptionSource
func (*UniformSubscriptionSource) Register ¶
func (s *UniformSubscriptionSource) Register(integration models.Integration) (string, error)
func (*UniformSubscriptionSource) Start ¶
func (s *UniformSubscriptionSource) Start(ctx context.Context, registrationData types.RegistrationData, subscriptionChannel chan []models.EventSubscription, errC chan error, wg *sync.WaitGroup) error
Start triggers the execution of the UniformSubscriptionSource
func (*UniformSubscriptionSource) Stop ¶
func (s *UniformSubscriptionSource) Stop() error
Source Files