Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueProcessingService ¶
type QueueProcessingService struct {
// contains filtered or unexported fields
}
func (*QueueProcessingService) Process ¶
func (t *QueueProcessingService) Process(ctx context.Context, wg *sync.WaitGroup, platformer contracts.Platformer)
type QueueProcessor ¶ added in v1.0.1
type QueueProcessor interface {
Process(ctx context.Context, wg *sync.WaitGroup, platformer contracts.Platformer)
}
func New ¶
func New(options *runtime.ServiceOptions, natsConnection *nats.Conn) QueueProcessor
Source Files
Click to show internal directories.
Click to hide internal directories.