data

Documentation

Index

• Constants
• func SetDefaultDatabasePath(path string)
• type Database
  • func NewDatabase(options *DatabaseOptions) Database
• type DatabaseOptions
• type GetDeploymentQuery
  • func NewGetDeploymentQuery(db *gorm.DB) *GetDeploymentQuery
  • func (q *GetDeploymentQuery) Execute(id uint) model.Deployment
• type InvokedOperationQuery
  • func NewInvokedOperationQuery(db *gorm.DB) *InvokedOperationQuery
  • func (q *InvokedOperationQuery) First(stageId uuid.UUID, correlationId string) (*model.InvokedOperation, error)
• type ListDeploymentsQuery
  • func NewListDeploymentsQuery(db *gorm.DB) *ListDeploymentsQuery
  • func (q *ListDeploymentsQuery) Execute() []model.Deployment
• type StageQuery
  • func NewStageQuery(db *gorm.DB) *StageQuery
  • func (q *StageQuery) Execute(id uuid.UUID) (*model.Deployment, *model.Stage, error)

Constants

const (
	DataDatabasePath = "./"
	DatabaseName     = "modm"
	DatabaseFileName = DatabaseName + ".db"
	InMemoryDsn      = "file::memory:"
)

Functions

func SetDefaultDatabasePath

func SetDefaultDatabasePath(path string)

Types

type Database

type Database interface {
	Instance() *gorm.DB
}

func NewDatabase

func NewDatabase(options *DatabaseOptions) Database

Gets a new db using the provided Options. If options are nil, the default DSN is used

type DatabaseOptions

type DatabaseOptions struct {
	UseInMemory bool
	Dsn         string
}

type GetDeploymentQuery

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

func NewGetDeploymentQuery

func NewGetDeploymentQuery(db *gorm.DB) *GetDeploymentQuery

func (*GetDeploymentQuery) Execute

func (q *GetDeploymentQuery) Execute(id uint) model.Deployment

type InvokedOperationQuery

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

func NewInvokedOperationQuery

func NewInvokedOperationQuery(db *gorm.DB) *InvokedOperationQuery

func (*InvokedOperationQuery) First

func (q *InvokedOperationQuery) First(stageId uuid.UUID, correlationId string) (*model.InvokedOperation, error)

finds the first invoked operation for a retry stage by id and correlation id if found returns the operation and nil error, otherwise returns nil, error

type ListDeploymentsQuery

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

List deployments

func NewListDeploymentsQuery

func NewListDeploymentsQuery(db *gorm.DB) *ListDeploymentsQuery

func (*ListDeploymentsQuery) Execute

func (q *ListDeploymentsQuery) Execute() []model.Deployment

type StageQuery

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

func NewStageQuery

func NewStageQuery(db *gorm.DB) *StageQuery

func (*StageQuery) Execute

func (q *StageQuery) Execute(id uuid.UUID) (*model.Deployment, *model.Stage, error)

finds a stage by id. If found returns the parent deployment, the stage and nil error if not found, returns nil, nil, error