Documentation ¶
Index ¶
- type Database
- type FakeHookService
- type FakeMessageSender
- func (fake *FakeMessageSender) Count() uint
- func (s *FakeMessageSender) EnsureTopology(ctx context.Context, queueName string) error
- func (fake *FakeMessageSender) Last() any
- func (fake *FakeMessageSender) Messages() []any
- func (fake *FakeMessageSender) Send(ctx context.Context, queueName string, messages ...any) ([]messaging.SendMessageResult, error)
- type FakeNotifyFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Database ¶ added in v1.3.1
type Database struct {
// contains filtered or unexported fields
}
fake database that's in memory
func NewFakeDatabase ¶ added in v1.3.1
type FakeHookService ¶
type FakeHookService struct {
// contains filtered or unexported fields
}
func NewFakeHookService ¶
func NewFakeHookService(t *testing.T) *FakeHookService
func (*FakeHookService) Messages ¶
func (q *FakeHookService) Messages() []sdk.EventHookMessage
func (*FakeHookService) Notify ¶
func (q *FakeHookService) Notify(ctx context.Context, message *sdk.EventHookMessage) (uuid.UUID, error)
type FakeMessageSender ¶
type FakeMessageSender struct {
// contains filtered or unexported fields
}
func NewFakeMessageSender ¶
func NewFakeMessageSender(t *testing.T) *FakeMessageSender
func (*FakeMessageSender) Count ¶ added in v1.3.4
func (fake *FakeMessageSender) Count() uint
message count
func (*FakeMessageSender) EnsureTopology ¶
func (s *FakeMessageSender) EnsureTopology(ctx context.Context, queueName string) error
func (*FakeMessageSender) Last ¶ added in v1.3.4
func (fake *FakeMessageSender) Last() any
func (*FakeMessageSender) Messages ¶ added in v1.3.4
func (fake *FakeMessageSender) Messages() []any
all messages passed to notify
func (*FakeMessageSender) Send ¶
func (fake *FakeMessageSender) Send(ctx context.Context, queueName string, messages ...any) ([]messaging.SendMessageResult, error)
type FakeNotifyFunc ¶ added in v1.3.4
type FakeNotifyFunc struct {
// contains filtered or unexported fields
}
func NewFakeNotifyFunc ¶ added in v1.3.4
func NewFakeNotifyFunc(t *testing.T) *FakeNotifyFunc
func (*FakeNotifyFunc) Count ¶ added in v1.3.4
func (fake *FakeNotifyFunc) Count() int
message count
func (*FakeNotifyFunc) Messages ¶ added in v1.3.4
func (fake *FakeNotifyFunc) Messages() []*sdk.EventHookMessage
all messages passed to notify
func (*FakeNotifyFunc) Notify ¶ added in v1.3.4
func (fake *FakeNotifyFunc) Notify(ctx context.Context, message *sdk.EventHookMessage) (uuid.UUID, error)
Click to show internal directories.
Click to hide internal directories.