mock

Documentation

Index

• func NewBrokerMockError() rabbitmq.BrokerInterface
• func NewBrokerMockOk() rabbitmq.BrokerInterface
• func NewMockRedis() *redismock.ClientMock
• type BrokerInterface
  • func (_m *BrokerInterface) Publish(_a0 string, _a1 proto.Message, _a2 amqp.Table) error
  • func (_m *BrokerInterface) RegisterSubscriber(_a0 string, _a1 interface{}) error
  • func (_m *BrokerInterface) SetExchangeName(_a0 string)
  • func (_m *BrokerInterface) SetQueueOptsArgs(args amqp.Table)
  • func (_m *BrokerInterface) Subscribe(_a0 chan bool) error
• type BrokerMockError
  • func (b *BrokerMockError) Publish(_ string, _ proto.Message, _ amqp.Table) error
  • func (b *BrokerMockError) PublishJson(string, interface{}, amqp.Table, int64) error
  • func (b *BrokerMockError) PublishProto(_ string, _ proto.Message, _ amqp.Table, _ int64) error
  • func (b *BrokerMockError) RegisterSubscriber(topic string, fn interface{}) error
  • func (b *BrokerMockError) SetExchangeName(name string)
  • func (b *BrokerMockError) SetQueueOptsArgs(args amqp.Table)
  • func (b *BrokerMockError) Subscribe(exit chan bool) error
• type BrokerMockOk
  • func (b *BrokerMockOk) Publish(topic string, msg proto.Message, h amqp.Table) error
  • func (b *BrokerMockOk) PublishJson(_ string, _ interface{}, _ amqp.Table, _ int64) error
  • func (b *BrokerMockOk) PublishProto(string, proto.Message, amqp.Table, int64) error
  • func (b *BrokerMockOk) RegisterSubscriber(topic string, fn interface{}) error
  • func (b *BrokerMockOk) SetExchangeName(name string)
  • func (b *BrokerMockOk) SetQueueOptsArgs(args amqp.Table)
  • func (b *BrokerMockOk) Subscribe(exit chan bool) error
• type CentrifugoInterface
  • func (_m *CentrifugoInterface) Publish(_a0 context.Context, _a1 string, _a2 interface{}) error
  • func (_m *CentrifugoInterface) SendToAdminCentrifugo(channel string, order *billingpb.Order, message string) error
  • func (_m *CentrifugoInterface) SendToMerchantTestingCentrifugo(channel string, order *billingpb.Order, testCase string, ...) error
  • func (_m *CentrifugoInterface) SendToUserCentrifugo(channel string, order *billingpb.Order) error
• type HttpSender
  • func (_m *HttpSender) Send(url string, req interface{}, action string, secretKey string) (*common.Request, *http.Response, error)
• type SlackSenderInterface
  • func (_m *SlackSenderInterface) SendMessage(_a0 *slack.Message) error

Functions

func NewBrokerMockError

func NewBrokerMockError() rabbitmq.BrokerInterface

func NewBrokerMockOk

func NewBrokerMockOk() rabbitmq.BrokerInterface

func NewMockRedis

func NewMockRedis() *redismock.ClientMock

Types

type BrokerInterface

type BrokerInterface struct {
	mock.Mock
}

BrokerInterface is an autogenerated mock type for the BrokerInterface type

func (*BrokerInterface) Publish

func (_m *BrokerInterface) Publish(_a0 string, _a1 proto.Message, _a2 amqp.Table) error

Publish provides a mock function with given fields: _a0, _a1, _a2

func (*BrokerInterface) RegisterSubscriber

func (_m *BrokerInterface) RegisterSubscriber(_a0 string, _a1 interface{}) error

RegisterSubscriber provides a mock function with given fields: _a0, _a1

func (*BrokerInterface) SetExchangeName

func (_m *BrokerInterface) SetExchangeName(_a0 string)

SetExchangeName provides a mock function with given fields: _a0

func (*BrokerInterface) SetQueueOptsArgs

func (_m *BrokerInterface) SetQueueOptsArgs(args amqp.Table)

SetQueueOptsArgs provides a mock function with given fields: args

func (*BrokerInterface) Subscribe

func (_m *BrokerInterface) Subscribe(_a0 chan bool) error

Subscribe provides a mock function with given fields: _a0

type BrokerMockError

type BrokerMockError struct{}

func (*BrokerMockError) Publish

func (b *BrokerMockError) Publish(_ string, _ proto.Message, _ amqp.Table) error

func (*BrokerMockError) PublishJson

func (b *BrokerMockError) PublishJson(string, interface{}, amqp.Table, int64) error

func (*BrokerMockError) PublishProto

func (b *BrokerMockError) PublishProto(_ string, _ proto.Message, _ amqp.Table, _ int64) error

func (*BrokerMockError) RegisterSubscriber

func (b *BrokerMockError) RegisterSubscriber(topic string, fn interface{}) error

func (*BrokerMockError) SetExchangeName

func (b *BrokerMockError) SetExchangeName(name string)

func (*BrokerMockError) SetQueueOptsArgs

func (b *BrokerMockError) SetQueueOptsArgs(args amqp.Table)

func (*BrokerMockError) Subscribe

func (b *BrokerMockError) Subscribe(exit chan bool) error

type BrokerMockOk

type BrokerMockOk struct{}

func (*BrokerMockOk) Publish

func (b *BrokerMockOk) Publish(topic string, msg proto.Message, h amqp.Table) error

func (*BrokerMockOk) PublishJson

func (b *BrokerMockOk) PublishJson(_ string, _ interface{}, _ amqp.Table, _ int64) error

func (*BrokerMockOk) PublishProto

func (b *BrokerMockOk) PublishProto(string, proto.Message, amqp.Table, int64) error

func (*BrokerMockOk) RegisterSubscriber

func (b *BrokerMockOk) RegisterSubscriber(topic string, fn interface{}) error

func (*BrokerMockOk) SetExchangeName

func (b *BrokerMockOk) SetExchangeName(name string)

func (*BrokerMockOk) SetQueueOptsArgs

func (b *BrokerMockOk) SetQueueOptsArgs(args amqp.Table)

func (*BrokerMockOk) Subscribe

func (b *BrokerMockOk) Subscribe(exit chan bool) error

type CentrifugoInterface

type CentrifugoInterface struct {
	mock.Mock
}

CentrifugoInterface is an autogenerated mock type for the CentrifugoInterface type

func (*CentrifugoInterface) Publish

func (_m *CentrifugoInterface) Publish(_a0 context.Context, _a1 string, _a2 interface{}) error

Publish provides a mock function with given fields: _a0, _a1, _a2

func (*CentrifugoInterface) SendToAdminCentrifugo

func (_m *CentrifugoInterface) SendToAdminCentrifugo(channel string, order *billingpb.Order, message string) error

SendToAdminCentrifugo provides a mock function with given fields: channel, order, message

func (*CentrifugoInterface) SendToMerchantTestingCentrifugo

func (_m *CentrifugoInterface) SendToMerchantTestingCentrifugo(channel string, order *billingpb.Order, testCase string, request *common.Request, response *http.Response) error

SendToMerchantTestingCentrifugo provides a mock function with given fields: channel, order, testCase, request, response

func (*CentrifugoInterface) SendToUserCentrifugo

func (_m *CentrifugoInterface) SendToUserCentrifugo(channel string, order *billingpb.Order) error

SendToUserCentrifugo provides a mock function with given fields: channel, order

type HttpSender

type HttpSender struct {
	mock.Mock
}

HttpSender is an autogenerated mock type for the HttpSender type

func (*HttpSender) Send

func (_m *HttpSender) Send(url string, req interface{}, action string, secretKey string) (*common.Request, *http.Response, error)

Send provides a mock function with given fields: url, req, action, secretKey

type SlackSenderInterface

type SlackSenderInterface struct {
	mock.Mock
}

SlackSenderInterface is an autogenerated mock type for the SlackSenderInterface type

func (*SlackSenderInterface) SendMessage

func (_m *SlackSenderInterface) SendMessage(_a0 *slack.Message) error

SendMessage provides a mock function with given fields: _a0