client

Documentation

Index

• type Alloc
  • func NewAllocClient(target string, opts ...grpc.DialOption) (*Alloc, error)
  • func (c *Alloc) Close(ctx context.Context) error
  • func (c *Alloc) GenUserSeq(ctx context.Context, id uint32, tag string) (int64, error)
  • func (c *Alloc) GetUserSeq(ctx context.Context, id uint32, tag string) (int64, error)
• type Assign
  • func NewAssignClient(target string, opts ...grpc.DialOption) (*Assign, error)
  • func (c *Assign) Close(ctx context.Context) error
  • func (c *Assign) ReBalance(ctx context.Context) error
  • func (c *Assign) RegSection(ctx context.Context, tag string, async bool) error
  • func (c *Assign) UnRegSection(ctx context.Context, tag string, async bool) error
• type Proxy
  • func NewProxyClient(target string, opts ...grpc.DialOption) (*Proxy, error)
  • func (c *Proxy) BatchGenUserSeq(ctx context.Context, idList []uint32, tag string, async bool) (map[uint32]int64, error)
  • func (c *Proxy) BatchGetUserSeq(ctx context.Context, idList []uint32, tag string) (map[uint32]int64, error)
  • func (c *Proxy) Close(ctx context.Context) error
  • func (c *Proxy) GenUserMultiSeq(ctx context.Context, id uint32, tagList []string, async bool) (map[string]int64, error)
  • func (c *Proxy) GenUserSeq(ctx context.Context, id uint32, tag string) (int64, error)
  • func (c *Proxy) GetUserMultiSeq(ctx context.Context, id uint32, tagList []string) (map[string]int64, error)
  • func (c *Proxy) GetUserSeq(ctx context.Context, id uint32, tag string) (int64, error)

Types

type Alloc

type Alloc struct {
	pb.AllocClient
	// contains filtered or unexported fields
}

func NewAllocClient

func NewAllocClient(target string, opts ...grpc.DialOption) (*Alloc, error)

func (*Alloc) Close

func (c *Alloc) Close(ctx context.Context) error

func (*Alloc) GenUserSeq

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

func (*Alloc) GetUserSeq

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

type Assign

type Assign struct {
	pb.AssignClient
	// contains filtered or unexported fields
}

func NewAssignClient

func NewAssignClient(target string, opts ...grpc.DialOption) (*Assign, error)

func (*Assign) Close

func (c *Assign) Close(ctx context.Context) error

func (*Assign) ReBalance

func (c *Assign) ReBalance(ctx context.Context) error

func (*Assign) RegSection

func (c *Assign) RegSection(ctx context.Context, tag string, async bool) error

func (*Assign) UnRegSection

func (c *Assign) UnRegSection(ctx context.Context, tag string, async bool) error

type Proxy

type Proxy struct {
	pb.ProxyClient
	// contains filtered or unexported fields
}

func NewProxyClient

func NewProxyClient(target string, opts ...grpc.DialOption) (*Proxy, error)

func (*Proxy) BatchGenUserSeq

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

func (*Proxy) BatchGetUserSeq

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

func (*Proxy) Close

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

func (*Proxy) GenUserMultiSeq

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

func (*Proxy) GenUserSeq

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

func (*Proxy) GetUserMultiSeq

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

func (*Proxy) GetUserSeq

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