Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrSubscriptionDoesNotExists = errors.New("subscription does not exists")
)
Functions ¶
This section is empty.
Types ¶
type SessionConfig ¶
type Subscriber ¶
type Subscriber struct { SubscriptionID string // contains filtered or unexported fields }
Subscriber is the kinesis subscriber.
func NewSubscriber ¶
func NewSubscriber(ctx context.Context, cfg SessionConfig) (*Subscriber, error, func() error)
NewSubscriber creates a new instance of Subscriber.
Click to show internal directories.
Click to hide internal directories.