testutils

Sep 21, 2024

Changes in this version

+ var File_testutils_proto protoreflect.FileDescriptor

+ type Channel = bus.Channel

+ type LaggyMessage struct

+ Body []byte

+ Origin string

+ SentAt int64

+ func (*LaggyMessage) Descriptor() ([]byte, []int)

+ func (*LaggyMessage) ProtoMessage()

+ func (x *LaggyMessage) GetBody() []byte

+ func (x *LaggyMessage) GetOrigin() string

+ func (x *LaggyMessage) GetSentAt() int64

+ func (x *LaggyMessage) ProtoReflect() protoreflect.Message

+ func (x *LaggyMessage) Reset()

+ func (x *LaggyMessage) String() string

type TestBusOption

+ func WithBusOptions(opts ...TestBusOption) TestBusOption

+ func WithLaggyBus(id string, latency latencyFunc) TestBusOption

Oct 23, 2023

Changes in this version

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

+ type AtomicFailureRate struct

+ func NewAtomicFailureRate(v float64) AtomicFailureRate

+ func (g *AtomicFailureRate) Rate() float64

+ func (g *AtomicFailureRate) SetRate(v float64)

+ type PublishHandler = bus.PublishHandler

+ type PublishInterceptor = bus.PublishInterceptor

+ type ReadHandler = bus.ReadHandler

+ type SubscribeInterceptor = bus.SubscribeInterceptor

+ type TestBusOption = bus.TestBusOption

+ func WithPublishInterceptor(interceptor PublishInterceptor) TestBusOption

+ func WithSubscribeInterceptor(interceptor SubscribeInterceptor) TestBusOption

+ func WithUnreliableBus(rate AtomicFailureRate) TestBusOption

+ func WithUnreliableBusChannel(rate AtomicFailureRate, channelFilter string) TestBusOption