metering

package

v1.15.0 Latest Latest Go to latest Published: Mar 27, 2025 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 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"

	MeterWasmInputBytes = "wasm_input_bytes"

	TotalReadBytes  = "total_read_bytes"
	TotalWriteBytes = "total_write_bytes"
)

Variables ¶

This section is empty.

Functions ¶

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, userID, apiKeyID, ip, userMeta, outputModuleHash, endpoint string, resp proto.Message)

Source Files ¶

View all Source files

metering.go

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