fakeyagnats

Documentation

Index

• type FakeYagnats
  • func New() *FakeYagnats
  • func (f *FakeYagnats) Connect(connectionProvider yagnats.ConnectionProvider) error
  • func (f *FakeYagnats) Disconnect()
  • func (f *FakeYagnats) OnPing(onPingCallback func() bool)
  • func (f *FakeYagnats) Ping() bool
  • func (f *FakeYagnats) Publish(subject string, payload []byte) error
  • func (f *FakeYagnats) PublishWithReplyTo(subject, reply string, payload []byte) error
  • func (f *FakeYagnats) PublishedMessages(subject string) []yagnats.Message
  • func (f *FakeYagnats) Reset()
  • func (f *FakeYagnats) Subscribe(subject string, callback yagnats.Callback) (int64, error)
  • func (f *FakeYagnats) SubscribeWithQueue(subject, queue string, callback yagnats.Callback) (int64, error)
  • func (f *FakeYagnats) Subscriptions(subject string) []yagnats.Subscription
  • func (f *FakeYagnats) Unsubscribe(subscription int64) error
  • func (f *FakeYagnats) UnsubscribeAll(subject string)
  • func (f *FakeYagnats) WhenPublishing(subject string, callback func(*yagnats.Message) error)
  • func (f *FakeYagnats) WhenSubscribing(subject string, callback func(yagnats.Callback) error)

Types

type FakeYagnats

type FakeYagnats struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *FakeYagnats

func (*FakeYagnats) Connect

func (f *FakeYagnats) Connect(connectionProvider yagnats.ConnectionProvider) error

func (*FakeYagnats) Disconnect

func (f *FakeYagnats) Disconnect()

func (*FakeYagnats) OnPing

func (f *FakeYagnats) OnPing(onPingCallback func() bool)

func (*FakeYagnats) Ping

func (f *FakeYagnats) Ping() bool

func (*FakeYagnats) Publish

func (f *FakeYagnats) Publish(subject string, payload []byte) error

func (*FakeYagnats) PublishWithReplyTo

func (f *FakeYagnats) PublishWithReplyTo(subject, reply string, payload []byte) error

func (*FakeYagnats) PublishedMessages

func (f *FakeYagnats) PublishedMessages(subject string) []yagnats.Message

func (*FakeYagnats) Reset

func (f *FakeYagnats) Reset()

func (*FakeYagnats) Subscribe

func (f *FakeYagnats) Subscribe(subject string, callback yagnats.Callback) (int64, error)

func (*FakeYagnats) SubscribeWithQueue

func (f *FakeYagnats) SubscribeWithQueue(subject, queue string, callback yagnats.Callback) (int64, error)

func (*FakeYagnats) Subscriptions

func (f *FakeYagnats) Subscriptions(subject string) []yagnats.Subscription

func (*FakeYagnats) Unsubscribe

func (f *FakeYagnats) Unsubscribe(subscription int64) error

func (*FakeYagnats) UnsubscribeAll

func (f *FakeYagnats) UnsubscribeAll(subject string)

func (*FakeYagnats) WhenPublishing

func (f *FakeYagnats) WhenPublishing(subject string, callback func(*yagnats.Message) error)

func (*FakeYagnats) WhenSubscribing

func (f *FakeYagnats) WhenSubscribing(subject string, callback func(yagnats.Callback) error)