repository

Documentation

Index

• type UserDeploymentRequest
• type UserDeploymentRequestRepository
• type UserDeploymentRequestRepositoryImpl
  • func NewUserDeploymentRequestRepositoryImpl(dbConnection *pg.DB, transactionUtilImpl *sql.TransactionUtilImpl) *UserDeploymentRequestRepositoryImpl
  • func (impl *UserDeploymentRequestRepositoryImpl) FindByCdWfId(cdWfId int) (*UserDeploymentRequest, error)
  • func (impl *UserDeploymentRequestRepositoryImpl) FindById(ctx context.Context, id int) (*UserDeploymentRequestWithAdditionalFields, error)
  • func (impl *UserDeploymentRequestRepositoryImpl) GetAllInCompleteRequests(ctx context.Context) ([]UserDeploymentRequestWithAdditionalFields, error)
  • func (impl *UserDeploymentRequestRepositoryImpl) GetLatestIdForPipeline(ctx context.Context, deploymentReqId int) (int, error)
  • func (impl *UserDeploymentRequestRepositoryImpl) IsLatestForPipelineId(id, pipelineId int) (bool, error)
  • func (impl *UserDeploymentRequestRepositoryImpl) Save(ctx context.Context, tx *pg.Tx, models ...*UserDeploymentRequest) error
• type UserDeploymentRequestWithAdditionalFields

Types

type UserDeploymentRequest

type UserDeploymentRequest struct {
	Id                   int                                 `sql:"id,pk"`
	PipelineId           int                                 `sql:"pipeline_id"`
	CiArtifactId         int                                 `sql:"ci_artifact_id"`
	AdditionalOverride   []byte                              `sql:"additional_override"`
	ForceTrigger         bool                                `sql:"force_trigger"`
	ForceSyncDeployment  bool                                `sql:"force_sync_deployment"`
	Strategy             string                              `sql:"strategy"`
	DeploymentWithConfig apiBean.DeploymentConfigurationType `sql:"deployment_with_config"`
	SpecificTriggerWfrId int                                 `sql:"specific_trigger_wfr_id"` // target cd_workflow_runner_id for rollback. Used in rollback deployment cases
	CdWorkflowId         int                                 `sql:"cd_workflow_id"`
	DeploymentType       models.DeploymentType               `sql:"deployment_type"`
	TriggeredAt          time.Time                           `sql:"triggered_at"`
	TriggeredBy          int32                               `sql:"triggered_by"`
	// contains filtered or unexported fields
}

type UserDeploymentRequestRepository

type UserDeploymentRequestRepository interface {
	// transaction util funcs
	sql.TransactionWrapper
	Save(ctx context.Context, tx *pg.Tx, models ...*UserDeploymentRequest) error
	FindById(ctx context.Context, id int) (*UserDeploymentRequestWithAdditionalFields, error)
	GetLatestIdForPipeline(ctx context.Context, deploymentReqId int) (int, error)
	FindByCdWfId(cdWfId int) (*UserDeploymentRequest, error)
	GetAllInCompleteRequests(ctx context.Context) ([]UserDeploymentRequestWithAdditionalFields, error)
	IsLatestForPipelineId(id, pipelineId int) (bool, error)
}

type UserDeploymentRequestRepositoryImpl

type UserDeploymentRequestRepositoryImpl struct {
	*sql.TransactionUtilImpl
	// contains filtered or unexported fields
}

func NewUserDeploymentRequestRepositoryImpl

func NewUserDeploymentRequestRepositoryImpl(dbConnection *pg.DB, transactionUtilImpl *sql.TransactionUtilImpl) *UserDeploymentRequestRepositoryImpl

func (*UserDeploymentRequestRepositoryImpl) FindByCdWfId

func (impl *UserDeploymentRequestRepositoryImpl) FindByCdWfId(cdWfId int) (*UserDeploymentRequest, error)

func (*UserDeploymentRequestRepositoryImpl) FindById

func (impl *UserDeploymentRequestRepositoryImpl) FindById(ctx context.Context, id int) (*UserDeploymentRequestWithAdditionalFields, error)

func (*UserDeploymentRequestRepositoryImpl) GetAllInCompleteRequests

func (impl *UserDeploymentRequestRepositoryImpl) GetAllInCompleteRequests(ctx context.Context) ([]UserDeploymentRequestWithAdditionalFields, error)

func (*UserDeploymentRequestRepositoryImpl) GetLatestIdForPipeline

func (impl *UserDeploymentRequestRepositoryImpl) GetLatestIdForPipeline(ctx context.Context, deploymentReqId int) (int, error)

func (*UserDeploymentRequestRepositoryImpl) IsLatestForPipelineId

func (impl *UserDeploymentRequestRepositoryImpl) IsLatestForPipelineId(id, pipelineId int) (bool, error)

func (*UserDeploymentRequestRepositoryImpl) Save

func (impl *UserDeploymentRequestRepositoryImpl) Save(ctx context.Context, tx *pg.Tx, models ...*UserDeploymentRequest) error

type UserDeploymentRequestWithAdditionalFields

type UserDeploymentRequestWithAdditionalFields struct {
	UserDeploymentRequest
	CdWorkflowRunnerId int `sql:"cd_workflow_runner_id"`
	PipelineOverrideId int `sql:"pipeline_override_id"`
}