Documentation
¶
Index ¶
- Constants
- func FilterExactAttribute(attribute, value string) *eventingbroker.Filter
- func GetTargetTriggers(target, broker, configBase string) ([]triggermesh.Component, error)
- func New(name, manifestPath string) (triggermesh.Component, error)
- func NewTrigger(name, broker, configBase string, target triggermesh.Component, ...) (triggermesh.Component, error)
- type Broker
- func (b *Broker) AsK8sObject() (kubernetes.Object, error)
- func (b *Broker) ConsumedEventTypes() ([]string, error)
- func (b *Broker) GetAPIVersion() string
- func (b *Broker) GetKind() string
- func (b *Broker) GetName() string
- func (b *Broker) GetPort(ctx context.Context) (string, error)
- func (b *Broker) GetSpec() map[string]interface{}
- func (b *Broker) Info(ctx context.Context) (*docker.Container, error)
- func (b *Broker) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)
- func (b *Broker) Stop(ctx context.Context) error
- type Configuration
- type LocalTarget
- type LocalTriggerSpec
- type Trigger
- func (t *Trigger) AsK8sObject() (kubernetes.Object, error)
- func (t *Trigger) GetAPIVersion() string
- func (t *Trigger) GetKind() string
- func (t *Trigger) GetName() string
- func (t *Trigger) GetSpec() map[string]interface{}
- func (t *Trigger) LookupTarget()
- func (t *Trigger) RemoveFromLocalConfig() error
- func (t *Trigger) SetTarget(target triggermesh.Component)
- func (t *Trigger) WriteLocalConfig() error
Constants ¶
View Source
const ( BrokerKind = "RedisBroker" TriggerKind = "Trigger" APIVersion = "eventing.triggermesh.io/v1alpha1" )
Variables ¶
This section is empty.
Functions ¶
func FilterExactAttribute ¶
func FilterExactAttribute(attribute, value string) *eventingbroker.Filter
func GetTargetTriggers ¶
func GetTargetTriggers(target, broker, configBase string) ([]triggermesh.Component, error)
func NewTrigger ¶
func NewTrigger(name, broker, configBase string, target triggermesh.Component, filter *eventingbroker.Filter) (triggermesh.Component, error)
Types ¶
type Broker ¶
func (*Broker) AsK8sObject ¶
func (b *Broker) AsK8sObject() (kubernetes.Object, error)
func (*Broker) ConsumedEventTypes ¶
func (*Broker) GetAPIVersion ¶
type Configuration ¶
type Configuration struct {
Triggers map[string]LocalTriggerSpec `yaml:"triggers"`
}
type LocalTarget ¶
type LocalTarget struct {
URL string `yaml:"url,omitempty"`
Component string `yaml:"component,omitempty"`
DeliveryOptions *eventingbroker.DeliveryOptions `yaml:"deliveryOptions,omitempty"`
}
type LocalTriggerSpec ¶
type LocalTriggerSpec struct {
Filters []eventingbroker.Filter `yaml:"filters,omitempty"`
Target LocalTarget `yaml:"target"`
}
type Trigger ¶
type Trigger struct {
Name string
ConfigBase string
ComponentName string
LocalURL *apis.URL
eventingv1alpha1.TriggerSpec `yaml:"spec,omitempty"`
}
func (*Trigger) AsK8sObject ¶
func (t *Trigger) AsK8sObject() (kubernetes.Object, error)
func (*Trigger) GetAPIVersion ¶
func (*Trigger) LookupTarget ¶
func (t *Trigger) LookupTarget()
func (*Trigger) RemoveFromLocalConfig ¶
func (*Trigger) SetTarget ¶
func (t *Trigger) SetTarget(target triggermesh.Component)
func (*Trigger) WriteLocalConfig ¶
Click to show internal directories.
Click to hide internal directories.