streamlog

Documentation

Index

• Constants
• func GetLogHander(c *gin.Context)
• func Init()
• func PushClientStreamLog(sender pb.Master_PushClientStreamLogServer) error
• func PushServerStreamLog(sender pb.Master_PushServerStreamLogServer) error
• type ClientLogManager
  • func Mgr() *ClientLogManager
  • func (c *ClientLogManager) GetClientLock(clientId string) *sync.Mutex

Constants

const (
	CacheBufSize = 4096
)

Functions

func GetLogHander

func GetLogHander(c *gin.Context)

func Init

func Init()

func PushClientStreamLog

func PushClientStreamLog(sender pb.Master_PushClientStreamLogServer) error

func PushServerStreamLog

func PushServerStreamLog(sender pb.Master_PushServerStreamLogServer) error

Types

type ClientLogManager

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

func Mgr

func Mgr() *ClientLogManager

func (*ClientLogManager) GetClientLock

func (c *ClientLogManager) GetClientLock(clientId string) *sync.Mutex