publisher

package
v0.0.0-...-05bc493 Latest Latest
Warning

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

Go to latest
Published: Sep 20, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BasicSender

type BasicSender interface {
	SendMessage(context.Context, *message.Message)
}

type Mock

type Mock struct {
	// contains filtered or unexported fields
}

func NewMock

func NewMock() *Mock

func (*Mock) Close

func (p *Mock) Close() error

func (*Mock) GetCount

func (p *Mock) GetCount() int

func (*Mock) Publish

func (p *Mock) Publish(topic string, messages ...*message.Message) error

func (*Mock) SetBaseChecker

func (p *Mock) SetBaseChecker(fn checker.Checker)

func (*Mock) SetChecker

func (p *Mock) SetChecker(fn checker.CallbackFn)

func (*Mock) SetResendMode

func (p *Mock) SetResendMode(ctx context.Context, sender BasicSender)

func (*Mock) SetTypedChecker

func (p *Mock) SetTypedChecker(ctx context.Context, t minimock.Tester, sender BasicSender) *checker.Typed

func (*Mock) SetTypedCheckerWithLightStubs

func (p *Mock) SetTypedCheckerWithLightStubs(ctx context.Context, t minimock.Tester, sender Sender) *checker.Typed

func (*Mock) WaitCount

func (p *Mock) WaitCount(count int, timeout time.Duration) bool

type Sender

type Sender interface {
	BasicSender
	SendPayload(ctx context.Context, pl rmsreg.GoGoSerializable)
}

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL