proxy

Documentation

Index

• type Proxy
  • func NewProxy(ctx context.Context, conf *utils.Config) (*Proxy, error)
  • func (p *Proxy) BatchGenUserSeq(ctx context.Context, idList []uint32, tag string, async bool) (map[uint32]int64, error)
  • func (p *Proxy) BatchGetUserSeq(ctx context.Context, idList []uint32, tag string) (map[uint32]int64, error)
  • func (p *Proxy) Close(ctx context.Context) error
  • func (p *Proxy) GenUserMultiSeq(ctx context.Context, id uint32, tagList []string, async bool) (map[string]int64, error)
  • func (p *Proxy) GenUserSeq(ctx context.Context, id uint32, tag string) (int64, error)
  • func (p *Proxy) GetUserMultiSeq(ctx context.Context, id uint32, tagList []string) (map[string]int64, error)
  • func (p *Proxy) GetUserSeq(ctx context.Context, id uint32, tag string) (int64, error)
• type Server
  • func NewProxyServer(ctx context.Context, conf *utils.Config) (*Server, error)
  • func (p *Server) BatchGenUserSeq(ctx context.Context, in *pb.BatchGenUserSeqReq) (*pb.BatchGenUserSeqResp, error)
  • func (p *Server) BatchGetUserSeq(ctx context.Context, in *pb.BatchGetUserSeqReq) (*pb.BatchGetUserSeqResp, error)
  • func (p *Server) Close(ctx context.Context) error
  • func (p *Server) GenUserMultiSeq(ctx context.Context, in *pb.GenUserMultiSeqReq) (*pb.GenUserMultiSeqResp, error)
  • func (p *Server) GenUserSeq(ctx context.Context, in *pb.GenUserSeqReq) (*pb.GenUserSeqResp, error)
  • func (p *Server) GetUserMultiSeq(ctx context.Context, in *pb.GetUserMultiSeqReq) (*pb.GetUserMultiSeqResp, error)
  • func (p *Server) GetUserSeq(ctx context.Context, in *pb.GetUserSeqReq) (*pb.GetUserSeqResp, error)

Types

type Proxy

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

Proxy watch /segment/{table}/routing/{addr}/{tag}/{hashId}, manage router in order to handler rpc.

func NewProxy

func NewProxy(ctx context.Context, conf *utils.Config) (*Proxy, error)

func (*Proxy) BatchGenUserSeq

func (p *Proxy) BatchGenUserSeq(ctx context.Context, idList []uint32, tag string, async bool) (map[uint32]int64, error)

func (*Proxy) BatchGetUserSeq

func (p *Proxy) BatchGetUserSeq(ctx context.Context, idList []uint32, tag string) (map[uint32]int64, error)

func (*Proxy) Close

func (p *Proxy) Close(ctx context.Context) error

func (*Proxy) GenUserMultiSeq

func (p *Proxy) GenUserMultiSeq(ctx context.Context, id uint32, tagList []string, async bool) (map[string]int64, error)

func (*Proxy) GenUserSeq

func (p *Proxy) GenUserSeq(ctx context.Context, id uint32, tag string) (int64, error)

func (*Proxy) GetUserMultiSeq

func (p *Proxy) GetUserMultiSeq(ctx context.Context, id uint32, tagList []string) (map[string]int64, error)

func (*Proxy) GetUserSeq

func (p *Proxy) GetUserSeq(ctx context.Context, id uint32, tag string) (int64, error)

type Server

type Server struct {
	*pb.UnimplementedProxyServer
	// contains filtered or unexported fields
}

func NewProxyServer

func NewProxyServer(ctx context.Context, conf *utils.Config) (*Server, error)

func (*Server) BatchGenUserSeq

func (p *Server) BatchGenUserSeq(ctx context.Context, in *pb.BatchGenUserSeqReq) (*pb.BatchGenUserSeqResp, error)

func (*Server) BatchGetUserSeq

func (p *Server) BatchGetUserSeq(ctx context.Context, in *pb.BatchGetUserSeqReq) (*pb.BatchGetUserSeqResp, error)

func (*Server) Close

func (p *Server) Close(ctx context.Context) error

func (*Server) GenUserMultiSeq

func (p *Server) GenUserMultiSeq(ctx context.Context, in *pb.GenUserMultiSeqReq) (*pb.GenUserMultiSeqResp, error)

func (*Server) GenUserSeq

func (p *Server) GenUserSeq(ctx context.Context, in *pb.GenUserSeqReq) (*pb.GenUserSeqResp, error)

func (*Server) GetUserMultiSeq

func (p *Server) GetUserMultiSeq(ctx context.Context, in *pb.GetUserMultiSeqReq) (*pb.GetUserMultiSeqResp, error)

func (*Server) GetUserSeq

func (p *Server) GetUserSeq(ctx context.Context, in *pb.GetUserSeqReq) (*pb.GetUserSeqResp, error)