eventprocessor

Apr 9, 2026

Changes in this version

+ const KeyVersionMismatchCode

+ var ErrKeyRotateMismatchedKeyIDs = errors.New("system key rotate requires identical key IDs")

+ func IsVersionMismatchError(errorMessage string) bool

type EventFactory

+ func (f *EventFactory) SystemKeyRotate(ctx context.Context, system *model.System, keyID string) (orbital.Job, error)

+ func (f *EventFactory) SystemUnlinkDecommission(ctx context.Context, system *model.System, keyID string) (orbital.Job, error)

type JobType

+ const JobTypeSystemKeyRotate

+ const JobTypeSystemUnlinkDecommission

+ type KeyDetachJobHandler struct

+ func NewKeyDetachJobHandler(repo repo.Repo, cmkAuditor *auditor.Auditor, orbitalManager *orbital.Manager, ...) *KeyDetachJobHandler

+ func (h *KeyDetachJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *KeyDetachJobHandler) HandleJobConfirm(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *KeyDetachJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *KeyDetachJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *KeyDetachJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type SystemKeyRotateJobHandler struct

+ func NewSystemKeyRotateJobHandler(repo repo.Repo, cmkAuditor *auditor.Auditor, orbitalManager *orbital.Manager, ...) *SystemKeyRotateJobHandler

+ func (h *SystemKeyRotateJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemKeyRotateJobHandler) HandleJobConfirm(_ context.Context, _ orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *SystemKeyRotateJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemKeyRotateJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemKeyRotateJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type SystemUnlinkDecommissionJobHandler struct

+ func NewSystemUnlinkDecommissionJobHandler(repo repo.Repo, registry registry.Service, cmkAuditor *auditor.Auditor, ...) *SystemUnlinkDecommissionJobHandler

+ func (h *SystemUnlinkDecommissionJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkDecommissionJobHandler) HandleJobConfirm(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *SystemUnlinkDecommissionJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkDecommissionJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkDecommissionJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

Mar 6, 2026

Changes in this version

+ const EmbeddedTarget

+ var ErrInvalidJobType = errors.New("invalid job type")

+ var ErrNoTasksResolvedForJob = errors.New("no tasks resolved for the job")

+ var ErrUnsupportedJobType = errors.New("unsupported job type")

+ func GetOrbitalError(ctx context.Context, err error) string

type CryptoReconciler

+ func (c *CryptoReconciler) GetHandlerByJobType(jobType string) (JobHandler, error)

type EventFactory

+ func (f *EventFactory) SystemSwitchNewPrimaryKey(ctx context.Context, system *model.System, keyIDTo string, keyIDFrom string) (orbital.Job, error)

+ type JobHandler interface

+ HandleJobCanceledEvent func(ctx context.Context, job orbital.Job) error

+ HandleJobConfirm func(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ HandleJobDoneEvent func(ctx context.Context, job orbital.Job) error

+ HandleJobFailedEvent func(ctx context.Context, job orbital.Job) error

+ ResolveTasks func(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type JobType string

+ const JobTypeKeyDelete

+ const JobTypeKeyDetach

+ const JobTypeKeyDisable

+ const JobTypeKeyEnable

+ const JobTypeKeyRotate

+ const JobTypeSystemLink

+ const JobTypeSystemSwitch

+ const JobTypeSystemSwitchNewPK

+ const JobTypeSystemUnlink

+ func (t JobType) String() string

+ type KeyConfigActionJobData struct

+ KeyConfigID string

+ TenantID string

+ type KeyJobHandler struct

+ func NewKeyJobHandler(taskResolver *KeyTaskInfoResolver) *KeyJobHandler

+ func (h *KeyJobHandler) HandleJobCanceledEvent(_ context.Context, _ orbital.Job) error

+ func (h *KeyJobHandler) HandleJobConfirm(_ context.Context, _ orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *KeyJobHandler) HandleJobDoneEvent(_ context.Context, _ orbital.Job) error

+ func (h *KeyJobHandler) HandleJobFailedEvent(_ context.Context, _ orbital.Job) error

+ func (h *KeyJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type KeyTaskInfoResolver struct

+ func (r *KeyTaskInfoResolver) Resolve(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

type Option

+ func WithMaxPendingReconciles(n uint64) Option

+ type OrbitalError struct

+ Code string

+ Message string

+ func ParseOrbitalError(errorMessage string) OrbitalError

+ func (e *OrbitalError) DefaultError() *OrbitalError

+ func (e *OrbitalError) IsDefaultError() bool

+ func (e *OrbitalError) SetContext(context *map[string]any)

+ func (e *OrbitalError) String() string

type SystemActionJobData

+ func GetSystemJobData(e *model.Event) (SystemActionJobData, error)

+ type SystemLinkJobHandler struct

+ func NewSystemLinkJobHandler(repo repo.Repo, registry registry.Service, cmkAuditor *auditor.Auditor, ...) *SystemLinkJobHandler

+ func (h *SystemLinkJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemLinkJobHandler) HandleJobConfirm(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *SystemLinkJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemLinkJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemLinkJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type SystemSwitchJobHandler struct

+ func NewSystemSwitchJobHandler(repo repo.Repo, registry registry.Service, cmkAuditor *auditor.Auditor, ...) *SystemSwitchJobHandler

+ func (h *SystemSwitchJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemSwitchJobHandler) HandleJobConfirm(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *SystemSwitchJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemSwitchJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemSwitchJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type SystemTaskInfoResolver struct

+ func (r *SystemTaskInfoResolver) Resolve(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

+ type SystemUnlinkJobHandler struct

+ func NewSystemUnlinkJobHandler(repo repo.Repo, registry registry.Service, cmkAuditor *auditor.Auditor, ...) *SystemUnlinkJobHandler

+ func (h *SystemUnlinkJobHandler) HandleJobCanceledEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkJobHandler) HandleJobConfirm(ctx context.Context, job orbital.Job) (orbital.JobConfirmerResult, error)

+ func (h *SystemUnlinkJobHandler) HandleJobDoneEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkJobHandler) HandleJobFailedEvent(ctx context.Context, job orbital.Job) error

+ func (h *SystemUnlinkJobHandler) ResolveTasks(ctx context.Context, job orbital.Job) ([]orbital.TaskInfo, error)

Feb 23, 2026

Changes in this version

+ type EventFactory struct

+ func NewEventFactory(ctx context.Context, cfg *config.Config, repository repo.Repo) (*EventFactory, error)

+ func (f *EventFactory) CreateJob(ctx context.Context, event *model.Event) (orbital.Job, error)

+ func (f *EventFactory) GetLastEvent(ctx context.Context, cmkItemID string) (*model.Event, error)

+ func (f *EventFactory) KeyDetach(ctx context.Context, keyID string) (orbital.Job, error)

+ func (f *EventFactory) KeyDisable(ctx context.Context, keyID string) (orbital.Job, error)

+ func (f *EventFactory) KeyEnable(ctx context.Context, keyID string) (orbital.Job, error)

+ func (f *EventFactory) SendEvent(ctx context.Context, event Event) error

+ func (f *EventFactory) SystemLink(ctx context.Context, system *model.System, keyID string) (orbital.Job, error)

+ func (f *EventFactory) SystemSwitch(ctx context.Context, system *model.System, keyIDTo string, keyIDFrom string, ...) (orbital.Job, error)

+ func (f *EventFactory) SystemUnlink(ctx context.Context, system *model.System, keyID string, trigger string) (orbital.Job, error)

Feb 4, 2026

Changes in this version

+ var ErrEventSendingFailed = errors.New("failed to send event")

+ var ErrKeyAccessMetadataNotFound = errors.New("key access metadata not found for system region")

+ var ErrMissingKeyID = errors.New("keyID is required to create key event job")

+ var ErrNoConnectedRegionsForKey = errors.New("no connected regions found for key")

+ var ErrNoPreviousEvent = errors.New("no previous events found for selected item")

+ var ErrPluginNotFound = errors.New("plugin not found for key provider")

+ var ErrSettingKeyClaim = errors.New("error setting key claim for system")

+ var ErrSystemProcessing = errors.New("system is still in processing state")

+ var ErrTargetNotConfigured = errors.New("target not configured for region")

+ var ErrUnsupportedRegion = errors.New("unsupported region")

+ var ErrUnsupportedTaskType = errors.New("unsupported task type")

+ type CryptoReconciler struct

+ func NewCryptoReconciler(ctx context.Context, cfg *config.Config, repository repo.Repo, ...) (*CryptoReconciler, error)

+ func (c *CryptoReconciler) CloseAmqpClients(ctx context.Context)

+ func (c *CryptoReconciler) CreateJob(ctx context.Context, event *model.Event) (orbital.Job, error)

+ func (c *CryptoReconciler) GetLastEvent(ctx context.Context, cmkItemID string) (*model.Event, error)

+ func (c *CryptoReconciler) KeyDetach(ctx context.Context, keyID string) (orbital.Job, error)

+ func (c *CryptoReconciler) KeyDisable(ctx context.Context, keyID string) (orbital.Job, error)

+ func (c *CryptoReconciler) KeyEnable(ctx context.Context, keyID string) (orbital.Job, error)

+ func (c *CryptoReconciler) SendEvent(ctx context.Context, event Event) error

+ func (c *CryptoReconciler) Start(ctx context.Context) error

+ func (c *CryptoReconciler) SystemLink(ctx context.Context, system *model.System, keyID string) (orbital.Job, error)

+ func (c *CryptoReconciler) SystemSwitch(ctx context.Context, system *model.System, keyIDTo string, keyIDFrom string, ...) (orbital.Job, error)

+ func (c *CryptoReconciler) SystemUnlink(ctx context.Context, system *model.System, keyID string) (orbital.Job, error)

+ type Event struct

+ Event func(ctx context.Context) (orbital.Job, error)

+ Name string

+ type KeyActionJobData struct

+ KeyID string

+ TenantID string

+ type Option func(manager *orbital.Manager)

+ func WithConfirmJobAfter(d time.Duration) Option

+ func WithExecInterval(d time.Duration) Option

+ func WithMaxReconcileCount(n int64) Option

+ type SystemActionJobData struct

+ KeyIDFrom string

+ KeyIDTo string

+ SystemID string

+ TenantID string

+ Trigger string