engine

type Consumer interface {
	Consume(context.Context) error
}

type Engine interface {
	// AddConsumer adds AMQP consumer to engine.
	AddConsumer(Consumer)
	// AddPeriodicalWorker adds periodical worker to engine.
	AddPeriodicalWorker(name string, worker PeriodicalWorker)
	// AddRoutine adds a long-running goroutine to engine.
	AddRoutine(Routine)
	AddDeferFunc(deferFunc func(ctx context.Context))
	// Run starts goroutines for all consumers and periodical workers.
	// Engine stops if one of consumer or periodical worker return error.
	Run(context.Context) error
}

type InstanceRunInfo struct {
	ID               string           `json:"_id"`
	Name             string           `json:"name"`
	ConsumeQueue     string           `json:"consume_queue"`
	PublishQueue     string           `json:"publish_queue"`
	RpcConsumeQueues []string         `json:"rpc_consume_queues"`
	RpcPublishQueues []string         `json:"rpc_publish_queues"`
	QueueLength      int              `json:"queue_length"`
	Time             datetime.CpsTime `json:"time"`
}

type MessageProcessor interface {
	Process(ctx context.Context, d amqp.Delivery) (newMessage []byte, err error)
}

type PeriodicalWorker interface {
	GetInterval() time.Duration
	Work(context.Context)
}

type RPCClient interface {
	// Consumer receives RPC responses from AMQP queue.
	Consumer
	// Call receives RPC request and publishes it to AMQP queue.
	Call(ctx context.Context, m RPCMessage) error
}

type RPCMessage struct {
	CorrelationID string
	Body          []byte
}

type RPCMessageProcessor interface {
	Process(ctx context.Context, msg RPCMessage) error
}

type Routine func(context.Context) error

type RunInfo struct {
	Name             string
	ConsumeQueue     string
	PublishQueue     string
	RpcConsumeQueues []string
	RpcPublishQueues []string
	Instances        int
	QueueLength      int
	Time             datetime.CpsTime
	HasDiffConfig    bool
}

type RunInfoManager interface {
	SaveInstance(ctx context.Context, info InstanceRunInfo, expiration time.Duration) error
	GetEngines(ctx context.Context) ([]RunInfo, error)
}