mocks

Documentation

Index

• type Consumer
  • func (_m *Consumer) Consume(req http.Request, cb messaging.Callback) (int, error)
  • func (_m *Consumer) Pull(ctx context.Context, cb messaging.Callback) error
• type Publisher
  • func (_m *Publisher) Publish(ctx context.Context, data ...[]byte) error

Types

type Consumer

type Consumer struct {
	mock.Mock
}

func (*Consumer) Consume

func (_m *Consumer) Consume(req http.Request, cb messaging.Callback) (int, error)

func (*Consumer) Pull

func (_m *Consumer) Pull(ctx context.Context, cb messaging.Callback) error

type Publisher

type Publisher struct {
	mock.Mock
}

func (*Publisher) Publish

func (_m *Publisher) Publish(ctx context.Context, data ...[]byte) error