Documentation
¶
Overview ¶
Package channelqueue adapts channel queue controls to the application service without exposing queue storage types to channels or RPC.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
func New ¶
func New(service *application.Service) *Adapter
func (*Adapter) EnqueueFollowUp ¶
func (*Adapter) EnqueueSteer ¶
Source Files
Click to show internal directories.
Click to hide internal directories.