migration

Aug 22, 2023

Changes in this version

type StageName

+ const ArchiveStage

type Step

+ const StepArchiveDone

+ const StepArchiveFailed

Aug 22, 2023

Changes in this version

type Client

+ ArchivePipeline func(source, owner, repo string) error

+ UnArchivePipeline func(source, owner, repo string) error

type StageName

+ const WaitingUnarchiveStage

type Step

+ const StepWaitingUnarchiveDone

+ const StepWaitingUnarchiveFailed

May 15, 2023

Changes in this version

+ type PagedBuildsResponse struct

+ Items []*contracts.Build

+ Pagination contracts.Pagination

May 15, 2023

Changes in this version

type Client

+ GetPipelineBuildStatus func(source, owner, name, branch string) (string, error)

Mar 21, 2023

Changes in this version

type Client

+ GetMigrationByFromRepo func(source, owner, name string) (*Task, error)

+ GetMigrationByID func(taskID string) (*Task, error)

+ GetMigrations func() ([]*Task, error)

+ RollbackMigration func(taskID string) (*Changes, error)

Mar 16, 2023

Changes in this version

type StageName

+ const ComputedTablesStage

type Step

+ const StepComputedTablesDone

+ const StepComputedTablesFailed

Mar 11, 2023

Changes in this version

+ type Changes struct

+ BuildLogs int

+ BuildVersions int

+ Builds int

+ ReleaseLogs int

+ Releases int

type Client

+ GetStatus func(taskID string) (*Task, error)

+ Queue func(request Request) (*Task, error)

+ Rollback func(taskID string) (*Changes, error)

Feb 22, 2023

Changes in this version

+ var ErrAuthFailed = fmt.Errorf("authentication failed")

+ type Request struct

+ CallbackURL *string

+ FromName string

+ FromOwner string

+ FromSource string

+ ID string

+ Restart StageName

+ ToName string

+ ToOwner string

+ ToSource string

type Stages

+ Len func() int

Feb 21, 2023

Changes in this version

type Change

+ func CallbackExecutor(_ context.Context, task *Task) ([]Change, error)

+ func CompletedExecutor(_ context.Context, task *Task) ([]Change, error)

type StageName

+ func (sn StageName) FailedStep() Step

+ func (sn StageName) SuccessStep() Step

+ type Stages interface

+ Current func() Stage

+ ExecuteNext func(ctx context.Context, task *Task) ([]Change, bool)

+ HasNext func() bool

+ Next func() Stage

+ Set func(name StageName, executor Executor) Stages

+ func NewStages(updater Updater, start Step) Stages

type Step

+ const StepCompletionDone

+ const StepCompletionFailed

+ type Updater func(ctx context.Context, task *Task) error

Feb 20, 2023

Changes in this version

type Status

+ func (s *Status) Scan(src any) error

+ func (s Status) Value() (driver.Value, error)

type Step

+ func (s *Step) Scan(src any) error

+ func (s Step) Value() (driver.Value, error)

Feb 20, 2023

Changes in this version

type Task

+ func (t *Task) SqlArgs() []sql.NamedArg

Feb 10, 2023

Changes in this version

+ type Change struct

+ FromID int64

+ ToID int64

+ type Client interface

+ GetMigrationStatus func(taskID string) (*Task, error)

+ QueueMigration func(request TaskRequest) (*Task, error)

+ func NewClient(serverURL, clientID, clientSecret string) Client

+ type Executor func(ctx context.Context, task *Task) ([]Change, error)

+ type LogType string

+ const BuildLog

+ const ReleaseLog

+ type Stage interface

+ Execute func(ctx context.Context, task *Task) ([]Change, bool)

+ Failure func() Step

+ Name func() StageName

+ Success func() Step

+ func BuildLogObjects(fn Executor) Stage

+ func BuildLogs(fn Executor) Stage

+ func BuildVersions(fn Executor) Stage

+ func Builds(fn Executor) Stage

+ func Callback() Stage

+ func Completed() Stage

+ func ReleaseLogObjects(fn Executor) Stage

+ func ReleaseLogs(fn Executor) Stage

+ func Releases(fn Executor) Stage

+ type StageName string

+ const BuildLogObjectsStage

+ const BuildLogsStage

+ const BuildVersionsStage

+ const BuildsStage

+ const CallbackStage

+ const CompletedStage

+ const LastStage

+ const ReleaseLogObjectsStage

+ const ReleaseLogsStage

+ const ReleasesStage

+ type Status int

+ const StatusCanceled

+ const StatusCompleted

+ const StatusFailed

+ const StatusInProgress

+ const StatusQueued

+ const StatusUnset

+ func StatusFrom(str string) Status

+ func (s *Status) MarshalJSON() ([]byte, error)

+ func (s *Status) String() string

+ func (s *Status) UnmarshalJSON(data []byte) error

+ type Step int

+ const StepBuildLogObjectsDone

+ const StepBuildLogObjectsFailed

+ const StepBuildLogsDone

+ const StepBuildLogsFailed

+ const StepBuildVersionsDone

+ const StepBuildVersionsFailed

+ const StepBuildsDone

+ const StepBuildsFailed

+ const StepCallbackDone

+ const StepCallbackFailed

+ const StepReleaseLogObjectsDone

+ const StepReleaseLogObjectsFailed

+ const StepReleaseLogsDone

+ const StepReleaseLogsFailed

+ const StepReleasesDone

+ const StepReleasesFailed

+ const StepWaiting

+ func FailedStepOf(stageName StageName) Step

+ func StepFrom(str string) Step

+ func (s *Step) MarshalJSON() ([]byte, error)

+ func (s *Step) String() string

+ func (s *Step) UnmarshalJSON(data []byte) error

+ type Task struct

+ Builds int

+ Changes map[StageName][]Change

+ Duration time.Duration

+ ErrorDetails *string

+ LastStep Step

+ QueuedAt time.Time

+ Releases int

+ Status Status

+ TotalDuration time.Duration

+ UpdatedAt time.Time

+ func (t *Task) FromFQN() string

+ func (t *Task) ToFQN() string

+ type TaskRequest struct

+ CallbackURL *string

+ FromName string

+ FromOwner string

+ FromSource string

+ ID string

+ Restart StageName

+ ToName string

+ ToOwner string

+ ToSource string