adapters

Documentation

Overview

Package adapters Message queue adapters.

Index

• type ConsumerAdapter
  • func NewConsumer(a conf.Adapter, id, parallel int) (adapter ConsumerAdapter, err error)
• type ProducerAdapter
  • func NewProducer(a conf.Adapter) (adapter ProducerAdapter, err error)
• type RemoterAdapter
  • func NewRemoter(a conf.Adapter) (adapter RemoterAdapter, err error)

Types

type ConsumerAdapter

type ConsumerAdapter interface {
	// Dispatcher
	// bind consume callback for consumer adapter.
	Dispatcher(dispatcher func(task *base.Task, message *base.Message) (retry bool))

	// Processor
	// return processor instance of consumer adapter.
	Processor() process.Processor
}

ConsumerAdapter interface of consumer adapter.

func NewConsumer

func NewConsumer(a conf.Adapter, id, parallel int) (adapter ConsumerAdapter, err error)

NewConsumer create and return consumer adapter instance.

type ProducerAdapter

type ProducerAdapter interface {
	// Processor
	// return processor instance of producer adapter.
	Processor() process.Processor

	// Publish
	// send message for producer adapter.
	Publish(p *base.Payload) (messageId string, err error)
}

ProducerAdapter interface of producer adapter.

func NewProducer

func NewProducer(a conf.Adapter) (adapter ProducerAdapter, err error)

NewProducer create and return producer adapter instance.

type RemoterAdapter

type RemoterAdapter interface {
	Build(ctx context.Context, task *base.Task) (err error)
	BuildById(ctx context.Context, id int) (err error)
	Destroy(ctx context.Context, task *base.Task) (err error)
	DestroyById(ctx context.Context, id int) (err error)

	// Processor
	// return processor instance of producer adapter.
	Processor() process.Processor
}

RemoterAdapter interface of remoter adapter.

func NewRemoter

func NewRemoter(a conf.Adapter) (adapter RemoterAdapter, err error)

NewRemoter create and return remoter adapter instance.