common

Documentation

Index

• type EcflowClientData
  • func CreateEcflowClientMessage(commandOptions string) (*EcflowClientData, error)
  • func (d *EcflowClientData) ParseCommandOptions(commandOptions string)
• type EpsProductionData
• type EpsProductionProperties
• type EventMessage
• type EventStatus
  • func ToEventStatus(status string) EventStatus
  • func (status EventStatus) String() string
• type MessageBrokerServer
  • func (s *MessageBrokerServer) SendKafkaMessage(ctx context.Context, req *pb.KafkaMessage) (*pb.Response, error)
  • func (s *MessageBrokerServer) SendRabbitMQMessage(ctx context.Context, req *pb.RabbitMQMessage) (*pb.Response, error)
• type OperationProductionData
• type OperationProductionProperties
• type ProductionEvent
• type ProductionEventStatus
• type ProductionInfo
• type ProductionName
• type ProductionStream
• type ProductionType
• type RabbitMQMessage

Types

type EcflowClientData

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"`
}

func CreateEcflowClientMessage

func CreateEcflowClientMessage(commandOptions string) (*EcflowClientData, error)

func (*EcflowClientData) ParseCommandOptions

func (d *EcflowClientData) ParseCommandOptions(commandOptions string)

type EpsProductionData

type EpsProductionData struct {
	ProductionInfo
	EpsProductionProperties
	ProductionEventStatus
}

type EpsProductionProperties

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

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

type EventStatus int

const (
	Unknown   EventStatus = 0
	Complete  EventStatus = 1
	Queued    EventStatus = 2
	Aborted   EventStatus = 3
	Submitted EventStatus = 4
	Active    EventStatus = 5
	Suspended EventStatus = 6
)

func ToEventStatus

func ToEventStatus(status string) EventStatus

func (EventStatus) String

func (status EventStatus) String() string

type MessageBrokerServer

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

func (*MessageBrokerServer) SendKafkaMessage

func (s *MessageBrokerServer) SendKafkaMessage(
	ctx context.Context,
	req *pb.KafkaMessage,
) (*pb.Response, error)

func (*MessageBrokerServer) SendRabbitMQMessage

func (s *MessageBrokerServer) SendRabbitMQMessage(
	ctx context.Context,
	req *pb.RabbitMQMessage,
) (*pb.Response, error)

type OperationProductionData

type OperationProductionData struct {
	ProductionInfo
	OperationProductionProperties
	ProductionEventStatus
}

type OperationProductionProperties

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

type ProductionEvent string

const (
	ProductionEventStorage ProductionEvent = "storage"
)

type ProductionEventStatus

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

type ProductionInfo

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

type ProductionName string

const (
	ProductionNameGrib2Orig ProductionName = "orig"
)

type ProductionStream

type ProductionStream string

const (
	ProductionStreamOperation ProductionStream = "oper"
	ProductionStreamEPS       ProductionStream = "eps"
)

type ProductionType

type ProductionType string

const (
	ProductionTypeObs      ProductionType = "obs"
	ProductionTypeForecast ProductionType = "fcst"
	ProductionTypeGrib2    ProductionType = "grib2"
	ProductionTypeGraph    ProductionType = "graph"
)

type RabbitMQMessage

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