channel

Documentation

Index

• type Channel
  • func NewChannel(ctx context.Context, conf *config.JSON) *Channel
  • func (c *Channel) Close()
  • func (c *Channel) IsEmpty() bool
  • func (c *Channel) Pop() (r element.Record, ok bool)
  • func (c *Channel) PopAll(onRecord func(element.Record) error) error
  • func (c *Channel) Push(r element.Record) (n int, err error)
  • func (c *Channel) PushAll(fetchRecord func() (element.Record, error)) error
  • func (c *Channel) PushTerminate() (n int)
  • func (c *Channel) Size() int
  • func (c *Channel) StatsJSON() StatsJSON
• type Stats
• type StatsJSON

Types

type Channel

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

Channel 通道

func NewChannel

func NewChannel(ctx context.Context, conf *config.JSON) *Channel

NewChannel 创建通道

func (*Channel) Close

func (c *Channel) Close()

Close 关闭

func (*Channel) IsEmpty

func (c *Channel) IsEmpty() bool

IsEmpty 通道是否为空

func (*Channel) Pop

func (c *Channel) Pop() (r element.Record, ok bool)

Pop 将记录弹出，当通道中不存在记录，就会返回false

func (*Channel) PopAll

func (c *Channel) PopAll(onRecord func(element.Record) error) error

PopAll 通过onRecord函数弹出多条记录

func (*Channel) Push

func (c *Channel) Push(r element.Record) (n int, err error)

Push 将记录r加入通道

func (*Channel) PushAll

func (c *Channel) PushAll(fetchRecord func() (element.Record, error)) error

PushAll 通过fetchRecord函数加入多条记录

func (*Channel) PushTerminate

func (c *Channel) PushTerminate() (n int)

PushTerminate 加入终止记录

func (*Channel) Size

func (c *Channel) Size() int

Size 通道记录大小

func (*Channel) StatsJSON

func (c *Channel) StatsJSON() StatsJSON

StatsJSON 返回Channel的统计信息

type Stats

type Stats struct {
	sync.RWMutex
	StatsJSON
}

Stats Channel的统计信息

type StatsJSON

type StatsJSON struct {
	TotalByte   int64 `json:"totalByte"`
	TotalRecord int64 `json:"totalRecord"`
	Byte        int64 `json:"byte"`
	Record      int64 `json:"record"`
}

StatsJSON Channel的JSON统计信息