mocks

Documentation

Index

• type Bus
  • func (b *Bus) Migrate(ctx context.Context) error
  • func (b *Bus) Publish(ctx context.Context, message *bus.OutboundMessage) error
  • func (b *Bus) Subscribe(ctx context.Context, subscribeName string, stream string, ...) (*bus.Subscription, error)
  • func (b *Bus) SubscriberInfo(ctx context.Context, stream string, consumerName string) (bus.SubscriberInfo, error)

Types

type Bus

type Bus struct {
	mock.Mock
}

func (*Bus) Migrate

func (b *Bus) Migrate(ctx context.Context) error

func (*Bus) Publish

func (b *Bus) Publish(ctx context.Context, message *bus.OutboundMessage) error

func (*Bus) Subscribe

func (b *Bus) Subscribe(ctx context.Context, subscribeName string, stream string, opts ...bus.SubscribeOption) (*bus.Subscription, error)

func (*Bus) SubscriberInfo

func (b *Bus) SubscriberInfo(ctx context.Context, stream string, consumerName string) (bus.SubscriberInfo, error)