Documentation ¶
Index ¶
- Variables
- func NewArchiveRecipientsUpdated(keys [][]byte) pb.RepoEvent
- func NewArchiveRepoCompletedError(workflowId uuid.I, code int32) pb.RepoEvent
- func NewArchiveRepoCompletedOk(workflowId uuid.I, tarPath string) pb.RepoEvent
- func NewArchiveRepoStarted(workflowId uuid.I) pb.RepoEvent
- func NewEnableGitlabAccepted(host, path string) pb.RepoEvent
- func NewFreezeRepoCompleted2Error(workflowId uuid.I, code int32) pb.RepoEvent
- func NewFreezeRepoCompleted2Ok(workflowId uuid.I) pb.RepoEvent
- func NewFreezeRepoStarted2(workflowId uuid.I) pb.RepoEvent
- func NewGitRepoCreated(inf *pb.FsoGitRepoInfo) pb.RepoEvent
- func NewPbRepoMoveStarted(ev *EvRepoMoveStarted) pb.RepoEvent
- func NewPbRepoMoved(ev *EvRepoMoved) pb.RepoEvent
- func NewRepoErrorCleared() pb.RepoEvent
- func NewRepoErrorSet(msg string) pb.RepoEvent
- func NewRepoInitStarted(inf *pb.FsoRepoInitInfo) pb.RepoEvent
- func NewShadowBackupRecipientsUpdated(keys [][]byte) pb.RepoEvent
- func NewShadowBackupRepoCreated(shadowBackupURL string) pb.RepoEvent
- func NewShadowBackupRepoMoved(shadowBackupURL string) pb.RepoEvent
- func NewShadowRepoCreated(shadowPath string) pb.RepoEvent
- func NewShadowRepoMoveStarted(workflowId uuid.I, newShadowPath string) pb.RepoEvent
- func NewShadowRepoMoved(workflowId uuid.I, workflowEventId ulid.I, newShadowPath string) pb.RepoEvent
- func NewTarttRepoCreated(tarttURL string) pb.RepoEvent
- func NewUnarchiveRepoCompletedError(workflowId uuid.I, code int32) pb.RepoEvent
- func NewUnarchiveRepoCompletedOk(workflowId uuid.I) pb.RepoEvent
- func NewUnarchiveRepoStarted(workflowId uuid.I) pb.RepoEvent
- func NewUnfreezeRepoCompleted2Error(workflowId uuid.I, code int32) pb.RepoEvent
- func NewUnfreezeRepoCompleted2Ok(workflowId uuid.I) pb.RepoEvent
- func NewUnfreezeRepoStarted2(workflowId uuid.I) pb.RepoEvent
- type EvArchiveRecipientsUpdated
- type EvArchiveRepoCompleted
- type EvArchiveRepoStarted
- type EvEnableGitlabAccepted
- type EvFreezeRepoCompleted
- type EvFreezeRepoCompleted2
- type EvFreezeRepoStarted
- type EvFreezeRepoStarted2
- type EvGitRepoCreated
- type EvRepoErrorCleared
- type EvRepoErrorSet
- type EvRepoInitStarted
- type EvRepoMoveStarted
- type EvRepoMoved
- type EvShadowBackupRecipientsUpdated
- type EvShadowBackupRepoCreated
- type EvShadowBackupRepoMoved
- type EvShadowRepoCreated
- type EvShadowRepoMoveStarted
- type EvShadowRepoMoved
- type EvTarttRepoCreated
- type EvUnarchiveRepoCompleted
- type EvUnarchiveRepoStarted
- type EvUnfreezeRepoCompleted
- type EvUnfreezeRepoCompleted2
- type EvUnfreezeRepoStarted
- type EvUnfreezeRepoStarted2
- type ParseError
- type RepoEvent
Constants ¶
This section is empty.
Variables ¶
var ErrMalformedGPGFingerprint = errors.New("malformed GPG key fingerprint")
var ErrMalformedGitAuthorEmail = errors.New("malformed GitAuthor.Email")
var ErrMalformedGitAuthorName = errors.New("malformed GitAuthor.Name")
var ErrMissingGitAuthor = errors.New("missing GitAuthor")
var ErrUnknownEventType = errors.New("unknown event type")
Functions ¶
func NewEnableGitlabAccepted ¶
func NewGitRepoCreated ¶
func NewGitRepoCreated(inf *pb.FsoGitRepoInfo) pb.RepoEvent
func NewPbRepoMoveStarted ¶
func NewPbRepoMoveStarted(ev *EvRepoMoveStarted) pb.RepoEvent
func NewPbRepoMoved ¶
func NewPbRepoMoved(ev *EvRepoMoved) pb.RepoEvent
func NewRepoErrorCleared ¶
func NewRepoErrorSet ¶
func NewRepoInitStarted ¶
func NewRepoInitStarted(inf *pb.FsoRepoInitInfo) pb.RepoEvent
func NewShadowRepoCreated ¶
func NewShadowRepoMoved ¶
func NewTarttRepoCreated ¶
Types ¶
type EvArchiveRecipientsUpdated ¶
type EvArchiveRecipientsUpdated struct {
Keys [][]byte
}
`RepoEvent_EV_FSO_ARCHIVE_RECIPIENTS_UPDATED` aka `EvArchiveRecipientsUpdated` replaces the GPG key fingerprints to which tartt archive secrets are encrypted.
func (EvArchiveRecipientsUpdated) RepoEvent ¶
func (EvArchiveRecipientsUpdated) RepoEvent()
type EvArchiveRepoCompleted ¶
`RepoEvent_EV_FSO_ARCHIVE_REPO_COMPLETED` aka `EvArchiveRepoCompleted`. See freeze-repo workflow aka freezerepowf.
func (EvArchiveRepoCompleted) RepoEvent ¶
func (EvArchiveRepoCompleted) RepoEvent()
type EvArchiveRepoStarted ¶
`RepoEvent_EV_FSO_ARCHIVE_REPO_STARTED` aka `EvArchiveRepoStarted`. See freeze-repo workflow aka freezerepowf.
func (EvArchiveRepoStarted) RepoEvent ¶
func (EvArchiveRepoStarted) RepoEvent()
type EvEnableGitlabAccepted ¶
`RepoEvent_EV_FSO_ENABLE_GITLAB_ACCEPTED` aka `EvEnableGitlabAccepted`.
func (EvEnableGitlabAccepted) RepoEvent ¶
func (EvEnableGitlabAccepted) RepoEvent()
type EvFreezeRepoCompleted ¶
type EvFreezeRepoCompleted struct{}
`RepoEvent_EV_FSO_FREEZE_REPO_COMPLETED` aka `EvFreezeRepoCompleted` is a legacy event that was used in the preliminary repo-freeze implementation.
func (EvFreezeRepoCompleted) RepoEvent ¶
func (EvFreezeRepoCompleted) RepoEvent()
type EvFreezeRepoCompleted2 ¶
`RepoEvent_EV_FSO_FREEZE_REPO_COMPLETED_2` aka `EvFreezeRepoCompleted2`. See freeze-repo workflow aka freezerepowf.
func (EvFreezeRepoCompleted2) RepoEvent ¶
func (EvFreezeRepoCompleted2) RepoEvent()
type EvFreezeRepoStarted ¶
type EvFreezeRepoStarted struct{}
`RepoEvent_EV_FSO_FREEZE_REPO_STARTED` aka `EvFreezeRepoStarted` is a legacy event that was used in the preliminary repo-freeze implementation.
func (EvFreezeRepoStarted) RepoEvent ¶
func (EvFreezeRepoStarted) RepoEvent()
type EvFreezeRepoStarted2 ¶
`RepoEvent_EV_FSO_FREEZE_REPO_STARTED_2` aka `EvFreezeRepoStarted2`. See freeze-repo workflow aka freezerepowf.
func (EvFreezeRepoStarted2) RepoEvent ¶
func (EvFreezeRepoStarted2) RepoEvent()
type EvGitRepoCreated ¶
type EvGitRepoCreated struct {
pb.FsoGitRepoInfo
}
`RepoEvent_EV_FSO_GIT_REPO_CREATED` aka `EvGitRepoCreated` is posted if a Git repo at a Git hosting service is created.
func (EvGitRepoCreated) RepoEvent ¶
func (EvGitRepoCreated) RepoEvent()
type EvRepoErrorCleared ¶
type EvRepoErrorCleared struct{}
`RepoEvent_EV_FSO_REPO_ERROR_CLEARED` aka `EvRepoErrorCleared` clears an repo error.
func (EvRepoErrorCleared) RepoEvent ¶
func (EvRepoErrorCleared) RepoEvent()
type EvRepoErrorSet ¶
type EvRepoErrorSet struct {
Message string
}
`RepoEvent_EV_FSO_REPO_ERROR_SET` aka `EvRepoErrorSet` sets an error string on the repo.
func (EvRepoErrorSet) RepoEvent ¶
func (EvRepoErrorSet) RepoEvent()
type EvRepoInitStarted ¶
type EvRepoInitStarted struct {
pb.FsoRepoInitInfo
}
`RepoEvent_EV_FSO_REPO_INIT_STARTED` aka `EvRepoInitStarted` is the event of a repo aggregate.
func (EvRepoInitStarted) RepoEvent ¶
func (EvRepoInitStarted) RepoEvent()
type EvRepoMoveStarted ¶
type EvRepoMoveStarted struct { RegistryEventId ulid.I WorkflowId uuid.I OldGlobalPath string OldFileHost string OldHostPath string OldShadowPath string NewGlobalPath string NewFileHost string NewHostPath string }
`RepoEvent_EV_FSO_REPO_MOVE_STARTED` aka `EvRepoMoveStarted` is part of the move-repo workflow. See package `moverepowf` for details.
func (EvRepoMoveStarted) RepoEvent ¶
func (EvRepoMoveStarted) RepoEvent()
type EvRepoMoved ¶
type EvRepoMoved struct { WorkflowId uuid.I WorkflowEventId ulid.I GlobalPath string FileHost string HostPath string ShadowPath string }
`RepoEvent_EV_FSO_REPO_MOVED` aka `EvRepoMoved` is part of the move-repo workflow. See package `moverepowf` for details.
func (EvRepoMoved) RepoEvent ¶
func (EvRepoMoved) RepoEvent()
type EvShadowBackupRecipientsUpdated ¶
type EvShadowBackupRecipientsUpdated struct {
Keys [][]byte
}
`RepoEvent_EV_FSO_SHADOW_BACKUP_RECIPIENTS_UPDATED` aka `EvShadowBackupRecipientsUpdated` replaces the GPG key fingerprints to which archive backups are encrypted.
func (EvShadowBackupRecipientsUpdated) RepoEvent ¶
func (EvShadowBackupRecipientsUpdated) RepoEvent()
type EvShadowBackupRepoCreated ¶
type EvShadowBackupRepoCreated struct {
pb.FsoShadowBackupRepoInfo
}
`RepoEvent_EV_FSO_SHADOW_BACKUP_REPO_CREATED` aka `EvShadowBackupRepoCreated` confirms that a backup directory has been created. It contains the location as a `nogfsobak://` URL.
See `EvTarttRepoCreated` for discussion about potential future two-phase initialization.
func (EvShadowBackupRepoCreated) RepoEvent ¶
func (EvShadowBackupRepoCreated) RepoEvent()
type EvShadowBackupRepoMoved ¶
type EvShadowBackupRepoMoved struct {
pb.FsoShadowBackupRepoInfo
}
`RepoEvent_EV_FSO_SHADOW_BACKUP_REPO_MOVED` aka `EvShadowBackupRepoMoved` changes the location of the backup directory. It contains the location as a `nogfsobak://` URL.
func (EvShadowBackupRepoMoved) RepoEvent ¶
func (EvShadowBackupRepoMoved) RepoEvent()
type EvShadowRepoCreated ¶
type EvShadowRepoCreated struct {
pb.FsoShadowRepoInfo
}
`RepoEvent_EV_FSO_SHADOW_REPO_CREATED` aka `EvShadowRepoCreated` is posted after the shadow has been created. It contains details about the repo location.
func (EvShadowRepoCreated) RepoEvent ¶
func (EvShadowRepoCreated) RepoEvent()
type EvShadowRepoMoveStarted ¶
`RepoEvent_EV_FSO_SHADOW_REPO_MOVE_STARTED` aka `EvShadowRepoMoveStarted` starts a workflow that changes the shadow location.
The workflow ends with:
- If committed, `RepoEvent_EV_FSO_SHADOW_REPO_MOVED` aka `EvShadowRepoMoved`.
- There is currently no way to abort the workflow.
func (EvShadowRepoMoveStarted) RepoEvent ¶
func (EvShadowRepoMoveStarted) RepoEvent()
type EvShadowRepoMoved ¶
type EvShadowRepoMoved struct { WorkflowId uuid.I // `WorkflowEventId` may be `ulid.Nil` for legacy events that were not // replicated from a workflow event. WorkflowEventId ulid.I NewShadowPath string }
`RepoEvent_EV_FSO_SHADOW_REPO_MOVED` aka `EvShadowRepoMoved` completes a workflow that started with `RepoEvent_EV_FSO_SHADOW_REPO_MOVE_STARTED` aka `EvShadowRepoMoveStarted`.
func (EvShadowRepoMoved) RepoEvent ¶
func (EvShadowRepoMoved) RepoEvent()
type EvTarttRepoCreated ¶
type EvTarttRepoCreated struct {
pb.FsoArchiveRepoInfo
}
`RepoEvent_EV_FSO_TARTT_REPO_CREATED` aka `EvTarttRepoCreated` confirms that a tartt repo has been created. It contains the tartt location as a `tartt://` URL.
`RepoEvent_EV_FSO_TARTT_REPO_CREATED` is currently the only event related to tartt repo initialization. Its name is chosen such that a corresponding event could be added in the future that would indicate the start of the tartt repo creation process:
- future registry event `tartt repo init started`, which would reserve the URL;
- repos event `RepoEvent_EV_FSO_TARTT_REPO_CREATED` would then indicate completion of the inititialization process.
Their relation would be similar to:
- registry event `RepoEvent_EV_FSO_REPO_ENABLE_GITLAB_ACCEPTED`;
- repos event `RepoEvent_EV_FSO_GIT_REPO_CREATED`.
func (EvTarttRepoCreated) RepoEvent ¶
func (EvTarttRepoCreated) RepoEvent()
type EvUnarchiveRepoCompleted ¶
`RepoEvent_EV_FSO_UNARCHIVE_REPO_COMPLETED` aka `EvUnarchiveRepoCompleted`. See freeze-repo workflow aka freezerepowf.
func (EvUnarchiveRepoCompleted) RepoEvent ¶
func (EvUnarchiveRepoCompleted) RepoEvent()
type EvUnarchiveRepoStarted ¶
`RepoEvent_EV_FSO_UNARCHIVE_REPO_STARTED` aka `EvUnarchiveRepoStarted`. See freeze-repo workflow aka freezerepowf.
func (EvUnarchiveRepoStarted) RepoEvent ¶
func (EvUnarchiveRepoStarted) RepoEvent()
type EvUnfreezeRepoCompleted ¶
type EvUnfreezeRepoCompleted struct{}
`RepoEvent_EV_FSO_UNFREEZE_REPO_COMPLETED` aka `EvUnfreezeRepoCompleted` is a legacy event that was used in the preliminary repo-freeze implementation.
func (EvUnfreezeRepoCompleted) RepoEvent ¶
func (EvUnfreezeRepoCompleted) RepoEvent()
type EvUnfreezeRepoCompleted2 ¶
`RepoEvent_EV_FSO_UNFREEZE_REPO_COMPLETED_2` aka `EvUnfreezeRepoCompleted2`. See freeze-repo workflow aka freezerepowf.
func (EvUnfreezeRepoCompleted2) RepoEvent ¶
func (EvUnfreezeRepoCompleted2) RepoEvent()
type EvUnfreezeRepoStarted ¶
type EvUnfreezeRepoStarted struct{}
`RepoEvent_EV_FSO_UNFREEZE_REPO_STARTED` aka `EvUnfreezeRepoStarted` is a legacy event that was used in the preliminary repo-freeze implementation.
func (EvUnfreezeRepoStarted) RepoEvent ¶
func (EvUnfreezeRepoStarted) RepoEvent()
type EvUnfreezeRepoStarted2 ¶
`RepoEvent_EV_FSO_UNFREEZE_REPO_STARTED_2` aka `EvUnfreezeRepoStarted2`. See freeze-repo workflow aka freezerepowf.
func (EvUnfreezeRepoStarted2) RepoEvent ¶
func (EvUnfreezeRepoStarted2) RepoEvent()
type ParseError ¶
func (*ParseError) Error ¶
func (err *ParseError) Error() string