comet

package
v0.2.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrTaskJobCantInit = errors.New("task job can not init")

Functions

This section is empty.

Types

type Bucket 

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

Bucket is a channel holder.

func NewBucket 

func NewBucket(cfg *BucketConfig) (b *Bucket)

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

func (*Bucket) Broadcast 

func (b *Bucket) Broadcast(p *protocol.Proto)

Broadcast push messages to all channels in the bucket.

func (*Bucket) Channel 

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

Channel get a channel by sub key.

func (*Bucket) ChannelCount 

func (b *Bucket) ChannelCount() int

ChannelCount channel count in the bucket

func (*Bucket) ChannelsCount 

func (b *Bucket) ChannelsCount() (res []string)

func (*Bucket) Del 

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

Del delete the channel instance.

func (*Bucket) DelGroup 

func (b *Bucket) DelGroup(group *Group)

DelGroup delete group instance.

func (*Bucket) Group 

func (b *Bucket) Group(gid string) (group *Group)

Group get a group by group id.

func (*Bucket) GroupCast 

func (b *Bucket) GroupCast(gid string, p *protocol.Proto)

GroupCast broadcast a message in the specified group

func (*Bucket) GroupCount 

func (b *Bucket) GroupCount() int

GroupCount groups count in the bucket

func (*Bucket) GroupsCount 

func (b *Bucket) GroupsCount() (res map[string]int32)

GroupsCount get all group id where online number > 0.

func (*Bucket) Put 

func (b *Bucket) Put(ch *Channel) (err error)

Put hold a channel instance.

func (*Bucket) PutGroup 

func (b *Bucket) PutGroup(gid string) (group *Group, err error)

PutGroup new and got group instance by id.

type BucketConfig 

type BucketConfig struct {
	Size          int    `json:",default=32"`
	Channel       int    `json:",default=1024"`
	Groups        int    `json:",default=1024"`
	RoutineAmount uint64 `json:",default=32"`
	RoutineSize   int    `json:",default=1024"`
}

BucketConfig is bucket config.

type Channel 

type Channel struct {
	CliProto Ring

	Writer bufio.Writer
	Reader bufio.Reader

	Seq  int32
	Key  string
	IP   string
	Port string
	// contains filtered or unexported fields
}

Channel used by message pusher send msg to write goroutine.

func NewChannel 

func NewChannel(cli, svr int) *Channel

NewChannel new a channel.

func (*Channel) Close 

func (c *Channel) Close()

Close notice goroutine finish.

func (*Channel) DelNode 

func (c *Channel) DelNode(id string)

DelNode delete the group node by id

func (*Channel) GetGroups 

func (c *Channel) GetGroups() []string

func (*Channel) GetIP 

func (c *Channel) GetIP() string

func (*Channel) GetKey 

func (c *Channel) GetKey() string

func (*Channel) GetNode 

func (c *Channel) GetNode(id string) *Node

GetNode get a group node by id

func (*Channel) GetPort 

func (c *Channel) GetPort() string

func (*Channel) GetSeq 

func (c *Channel) GetSeq() int32

func (*Channel) Groups 

func (c *Channel) Groups() map[string]*Node

Groups get joined groups.

func (*Channel) Push 

func (c *Channel) Push(p *protocol.Proto) (err error)

Push server push message.

func (*Channel) Ready 

func (c *Channel) Ready() *protocol.Proto

Ready check the channel ready or close?

func (*Channel) Resend 

func (c *Channel) Resend()

Resend send signal to the channel, protocol resend.

func (*Channel) SetNode 

func (c *Channel) SetNode(id string, node *Node)

SetNode set a group node by id

func (*Channel) Signal 

func (c *Channel) Signal()

Signal send signal to the channel, protocol ready.

type Group 

type Group struct {
	ID string

	Online    int32 // dirty read is ok
	AllOnline int32
	// contains filtered or unexported fields
}

Group is a group and store channel group info.

func NewGroup 

func NewGroup(id string) (r *Group)

NewGroup new a group struct, store channel group info.

func (*Group) Close 

func (r *Group) Close()

Close remove group channel index.

func (*Group) Del 

func (r *Group) Del(ch *Channel) bool

Del delete channel from the group.

func (*Group) Members 

func (r *Group) Members() ([]string, []string)

Members group members Key,IP

func (*Group) OnlineNum 

func (r *Group) OnlineNum() int32

OnlineNum the group all online.

func (*Group) Push 

func (r *Group) Push(p *protocol.Proto)

Push broadcast msg inner group, if chan full discard it.

func (*Group) Put 

func (r *Group) Put(ch *Channel) (err error)

Put hold the channel instance.

type GroupCastReq 

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

type Node 

type Node struct {
	Current *Channel
	Next    *Node
	Prev    *Node
}

type Resend 

type Resend struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewResend 

func NewResend(connId string, rto time.Duration, taskPool *dtask.Task, repeatJob func()) *Resend

func (*Resend) Add 

func (rp *Resend) Add(p *protocol.Proto) error

func (*Resend) All 

func (rp *Resend) All() []*protocol.Proto

func (*Resend) Del 

func (rp *Resend) Del(seq int32)

func (*Resend) Stop 

func (rp *Resend) Stop()

type Ring 

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

Ring ring proto buffer.

func NewRing 

func NewRing(num int) *Ring

NewRing new a ring buffer.

func (*Ring) Get 

func (r *Ring) Get() (proto *protocol.Proto, err error)

Get a proto to read.

func (*Ring) GetAdv 

func (r *Ring) GetAdv()

GetAdv incr read index.

func (*Ring) Init 

func (r *Ring) Init(num int)

Init init ring.

func (*Ring) Reset 

func (r *Ring) Reset()

Reset reset ring.

func (*Ring) Set 

func (r *Ring) Set() (proto *protocol.Proto, err error)

Set get a proto to write.

func (*Ring) SetAdv 

func (r *Ring) SetAdv()

SetAdv incr write index.

type Round 

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

Round used for connection round-robin get a reader/writer/timer for split big lock.

func NewRound 

func NewRound(opts RoundOptions) (r *Round)

NewRound new a round struct.

func (*Round) Reader 

func (r *Round) Reader(rn int) *bytes.Pool

Reader get a reader memory buffer.

func (*Round) Timer 

func (r *Round) Timer(rn int) *time.Timer

Timer get a timer.

func (*Round) Writer 

func (r *Round) Writer(rn int) *bytes.Pool

Writer get a writer memory buffer pool.

type RoundOptions 

type RoundOptions struct {
	Timer        int
	TimerSize    int
	Reader       int
	ReadBuf      int
	ReadBufSize  int
	Writer       int
	WriteBuf     int
	WriteBufSize int
	Task         int
	TaskSize     int
}

RoundOptions round options.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.