v1

type ApprovalWorkflowStep struct{}

type ContainerMixin struct {
	Image     string        `yaml:"image" json:"image"`
	Spec      ExpressionMap `yaml:"spec" json:"spec,omitempty"`
	Env       ExpressionMap `yaml:"env" json:"env,omitempty"`
	InputFile string        `yaml:"inputFile" json:"inputFile,omitempty"`
	Input     []string      `yaml:"input" json:"input,omitempty"`
	Command   string        `yaml:"command" json:"command,omitempty"`
	Args      []string      `yaml:"args" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type ContainerWorkflowStep struct {
	ContainerMixin
}

type Decoder interface {
	Decode(ctx context.Context, data []byte) (*WorkflowData, error)
}

type DefaultRunEngineMapper struct {
	// contains filtered or unexported fields
}

type DefaultRunEngineMapperOption func(*DefaultRunEngineMapper)

type DefaultTenantEngineMapper struct {
	// contains filtered or unexported fields
}

type DefaultTenantEngineMapperOption func(*DefaultTenantEngineMapper)

type DefaultWebhookTriggerEngineMapper struct {
	// contains filtered or unexported fields
}

type DefaultWebhookTriggerEngineMapperOption func(*DefaultWebhookTriggerEngineMapper)

type DefaultWorkflowMapper struct {
	// contains filtered or unexported fields
}

type DefaultWorkflowMapperOption func(*DefaultWorkflowMapper)

type ExpressionMap map[string]serialize.JSONTree

type PushWorkflowTriggerSource struct {
	// TODO: Implement serialization for schema field types.
	Schema map[string]interface{} `yaml:"schema" json:"schema,omitempty"`
}

type RunKubernetesEngineMapper interface {
	ToRuntimeObjectsManifest(*WorkflowData) (*RunKubernetesObjectMapping, error)
}

type RunKubernetesObjectMapping struct {
	Namespace   *corev1.Namespace
	WorkflowRun *v1beta1.Run
}

type ScheduleWorkflowTriggerSource struct {
	Schedule string `yaml:"schedule" json:"schedule,omitempty"`
}

type StreamingDecoder interface {
	// DecodeStream returns io.EOF when the reader is empty. If the error is
	// nil, then additional calls to DecodeStream will return more WorkflowData
	// objects if the implementation supports streaming multiple objects.
	DecodeStream(ctx context.Context) (*WorkflowData, error)
	Close() error
}

type TenantKubernetesEngineMapper interface {
	ToRuntimeObjectsManifest(id string) (*TenantKubernetesObjectMapping, error)
}

type TenantKubernetesObjectMapping struct {
	Namespace *corev1.Namespace
	Tenant    *v1beta1.Tenant
}

type WebhookTriggerKubernetesEngineMapper interface {
	ToRuntimeObjectsManifest(source *WebhookWorkflowTriggerSource) (*WebhookTriggerKubernetesObjectMapping, error)
}

type WebhookTriggerKubernetesObjectMapping struct {
	WebhookTrigger *v1beta1.WebhookTrigger
}

type WebhookWorkflowTriggerSource struct {
	ContainerMixin
}

type WorkflowData struct {
	APIVersion  string                 `yaml:"apiVersion" json:"apiVersion"`
	Description string                 `yaml:"description" json:"description"`
	Name        string                 `yaml:"name" json:"name,omitempty"`
	Parameters  WorkflowParameters     `yaml:"parameters" json:"parameters,omitempty"`
	Steps       []*WorkflowStep        `yaml:"steps" json:"steps"`
	Triggers    []*WorkflowDataTrigger `yaml:"triggers" json:"triggers"`
}

type WorkflowDataTrigger struct {
	Name    string                      `yaml:"name" json:"name"`
	Source  *WorkflowDataTriggerSource  `yaml:"source" json:"source,omitempty"`
	Binding *WorkflowDataTriggerBinding `yaml:"binding" json:"binding,omitempty"`
	When    serialize.JSONTree          `yaml:"when" json:"when,omitempty"`
}

type WorkflowDataTriggerBinding struct {
	Key        serialize.JSONTree `yaml:"key" json:"key,omitempty"`
	Parameters ExpressionMap      `yaml:"parameters" json:"parameters,omitempty"`
}

type WorkflowDataTriggerSource struct {
	Type    string `yaml:"type" json:"type,omitempty"`
	Variant WorkflowTriggerSourceVariant
}

type WorkflowFileFormatError struct {
	Cause error
}

type WorkflowMapper interface {
	Map(*WorkflowData) (*WorkflowMapping, error)
}

type WorkflowMapping struct {
	Namespace *corev1.Namespace
	Workflow  *v1beta1.Workflow
}

type WorkflowParameter struct {
	Description string
	Type        string
	// contains filtered or unexported fields
}

type WorkflowParameters map[string]*WorkflowParameter

type WorkflowRunParameter struct {
	Value interface{} `json:"value"`
}

type WorkflowRunParameters map[string]*WorkflowRunParameter

type WorkflowStep struct {
	Name      string             `yaml:"name" json:"name"`
	DependsOn []string           `yaml:"dependsOn" json:"depends_on"`
	When      serialize.JSONTree `yaml:"when" json:"when,omitempty"`
	Variant   WorkflowStepVariant
}

type WorkflowStepApprovalStatus string

type WorkflowStepInvalidError struct {
	Name string
	Type string
}

type WorkflowStepType string

type WorkflowStepVariant interface {
	StepType() string
	// contains filtered or unexported methods
}

type WorkflowTriggerSource struct {
	Type    string `json:"type,omitempty"`
	Variant WorkflowTriggerSourceVariant
}

type WorkflowTriggerSourceType string

type WorkflowTriggerSourceVariant interface {
	TriggerSourceType() string
	// contains filtered or unexported methods
}

type YAMLContainerMixin struct {
	Image     string                        `yaml:"image" json:"image,omitempty"`
	Spec      map[string]serialize.YAMLTree `yaml:"spec" json:"spec,omitempty"`
	Env       map[string]serialize.YAMLTree `yaml:"env,omitempty" json:"env,omitempty"`
	Input     []string                      `yaml:"input,omitempty" json:"input,omitempty"`
	InputFile string                        `yaml:"inputFile,omitempty" json:"inputFile,omitempty"`
	Command   string                        `yaml:"command,omitempty" json:"command,omitempty"`
	Args      []string                      `yaml:"args,omitempty" json:"args,omitempty"`
}

type YAMLDecoder struct{}

type YAMLPushWorkflowTriggerSource struct {
	// TODO: Implement serialization for schema field types.
	Schema map[string]interface{} `yaml:"schema" json:"schema,omitempty"`
}

type YAMLScheduleWorkflowTriggerSource struct {
	Schedule string `yaml:"schedule" json:"schedule,omitempty"`
}

type YAMLWebhookWorkflowTriggerSource struct {
	YAMLContainerMixin `yaml:",inline"`
}

type YAMLWorkflowData struct {
	APIVersion  string                `yaml:"apiVersion,omitempty" json:"apiVersion"`
	Description string                `yaml:"description,omitempty" json:"description"`
	Name        string                `yaml:"name,omitempty" json:"name,omitempty"`
	Parameters  WorkflowParameters    `yaml:"parameters,omitempty" json:"parameters,omitempty"`
	Steps       []YAMLWorkflowStep    `yaml:"steps" json:"steps"`
	Triggers    []YAMLWorkflowTrigger `yaml:"triggers,omitempty" json:"triggers"`
}

type YAMLWorkflowStep struct {
	Name               string `yaml:"name" json:"name"`
	Type               string `yaml:"type,omitempty" json:"type,omitempty"`
	YAMLContainerMixin `yaml:",inline"`
	DependsOn          stringutil.StringArray `yaml:"dependsOn,omitempty" json:"depends_on,omitempty"`
	When               serialize.YAMLTree     `yaml:"when,omitempty" json:"when,omitempty"`
}

type YAMLWorkflowTrigger struct {
	Name    string                     `yaml:"name" json:"name"`
	Source  YAMLWorkflowTriggerSource  `yaml:"source" json:"source"`
	Binding YAMLWorkflowTriggerBinding `yaml:"binding" json:"binding"`
	When    serialize.YAMLTree         `yaml:"when" json:"when,omitempty"`
}

type YAMLWorkflowTriggerBinding struct {
	Key        serialize.YAMLTree            `yaml:"key" json:"key,omitempty"`
	Parameters map[string]serialize.YAMLTree `yaml:"parameters" json:"parameters,omitempty"`
}

type YAMLWorkflowTriggerSource struct {
	Type                              string `yaml:"type" json:"type,omitempty"`
	YAMLPushWorkflowTriggerSource     `yaml:",inline"`
	YAMLScheduleWorkflowTriggerSource `yaml:",inline"`
	YAMLWebhookWorkflowTriggerSource  `yaml:",inline"`
}