synchronizer_manager

package
v1.0.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 15, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v0.0.18

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL