core

Documentation

Index

• type QueuedMessage
• type Worker

Types

type QueuedMessage

type QueuedMessage interface {
	Bytes() []byte
}

QueuedMessage ...

type Worker

type Worker interface {
	// Run is called to start the worker
	Run(ctx context.Context, task QueuedMessage) error
	// Shutdown is called if stop all worker
	Shutdown() error
	// Queue to send message in Queue
	Queue(task QueuedMessage) error
	// Request to get message from Queue
	Request() (QueuedMessage, error)
}

Worker interface