Documentation ¶
Index ¶
- type BufferedLiveLogger
- type JobLogger
- 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
- type VssLiveLogger
- type WebsocketLivelogger
- type WebsocketLiveloggerWithFallback
- func (logger *WebsocketLiveloggerWithFallback) Close() error
- func (logger *WebsocketLiveloggerWithFallback) Initialize()
- func (logger *WebsocketLiveloggerWithFallback) InitializeVssLogger()
- func (logger *WebsocketLiveloggerWithFallback) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BufferedLiveLogger ¶
type BufferedLiveLogger struct { LiveLogger // contains filtered or unexported fields }
func (*BufferedLiveLogger) Close ¶
func (logger *BufferedLiveLogger) Close() error
func (*BufferedLiveLogger) SendLog ¶
func (logger *BufferedLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
type JobLogger ¶
type JobLogger struct { JobRequest *protocol.AgentJobRequestMessage Connection *protocol.VssConnection ResultsConnection *protocol.VssConnection TimelineRecords *protocol.TimelineRecordWrapper CurrentRecord int64 CurrentLine int64 JobBuffer bytes.Buffer CurrentBuffer bytes.Buffer ResultsJobBuffer bytes.Buffer ResultsCurrentBuffer bytes.Buffer Logger LiveLogger IsResults bool ChangeId int64 CurrentJobLine int64 FirstBlock bool FirstJobBlock bool // contains filtered or unexported fields }
func (*JobLogger) Append ¶
func (logger *JobLogger) Append(record protocol.TimelineRecord) *protocol.TimelineRecord
func (*JobLogger) Current ¶
func (logger *JobLogger) Current() *protocol.TimelineRecord
func (*JobLogger) Insert ¶
func (logger *JobLogger) Insert(record protocol.TimelineRecord) *protocol.TimelineRecord
func (*JobLogger) MoveNext ¶
func (logger *JobLogger) MoveNext() *protocol.TimelineRecord
func (*JobLogger) MoveNextExt ¶
func (logger *JobLogger) MoveNextExt(startNextRecord bool) *protocol.TimelineRecord
type LiveLogger ¶
type LiveLogger interface { io.Closer SendLog(lines *protocol.TimelineRecordFeedLinesWrapper) error }
type VssLiveLogger ¶
type VssLiveLogger struct { JobRequest *protocol.AgentJobRequestMessage Connection *protocol.VssConnection }
func (*VssLiveLogger) Close ¶
func (*VssLiveLogger) Close() error
func (*VssLiveLogger) SendLog ¶
func (logger *VssLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
type WebsocketLivelogger ¶
type WebsocketLivelogger struct { JobRequest *protocol.AgentJobRequestMessage Connection *protocol.VssConnection FeedStreamUrl string // contains filtered or unexported fields }
func (*WebsocketLivelogger) Close ¶
func (logger *WebsocketLivelogger) Close() error
func (*WebsocketLivelogger) Connect ¶
func (logger *WebsocketLivelogger) Connect() error
func (*WebsocketLivelogger) SendLog ¶
func (logger *WebsocketLivelogger) SendLog(lines *protocol.TimelineRecordFeedLinesWrapper) error
type WebsocketLiveloggerWithFallback ¶
type WebsocketLiveloggerWithFallback struct { JobRequest *protocol.AgentJobRequestMessage Connection *protocol.VssConnection FeedStreamUrl string ForceWebsock bool // contains filtered or unexported fields }
func (*WebsocketLiveloggerWithFallback) Close ¶
func (logger *WebsocketLiveloggerWithFallback) Close() error
func (*WebsocketLiveloggerWithFallback) Initialize ¶
func (logger *WebsocketLiveloggerWithFallback) Initialize()
func (*WebsocketLiveloggerWithFallback) InitializeVssLogger ¶
func (logger *WebsocketLiveloggerWithFallback) InitializeVssLogger()
func (*WebsocketLiveloggerWithFallback) SendLog ¶
func (logger *WebsocketLiveloggerWithFallback) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
Click to show internal directories.
Click to hide internal directories.