logH

Documentation

Index

• type ConnSeqItem
• type Engine
• type LogHelper
  • func NewLogHelper(e Engine) *LogHelper
  • func (lh *LogHelper) GetLogsIndex(key string, seq int32) (*ConnSeqItem, error)
  • func (lh *LogHelper) Save(key string, seq int32, item *ConnSeqItem) error
  • func (lh *LogHelper) SaveProxy(key string, seq int32, item *ConnSeqItem) error

Types

type ConnSeqItem

type ConnSeqItem struct {
	Type   string  `json:"type"`
	Sender string  `json:"sender"`
	Client string  `json:"client"`
	Logs   []int64 `json:"logs"`
}

type Engine

type Engine interface {
	GetConnSeqIndex(cid string, seq int32) (*ConnSeqItem, error)
	AddConnSeqIndex(cid string, seq int32, item *ConnSeqItem) error
	GetGroupSession(cid string, seq int32) (session string, err error)
}

type LogHelper

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

用于建立通信层协议seq和业务协议logId的映射关系

func NewLogHelper

func NewLogHelper(e Engine) *LogHelper

func (*LogHelper) GetLogsIndex

func (lh *LogHelper) GetLogsIndex(key string, seq int32) (*ConnSeqItem, error)

func (*LogHelper) Save

func (lh *LogHelper) Save(key string, seq int32, item *ConnSeqItem) error

func (*LogHelper) SaveProxy

func (lh *LogHelper) SaveProxy(key string, seq int32, item *ConnSeqItem) error