broker

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

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 New

func New(name, manifestPath string) (triggermesh.Component, error)

func NewTrigger

func NewTrigger(name, broker, configBase string, target triggermesh.Component, filter *eventingbroker.Filter) (triggermesh.Component, error)

Types

type Broker

type Broker struct {
	ConfigFile string
	Name       string
	// contains filtered or unexported fields
}

func (*Broker) AsK8sObject

func (b *Broker) AsK8sObject() (kubernetes.Object, error)

func (*Broker) ConsumedEventTypes

func (b *Broker) ConsumedEventTypes() ([]string, error)

func (*Broker) GetAPIVersion

func (b *Broker) GetAPIVersion() string

func (*Broker) GetKind

func (b *Broker) GetKind() string

func (*Broker) GetName

func (b *Broker) GetName() string

func (*Broker) GetPort

func (b *Broker) GetPort(ctx context.Context) (string, error)

func (*Broker) GetSpec

func (b *Broker) GetSpec() map[string]interface{}

func (*Broker) Info

func (b *Broker) Info(ctx context.Context) (*docker.Container, error)

func (*Broker) Start

func (b *Broker) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)

func (*Broker) Stop

func (b *Broker) Stop(ctx context.Context) error

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 (t *Trigger) GetAPIVersion() string

func (*Trigger) GetKind

func (t *Trigger) GetKind() string

func (*Trigger) GetName

func (t *Trigger) GetName() string

func (*Trigger) GetSpec

func (t *Trigger) GetSpec() map[string]interface{}

func (*Trigger) LookupTarget

func (t *Trigger) LookupTarget()

func (*Trigger) RemoveFromLocalConfig

func (t *Trigger) RemoveFromLocalConfig() error

func (*Trigger) SetTarget

func (t *Trigger) SetTarget(target triggermesh.Component)

func (*Trigger) WriteLocalConfig

func (t *Trigger) WriteLocalConfig() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL