metricSchemaFlusher implements MetricSchemaFlusher interface.
| 41 | |
| 42 | // metricSchemaFlusher implements MetricSchemaFlusher interface. |
| 43 | type metricSchemaFlusher struct { |
| 44 | kvFlusher kv.Flusher |
| 45 | kvWriter table.StreamWriter |
| 46 | } |
| 47 | |
| 48 | // NewMetricSchemaFlusher creates a metric schema flusher. |
| 49 | func NewMetricSchemaFlusher(kvFlusher kv.Flusher) (MetricSchemaFlusher, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected