joinmgr

Documentation

Overview

Package joinmgr implements channel JOIN management in an environment with connection pooling and a global rate-limit in JOIN commands.

XXX: WIP, partially implemented

Index

• type JM
  • func New(per15 int) *JM
  • func (jm *JM) Connected(con *conpool.Con)
  • func (jm *JM) Disconnected(con *conpool.Con, err error)
  • func (jm *JM) Join(target string)
  • func (jm *JM) Joined(con *conpool.Con, msg *conpool.Message)
  • func (jm *JM) Part(target string)
  • func (jm *JM) Parted(con *conpool.Con, msg *conpool.Message)
  • func (jm *JM) Run(ctx context.Context, cpool *conpool.Pool, targets []string)

Types

type JM

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

func New

func New(per15 int) *JM

func (*JM) Connected

func (jm *JM) Connected(con *conpool.Con)

func (*JM) Disconnected

func (jm *JM) Disconnected(con *conpool.Con, err error)

func (*JM) Join

func (jm *JM) Join(target string)

Join a channel, eventually.

func (*JM) Joined

func (jm *JM) Joined(con *conpool.Con, msg *conpool.Message)

func (*JM) Part

func (jm *JM) Part(target string)

Part a channel, eventually.

func (*JM) Parted

func (jm *JM) Parted(con *conpool.Con, msg *conpool.Message)

func (*JM) Run

func (jm *JM) Run(ctx context.Context, cpool *conpool.Pool, targets []string)

Run performs channel synchronization in the background until the context is completed.