rpc

Documentation

Index

• func Connect(ctx context.Context, req *logic.ConnectReq) (memberId uint64, key, roomId string, accepts []int32, hb time.Duration, ...)
• func Disconnect(ctx context.Context, req *logic.DisconnectReq) (err error)
• func Heartbeat(ctx context.Context, req *logic.HeartbeatReq) (err error)
• func Init(etcdClient *clientv3.Client)
• func Receive(ctx context.Context, req *logic.ReceiveReq) (m *protocol.Message, err error)

Functions

func Connect

func Connect(ctx context.Context, req *logic.ConnectReq) (memberId uint64, key, roomId string, accepts []int32, hb time.Duration, err error)

func Disconnect

func Disconnect(ctx context.Context, req *logic.DisconnectReq) (err error)

func Heartbeat

func Heartbeat(ctx context.Context, req *logic.HeartbeatReq) (err error)

func Init

func Init(etcdClient *clientv3.Client)

func Receive

func Receive(ctx context.Context, req *logic.ReceiveReq) (m *protocol.Message, err error)