testutils

Documentation

Index

• func NewTestBus(next psrpc.MessageBus, opts ...TestBusOption) psrpc.MessageBus
• type AtomicFailureRate
  • func NewAtomicFailureRate(v float64) AtomicFailureRate
  • func (g *AtomicFailureRate) Rate() float64
  • func (g *AtomicFailureRate) SetRate(v float64)
• type PublishHandler
• type PublishInterceptor
• type ReadHandler
• type SubscribeInterceptor
• type TestBusOption
  • func WithPublishInterceptor(interceptor PublishInterceptor) TestBusOption
  • func WithSubscribeInterceptor(interceptor SubscribeInterceptor) TestBusOption
  • func WithUnreliableBus(rate AtomicFailureRate) TestBusOption
  • func WithUnreliableBusChannel(rate AtomicFailureRate, channelFilter string) TestBusOption

Functions

func NewTestBus

func NewTestBus(next psrpc.MessageBus, opts ...TestBusOption) psrpc.MessageBus

Types

type AtomicFailureRate

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

func NewAtomicFailureRate

func NewAtomicFailureRate(v float64) AtomicFailureRate

func (*AtomicFailureRate) Rate

func (g *AtomicFailureRate) Rate() float64

func (*AtomicFailureRate) SetRate

func (g *AtomicFailureRate) SetRate(v float64)

type PublishHandler

type PublishHandler = bus.PublishHandler

type PublishInterceptor

type PublishInterceptor = bus.PublishInterceptor

type ReadHandler

type ReadHandler = bus.ReadHandler

type SubscribeInterceptor

type SubscribeInterceptor = bus.SubscribeInterceptor

type TestBusOption

type TestBusOption = bus.TestBusOption

func WithPublishInterceptor

func WithPublishInterceptor(interceptor PublishInterceptor) TestBusOption

func WithSubscribeInterceptor

func WithSubscribeInterceptor(interceptor SubscribeInterceptor) TestBusOption

func WithUnreliableBus

func WithUnreliableBus(rate AtomicFailureRate) TestBusOption

func WithUnreliableBusChannel

func WithUnreliableBusChannel(rate AtomicFailureRate, channelFilter string) TestBusOption