sender

Documentation

Index

• type GenericSender
• type PublishError
• type PublishingMetricsCollectorStub
  • func (p PublishingMetricsCollectorStub) Collect(chan<- prometheus.Metric)
  • func (p PublishingMetricsCollectorStub) Describe(chan<- *prometheus.Desc)
  • func (p PublishingMetricsCollectorStub) RecordError()
  • func (p PublishingMetricsCollectorStub) RecordEventType(string, string, int)
  • func (p PublishingMetricsCollectorStub) RecordLatency(time.Duration, int, string)
  • func (p PublishingMetricsCollectorStub) RecordRequests(int, string)

Types

type GenericSender

type GenericSender interface {
	Send(context.Context, *event.Event) PublishError
	URL() string
}

type PublishError

type PublishError interface {
	error
	Code() int
	Message() string
}

type PublishingMetricsCollectorStub

type PublishingMetricsCollectorStub struct{}

func (PublishingMetricsCollectorStub) Collect

func (p PublishingMetricsCollectorStub) Collect(chan<- prometheus.Metric)

func (PublishingMetricsCollectorStub) Describe

func (p PublishingMetricsCollectorStub) Describe(chan<- *prometheus.Desc)

func (PublishingMetricsCollectorStub) RecordError

func (p PublishingMetricsCollectorStub) RecordError()

func (PublishingMetricsCollectorStub) RecordEventType

func (p PublishingMetricsCollectorStub) RecordEventType(string, string, int)

func (PublishingMetricsCollectorStub) RecordLatency

func (p PublishingMetricsCollectorStub) RecordLatency(time.Duration, int, string)

func (PublishingMetricsCollectorStub) RecordRequests

func (p PublishingMetricsCollectorStub) RecordRequests(int, string)