v0.0.26 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2022 License: BSD-3-Clause Imports: 39 Imported by: 0



Package server provides functions for goma servers.



View Source
const (
	// same as default sampler
	DefaultTraceFraction = 1e-4

	// trace API limit is 4800/minutes.
	// 4800/60/(total number of replicas in the project)
	DefaultTraceQPS = 0.05


This section is empty.


func ClusterName

func ClusterName(ctx context.Context) string

ClusterName returns cluster name where server is running on.

func DefaultDialOption

func DefaultDialOption() []grpc.DialOption

DefaultDialOption is default dial option to record opencensus stats and traces.

func DialContext

func DialContext(ctx context.Context, addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

DialContext dials to addr with default dial options.

func Flush

func Flush()

Flush flushes opencensus data.

func GC

func GC(ctx context.Context) int64

GC runs garbage-collector and reports latest measured resident memory size in bytes.

func HostName

func HostName(ctx context.Context) string

HostName returns hostname. in k8s, it is podname.

func Init

func Init(ctx context.Context, projectID, name string) error

Init initializes opencensus instrumentations, and error reporter. If projectID is not empty, it registers stackdriver exporter for the project. It also calls SetupHTTPClient.

func MemoryLimit

func MemoryLimit() (int64, error)

MemoryLimit returns server memory limit, set by cgroup.

func NewHTTP

func NewHTTP(port int, handler http.Handler) *http.Server

NewHTTP creates http server.

func NewLimitedSampler

func NewLimitedSampler(fraction, qps float64) trace.Sampler

NewLimitedSampler returns trace sampler limited by fraction and qps.

func ProjectID

func ProjectID(ctx context.Context) string

ProjectID returns current project id.

func ResidentMemorySize

func ResidentMemorySize() int64

ResidentMemorySize reports latest measured resident memory size in bytes.

func Run

func Run(ctx context.Context, servers ...Server)

Run runs servers. This is typically invoked as the last statement in the server's main function.

func SetupHTTPClient

func SetupHTTPClient()

SetupHTTPClient sets up http default client to monitor by opencensus.


type GRPC

type GRPC struct {

GRPC represents grpc server.

func NewGRPC

func NewGRPC(port int, opts ...grpc.ServerOption) (GRPC, error)

NewGRPC creates grpc server listening on port.

func (GRPC) ListenAndServe

func (g GRPC) ListenAndServe() error

ListenAndServe listens on Listener and handles requests with Server.

func (GRPC) Shutdown

func (g GRPC) Shutdown(ctx context.Context) error

Shutdown gracefully shuts down the server.

type Server

type Server interface {
	// ListenAndServe listens and then serve to handle requests on incoming
	// connections.
	ListenAndServe() error

	// Shutdown gracefully shuts down the server.
	Shutdown(context.Context) error

Server is interface to control server.

func NewHTTPS

func NewHTTPS(hs *http.Server, certFile, keyFile string) Server

NewHTTPS creates https server.


Path Synopsis
Package healthz provides /healthz for grpc server.
Package healthz provides /healthz for grpc server.

Jump to

Keyboard shortcuts

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