Documentation
¶
Index ¶
- Variables
- type GRPCServer
- func (s *GRPCServer) GetUsageByMeta(ctx context.Context, req *pb.GetUsageByMetaRequest) (*pb.GetUsageByMetaResponse, error)
- func (s *GRPCServer) GetUsageSummary(ctx context.Context, req *pb.GetUsageSummaryRequest) (*pb.GetUsageSummaryResponse, error)
- func (s *GRPCServer) RecordUsageEvent(ctx context.Context, req *pb.RecordUsageEventRequest) (*pb.RecordUsageEventResponse, error)
- func (s *GRPCServer) RecordUsageEvents(ctx context.Context, req *pb.RecordUsageEventsRequest) (*pb.RecordUsageEventsResponse, error)
- func (s *GRPCServer) Start() error
- func (s *GRPCServer) Stop()
- type HTTPServer
Constants ¶
This section is empty.
Variables ¶
var Version = "dev"
Health check handlers Version is the build's release version, reported by /healthz.
Functions ¶
This section is empty.
Types ¶
type GRPCServer ¶
type GRPCServer struct {
pb.UnimplementedUsageServiceServer
// contains filtered or unexported fields
}
GRPCServer wraps the gRPC server implementation
func NewGRPCServer ¶
func NewGRPCServer(repo *repository.Repository, addr string) *GRPCServer
NewGRPCServer creates a new gRPC server with a repository.
func NewGRPCServerWithService ¶
func NewGRPCServerWithService(usageService *service.UsageService, addr string, verifier *auth.Verifier) *GRPCServer
NewGRPCServerWithService creates a new gRPC server with an existing usage service. A nil or empty verifier serves without authentication.
func (*GRPCServer) GetUsageByMeta ¶
func (s *GRPCServer) GetUsageByMeta(ctx context.Context, req *pb.GetUsageByMetaRequest) (*pb.GetUsageByMetaResponse, error)
GetUsageByMeta returns usage aggregated over events carrying a meta key/value (e.g. one batch job), split by an optional second meta key plus vendor and model.
func (*GRPCServer) GetUsageSummary ¶
func (s *GRPCServer) GetUsageSummary(ctx context.Context, req *pb.GetUsageSummaryRequest) (*pb.GetUsageSummaryResponse, error)
GetUsageSummary returns aggregated usage statistics
func (*GRPCServer) RecordUsageEvent ¶
func (s *GRPCServer) RecordUsageEvent(ctx context.Context, req *pb.RecordUsageEventRequest) (*pb.RecordUsageEventResponse, error)
RecordUsageEvent records a single usage event
func (*GRPCServer) RecordUsageEvents ¶
func (s *GRPCServer) RecordUsageEvents(ctx context.Context, req *pb.RecordUsageEventsRequest) (*pb.RecordUsageEventsResponse, error)
RecordUsageEvents records multiple usage events in a batch
type HTTPServer ¶
type HTTPServer struct {
// contains filtered or unexported fields
}
HTTPServer wraps the HTTP server implementation
func NewHTTPServer ¶
func NewHTTPServer(repo *repository.Repository, addr string) *HTTPServer
NewHTTPServer creates a new HTTP server
func NewHTTPServerWithService ¶
func NewHTTPServerWithService(usageService *service.UsageService, repo *repository.Repository, addr string, verifier *auth.Verifier) *HTTPServer
NewHTTPServerWithService creates a new HTTP server with an existing usage service. A nil or empty verifier serves without authentication.
Source Files