Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogBroker ¶
type LogBroker struct {
// contains filtered or unexported fields
}
LogBroker manages log streams for jobs
func (*LogBroker) HasSubscribers ¶
HasSubscribers returns true if there are active subscribers for a job
type StreamWriter ¶
type StreamWriter struct {
// contains filtered or unexported fields
}
StreamWriter is an io.Writer that broadcasts to both a buffer and the broker
func NewStreamWriter ¶
NewStreamWriter creates a writer that broadcasts to the broker and writes to a buffer
type ValkeyLogWriter ¶
type ValkeyLogWriter struct {
// contains filtered or unexported fields
}
ValkeyLogWriter publishes log lines to Valkey pub/sub channel Implements io.Writer interface for use with log streaming
func NewValkeyLogWriter ¶
func NewValkeyLogWriter(client valkey.Client, jobID string) *ValkeyLogWriter
NewValkeyLogWriter creates a new Valkey log publisher
func (*ValkeyLogWriter) Publish ¶
func (w *ValkeyLogWriter) Publish(message string) error
Publish sends a message to the log channel (for completion/error messages)
func (*ValkeyLogWriter) SetTTL ¶
func (w *ValkeyLogWriter) SetTTL(seconds int64) error
SetTTL sets the TTL on the log channel for cleanup
Source Files
Click to show internal directories.
Click to hide internal directories.