queue

Documentation

Index

• type Interface
• type InternalQueue
  • 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

Types

type Interface

type Interface interface {
	Push(entity *pkg.TemplgridEmailEntity) error
	GetChannel() (chan *pkg.TemplgridEmailEntity, error)
	Run(ctx context.Context) error
}

type InternalQueue

type InternalQueue struct {
	// contains filtered or unexported fields
}

func NewInternalQueue

func NewInternalQueue(log logging.Logger) *InternalQueue

func (*InternalQueue) GetChannel

func (q *InternalQueue) GetChannel() (chan *pkg.TemplgridEmailEntity, error)

func (*InternalQueue) Push

func (q *InternalQueue) Push(entity *pkg.TemplgridEmailEntity) error

func (*InternalQueue) Run

func (q *InternalQueue) Run(ctx context.Context) error