redirected

Documentation

Index

• type QueueAdapter
  • func NewQueueAdapter(config config.Config, resolver Resolver) *QueueAdapter
  • func (a *QueueAdapter) ListenWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)
  • func (a *QueueAdapter) QueueWithOpts(service *types.Service, request types.Request, opts types.Options) (string, error)
• type Resolver

Types

type QueueAdapter

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

QueueAdapter -

func NewQueueAdapter

func NewQueueAdapter(config config.Config, resolver Resolver) *QueueAdapter

NewQueueAdapter -

func (*QueueAdapter) ListenWithOpts

func (a *QueueAdapter) ListenWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)

ListenWithOpts -

func (*QueueAdapter) QueueWithOpts

func (a *QueueAdapter) QueueWithOpts(service *types.Service, request types.Request, opts types.Options) (string, error)

QueueWithOpts -

type Resolver

type Resolver interface {
	Resolve(resolver config.Resolver) (*types.Response, error)
}

Resolver is an interface for a type which takes a resolver config and returns a response