logger

Documentation

Index

• type BufferedLiveLogger
  • func (logger *BufferedLiveLogger) Close() error
  • func (logger *BufferedLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
• 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
  • func (*VssLiveLogger) Close() error
  • func (logger *VssLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error
• type WebsocketLivelogger
  • func (logger *WebsocketLivelogger) Close() error
  • func (logger *WebsocketLivelogger) Connect() error
  • func (logger *WebsocketLivelogger) SendLog(lines *protocol.TimelineRecordFeedLinesWrapper) error
• type WebsocketLiveloggerWithFallback
  • func (logger *WebsocketLiveloggerWithFallback) Close() error
  • func (logger *WebsocketLiveloggerWithFallback) Initialize()
  • func (logger *WebsocketLiveloggerWithFallback) InitializeVssLogger()
  • func (logger *WebsocketLiveloggerWithFallback) SendLog(wrapper *protocol.TimelineRecordFeedLinesWrapper) error

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

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