worker

package

v0.10.0 Latest Latest Go to latest Published: Jul 24, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

MultiWriterWithWebsocket wraps a multiwriter and provides websocket functionality

func NewMultiWriterWithWebsocket(writer io.Writer, prefix string) *MultiWriterWithWebsocket

func (m *MultiWriterWithWebsocket) SetPrefix(prefix string)

SetPrefix sets the prefix for the writer

func (m *MultiWriterWithWebsocket) SetWebsocket(ws *websocket.Conn)

func (m *MultiWriterWithWebsocket) Write(p []byte) (n int, err error)

func (m *MultiWriterWithWebsocket) WriteStr(s string) (n int, err error)

WriteStr writes a string to the writer, handling the byte conversion internally

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

func NewWorker(endpoint, workerID string) *Worker

func (w *Worker) Start(ctx context.Context) error