task

func (Sender) Complete ¶

func (s Sender) Complete(status Status)

func (Sender) Write ¶

func (s Sender) Write(line string)

func (*Store) AppID ¶ added in v0.0.2

func (s *Store) AppID(id string) string

AppID returns the app ID associated with a task, or empty string if not found.

func (*Store) Create ¶

func (s *Store) Create(id, appID string) Sender

Create registers a new running task. Returns a Sender for writing log lines.

func (*Store) CreatedAt ¶

func (s *Store) CreatedAt(id string) string

CreatedAt returns the task's creation timestamp as an RFC3339 string. Returns empty string if the task is not found.

func (*Store) Status ¶

func (s *Store) Status(id string) (Status, bool)

Status returns the task's current status. Returns false if not found.

func (*Store) Subscribe ¶

func (s *Store) Subscribe(id string) (snapshot []string, live <-chan string, done <-chan struct{}, ok bool)

Subscribe returns a snapshot of buffered lines and a channel for live lines written after the snapshot. The live channel only delivers new lines — no dedup needed by the caller. The done channel is closed when the task completes.