rpcserver

Documentation

Index

• Variables
• type RPCServer
  • func NewRPCServer(ctx context.Context, cancel context.CancelFunc, registerFunc RegisterFunc, ...) (*RPCServer, error)
  • func (rpcSrv *RPCServer) Serve() error
• type RegisterFunc

Variables

var Kaep = keepalive.EnforcementPolicy{
	MinTime:             5 * time.Second,
	PermitWithoutStream: true,
}

var Kasp = keepalive.ServerParameters{
	MaxConnectionIdle:     30 * time.Second,
	MaxConnectionAge:      30 * time.Second,
	MaxConnectionAgeGrace: 5 * time.Second,
	Time:                  5 * time.Second,
	Timeout:               3 * time.Second,
}

resource --> driver是短连接,以下参数可有可无

Types

type RPCServer

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

func NewRPCServer

func NewRPCServer(
	ctx context.Context,
	cancel context.CancelFunc,
	registerFunc RegisterFunc,
	rpcConfig config.RPCConfig,
	lc commons.TedgeLogger) (*RPCServer, error)

func (*RPCServer) Serve

func (rpcSrv *RPCServer) Serve() error

type RegisterFunc

type RegisterFunc func(serve *grpc.Server)