dispenser

Documentation

Index

• Constants
• type State
  • func Initialize(s *state.State, channelID discord.ChannelID) (*State, error)
  • func (s *State) AddMessage(m discord.Message)
  • func (s *State) Broadcast(r templates.Renderer)
  • func (s *State) Close() error
  • func (s *State) CopyPool() templates.Messages
  • func (s *State) DeleteMessage(id discord.MessageID)
  • func (s *State) EditMessage(m discord.Message)
  • func (s *State) Handler(w http.ResponseWriter, r *http.Request) (int, error)
  • func (s *State) RegisterWriter(w io.Writer, ctx context.Context) (int, error)
  • func (s *State) StopTyping(user discord.User)

Constants

const BufSz = 25

const PoolBuf = 5

const TypingTimeout = 10 * time.Second

Types

type State

type State struct {
	MessagePool templates.Messages
	MessageMu   sync.Mutex
	LastAuthor  *discord.User

	Typers   *templates.Typing
	Typing   chan *gateway.TypingStartEvent
	StopType chan discord.User // userID

	Session   *state.State
	ChannelID discord.ChannelID
	GuildID   discord.GuildID

	ClientPool map[uint64]chan<- templates.Renderer
	ClientMu   sync.RWMutex
	Counter    uint64
	// contains filtered or unexported fields
}

func Initialize

func Initialize(s *state.State, channelID discord.ChannelID) (*State, error)

func (*State) AddMessage

func (s *State) AddMessage(m discord.Message)

func (*State) Broadcast

func (s *State) Broadcast(r templates.Renderer)

func (*State) Close

func (s *State) Close() error

func (*State) CopyPool

func (s *State) CopyPool() templates.Messages

func (*State) DeleteMessage

func (s *State) DeleteMessage(id discord.MessageID)

func (*State) EditMessage

func (s *State) EditMessage(m discord.Message)

func (*State) Handler

func (s *State) Handler(w http.ResponseWriter, r *http.Request) (int, error)

func (*State) RegisterWriter

func (s *State) RegisterWriter(w io.Writer, ctx context.Context) (int, error)

func (*State) StopTyping

func (s *State) StopTyping(user discord.User)