ingester

type Config struct {
	ProductionLogging bool   `envconfig:"production_logging"`
	Addr              string `split_words:"true" default:"127.0.0.1:8080" required:"true"`
	PostgresURL       string `split_words:"true" default:"postgres://localhost/fieldkit?sslmode=disable" required:"true"`
	AwsProfile        string `envconfig:"aws_profile" default:"fieldkit" required:"true"`
	AwsId             string `split_words:"true" default:""`
	AwsSecret         string `split_words:"true" default:""`
	Archiver          string `split_words:"true" default:"default" required:"true"`
	SessionKey        string `split_words:"true"`
	StatsdAddress     string `split_words:"true" default:""`
	StreamsBucketName string `split_words:"true" default:""`
	Help              bool
}

type IncomingHeaders struct {
	ContentType     string
	ContentLength   int32
	MediaType       string
	MediaTypeParams map[string]string
	XForwardedFor   string
	FkType          string
	FkDeviceID      []byte
	FkGenerationID  []byte
	FkDeviceName    string
	FkBlocks        []int64
	FkFlags         []int64
}

type Ingester struct {
	Handler http.Handler
	Options *IngesterOptions
	// contains filtered or unexported fields
}

type IngesterOptions struct {
	Database   *sqlxcache.DB
	Files      files.FileArchive
	Publisher  jobs.MessagePublisher
	Metrics    *logging.Metrics
	JwtHMACKey []byte
}

type IngestionSuccessful struct {
	ID       int64  `json:"id"`
	UploadID string `json:"upload_id"`
}

type ServiceError struct {
	ID     string `json:"id"`
	Code   string `json:"code"`
	Detail string `json:"detail"`
	Status int32  `json:"status"`
}