sql

type AppRelease struct {
	Id                    int           `pg:"id,pk"`
	AppId                 int           `pg:"app_id,notnull,use_zero"`                   //orchestrator appId
	EnvironmentId         int           `pg:"environment_id,notnull,use_zero"`           //orchestrator env id
	CiArtifactId          int           `pg:"ci_artifact_id,notnull,use_zero"`           //orchestrator ciAretefactId  used for identifying rollback (appId,environmentId, ciArtifactId)
	ReleaseId             int           `pg:"release_id,notnull,use_zero"`               // orchestrator release counter
	PipelineOverrideId    int           `pg:"pipeline_override_id,notnull,use_zero"`     //pipeline override id orchestrator
	ChangeSizeLineAdded   int           `pg:"change_size_line_added,notnull,use_zero"`   //total lines added in this release
	ChangeSizeLineDeleted int           `pg:"change_size_line_deleted,notnull,use_zero"` //total lines deleted during this release
	TriggerTime           time.Time     `pg:"trigger_time,notnull"`                      //deployment time
	ReleaseType           ReleaseType   `pg:"release_type,notnull,use_zero"`
	ReleaseStatus         ReleaseStatus `pg:"release_status,notnull,use_zero"`
	ProcessStage          ProcessStage  `pg:"process_status,notnull,use_zero"`
	CreatedTime           time.Time     `pg:"created_time,notnull"`
	UpdatedTime           time.Time     `pg:"updated_time,notnull"`
	LeadTime              *LeadTime
	// contains filtered or unexported fields
}

type AppReleaseRepository interface {
	Save(appRelease *AppRelease) (*AppRelease, error)
	Update(appRelease *AppRelease) (*AppRelease, error)
	CheckDuplicateRelease(appId, environmentId, ciArtifactId int) (bool, error)
	GetPreviousReleaseWithinTime(appId, environmentId int, within time.Time, currentAppReleaseId int) (*AppRelease, error)
	GetPreviousRelease(appId, environmentId int, appReleaseId int) (*AppRelease, error)
	GetReleaseBetween(appId, environmentId int, from time.Time, to time.Time) ([]AppRelease, error)
	CleanAppDataForEnvironment(appId, environmentId int) error
}

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

type Config struct {
	Addr            string `env:"PG_ADDR" envDefault:"127.0.0.1"`
	Port            string `env:"PG_PORT" envDefault:"5432"`
	User            string `env:"PG_USER" envDefault:""`
	Password        string `env:"PG_PASSWORD" envDefault:"" secretData:"-"`
	Database        string `env:"PG_DATABASE" envDefault:"lens"`
	ApplicationName string `env:"APP" envDefault:"lens"`
	LogQuery        bool   `env:"PG_LOG_QUERY" envDefault:"true"`
}

type LeadTime struct {
	Id                 int           `pg:"id"`
	AppReleaseId       int           `pg:"app_release_id"`
	PipelineMaterialId int           `pg:"pipeline_material_id"`
	CommitHash         string        `pg:"commit_hash"`
	CommitTime         time.Time     `pg:"commit_time"`
	LeadTime           time.Duration `pg:"lead_time"`
	AppRelease         *AppRelease
	// contains filtered or unexported fields
}

type LeadTimeRepository interface {
	Save(leadTime *LeadTime) (*LeadTime, error)
	FindByIds(ids []int) ([]LeadTime, error)
	CleanAppDataForEnvironment(appId, environmentId int, tx *pg.Tx) error
}

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

type PipelineMaterial struct {
	PipelineMaterialId int    `pg:"pipeline_material_id"`
	CommitHash         string `pg:"commit_hash"`
	AppReleaseId       int    `pg:"app_release_id"`
	AppRelease         *AppRelease
	// contains filtered or unexported fields
}

type PipelineMaterialRepository interface {
	Save(pipelineMaterial ...*PipelineMaterial) error
	FindByAppReleaseId(appReleaseId int) ([]*PipelineMaterial, error)
	FindByAppReleaseIds(appReleaseIds []int) ([]*PipelineMaterial, error)
	CleanAppDataForEnvironment(appId, environmentId int, tx *pg.Tx) error
}

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

type ProcessStage int

type ReleaseStatus int

type ReleaseType int