msg_queue

type MsgQueueCommon struct {
	ID        primitive.ObjectID `bson:"_id,omitempty"           json:"id,omitempty"`
	Payload   string             `json:"payload" bson:"payload"`
	QueueType string             `json:"queue_type" bson:"queue_type"`
}

type MsgQueuePipelineTask struct {
	ID        primitive.ObjectID `bson:"_id,omitempty"             json:"id,omitempty"`
	Task      *task.Task
	QueueType string `json:"queue_type" bson:"queue_type"`
	QueueID   int    `json:"queue_id" bson:"queue_id"`
}