grpc

Documentation

Index

• type Config
• type PanicServer
  • func (s *PanicServer) Panic(ctx context.Context, req *pb.PanicRequest) (*pb.PanicResponse, error)
• type Server
  • func NewMockGrpcServer() *Server
  • func NewServer(config *Config, logger *zap.Logger) (*Server, error)
  • func (s *Server) ListenAndServe() *grpc.Server
• type VersionServer
  • func (s *VersionServer) Version(ctx context.Context, req *pb.VersionRequest) (*pb.VersionResponse, error)

Types

type Config

type Config struct {
	Port        int    `mapstructure:"grpc-port"`
	ServiceName string `mapstructure:"grpc-service-name"`

	BackendURL []string `mapstructure:"backend-url"`
	UILogo     string   `mapstructure:"ui-logo"`
	UIMessage  string   `mapstructure:"ui-message"`
	UIColor    string   `mapstructure:"ui-color"`
	UIPath     string   `mapstructure:"ui-path"`
	DataPath   string   `mapstructure:"data-path"`
	ConfigPath string   `mapstructure:"config-path"`
	CertPath   string   `mapstructure:"cert-path"`
	Host       string   `mapstructure:"host"`
	//Port                  string        `mapstructure:"port"`
	SecurePort      string `mapstructure:"secure-port"`
	PortMetrics     int    `mapstructure:"port-metrics"`
	Hostname        string `mapstructure:"hostname"`
	H2C             bool   `mapstructure:"h2c"`
	RandomDelay     bool   `mapstructure:"random-delay"`
	RandomDelayUnit string `mapstructure:"random-delay-unit"`
	RandomDelayMin  int    `mapstructure:"random-delay-min"`
	RandomDelayMax  int    `mapstructure:"random-delay-max"`
	RandomError     bool   `mapstructure:"random-error"`
	Unhealthy       bool   `mapstructure:"unhealthy"`
	Unready         bool   `mapstructure:"unready"`
	JWTSecret       string `mapstructure:"jwt-secret"`
	CacheServer     string `mapstructure:"cache-server"`
}

type PanicServer

type PanicServer struct {
	pb.UnimplementedPanicServiceServer
	// contains filtered or unexported fields
}

func (*PanicServer) Panic

func (s *PanicServer) Panic(ctx context.Context, req *pb.PanicRequest) (*pb.PanicResponse, error)

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewMockGrpcServer

func NewMockGrpcServer() *Server

func NewServer

func NewServer(config *Config, logger *zap.Logger) (*Server, error)

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() *grpc.Server

type VersionServer

type VersionServer struct {
	pb.UnimplementedVersionServiceServer
	// contains filtered or unexported fields
}

func (*VersionServer) Version

func (s *VersionServer) Version(ctx context.Context, req *pb.VersionRequest) (*pb.VersionResponse, error)