client

Documentation

Index

• type Client
  • func NewClient(opts ...Option) *Client
  • func (c *Client) Destroy()
  • func (c *Client) Init()
  • func (c *Client) Name() string
  • func (c *Client) Proxy() *Proxy
  • func (c *Client) Start()
• type Context
  • func (c *Context) Bind(uid int64) error
  • func (c *Context) CID() int64
  • func (c *Context) Context() context.Context
  • func (c *Context) Data() interface{}
  • func (c *Context) Parse(v interface{}) (err error)
  • func (c *Context) Proxy() *Proxy
  • func (c *Context) Push(message *Message) error
  • func (c *Context) Route() int32
  • func (c *Context) Seq() int32
  • func (c *Context) UID() int64
  • func (c *Context) Unbind() error
• type EventHandler
• type Message
• type Option
  • func WithClient(client network.Client) Option
  • func WithCodec(codec encoding.Codec) Option
  • func WithContext(ctx context.Context) Option
  • func WithEncryptor(encryptor crypto.Encryptor) Option
  • func WithID(id string) Option
  • func WithName(name string) Option
  • func WithTimeout(timeout time.Duration) Option
• type Proxy
  • func (p *Proxy) AddEventListener(event cluster.Event, handler EventHandler)
  • func (p *Proxy) AddRouteHandler(route int32, handler RouteHandler)
  • func (p *Proxy) Bind(uid int64) error
  • func (p *Proxy) Disconnect() error
  • func (p *Proxy) GetClientID() string
  • func (p *Proxy) Push(message *Message) error
  • func (p *Proxy) Reconnect() error
  • func (p *Proxy) SetDefaultRouteHandler(handler RouteHandler)
  • func (p *Proxy) Unbind() error
• type RouteHandler

Types

type Client

type Client struct {
	component.Base
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts ...Option) *Client

func (*Client) Destroy

func (c *Client) Destroy()

Destroy 销毁组件

func (*Client) Init

func (c *Client) Init()

Init 初始化节点

func (*Client) Name

func (c *Client) Name() string

Name 组件名称

func (*Client) Proxy

func (c *Client) Proxy() *Proxy

Proxy 获取节点代理

func (*Client) Start

func (c *Client) Start()

Start 启动组件

type Context

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

func (*Context) Bind

func (c *Context) Bind(uid int64) error

Bind 绑定用户ID

func (*Context) CID

func (c *Context) CID() int64

CID 获取连接ID

func (*Context) Context

func (c *Context) Context() context.Context

Context 获取上线文

func (*Context) Data

func (c *Context) Data() interface{}

Data 获取消息数据

func (*Context) Parse

func (c *Context) Parse(v interface{}) (err error)

Parse 解析消息

func (*Context) Proxy

func (c *Context) Proxy() *Proxy

Proxy 响应请求

func (*Context) Push

func (c *Context) Push(message *Message) error

Push 推送消息

func (*Context) Route

func (c *Context) Route() int32

Route 获取消息路由

func (*Context) Seq

func (c *Context) Seq() int32

Seq 获取消息序列号

func (*Context) UID

func (c *Context) UID() int64

UID 获取用户ID

func (*Context) Unbind

func (c *Context) Unbind() error

Unbind 解绑用户ID

type EventHandler

type EventHandler func(proxy *Proxy)

type Message

type Message = link.Message

type Option

type Option func(o *options)

func WithClient

func WithClient(client network.Client) Option

WithClient 设置客户端

func WithCodec

func WithCodec(codec encoding.Codec) Option

WithCodec 设置编解码器

func WithContext

func WithContext(ctx context.Context) Option

WithContext 设置上下文

func WithEncryptor

func WithEncryptor(encryptor crypto.Encryptor) Option

WithEncryptor 设置消息加密器

func WithID

func WithID(id string) Option

WithID 设置实例ID

func WithName

func WithName(name string) Option

WithName 设置实例名称

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout 设置RPC调用超时时间

type Proxy

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

func (*Proxy) AddEventListener

func (p *Proxy) AddEventListener(event cluster.Event, handler EventHandler)

AddEventListener 添加事件监听器

func (*Proxy) AddRouteHandler

func (p *Proxy) AddRouteHandler(route int32, handler RouteHandler)

AddRouteHandler 添加路由处理器

func (*Proxy) Bind

func (p *Proxy) Bind(uid int64) error

Bind 绑定用户ID

func (*Proxy) Disconnect

func (p *Proxy) Disconnect() error

Disconnect 断开连接

func (*Proxy) GetClientID

func (p *Proxy) GetClientID() string

GetClientID 获取客户端ID

func (*Proxy) Push

func (p *Proxy) Push(message *Message) error

Push 推送消息

func (*Proxy) Reconnect

func (p *Proxy) Reconnect() error

Reconnect 重新连接

func (*Proxy) SetDefaultRouteHandler

func (p *Proxy) SetDefaultRouteHandler(handler RouteHandler)

SetDefaultRouteHandler 设置默认路由处理器，所有未注册的路由均走默认路由处理器

func (*Proxy) Unbind

func (p *Proxy) Unbind() error

Unbind 解绑用户ID

type RouteHandler

type RouteHandler func(ctx *Context)