lib

package
v0.0.0-...-574e1aa Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2017 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelStatus 

type ChannelStatus struct {
	Name          string `json:"name"`
	UserCount     uint64 `json:"user_count"`
	RealUserCount uint64 `json:"real_user_count"`
}

func (*ChannelStatus) MarshalJSON 

func (mj *ChannelStatus) MarshalJSON() ([]byte, error)

func (*ChannelStatus) MarshalJSONBuf 

func (mj *ChannelStatus) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*ChannelStatus) UnmarshalJSON 

func (uj *ChannelStatus) UnmarshalJSON(input []byte) error

func (*ChannelStatus) UnmarshalJSONFFLexer 

func (uj *ChannelStatus) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type ChannelStatusReply 

type ChannelStatusReply struct {
	Result int             `json:"result"`
	Data   []ChannelStatus `json:"data"`
}

func (*ChannelStatusReply) MarshalJSON 

func (mj *ChannelStatusReply) MarshalJSON() ([]byte, error)

func (*ChannelStatusReply) MarshalJSONBuf 

func (mj *ChannelStatusReply) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*ChannelStatusReply) UnmarshalJSON 

func (uj *ChannelStatusReply) UnmarshalJSON(input []byte) error

func (*ChannelStatusReply) UnmarshalJSONFFLexer 

func (uj *ChannelStatusReply) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type DeleteMessageReply 

type DeleteMessageReply struct {
	Result int `json:"result"`
}

func (*DeleteMessageReply) MarshalJSON 

func (mj *DeleteMessageReply) MarshalJSON() ([]byte, error)

func (*DeleteMessageReply) MarshalJSONBuf 

func (mj *DeleteMessageReply) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*DeleteMessageReply) UnmarshalJSON 

func (uj *DeleteMessageReply) UnmarshalJSON(input []byte) error

func (*DeleteMessageReply) UnmarshalJSONFFLexer 

func (uj *DeleteMessageReply) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type GeneralOnlineUsers 

type GeneralOnlineUsers struct {
	Result    int                            `json:"result"`
	Timestamp int64                          `json:"timestamp"`
	UserTags  map[string]*OnlineUsersWithTag `json:"user_tags"`
}

func (*GeneralOnlineUsers) MarshalJSON 

func (mj *GeneralOnlineUsers) MarshalJSON() ([]byte, error)

func (*GeneralOnlineUsers) MarshalJSONBuf 

func (mj *GeneralOnlineUsers) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*GeneralOnlineUsers) UnmarshalJSON 

func (uj *GeneralOnlineUsers) UnmarshalJSON(input []byte) error

func (*GeneralOnlineUsers) UnmarshalJSONFFLexer 

func (uj *GeneralOnlineUsers) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type GeneralOnlineUsersSimple 

type GeneralOnlineUsersSimple struct {
	Result    int                                  `json:"result"`
	Timestamp int64                                `json:"timestamp"`
	UserTags  map[string]*OnlineUsersSimpleWithTag `json:"user_tags"`
}

func (*GeneralOnlineUsersSimple) MarshalJSON 

func (mj *GeneralOnlineUsersSimple) MarshalJSON() ([]byte, error)

func (*GeneralOnlineUsersSimple) MarshalJSONBuf 

func (mj *GeneralOnlineUsersSimple) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*GeneralOnlineUsersSimple) UnmarshalJSON 

func (uj *GeneralOnlineUsersSimple) UnmarshalJSON(input []byte) error

func (*GeneralOnlineUsersSimple) UnmarshalJSONFFLexer 

func (uj *GeneralOnlineUsersSimple) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type GlobalConfig 

type GlobalConfig struct {
	LogFile              string `json:"log_file"`
	ListenAddress        string `json:"listen_address"`
	ProfileListenAddress string `json:"profile_listen_address"`
	ServerDebug          bool   `json:"server_debug"`
	ForceGCPeriod        int    `json:"force_gc_period"`
	ForceGC              bool   `json:"force_gc"`
	ForceFreeOSMemory    bool   `json:"force_free_os_memory"`
	KeepAlive            bool   `json:"keepalive"`
	PollMessageSize      int    `json:"poll_message_size"`
	MQTTServerAddress    string `json:"mqtt_server"`
	MQTTServerPort       string `json:"mqtt_server_port"`
	MQTTServerEnable     bool   `json:"mqtt_server_enable"`
	EnableServerProfile  bool
	LogToStdout          bool
	Lock                 *sync.Mutex
}

type MQTTSingleTopicUsers 

type MQTTSingleTopicUsers struct {
	Name   string
	Length uint64
}

type OnlineUsers 

type OnlineUsers struct {
	Result   int      `json:"result"`
	Length   int      `json:"length"`
	UserList []string `json:"users"`
}

func (*OnlineUsers) MarshalJSON 

func (mj *OnlineUsers) MarshalJSON() ([]byte, error)

func (*OnlineUsers) MarshalJSONBuf 

func (mj *OnlineUsers) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*OnlineUsers) UnmarshalJSON 

func (uj *OnlineUsers) UnmarshalJSON(input []byte) error

func (*OnlineUsers) UnmarshalJSONFFLexer 

func (uj *OnlineUsers) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type OnlineUsersSimple 

type OnlineUsersSimple struct {
	Result int    `json:"result"`
	Length uint64 `json:"length"`
}

func (*OnlineUsersSimple) MarshalJSON 

func (mj *OnlineUsersSimple) MarshalJSON() ([]byte, error)

func (*OnlineUsersSimple) MarshalJSONBuf 

func (mj *OnlineUsersSimple) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*OnlineUsersSimple) UnmarshalJSON 

func (uj *OnlineUsersSimple) UnmarshalJSON(input []byte) error

func (*OnlineUsersSimple) UnmarshalJSONFFLexer 

func (uj *OnlineUsersSimple) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type OnlineUsersSimpleWithTag 

type OnlineUsersSimpleWithTag struct {
	Length uint64 `json:"length"`
}

func (*OnlineUsersSimpleWithTag) MarshalJSON 

func (mj *OnlineUsersSimpleWithTag) MarshalJSON() ([]byte, error)

func (*OnlineUsersSimpleWithTag) MarshalJSONBuf 

func (mj *OnlineUsersSimpleWithTag) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*OnlineUsersSimpleWithTag) UnmarshalJSON 

func (uj *OnlineUsersSimpleWithTag) UnmarshalJSON(input []byte) error

func (*OnlineUsersSimpleWithTag) UnmarshalJSONFFLexer 

func (uj *OnlineUsersSimpleWithTag) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type OnlineUsersWithTag 

type OnlineUsersWithTag struct {
	Length   int      `json:"length"`
	UserList []string `json:"users"`
}

func (*OnlineUsersWithTag) MarshalJSON 

func (mj *OnlineUsersWithTag) MarshalJSON() ([]byte, error)

func (*OnlineUsersWithTag) MarshalJSONBuf 

func (mj *OnlineUsersWithTag) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*OnlineUsersWithTag) UnmarshalJSON 

func (uj *OnlineUsersWithTag) UnmarshalJSON(input []byte) error

func (*OnlineUsersWithTag) UnmarshalJSONFFLexer 

func (uj *OnlineUsersWithTag) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type PollMessage 

type PollMessage struct {
	Result        int            `json:"result"`
	MessageLength int            `json:"length"`
	MessageList   []*PostMessage `json:"message_list"`
}

func (*PollMessage) MarshalJSON 

func (mj *PollMessage) MarshalJSON() ([]byte, error)

func (*PollMessage) MarshalJSONBuf 

func (mj *PollMessage) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*PollMessage) UnmarshalJSON 

func (uj *PollMessage) UnmarshalJSON(input []byte) error

func (*PollMessage) UnmarshalJSONFFLexer 

func (uj *PollMessage) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type PostMessage 

type PostMessage struct {
	MessageType string `json:"type"`
	MessageID   string `json:"id"`
	ToUser      string `json:"to_user"`
	Delay       int    `json:"delay"`
	PayLoad     string `json:"payload"`
	Count       uint64
	Lock        *sync.SpinLock
}

func (*PostMessage) MarshalJSON 

func (mj *PostMessage) MarshalJSON() ([]byte, error)

func (*PostMessage) MarshalJSONBuf 

func (mj *PostMessage) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*PostMessage) UnmarshalJSON 

func (uj *PostMessage) UnmarshalJSON(input []byte) error

func (*PostMessage) UnmarshalJSONFFLexer 

func (uj *PostMessage) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

type PostReply 

type PostReply struct {
	Result    int    `json:"result"`
	MessageID string `json:"id"`
}

func (*PostReply) MarshalJSON 

func (mj *PostReply) MarshalJSON() ([]byte, error)

func (*PostReply) MarshalJSONBuf 

func (mj *PostReply) MarshalJSONBuf(buf fflib.EncodingBuffer) error

func (*PostReply) UnmarshalJSON 

func (uj *PostReply) UnmarshalJSON(input []byte) error

func (*PostReply) UnmarshalJSONFFLexer 

func (uj *PostReply) UnmarshalJSONFFLexer(fs *fflib.FFLexer, state fflib.FFParseState) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.