event

Documentation

Overview

Package event handle client metric

Package event NOTES

Package event handle publish

Index

• Variables
• func Run(set dao.Set, state serviced.State, bds bedis.Client) error
• type ClientMetric
  • func NewClientMetric(set dao.Set, state serviced.State, bds bedis.Client, op client.Interface) ClientMetric
  • func (cm *ClientMetric) Run()
• type Publish
  • func NewPublish(set dao.Set, state serviced.State, bds bedis.Client, op client.Interface) Publish
  • func (cm *Publish) Run()

Variables

var MaxCacheConcurrent = 10

MaxCacheConcurrent is the max concurrent(goroutine) number of cache.

Functions

func Run

func Run(set dao.Set, state serviced.State, bds bedis.Client) error

Run the event watch task.

Types

type ClientMetric

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

ClientMetric xxx

func NewClientMetric

func NewClientMetric(set dao.Set, state serviced.State, bds bedis.Client, op client.Interface) ClientMetric

NewClientMetric init client metric

func (*ClientMetric) Run

func (cm *ClientMetric) Run()

Run the client metric task

type Publish

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

Publish xxx

func NewPublish

func NewPublish(set dao.Set, state serviced.State, bds bedis.Client, op client.Interface) Publish

NewPublish init publish

func (*Publish) Run

func (cm *Publish) Run()

Run the publish task