collector

Documentation

Index

• Constants
• func FireCollectors(collectors ...Collector)
• type Collector
• type Option
  • func Dao(d *dao.Dao) Option
  • func DiscoveryConf(dis *naming.Config) Option
  • func Interval(itvl xtime.Duration) Option
• type Options

Constants

const (
	DefaultItvl = xtime.Duration(3 * time.Second)
)

Functions

func FireCollectors

func FireCollectors(collectors ...Collector)

Types

type Collector

type Collector interface {
	Init(opts ...Option) error
	Collect() error
	Stop()
	ReCollect(opts ...Option) error
	Options() Options
	String() string
}

type Option

type Option func(o *Options)

func Dao

func Dao(d *dao.Dao) Option

func DiscoveryConf

func DiscoveryConf(dis *naming.Config) Option

func Interval

func Interval(itvl xtime.Duration) Option

type Options

type Options struct {
	Discovery *naming.Config
	Itvl      xtime.Duration
	Dao       *dao.Dao
	Context   context.Context
}