syncservice

Documentation

Index

• type SyncService
  • func NewSyncService(log logr.Logger, conflationManager *conflator.ConflationManager, ...) (*SyncService, error)
  • func (s *SyncService) Register(registration *transport.BundleRegistration)
  • func (s *SyncService) Start()
  • func (s *SyncService) Stop()

Types

type SyncService

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

SyncService abstracts Sync Service client.

func NewSyncService

func NewSyncService(log logr.Logger, conflationManager *conflator.ConflationManager,
	statistics *statistics.Statistics) (*SyncService, error)

NewSyncService creates a new instance of SyncService.

func (*SyncService) Register

func (s *SyncService) Register(registration *transport.BundleRegistration)

Register function registers a msgID for sync service to know how to create the bundle, and use predicate.

func (*SyncService) Start

func (s *SyncService) Start()

Start function starts sync service.

func (*SyncService) Stop

func (s *SyncService) Stop()

Stop function stops sync service.