publisher

Documentation

Index

• type BasicSender
• type Mock
  • func NewMock() *Mock
  • func (p *Mock) Close() error
  • func (p *Mock) GetCount() int
  • func (p *Mock) Publish(topic string, messages ...*message.Message) error
  • func (p *Mock) SetBaseChecker(fn checker.Checker)
  • func (p *Mock) SetChecker(fn checker.CallbackFn)
  • func (p *Mock) SetResendMode(ctx context.Context, sender BasicSender)
  • func (p *Mock) SetTypedChecker(ctx context.Context, t minimock.Tester, sender BasicSender) *checker.Typed
  • func (p *Mock) SetTypedCheckerWithLightStubs(ctx context.Context, t minimock.Tester, sender Sender) *checker.Typed
  • func (p *Mock) WaitCount(count int, timeout time.Duration) bool
• type Sender

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)
}