event

Documentation

Index

• Constants
• type ErrorOccured
  • func (e ErrorOccured) GetError() error
  • func (e ErrorOccured) GetPickerGroupID() uuid.UUID
  • func (e ErrorOccured) GetTimestamp() time.Time
  • func (e ErrorOccured) String() string
• type EventHandler
• type Picked
  • func (p Picked) GetPickerGroupID() uuid.UUID
  • func (p Picked) GetRecord() *model.OutboxRecord
  • func (p Picked) GetTimestamp() time.Time
  • func (f Picked) String() string
• type PickerPaused
  • func (p PickerPaused) GetPickerGroupID() uuid.UUID
  • func (p PickerPaused) GetTimestamp() time.Time
  • func (p PickerPaused) String() string
• type PickerStarted
  • func (p PickerStarted) GetPickerGroupID() uuid.UUID
  • func (p PickerStarted) GetTimestamp() time.Time
  • func (p PickerStarted) String() string
• type Removed
  • func (r Removed) GetPickerGroupID() uuid.UUID
  • func (r Removed) GetRecord() *model.OutboxRecord
  • func (r Removed) GetTimestamp() time.Time
  • func (r Removed) String() string
• type RemoverPaused
  • func (r RemoverPaused) GetPickerGroupID() uuid.UUID
  • func (r RemoverPaused) GetTimestamp() time.Time
  • func (r RemoverPaused) String() string
• type RemoverStarted
  • func (r RemoverStarted) GetPickerGroupID() uuid.UUID
  • func (r RemoverStarted) GetTimestamp() time.Time
  • func (r RemoverStarted) String() string
• type Sent
  • func (s Sent) GetPickerGroupID() uuid.UUID
  • func (s Sent) GetRecord() *model.OutboxRecord
  • func (s Sent) GetTimestamp() time.Time
  • func (s Sent) String() string
• type StatusChanged
  • func (s StatusChanged) GetFrom() string
  • func (s StatusChanged) GetPickerGroupID() uuid.UUID
  • func (s StatusChanged) GetRecord() *model.OutboxRecord
  • func (s StatusChanged) GetTimestamp() time.Time
  • func (s StatusChanged) GetTo() string
  • func (s StatusChanged) String() string
• type ZombieAcquired
  • func (z ZombieAcquired) GetOriginGroupID() uuid.UUID
  • func (z ZombieAcquired) GetPickerGroupID() uuid.UUID
  • func (z ZombieAcquired) GetRecord() *model.OutboxRecord
  • func (z ZombieAcquired) GetTimestamp() time.Time
  • func (z ZombieAcquired) String() string
• type ZombiePicked
  • func (z ZombiePicked) GetPickerGroupID() uuid.UUID
  • func (z ZombiePicked) GetRecord() *model.OutboxRecord
  • func (z ZombiePicked) GetTimestamp() time.Time
  • func (z ZombiePicked) String() string
• type ZombiePickerPaused
  • func (z ZombiePickerPaused) GetPickerGroupID() uuid.UUID
  • func (z ZombiePickerPaused) GetTimestamp() time.Time
  • func (z ZombiePickerPaused) String() string
• type ZombiePickerStarted
  • func (z ZombiePickerStarted) GetPickerGroupID() uuid.UUID
  • func (z ZombiePickerStarted) GetTimestamp() time.Time
  • func (z ZombiePickerStarted) String() string

Constants

const PREFIX = "pokabox"

Types

type ErrorOccured

type ErrorOccured struct {
	PickerGroupID uuid.UUID
	Error         error
	Timestamp     time.Time
}

func (ErrorOccured) GetError

func (e ErrorOccured) GetError() error

func (ErrorOccured) GetPickerGroupID

func (e ErrorOccured) GetPickerGroupID() uuid.UUID

func (ErrorOccured) GetTimestamp

func (e ErrorOccured) GetTimestamp() time.Time

func (ErrorOccured) String

func (e ErrorOccured) String() string

type EventHandler

type EventHandler func(event.Event)

type Picked

type Picked struct {
	OutboxRecord *model.OutboxRecord
	Timestamp    time.Time
}

func (Picked) GetPickerGroupID

func (p Picked) GetPickerGroupID() uuid.UUID

func (Picked) GetRecord

func (p Picked) GetRecord() *model.OutboxRecord

func (Picked) GetTimestamp

func (p Picked) GetTimestamp() time.Time

func (Picked) String

func (f Picked) String() string

type PickerPaused

type PickerPaused struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (PickerPaused) GetPickerGroupID

func (p PickerPaused) GetPickerGroupID() uuid.UUID

func (PickerPaused) GetTimestamp

func (p PickerPaused) GetTimestamp() time.Time

func (PickerPaused) String

func (p PickerPaused) String() string

type PickerStarted

type PickerStarted struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (PickerStarted) GetPickerGroupID

func (p PickerStarted) GetPickerGroupID() uuid.UUID

func (PickerStarted) GetTimestamp

func (p PickerStarted) GetTimestamp() time.Time

func (PickerStarted) String

func (p PickerStarted) String() string

type Removed

type Removed struct {
	PickerGroupID uuid.UUID
	OutboxRecord  *model.OutboxRecord
	Timestamp     time.Time
}

func (Removed) GetPickerGroupID

func (r Removed) GetPickerGroupID() uuid.UUID

func (Removed) GetRecord

func (r Removed) GetRecord() *model.OutboxRecord

func (Removed) GetTimestamp

func (r Removed) GetTimestamp() time.Time

func (Removed) String

func (r Removed) String() string

type RemoverPaused

type RemoverPaused struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (RemoverPaused) GetPickerGroupID

func (r RemoverPaused) GetPickerGroupID() uuid.UUID

func (RemoverPaused) GetTimestamp

func (r RemoverPaused) GetTimestamp() time.Time

func (RemoverPaused) String

func (r RemoverPaused) String() string

type RemoverStarted

type RemoverStarted struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (RemoverStarted) GetPickerGroupID

func (r RemoverStarted) GetPickerGroupID() uuid.UUID

func (RemoverStarted) GetTimestamp

func (r RemoverStarted) GetTimestamp() time.Time

func (RemoverStarted) String

func (r RemoverStarted) String() string

type Sent

type Sent struct {
	PickerGroupID  uuid.UUID
	KafkaTopic     string
	KafkaPartition int32
	OutboxRecord   *model.OutboxRecord
	Timestamp      time.Time
}

func (Sent) GetPickerGroupID

func (s Sent) GetPickerGroupID() uuid.UUID

func (Sent) GetRecord

func (s Sent) GetRecord() *model.OutboxRecord

func (Sent) GetTimestamp

func (s Sent) GetTimestamp() time.Time

func (Sent) String

func (s Sent) String() string

type StatusChanged

type StatusChanged struct {
	From         string
	To           string
	OutboxRecord *model.OutboxRecord
	Timestamp    time.Time
}

func (StatusChanged) GetFrom

func (s StatusChanged) GetFrom() string

func (StatusChanged) GetPickerGroupID

func (s StatusChanged) GetPickerGroupID() uuid.UUID

func (StatusChanged) GetRecord

func (s StatusChanged) GetRecord() *model.OutboxRecord

func (StatusChanged) GetTimestamp

func (s StatusChanged) GetTimestamp() time.Time

func (StatusChanged) GetTo

func (s StatusChanged) GetTo() string

func (StatusChanged) String

func (s StatusChanged) String() string

type ZombieAcquired

type ZombieAcquired struct {
	PickerGroupID uuid.UUID
	OriginGroupID uuid.UUID
	OutboxRecord  *model.OutboxRecord
	Timestamp     time.Time
}

func (ZombieAcquired) GetOriginGroupID

func (z ZombieAcquired) GetOriginGroupID() uuid.UUID

func (ZombieAcquired) GetPickerGroupID

func (z ZombieAcquired) GetPickerGroupID() uuid.UUID

func (ZombieAcquired) GetRecord

func (z ZombieAcquired) GetRecord() *model.OutboxRecord

func (ZombieAcquired) GetTimestamp

func (z ZombieAcquired) GetTimestamp() time.Time

func (ZombieAcquired) String

func (z ZombieAcquired) String() string

type ZombiePicked

type ZombiePicked struct {
	PickerGroupID uuid.UUID
	OutboxRecord  *model.OutboxRecord
	Timestamp     time.Time
}

func (ZombiePicked) GetPickerGroupID

func (z ZombiePicked) GetPickerGroupID() uuid.UUID

func (ZombiePicked) GetRecord

func (z ZombiePicked) GetRecord() *model.OutboxRecord

func (ZombiePicked) GetTimestamp

func (z ZombiePicked) GetTimestamp() time.Time

func (ZombiePicked) String

func (z ZombiePicked) String() string

type ZombiePickerPaused

type ZombiePickerPaused struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (ZombiePickerPaused) GetPickerGroupID

func (z ZombiePickerPaused) GetPickerGroupID() uuid.UUID

func (ZombiePickerPaused) GetTimestamp

func (z ZombiePickerPaused) GetTimestamp() time.Time

func (ZombiePickerPaused) String

func (z ZombiePickerPaused) String() string

type ZombiePickerStarted

type ZombiePickerStarted struct {
	PickerGroupID uuid.UUID
	Timestamp     time.Time
}

func (ZombiePickerStarted) GetPickerGroupID

func (z ZombiePickerStarted) GetPickerGroupID() uuid.UUID

func (ZombiePickerStarted) GetTimestamp

func (z ZombiePickerStarted) GetTimestamp() time.Time

func (ZombiePickerStarted) String

func (z ZombiePickerStarted) String() string