Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SyncService ¶
type SyncService struct {
// contains filtered or unexported fields
}
SyncService abstracts Sync Service client.
func NewSyncService ¶
func NewSyncService(compressor compressors.Compressor, log logr.Logger) (*SyncService, error)
NewSyncService creates a new instance of SyncService.
func (*SyncService) SendAsync ¶
func (s *SyncService) SendAsync(message *transport.Message)
SendAsync function sends a message to the sync service asynchronously.
func (*SyncService) Subscribe ¶
func (s *SyncService) Subscribe(messageID string, callbacks map[transport.EventType]transport.EventCallback)
Subscribe adds a callback to be delegated when a given event occurs for a message with the given ID.
func (*SyncService) SupportsDeltaBundles ¶
func (s *SyncService) SupportsDeltaBundles() bool
SupportsDeltaBundles returns false. sync service doesn't support delta bundles.
Click to show internal directories.
Click to hide internal directories.