Documentation
¶
Index ¶
- type DeliveryAttemptRepository
- func (_m *DeliveryAttemptRepository) Find(ctx context.Context, id string) (*hammer.DeliveryAttempt, error)
- func (_m *DeliveryAttemptRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.DeliveryAttempt, error)
- func (_m *DeliveryAttemptRepository) Store(ctx context.Context, deliveryAttempt *hammer.DeliveryAttempt) error
- type DeliveryAttemptService
- type DeliveryRepository
- func (_m *DeliveryRepository) Dispatch(ctx context.Context) (*hammer.DeliveryAttempt, error)
- func (_m *DeliveryRepository) Find(ctx context.Context, id string) (*hammer.Delivery, error)
- func (_m *DeliveryRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Delivery, error)
- func (_m *DeliveryRepository) Store(ctx context.Context, delivery *hammer.Delivery) error
- type DeliveryService
- type HammerClient
- func (_m *HammerClient) CreateMessage(ctx context.Context, in *api.CreateMessageRequest, opts ...grpc.CallOption) (*api.Message, error)
- func (_m *HammerClient) CreateSubscription(ctx context.Context, in *api.CreateSubscriptionRequest, ...) (*api.Subscription, error)
- func (_m *HammerClient) CreateTopic(ctx context.Context, in *api.CreateTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
- func (_m *HammerClient) DeleteMessage(ctx context.Context, in *api.DeleteMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (_m *HammerClient) DeleteSubscription(ctx context.Context, in *api.DeleteSubscriptionRequest, ...) (*emptypb.Empty, error)
- func (_m *HammerClient) DeleteTopic(ctx context.Context, in *api.DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (_m *HammerClient) GetDelivery(ctx context.Context, in *api.GetDeliveryRequest, opts ...grpc.CallOption) (*api.Delivery, error)
- func (_m *HammerClient) GetDeliveryAttempt(ctx context.Context, in *api.GetDeliveryAttemptRequest, ...) (*api.DeliveryAttempt, error)
- func (_m *HammerClient) GetMessage(ctx context.Context, in *api.GetMessageRequest, opts ...grpc.CallOption) (*api.Message, error)
- func (_m *HammerClient) GetSubscription(ctx context.Context, in *api.GetSubscriptionRequest, opts ...grpc.CallOption) (*api.Subscription, error)
- func (_m *HammerClient) GetTopic(ctx context.Context, in *api.GetTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
- func (_m *HammerClient) ListDeliveries(ctx context.Context, in *api.ListDeliveriesRequest, opts ...grpc.CallOption) (*api.ListDeliveriesResponse, error)
- func (_m *HammerClient) ListDeliveryAttempts(ctx context.Context, in *api.ListDeliveryAttemptsRequest, ...) (*api.ListDeliveryAttemptsResponse, error)
- func (_m *HammerClient) ListMessages(ctx context.Context, in *api.ListMessagesRequest, opts ...grpc.CallOption) (*api.ListMessagesResponse, error)
- func (_m *HammerClient) ListSubscriptions(ctx context.Context, in *api.ListSubscriptionsRequest, opts ...grpc.CallOption) (*api.ListSubscriptionsResponse, error)
- func (_m *HammerClient) ListTopics(ctx context.Context, in *api.ListTopicsRequest, opts ...grpc.CallOption) (*api.ListTopicsResponse, error)
- func (_m *HammerClient) UpdateSubscription(ctx context.Context, in *api.UpdateSubscriptionRequest, ...) (*api.Subscription, error)
- func (_m *HammerClient) UpdateTopic(ctx context.Context, in *api.UpdateTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
- type HammerServer
- func (_m *HammerServer) CreateMessage(_a0 context.Context, _a1 *api.CreateMessageRequest) (*api.Message, error)
- func (_m *HammerServer) CreateSubscription(_a0 context.Context, _a1 *api.CreateSubscriptionRequest) (*api.Subscription, error)
- func (_m *HammerServer) CreateTopic(_a0 context.Context, _a1 *api.CreateTopicRequest) (*api.Topic, error)
- func (_m *HammerServer) DeleteMessage(_a0 context.Context, _a1 *api.DeleteMessageRequest) (*emptypb.Empty, error)
- func (_m *HammerServer) DeleteSubscription(_a0 context.Context, _a1 *api.DeleteSubscriptionRequest) (*emptypb.Empty, error)
- func (_m *HammerServer) DeleteTopic(_a0 context.Context, _a1 *api.DeleteTopicRequest) (*emptypb.Empty, error)
- func (_m *HammerServer) GetDelivery(_a0 context.Context, _a1 *api.GetDeliveryRequest) (*api.Delivery, error)
- func (_m *HammerServer) GetDeliveryAttempt(_a0 context.Context, _a1 *api.GetDeliveryAttemptRequest) (*api.DeliveryAttempt, error)
- func (_m *HammerServer) GetMessage(_a0 context.Context, _a1 *api.GetMessageRequest) (*api.Message, error)
- func (_m *HammerServer) GetSubscription(_a0 context.Context, _a1 *api.GetSubscriptionRequest) (*api.Subscription, error)
- func (_m *HammerServer) GetTopic(_a0 context.Context, _a1 *api.GetTopicRequest) (*api.Topic, error)
- func (_m *HammerServer) ListDeliveries(_a0 context.Context, _a1 *api.ListDeliveriesRequest) (*api.ListDeliveriesResponse, error)
- func (_m *HammerServer) ListDeliveryAttempts(_a0 context.Context, _a1 *api.ListDeliveryAttemptsRequest) (*api.ListDeliveryAttemptsResponse, error)
- func (_m *HammerServer) ListMessages(_a0 context.Context, _a1 *api.ListMessagesRequest) (*api.ListMessagesResponse, error)
- func (_m *HammerServer) ListSubscriptions(_a0 context.Context, _a1 *api.ListSubscriptionsRequest) (*api.ListSubscriptionsResponse, error)
- func (_m *HammerServer) ListTopics(_a0 context.Context, _a1 *api.ListTopicsRequest) (*api.ListTopicsResponse, error)
- func (_m *HammerServer) UpdateSubscription(_a0 context.Context, _a1 *api.UpdateSubscriptionRequest) (*api.Subscription, error)
- func (_m *HammerServer) UpdateTopic(_a0 context.Context, _a1 *api.UpdateTopicRequest) (*api.Topic, error)
- type MessageRepository
- func (_m *MessageRepository) Delete(ctx context.Context, id string) error
- func (_m *MessageRepository) Find(ctx context.Context, id string) (*hammer.Message, error)
- func (_m *MessageRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)
- func (_m *MessageRepository) Store(ctx context.Context, message *hammer.Message) error
- type MessageService
- func (_m *MessageService) Create(ctx context.Context, message *hammer.Message) error
- func (_m *MessageService) Delete(ctx context.Context, id string) error
- func (_m *MessageService) Find(ctx context.Context, id string) (*hammer.Message, error)
- func (_m *MessageService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)
- type MigrationRepository
- type MigrationService
- type SubscriptionRepository
- func (_m *SubscriptionRepository) Delete(ctx context.Context, id string) error
- func (_m *SubscriptionRepository) Find(ctx context.Context, id string) (*hammer.Subscription, error)
- func (_m *SubscriptionRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
- func (_m *SubscriptionRepository) Store(ctx context.Context, subscription *hammer.Subscription) error
- type SubscriptionService
- func (_m *SubscriptionService) Create(ctx context.Context, subscription *hammer.Subscription) error
- func (_m *SubscriptionService) Delete(ctx context.Context, id string) error
- func (_m *SubscriptionService) Find(ctx context.Context, id string) (*hammer.Subscription, error)
- func (_m *SubscriptionService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
- func (_m *SubscriptionService) Update(ctx context.Context, subscription *hammer.Subscription) error
- type TopicRepository
- func (_m *TopicRepository) Delete(ctx context.Context, id string) error
- func (_m *TopicRepository) Find(ctx context.Context, id string) (*hammer.Topic, error)
- func (_m *TopicRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)
- func (_m *TopicRepository) Store(ctx context.Context, topic *hammer.Topic) error
- type TopicService
- func (_m *TopicService) Create(ctx context.Context, topic *hammer.Topic) error
- func (_m *TopicService) Delete(ctx context.Context, id string) error
- func (_m *TopicService) Find(ctx context.Context, id string) (*hammer.Topic, error)
- func (_m *TopicService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)
- func (_m *TopicService) Update(ctx context.Context, topic *hammer.Topic) error
- type WorkerService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeliveryAttemptRepository ¶
DeliveryAttemptRepository is an autogenerated mock type for the DeliveryAttemptRepository type
func (*DeliveryAttemptRepository) Find ¶
func (_m *DeliveryAttemptRepository) Find(ctx context.Context, id string) (*hammer.DeliveryAttempt, error)
Find provides a mock function with given fields: ctx, id
func (*DeliveryAttemptRepository) FindAll ¶
func (_m *DeliveryAttemptRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.DeliveryAttempt, error)
FindAll provides a mock function with given fields: ctx, findOptions
func (*DeliveryAttemptRepository) Store ¶
func (_m *DeliveryAttemptRepository) Store(ctx context.Context, deliveryAttempt *hammer.DeliveryAttempt) error
Store provides a mock function with given fields: ctx, deliveryAttempt
type DeliveryAttemptService ¶
DeliveryAttemptService is an autogenerated mock type for the DeliveryAttemptService type
func (*DeliveryAttemptService) Find ¶
func (_m *DeliveryAttemptService) Find(ctx context.Context, id string) (*hammer.DeliveryAttempt, error)
Find provides a mock function with given fields: ctx, id
func (*DeliveryAttemptService) FindAll ¶
func (_m *DeliveryAttemptService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.DeliveryAttempt, error)
FindAll provides a mock function with given fields: ctx, findOptions
type DeliveryRepository ¶
DeliveryRepository is an autogenerated mock type for the DeliveryRepository type
func (*DeliveryRepository) Dispatch ¶ added in v0.6.0
func (_m *DeliveryRepository) Dispatch(ctx context.Context) (*hammer.DeliveryAttempt, error)
Dispatch provides a mock function with given fields: ctx
func (*DeliveryRepository) FindAll ¶
func (_m *DeliveryRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Delivery, error)
FindAll provides a mock function with given fields: ctx, findOptions
type DeliveryService ¶
DeliveryService is an autogenerated mock type for the DeliveryService type
func (*DeliveryService) FindAll ¶
func (_m *DeliveryService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Delivery, error)
FindAll provides a mock function with given fields: ctx, findOptions
type HammerClient ¶ added in v0.6.0
HammerClient is an autogenerated mock type for the HammerClient type
func (*HammerClient) CreateMessage ¶ added in v0.6.0
func (_m *HammerClient) CreateMessage(ctx context.Context, in *api.CreateMessageRequest, opts ...grpc.CallOption) (*api.Message, error)
CreateMessage provides a mock function with given fields: ctx, in, opts
func (*HammerClient) CreateSubscription ¶ added in v0.6.0
func (_m *HammerClient) CreateSubscription(ctx context.Context, in *api.CreateSubscriptionRequest, opts ...grpc.CallOption) (*api.Subscription, error)
CreateSubscription provides a mock function with given fields: ctx, in, opts
func (*HammerClient) CreateTopic ¶ added in v0.6.0
func (_m *HammerClient) CreateTopic(ctx context.Context, in *api.CreateTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
CreateTopic provides a mock function with given fields: ctx, in, opts
func (*HammerClient) DeleteMessage ¶ added in v0.6.0
func (_m *HammerClient) DeleteMessage(ctx context.Context, in *api.DeleteMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteMessage provides a mock function with given fields: ctx, in, opts
func (*HammerClient) DeleteSubscription ¶ added in v0.6.0
func (_m *HammerClient) DeleteSubscription(ctx context.Context, in *api.DeleteSubscriptionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteSubscription provides a mock function with given fields: ctx, in, opts
func (*HammerClient) DeleteTopic ¶ added in v0.6.0
func (_m *HammerClient) DeleteTopic(ctx context.Context, in *api.DeleteTopicRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteTopic provides a mock function with given fields: ctx, in, opts
func (*HammerClient) GetDelivery ¶ added in v0.6.0
func (_m *HammerClient) GetDelivery(ctx context.Context, in *api.GetDeliveryRequest, opts ...grpc.CallOption) (*api.Delivery, error)
GetDelivery provides a mock function with given fields: ctx, in, opts
func (*HammerClient) GetDeliveryAttempt ¶ added in v0.6.0
func (_m *HammerClient) GetDeliveryAttempt(ctx context.Context, in *api.GetDeliveryAttemptRequest, opts ...grpc.CallOption) (*api.DeliveryAttempt, error)
GetDeliveryAttempt provides a mock function with given fields: ctx, in, opts
func (*HammerClient) GetMessage ¶ added in v0.6.0
func (_m *HammerClient) GetMessage(ctx context.Context, in *api.GetMessageRequest, opts ...grpc.CallOption) (*api.Message, error)
GetMessage provides a mock function with given fields: ctx, in, opts
func (*HammerClient) GetSubscription ¶ added in v0.6.0
func (_m *HammerClient) GetSubscription(ctx context.Context, in *api.GetSubscriptionRequest, opts ...grpc.CallOption) (*api.Subscription, error)
GetSubscription provides a mock function with given fields: ctx, in, opts
func (*HammerClient) GetTopic ¶ added in v0.6.0
func (_m *HammerClient) GetTopic(ctx context.Context, in *api.GetTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
GetTopic provides a mock function with given fields: ctx, in, opts
func (*HammerClient) ListDeliveries ¶ added in v0.6.0
func (_m *HammerClient) ListDeliveries(ctx context.Context, in *api.ListDeliveriesRequest, opts ...grpc.CallOption) (*api.ListDeliveriesResponse, error)
ListDeliveries provides a mock function with given fields: ctx, in, opts
func (*HammerClient) ListDeliveryAttempts ¶ added in v0.6.0
func (_m *HammerClient) ListDeliveryAttempts(ctx context.Context, in *api.ListDeliveryAttemptsRequest, opts ...grpc.CallOption) (*api.ListDeliveryAttemptsResponse, error)
ListDeliveryAttempts provides a mock function with given fields: ctx, in, opts
func (*HammerClient) ListMessages ¶ added in v0.6.0
func (_m *HammerClient) ListMessages(ctx context.Context, in *api.ListMessagesRequest, opts ...grpc.CallOption) (*api.ListMessagesResponse, error)
ListMessages provides a mock function with given fields: ctx, in, opts
func (*HammerClient) ListSubscriptions ¶ added in v0.6.0
func (_m *HammerClient) ListSubscriptions(ctx context.Context, in *api.ListSubscriptionsRequest, opts ...grpc.CallOption) (*api.ListSubscriptionsResponse, error)
ListSubscriptions provides a mock function with given fields: ctx, in, opts
func (*HammerClient) ListTopics ¶ added in v0.6.0
func (_m *HammerClient) ListTopics(ctx context.Context, in *api.ListTopicsRequest, opts ...grpc.CallOption) (*api.ListTopicsResponse, error)
ListTopics provides a mock function with given fields: ctx, in, opts
func (*HammerClient) UpdateSubscription ¶ added in v0.6.0
func (_m *HammerClient) UpdateSubscription(ctx context.Context, in *api.UpdateSubscriptionRequest, opts ...grpc.CallOption) (*api.Subscription, error)
UpdateSubscription provides a mock function with given fields: ctx, in, opts
func (*HammerClient) UpdateTopic ¶ added in v0.6.0
func (_m *HammerClient) UpdateTopic(ctx context.Context, in *api.UpdateTopicRequest, opts ...grpc.CallOption) (*api.Topic, error)
UpdateTopic provides a mock function with given fields: ctx, in, opts
type HammerServer ¶ added in v0.6.0
HammerServer is an autogenerated mock type for the HammerServer type
func (*HammerServer) CreateMessage ¶ added in v0.6.0
func (_m *HammerServer) CreateMessage(_a0 context.Context, _a1 *api.CreateMessageRequest) (*api.Message, error)
CreateMessage provides a mock function with given fields: _a0, _a1
func (*HammerServer) CreateSubscription ¶ added in v0.6.0
func (_m *HammerServer) CreateSubscription(_a0 context.Context, _a1 *api.CreateSubscriptionRequest) (*api.Subscription, error)
CreateSubscription provides a mock function with given fields: _a0, _a1
func (*HammerServer) CreateTopic ¶ added in v0.6.0
func (_m *HammerServer) CreateTopic(_a0 context.Context, _a1 *api.CreateTopicRequest) (*api.Topic, error)
CreateTopic provides a mock function with given fields: _a0, _a1
func (*HammerServer) DeleteMessage ¶ added in v0.6.0
func (_m *HammerServer) DeleteMessage(_a0 context.Context, _a1 *api.DeleteMessageRequest) (*emptypb.Empty, error)
DeleteMessage provides a mock function with given fields: _a0, _a1
func (*HammerServer) DeleteSubscription ¶ added in v0.6.0
func (_m *HammerServer) DeleteSubscription(_a0 context.Context, _a1 *api.DeleteSubscriptionRequest) (*emptypb.Empty, error)
DeleteSubscription provides a mock function with given fields: _a0, _a1
func (*HammerServer) DeleteTopic ¶ added in v0.6.0
func (_m *HammerServer) DeleteTopic(_a0 context.Context, _a1 *api.DeleteTopicRequest) (*emptypb.Empty, error)
DeleteTopic provides a mock function with given fields: _a0, _a1
func (*HammerServer) GetDelivery ¶ added in v0.6.0
func (_m *HammerServer) GetDelivery(_a0 context.Context, _a1 *api.GetDeliveryRequest) (*api.Delivery, error)
GetDelivery provides a mock function with given fields: _a0, _a1
func (*HammerServer) GetDeliveryAttempt ¶ added in v0.6.0
func (_m *HammerServer) GetDeliveryAttempt(_a0 context.Context, _a1 *api.GetDeliveryAttemptRequest) (*api.DeliveryAttempt, error)
GetDeliveryAttempt provides a mock function with given fields: _a0, _a1
func (*HammerServer) GetMessage ¶ added in v0.6.0
func (_m *HammerServer) GetMessage(_a0 context.Context, _a1 *api.GetMessageRequest) (*api.Message, error)
GetMessage provides a mock function with given fields: _a0, _a1
func (*HammerServer) GetSubscription ¶ added in v0.6.0
func (_m *HammerServer) GetSubscription(_a0 context.Context, _a1 *api.GetSubscriptionRequest) (*api.Subscription, error)
GetSubscription provides a mock function with given fields: _a0, _a1
func (*HammerServer) GetTopic ¶ added in v0.6.0
func (_m *HammerServer) GetTopic(_a0 context.Context, _a1 *api.GetTopicRequest) (*api.Topic, error)
GetTopic provides a mock function with given fields: _a0, _a1
func (*HammerServer) ListDeliveries ¶ added in v0.6.0
func (_m *HammerServer) ListDeliveries(_a0 context.Context, _a1 *api.ListDeliveriesRequest) (*api.ListDeliveriesResponse, error)
ListDeliveries provides a mock function with given fields: _a0, _a1
func (*HammerServer) ListDeliveryAttempts ¶ added in v0.6.0
func (_m *HammerServer) ListDeliveryAttempts(_a0 context.Context, _a1 *api.ListDeliveryAttemptsRequest) (*api.ListDeliveryAttemptsResponse, error)
ListDeliveryAttempts provides a mock function with given fields: _a0, _a1
func (*HammerServer) ListMessages ¶ added in v0.6.0
func (_m *HammerServer) ListMessages(_a0 context.Context, _a1 *api.ListMessagesRequest) (*api.ListMessagesResponse, error)
ListMessages provides a mock function with given fields: _a0, _a1
func (*HammerServer) ListSubscriptions ¶ added in v0.6.0
func (_m *HammerServer) ListSubscriptions(_a0 context.Context, _a1 *api.ListSubscriptionsRequest) (*api.ListSubscriptionsResponse, error)
ListSubscriptions provides a mock function with given fields: _a0, _a1
func (*HammerServer) ListTopics ¶ added in v0.6.0
func (_m *HammerServer) ListTopics(_a0 context.Context, _a1 *api.ListTopicsRequest) (*api.ListTopicsResponse, error)
ListTopics provides a mock function with given fields: _a0, _a1
func (*HammerServer) UpdateSubscription ¶ added in v0.6.0
func (_m *HammerServer) UpdateSubscription(_a0 context.Context, _a1 *api.UpdateSubscriptionRequest) (*api.Subscription, error)
UpdateSubscription provides a mock function with given fields: _a0, _a1
func (*HammerServer) UpdateTopic ¶ added in v0.6.0
func (_m *HammerServer) UpdateTopic(_a0 context.Context, _a1 *api.UpdateTopicRequest) (*api.Topic, error)
UpdateTopic provides a mock function with given fields: _a0, _a1
type MessageRepository ¶
MessageRepository is an autogenerated mock type for the MessageRepository type
func (*MessageRepository) Delete ¶
func (_m *MessageRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*MessageRepository) FindAll ¶
func (_m *MessageRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)
FindAll provides a mock function with given fields: ctx, findOptions
type MessageService ¶
MessageService is an autogenerated mock type for the MessageService type
func (*MessageService) Delete ¶
func (_m *MessageService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*MessageService) FindAll ¶
func (_m *MessageService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)
FindAll provides a mock function with given fields: ctx, findOptions
type MigrationRepository ¶
MigrationRepository is an autogenerated mock type for the MigrationRepository type
type MigrationService ¶ added in v0.6.0
MigrationService is an autogenerated mock type for the MigrationService type
type SubscriptionRepository ¶
SubscriptionRepository is an autogenerated mock type for the SubscriptionRepository type
func (*SubscriptionRepository) Delete ¶
func (_m *SubscriptionRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*SubscriptionRepository) Find ¶
func (_m *SubscriptionRepository) Find(ctx context.Context, id string) (*hammer.Subscription, error)
Find provides a mock function with given fields: ctx, id
func (*SubscriptionRepository) FindAll ¶
func (_m *SubscriptionRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
FindAll provides a mock function with given fields: ctx, findOptions
func (*SubscriptionRepository) Store ¶
func (_m *SubscriptionRepository) Store(ctx context.Context, subscription *hammer.Subscription) error
Store provides a mock function with given fields: ctx, subscription
type SubscriptionService ¶
SubscriptionService is an autogenerated mock type for the SubscriptionService type
func (*SubscriptionService) Create ¶
func (_m *SubscriptionService) Create(ctx context.Context, subscription *hammer.Subscription) error
Create provides a mock function with given fields: ctx, subscription
func (*SubscriptionService) Delete ¶
func (_m *SubscriptionService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*SubscriptionService) Find ¶
func (_m *SubscriptionService) Find(ctx context.Context, id string) (*hammer.Subscription, error)
Find provides a mock function with given fields: ctx, id
func (*SubscriptionService) FindAll ¶
func (_m *SubscriptionService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
FindAll provides a mock function with given fields: ctx, findOptions
func (*SubscriptionService) Update ¶
func (_m *SubscriptionService) Update(ctx context.Context, subscription *hammer.Subscription) error
Update provides a mock function with given fields: ctx, subscription
type TopicRepository ¶
TopicRepository is an autogenerated mock type for the TopicRepository type
func (*TopicRepository) Delete ¶
func (_m *TopicRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*TopicRepository) FindAll ¶
func (_m *TopicRepository) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)
FindAll provides a mock function with given fields: ctx, findOptions
type TopicService ¶
TopicService is an autogenerated mock type for the TopicService type
func (*TopicService) Delete ¶
func (_m *TopicService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*TopicService) FindAll ¶
func (_m *TopicService) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)
FindAll provides a mock function with given fields: ctx, findOptions
type WorkerService ¶ added in v0.6.0
WorkerService is an autogenerated mock type for the WorkerService type
func (*WorkerService) Run ¶ added in v0.6.0
func (_m *WorkerService) Run(ctx context.Context)
Run provides a mock function with given fields: ctx
func (*WorkerService) Stop ¶ added in v0.6.0
func (_m *WorkerService) Stop(ctx context.Context)
Stop provides a mock function with given fields: ctx