sources

type EventSource interface {
	SetCtx()
	ConstructCloudEventsClient()
	GenerateEvents() interface{}
}

type ObjectStoreConfig struct {
	Bucket    string `envconfig:"S3_BUCKET"`
	Key       string `envconfig:"S3_FILE_NAME"`
	Region    string `envconfig:"S3_REGION"`
	Access    string `envconfig:"S3_ACCESS_KEY"`
	Secret    string `envconfig:"S3_SECRET_KEY"`
	Endpoint  string `envconfig:"S3_URL"`
	ChunkSize string `envconfig:"DOWNLOAD_CHUNK_SIZE" default:"500000000"`
}

type Result struct {
	ErrorCount int
	SentCount  int
}

type S3Source struct {
	Sink       SinkConfig
	Connection ObjectStoreConfig
	// contains filtered or unexported fields
}

type S3SourceData struct {
	Data string
}

type SinkConfig struct {
	URL           string `envconfig:"K_SINK"`
	CEOverrides   string `envconfig:"K_CE_OVERRIDES"`
	DumpCount     string `envconfig:"SINK_DUMP_COUNT" default:"100"`
	Retries       string `envconfig:"SINK_RETRY_COUNT" default:"3"`
	RetryInterval string `envconfig:"SINK_RETRY_INTERVAL" default:"1"`
}