syncservice

Documentation

Index

• type SyncService
  • func NewSyncService(log logr.Logger) (*SyncService, error)
  • func (s *SyncService) GetVersion(id string, msgType string) string
  • func (s *SyncService) SendAsync(id string, msgType string, version string, payload []byte)
  • 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) (*SyncService, error)

NewSyncService creates a new instance of SyncService.

func (*SyncService) GetVersion

func (s *SyncService) GetVersion(id string, msgType string) string

GetVersion if the object doesn't exist or an error occurred returns an empty string, otherwise returns the version.

func (*SyncService) SendAsync

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

SendAsync function sends a message to the sync service asynchronously.

func (*SyncService) Start

func (s *SyncService) Start()

Start function starts sync service.

func (*SyncService) Stop

func (s *SyncService) Stop()

Stop function stops sync service.