broker

package

v1.4.0 Latest Latest Go to latest Published: Jul 5, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/triggermesh/tmctl

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CreateBrokerConfig(configHome, broker string) (string, error)
func FilterAttribute(attribute, value string) *eventingbroker.Filter
func GetTargetTriggers(target, broker, configBase string) ([]triggermesh.Component, error)
func New(name string, brokerConfig config.BrokerConfig) (triggermesh.Component, error)
func NewTrigger(name, broker, configBase string, target triggermesh.Component, ...) (triggermesh.Component, error)
type Broker
type Configuration
type LocalTarget
type LocalTriggerSpec
type Trigger

Constants ¶

View Source

const (
	BrokerKind  = "RedisBroker"
	TriggerKind = "Trigger"
	APIVersion  = "eventing.triggermesh.io/v1alpha1"
)

Variables ¶

This section is empty.

Functions ¶

func CreateBrokerConfig ¶ added in v1.2.0

func CreateBrokerConfig(configHome, broker string) (string, error)

func FilterAttribute ¶ added in v1.2.0

func FilterAttribute(attribute, value string) *eventingbroker.Filter

func GetTargetTriggers ¶

func GetTargetTriggers(target, broker, configBase string) ([]triggermesh.Component, error)

func New ¶

func New(name string, brokerConfig config.BrokerConfig) (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 {
	Name string
	// contains filtered or unexported fields
}

func (*Broker) AsDigitalOceanObject ¶ added in v1.2.0

func (b *Broker) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)

func (*Broker) AsDockerComposeObject ¶ added in v1.2.0

func (b *Broker) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)

func (*Broker) AsK8sObject ¶

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

func (*Broker) AsKubernetesDeployment ¶ added in v1.4.0

func (b *Broker) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, 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) Logs ¶ added in v1.2.0

func (b *Broker) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)

func (*Broker) SetSpec ¶ added in v1.2.0

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

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" json:"triggers"`
}

type LocalTarget ¶

type LocalTarget struct {
	URL             string                          `yaml:"url,omitempty" json:"url,omitempty"`
	Component       string                          `yaml:"component,omitempty" json:"component,omitempty"`
	DeliveryOptions *eventingbroker.DeliveryOptions `yaml:"deliveryOptions,omitempty" json:"deliveryOptions,omitempty"`
}

type LocalTriggerSpec ¶

type LocalTriggerSpec struct {
	Filters []eventingbroker.Filter `yaml:"filters,omitempty" json:"filters,omitempty"`
	Target  LocalTarget             `yaml:"target" json:"target"`
}

type Trigger ¶

type Trigger struct {
	Name       string
	ConfigBase 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) SetSpec ¶ added in v1.2.0

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

func (*Trigger) SetTarget ¶

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

func (*Trigger) WriteLocalConfig ¶

func (t *Trigger) WriteLocalConfig() error

Source Files ¶

View all Source files

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