logger

Sep 5, 2025

Changes in this version

type JobLogger

+ ChangeID int64

type WebsocketLivelogger

+ FeedStreamURL string

type WebsocketLiveloggerWithFallback

+ FeedStreamURL string

Jan 23, 2024

Changes in this version

type JobLogger

+ ResultsConnection *protocol.VssConnection

+ ResultsCurrentBuffer bytes.Buffer

+ ResultsJobBuffer bytes.Buffer

May 4, 2023

Changes in this version

+ type BufferedLiveLogger struct

+ func (logger *BufferedLiveLogger) Close() error

+ func (logger *BufferedLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error

+ type JobLogger struct

+ ChangeId int64

+ Connection *protocol.VssConnection

+ CurrentBuffer bytes.Buffer

+ CurrentJobLine int64

+ CurrentLine int64

+ CurrentRecord int64

+ FirstBlock bool

+ FirstJobBlock bool

+ IsResults bool

+ JobBuffer bytes.Buffer

+ JobRequest *protocol.AgentJobRequestMessage

+ Logger LiveLogger

+ TimelineRecords *protocol.TimelineRecordWrapper

+ func (logger *JobLogger) Append(record protocol.TimelineRecord) *protocol.TimelineRecord

+ func (logger *JobLogger) Current() *protocol.TimelineRecord

+ func (logger *JobLogger) Finish()

+ func (logger *JobLogger) Insert(record protocol.TimelineRecord) *protocol.TimelineRecord

+ func (logger *JobLogger) Log(lines string)

+ func (logger *JobLogger) MoveNext() *protocol.TimelineRecord

+ func (logger *JobLogger) MoveNextExt(startNextRecord bool) *protocol.TimelineRecord

+ func (logger *JobLogger) Update() error

+ func (logger *JobLogger) Write(p []byte) (n int, err error)

+ type LiveLogger interface

+ SendLog func(lines *protocol.TimelineRecordFeedLinesWrapper) error

+ type VssLiveLogger struct

+ Connection *protocol.VssConnection

+ JobRequest *protocol.AgentJobRequestMessage

+ func (*VssLiveLogger) Close() error

+ func (logger *VssLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error

+ type WebsocketLivelogger struct

+ Connection *protocol.VssConnection

+ FeedStreamUrl string

+ JobRequest *protocol.AgentJobRequestMessage

+ func (logger *WebsocketLivelogger) Close() error

+ func (logger *WebsocketLivelogger) Connect() error

+ func (logger *WebsocketLivelogger) SendLog(lines *protocol.TimelineRecordFeedLinesWrapper) error

+ type WebsocketLiveloggerWithFallback struct

+ Connection *protocol.VssConnection

+ FeedStreamUrl string

+ ForceWebsock bool

+ JobRequest *protocol.AgentJobRequestMessage

+ func (logger *WebsocketLiveloggerWithFallback) Close() error

+ func (logger *WebsocketLiveloggerWithFallback) Initialize()

+ func (logger *WebsocketLiveloggerWithFallback) InitializeVssLogger()

+ func (logger *WebsocketLiveloggerWithFallback) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error