func NewIngestingReceiver(e e2e.Environment, name string) (*e2e.InstrumentedRunnable, error) {
	dir := filepath.Join(e.SharedDir(), "data", "receive", name)
	dataDir := filepath.Join(dir, "data")
	container := filepath.Join(ContainerSharedDir, "data", "receive", name)
	if err := os.MkdirAll(dataDir, 0750); err != nil {
		return nil, errors.Wrap(err, "create receive dir")
	}
	receiver := NewService(e,
		fmt.Sprintf("receive-%v", name),
		DefaultImage(),
		// TODO(bwplotka): BuildArgs should be interface.
		e2e.NewCommand("receive", e2e.BuildArgs(map[string]string{
			"--debug.name":           fmt.Sprintf("receive-%v", name),
			"--grpc-address":         ":9091",
			"--grpc-grace-period":    "0s",
			"--http-address":         ":8080",
			"--remote-write.address": ":8081",
			"--label":                fmt.Sprintf(`receive="%s"`, name),
			"--tsdb.path":            filepath.Join(container, "data"),
			"--log.level":            infoLogLevel,
		})...),
		e2e.NewHTTPReadinessProbe("http", "/-/ready", 200, 200),
		8080,
		9091,
		Port{Name: "remote-write", PortNum: 8081},
	)

	return receiver, nil
}
// NewIngestingReceiver creates a Thanos Receive instance that is only configured to ingest, not route to other receivers.
NewIngestingReceiver creates a Thanos Receive instance that is only configured to ingest, not route to other receivers.
// NewIngestingReceiver creates a Thanos Receive instance that is only configured to ingest not route to other receivers .
func NewIngestingReceiver(e e2e.Environment, name string) (*e2e.InstrumentedRunnable, error) {
	dir := filepath.Join(e.SharedDir(), "data", "receive", name)
	dataDir := filepath.Join(dir, "data")
	container := filepath.Join(ContainerSharedDir, "data", "receive", name)
	if err := os.MkdirAll(dataDir, 0750); err != nil {
		return nil, errors.Wrap(err, "create receive dir")
	}
	receiver := NewService(e,
		fmt.Sprintf("receive-%v", name),
		DefaultImage(),
		e2e.NewCommand("receive", e2e.BuildArgs(map[string]string{
			"--debug.name":           fmt.Sprintf("receive-%v", name),
			"--grpc-address":         ":9091",
			"--grpc-grace-period":    "0s",
			"--http-address":         ":8080",
			"--remote-write.address": ":8081",
			"--label":                fmt.Sprintf(`receive="%s"`, name),
			"--tsdb.path":            filepath.Join(container, "data"),
			"--log.level":            infoLogLevel,
		})...),
		e2e.NewHTTPReadinessProbe("http", "/-/ready", 200, 200),
		8080,
		9091,
		Port{Name: "remote-write", PortNum: 8081},
	)
	return receiver, nil
}
func NewIngestingReceiver ( e e2e . Environment , name string ) ( * e2e . InstrumentedRunnable , error ) { dir := filepath . Join ( e . SharedDir ( ) , " " , " " , name ) dataDir := filepath . Join ( dir , " " ) container := filepath . Join ( ContainerSharedDir , " " , " " , name ) if err := os . MkdirAll ( dataDir , 0750 ) ; err != nil { return nil , errors . Wrap ( err , " " ) } receiver := NewService ( e , fmt . Sprintf ( " " , name ) , DefaultImage ( ) , e2e . NewCommand ( " " , e2e . BuildArgs ( map [ string ] string { " " : fmt . Sprintf ( " " , name ) , " " : " " , " " : " " , " " : " " , " " : " " , " " : fmt . Sprintf ( `receive="%s"` , name ) , " " : filepath . Join ( container , " " ) , " " : infoLogLevel , } ) ... ) , e2e . NewHTTPReadinessProbe ( " " , " " , 200 , 200 ) , 8080 , 9091 , Port { Name : " " , PortNum : 8081 } , ) return receiver , nil }
NewIngestingReceiver creates a Thanos Receive instance that is only configured to ingest, not route to other receivers.
NewIngestingReceiver creates a Thanos Receive instance that is only configured to ingest not route to other receivers .
// TODO(bwplotka): BuildArgs should be interface.