syncservice

Documentation

Index

• type SyncService
  • func NewSyncService(compressor compressor.Compressor, ...) (*SyncService, error)
  • func (s *SyncService) SendAsync(destinationHubName string, id string, msgType string, version string, ...)
  • func (s *SyncService) Start()
  • func (s *SyncService) Stop()

Types

type SyncService

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

SyncService abstracts Open Horizon Sync Service usage.

func NewSyncService

func NewSyncService(compressor compressor.Compressor, syncServiceConfig *statussyncservice.SyncServiceConfig, log logr.Logger) (*SyncService, error)

NewSyncService returns a new instance of SyncService object.

func (*SyncService) SendAsync

func (s *SyncService) SendAsync(destinationHubName string, id string, msgType string, version string, payload []byte)

SendAsync sends a message to the sync service asynchronously.

func (*SyncService) Start

func (s *SyncService) Start()

Start starts the sync service.

func (*SyncService) Stop

func (s *SyncService) Stop()

Stop stops the sync service.