ingestserver

type Server struct {
	Listener net.Listener

	MetaClient *meta.Client
	TSDBStore  netstorage.Storage
	Logger     *Logger.Logger

	QueryExecutor     *query.Executor
	PointsWriter      *coordinator.PointsWriter
	SubscriberManager *coordinator.SubscriberManager

	RecordWriter    *coordinator.RecordWriter
	RPCRecordWriter *writer.RecordWriter
	// contains filtered or unexported fields
}

type Service interface {
	Open() error
	Close() error
}