kinesis

Documentation

Index

• type Client
• type Opt
  • func WithPublishTimeout(timeout time.Duration) Opt
  • func WithShards(n uint32) Opt
  • func WithStreamAutocreate(autocreate bool) Opt
  • func WithStreamMode(mode types.StreamMode) Opt
  • func WithStreamPattern(pattern string) Opt
  • func WithStreamProbleInterval(interval time.Duration) Opt
• type Publisher
  • func New(client Client, opts ...Opt) (*Publisher, error)
  • func (*Publisher) Close() error
  • func (*Publisher) Name() string
  • func (p *Publisher) ProduceBulk(events []*pb.Event, connGroup string) error

Types

type Client

type Client interface {
	PutRecord(context.Context, *kinesis.PutRecordInput, ...func(*kinesis.Options)) (*kinesis.PutRecordOutput, error)
	DescribeStreamSummary(context.Context, *kinesis.DescribeStreamSummaryInput, ...func(*kinesis.Options)) (*kinesis.DescribeStreamSummaryOutput, error)
	CreateStream(context.Context, *kinesis.CreateStreamInput, ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)
}

Client is an interface to *kinesis.Client

type Opt

type Opt func(*Publisher) error

func WithPublishTimeout

func WithPublishTimeout(timeout time.Duration) Opt

func WithShards

func WithShards(n uint32) Opt

func WithStreamAutocreate

func WithStreamAutocreate(autocreate bool) Opt

func WithStreamMode

func WithStreamMode(mode types.StreamMode) Opt

func WithStreamPattern

func WithStreamPattern(pattern string) Opt

func WithStreamProbleInterval

func WithStreamProbleInterval(interval time.Duration) Opt

type Publisher

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

func New

func New(client Client, opts ...Opt) (*Publisher, error)

func (*Publisher) Close

func (*Publisher) Close() error

func (*Publisher) Name

func (*Publisher) Name() string

func (*Publisher) ProduceBulk

func (p *Publisher) ProduceBulk(events []*pb.Event, connGroup string) error