Documentation ¶
Index ¶
- func New(name, kind, broker, version string, crd crd.CRD, params interface{}, ...) triggermesh.Component
- type Source
- func (s *Source) AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)
- func (s *Source) AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)
- func (s *Source) AsK8sObject() (kubernetes.Object, error)
- func (s *Source) AsKubernetesDeployment(additionalEnvs map[string]string) (interface{}, 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) Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)
- func (s *Source) SetEventAttributes(map[string]string) error
- func (s *Source) SetSpec(spec map[string]interface{})
- 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{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Source ¶
type Source struct { Name string CRD crd.CRD Broker string Kind string Version string // contains filtered or unexported fields }
func (*Source) AsDigitalOceanObject ¶ added in v1.2.0
func (*Source) AsDockerComposeObject ¶ added in v1.2.0
func (*Source) AsK8sObject ¶
func (s *Source) AsK8sObject() (kubernetes.Object, error)
func (*Source) AsKubernetesDeployment ¶ added in v1.4.0
func (*Source) GetAPIVersion ¶
func (*Source) GetChildren ¶
func (s *Source) GetChildren() ([]triggermesh.Component, error)
func (*Source) GetEventSource ¶
func (*Source) GetEventTypes ¶
func (*Source) GetExternalResources ¶ added in v0.0.2
func (*Source) Initialize ¶
func (*Source) UpdateStatus ¶
Click to show internal directories.
Click to hide internal directories.