source

package

v1.1.1 Latest Latest Go to latest Published: Feb 2, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

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

type Source struct {
	Name    string
	CRDFile string

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

func (s *Source) AsK8sObject() (kubernetes.Object, error)

func (s *Source) Finalize(ctx context.Context, secrets map[string]string) error

func (s *Source) GetAPIVersion() string

func (s *Source) GetChildren() ([]triggermesh.Component, error)

func (s *Source) GetEventSource() (string, error)

func (s *Source) GetEventTypes() ([]string, error)

func (s *Source) GetExternalResources() map[string]interface{}

func (s *Source) GetKind() string

func (s *Source) GetName() string

func (s *Source) GetSpec() map[string]interface{}

func (s *Source) Info(ctx context.Context) (*docker.Container, error)

func (s *Source) Initialize(ctx context.Context, secrets map[string]string) (map[string]interface{}, error)

func (s *Source) SetEventAttributes(map[string]string) error

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

func (s *Source) Stop(ctx context.Context) error

func (s *Source) UpdateStatus(status map[string]interface{})