thread

Documentation

Overview

Package thread contains code for interacting with a single stenotype thread.

Index

• type Thread
  • func Threads(configs []config.ThreadConfig, baseDir string, fc *filecache.Cache) ([]*Thread, error)
  • func (t *Thread) ExportDebugHandlers(mux *http.ServeMux)
  • func (t *Thread) FileLastSeen() time.Time
  • func (t *Thread) Lookup(ctx context.Context, q query.Query) *base.PacketChan
  • func (t *Thread) OldestFileTimestamp() time.Time
  • func (t *Thread) SyncFiles()

Types

type Thread

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

Thread watches the environment of a single stenotype thread. Stenotype runs multiple threads, each of which interacts with a specific set of directories in the environment. Each stenotype thread has a corresponding Thread object server-side which watches for file changes, cleans up old/dead files, etc.

func Threads

func Threads(configs []config.ThreadConfig, baseDir string, fc *filecache.Cache) ([]*Thread, error)

Threads creates a set of thread objects based on a set of ThreadConfigs.

func (*Thread) ExportDebugHandlers

func (t *Thread) ExportDebugHandlers(mux *http.ServeMux)

ExportDebugHandlers exports a set of HTTP handlers on /debug/t<thread id> for querying internal state from this thread.

func (*Thread) FileLastSeen

func (t *Thread) FileLastSeen() time.Time

FileLastSeen returns the last timne this thread saw a new file from stenotype.

func (*Thread) Lookup

func (t *Thread) Lookup(ctx context.Context, q query.Query) *base.PacketChan

Lookup looks up packets that match a given query within the files owned by a single stenotype thread.

func (*Thread) OldestFileTimestamp

func (t *Thread) OldestFileTimestamp() time.Time

OldestFileTimestamp returns timestamp of the oldest file we have.

func (*Thread) SyncFiles

func (t *Thread) SyncFiles()

SyncFiles checks the disk to see if stenotype has created any new files, or if old files should be deleted.