streaming

Documentation

Index

• Constants
• Variables
• func NewMastodon(dialer wrapper.Dialer, timer wrapper.Timer, ...) service.Streaming

Constants

const (
	ReconnectNone    = 0 * time.Second
	ReconnectInitial = 5 * time.Second
	ReconnectMax     = 320 * time.Second
	ServerHeader     = "X-Served-By"
)

Variables

var (
	StreamingMessageTotal = promauto.NewCounterVec(prometheus.CounterOpts{
		Namespace: "ejaculation_counter",
		Name:      "streaming_message_total",
		Help:      "Total number of messages from streaming.",
	}, []string{"server"})
	StreamingRetryTotal = promauto.NewCounter(prometheus.CounterOpts{
		Namespace: "ejaculation_counter",
		Name:      "streaming_retry_total",
		Help:      "Total number of retry for streaming.",
	})
)

Functions

func NewMastodon

func NewMastodon(
	dialer wrapper.Dialer,
	timer wrapper.Timer,
	serverURL, accessToken, stream string,
) service.Streaming