transaction

Documentation

Index

• type Tracked
  • func NewTracked(msg types.Message, resChan chan<- types.Response) *Tracked
  • func (t *Tracked) Ack(ctx context.Context, err error) error
  • func (t *Tracked) Message() types.Message
  • func (t *Tracked) ResponseChan() chan<- types.Response

Types

type Tracked

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

Tracked is a transaction type that adds identifying tags to messages such that an error returned resulting from multiple transaction messages can be reduced.

func NewTracked

func NewTracked(msg types.Message, resChan chan<- types.Response) *Tracked

NewTracked creates a transaction from a message batch and a response channel. The message is tagged with an identifier for the transaction, and if an error is returned from a downstream component that merged messages from other transactions the tag can be used in order to determine whether the message owned by this transaction succeeded.

func (*Tracked) Ack

func (t *Tracked) Ack(ctx context.Context, err error) error

Ack provides a response to the upstream service from an error.

func (*Tracked) Message

func (t *Tracked) Message() types.Message

Message returns the message owned by this transaction.

func (*Tracked) ResponseChan

func (t *Tracked) ResponseChan() chan<- types.Response

ResponseChan returns the response channel owned by this transaction.