internal

Documentation

Index

• type Bench
  • func NewBench(b *testing.B) *Bench
  • func (bench *Bench) HandleConn(context.Context, stats.ConnStats)
  • func (bench *Bench) HandleRPC(ctx context.Context, s stats.RPCStats)
  • func (bench *Bench) TagConn(ctx context.Context, connTagInfo *stats.ConnTagInfo) context.Context
  • func (bench *Bench) TagRPC(ctx context.Context, rpcTagInfo *stats.RPCTagInfo) context.Context
• type GinGrpcOption
  • func (option *GinGrpcOption) GetHandler(key string) (*gingrpc.Handler, bool)
  • func (option *GinGrpcOption) PathToGrpcService(c *gin.Context) string
  • func (option *GinGrpcOption) RemoveGrpcHandler(key string)
  • func (option *GinGrpcOption) SetHandler(key string, handler *gingrpc.Handler)
• type GrpcRouteOption
  • func (option *GrpcRouteOption) GetHandler(key string) (grpcroute.HandleProto, bool)
  • func (option *GrpcRouteOption) RemoveHandler(key string)
  • func (option *GrpcRouteOption) SetHandler(key string, h grpcroute.HandleProto)
• type GrpcRouteOptionStream
  • func (option *GrpcRouteOptionStream) GetHandler(key string) (grpcroute.HandleProtoStream, bool)
  • func (option *GrpcRouteOptionStream) RemoveHandler(key string)
  • func (option *GrpcRouteOptionStream) SetHandler(key string, h grpcroute.HandleProtoStream)
• type Network
  • func GetSingleInst() *Network
  • func (network *Network) Benchmark(b *testing.B, method string, req, resp interface{})
  • func (network *Network) CoreChanged()
  • func (network *Network) HandleProto(pkg, service, method string, desc *grpc.ServiceDesc, handler gingrpc.Handler)
  • func (network *Network) ListenProto(pkg, service, method string, desc *grpc.ServiceDesc, ...)
  • func (network *Network) ModuleAfterRestart()
  • func (network *Network) ModuleAfterRun(method string)
  • func (network *Network) ModuleBeforeRun(method string)
  • func (network *Network) ModuleConstruct()
  • func (network *Network) ModuleDestruct()
  • func (network *Network) ModuleLock() singleinstmodule.ModuleCore
  • func (network *Network) ModuleRestart() bool
  • func (network *Network) ModuleRunStartup()
  • func (network *Network) ModuleShutdown()
  • func (network *Network) ModuleUnlock()
  • func (network *Network) ModuleUnlockBenchmark(b *testing.B, method string, req, resp interface{})
  • func (network *Network) NoFound(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
  • func (network *Network) NoFoundStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (network *Network) Recreate() error
  • func (network *Network) Start()
  • func (network *Network) Stop()
  • func (network *Network) StopHandleProto(pkg, service, method string)
  • func (network *Network) StopListenProto(pkg, service, method string)

Types

type Bench

type Bench struct {
	MockCh chan struct{}
	// contains filtered or unexported fields
}

func NewBench

func NewBench(b *testing.B) *Bench

func (*Bench) HandleConn

func (bench *Bench) HandleConn(context.Context, stats.ConnStats)

func (*Bench) HandleRPC

func (bench *Bench) HandleRPC(ctx context.Context, s stats.RPCStats)

func (*Bench) TagConn

func (bench *Bench) TagConn(ctx context.Context, connTagInfo *stats.ConnTagInfo) context.Context

func (*Bench) TagRPC

func (bench *Bench) TagRPC(ctx context.Context, rpcTagInfo *stats.RPCTagInfo) context.Context

type GinGrpcOption

type GinGrpcOption struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*GinGrpcOption) GetHandler

func (option *GinGrpcOption) GetHandler(key string) (*gingrpc.Handler, bool)

func (*GinGrpcOption) PathToGrpcService

func (option *GinGrpcOption) PathToGrpcService(c *gin.Context) string

func (*GinGrpcOption) RemoveGrpcHandler

func (option *GinGrpcOption) RemoveGrpcHandler(key string)

func (*GinGrpcOption) SetHandler

func (option *GinGrpcOption) SetHandler(key string, handler *gingrpc.Handler)

type GrpcRouteOption

type GrpcRouteOption struct {
	Handlers map[string]grpcroute.HandleProto
	sync.RWMutex
}

func (*GrpcRouteOption) GetHandler

func (option *GrpcRouteOption) GetHandler(key string) (grpcroute.HandleProto, bool)

func (*GrpcRouteOption) RemoveHandler

func (option *GrpcRouteOption) RemoveHandler(key string)

func (*GrpcRouteOption) SetHandler

func (option *GrpcRouteOption) SetHandler(key string, h grpcroute.HandleProto)

type GrpcRouteOptionStream

type GrpcRouteOptionStream struct {
	Handlers map[string]grpcroute.HandleProtoStream
	sync.RWMutex
}

func (*GrpcRouteOptionStream) GetHandler

func (option *GrpcRouteOptionStream) GetHandler(key string) (grpcroute.HandleProtoStream, bool)

func (*GrpcRouteOptionStream) RemoveHandler

func (option *GrpcRouteOptionStream) RemoveHandler(key string)

func (*GrpcRouteOptionStream) SetHandler

func (option *GrpcRouteOptionStream) SetHandler(key string, h grpcroute.HandleProtoStream)

type Network

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

func GetSingleInst

func GetSingleInst() *Network

func (*Network) Benchmark

func (network *Network) Benchmark(b *testing.B, method string, req, resp interface{})

func (*Network) CoreChanged

func (network *Network) CoreChanged()

func (*Network) HandleProto

func (network *Network) HandleProto(pkg, service, method string, desc *grpc.ServiceDesc, handler gingrpc.Handler)

func (*Network) ListenProto

func (network *Network) ListenProto(pkg, service, method string, desc *grpc.ServiceDesc, listener func(grpc.ServerStream) error)

func (*Network) ModuleAfterRestart

func (network *Network) ModuleAfterRestart()

func (*Network) ModuleAfterRun

func (network *Network) ModuleAfterRun(method string)

func (*Network) ModuleBeforeRun

func (network *Network) ModuleBeforeRun(method string)

func (*Network) ModuleConstruct

func (network *Network) ModuleConstruct()

func (*Network) ModuleDestruct

func (network *Network) ModuleDestruct()

func (*Network) ModuleLock

func (network *Network) ModuleLock() singleinstmodule.ModuleCore

func (*Network) ModuleRestart

func (network *Network) ModuleRestart() bool

func (*Network) ModuleRunStartup

func (network *Network) ModuleRunStartup()

func (*Network) ModuleShutdown

func (network *Network) ModuleShutdown()

func (*Network) ModuleUnlock

func (network *Network) ModuleUnlock()

func (*Network) ModuleUnlockBenchmark

func (network *Network) ModuleUnlockBenchmark(b *testing.B, method string, req, resp interface{})

func (*Network) NoFound

func (network *Network) NoFound(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

func (*Network) NoFoundStream

func (network *Network) NoFoundStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*Network) Recreate

func (network *Network) Recreate() error

func (*Network) Start

func (network *Network) Start()

func (*Network) Stop

func (network *Network) Stop()

func (*Network) StopHandleProto

func (network *Network) StopHandleProto(pkg, service, method string)

func (*Network) StopListenProto

func (network *Network) StopListenProto(pkg, service, method string)