Documentation ¶
Index ¶
- Constants
- func New(name, kind, broker, version string, crd crd.CRD, spec map[string]interface{}) triggermesh.Component
- type Transformation
- func (t *Transformation) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)
- func (t *Transformation) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)
- func (t *Transformation) AsK8sObject() (kubernetes.Object, error)
- func (t *Transformation) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, error)
- func (t *Transformation) ConsumedEventTypes() ([]string, error)
- func (t *Transformation) GetAPIVersion() string
- func (t *Transformation) GetEventSource() (string, error)
- func (t *Transformation) GetEventTypes() ([]string, error)
- func (t *Transformation) GetKind() string
- func (t *Transformation) GetName() string
- func (t *Transformation) GetPort(ctx context.Context) (string, error)
- func (t *Transformation) GetSpec() map[string]interface{}
- func (t *Transformation) Info(ctx context.Context) (*docker.Container, error)
- func (t *Transformation) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)
- func (t *Transformation) SetEventAttributes(attributes map[string]string) error
- func (t *Transformation) SetLabel(key, value string)
- func (t *Transformation) SetSpec(spec map[string]interface{})
- func (t *Transformation) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)
- func (t *Transformation) Stop(ctx context.Context) error
Constants ¶
View Source
const TransformationContextLabel = "triggermesh.io/transformation-context"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Transformation ¶
type Transformation struct { Name string CRD crd.CRD Broker string Version string // contains filtered or unexported fields }
func (*Transformation) AsDigitalOceanObject ¶ added in v1.2.0
func (t *Transformation) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)
func (*Transformation) AsDockerComposeObject ¶ added in v1.2.0
func (t *Transformation) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)
func (*Transformation) AsK8sObject ¶
func (t *Transformation) AsK8sObject() (kubernetes.Object, error)
func (*Transformation) AsKubernetesDeployment ¶ added in v1.4.0
func (t *Transformation) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, error)
func (*Transformation) ConsumedEventTypes ¶
func (t *Transformation) ConsumedEventTypes() ([]string, error)
func (*Transformation) GetAPIVersion ¶
func (t *Transformation) GetAPIVersion() string
func (*Transformation) GetEventSource ¶
func (t *Transformation) GetEventSource() (string, error)
func (*Transformation) GetEventTypes ¶
func (t *Transformation) GetEventTypes() ([]string, error)
func (*Transformation) GetKind ¶
func (t *Transformation) GetKind() string
func (*Transformation) GetName ¶
func (t *Transformation) GetName() string
func (*Transformation) GetPort ¶
func (t *Transformation) GetPort(ctx context.Context) (string, error)
func (*Transformation) GetSpec ¶
func (t *Transformation) GetSpec() map[string]interface{}
func (*Transformation) Logs ¶ added in v1.2.0
func (t *Transformation) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)
func (*Transformation) SetEventAttributes ¶
func (t *Transformation) SetEventAttributes(attributes map[string]string) error
SetEventType sets events context attributes.
func (*Transformation) SetLabel ¶ added in v1.3.0
func (t *Transformation) SetLabel(key, value string)
func (*Transformation) SetSpec ¶ added in v1.2.0
func (t *Transformation) SetSpec(spec map[string]interface{})
Click to show internal directories.
Click to hide internal directories.