worker

Documentation

Index

• Variables
• type Config
• type StoreQueues
  • func NewStoreQueues(num int) *StoreQueues
  • func (s *StoreQueues) Get(index int) *lane.Deque
  • func (s *StoreQueues) Set(index int, value interface{})
• type StoreWorker
  • func NewDelayer(conf *Config, batchConf client.BatchPointsConfig, client client.Client) *StoreWorker
  • func (s *StoreWorker) AsyncStoreSharePoint(point *client.Point) error
  • func (s *StoreWorker) Init() error
  • func (s *StoreWorker) Loop() error
  • func (s *StoreWorker) Stop()
  • func (s *StoreWorker) SyncStoreSharePoint(point *client.Point) error

Variables

var (
	ErrorUninitialized           = errors.New("Uninitialized Error.")
	ErrorInvalidConfigQueuesNum  = errors.New("Invalid Config QueuesNum.")
	ErrorInvalidConfigStoreCycle = errors.New("Invalid Config StoreCycle.")
	ErrorInvalidPackPointsSize   = errors.New("Invalid Config PackPointsSize.")
)

Types

type Config

type Config struct {
	StoreQueuesNum int
	StoreInterval  time.Duration
	PackPointsSize int
}

type StoreQueues

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

func NewStoreQueues

func NewStoreQueues(num int) *StoreQueues

func (*StoreQueues) Get

func (s *StoreQueues) Get(index int) *lane.Deque

func (*StoreQueues) Set

func (s *StoreQueues) Set(index int, value interface{})

type StoreWorker

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

func NewDelayer

func NewDelayer(conf *Config, batchConf client.BatchPointsConfig, client client.Client) *StoreWorker

func (*StoreWorker) AsyncStoreSharePoint

func (s *StoreWorker) AsyncStoreSharePoint(point *client.Point) error

func (*StoreWorker) Init

func (s *StoreWorker) Init() error

func (*StoreWorker) Loop

func (s *StoreWorker) Loop() error

func (*StoreWorker) Stop

func (s *StoreWorker) Stop()

func (*StoreWorker) SyncStoreSharePoint

func (s *StoreWorker) SyncStoreSharePoint(point *client.Point) error