mocks

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppRepository 

type AppRepository struct {
	mock.Mock
}

AppRepository is an autogenerated mock type for the AppRepository type

func (*AppRepository) CompleteAppInit 

func (_m *AppRepository) CompleteAppInit() error

CompleteAppInit provides a mock function with given fields:

func (*AppRepository) GetApp 

func (_m *AppRepository) GetApp() (*data.App, error)

GetApp provides a mock function with given fields:

func (*AppRepository) StartAppInit 

func (_m *AppRepository) StartAppInit(_a0 *config.SeedData) error

StartAppInit provides a mock function with given fields: _a0

type ChannelRepository 

type ChannelRepository struct {
	mock.Mock
}

ChannelRepository is an autogenerated mock type for the ChannelRepository type

func (*ChannelRepository) Get 

func (_m *ChannelRepository) Get(channelID string) (*data.Channel, error)

Get provides a mock function with given fields: channelID

func (*ChannelRepository) GetList 

func (_m *ChannelRepository) GetList(page *data.Pagination) ([]*data.Channel, *data.Pagination, error)

GetList provides a mock function with given fields: page

func (*ChannelRepository) Store 

func (_m *ChannelRepository) Store(channel *data.Channel) (*data.Channel, error)

Store provides a mock function with given fields: channel

type ConsumerRepository 

type ConsumerRepository struct {
	mock.Mock
}

ConsumerRepository is an autogenerated mock type for the ConsumerRepository type

func (*ConsumerRepository) Delete 

func (_m *ConsumerRepository) Delete(consumer *data.Consumer) error

Delete provides a mock function with given fields: consumer

func (*ConsumerRepository) Get 

func (_m *ConsumerRepository) Get(channelID string, consumerID string) (*data.Consumer, error)

Get provides a mock function with given fields: channelID, consumerID

func (*ConsumerRepository) GetByID 

func (_m *ConsumerRepository) GetByID(id string) (*data.Consumer, error)

GetByID provides a mock function with given fields: id

func (*ConsumerRepository) GetList 

func (_m *ConsumerRepository) GetList(channelID string, page *data.Pagination) ([]*data.Consumer, *data.Pagination, error)

GetList provides a mock function with given fields: channelID, page

func (*ConsumerRepository) Store 

func (_m *ConsumerRepository) Store(consumer *data.Consumer) (*data.Consumer, error)

Store provides a mock function with given fields: consumer

type DataAccessor 

type DataAccessor struct {
	mock.Mock
}

DataAccessor is an autogenerated mock type for the DataAccessor type

func (*DataAccessor) Close 

func (_m *DataAccessor) Close()

Close provides a mock function with given fields:

func (*DataAccessor) GetAppRepository 

func (_m *DataAccessor) GetAppRepository() storage.AppRepository

GetAppRepository provides a mock function with given fields:

func (*DataAccessor) GetChannelRepository 

func (_m *DataAccessor) GetChannelRepository() storage.ChannelRepository

GetChannelRepository provides a mock function with given fields:

func (*DataAccessor) GetConsumerRepository 

func (_m *DataAccessor) GetConsumerRepository() storage.ConsumerRepository

GetConsumerRepository provides a mock function with given fields:

func (*DataAccessor) GetDeliveryJobRepository 

func (_m *DataAccessor) GetDeliveryJobRepository() storage.DeliveryJobRepository

GetDeliveryJobRepository provides a mock function with given fields:

func (*DataAccessor) GetLockRepository 

func (_m *DataAccessor) GetLockRepository() storage.LockRepository

GetLockRepository provides a mock function with given fields:

func (*DataAccessor) GetMessageRepository 

func (_m *DataAccessor) GetMessageRepository() storage.MessageRepository

GetMessageRepository provides a mock function with given fields:

func (*DataAccessor) GetProducerRepository 

func (_m *DataAccessor) GetProducerRepository() storage.ProducerRepository

GetProducerRepository provides a mock function with given fields:

type DeliveryJobRepository 

type DeliveryJobRepository struct {
	mock.Mock
}

DeliveryJobRepository is an autogenerated mock type for the DeliveryJobRepository type

func (*DeliveryJobRepository) DispatchMessage 

func (_m *DeliveryJobRepository) DispatchMessage(message *data.Message, deliveryJobs ...*data.DeliveryJob) error

DispatchMessage provides a mock function with given fields: message, deliveryJobs

func (*DeliveryJobRepository) GetByID 

func (_m *DeliveryJobRepository) GetByID(id string) (*data.DeliveryJob, error)

GetByID provides a mock function with given fields: id

func (*DeliveryJobRepository) GetJobsForConsumer 

func (_m *DeliveryJobRepository) GetJobsForConsumer(consumer *data.Consumer, jobStatus data.JobStatus, page *data.Pagination) ([]*data.DeliveryJob, *data.Pagination, error)

GetJobsForConsumer provides a mock function with given fields: consumer, jobStatus, page

func (*DeliveryJobRepository) GetJobsForMessage 

func (_m *DeliveryJobRepository) GetJobsForMessage(message *data.Message, page *data.Pagination) ([]*data.DeliveryJob, *data.Pagination, error)

GetJobsForMessage provides a mock function with given fields: message, page

func (*DeliveryJobRepository) GetJobsInflightSince 

func (_m *DeliveryJobRepository) GetJobsInflightSince(delta time.Duration) []*data.DeliveryJob

GetJobsInflightSince provides a mock function with given fields: delta

func (*DeliveryJobRepository) GetJobsReadyForInflightSince 

func (_m *DeliveryJobRepository) GetJobsReadyForInflightSince(delta time.Duration) []*data.DeliveryJob

GetJobsReadyForInflightSince provides a mock function with given fields: delta

func (*DeliveryJobRepository) MarkJobDead 

func (_m *DeliveryJobRepository) MarkJobDead(deliveryJob *data.DeliveryJob) error

MarkJobDead provides a mock function with given fields: deliveryJob

func (*DeliveryJobRepository) MarkJobDelivered 

func (_m *DeliveryJobRepository) MarkJobDelivered(deliveryJob *data.DeliveryJob) error

MarkJobDelivered provides a mock function with given fields: deliveryJob

func (*DeliveryJobRepository) MarkJobInflight 

func (_m *DeliveryJobRepository) MarkJobInflight(deliveryJob *data.DeliveryJob) error

MarkJobInflight provides a mock function with given fields: deliveryJob

func (*DeliveryJobRepository) MarkJobRetry 

func (_m *DeliveryJobRepository) MarkJobRetry(deliveryJob *data.DeliveryJob, earliestDelta time.Duration) error

MarkJobRetry provides a mock function with given fields: deliveryJob, earliestDelta

func (*DeliveryJobRepository) RequeueDeadJobsForConsumer 

func (_m *DeliveryJobRepository) RequeueDeadJobsForConsumer(consumer *data.Consumer) error

RequeueDeadJobsForConsumer provides a mock function with given fields: consumer

type LockRepository 

type LockRepository struct {
	mock.Mock
}

LockRepository is an autogenerated mock type for the LockRepository type

func (*LockRepository) ReleaseLock 

func (_m *LockRepository) ReleaseLock(lock *data.Lock) error

ReleaseLock provides a mock function with given fields: lock

func (*LockRepository) TimeoutLocks 

func (_m *LockRepository) TimeoutLocks(threshold time.Duration) error

TimeoutLocks provides a mock function with given fields: threshold

func (*LockRepository) TryLock 

func (_m *LockRepository) TryLock(lock *data.Lock) error

TryLock provides a mock function with given fields: lock

type Lockable 

type Lockable struct {
	mock.Mock
}

Lockable is an autogenerated mock type for the Lockable type

func (*Lockable) GetLockID 

func (_m *Lockable) GetLockID() string

GetLockID provides a mock function with given fields:

type MessageRepository 

type MessageRepository struct {
	mock.Mock
}

MessageRepository is an autogenerated mock type for the MessageRepository type

func (*MessageRepository) Create 

func (_m *MessageRepository) Create(message *data.Message) error

Create provides a mock function with given fields: message

func (*MessageRepository) Get 

func (_m *MessageRepository) Get(channelID string, messageID string) (*data.Message, error)

Get provides a mock function with given fields: channelID, messageID

func (*MessageRepository) GetByID 

func (_m *MessageRepository) GetByID(id string) (*data.Message, error)

GetByID provides a mock function with given fields: id

func (*MessageRepository) GetMessagesForChannel 

func (_m *MessageRepository) GetMessagesForChannel(channelID string, page *data.Pagination) ([]*data.Message, *data.Pagination, error)

GetMessagesForChannel provides a mock function with given fields: channelID, page

func (*MessageRepository) GetMessagesNotDispatchedForCertainPeriod 

func (_m *MessageRepository) GetMessagesNotDispatchedForCertainPeriod(delta time.Duration) []*data.Message

GetMessagesNotDispatchedForCertainPeriod provides a mock function with given fields: delta

func (*MessageRepository) SetDispatched 

func (_m *MessageRepository) SetDispatched(txContext context.Context, message *data.Message) error

SetDispatched provides a mock function with given fields: txContext, message

type Paginateable 

type Paginateable struct {
	mock.Mock
}

Paginateable is an autogenerated mock type for the Paginateable type

func (*Paginateable) GetCursor 

func (_m *Paginateable) GetCursor() (*data.Cursor, error)

GetCursor provides a mock function with given fields:

type ProducerRepository 

type ProducerRepository struct {
	mock.Mock
}

ProducerRepository is an autogenerated mock type for the ProducerRepository type

func (*ProducerRepository) Get 

func (_m *ProducerRepository) Get(producerID string) (*data.Producer, error)

Get provides a mock function with given fields: producerID

func (*ProducerRepository) GetList 

func (_m *ProducerRepository) GetList(page *data.Pagination) ([]*data.Producer, *data.Pagination, error)

GetList provides a mock function with given fields: page

func (*ProducerRepository) Store 

func (_m *ProducerRepository) Store(producer *data.Producer) (*data.Producer, error)

Store provides a mock function with given fields: producer

type Updateable 

type Updateable struct {
	mock.Mock
}

Updateable is an autogenerated mock type for the Updateable type

func (*Updateable) GetLastUpdatedHTTPTimeString 

func (_m *Updateable) GetLastUpdatedHTTPTimeString() string

GetLastUpdatedHTTPTimeString provides a mock function with given fields:

type ValidateableModel 

type ValidateableModel struct {
	mock.Mock
}

ValidateableModel is an autogenerated mock type for the ValidateableModel type

func (*ValidateableModel) IsInValidState 

func (_m *ValidateableModel) IsInValidState() bool

IsInValidState provides a mock function with given fields:

func (*ValidateableModel) QuickFix 

func (_m *ValidateableModel) QuickFix() bool

QuickFix provides a mock function with given fields:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.