bucket

Documentation

Index

• type Bucket
  • func NewBucket(cns int) (b *Bucket)
  • func (b *Bucket) Channel(key string) (ch *channel.Channel)
  • func (b *Bucket) ChannelCount() int
  • func (b *Bucket) Del(dch *channel.Channel)
  • func (b *Bucket) IPCount() (res map[string]struct{})
  • func (b *Bucket) Put(ch *channel.Channel)

Types

type Bucket

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

Bucket is a channel holder.

func NewBucket

func NewBucket(cns int) (b *Bucket)

NewBucket new a bucket struct. store the key with im channel.

func (*Bucket) Channel

func (b *Bucket) Channel(key string) (ch *channel.Channel)

Channel get a channel by sub key.

func (*Bucket) ChannelCount

func (b *Bucket) ChannelCount() int

ChannelCount channel count in the bucket

func (*Bucket) Del

func (b *Bucket) Del(dch *channel.Channel)

Del delete the channel by sub key.

func (*Bucket) IPCount

func (b *Bucket) IPCount() (res map[string]struct{})

IPCount get ip count.

func (*Bucket) Put

func (b *Bucket) Put(ch *channel.Channel)

Put put a channel according with sub key.