transformation

Documentation

Index

• func New(name, crdFile, kind, broker, version string, spec map[string]interface{}) triggermesh.Component
• type Transformation
  • func (t *Transformation) AsK8sObject() (kubernetes.Object, 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) SetEventAttributes(attributes map[string]string) error
  • func (t *Transformation) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)
  • func (t *Transformation) Stop(ctx context.Context) error

Functions

func New

func New(name, crdFile, kind, broker, version string, spec map[string]interface{}) triggermesh.Component

Types

type Transformation

type Transformation struct {
	Name    string
	CRDFile string
	Broker  string
	Version string
	// contains filtered or unexported fields
}

func (*Transformation) AsK8sObject

func (t *Transformation) AsK8sObject() (kubernetes.Object, 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) Info

func (t *Transformation) Info(ctx context.Context) (*docker.Container, error)

func (*Transformation) SetEventAttributes

func (t *Transformation) SetEventAttributes(attributes map[string]string) error

SetEventType sets events context attributes.

func (*Transformation) Start

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

func (*Transformation) Stop

func (t *Transformation) Stop(ctx context.Context) error