target

Documentation

Index

• func New(name, crdFile, kind, broker, version string, params interface{}) triggermesh.Component
• type Target
  • func (t *Target) AsK8sObject() (kubernetes.Object, error)
  • func (t *Target) ConsumedEventTypes() ([]string, error)
  • func (t *Target) GetAPIVersion() string
  • func (t *Target) GetChildren() ([]triggermesh.Component, error)
  • func (t *Target) GetKind() string
  • func (t *Target) GetName() string
  • func (t *Target) GetPort(ctx context.Context) (string, error)
  • func (t *Target) GetSpec() map[string]interface{}
  • func (t *Target) Info(ctx context.Context) (*docker.Container, error)
  • func (t *Target) Start(ctx context.Context, additionalEnvs map[string]string, restart bool) (*docker.Container, error)
  • func (t *Target) Stop(ctx context.Context) error

Functions

func New

func New(name, crdFile, kind, broker, version string, params interface{}) triggermesh.Component

Types

type Target

type Target struct {
	Name    string
	CRDFile string

	Broker  string
	Version string
	Kind    string
	// contains filtered or unexported fields
}

func (*Target) AsK8sObject

func (t *Target) AsK8sObject() (kubernetes.Object, error)

func (*Target) ConsumedEventTypes

func (t *Target) ConsumedEventTypes() ([]string, error)

func (*Target) GetAPIVersion

func (t *Target) GetAPIVersion() string

func (*Target) GetChildren

func (t *Target) GetChildren() ([]triggermesh.Component, error)

func (*Target) GetKind

func (t *Target) GetKind() string

func (*Target) GetName

func (t *Target) GetName() string

func (*Target) GetPort

func (t *Target) GetPort(ctx context.Context) (string, error)

func (*Target) GetSpec

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

func (*Target) Info

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

func (*Target) Start

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

func (*Target) Stop

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