multiplexer

Documentation

Index

• type DecrementTabCounter
• type InboundMessage
• type IncrementTabCounter
• type Multiplexer
  • func NewMultiplexer(logger zerolog.Logger, provider twitch.AccountProvider) *Multiplexer
  • func (m *Multiplexer) ListenAndServe(inbound <-chan InboundMessage) <-chan OutboundMessage
• type OutboundMessage

Types

type DecrementTabCounter

type DecrementTabCounter struct{}

type InboundMessage

type InboundMessage struct {
	AccountID string
	Msg       any // Type of IncrementCounter, DecrementCounter, or twitch.IRCer
}

type IncrementTabCounter

type IncrementTabCounter struct{}

type Multiplexer

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

func NewMultiplexer

func NewMultiplexer(logger zerolog.Logger, provider twitch.AccountProvider) *Multiplexer

func (*Multiplexer) ListenAndServe

func (m *Multiplexer) ListenAndServe(inbound <-chan InboundMessage) <-chan OutboundMessage

type OutboundMessage

type OutboundMessage struct {
	ID  string
	Msg twitch.IRCer
	Err error
}