metering

package

v1.17.10 Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

Constants
func AddEgressBytes(ctx context.Context, n int)
func AddProcessedBlocks(ctx context.Context, n int)
func AddWasmInputBytes(ctx context.Context, n int)
func FileSourceMiddlewareHandlerFactory(ctx context.Context) func(handler bstream.Handler) bstream.Handler
func GetTotalBytesRead(meter dmetering.Meter) uint64
func GetTotalBytesWritten(meter dmetering.Meter) uint64
func LiveSourceMiddlewareHandlerFactory(ctx context.Context) func(handler bstream.Handler) bstream.Handler
func WithBlockBytesReadMeteringOptions(meter dmetering.Meter, logger *zap.Logger) []dstore.Option
func WithBytesMeteringOptions(meter dmetering.Meter, logger *zap.Logger) []dstore.Option
func WithMetricsSender(ctx context.Context) context.Context
type MetricsSender
- func GetMetricsSender(ctx context.Context) *MetricsSender
- func NewMetricsSender() *MetricsSender
- func (ms *MetricsSender) Send(ctx context.Context, ...)

Constants ¶

View Source

const (
	MeterLiveUncompressedReadBytes = "live_uncompressed_read_bytes"

	MeterFileUncompressedReadBytes = "file_uncompressed_read_bytes"
	MeterFileCompressedReadBytes   = "file_compressed_read_bytes"

	MeterFileUncompressedWriteBytes = "file_uncompressed_write_bytes"
	MeterFileCompressedWriteBytes   = "file_compressed_write_bytes"

	MeterUncompressedEgressBytes = "egress_bytes" // named like this to be backwards compatible with the previous metrics
	MeterProcessedBlocks         = "processed_blocks"

	MeterWasmInputBytes = "wasm_input_bytes"

	TotalReadBytes  = "total_read_bytes"
	TotalWriteBytes = "total_write_bytes"
)

Variables ¶

This section is empty.

Functions ¶

func AddEgressBytes ¶ added in v1.15.5

func AddEgressBytes(ctx context.Context, n int)

func AddProcessedBlocks ¶ added in v1.15.5

func AddProcessedBlocks(ctx context.Context, n int)

func AddWasmInputBytes ¶ added in v1.10.7

func AddWasmInputBytes(ctx context.Context, n int)

func FileSourceMiddlewareHandlerFactory ¶ added in v1.10.7

func FileSourceMiddlewareHandlerFactory(ctx context.Context) func(handler bstream.Handler) bstream.Handler

func GetTotalBytesRead ¶

func GetTotalBytesRead(meter dmetering.Meter) uint64

func GetTotalBytesWritten ¶

func GetTotalBytesWritten(meter dmetering.Meter) uint64

func LiveSourceMiddlewareHandlerFactory ¶ added in v1.10.7

func LiveSourceMiddlewareHandlerFactory(ctx context.Context) func(handler bstream.Handler) bstream.Handler

func WithBlockBytesReadMeteringOptions ¶

func WithBlockBytesReadMeteringOptions(meter dmetering.Meter, logger *zap.Logger) []dstore.Option

func WithBytesMeteringOptions ¶

func WithBytesMeteringOptions(meter dmetering.Meter, logger *zap.Logger) []dstore.Option

func WithMetricsSender ¶ added in v1.10.7

func WithMetricsSender(ctx context.Context) context.Context

Types ¶

type MetricsSender ¶ added in v1.10.7

type MetricsSender struct {
	sync.Mutex
}

func GetMetricsSender ¶ added in v1.10.7

func GetMetricsSender(ctx context.Context) *MetricsSender

func NewMetricsSender ¶ added in v1.10.7

func NewMetricsSender() *MetricsSender

func (*MetricsSender) Send ¶ added in v1.10.7

func (ms *MetricsSender) Send(ctx context.Context, organizationID, apiKeyID, ip, userMeta, outputModuleHash, endpoint string)

Source Files ¶

View all Source files

metering.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL