Documentation
¶
Index ¶
- func GetLatestMessage(addr string, r *model.HistoryRequest) []*model.HistoryMessage
- func GetNewCount(addr string, sync_key *model.SyncHistory) (int64, error)
- func Listen(listen_addr string)
- func ListenRPCClient(Rpc_listen string)
- func SaveGroupMessage(addr string, m *model.GroupMessage) (int64, error)
- func SavePeerMessage(addr string, m *model.PeerMessage) (int64, error)
- func Stack(rw http.ResponseWriter, req *http.Request)
- func StartHttpServer(addr string)
- func Summary(rw http.ResponseWriter, req *http.Request)
- func SyncGroupMessage(addr string, sync_key *model.SyncGroupHistory) *model.GroupHistoryMessage
- func SyncMessage(addr string, sync_key *model.SyncHistory) *model.PeerHistoryMessage
- func WriteHttpError(status int, err string, w http.ResponseWriter)
- func WriteHttpObj(data map[string]interface{}, w http.ResponseWriter)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetLatestMessage ¶
func GetLatestMessage(addr string, r *model.HistoryRequest) []*model.HistoryMessage
func GetNewCount ¶
func GetNewCount(addr string, sync_key *model.SyncHistory) (int64, error)
func ListenRPCClient ¶
func ListenRPCClient(Rpc_listen string)
func SaveGroupMessage ¶
func SaveGroupMessage(addr string, m *model.GroupMessage) (int64, error)
func SavePeerMessage ¶
func SavePeerMessage(addr string, m *model.PeerMessage) (int64, error)
func StartHttpServer ¶
func StartHttpServer(addr string)
func SyncGroupMessage ¶
func SyncGroupMessage(addr string, sync_key *model.SyncGroupHistory) *model.GroupHistoryMessage
func SyncMessage ¶
func SyncMessage(addr string, sync_key *model.SyncHistory) *model.PeerHistoryMessage
func WriteHttpError ¶
func WriteHttpError(status int, err string, w http.ResponseWriter)
func WriteHttpObj ¶
func WriteHttpObj(data map[string]interface{}, w http.ResponseWriter)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.