client

Documentation

Index

• Constants
• func CloseClient(client *Client)
• type Client
  • func FindClientsBySessionIds(sessionIds []string) []*Client
  • func NewClient(cp *packets.ConnectPacket, conn net.Conn, ...) (*Client, bool)
  • func (client *Client) CanPub(topic string) bool
  • func (client *Client) CanSub(topic string) bool
  • func (client *Client) IsConnected() bool
  • func (client *Client) Touch()
• type Session

Constants

const (
	Unknown      = 0
	Connecting   = 1
	Connected    = 2
	Disconnected = 3
)

Functions

func CloseClient

func CloseClient(client *Client)

Types

type Client

type Client struct {
	Id        string
	SessionId string

	Conn net.Conn

	LastPingTime  time.Time
	ConnectedTime time.Time
	CleanSession  bool
	Keepalive     uint16
	// contains filtered or unexported fields
}

func FindClientsBySessionIds

func FindClientsBySessionIds(sessionIds []string) []*Client

func NewClient

func NewClient(cp *packets.ConnectPacket, conn net.Conn, authentication *security.Authentication, serverConfig *config.ServerConfig) (*Client, bool)

func (*Client) CanPub

func (client *Client) CanPub(topic string) bool

该方法会对pubAuthCache进行读写，需要确保非并发调用（使用map是为了提高性能）

func (*Client) CanSub

func (client *Client) CanSub(topic string) bool

func (*Client) IsConnected

func (client *Client) IsConnected() bool

func (*Client) Touch

func (client *Client) Touch()

type Session

type Session struct {
	Id       string
	ClientId string
	// contains filtered or unexported fields
}