types

Documentation

Index

• type ConsumeMsg
• type ConsumeOpts
• type ConsumerOutput
• type ErrShouldRetry
  • func (e ErrShouldRetry) Error() string
• type NatsJetstreamProduceMsg
• type ProduceMsg
• type ProducerOutput

Types

type ConsumeMsg

type ConsumeMsg struct {
	Subject   string
	Timestamp time.Time
	Payload   []byte
}

type ConsumeOpts

type ConsumeOpts struct {
	/* OnError is called when an error occurs while consuming a message.
	   If OnError returns an error, then
	      the consumer will not commit that message, so that it will be queued again.
	    Otherwise,
	      the consumer will commit the message, so that it will not be consumed again
	*/
	OnError func(err error) error
}

type ConsumerOutput

type ConsumerOutput struct{}

type ErrShouldRetry

type ErrShouldRetry struct {
	Err error
}

func (ErrShouldRetry) Error

func (e ErrShouldRetry) Error() string

type NatsJetstreamProduceMsg

type NatsJetstreamProduceMsg struct {
	Subject string
	Payload []byte
}

type ProduceMsg

type ProduceMsg struct {
	Subject string
	Payload []byte
}

type ProducerOutput

type ProducerOutput struct{}