Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

eventprocessor

package

Go to main page

Versions in this module

v0

v0.3.0

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)

v0.2.1

Feb 5, 2026

v0.2.0

Feb 4, 2026

v0.1.2

Feb 4, 2026

v0.1.1

Feb 4, 2026

v0.1.0

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