listen

Documentation

Index

• Variables
• func NewListenCommand(logger *logging.Logger) *cobra.Command
• func ReadMessages(ctx context.Context, logger logr.Logger, twitchChat chat.TwitchChatClient, ...) error
• func RegisterDefaultViews()

Variables

var (
	MessageLatencyView = &view.View{
		Name:        "messages/latency",
		Measure:     messageLatency,
		Description: "The distribution of the latencies",
		TagKeys:     []tag.Key{keyMessageType, keyExitCode, keyChannel, keyDisplayName},
		Aggregation: view.Distribution(0, 1, 2, 5, 10, 25, 100, 200, 400, 800, 10000),
	}

	MessageTotalView = &view.View{
		Name:        "messages/total",
		Measure:     messageLatency,
		Description: "The number of messages that were received",
		TagKeys:     []tag.Key{keyMessageType, keyExitCode, keyChannel, keyDisplayName},
		Aggregation: view.Count(),
	}
)

var DefaultViews = []*view.View{
	MessageLatencyView,
	MessageTotalView,
}

Functions

func NewListenCommand

func NewListenCommand(logger *logging.Logger) *cobra.Command

NewListenCommand creates a cobra command given a logger.

This will listen for messages on the queue and push them to webhookd to be sent to clients.

func ReadMessages

func ReadMessages(ctx context.Context, logger logr.Logger, twitchChat chat.TwitchChatClient, channel string, pattern string, args []string, msgs <-chan *messages.TwitchMessage) error

ReadMessages reads and processes the messages, returning a response if required

func RegisterDefaultViews

func RegisterDefaultViews()