event

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2020 License: GPL-3.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

View Source 
const PREFIX = "mokabox"

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrorOccured 

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

func (ErrorOccured) GetError 

func (e ErrorOccured) GetError() error

func (ErrorOccured) GetPickerGroupID 

func (e ErrorOccured) GetPickerGroupID() string

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() string

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 string
	Timestamp     time.Time
}

func (PickerPaused) GetPickerGroupID 

func (p PickerPaused) GetPickerGroupID() string

func (PickerPaused) GetTimestamp 

func (p PickerPaused) GetTimestamp() time.Time

func (PickerPaused) String 

func (p PickerPaused) String() string

type PickerStarted 

type PickerStarted struct {
	PickerGroupID string
	Timestamp     time.Time
}

func (PickerStarted) GetPickerGroupID 

func (p PickerStarted) GetPickerGroupID() string

func (PickerStarted) GetTimestamp 

func (p PickerStarted) GetTimestamp() time.Time

func (PickerStarted) String 

func (p PickerStarted) String() string

type Removed 

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

func (Removed) GetPickerGroupID 

func (r Removed) GetPickerGroupID() string

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 string
	Timestamp     time.Time
}

func (RemoverPaused) GetPickerGroupID 

func (r RemoverPaused) GetPickerGroupID() string

func (RemoverPaused) GetTimestamp 

func (r RemoverPaused) GetTimestamp() time.Time

func (RemoverPaused) String 

func (r RemoverPaused) String() string

type RemoverStarted 

type RemoverStarted struct {
	PickerGroupID string
	Timestamp     time.Time
}

func (RemoverStarted) GetPickerGroupID 

func (r RemoverStarted) GetPickerGroupID() string

func (RemoverStarted) GetTimestamp 

func (r RemoverStarted) GetTimestamp() time.Time

func (RemoverStarted) String 

func (r RemoverStarted) String() string

type Sent 

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

func (Sent) GetPickerGroupID 

func (s Sent) GetPickerGroupID() string

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() string

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 string
	OriginGroupID string
	OutboxRecord  *model.OutboxRecord
	Timestamp     time.Time
}

func (ZombieAcquired) GetOriginGroupID 

func (z ZombieAcquired) GetOriginGroupID() string

func (ZombieAcquired) GetPickerGroupID 

func (z ZombieAcquired) GetPickerGroupID() string

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 string
	OutboxRecord  *model.OutboxRecord
	Timestamp     time.Time
}

func (ZombiePicked) GetPickerGroupID 

func (z ZombiePicked) GetPickerGroupID() string

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 string
	Timestamp     time.Time
}

func (ZombiePickerPaused) GetPickerGroupID 

func (z ZombiePickerPaused) GetPickerGroupID() string

func (ZombiePickerPaused) GetTimestamp 

func (z ZombiePickerPaused) GetTimestamp() time.Time

func (ZombiePickerPaused) String 

func (z ZombiePickerPaused) String() string

type ZombiePickerStarted 

type ZombiePickerStarted struct {
	PickerGroupID string
	Timestamp     time.Time
}

func (ZombiePickerStarted) GetPickerGroupID 

func (z ZombiePickerStarted) GetPickerGroupID() string

func (ZombiePickerStarted) GetTimestamp 

func (z ZombiePickerStarted) GetTimestamp() time.Time

func (ZombiePickerStarted) String 

func (z ZombiePickerStarted) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.