common

type EcflowClientData struct {
	Command    string              `json:"command"`
	Arguments  []string            `json:"args"`
	Envs       []map[string]string `json:"envs"`
	EcflowHost string              `json:"ecf_host"`
	EcflowPort string              `json:"ecf_port"`
	NodeName   string              `json:"ecf_name"`
	NodeRID    string              `json:"ecf_rid"`
	TryNo      string              `json:"ecf_tryno"`
	EcfDate    string              `json:"ecf_date"`
}

type EpsProductionData struct {
	ProductionInfo
	EpsProductionProperties
	ProductionEventStatus
}

type EpsProductionProperties struct {
	StartTime    time.Time `json:"start_time"`    // start time, YYYYMMDDHH
	ForecastTime string    `json:"forecast_time"` // time duration, such as 3h, 12h, 120h
	Number       int       `json:"number"`
}

type EventMessage struct {
	App  string      `json:"app"`  // app name
	Type string      `json:"type"` // type
	Time time.Time   `json:"time"` // time string, RFC 3339
	Data interface{} `json:"data"` // data structure
}

type EventStatus int

type MessageBrokerServer struct {
	pb.MessageBrokerServer
	DisableDeliver bool
	BrokerMode     string
	MessageChan    chan RabbitMQMessage
}

type OperationProductionData struct {
	ProductionInfo
	OperationProductionProperties
	ProductionEventStatus
}

type OperationProductionProperties struct {
	StartTime    time.Time `json:"start_time"`    // start time, YYYYMMDDHH
	ForecastTime string    `json:"forecast_time"` // time duration, such as 3h, 12h, 120h
}

type ProductionEvent string

type ProductionEventStatus struct {
	Event  ProductionEvent `json:"event"`  // production event, storage
	Status EventStatus     `json:"status"` // unknown, complete, queued, aborted, submitted, active, suspended
}

type ProductionInfo struct {
	System string           `json:"system"` // system name: grapes_gfs_gmf, grapes_gfs_gda
	Stream ProductionStream `json:"stream"` // stream: oper, eps, ...
	Type   ProductionType   `json:"type"`   // production type: grib2
	Name   ProductionName   `json:"name"`   // production name, orig, ...
}

type ProductionName string

type ProductionStream string

type ProductionType string

type RabbitMQMessage struct {
	Target  sender.RabbitMQTarget
	Message []byte
}