aggregate

Documentation

Index

• func ExposureKeys(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error
• func Holding(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error
• func Tokens(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error

Functions

func ExposureKeys

func ExposureKeys(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error

ExposureKeys handles aggregating all the input expsorue keys in a holding bucket and publishing to a publish bucket

func Holding

func Holding(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error

Holding handles aggregating all the input points in a holding bucket and publishing to a publish bucket

func Tokens

func Tokens(ctx context.Context, c *config.Config, s *storage.Client, throttle int64) error

Tokens handles aggregating all the input tokens in a holding bucket and publishing to a publish bucket