conn

Documentation

Index

• type GrpcServer
  • func NewGrpcServer(ctx *gctx.GrpcSrvContext) *GrpcServer
  • func (srv *GrpcServer) Disconnect(ctx context.Context, req *conn.DisconnectReq) (*conn.DisconnectResp, error)
  • func (s *GrpcServer) GracefulStop() error
  • func (srv *GrpcServer) Notify(ctx context.Context, req *conn.NotifyReq) (*conn.NotifyResp, error)
  • func (s *GrpcServer) Serve(lis net.Listener) error
  • func (s *GrpcServer) Stop() error
• type MQTTServer
  • func NewMQTTServer(ctx *context.MqttSrvContext) *MQTTServer
  • func (s *MQTTServer) GracefulStop() error
  • func (s *MQTTServer) Serve(l net.Listener) error
  • func (s *MQTTServer) Stop() error

Types

type GrpcServer

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

func NewGrpcServer

func NewGrpcServer(ctx *gctx.GrpcSrvContext) *GrpcServer

func (*GrpcServer) Disconnect

func (srv *GrpcServer) Disconnect(ctx context.Context, req *conn.DisconnectReq) (*conn.DisconnectResp, error)

func (*GrpcServer) GracefulStop

func (s *GrpcServer) GracefulStop() error

func (*GrpcServer) Notify

func (srv *GrpcServer) Notify(ctx context.Context, req *conn.NotifyReq) (*conn.NotifyResp, error)

func (*GrpcServer) Serve

func (s *GrpcServer) Serve(lis net.Listener) error

func (*GrpcServer) Stop

func (s *GrpcServer) Stop() error

type MQTTServer

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

MQTTServer

func NewMQTTServer

func NewMQTTServer(ctx *context.MqttSrvContext) *MQTTServer

NewMQTTServer create a new mqtt server

func (*MQTTServer) GracefulStop

func (s *MQTTServer) GracefulStop() error

GracefulStop first close the client connection before pushing out the program

func (*MQTTServer) Serve

func (s *MQTTServer) Serve(l net.Listener) error

Serve start server

func (*MQTTServer) Stop

func (s *MQTTServer) Stop() error

Stop provide fastclose, will not send will msg