kinesis

Documentation

Index

• func Module() fx.Option
• func NewEvent(c kinesis.Client, options *Options) repository.Event
• func RandomPartitionKeyValue() bool
• type Client
  • func NewClient(c kinesis.Client, options *Options) *Client
  • func (p *Client) Publish(ctx context.Context, outs []*v2.Event) (err error)
• type Options
  • func DefaultOptions() (*Options, error)

Functions

func Module

func Module() fx.Option

func NewEvent

func NewEvent(c kinesis.Client, options *Options) repository.Event

NewEvent returns a initialized client

func RandomPartitionKeyValue

func RandomPartitionKeyValue() bool

Types

type Client

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

func NewClient

func NewClient(c kinesis.Client, options *Options) *Client

func (*Client) Publish

func (p *Client) Publish(ctx context.Context, outs []*v2.Event) (err error)

type Options

type Options struct {
	RandomPartitionKey bool `config:"randompartitionkey"`
}

func DefaultOptions

func DefaultOptions() (*Options, error)