mock

Documentation

Index

• type Dispatcher
  • func (m *Dispatcher) Dispatch(ctx context.Context, e messenger.Envelope)
• type Envelope
  • func (m *Envelope) FirstHeader(name string) (string, bool)
  • func (m *Envelope) HasHeader(name string) bool
  • func (m *Envelope) Header(name string) []string
  • func (m *Envelope) Headers() map[string][]string
  • func (m *Envelope) Is(e messenger.Envelope) bool
  • func (m *Envelope) LastHeader(name string) (string, bool)
  • func (m *Envelope) Message() interface{}
• type Middleware
  • func (m *Middleware) Handle(ctx context.Context, b messenger.Dispatcher, e messenger.Envelope, ...)
• type Receiver
  • func (m *Receiver) Ack(ctx context.Context, e messenger.Envelope) error
  • func (m *Receiver) Nack(ctx context.Context, e messenger.Envelope) error
  • func (m *Receiver) Receive(ctx context.Context) (<-chan messenger.Envelope, error)
• type Sender
  • func (m *Sender) Send(ctx context.Context, e messenger.Envelope) error

Types

type Dispatcher

type Dispatcher struct {
	mock.Mock
}

func (*Dispatcher) Dispatch

func (m *Dispatcher) Dispatch(ctx context.Context, e messenger.Envelope)

type Envelope

type Envelope struct {
	mock.Mock
}

func (*Envelope) FirstHeader

func (m *Envelope) FirstHeader(name string) (string, bool)

func (*Envelope) HasHeader

func (m *Envelope) HasHeader(name string) bool

func (*Envelope) Header

func (m *Envelope) Header(name string) []string

func (*Envelope) Headers

func (m *Envelope) Headers() map[string][]string

func (*Envelope) Is

func (m *Envelope) Is(e messenger.Envelope) bool

func (*Envelope) LastHeader

func (m *Envelope) LastHeader(name string) (string, bool)

func (*Envelope) Message

func (m *Envelope) Message() interface{}

type Middleware

type Middleware struct {
	mock.Mock
}

func (*Middleware) Handle

func (m *Middleware) Handle(ctx context.Context, b messenger.Dispatcher, e messenger.Envelope, next messenger.NextFunc)

type Receiver

type Receiver struct {
	mock.Mock
}

func (*Receiver) Ack

func (m *Receiver) Ack(ctx context.Context, e messenger.Envelope) error

func (*Receiver) Nack

func (m *Receiver) Nack(ctx context.Context, e messenger.Envelope) error

func (*Receiver) Receive

func (m *Receiver) Receive(ctx context.Context) (<-chan messenger.Envelope, error)

type Sender

type Sender struct {
	mock.Mock
}

func (*Sender) Send

func (m *Sender) Send(ctx context.Context, e messenger.Envelope) error