Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ReplicaSnapshotTotalGaugeVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "litestream", Subsystem: "replica", Name: "snapshot_total", Help: "The current number of snapshots", }, []string{"db", "name"}) ReplicaWALBytesCounterVec = promauto.NewCounterVec(prometheus.CounterOpts{ Namespace: "litestream", Subsystem: "replica", Name: "wal_bytes", Help: "The number wal bytes written", }, []string{"db", "name"}) ReplicaWALIndexGaugeVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "litestream", Subsystem: "replica", Name: "wal_index", Help: "The current WAL index", }, []string{"db", "name"}) ReplicaWALOffsetGaugeVec = promauto.NewGaugeVec(prometheus.GaugeOpts{ Namespace: "litestream", Subsystem: "replica", Name: "wal_offset", Help: "The current WAL offset", }, []string{"db", "name"}) ReplicaValidationTotalCounterVec = promauto.NewCounterVec(prometheus.CounterOpts{ Namespace: "litestream", Subsystem: "replica", Name: "validation_total", Help: "The number of validations performed", }, []string{"db", "name", "status"}) )
Shared replica metrics.
Functions ¶
This section is empty.
Types ¶
type ReadCloser ¶
type ReadCloser struct {
// contains filtered or unexported fields
}
ReadCloser wraps a reader to also attach a separate closer.
func NewReadCloser ¶
func NewReadCloser(r io.Reader, c io.Closer) *ReadCloser
NewReadCloser returns a new instance of ReadCloser.
func (*ReadCloser) Close ¶
func (r *ReadCloser) Close() error
Close closes the reader (if implementing io.ReadCloser) and the Closer.
Click to show internal directories.
Click to hide internal directories.