mocks

Documentation

Index

• type DocumentStoreMock
  • func (ds *DocumentStoreMock) GetDocument(ctx context.Context, ie interfaces.IncomingEventInterface) map[string]interface{}
• type SenderMock
  • func (s *SenderMock) SendEvent(ctx context.Context, ie interfaces.IncomingEventInterface, ...) error
• type StoreMock
  • func (s *StoreMock) DataKey(ctx context.Context, ie interfaces.IncomingEventInterface, ...) string
  • func (s *StoreMock) Enqueue(ctx context.Context, key string, value string, ttl time.Duration) (bool, error)
  • func (s *StoreMock) Get(ctx context.Context, key string) (string, bool, time.Duration, error)
  • func (s *StoreMock) GetQueue(ctx context.Context, key string) ([]string, bool, time.Duration, error)
  • func (s *StoreMock) Remove(ctx context.Context, key string) (bool, error)
  • func (s *StoreMock) Set(ctx context.Context, key string, value string, ttl time.Duration) (bool, error)
  • func (s *StoreMock) Update(ctx context.Context, key string, value string) (bool, error)
• type ThrottleMock
  • func (t *ThrottleMock) CanTrigger(ctx context.Context, id string, period time.Duration) (bool, time.Duration, error)

Types

type DocumentStoreMock

type DocumentStoreMock struct {
	mock.Mock
}

DocumentStoreMock - Mock of DocumentStoreInterface

func (*DocumentStoreMock) GetDocument

func (ds *DocumentStoreMock) GetDocument(ctx context.Context, ie interfaces.IncomingEventInterface) map[string]interface{}

Get - Get value from store, return with remaining time

type SenderMock

type SenderMock struct {
	mock.Mock
}

SenderMock - Mock of SenderInterface

func (*SenderMock) SendEvent

func (s *SenderMock) SendEvent(ctx context.Context, ie interfaces.IncomingEventInterface, id interfaces.DestinationInterface) error

SendEvent - Send an event

type StoreMock

type StoreMock struct {
	mock.Mock
}

StoreMock - Mock of StoreInterface

func (*StoreMock) DataKey

func (s *StoreMock) DataKey(ctx context.Context, ie interfaces.IncomingEventInterface, idest interfaces.DestinationInterface, prefix string, suffix string) string

DataKey - Generate DataKey with events and destination (Won't Mock)

func (*StoreMock) Enqueue

func (s *StoreMock) Enqueue(ctx context.Context, key string, value string, ttl time.Duration) (bool, error)

func (*StoreMock) Get

func (s *StoreMock) Get(ctx context.Context, key string) (string, bool, time.Duration, error)

Get - Get value from store, return with remaining time

func (*StoreMock) GetQueue

func (s *StoreMock) GetQueue(ctx context.Context, key string) ([]string, bool, time.Duration, error)

func (*StoreMock) Remove

func (s *StoreMock) Remove(ctx context.Context, key string) (bool, error)

Remove - Remove value for key

func (*StoreMock) Set

func (s *StoreMock) Set(ctx context.Context, key string, value string, ttl time.Duration) (bool, error)

Set - Set value into store with ttl

func (*StoreMock) Update

func (s *StoreMock) Update(ctx context.Context, key string, value string) (bool, error)

Update - Update value for key

type ThrottleMock

type ThrottleMock struct {
	mock.Mock
}

ThrottleMock - Mock ThrottleInterface

func (*ThrottleMock) CanTrigger

func (t *ThrottleMock) CanTrigger(ctx context.Context, id string, period time.Duration) (bool, time.Duration, error)