v1

type Agent struct {
	Url, Token string
}

type AgentDeployableResource struct {
	Step        string                       `json:"step"`
	ProcessId   string                       `json:"process_id"`
	Descriptors *[]unstructured.Unstructured `json:"descriptors" yaml:"descriptors"`
	Type        enums.PIPELINE_RESOURCE_TYPE `json:"type"`
	Name        string                       `json:"name"`
	Namespace   string                       `json:"namespace"`
	Images      []string                     `json:"images"`
}

type CompanyMetadata struct {
	Labels                    map[string]string `bson:"labels" json:"labels" yaml:"labels"`
	NumberOfConcurrentProcess int64             `bson:"number_of_concurrent_process" json:"number_of_concurrent_process" yaml:"number_of_concurrent_process"`
	TotalProcessPerDay        int64             `bson:"total_process_per_day" json:"total_process_per_day" yaml:"total_process_per_day"`
}

type Jwt struct {
	PublicKey *rsa.PublicKey
}

type LogEvent struct {
	ProcessId string    `bson:"process_id"`
	Log       string    `bson:"log"`
	Step      string    `bson:"step"`
	Footmark  string    `bson:"footmark"`
	CreatedAt time.Time `bson:"created_at"`
	Claim     int       `bson:"claim" json:"claim"`
}

type LogEventQueryOption struct {
	Pagination struct {
		Page  int64
		Limit int64
	}
	Step string
}

type Pipeline struct {
	MetaData   PipelineMetadata    `json:"_metadata" yaml:"_metadata"`
	Option     PipelineApplyOption `json:"option" yaml:"option"`
	ApiVersion string              `json:"api_version" yaml:"api_version"`
	Name       string              `json:"name"  yaml:"name"`
	ProcessId  string              `json:"process_id" yaml:"process_id"`
	Label      map[string]string   `json:"label" yaml:"label"`
	Steps      []Step              `json:"steps" yaml:"steps"`
}

type PipelineApplyOption struct {
	Purging enums.PIPELINE_PURGING
}

type PipelineMetadata struct {
	CompanyId       string          `json:"company_id" yaml:"company_id"`
	CompanyMetadata CompanyMetadata `json:"company_metadata" yaml:"company_metadata"`
}

type PodListGetOption struct {
	Wait     bool
	Duration int
}

type ProcessEvent struct {
	ProcessId string                 `bson:"process_id" json:"process_id"`
	CompanyId string                 `bson:"company_id" json:"company_id"`
	Data      map[string]interface{} `bson:"data" json:"data"`
}

type ProcessLifeCycleEvent struct {
	ProcessId string               `bson:"process_id" json:"process_id"`
	Step      string               `bson:"step" json:"step"`
	StepType  enums.STEP_TYPE      `bson:"step_type" json:"step_type"`
	Status    enums.PROCESS_STATUS `bson:"status" json:"status"`
	Next      []string             `bson:"next" json:"next"`
	Agent     string               `bson:"agent" json:"agent"`
	Pipeline  *Pipeline            `bson:"pipeline" json:"pipeline"`
	CreatedAt time.Time            `bson:"created_at" json:"created_at"`
	Trigger   enums.TRIGGER        `bson:"trigger" json:"trigger"`
	Claim     int                  `bson:"claim" json:"claim"`
}

type Step struct {
	Name        string                       `json:"name" yaml:"name"`
	Type        enums.STEP_TYPE              `json:"type" yaml:"type"`
	Trigger     enums.TRIGGER                `json:"trigger" yaml:"trigger"`
	Params      map[enums.PARAMS]string      `json:"params" yaml:"params"`
	Next        []string                     `json:"next" yaml:"next"`
	ArgData     map[string]string            `json:"arg_data"  yaml:"arg_data"`
	EnvData     map[string]string            `json:"env_data"  yaml:"env_data"`
	Descriptors *[]unstructured.Unstructured `json:"descriptors" yaml:"descriptors"`
}

type Subject struct {
	Step, Log    string
	StepType     enums.STEP_TYPE
	EventData    map[string]interface{}
	ProcessLabel map[string]string
	Pipeline     Pipeline
}