middlewares

Documentation

Index

• type Metrics
  • func NewMetrics(namespace string) (m *Metrics)
  • func (m *Metrics) Handler() http.Handler
  • func (m *Metrics) OnSinkInput(streamID, sinkID string)
  • func (m *Metrics) OnSinkInputSuccess(streamID, sinkID string)
  • func (m *Metrics) OnSinkOutput(streamID, sinkID string)
  • func (m *Metrics) OnSinkOutputSuccess(streamID, sinkID string)
  • func (m *Metrics) OnSourceInput(streamID, sourceID string)
  • func (m *Metrics) OnSourceInputSuccess(streamID, sourceID string)
  • func (m *Metrics) OnSourceOutput(streamID, sourceID string)
  • func (m *Metrics) OnSourceOutputSuccess(streamID, sourceID string)
  • func (m *Metrics) OnTransformConvert(streamID string)
  • func (m *Metrics) OnTransformConvertSuccess(streamID string)
  • func (m *Metrics) OnTransformInput(streamID string)
  • func (m *Metrics) OnTransformInputSuccess(streamID string)
  • func (m *Metrics) OnTransformOutput(streamID string)
  • func (m *Metrics) OnTransformOutputSuccess(streamID string)

Types

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(namespace string) (m *Metrics)

NewMetrics creates a new Metrics instance

func (*Metrics) Handler

func (m *Metrics) Handler() http.Handler

func (*Metrics) OnSinkInput

func (m *Metrics) OnSinkInput(streamID, sinkID string)

func (*Metrics) OnSinkInputSuccess

func (m *Metrics) OnSinkInputSuccess(streamID, sinkID string)

func (*Metrics) OnSinkOutput

func (m *Metrics) OnSinkOutput(streamID, sinkID string)

func (*Metrics) OnSinkOutputSuccess

func (m *Metrics) OnSinkOutputSuccess(streamID, sinkID string)

func (*Metrics) OnSourceInput

func (m *Metrics) OnSourceInput(streamID, sourceID string)

func (*Metrics) OnSourceInputSuccess

func (m *Metrics) OnSourceInputSuccess(streamID, sourceID string)

func (*Metrics) OnSourceOutput

func (m *Metrics) OnSourceOutput(streamID, sourceID string)

func (*Metrics) OnSourceOutputSuccess

func (m *Metrics) OnSourceOutputSuccess(streamID, sourceID string)

func (*Metrics) OnTransformConvert

func (m *Metrics) OnTransformConvert(streamID string)

func (*Metrics) OnTransformConvertSuccess

func (m *Metrics) OnTransformConvertSuccess(streamID string)

func (*Metrics) OnTransformInput

func (m *Metrics) OnTransformInput(streamID string)

func (*Metrics) OnTransformInputSuccess

func (m *Metrics) OnTransformInputSuccess(streamID string)

func (*Metrics) OnTransformOutput

func (m *Metrics) OnTransformOutput(streamID string)

func (*Metrics) OnTransformOutputSuccess

func (m *Metrics) OnTransformOutputSuccess(streamID string)