api

Jul 25, 2023

Changes in this version

type Runner

+ Logger *logr.Logger

Jun 28, 2023

Changes in this version

+ func Join(errs ...error) error

type Runner

+ MaxRecords int

Jun 21, 2023

Changes in this version

+ func FirstError(errors ...error) error

May 26, 2023

Changes in this version

type Runner

+ RequestTimeout *time.Duration

Jan 4, 2023

Changes in this version

+ func DecodeConfig(input interface{}, output interface{}) error

+ func SendRecords(ctx context.Context, ch chan<- *Record, name string, s Source) bool

+ type Config struct

+ Action string

+ Config map[string]interface{}

+ type Endpoint map[string]RequestBuilder

+ func (e *Endpoint) Filter(pattern string) Endpoint

+ func (e *Endpoint) New(action string, config interface{}) ([]Request, error)

+ func (e *Endpoint) Resolve(m *Manifest) ([]Request, error)

+ type Manifest struct

+ Exclude []string

+ Include []string

+ Overrides []*Config

+ type Record struct

+ Action string

+ Data interface{}

+ ID *string

+ Timestamp *int64

+ type Recorder interface

+ ReadFrom func(context.Context, <-chan *Record) error

+ type RecorderFunc func(context.Context, <-chan *Record) error

+ func (r RecorderFunc) ReadFrom(ctx context.Context, ch <-chan *Record) error

+ type Request func(context.Context, chan<- *Record) error

+ type RequestBuilder interface

+ New func(action string, config interface{}) ([]Request, error)

+ type Runner struct

+ BufferSize int

+ ConcurrentRecorders int

+ MaxConcurrentRequests int

+ Recorder Recorder

+ Requests []Request

+ func (r *Runner) Run(ctx context.Context) error

+ type Service interface

+ New func(p client.ConfigProvider, opts ...*aws.Config) Endpoint

+ type ServiceFunc func(p client.ConfigProvider, opts ...*aws.Config) Endpoint

+ func (s ServiceFunc) New(p client.ConfigProvider, opts ...*aws.Config) Endpoint

+ type Source interface

+ Records func() []*Record