Documentation
¶
Index ¶
- func ToAPIMeter(m meter.Meter) api.Meter
- func ToAPIMeterQueryResult(from *time.Time, to *time.Time, windowSize *api.WindowSize, ...) api.MeterQueryResult
- func ToAPIMeterQueryRow(row meter.MeterQueryRow) api.MeterQueryRow
- func ToAPIMeterQueryRowList(rows []meter.MeterQueryRow) []api.MeterQueryRow
- func ToRequestFromQueryParamsPOSTBody(apiParams api.QueryMeterParams) api.QueryMeterPostJSONRequestBody
- type CreateMeterHandler
- type CreateMeterRequest
- type CreateMeterResponse
- type DeleteMeterHandler
- type DeleteMeterParams
- type DeleteMeterRequest
- type DeleteMeterResponse
- type GetMeterHandler
- type GetMeterParams
- type GetMeterRequest
- type GetMeterResponse
- type Handler
- type ListGroupByValuesHandler
- type ListGroupByValuesParams
- type ListGroupByValuesRequest
- type ListGroupByValuesResponse
- type ListMetersHandler
- type ListMetersParams
- type ListMetersRequest
- type ListMetersResponse
- type ListSubjectsHandler
- type ListSubjectsParams
- type ListSubjectsRequest
- type ListSubjectsResponse
- type MeterHandler
- type QueryMeterCSVHandler
- type QueryMeterCSVParams
- type QueryMeterCSVRequest
- type QueryMeterCSVResponse
- type QueryMeterHandler
- type QueryMeterParams
- type QueryMeterPostCSVHandler
- type QueryMeterPostCSVParams
- type QueryMeterPostCSVRequest
- type QueryMeterPostCSVResponse
- type QueryMeterPostHandler
- type QueryMeterPostParams
- type QueryMeterPostRequest
- type QueryMeterPostResponse
- type QueryMeterRequest
- type QueryMeterResponse
- type UpdateMeterHandler
- type UpdateMeterRequest
- type UpdateMeterResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToAPIMeter ¶
ToAPIMeter converts a meter.Meter to an api.Meter.
func ToAPIMeterQueryResult ¶
func ToAPIMeterQueryResult(from *time.Time, to *time.Time, windowSize *api.WindowSize, rows []meter.MeterQueryRow) api.MeterQueryResult
ToAPIMeterQueryResult constructs an api.MeterQueryResult
func ToAPIMeterQueryRow ¶
func ToAPIMeterQueryRow(row meter.MeterQueryRow) api.MeterQueryRow
ToAPIMeterQueryRow converts a meter.MeterQueryRow to an api.MeterQueryRow.
func ToAPIMeterQueryRowList ¶
func ToAPIMeterQueryRowList(rows []meter.MeterQueryRow) []api.MeterQueryRow
ToAPIMeterQueryRowList converts a list of meter.MeterQueryRow to a list of api.MeterQueryRow.
func ToRequestFromQueryParamsPOSTBody ¶
func ToRequestFromQueryParamsPOSTBody(apiParams api.QueryMeterParams) api.QueryMeterPostJSONRequestBody
ToQueryParamsFromAPIParams converts a api.QueryMeterParams to a streaming.QueryParams. This is used to convert an API POST query body to GET request params.
Types ¶
type CreateMeterHandler ¶
type CreateMeterHandler = httptransport.Handler[CreateMeterRequest, CreateMeterResponse]
type CreateMeterRequest ¶
type CreateMeterRequest = struct {
Namespace string
api.MeterCreate
}
type CreateMeterResponse ¶
type DeleteMeterHandler ¶
type DeleteMeterHandler = httptransport.HandlerWithArgs[DeleteMeterRequest, DeleteMeterResponse, DeleteMeterParams]
type DeleteMeterParams ¶
type DeleteMeterParams = string
type DeleteMeterRequest ¶
type DeleteMeterRequest = models.NamespacedID
type DeleteMeterResponse ¶
type DeleteMeterResponse = any
type GetMeterHandler ¶
type GetMeterHandler httptransport.HandlerWithArgs[GetMeterRequest, GetMeterResponse, GetMeterParams]
type GetMeterParams ¶
type GetMeterParams = string
type GetMeterRequest ¶
type GetMeterRequest struct {
// contains filtered or unexported fields
}
type GetMeterResponse ¶
type Handler ¶
type Handler interface {
MeterHandler
}
func New ¶
func New( namespaceDecoder namespacedriver.NamespaceDecoder, customerService customer.Service, meterService meter.ManageService, streaming streaming.Connector, subjectService subject.Service, options ...httptransport.HandlerOption, ) Handler
type ListGroupByValuesHandler ¶
type ListGroupByValuesHandler httptransport.HandlerWithArgs[ListGroupByValuesRequest, ListGroupByValuesResponse, ListGroupByValuesParams]
type ListGroupByValuesParams ¶
type ListGroupByValuesRequest ¶
type ListGroupByValuesRequest struct {
// contains filtered or unexported fields
}
type ListGroupByValuesResponse ¶
type ListGroupByValuesResponse = *[]string
type ListMetersHandler ¶
type ListMetersHandler httptransport.HandlerWithArgs[ListMetersRequest, ListMetersResponse, ListMetersParams]
type ListMetersParams ¶
type ListMetersParams = api.ListMetersParams
type ListMetersRequest ¶
type ListMetersRequest struct {
// contains filtered or unexported fields
}
type ListMetersResponse ¶
type ListSubjectsHandler ¶
type ListSubjectsHandler httptransport.HandlerWithArgs[ListSubjectsRequest, ListSubjectsResponse, ListSubjectsParams]
type ListSubjectsParams ¶
type ListSubjectsRequest ¶
type ListSubjectsRequest struct {
// contains filtered or unexported fields
}
type ListSubjectsResponse ¶
type ListSubjectsResponse = *[]string
type MeterHandler ¶
type MeterHandler interface {
ListMeters() ListMetersHandler
GetMeter() GetMeterHandler
CreateMeter() CreateMeterHandler
UpdateMeter() UpdateMeterHandler
DeleteMeter() DeleteMeterHandler
QueryMeter() QueryMeterHandler
QueryMeterPost() QueryMeterPostHandler
QueryMeterPostCSV() QueryMeterPostCSVHandler
QueryMeterCSV() QueryMeterCSVHandler
ListSubjects() ListSubjectsHandler
ListGroupByValues() ListGroupByValuesHandler
}
type QueryMeterCSVHandler ¶
type QueryMeterCSVHandler httptransport.HandlerWithArgs[QueryMeterCSVRequest, QueryMeterCSVResponse, QueryMeterCSVParams]
type QueryMeterCSVParams ¶
type QueryMeterCSVParams = QueryMeterParams
type QueryMeterCSVRequest ¶
type QueryMeterCSVRequest = QueryMeterRequest
type QueryMeterCSVResponse ¶
type QueryMeterCSVResponse = commonhttp.CSVResponse
func NewQueryMeterCSVResult ¶
func NewQueryMeterCSVResult(meterSlug string, queryGroupBy []string, rows []meter.MeterQueryRow, subjectsByKey map[string]subject.Subject) QueryMeterCSVResponse
type QueryMeterHandler ¶
type QueryMeterHandler httptransport.HandlerWithArgs[QueryMeterRequest, QueryMeterResponse, QueryMeterParams]
type QueryMeterParams ¶
type QueryMeterParams struct {
api.QueryMeterParams
IdOrSlug string
}
type QueryMeterPostCSVHandler ¶
type QueryMeterPostCSVHandler httptransport.HandlerWithArgs[QueryMeterPostCSVRequest, QueryMeterPostCSVResponse, QueryMeterPostCSVParams]
type QueryMeterPostCSVParams ¶
type QueryMeterPostCSVParams = QueryMeterPostParams
type QueryMeterPostCSVRequest ¶
type QueryMeterPostCSVRequest = QueryMeterPostRequest
type QueryMeterPostCSVResponse ¶
type QueryMeterPostCSVResponse = commonhttp.CSVResponse
type QueryMeterPostHandler ¶
type QueryMeterPostHandler httptransport.HandlerWithArgs[QueryMeterPostRequest, QueryMeterPostResponse, QueryMeterPostParams]
type QueryMeterPostParams ¶
type QueryMeterPostParams = string // meterIdOrSlug
type QueryMeterPostRequest ¶
type QueryMeterPostRequest struct {
// contains filtered or unexported fields
}
type QueryMeterPostResponse ¶
type QueryMeterPostResponse = QueryMeterResponse
type QueryMeterRequest ¶
type QueryMeterRequest struct {
// contains filtered or unexported fields
}
type QueryMeterResponse ¶
type QueryMeterResponse = *api.MeterQueryResult
type UpdateMeterHandler ¶
type UpdateMeterHandler = httptransport.HandlerWithArgs[UpdateMeterRequest, UpdateMeterResponse, string]
type UpdateMeterRequest ¶
type UpdateMeterRequest = struct {
api.MeterUpdate
// contains filtered or unexported fields
}
type UpdateMeterResponse ¶
Click to show internal directories.
Click to hide internal directories.