io

type Config struct {
	Debug             bool            `json:"debug"`
	UID               string          `json:"uid" validate:"required"`
	BatchSize         int             `json:"batch_size"`
	BatchInterval     int             `json:"batch_interval"`
	Sink              string          `json:"sink" validate:"required"`
	Raw               json.RawMessage `json:"-"`
	HeartbeatHook     string          `json:"heartbeat_hook"`
	HeartbeatInterval int             `json:"heartbeat_interval"`
	HeartbeatTimeout  int             `json:"heartbeat_timeout_ms"`
}

type FileSink struct {
	Dir string `json:"file_sink_dir" validate:"required"`
}

type Flusher interface {
	Flush(uuid, ident string, d []byte) error
	LoadConfig(json.RawMessage) error
}

type MemSink struct {
	Records map[string][]byte
	OnFetch func(string)
	// contains filtered or unexported fields
}

type S3Sink struct {
	Prefix  string `json:"prefix" validate:"required"`
	Region  string `json:"aws_region", validate:"required"`
	Bucket  string `json:"aws_bucket" validate:"required"`
	Profile string `json:"aws_profile" validate:"required"`
}