sync

Documentation

Index

• type Controller
  • func NewController(conf *common.Config) (*Controller, error)
  • func (c Controller) StartSyncForAll()
  • func (c Controller) StopSyncForAll()
• type Dst
• type Src
• type Synchronizer

Types

type Controller

type Controller struct {
	// SyncMap contains the map of series with active synchronization
	SyncMap map[string]*Synchronizer
	// contains filtered or unexported fields
}

func NewController

func NewController(conf *common.Config) (*Controller, error)

func (Controller) StartSyncForAll

func (c Controller) StartSyncForAll()

func (Controller) StopSyncForAll

func (c Controller) StopSyncForAll()

type Dst

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

type Src

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

type Synchronizer

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