Documentation
¶
Index ¶
- func ToAPIMeter(m meter.Meter) api.Meter
- func ToAPIMeterQueryResult(apiParams api.QueryMeterParams, rows []meter.MeterQueryRow) api.MeterQueryResult
- func ToAPIMeterQueryRow(row meter.MeterQueryRow) api.MeterQueryRow
- func ToAPIMeterQueryRowList(rows []meter.MeterQueryRow) []api.MeterQueryRow
- func ToQueryMeterParams(m meter.Meter, apiParams api.QueryMeterParams) (streaming.QueryParams, error)
- 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 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 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(apiParams api.QueryMeterParams, 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 ToQueryMeterParams ¶
func ToQueryMeterParams(m meter.Meter, apiParams api.QueryMeterParams) (streaming.QueryParams, error)
ToQueryMeterParams converts a api.QueryMeterParams to a streaming.QueryParams.
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, meterService meter.ManageService, streaming streaming.Connector, options ...httptransport.HandlerOption, ) Handler
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 ListSubjectsParams struct {
IdOrSlug string
}
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
QueryMeterCSV() QueryMeterCSVHandler
ListSubjects() ListSubjectsHandler
}
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) QueryMeterCSVResponse
type QueryMeterHandler ¶
type QueryMeterHandler httptransport.HandlerWithArgs[QueryMeterRequest, QueryMeterResponse, QueryMeterParams]
type QueryMeterParams ¶
type QueryMeterParams struct {
api.QueryMeterParams
IdOrSlug string
}
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.