MapperToSchema creates a BigQuery schema representation for the provided coster.Mapper configuration.

NewBigQueryAggregator creates a new Aggregator that publishes consumed pubsub events to the named BigQuery dataset and table.

NewPubsubConsumer consumes messages from pubsub and invokes the provider aggregator with the message contents.

MeasureConsume measures aggregation results into the pubsub queue.

TagConsumeStatus indicates the success or failure of a consumption.

BigQueryAggregator coalesces and persists coster.CosData data to BigQuery.

CostRow augments CostData with BigQuery specific interfaces for import purposes via the bigquery.Uploader.

PubsubConsumer consumers messages from pubsub and forwards them to the provided aggregator.

Aggregator coalesces and persists coster.CostData from kostanza.

Consumer consumes messages as long as the provided context is not canceled, or its deadline exceeded.