messageprocessor

README

messageprocessor - An abstraction for consuming aws Kinesis messages

• messageprocessor - An abstraction for consuming aws Kinesis messages
  • Usage
  • Contributing
    • License
    • Contributing Agreement

Contributing

License

This project is licensed under Apache 2.0. See LICENSE.txt for details.

Contributing Agreement

Atlassian requires signing a contributor's agreement before we can accept a patch. If you are an individual you can fill out the individual CLA. If you are contributing on behalf of your company then please fill out the corporate CLA.

Documentation

Index

• type Chain
  • func (c Chain) Apply(base MessageProcessor) MessageProcessor
• type Decorator
• type MessageProcessError
• type MessageProcessor

Types

type Chain

type Chain []Decorator

Chain is an ordered collection of Decorators.

func (Chain) Apply

func (c Chain) Apply(base MessageProcessor) MessageProcessor

Apply wraps the given RoundTripper with the Decorator chain.

type Decorator

type Decorator func(MessageProcessor) MessageProcessor

Decorator is a named type for any function that takes a RoundTripper and returns a RoundTripper.

type MessageProcessError

type MessageProcessError interface {
	IsRetryable() bool
	Error() error
}

MessageProcessError represents an error that can be used to indicate to the consumer that an error should be retried

type MessageProcessor

type MessageProcessor interface {
	ProcessMessage(ctx context.Context, record *kinesis.Record) MessageProcessError
}

MessageProcessor processes a consumed message. Implementors are responsible for unmarshalling the data