storage

type CheckinObj struct {
	Step      string    `bson:"step" json:"step"`
	Timestamp time.Time `bson:"timestamp" json:"timestamp"`
}

type KV map[string]interface{}

type MongoStorage struct {
	// contains filtered or unexported fields
}

type Object struct {
	ID           interface{}            `bson:"_id" json:"id"`
	CreatedAt    time.Time              `bson:"createdAt" json:"createdAt"`
	UpdatedAt    time.Time              `bson:"updatedAt" json:"updatedAt"`
	CompletedAt  time.Time              `bson:"completedAt" json:"completedAt"`
	Error        string                 `bson:"error" json:"error"`
	CurrentStep  string                 `bson:"currentStep" json:"currentStep"`
	CommandGraph string                 `bson:"commandGraph" json:"commandGraph"`
	Status       Status                 `bson:"status" json:"status"`
	Params       map[string]interface{} `bson:"params" json:"params"`
}

type ObjectDTO struct {
	CommandGraph string                 `bson:"commandGraph" json:"commandGraph"`
	Status       Status                 `bson:"status" json:"status"`
	Params       map[string]interface{} `bson:"params" json:"params"`
}

type OperationKey string

type OperationMap map[OperationKey]OperationValue

type OperationValue map[string]interface{}

type Repository struct {
	Storage
}

type Status string

type Storage interface {
	Create(obj ObjectDTO) (*Object, error)
	FindById(id string) (*Object, error)
	UpdateById(id string, update KV, operation OperationMap) error
}