synchronizer_manager

Documentation

Index

• type Options
  • func NewOptions() *Options
• type Synchronizer
• type SynchronizerManager
  • func NewSynchronizerManager(options *Options) *SynchronizerManager
  • func NewSynchronizerManagerWithClient(client *core.Client, options *Options) *SynchronizerManager
  • func (sm *SynchronizerManager) Connect(host string, options *core.Options) error
  • func (sm *SynchronizerManager) Disconnect()
  • func (sm *SynchronizerManager) GetEndpoint() (*core.Endpoint, error)
  • func (sm *SynchronizerManager) GetPipelines(synchronizerID string) ([]uint64, error)
  • func (sm *SynchronizerManager) GetSynchronizers() ([]*Synchronizer, error)
  • func (sm *SynchronizerManager) Register(synchronizerID string) error
  • func (sm *SynchronizerManager) ReleasePipelines(synchronizerID string, pipelines []uint64) error

Types

type Options

type Options struct {
	Endpoint string
	Domain   string
	Key      *keyring.KeyInfo
	Verbose  bool
}

func NewOptions

func NewOptions() *Options

type Synchronizer

type Synchronizer struct {
	ID string
}

type SynchronizerManager

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

func NewSynchronizerManager

func NewSynchronizerManager(options *Options) *SynchronizerManager

func NewSynchronizerManagerWithClient

func NewSynchronizerManagerWithClient(client *core.Client, options *Options) *SynchronizerManager

func (*SynchronizerManager) Connect

func (sm *SynchronizerManager) Connect(host string, options *core.Options) error

func (*SynchronizerManager) Disconnect

func (sm *SynchronizerManager) Disconnect()

func (*SynchronizerManager) GetEndpoint

func (sm *SynchronizerManager) GetEndpoint() (*core.Endpoint, error)

func (*SynchronizerManager) GetPipelines

func (sm *SynchronizerManager) GetPipelines(synchronizerID string) ([]uint64, error)

func (*SynchronizerManager) GetSynchronizers

func (sm *SynchronizerManager) GetSynchronizers() ([]*Synchronizer, error)

func (*SynchronizerManager) Register

func (sm *SynchronizerManager) Register(synchronizerID string) error

func (*SynchronizerManager) ReleasePipelines

func (sm *SynchronizerManager) ReleasePipelines(synchronizerID string, pipelines []uint64) error