disway

Documentation

Index

• Variables
• type Cluster
  • func NewCluster(token string, logger *slog.Logger, opts ...sharding.ConfigOpt) *Cluster
  • func (c *Cluster) AddAllEventListener(f func(s int, t distype.EventType, e any))
  • func (c *Cluster) AddEventListener(t distype.EventType, f func(s int, e any))
  • func (c *Cluster) Close(ctx context.Context)
  • func (c *Cluster) Open(ctx context.Context)

Variables

var ErrWSAlreadyOpen = errors.New("web socket already opened")

ErrWSAlreadyOpen is thrown when you attempt to open a websocket that already is open.

var ErrWSNotFound = errors.New("no websocket connection exists")

ErrWSNotFound is thrown when you attempt to use a websocket that doesn't exist

var ErrWSShardBounds = errors.New("ShardID must be less than ShardCount")

ErrWSShardBounds is thrown when you try to use a shard ID that is more than the total shard count

Types

type Cluster

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

func NewCluster

func NewCluster(token string, logger *slog.Logger, opts ...sharding.ConfigOpt) *Cluster

func (*Cluster) AddAllEventListener

func (c *Cluster) AddAllEventListener(f func(s int, t distype.EventType, e any))

func (*Cluster) AddEventListener

func (c *Cluster) AddEventListener(t distype.EventType, f func(s int, e any))

func (*Cluster) Close

func (c *Cluster) Close(ctx context.Context)

func (*Cluster) Open

func (c *Cluster) Open(ctx context.Context)