mocks

Documentation

Index

• type MockDal
  • func (m *MockDal) DeleteDeadLetterItems(dead []*entities.DeadLetterItem) error
  • func (m *MockDal) DeleteRegistration(registration *entities.Registration) error
  • func (m *MockDal) GetDeadLetterItemsReadyForRetry() ([]*entities.DeadLetterItem, error)
  • func (m *MockDal) GetRegistrationByEventAndCallback(event string, callback_url string) (*entities.Registration, error)
  • func (m *MockDal) GetRegistrationsByEvent(event string) ([]*entities.Registration, error)
  • func (m *MockDal) UpsertDeadLetterItem(dead *entities.DeadLetterItem) error
  • func (m *MockDal) UpsertEventStore(event *entities.EventStoreItem) error
  • func (m *MockDal) UpsertRegistration(registration *entities.Registration) error
• type MockEventDispatcher
  • func (m *MockEventDispatcher) DispatchEvent(event *entities.Event, endpoint string) (int, error)
• type MockQueue
  • func (m *MockQueue) Add(event_name string, payload string) error
  • func (m *MockQueue) AddEvent(event *entities.Event, callback string) error
  • func (m *MockQueue) StartConsuming(size int, poll_interval time.Duration, callback func(callbackItem interface{}))
• type MockStatsD
  • func (m *MockStatsD) Increment(label string)
• type MockWorker
  • func (m *MockWorker) HandleItem(item interface{}) error

Types

type MockDal

type MockDal struct {
	mock.Mock
	UpsertObject     *entities.Registration
	DeleteObject     *entities.Registration
	UpsertDeadLetter *entities.DeadLetterItem
}

func (*MockDal) DeleteDeadLetterItems

func (m *MockDal) DeleteDeadLetterItems(dead []*entities.DeadLetterItem) error

func (*MockDal) DeleteRegistration

func (m *MockDal) DeleteRegistration(registration *entities.Registration) error

func (*MockDal) GetDeadLetterItemsReadyForRetry

func (m *MockDal) GetDeadLetterItemsReadyForRetry() ([]*entities.DeadLetterItem, error)

func (*MockDal) GetRegistrationByEventAndCallback

func (m *MockDal) GetRegistrationByEventAndCallback(event string, callback_url string) (*entities.Registration, error)

func (*MockDal) GetRegistrationsByEvent

func (m *MockDal) GetRegistrationsByEvent(event string) ([]*entities.Registration, error)

func (*MockDal) UpsertDeadLetterItem

func (m *MockDal) UpsertDeadLetterItem(dead *entities.DeadLetterItem) error

func (*MockDal) UpsertEventStore

func (m *MockDal) UpsertEventStore(event *entities.EventStoreItem) error

func (*MockDal) UpsertRegistration

func (m *MockDal) UpsertRegistration(registration *entities.Registration) error

type MockEventDispatcher

type MockEventDispatcher struct {
	mock.Mock
}

func (*MockEventDispatcher) DispatchEvent

func (m *MockEventDispatcher) DispatchEvent(event *entities.Event, endpoint string) (int, error)

type MockQueue

type MockQueue struct {
	mock.Mock
	ConsumerCallback func(callbackItem interface{})
}

func (*MockQueue) Add

func (m *MockQueue) Add(event_name string, payload string) error

func (*MockQueue) AddEvent

func (m *MockQueue) AddEvent(event *entities.Event, callback string) error

func (*MockQueue) StartConsuming

func (m *MockQueue) StartConsuming(size int, poll_interval time.Duration, callback func(callbackItem interface{}))

type MockStatsD

type MockStatsD struct {
	mock.Mock
}

func (*MockStatsD) Increment

func (m *MockStatsD) Increment(label string)

type MockWorker

type MockWorker struct {
	mock.Mock
}

func (*MockWorker) HandleItem

func (m *MockWorker) HandleItem(item interface{}) error