api

type Config struct {
	Action string                 `json:"action"`
	Config map[string]interface{} `json:"config"`
}

type Endpoint map[string]RequestBuilder

type Manifest struct {
	Include   []string  `json:"include"`   // Include is a list of actions
	Exclude   []string  `json:"exclude"`   // Exclude is a list of actions
	Overrides []*Config `json:"overrides"` // Overrides are key value pairs of configuration data.
}

type Record struct {
	Timestamp *int64      `json:"timestamp,omitempty"` // Optional nanosecond timestamp.
	Action    string      `json:"action"`              // Action performed. Naming should match IAM policy.
	ID        *string     `json:"id,omitempty"`        // ID of resource contained in Data. Optional
	Data      interface{} `json:"data"`
}

type Recorder interface {
	ReadFrom(context.Context, <-chan *Record) error
}

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

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

type RequestBuilder interface {
	New(action string, config interface{}) ([]Request, error)
}

type Runner struct {
	Requests              []Request
	Recorder              Recorder
	BufferSize            int
	MaxConcurrentRequests int
	MaxRecords            int
	ConcurrentRecorders   int
	RequestTimeout        *time.Duration
	Logger                *logr.Logger
}

type Service interface {
	New(p client.ConfigProvider, opts ...*aws.Config) Endpoint
}

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

type Source interface {
	Records() []*Record
}