Versions in this module Expand all Collapse all v1 v1.0.1 Sep 2, 2022 Changes in this version + const MsgNone + const MsgNotSubscribed + const MsgSubscribed + const MsgSubscribedAlready + const MsgUnSubscribed + const MsgUnknownChannel + const MsgWorkerError + func FileServer(path string) http.Handler + type Client struct + type Config struct + Bytes int64 + ClientBufferSize int + Lines int + ListCache int + MaxLineSize int + Poll bool + Root string + Trace bool + WSReadBufferSize int + WSWriteBufferSize int + type Hub struct + func NewHub(logger logr.Logger, ts *TailService, wg *sync.WaitGroup) *Hub + func (h *Hub) Close() + func (h *Hub) Run() + type InMessage struct + Channel string + Type string + type IndexItemAttr struct + ModTime time.Time + Size int64 + type IndexItemAttrStore map[string]*IndexItemAttr + type IndexItemEvent struct + Deleted bool + ModTime time.Time + Name string + Size int64 + type IndexMessage struct + Data IndexItemEvent + Error string + Type string + type Message struct + Client *Client + Message []byte + type Service struct + func New(log logr.Logger, cfg *Config) (*Service, error) + func (wt *Service) Close() + func (wt *Service) Run() + func (wt *Service) ServeHTTP(w http.ResponseWriter, r *http.Request) + type StatsMessage struct + Data map[string]uint64 + Type string + type TailAttr struct + Buffer [][]byte + IsHeadTrimmed bool + Quit chan struct{} + type TailMessage struct + Channel string + Data string + Type string + type TailService struct + Config *Config + func NewTailService(logger logr.Logger, cfg *Config) (*TailService, error) + func (ts *TailService) ChannelExists(channel string) bool + func (ts *TailService) IndexItem(key string) *IndexItemAttr + func (ts *TailService) IndexKeys() []string + func (ts *TailService) IndexUpdate(msg *IndexItemEvent) + func (ts *TailService) IndexerRun(out chan *IndexItemEvent, wg *sync.WaitGroup) + func (ts *TailService) SetTrace(mode string) + func (ts *TailService) TailerAppend(channel string, data []byte) bool + func (ts *TailService) TailerBuffer(channel string) [][]byte + func (ts *TailService) TailerRun(channel string, out chan *TailMessage, readyChan chan struct{}, ...) error + func (ts *TailService) TraceEnabled() bool + func (ts *TailService) WorkerExists(channel string) bool + func (ts *TailService) WorkerStop(channel string) + type TraceMessage struct + Enabled bool + Type string