Versions in this module Expand all Collapse all v0 v0.0.1 Aug 14, 2022 Changes in this version + type Interface interface + GetChannel func() (chan *pkg.TemplgridEmailEntity, error) + Push func(entity *pkg.TemplgridEmailEntity) error + Run func(ctx context.Context) error + type InternalQueue struct + func NewInternalQueue(log logging.Logger) *InternalQueue + func (q *InternalQueue) GetChannel() (chan *pkg.TemplgridEmailEntity, error) + func (q *InternalQueue) Push(entity *pkg.TemplgridEmailEntity) error + func (q *InternalQueue) Run(ctx context.Context) error
Go to main page