grpc

Documentation

Overview

Package grpc is a layer for interacting with gRPC protocol.

Index

• func Dial(config ConnConfig) (*grpc.ClientConn, error)
• type ConnConfig
• type Server
  • func NewServer(config ServerConfig, ratelimiter ratelimit.Limiter) (*Server, error)
  • func (s *Server) ListenAndServe() error
• type ServerConfig

Functions

func Dial

func Dial(config ConnConfig) (*grpc.ClientConn, error)

Types

type ConnConfig

type ConnConfig struct {
	Host string `envconfig:"GRPC_HOST" default:"localhost"`
	Port string `envconfig:"GRPC_PORT" default:"8000"`
}

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(config ServerConfig, ratelimiter ratelimit.Limiter) (*Server, error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

type ServerConfig

type ServerConfig struct {
	Host string `envconfig:"GRPC_HOST" default:"0.0.0.0"`
	Port string `envconfig:"GRPC_PORT" default:"8000"`
	RPS  int    `envconfig:"RPS"`
}