core

Documentation

Index

• Variables
• type GraphAPITokenClaims
• type MetricsService
  • func NewMetricsService(logger *zap.Logger, chConn clickhouse.Conn) *MetricsService
  • func (s *MetricsService) PublishGraphQLMetrics(ctx context.Context, ...) (*connect.Response[graphqlmetricsv1.PublishOperationCoverageReportResponse], ...)
  • func (s *MetricsService) Shutdown(deadline time.Duration)
• type Option
  • func WithJwtSecret(secret []byte) Option
  • func WithListenAddr(addr string) Option
  • func WithLogger(logger *zap.Logger) Option
• type Server
  • func NewServer(metricsService graphqlmetricsv1connect.GraphQLMetricsServiceHandler, ...) *Server
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start() error

Variables

var Version = "dev"

Version set by the build system.

Types

type GraphAPITokenClaims

type GraphAPITokenClaims struct {
	OrganizationID   string `json:"organization_id"`
	FederatedGraphID string `json:"federated_graph_id"`
	jwt.RegisteredClaims
}

type MetricsService

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

func NewMetricsService

func NewMetricsService(logger *zap.Logger, chConn clickhouse.Conn) *MetricsService

NewMetricsService creates a new metrics service

func (*MetricsService) PublishGraphQLMetrics

func (s *MetricsService) PublishGraphQLMetrics(
	ctx context.Context,
	req *connect.Request[graphqlmetricsv1.PublishGraphQLRequestMetricsRequest],
) (*connect.Response[graphqlmetricsv1.PublishOperationCoverageReportResponse], error)

func (*MetricsService) Shutdown

func (s *MetricsService) Shutdown(deadline time.Duration)

type Option

type Option func(s *Server)

Option defines the method to customize Server.

func WithJwtSecret

func WithJwtSecret(secret []byte) Option

func WithListenAddr

func WithListenAddr(addr string) Option

func WithLogger

func WithLogger(logger *zap.Logger) Option

type Server

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

func NewServer

func NewServer(metricsService graphqlmetricsv1connect.GraphQLMetricsServiceHandler, opts ...Option) *Server

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Start

func (s *Server) Start() error