grpc

Documentation

Index

• Variables
• func AsStatusError(err error) error
• func NewGatewayService(name string, port, offset int, routes gin.IRoutes, paths []string, ...) *gatewayService
• func NewGrpcService(port, offset int, opts []grpc.ServerOption, faults *faults.Set, ...) *grpcServer
• func StreamFaultInjector(s *faults.Set) grpc.StreamServerInterceptor
• func UnaryFaultInjector(s *faults.Set) grpc.UnaryServerInterceptor
• func WrapError(err error, format string, args ...interface{}) error
• type GrpcInitializer

Variables

var SwaggerFS embed.FS

Functions

func AsStatusError

func AsStatusError(err error) error

func NewGatewayService

func NewGatewayService(
	name string,
	port, offset int,
	routes gin.IRoutes,
	paths []string,
	initHandlers func(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error,
) *gatewayService

func NewGrpcService

func NewGrpcService(
	port, offset int,
	opts []grpc.ServerOption,
	faults *faults.Set,
	initializers ...GrpcInitializer,
) *grpcServer

func StreamFaultInjector

func StreamFaultInjector(s *faults.Set) grpc.StreamServerInterceptor

func UnaryFaultInjector

func UnaryFaultInjector(s *faults.Set) grpc.UnaryServerInterceptor

func WrapError

func WrapError(err error, format string, args ...interface{}) error

workaround for grpc not supporting error unwrapping. if err seems to be a grpc status error, returns a new error with the same code & details, but a wrapped description. Otherwise wraps err normally. upstream: https://github.com/grpc/grpc-go/issues/2934

Types

type GrpcInitializer

type GrpcInitializer func(context.Context, *grpc.Server, *ent.Client) error