grpc

Documentation

Index

• 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, initializers ...GrpcInitializer) *grpcServer
• func StreamFaultInjector(s *faults.Set) grpc.StreamServerInterceptor
• func UnaryFaultInjector(s *faults.Set) grpc.UnaryServerInterceptor
• type GrpcInitializer

Functions

func AsStatusError

func AsStatusError(err error) error

func NewGatewayService

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

func NewGrpcService

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

func StreamFaultInjector

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

func UnaryFaultInjector

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

Types

type GrpcInitializer

type GrpcInitializer func(context.Context, *grpc.Server, *registry.Registry, ent.EntClient) error