dmetering

type Event struct {
	Endpoint         string             `json:"endpoint"`
	Network          string             `json:"network"` // can be omitted if the emitter is set up with a global network config
	Metrics          map[string]float64 `json:"metrics,omitempty"`
	OutputModuleHash string             `json:"output_module_hash,omitempty"` //substreams-only field

	// OrganizationID identify the organization that emitted the event.
	//
	// This was previously named UserID but has been renamed to OrganizationID to
	// better reflect the real underlying data in this field.
	//
	// As a measure of ensuring backward compatibility, we kept the JSON version as
	// 'user_id' for now, we should search better how this is used to change it safely.
	OrganizationID string `json:"user_id"`
	ApiKeyID       string `json:"api_key_id"`
	IpAddress      string `json:"ip_address"`

	Meta string `json:"meta"`

	Timestamp time.Time `json:"timestamp"`
}

type EventEmitter interface {
	Shutdown(error)
	Emit(ctx context.Context, ev Event)
}

type FactoryFunc func(config string, logger *zap.Logger) (EventEmitter, error)

type Meter interface {
	AddBytesWritten(n int)
	AddBytesRead(n int)

	AddBytesWrittenCtx(ctx context.Context, n int)
	AddBytesReadCtx(ctx context.Context, n int)

	BytesWritten() uint64
	BytesRead() uint64

	BytesWrittenDelta() uint64
	BytesReadDelta() uint64

	AddCounter(name string)
	CountInc(name string, n int)
	CountDec(name string, n int)
	GetCount(name string) int
	GetCountAndReset(name string) int
	ResetCount(name string)
}

type MeterLogData struct {
	Filename *string
	Store    *string
	TraceId  *string
	Mode     mode
	NBytes   int
}