package
0.4.1
Repository: https://github.com/melenium2/go-iobox.git
Documentation: pkg.go.dev

# Packages

No description provided by the author
No description provided by the author

# Functions

No description provided by the author
No description provided by the author
No description provided by the author
NewRecord creates new record that can be processed by inbox worker.
No description provided by the author
OnDeadCallback sets custom callback for each message that can not be processed and marks as 'dead'.
WithHandlerTimeout sets new interval after which handler will be stopped.
WithIterationRate sets new interval for process all inbox events.
WithLogger sets custom implementation of Logger.
WithMaxRetryAttempt sets custom max attempts for processing event.

# Constants

Dead means the current Record is not processable.
DebugMode enables additional logs for debug inbox process.
DefaultHandlerTimeout is the timeout after which the handler will be stopped and the status will be set as Fail.
DefaultIterationRate is the timeout after which all events in the inbox table will be processed.
DefaultRetryAttempts is the max attempts before event marks as 'dead'.
Done means the current Record is successfully processed.
Failed means the current Record not processed by worker by specific reason.
Null means the current Record is not processed yet.
Progress means the current Record is processed by worker.

# Variables

No description provided by the author
No description provided by the author

# Structs

Inbox is struct that implement inbox pattern.
NopLogger logs nothing.
Record is event that should be processed by inbox worker.
Registry contains all handler that will be processed by Inbox.

# Interfaces

Client provides possibility to set records to the inbox table.
go:generate mockery --name Handler.
No description provided by the author

# Type aliases

ErrorCallback prototype of function that can be called on failed or dead message.
Option sets specific configuration to the Inbox.
Status defines current status of Record.