event

Documentation

Index

• func ProvideNats(config *pkg.Config) (*nats.EncodedConn, func(), error)
• type NatsMeowEventReceiver
  • func ProvideNatsMeowEventReceiver(connection *nats.EncodedConn) (*NatsMeowEventReceiver, func(), error)
  • func (receiver *NatsMeowEventReceiver) Receive() <-chan *eventContract.MeowCreatedEvent

Functions

func ProvideNats

func ProvideNats(config *pkg.Config) (*nats.EncodedConn, func(), error)

Types

type NatsMeowEventReceiver

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

func ProvideNatsMeowEventReceiver

func ProvideNatsMeowEventReceiver(connection *nats.EncodedConn) (*NatsMeowEventReceiver, func(), error)

func (*NatsMeowEventReceiver) Receive

func (receiver *NatsMeowEventReceiver) Receive() <-chan *eventContract.MeowCreatedEvent