monitor

package

v0.3.3 Latest Latest Go to latest Published: Mar 26, 2019 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/livepeer/go-livepeer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func LogJobCreatedEvent(job *ethTypes.Job, nonce uint64)
func LogJobReusedEvent(job *ethTypes.Job, startSeq int, nonce uint64)
func LogSegmentEmerged(nonce, seqNo uint64)
func LogSegmentTranscodeFailed(ev string, nonce, seqNo uint64, err error)
func LogSegmentTranscoded(nonce, seqNo uint64, transcodeDur, totalDur time.Duration)
func LogSegmentUploadFailed(nonce, seqNo uint64, reason string)
func LogSegmentUploaded(nonce, seqNo uint64, uploadDur time.Duration)
func LogStartBroadcastClientFailed(nonce uint64, serviceURI, transcoderAddress string, jobID uint64, ...)
func LogStreamCreateFailed(nonce uint64, reason string)
func LogStreamCreatedEvent(hlsStrmID string, nonce uint64)
func LogStreamEndedEvent(nonce uint64)
func LogStreamStartedEvent(nonce uint64)
func SegmentUploadStart(nonce, seqNo uint64)
func SetURL(url string)
type Monitor
- func Instance() *Monitor

Constants ¶

View Source

const PostFreq = time.Second * 10

Variables ¶

View Source

var Enabled bool

View Source

var Endpoint string

Functions ¶

func LogJobCreatedEvent ¶ added in v0.3.3

func LogJobCreatedEvent(job *ethTypes.Job, nonce uint64)

func LogJobReusedEvent ¶ added in v0.3.3

func LogJobReusedEvent(job *ethTypes.Job, startSeq int, nonce uint64)

func LogSegmentEmerged ¶ added in v0.3.3

func LogSegmentEmerged(nonce, seqNo uint64)

func LogSegmentTranscodeFailed ¶ added in v0.3.3

func LogSegmentTranscodeFailed(ev string, nonce, seqNo uint64, err error)

func LogSegmentTranscoded ¶ added in v0.3.3

func LogSegmentTranscoded(nonce, seqNo uint64, transcodeDur, totalDur time.Duration)

func LogSegmentUploadFailed ¶ added in v0.3.3

func LogSegmentUploadFailed(nonce, seqNo uint64, reason string)

func LogSegmentUploaded ¶ added in v0.3.3

func LogSegmentUploaded(nonce, seqNo uint64, uploadDur time.Duration)

func LogStartBroadcastClientFailed ¶ added in v0.3.3

func LogStartBroadcastClientFailed(nonce uint64, serviceURI, transcoderAddress string, jobID uint64, reason string)

func LogStreamCreateFailed ¶ added in v0.3.3

func LogStreamCreateFailed(nonce uint64, reason string)

func LogStreamCreatedEvent ¶ added in v0.3.3

func LogStreamCreatedEvent(hlsStrmID string, nonce uint64)

func LogStreamEndedEvent ¶ added in v0.3.3

func LogStreamEndedEvent(nonce uint64)

func LogStreamStartedEvent ¶ added in v0.3.3

func LogStreamStartedEvent(nonce uint64)

func SegmentUploadStart ¶ added in v0.3.3

func SegmentUploadStart(nonce, seqNo uint64)

func SetURL ¶ added in v0.3.3

func SetURL(url string)

Types ¶

type Monitor ¶

type Monitor struct {
	Node *data.Node
}

func Instance ¶

func Instance() *Monitor

func (*Monitor) GetPeerCount ¶

func (m *Monitor) GetPeerCount() int

func (*Monitor) LogBroadcaster ¶

func (m *Monitor) LogBroadcaster(strmID string)

func (*Monitor) LogBuffer ¶

func (m *Monitor) LogBuffer(strmID string)

func (*Monitor) LogNewConn ¶

func (m *Monitor) LogNewConn(local, remote string)

func (*Monitor) LogRelay ¶

func (m *Monitor) LogRelay(strmID, remote string)

func (*Monitor) LogStream ¶

func (m *Monitor) LogStream(strmID string, size uint, avgChunkSize uint)

func (*Monitor) LogSub ¶

func (m *Monitor) LogSub(strmID string)

func (*Monitor) RemoveBroadcast ¶

func (m *Monitor) RemoveBroadcast(strmID string)

func (*Monitor) RemoveConn ¶

func (m *Monitor) RemoveConn(local, remote string)

func (*Monitor) RemoveRelay ¶

func (m *Monitor) RemoveRelay(strmID string)

func (*Monitor) RemoveStream ¶

func (m *Monitor) RemoveStream(strmID string)

func (*Monitor) RemoveSub ¶

func (m *Monitor) RemoveSub(strmID string)

func (*Monitor) SetBootNode ¶

func (m *Monitor) SetBootNode()

func (*Monitor) StartWorker ¶

func (m *Monitor) StartWorker(ctx context.Context)

Source Files ¶

View all Source files

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