triggermesh

package

v1.0.0 Latest Latest Go to latest Published: Dec 1, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/triggermesh/tmctl

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	ConfigFile = "config.yaml"
	ConfigDir  = ".triggermesh/cli"

	Namespace    = "local"
	ManifestFile = "manifest.yaml"

	// objects meta
	ContextLabel                = "triggermesh.io/context"
	ExternalResourcesAnnotation = "triggermesh.io/external-resources"

	// broker default parameters
	MemoryBrokerImage          = "gcr.io/triggermesh/memory-broker:latest"
	MemoryBrokerBufferSize     = "100"
	MemoryBrokerProduceTimeout = "1s"
)

TriggerMesh constant values used as default paths, configs, etc.

Variables ¶

View Source

var DefaultConfig = map[string]interface{}{
	"context":                                   defaultContext,
	"triggermesh.version":                       latestOrDefault(defaultVersion),
	"triggermesh.broker.image":                  MemoryBrokerImage,
	"triggermesh.broker.memory.buffer-size":     MemoryBrokerBufferSize,
	"triggermesh.broker.memory.produce-timeout": MemoryBrokerProduceTimeout,
}

Functions ¶

This section is empty.

Types ¶

type Component ¶

type Component interface {
	AsK8sObject() (kubernetes.Object, error)

	GetName() string
	GetKind() string
	GetAPIVersion() string
	GetSpec() map[string]interface{}
}

Component is the common interface for all TriggerMesh components.

type Consumer ¶

type Consumer interface {
	ConsumedEventTypes() ([]string, error)
	GetPort(context.Context) (string, error)
}

Consumer is implemented by all components that consume events.

type Parent ¶

type Parent interface {
	GetChildren() ([]Component, error)
}

Parent is the interface of the components that produce additional components.

type Producer ¶

type Producer interface {
	SetEventAttributes(map[string]string) error

	GetEventTypes() ([]string, error)
	GetEventSource() (string, error)
}

Producer is implemeted by all components that produce events.

type Reconcilable ¶

type Reconcilable interface {
	Initialize(context.Context, map[string]string) (map[string]interface{}, error)
	Finalize(context.Context, map[string]string) error

	UpdateStatus(map[string]interface{})
	GetExternalResources() map[string]interface{}
}

Reconcilable is implemented by the components that depend on external services and require additional initialization and finalization logic.

type Runnable ¶

type Runnable interface {
	Start(ctx context.Context, additionalEnv map[string]string, restart bool) (*docker.Container, error)
	Stop(context.Context) error
	Info(context.Context) (*docker.Container, error)
}

Runnable is the interface for components that can run as Docker containers.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
adapter
ce
env
reconciler
reconciler/external/aws
reconciler/external/azure
reconciler/external/gcp
components
broker
secret
service
source
target
transformation
crd
pkg

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