grpc

Documentation

Index

• Constants
• func GetPeerAddressFromStreamContext(ctx context.Context) string
• func GetPeerHostFromStreamContext(ctx context.Context) string
• type AcceptConnectionConfig
• type AcceptLimiter
  • func NewAcceptLimiter(config AcceptConnectionConfig) (*AcceptLimiter, error)
  • func (a *AcceptLimiter) CloseConnection()
  • func (a *AcceptLimiter) CouldHandleConnection() bool
• type ConnectionManager
  • func NewConnectionManager(network, address string, acceptConnectionConfig AcceptConnectionConfig) (*ConnectionManager, error)
  • func (c *ConnectionManager) Accept() (net.Conn, error)
• type ConnectionWrapper
  • func (c *ConnectionWrapper) Close() error
  • func (c *ConnectionWrapper) CloseNotify()
• type OriginalData
  • func NewOriginalData(data []byte) *OriginalData
• type Server
  • func (s *Server) Close() error
  • func (s *Server) DefaultConfig() string
  • func (s *Server) Description() string
  • func (s *Server) GetServer() interface{}
  • func (s *Server) Name() string
  • func (s *Server) Prepare() error
  • func (s *Server) ShowName() string
  • func (s *Server) Start() error

Constants

const (
	Name     = "grpc-server"
	ShowName = "GRPC Server"
)

const CPUUpdateInterval = time.Second * 5

Functions

func GetPeerAddressFromStreamContext

func GetPeerAddressFromStreamContext(ctx context.Context) string

func GetPeerHostFromStreamContext

func GetPeerHostFromStreamContext(ctx context.Context) string

Types

type AcceptConnectionConfig

type AcceptConnectionConfig struct {
	CPUUtilization  float64 `mapstructure:"cpu_utilization"`  // The max CPU utilization limit
	ConnectionCount int32   `mapstructure:"connection_count"` // The max connection count
}

type AcceptLimiter

type AcceptLimiter struct {
	Config           AcceptConnectionConfig
	ActiveConnection int32
	CurrentCPU       float64

	telemetry.Counter
	// contains filtered or unexported fields
}

func NewAcceptLimiter

func NewAcceptLimiter(config AcceptConnectionConfig) (*AcceptLimiter, error)

func (*AcceptLimiter) CloseConnection

func (a *AcceptLimiter) CloseConnection()

func (*AcceptLimiter) CouldHandleConnection

func (a *AcceptLimiter) CouldHandleConnection() bool

type ConnectionManager

type ConnectionManager struct {
	net.Listener
	// contains filtered or unexported fields
}

func NewConnectionManager

func NewConnectionManager(network, address string, acceptConnectionConfig AcceptConnectionConfig) (*ConnectionManager, error)

func (*ConnectionManager) Accept

func (c *ConnectionManager) Accept() (net.Conn, error)

type ConnectionWrapper

type ConnectionWrapper struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*ConnectionWrapper) Close

func (c *ConnectionWrapper) Close() error

func (*ConnectionWrapper) CloseNotify

func (c *ConnectionWrapper) CloseNotify()

type OriginalData

type OriginalData struct {
	Content []byte
}

OriginalData is keep binary Content

func NewOriginalData

func NewOriginalData(data []byte) *OriginalData

type Server

type Server struct {
	config.CommonFields
	Address              string `mapstructure:"address"`                // The address of grpc server.
	Network              string `mapstructure:"network"`                // The network of grpc.
	MaxRecvMsgSize       int    `mapstructure:"max_recv_msg_size"`      // The max size of the received log.
	MaxConcurrentStreams uint32 `mapstructure:"max_concurrent_streams"` // The max concurrent stream channels.
	TLSCertFile          string `mapstructure:"tls_cert_file"`          // The TLS cert file path.
	TLSKeyFile           string `mapstructure:"tls_key_file"`           // The TLS key file path.

	AcceptLimit AcceptConnectionConfig `mapstructure:"accept_limit"` // To Accept Connection Limiter when reach the resource
	// contains filtered or unexported fields
}

func (*Server) Close

func (s *Server) Close() error

func (*Server) DefaultConfig

func (s *Server) DefaultConfig() string

func (*Server) Description

func (s *Server) Description() string

func (*Server) GetServer

func (s *Server) GetServer() interface{}

func (*Server) Name

func (s *Server) Name() string

func (*Server) Prepare

func (s *Server) Prepare() error

func (*Server) ShowName

func (s *Server) ShowName() string

func (*Server) Start

func (s *Server) Start() error