meter

type CreateMeterInput struct {
	Namespace     string
	Name          string
	Key           string
	Description   *string
	Aggregation   MeterAggregation
	EventType     string
	EventFrom     *time.Time
	ValueProperty *string
	GroupBy       map[string]string
}

type DeleteMeterInput struct {
	Namespace string
	IDOrSlug  string
}

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

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

type GetMeterInput struct {
	Namespace string
	IDOrSlug  string
}

type ListMetersParams struct {
	pagination.Page

	OrderBy OrderBy
	Order   sortx.Order

	Namespace string

	SlugFilter *[]string

	// WithoutNamespace is a flag to list meters without a namespace.
	// We do this instead of letting the namespace be empty to avoid
	// accidental listing of all meters across all namespaces.
	WithoutNamespace bool

	// IncludeDeleted is a flag to include deleted meters in the list.
	IncludeDeleted bool
}

type ManageService interface {
	Service

	CreateMeter(ctx context.Context, input CreateMeterInput) (Meter, error)
	UpdateMeter(ctx context.Context, input UpdateMeterInput) (Meter, error)
	DeleteMeter(ctx context.Context, input DeleteMeterInput) error

	// Observer hooks
	// Useful to coordinate with other services
	RegisterPreUpdateMeterHook(hook PreUpdateMeterHook) error
}

type Meter struct {
	models.ManagedResource `mapstructure:",squash"`

	Key           string `mapstructure:"slug"`
	Aggregation   MeterAggregation
	EventType     string
	EventFrom     *time.Time
	ValueProperty *string
	GroupBy       map[string]string

	// Deprecated, always set to MINUTE
	WindowSize WindowSize
}

type MeterAggregation string

type MeterCreateEvent struct {
	Meter  *Meter  `json:"meter"`
	UserID *string `json:"userId,omitempty"`
}

type MeterDeleteEvent struct {
	Meter  *Meter  `json:"meter"`
	UserID *string `json:"userId,omitempty"`
}

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

type MeterQueryRow struct {
	Value       float64            `json:"value"`
	WindowStart time.Time          `json:"windowStart"`
	WindowEnd   time.Time          `json:"windowEnd"`
	Subject     *string            `json:"subject"`
	GroupBy     map[string]*string `json:"groupBy"`
}

type MeterUpdateEvent struct {
	Meter  *Meter  `json:"meter"`
	UserID *string `json:"userId,omitempty"`
}

type OrderBy string

type ParsedEvent struct {
	Value       *float64
	ValueString *string
	GroupBy     map[string]string
}

type PreUpdateMeterHook = func(context.Context, UpdateMeterInput) error

type Service interface {
	ListMeters(ctx context.Context, params ListMetersParams) (pagination.PagedResponse[Meter], error)
	GetMeterByIDOrSlug(ctx context.Context, input GetMeterInput) (Meter, error)
}

type UpdateMeterInput struct {
	ID          models.NamespacedID
	Name        string
	Description *string
	GroupBy     map[string]string
}

type WindowSize string