Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
func NewMetrics ¶
func NewMetrics() *Metrics
type Options ¶
type Options struct { GRPCAddress string `long:"grpc-address" description:"API gRPC listen address" default:"0.0.0.0"` GRPCPort uint `long:"grpc-port" description:"API gRPC listen port" default:"0"` HTTPAddress string `long:"http-address" description:"API HTTP listen address" default:"0.0.0.0"` HTTPPort uint `long:"http-port" description:"API HTTP listen port" default:"0"` MaxMsgSize int `long:"max-msg-size" description:"Max message size in bytes (default 10Mb)" default:"1250000"` }
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) HTTPListenAddr ¶
func (*Server) HTTPListenPort ¶
type TelemetryInterceptor ¶
type TelemetryInterceptor struct {
// contains filtered or unexported fields
}
func NewTelemetryInterceptor ¶
func NewTelemetryInterceptor(log *zap.Logger, metrics *Metrics) (*TelemetryInterceptor, error)
func (*TelemetryInterceptor) Stream ¶
func (ti *TelemetryInterceptor) Stream() grpc.StreamServerInterceptor
func (*TelemetryInterceptor) Unary ¶
func (ti *TelemetryInterceptor) Unary() grpc.UnaryServerInterceptor
Click to show internal directories.
Click to hide internal directories.