multitenant

Mar 27, 2017

Changes in this version

+ type BillingEmitter struct

+ func NewBillingEmitter(upstream app.Collector, billingClient *billing.Client, ...) (*BillingEmitter, error)

+ func (e *BillingEmitter) Add(ctx context.Context, rep report.Report, buf []byte) error

+ func (e *BillingEmitter) Close() error

+ type BillingEmitterConfig struct

+ DefaultInterval time.Duration

+ Enabled bool

+ UserIDer UserIDer

+ func (cfg *BillingEmitterConfig) RegisterFlags(f *flag.FlagSet)

Nov 7, 2016

Changes in this version

type MemcacheClient

+ func (c *MemcacheClient) StoreReportBytes(key string, rpt []byte) (int, error)

type S3Store

+ func (store *S3Store) StoreReportBytes(key string, buf []byte) (int, error)

Aug 16, 2016

Changes in this version

type MemcacheClient

+ func (c *MemcacheClient) StoreReport(key string, report *report.Report) (int, error)

type MemcacheConfig

+ CompressionLevel int

type S3Store

+ func (store *S3Store) StoreReport(key string, report *report.Report) (int, error)

Jul 14, 2016

Changes in this version

+ type AWSCollector interface

+ CreateTables func() error

+ func NewAWSCollector(config AWSCollectorConfig) (AWSCollector, error)

+ type AWSCollectorConfig struct

+ DynamoDBConfig *aws.Config

+ DynamoTable string

+ MemcacheClient *MemcacheClient

+ NatsHost string

+ S3Store *S3Store

+ UserIDer UserIDer

+ Window time.Duration

+ type MemcacheClient struct

+ func NewMemcacheClient(config MemcacheConfig) *MemcacheClient

+ func (c *MemcacheClient) FetchReports(keys []string) (map[string]report.Report, []string, error)

+ func (c *MemcacheClient) Stop()

+ func (c *MemcacheClient) StoreBytes(key string, content []byte) error

+ type MemcacheConfig struct

+ Expiration time.Duration

+ Host string

+ Service string

+ Timeout time.Duration

+ UpdateInterval time.Duration

+ type ReportStore interface

+ FetchReports func([]string) (map[string]report.Report, []string, error)

+ type S3Store struct

+ func NewS3Client(config *aws.Config, bucketName string) S3Store

+ func (store *S3Store) FetchReports(keys []string) (map[string]report.Report, []string, error)

+ func (store *S3Store) StoreBytes(key string, content []byte) error

Apr 19, 2016

Changes in this version

+ var ErrNotFound = fmt.Errorf("Not found")

+ var ErrUserIDNotFound = fmt.Errorf("User ID not found")

+ func NewConsulPipeRouter(client ConsulClient, prefix, advertise string, userIDer UserIDer) app.PipeRouter

+ func NewSQSControlRouter(config *aws.Config, userIDer UserIDer) app.ControlRouter

+ func NoopUserIDer(context.Context) (string, error)

+ type CASCallback func(in interface{}) (out interface{}, retry bool, err error)

+ type ConsulClient interface

+ CAS func(key string, out interface{}, f CASCallback) error

+ Get func(key string, out interface{}) error

+ WatchPrefix func(prefix string, out interface{}, done chan struct{}, ...)

+ func NewConsulClient(addr string) (ConsulClient, error)

+ type DynamoDBCollector interface

+ CreateTables func() error

+ func NewDynamoDBCollector(config *aws.Config, userIDer UserIDer) DynamoDBCollector

+ type UserIDer func(context.Context) (string, error)

+ func UserIDHeader(headerName string) UserIDer