logger

package
v0.6.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 2, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

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

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) Finish

func (logger *JobLogger) Finish()

func (*JobLogger) Insert

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

func (*JobLogger) Log

func (logger *JobLogger) Log(lines string)

func (*JobLogger) MoveNext

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

func (*JobLogger) MoveNextExt

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

func (*JobLogger) Update

func (logger *JobLogger) Update() error

func (*JobLogger) Write

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL