handlers

type Error struct {
	// Type defines the error type.
	Type string
	// Message defines human readable error message.
	Message string
	// Details defines details of the error.
	Details interface{}
}

type ErrorPush struct {
	// contains error message
	Message string `json:"message"`
	// contains pipeline config
	Details interface{} `json:"details"`
}

type Input struct {
	// Model project ID (there may be several model projects within one cloud project).
	ProjectID string `json:"project_id"`
	// CodeHash is the model codebase ID.
	CodeHash string `json:"code_hash,omitempty"`
	// TrainID is the experiment's ID.
	TrainID string `json:"train_id,omitempty"`
	// Config is the ML pipeline config
	Config []interface{} `json:"pipeline_config"`
}

type OutputDistribution struct {
	// Topic is the message broker topic to push payload to.
	Topic string
}

type OutputPayload struct {
	Errors      []string `json:"errors"`
	SubmittedID []string `json:"submitted_id"`
}

type Processor struct {
	// Type defines the execution type, either train, or predict
	Type string
	// TopicPrefix represents prefix of the topic to post the payload to.
	TopicPrefix string
	// InputJSONSchema defines the jsonschema of the input payload.
	InputJSONSchema string
	// Message bus to disctribute messages
	Bus *bus.Client
}