gateway

package
v0.0.0-...-a4d05e0 Latest Latest
Warning

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

Go to latest
Published: May 11, 2023 License: MIT Imports: 22 Imported by: 0

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 New

func New(ctx context.Context, messagev1 messagev1.MessageApiServer, metrics *Metrics, opts *Options) (*Server, error)

func (*Server) Close

func (s *Server) Close()

func (*Server) HTTPListenAddr

func (s *Server) HTTPListenAddr() string

func (*Server) HTTPListenPort

func (s *Server) HTTPListenPort() uint

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 (*TelemetryInterceptor) Unary

Jump to

Keyboard shortcuts

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