billing

Documentation

Index

• Constants
• type Metronome
  • func NewMetronomeProvider(config config.Metronome) (*Metronome, error)
  • func (m *Metronome) AddDefaultPlan(ctx context.Context, accountId MetronomeId) (bool, error)
  • func (m *Metronome) AddPlan(ctx context.Context, accountId MetronomeId, planId uuid.UUID) (bool, error)
  • func (m *Metronome) CreateAccount(ctx context.Context, namespaceId string, name string) (MetronomeId, error)
  • func (m *Metronome) PushStorageEvents(ctx context.Context, events []*StorageEvent) error
  • func (m *Metronome) PushUsageEvents(ctx context.Context, events []*UsageEvent) error
• type MetronomeError
  • func NewMetronomeError(code int, message string) *MetronomeError
  • func (e *MetronomeError) Error() string
• type MetronomeId
• type Provider
  • func NewProvider() Provider
• type StorageEvent
• type StorageEventBuilder
  • func NewStorageEventBuilder() *StorageEventBuilder
  • func (sb *StorageEventBuilder) Build() *StorageEvent
  • func (sb *StorageEventBuilder) WithDatabaseBytes(value int64) *StorageEventBuilder
  • func (sb *StorageEventBuilder) WithIndexBytes(value int64) *StorageEventBuilder
  • func (sb *StorageEventBuilder) WithNamespaceId(id string) *StorageEventBuilder
  • func (sb *StorageEventBuilder) WithTimestamp(ts time.Time) *StorageEventBuilder
  • func (sb *StorageEventBuilder) WithTransactionId(id string) *StorageEventBuilder
• type UsageEvent
• type UsageEventBuilder
  • func NewUsageEventBuilder() *UsageEventBuilder
  • func (ub *UsageEventBuilder) Build() *UsageEvent
  • func (ub *UsageEventBuilder) WithDatabaseUnits(value int64) *UsageEventBuilder
  • func (ub *UsageEventBuilder) WithNamespaceId(id string) *UsageEventBuilder
  • func (ub *UsageEventBuilder) WithSearchUnits(value int64) *UsageEventBuilder
  • func (ub *UsageEventBuilder) WithTimestamp(ts time.Time) *UsageEventBuilder
  • func (ub *UsageEventBuilder) WithTransactionId(id string) *UsageEventBuilder
• type UsageReporter
  • func NewUsageReporter(gs metrics.UsageProvider, tm metadata.NamespaceMetadataMgr, billing Provider) (*UsageReporter, error)
  • func (r *UsageReporter) Start()

Constants

const (
	EventTypeUsage   string = "usage"
	EventTypeStorage string = "storage"
)

const (
	TimeFormat = time.RFC3339
)

Types

type Metronome

type Metronome struct {
	Config config.Metronome
	// contains filtered or unexported fields
}

func NewMetronomeProvider

func NewMetronomeProvider(config config.Metronome) (*Metronome, error)

func (*Metronome) AddDefaultPlan

func (m *Metronome) AddDefaultPlan(ctx context.Context, accountId MetronomeId) (bool, error)

func (*Metronome) AddPlan

func (m *Metronome) AddPlan(ctx context.Context, accountId MetronomeId, planId uuid.UUID) (bool, error)

func (*Metronome) CreateAccount

func (m *Metronome) CreateAccount(ctx context.Context, namespaceId string, name string) (MetronomeId, error)

func (*Metronome) PushStorageEvents

func (m *Metronome) PushStorageEvents(ctx context.Context, events []*StorageEvent) error

func (*Metronome) PushUsageEvents

func (m *Metronome) PushUsageEvents(ctx context.Context, events []*UsageEvent) error

type MetronomeError

type MetronomeError struct {
	HttpCode int
	Message  string
}

func NewMetronomeError

func NewMetronomeError(code int, message string) *MetronomeError

func (*MetronomeError) Error

func (e *MetronomeError) Error() string

type MetronomeId

type MetronomeId = uuid.UUID

type Provider

type Provider interface {
	CreateAccount(ctx context.Context, namespaceId string, name string) (MetronomeId, error)
	AddDefaultPlan(ctx context.Context, accountId MetronomeId) (bool, error)
	AddPlan(ctx context.Context, accountId MetronomeId, planId uuid.UUID) (bool, error)
	PushUsageEvents(ctx context.Context, events []*UsageEvent) error
	PushStorageEvents(ctx context.Context, events []*StorageEvent) error
}

func NewProvider

func NewProvider() Provider

type StorageEvent

type StorageEvent struct {
	biller.Event
}

type StorageEventBuilder

type StorageEventBuilder struct {
	// contains filtered or unexported fields
}

func NewStorageEventBuilder

func NewStorageEventBuilder() *StorageEventBuilder

func (*StorageEventBuilder) Build

func (sb *StorageEventBuilder) Build() *StorageEvent

func (*StorageEventBuilder) WithDatabaseBytes

func (sb *StorageEventBuilder) WithDatabaseBytes(value int64) *StorageEventBuilder

func (*StorageEventBuilder) WithIndexBytes

func (sb *StorageEventBuilder) WithIndexBytes(value int64) *StorageEventBuilder

func (*StorageEventBuilder) WithNamespaceId

func (sb *StorageEventBuilder) WithNamespaceId(id string) *StorageEventBuilder

func (*StorageEventBuilder) WithTimestamp

func (sb *StorageEventBuilder) WithTimestamp(ts time.Time) *StorageEventBuilder

func (*StorageEventBuilder) WithTransactionId

func (sb *StorageEventBuilder) WithTransactionId(id string) *StorageEventBuilder

type UsageEvent

type UsageEvent struct {
	biller.Event
}

type UsageEventBuilder

type UsageEventBuilder struct {
	// contains filtered or unexported fields
}

func NewUsageEventBuilder

func NewUsageEventBuilder() *UsageEventBuilder

func (*UsageEventBuilder) Build

func (ub *UsageEventBuilder) Build() *UsageEvent

func (*UsageEventBuilder) WithDatabaseUnits

func (ub *UsageEventBuilder) WithDatabaseUnits(value int64) *UsageEventBuilder

func (*UsageEventBuilder) WithNamespaceId

func (ub *UsageEventBuilder) WithNamespaceId(id string) *UsageEventBuilder

func (*UsageEventBuilder) WithSearchUnits

func (ub *UsageEventBuilder) WithSearchUnits(value int64) *UsageEventBuilder

func (*UsageEventBuilder) WithTimestamp

func (ub *UsageEventBuilder) WithTimestamp(ts time.Time) *UsageEventBuilder

func (*UsageEventBuilder) WithTransactionId

func (ub *UsageEventBuilder) WithTransactionId(id string) *UsageEventBuilder

type UsageReporter

type UsageReporter struct {
	// contains filtered or unexported fields
}

func NewUsageReporter

func NewUsageReporter(gs metrics.UsageProvider, tm metadata.NamespaceMetadataMgr, billing Provider) (*UsageReporter, error)

func (*UsageReporter) Start

func (r *UsageReporter) Start()