gcp

Documentation

Index

• Variables
• func Query(account string, tr usagetime.Range) (*storage.Query, error)
• type ObjectHandleEventReader
  • func (r *ObjectHandleEventReader) Close() error
  • func (r *ObjectHandleEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
• type ObjectIteratorEventReader
  • func (r *ObjectIteratorEventReader) Close() error
  • func (r *ObjectIteratorEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
• type QueryEventReader
  • func (r *QueryEventReader) Close() error
  • func (r *QueryEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
• type QueryIterator
  • func NewQueryIterator(account string, tr usagetime.Range, window time.Duration) (*QueryIterator, error)
  • func (i *QueryIterator) More() bool
  • func (i *QueryIterator) Next() (*storage.Query, usagetime.Range, error)
• type WindowIterator
  • func NewWindowIterator(bkt *storage.BucketHandle, account string, tr usagetime.Range, ...) (*WindowIterator, error)
  • func (i *WindowIterator) More() bool
  • func (i *WindowIterator) Next() (event.Reader, usagetime.Range, error)

Variables

var ErrEOF = event.ErrEOF

Functions

func Query

func Query(account string, tr usagetime.Range) (*storage.Query, error)

Query() returns a query for usage data for an Upbound account across a range of time. The start of the range is inclusive and the end is exclusive to the hour.

Types

type ObjectHandleEventReader

type ObjectHandleEventReader struct {
	Object *storage.ObjectHandle
	Attrs  *storage.ObjectAttrs
	// contains filtered or unexported fields
}

func (*ObjectHandleEventReader) Close

func (r *ObjectHandleEventReader) Close() error

func (*ObjectHandleEventReader) Read

func (r *ObjectHandleEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)

type ObjectIteratorEventReader

type ObjectIteratorEventReader struct {
	Bucket   *storage.BucketHandle
	Iterator *storage.ObjectIterator
	// contains filtered or unexported fields
}

func (*ObjectIteratorEventReader) Close

func (r *ObjectIteratorEventReader) Close() error

func (*ObjectIteratorEventReader) Read

func (r *ObjectIteratorEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)

type QueryEventReader

type QueryEventReader struct {
	Bucket *storage.BucketHandle
	Query  *storage.Query
	// contains filtered or unexported fields
}

func (*QueryEventReader) Close

func (r *QueryEventReader) Close() error

func (*QueryEventReader) Read

func (r *QueryEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)

type QueryIterator

type QueryIterator struct {
	Account string
	Iter    *usagetime.WindowIterator
}

QueryIterator iterates through queries for usage data for an Upbound account across a range of time. Each query covers a window of time within the time range. Must be initialized with NewUsageQueryIterator().

func NewQueryIterator

func NewQueryIterator(account string, tr usagetime.Range, window time.Duration) (*QueryIterator, error)

NewQueryIterator() returns an initialized *UsageQueryIterator. The start of the time range is inclusive and the end is exclusive to the hour. The time range and window are truncated to the hour.

func (*QueryIterator) More

func (i *QueryIterator) More() bool

More() returns true if Next() has more queries to return.

func (*QueryIterator) Next

func (i *QueryIterator) Next() (*storage.Query, usagetime.Range, error)

Next() returns a query covering the next window of time, as well as a pair of times marking the start and end of the window.

type WindowIterator

type WindowIterator struct {
	Iter   *QueryIterator
	Bucket *storage.BucketHandle
}

WindowIterator iterates through readers for windows of usage events from an Azure blob storage container. Must be initialized with NewWindowIterator().

func NewWindowIterator

func NewWindowIterator(bkt *storage.BucketHandle, account string, tr usagetime.Range, window time.Duration) (*WindowIterator, error)

NewWindowIterator returns an initialized *WindowIterator.

func (*WindowIterator) More

func (i *WindowIterator) More() bool

func (*WindowIterator) Next

func (i *WindowIterator) Next() (event.Reader, usagetime.Range, error)