pipeline

type CreatePipelineRequest struct {
	pipeline.PipelineConfigV2
	Processors []map[string]interface{} `json:"processor"`
}

type EchoConfig struct {
	Message string `config:"message"`
}

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

type GetPipelinesResponse map[string]*PipelineStatus

type PipeModule struct {
	api.Handler
	// contains filtered or unexported fields
}

type PipelineStatus struct {
	State      pipeline.RunningState      `json:"state"`
	CreateTime time.Time                  `json:"create_time"`
	StartTime  *time.Time                 `json:"start_time"`
	EndTime    *time.Time                 `json:"end_time"`
	Context    util.MapStr                `json:"context"`
	Config     *pipeline.PipelineConfigV2 `json:"config"`
	Processors []map[string]interface{}   `json:"processor"`
}

type SearchPipelinesRequest struct {
	Ids []string `json:"ids"`
}