persistence

type DelayQueue interface {
	Push(queueName string, mesage []byte) error
	Pop(queueName string) ([]string, error)
	PushWithDelay(queueName string, delay time.Duration, message []byte) error
}

type FlowDao interface {
	SaveFlowContext(wfName string, flowId string, flowCtx *model.FlowContext) error
	CreateAndSaveFlowContext(wFname string, flowId string, action int, dataMap map[string]any) (*model.FlowContext, error)
	AddActionOutputToFlowContext(wFname string, flowId string, action int, dataMap map[string]any) (*model.FlowContext, error)
	GetFlowContext(wfName string, flowId string) (*model.FlowContext, error)
	DeleteFlowContext(wfName string, flowId string) error
}

type Partition interface {
	GetFlowDao() FlowDao
	GetQueue() Queue
	GetDelayQueue() DelayQueue
}

type Partitions struct {
	Partitions map[int]Partition
	// contains filtered or unexported fields
}

type Queue interface {
	Push(queueName string, mesage []byte) error
	Pop(queuName string, batchSize int) ([]string, error)
}

type StorageLayerError struct {
	Message string
}

type TaskDao interface {
	SaveTask(task model.TaskDef) error
	DeleteTask(task string) error
	GetTask(task string) (*model.TaskDef, error)
}

type WorkflowDao interface {
	Save(wf model.Workflow) error

	Delete(name string) error

	Get(name string) (*model.Workflow, error)
}