resourcemanager

type Config struct {
	ResourceManagerConfig

	// DeploymentIdentity carries the static deployment + node identity
	// dimensions resolved from the LOOP environment.
	DeploymentIdentity DeploymentIdentity
}

type DeploymentIdentity struct {
	// Product is the deployment product, e.g. "cre".
	Product string
	// Tenant is the human-readable deployment tenant name, e.g. "mainline" or
	// "enterprise".
	Tenant string
	// NumericTenantID is the numbered tenant identifier as a string.
	NumericTenantID string
	// Environment is the deployment environment, e.g. "production", "staging".
	Environment string
	// Zone is the deployment zone, e.g. "wf-zone-a".
	Zone string
	// NodeID is the node's logical name, e.g. "clp-cre-wf-zone-a-1". It is NOT
	// the CSA public key; it is a stable name the billing service can use to
	// look up the node's CSA key in the workflow registry. The CSA key itself is
	// carried separately as the node_csa_key event attribute.
	NodeID string
}

type DonIdentity struct {
	// DonID is the DON ID the emitting service belongs to.
	DonID string
	// NodeID is the node's logical name within the scope of the DON, e.g.
	// "clp-cre-wf-zone-a-1". It is a human-readable ID, NOT the CSA
	// public key. The prefix can be redundant with other fully-qualified
	// dimensions, but helps readability. The CSA key is emitted separately via
	// the node_csa_key attribute.
	NodeID string
}

type Emitter interface {
	Emit(ctx context.Context, body []byte, attrKVs ...any) error
}

type Meterable interface {
	// ResourceIdentity returns the producer's base identity: the coarse
	// dimensions (product, tenant, numeric_tenant_id, environment, zone, don, service) plus
	// the service-level resource_pool / resource_pool_id. Per-resource billing
	// fields (resource_type/resource_id/org_id/value) are carried by
	// Utilizations on MeterRecord and MeterSnapshot; event_id is stamped by the
	// ResourceManager at emit time.
	ResourceIdentity() ResourceIdentity

	// GetUtilization returns the current level of the producer's currently
	// active resources, one SnapshotEntry per resource. The manager emits one
	// MeterSnapshot per entry.
	//
	// It is called on the snapshot tick and MUST be a cheap, non-blocking
	// read-snapshot of in-memory state: no network, no disk, no lock held
	// across I/O. It must tolerate ctx cancellation (returning promptly, and
	// nil/empty is acceptable) and tolerate concurrent registration of new
	// resources. An empty or nil return is valid and means nothing is currently
	// active: no snapshots are emitted, and billing zeroes the resource out by
	// its absence from subsequent snapshots.
	GetUtilization(ctx context.Context) []SnapshotEntry
}

type ResourceIdentity struct {
	// Product is the deployment product, e.g. "cre".
	Product string

	// Tenant is the human-readable deployment tenant name, e.g. "mainline" or
	// "enterprise".
	Tenant string

	// NumericTenantID is the numbered tenant identifier as a string.
	NumericTenantID string

	// Environment is the deployment environment, e.g. "production",
	// "staging".
	Environment string

	// Zone is the deployment zone, e.g. "wf-zone-a".
	Zone string

	// Don groups DON-specific identity dimensions so consumers can
	// branch on one struct instead of handling don/node permutations.
	Don *DonIdentity

	// Service is the stable service constant identifying the emitting service,
	// e.g. "cron-trigger", "http-trigger", "evm-log-trigger",
	// "workflow-syncer-v2". It must not
	// encode deployment environment or zone.
	Service string

	// ResourcePool is the service-level resource pool the record applies to,
	// e.g. "trigger_registrations", "log_filters", "workflow_storage".
	ResourcePool string

	// ResourcePoolID optionally scopes identity further within the resource pool.
	ResourcePoolID string
}

type ResourceManager struct {
	services.Service
	// contains filtered or unexported fields
}

type ResourceManagerConfig struct {
	// MeterRecordsEnabled is the meter-record rollout gate. When false (the
	// default), EmitDelta and EmitUsage are no-ops.
	MeterRecordsEnabled bool

	// MeterSnapshotsEnabled gates snapshot emission. Snapshots are only emitted
	// when this is true AND MeterRecordsEnabled is true.
	MeterSnapshotsEnabled bool

	// Emitter delivers encoded records, typically beholder.GetEmitter(). A nil
	// Emitter makes EmitDelta and EmitUsage no-ops even when enabled and keeps
	// the snapshot loop from starting.
	Emitter Emitter

	// SnapshotInterval is the period between snapshots. Zero (the default)
	// DISABLES the snapshot loop; the manager still starts as a service and
	// EmitDelta / EmitUsage still work. Callers that want snapshots set a
	// positive value, e.g. DefaultSnapshotInterval. The default is not
	// substituted for zero — zero means off.
	SnapshotInterval time.Duration

	// Clock drives snapshot tick timing and record timestamps. Nil selects the
	// real clock.
	Clock clockwork.Clock
}

type SnapshotEntry struct {
	Identity     ResourceIdentity
	Utilizations []*meteringpb.Utilization
}

type UtilizationFields struct {
	ResourceType string
	ResourceID   string
	OrgID        string
}