control

Documentation

Index

• func WriteLine(cc *ConnCarrier, line string, msgType int)
• type ConnCarrier
  • func NewConnCarrier(cm *ConnManager, conn *websocket.Conn, cf config.CatalogConf, file string) ConnCarrier
  • func (cc *ConnCarrier) Close()
  • func (cc *ConnCarrier) Handler()
  • func (cc *ConnCarrier) Id() uint64
  • func (cc *ConnCarrier) String() string
• type ConnManager
  • func NewConnManager() *ConnManager
  • func (cc *ConnManager) AddConnCarrier(carrier *ConnCarrier)
  • func (cc *ConnManager) CheckConnMaxTime()
  • func (cc *ConnManager) CheckHeartTimeout()
  • func (cc *ConnManager) GenerateCarrierId() uint64
  • func (cc *ConnManager) ProcessNewConn()
  • func (cc *ConnManager) Run()
• type TailReqProtocol
  • func (t *TailReqProtocol) LineNum() int
• type TailRespProtocol
• type Type

Functions

func WriteLine

func WriteLine(cc *ConnCarrier, line string, msgType int)

Types

type ConnCarrier

type ConnCarrier struct {
	Conn          *websocket.Conn
	Cf            config.CatalogConf
	File          string
	Tail          *tail.Tail
	StartTime     int64
	LastHeartTime int64
	Peer          string
	Add           bool

	Running bool
	// contains filtered or unexported fields
}

func NewConnCarrier

func NewConnCarrier(cm *ConnManager, conn *websocket.Conn, cf config.CatalogConf, file string) ConnCarrier

func (*ConnCarrier) Close

func (cc *ConnCarrier) Close()

func (*ConnCarrier) Handler

func (cc *ConnCarrier) Handler()

func (*ConnCarrier) Id

func (cc *ConnCarrier) Id() uint64

func (*ConnCarrier) String

func (cc *ConnCarrier) String() string

type ConnManager

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

func NewConnManager

func NewConnManager() *ConnManager

func (*ConnManager) AddConnCarrier

func (cc *ConnManager) AddConnCarrier(carrier *ConnCarrier)

func (*ConnManager) CheckConnMaxTime

func (cc *ConnManager) CheckConnMaxTime()

func (*ConnManager) CheckHeartTimeout

func (cc *ConnManager) CheckHeartTimeout()

func (*ConnManager) GenerateCarrierId

func (cc *ConnManager) GenerateCarrierId() uint64

func (*ConnManager) ProcessNewConn

func (cc *ConnManager) ProcessNewConn()

func (*ConnManager) Run

func (cc *ConnManager) Run()

type TailReqProtocol

type TailReqProtocol struct {
	Type    Type `json:"type"`
	UiWidth int  `json:"ui_width"`
}

func (*TailReqProtocol) LineNum

func (t *TailReqProtocol) LineNum() int

type TailRespProtocol

type TailRespProtocol struct {
	Type Type   `json:"type"`
	Msg  string `json:"msg"`
}

type Type

type Type int8

const (
	Read Type = iota
	Write
	Heart
	Close
)