triggermesh

type Component interface {
	AsK8sObject() (kubernetes.Object, error)

	GetName() string
	GetKind() string
	GetAPIVersion() string
	GetSpec() map[string]interface{}

	SetSpec(map[string]interface{})
}

type Consumer interface {
	ConsumedEventTypes() ([]string, error)
	GetPort(context.Context) (string, error)
}

type Exportable interface {
	AsDockerComposeObject(additionalEnvs map[string]string) (interface{}, error)
	AsDigitalOceanObject(additionalEnvs map[string]string) (interface{}, error)
}

type Parent interface {
	GetChildren() ([]Component, error)
}

type Producer interface {
	SetEventAttributes(map[string]string) error

	GetEventTypes() ([]string, error)
	GetEventSource() (string, error)
}

type Reconcilable interface {
	Initialize(context.Context, map[string]string) (map[string]interface{}, error)
	Finalize(context.Context, map[string]string) error

	UpdateStatus(map[string]interface{})
	GetExternalResources() map[string]interface{}
}

type Runnable interface {
	Start(ctx context.Context, additionalEnv map[string]string, restart bool) (*docker.Container, error)
	Stop(context.Context) error
	Info(context.Context) (*docker.Container, error)
	Logs(ctx context.Context, since time.Time, follow bool) (io.ReadCloser, error)
}