webtail

Nov 14, 2021

Changes in this version

+ func FileServer(path string) http.Handler

Jan 28, 2021

Changes in this version

+ const MsgNone

+ const MsgNotSubscribed

+ const MsgSubscribed

+ const MsgSubscribedAlready

+ const MsgUnSubscribed

+ const MsgUnknownChannel

+ const MsgWorkerError

type Config

+ ClientBufferSize int

+ WSReadBufferSize int

+ WSWriteBufferSize int

type Hub

+ 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 IndexMessage struct

+ Data IndexItemEvent

+ Error string

+ Type string

type Service

+ func (wt *Service) Close()

+ 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 *TailerMessage, readyChan chan struct{}, ...) error

+ func (ts *TailService) TraceEnabled() bool

+ func (ts *TailService) WorkerExists(channel string) bool

+ func (ts *TailService) WorkerStop(channel string)

+ type TailerMessage struct

+ Channel string

+ Data string

+ type TraceMessage struct

+ Enabled bool

+ Type string

Jan 24, 2021

Changes in this version

+ type ClientHub struct

+ 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 Service

+ func (wt *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type TailHub struct

+ Config Config

+ Log log.Logger

+ func NewTailHub(logger log.Logger, cfg Config) (*TailHub, error)

+ func (wh *TailHub) Append(channel string, data []byte) bool

+ func (wh *TailHub) Buffer(channel string) [][]byte

+ func (wh *TailHub) ChannelExists(channel string) bool

+ func (wh *TailHub) Index() *IndexItemAttrStore

+ func (wh *TailHub) IndexRun(out chan *IndexItemEvent) error

+ func (wh *TailHub) LoadIndex(out chan *IndexItemEvent)

+ func (wh *TailHub) SetTrace(on bool)

+ func (wh *TailHub) TailRun(channel string, out chan *WorkerMessage) error

+ func (wh *TailHub) TraceEnabled() bool

+ func (wh *TailHub) Update(msg *IndexItemEvent)

+ func (wh *TailHub) WorkerExists(channel string) bool

+ func (wh *TailHub) WorkerStop(channel string) error

+ type WorkerMessage struct

+ Channel string

+ Data string

Jan 12, 2021

Changes in this version

+ type Client struct

type Config

+ Bytes int64

+ Lines int

+ ListCache int

+ MaxLineSize int

+ Poll bool

+ Root string

+ Trace bool

+ type Hub struct

+ type Message struct

+ Client *Client

+ Message []byte

+ type Service struct

+ func New(lg log.Logger, cfg Config) (*Service, error)

+ func (wt *Service) Handle(w http.ResponseWriter, r *http.Request)

+ func (wt *Service) Run()

+ type WorkerHub struct

+ Config Config

+ Log log.Logger

+ func NewTailer(logger log.Logger, cfg Config) (*WorkerHub, error)

+ func (wh *WorkerHub) Append(channel string, data []byte) bool

+ func (wh *WorkerHub) Buffer(channel string) [][]byte

+ func (wh *WorkerHub) ChannelExists(channel string) bool

+ func (wh *WorkerHub) Index() *worker.IndexStore

+ func (wh *WorkerHub) IndexRun(out chan *worker.Index) error

+ func (wh *WorkerHub) LoadIndex(out chan *worker.Index)

+ func (wh *WorkerHub) SetTrace(on bool)

+ func (wh *WorkerHub) TraceEnabled() bool

+ func (wh *WorkerHub) Update(msg *worker.Index)

+ func (wh *WorkerHub) WorkerExists(channel string) bool

+ func (wh *WorkerHub) WorkerRun(channel string, out chan *worker.Message) error

+ func (wh *WorkerHub) WorkerStop(channel string) error

Aug 27, 2017

Changes in this version

+ const Version

+ var Build string

+ var Commit string

+ func Asset(name string) ([]byte, error)

+ func AssetDir(name string) ([]string, error)

+ func AssetInfo(name string) (os.FileInfo, error)

+ func AssetNames() []string

+ func MustAsset(name string) []byte

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

+ type Config struct

+ type FileAttr struct

+ MTime time.Time

+ Size int64

+ type FileStore map[string]*FileAttr

+ type Flags struct

+ Addr string

+ Host string

+ Length int

+ Lines string

+ LogLevel string

+ Root string

+ Version bool