events

package

v0.0.4 Latest Latest Go to latest Published: Oct 27, 2022 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer interface {
	Consume(string, any) (any, error)
}

type ConsumerFunc = func() (any, error)

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

func NatsEvents(nc *nats.EncodedConn) *Nats

func (n *Nats) Consume(topic string, handler NatsHandler) (*nats.Subscription, error)

func (n *Nats) Produce(topic string, msg any) error

func (n *Nats) Request(topic string, payload any, response *any, timeout time.Duration) error

type NatsHandler = func(m *nats.Msg)

type Producer interface {
	Produce(ctx context.Context, topic string, message any)
}