serverutils

package module

Go to main page

Versions in this module

v1

v1.0.1

Oct 23, 2025

v1.0.0

Sep 30, 2025

v0

v0.1.1

Sep 30, 2025

v0.1.0

Jun 23, 2025

Changes in this version

+ type Connection struct

+ Edges []Edge[T]

+ PageInfo PageInfo

+ TotalCount int

+ func BuildLimitOffsetConnection[T Node](items []T, offset, limit, total int) Connection[T]

+ func BuildPageNumberConnection[T Node](items []T, currentPage, pageSize, total int) Connection[T]

+ type Edge struct

+ Cursor string

+ Node T

+ type Node interface

+ NodeID func() string

+ type PageInfo struct

+ EndCursor string

+ HasNextPage bool

+ HasPreviousPage bool

+ StartCursor string

+ type PaginationInput struct

+ After *string

+ Before *string

+ First *int

+ Last *int

+ func (p *PaginationInput) Validate() error

+ func (p PaginationInput) IsBackward() bool

+ func (p PaginationInput) IsForward() bool

+ func (p PaginationInput) ToLimitOffset() (limit, offset int, err error)

+ func (p PaginationInput) ToPageNumber() (pageSize, page int, err error)

v0.0.9

Jul 12, 2023

Changes in this version

+ const TraceSampleRateEnvVarName

v0.0.8

Jul 12, 2023

v0.0.7

Aug 3, 2022

v0.0.6

Aug 31, 2021

v0.0.5

Aug 31, 2021

Changes in this version

+ func NewImportPlugin(earlySources, lateSources []*ast.Source, generate bool, path string) plugin.Plugin

+ type ImportPlugin struct

+ func (m *ImportPlugin) CreateSourceDirectory(path string) string

+ func (m *ImportPlugin) GenerateSchemaFile(dir string, source *ast.Source)

+ func (m *ImportPlugin) InjectSourceEarly() *ast.Source

+ func (m *ImportPlugin) InjectSourceLate(schema *ast.Schema) *ast.Source

+ func (m *ImportPlugin) MutateConfig(cfg *config.Config) error

+ func (m *ImportPlugin) Name() string

v0.0.4

Aug 9, 2021

v0.0.3

Jul 14, 2021

Changes in this version

+ func InitOtelSDK(ctx context.Context, serviceName string) (*tracesdk.TracerProvider, error)

v0.0.2

Jun 21, 2021

Changes in this version

+ const AppName

+ const AppVersion

+ const DSNEnvVarName

+ const DebugEnvVarName

+ const DefaultPort

+ const DemoEnv

+ const Environment

+ const GoogleCloudProjectIDEnvVarName

+ const IsRunningTestsEnvVarName

+ const PortEnvVarName

+ const ProdEnv

+ const ResolverFailureValue

+ const ResolverSuccessValue

+ const StagingEnv

+ const TestingEnv

+ var DefaultServiceViews = []*view.View

+ var GraphqlResolverCountView = &view.View

+ var GraphqlResolverLatency = stats.Float64("graphql_resolver_latency", ...)

+ var GraphqlResolverLatencyView = &view.View

+ var HTTPMethod = tag.MustNewKey("http.method")

+ var HTTPPath = tag.MustNewKey("http.path")

+ var HTTPRequestLatency = stats.Float64("http_request_latency", ...)

+ var HTTPStatusCode = tag.MustNewKey("http.status")

+ var LatencyBounds = GenerateLatencyBounds(60000, 200)

+ var ResolverErrorMessage = tag.MustNewKey("resolver.error")

+ var ResolverName = tag.MustNewKey("resolver.name")

+ var ResolverStatus = tag.MustNewKey("resolver.status")

+ var ServerRequestCountView = &view.View

+ var ServerRequestLatencyView = &view.View

+ func BoolEnv(envVarName string) bool

+ func CloseStackDriverErrorClient(errorClient *errorreporting.Client)

+ func CloseStackDriverLoggingClient(loggingClient *logging.Client)

+ func ConvertStringToInt(w http.ResponseWriter, val string) int

+ func CustomHTTPRequestMetricsMiddleware() func(http.Handler) http.Handler

+ func DecodeJSONToTargetStruct(w http.ResponseWriter, r *http.Request, targetStruct interface{})

+ func EnableStatsAndTraceExporters(ctx context.Context, service string) (func(), error)

+ func ErrorMap(err error) map[string]string

+ func GenerateLatencyBounds(max, interval int) []float64

+ func GetEnvVar(envVarName string) (string, error)

+ func GetRunningEnvironment() string

+ func HealthStatusCheck(w http.ResponseWriter, r *http.Request)

+ func IsDebug() bool

+ func IsRunningTests() bool

+ func ListenAddress() string

+ func LogStartupError(ctx context.Context, err error)

+ func MetricsCollectorService(serviceName string) string

+ func MustGetEnvVar(envVarName string) string

+ func RecordGraphqlResolverMetrics(ctx context.Context, startTime time.Time, name string, e error)

+ func RecordHTTPStats(w *MetricsResponseWriter, r *http.Request)

+ func RequestDebugMiddleware() func(http.Handler) http.Handler

+ func Sentry() error

+ func StackDriver(ctx context.Context) *errorreporting.Client

+ func StartTestServer(ctx context.Context, prepareServer PrepareServer, allowedOrigins []string) (*http.Server, string, error)

+ func WriteJSONResponse(w http.ResponseWriter, source interface{}, status int)

+ type ErrorResponseWriter struct

+ func NewErrorResponseWriter(err error) *ErrorResponseWriter

+ func (w *ErrorResponseWriter) Header() http.Header

+ func (w *ErrorResponseWriter) Write([]byte) (int, error)

+ func (w *ErrorResponseWriter) WriteHeader(statusCode int)

+ type MetricsResponseWriter struct

+ StartTime time.Time

+ StatusCode int

+ func NewMetricsResponseWriter(w http.ResponseWriter) *MetricsResponseWriter

+ func (m *MetricsResponseWriter) Header() http.Header

+ func (m *MetricsResponseWriter) Write(b []byte) (int, error)

+ func (m *MetricsResponseWriter) WriteHeader(code int)

+ type PrepareServer func(ctx context.Context, port int, allowedOrigins []string) *http.Server

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL