server

Documentation

Index

• Constants
• type BaseDrpcServer
  • func NewBaseDrpcServer() *BaseDrpcServer
  • func (s *BaseDrpcServer) Close(ctx context.Context) (err error)
  • func (s *BaseDrpcServer) ListenAddrs() (addrs []net.Addr)
  • func (s *BaseDrpcServer) Run(ctx context.Context, params Params) (err error)
• type DRPCHandlerWrapper
• type DRPCServer
  • func New() DRPCServer
• type Params

Constants

const CName = "common.net.drpcserver"

Types

type BaseDrpcServer

type BaseDrpcServer struct {
	*drpcmux.Mux
	// contains filtered or unexported fields
}

func NewBaseDrpcServer

func NewBaseDrpcServer() *BaseDrpcServer

func (*BaseDrpcServer) Close

func (s *BaseDrpcServer) Close(ctx context.Context) (err error)

func (*BaseDrpcServer) ListenAddrs

func (s *BaseDrpcServer) ListenAddrs() (addrs []net.Addr)

func (*BaseDrpcServer) Run

func (s *BaseDrpcServer) Run(ctx context.Context, params Params) (err error)

type DRPCHandlerWrapper

type DRPCHandlerWrapper func(handler drpc.Handler) drpc.Handler

type DRPCServer

type DRPCServer interface {
	app.ComponentRunnable
	drpc.Mux
}

func New

func New() DRPCServer

type Params

type Params struct {
	BufferSizeMb  int
	ListenAddrs   []string
	Wrapper       DRPCHandlerWrapper
	TimeoutMillis int
	Handshake     func(conn net.Conn) (cCtx context.Context, sc sec.SecureConn, err error)
}