Versions in this module Expand all Collapse all v1 v1.7.2 Sep 2, 2021 Changes in this version + func DeleteStoredData(store Storage, metaData common.MetaData) common.SyncServiceError + func DeleteStoredObject(store Storage, metaData common.MetaData) common.SyncServiceError + func IsDiscarded(err error) bool + func IsNotConnected(err error) bool + func IsNotFound(err error) bool + type BoltStorage struct + func (store *BoltStorage) ActivateObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) AddObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *BoltStorage) AddUsersToACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *BoltStorage) AddWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *BoltStorage) AppendObjectData(orgID string, objectType string, objectID string, dataReader io.Reader, ...) common.SyncServiceError + func (store *BoltStorage) CleanObjects() common.SyncServiceError + func (store *BoltStorage) Cleanup(isTest bool) common.SyncServiceError + func (store *BoltStorage) CloseDataReader(dataReader io.Reader) common.SyncServiceError + func (store *BoltStorage) DecrementAndReturnRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *BoltStorage) DecrementAndReturnRemainingReceivers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *BoltStorage) DeleteDestination(orgID string, destType string, destID string) common.SyncServiceError + func (store *BoltStorage) DeleteNotificationRecords(orgID string, objectType string, objectID string, destType string, ...) common.SyncServiceError + func (store *BoltStorage) DeleteObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *BoltStorage) DeleteOrgToMessagingGroup(orgID string) common.SyncServiceError + func (store *BoltStorage) DeleteOrganization(orgID string) common.SyncServiceError + func (store *BoltStorage) DeleteOrganizationInfo(orgID string) common.SyncServiceError + func (store *BoltStorage) DeleteStoredData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) DeleteStoredObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) DeleteWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *BoltStorage) DestinationExists(orgID string, destType string, destID string) (bool, common.SyncServiceError) + func (store *BoltStorage) GetNumberOfDestinations() (uint32, common.SyncServiceError) + func (store *BoltStorage) GetNumberOfStoredObjects() (uint32, common.SyncServiceError) + func (store *BoltStorage) GetObjectDestinations(metaData common.MetaData) ([]common.Destination, common.SyncServiceError) + func (store *BoltStorage) GetObjectDestinationsList(orgID string, objectType string, objectID string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *BoltStorage) GetObjectsForDestination(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError) + func (store *BoltStorage) GetObjectsToActivate() ([]common.MetaData, common.SyncServiceError) + func (store *BoltStorage) Init() common.SyncServiceError + func (store *BoltStorage) InsertInitialLeader(leaderID string) (bool, common.SyncServiceError) + func (store *BoltStorage) IsConnected() bool + func (store *BoltStorage) IsPersistent() bool + func (store *BoltStorage) LeaderPeriodicUpdate(leaderID string) (bool, common.SyncServiceError) + func (store *BoltStorage) MarkDestinationPolicyReceived(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) MarkObjectDeleted(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) PerformMaintenance() + func (store *BoltStorage) ReadObjectData(orgID string, objectType string, objectID string, size int, offset int64) (data []byte, eof bool, length int, err common.SyncServiceError) + func (store *BoltStorage) RemoveInactiveDestinations(lastTimestamp time.Time) + func (store *BoltStorage) RemoveObjectTempData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) RemoveUsersFromACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *BoltStorage) ResetObjectRemainingConsumers(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) ResignLeadership(leaderID string) common.SyncServiceError + func (store *BoltStorage) RetrieveACL(aclType string, orgID string, key string, aclUserType string) ([]common.ACLentry, common.SyncServiceError) + func (store *BoltStorage) RetrieveACLsInOrg(aclType string, orgID string) ([]string, common.SyncServiceError) + func (store *BoltStorage) RetrieveAllObjects(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *BoltStorage) RetrieveAllObjectsAndUpdateDestinationListForDestination(destOrgID string, destType string, destID string) ([]common.MetaData, common.SyncServiceError) + func (store *BoltStorage) RetrieveConsumedObjects() ([]common.ConsumedObject, common.SyncServiceError) + func (store *BoltStorage) RetrieveDestination(orgID string, destType string, destID string) (*common.Destination, common.SyncServiceError) + func (store *BoltStorage) RetrieveDestinationProtocol(orgID string, destType string, destID string) (string, common.SyncServiceError) + func (store *BoltStorage) RetrieveDestinations(orgID string, destType string) ([]common.Destination, common.SyncServiceError) + func (store *BoltStorage) RetrieveLeader() (string, int32, time.Time, int64, common.SyncServiceError) + func (store *BoltStorage) RetrieveMessagingGroup(orgID string) (string, common.SyncServiceError) + func (store *BoltStorage) RetrieveNotificationRecord(orgID string, objectType string, objectID string, destType string, ...) (*common.Notification, common.SyncServiceError) + func (store *BoltStorage) RetrieveNotifications(orgID string, destType string, destID string, retrieveReceived bool) ([]common.Notification, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjOrDestTypeForGivenACLUser(aclType string, orgID string, aclUserType string, aclUsername string, ...) ([]string, common.SyncServiceError) + func (store *BoltStorage) RetrieveObject(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectAndRemovedDestinationPolicyServices(orgID string, objectType string, objectID string) (*common.MetaData, []common.ServiceID, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectAndStatus(orgID string, objectType string, objectID string) (*common.MetaData, string, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectStatus(orgID string, objectType string, objectID string) (string, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjects(orgID string, destType string, destID string, resend int) ([]common.MetaData, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectsWithDestinationPolicy(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectsWithDestinationPolicyByService(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectsWithDestinationPolicyUpdatedSince(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *BoltStorage) RetrieveObjectsWithFilters(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError) + func (store *BoltStorage) RetrieveOrganizationInfo(orgID string) (*common.StoredOrganization, common.SyncServiceError) + func (store *BoltStorage) RetrieveOrganizations() ([]common.StoredOrganization, common.SyncServiceError) + func (store *BoltStorage) RetrievePendingNotifications(orgID string, destType string, destID string) ([]common.Notification, common.SyncServiceError) + func (store *BoltStorage) RetrieveTempObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *BoltStorage) RetrieveTimeOnServer() (time.Time, error) + func (store *BoltStorage) RetrieveUpdatedMessagingGroups(time time.Time) ([]common.MessagingGroup, common.SyncServiceError) + func (store *BoltStorage) RetrieveUpdatedObjects(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError) + func (store *BoltStorage) RetrieveUpdatedOrganizations(time time.Time) ([]common.StoredOrganization, common.SyncServiceError) + func (store *BoltStorage) RetrieveWebhooks(orgID string, objectType string) ([]string, common.SyncServiceError) + func (store *BoltStorage) Stop() + func (store *BoltStorage) StoreDestination(destination common.Destination) common.SyncServiceError + func (store *BoltStorage) StoreObject(metaData common.MetaData, data []byte, status string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *BoltStorage) StoreObjectData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *BoltStorage) StoreObjectTempData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *BoltStorage) StoreOrgToMessagingGroup(orgID string, messagingGroup string) common.SyncServiceError + func (store *BoltStorage) StoreOrganization(org common.Organization) (time.Time, common.SyncServiceError) + func (store *BoltStorage) UpdateDestinationLastPingTime(destination common.Destination) common.SyncServiceError + func (store *BoltStorage) UpdateLeader(leaderID string, version int64) (bool, common.SyncServiceError) + func (store *BoltStorage) UpdateNotificationRecord(notification common.Notification) common.SyncServiceError + func (store *BoltStorage) UpdateNotificationResendTime(notification common.Notification) common.SyncServiceError + func (store *BoltStorage) UpdateObjectDelivering(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *BoltStorage) UpdateObjectDeliveryStatus(status string, message string, orgID string, objectType string, ...) (bool, common.SyncServiceError) + func (store *BoltStorage) UpdateObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *BoltStorage) UpdateObjectSourceDataURI(orgID string, objectType string, objectID string, sourceDataURI string) common.SyncServiceError + func (store *BoltStorage) UpdateObjectStatus(orgID string, objectType string, objectID string, status string) common.SyncServiceError + func (store *BoltStorage) UpdateRemovedDestinationPolicyServices(orgID string, objectType string, objectID string, ...) common.SyncServiceError + type Cache struct + Store Storage + func (store *Cache) ActivateObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) AddObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *Cache) AddUsersToACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *Cache) AddWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *Cache) AppendObjectData(orgID string, objectType string, objectID string, dataReader io.Reader, ...) common.SyncServiceError + func (store *Cache) CleanObjects() common.SyncServiceError + func (store *Cache) Cleanup(isTest bool) common.SyncServiceError + func (store *Cache) CloseDataReader(dataReader io.Reader) common.SyncServiceError + func (store *Cache) DecrementAndReturnRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *Cache) DecrementAndReturnRemainingReceivers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *Cache) DeleteDestination(orgID string, destType string, destID string) common.SyncServiceError + func (store *Cache) DeleteNotificationRecords(orgID string, objectType string, objectID string, destType string, ...) common.SyncServiceError + func (store *Cache) DeleteObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *Cache) DeleteOrgToMessagingGroup(orgID string) common.SyncServiceError + func (store *Cache) DeleteOrganization(orgID string) common.SyncServiceError + func (store *Cache) DeleteOrganizationInfo(orgID string) common.SyncServiceError + func (store *Cache) DeleteStoredData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) DeleteStoredObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) DeleteWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *Cache) DestinationExists(orgID string, destType string, destID string) (bool, common.SyncServiceError) + func (store *Cache) GetNumberOfDestinations() (uint32, common.SyncServiceError) + func (store *Cache) GetNumberOfStoredObjects() (uint32, common.SyncServiceError) + func (store *Cache) GetObjectDestinations(metaData common.MetaData) ([]common.Destination, common.SyncServiceError) + func (store *Cache) GetObjectDestinationsList(orgID string, objectType string, objectID string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *Cache) GetObjectsForDestination(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError) + func (store *Cache) GetObjectsToActivate() ([]common.MetaData, common.SyncServiceError) + func (store *Cache) Init() common.SyncServiceError + func (store *Cache) InsertInitialLeader(leaderID string) (bool, common.SyncServiceError) + func (store *Cache) IsConnected() bool + func (store *Cache) IsPersistent() bool + func (store *Cache) LeaderPeriodicUpdate(leaderID string) (bool, common.SyncServiceError) + func (store *Cache) MarkDestinationPolicyReceived(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) MarkObjectDeleted(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) PerformMaintenance() + func (store *Cache) ReadObjectData(orgID string, objectType string, objectID string, size int, offset int64) ([]byte, bool, int, common.SyncServiceError) + func (store *Cache) RemoveInactiveDestinations(lastTimestamp time.Time) + func (store *Cache) RemoveObjectTempData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) RemoveUsersFromACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *Cache) ResetObjectRemainingConsumers(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) ResignLeadership(leaderID string) common.SyncServiceError + func (store *Cache) RetrieveACL(aclType string, orgID string, key string, aclUserType string) ([]common.ACLentry, common.SyncServiceError) + func (store *Cache) RetrieveACLsInOrg(aclType string, orgID string) ([]string, common.SyncServiceError) + func (store *Cache) RetrieveAllObjects(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *Cache) RetrieveAllObjectsAndUpdateDestinationListForDestination(orgID string, destType string, destID string) ([]common.MetaData, common.SyncServiceError) + func (store *Cache) RetrieveConsumedObjects() ([]common.ConsumedObject, common.SyncServiceError) + func (store *Cache) RetrieveDestination(orgID string, destType string, destID string) (*common.Destination, common.SyncServiceError) + func (store *Cache) RetrieveDestinationProtocol(orgID string, destType string, destID string) (string, common.SyncServiceError) + func (store *Cache) RetrieveDestinations(orgID string, destType string) ([]common.Destination, common.SyncServiceError) + func (store *Cache) RetrieveLeader() (string, int32, time.Time, int64, common.SyncServiceError) + func (store *Cache) RetrieveMessagingGroup(orgID string) (string, common.SyncServiceError) + func (store *Cache) RetrieveNotificationRecord(orgID string, objectType string, objectID string, destType string, ...) (*common.Notification, common.SyncServiceError) + func (store *Cache) RetrieveNotifications(orgID string, destType string, destID string, retrieveReceived bool) ([]common.Notification, common.SyncServiceError) + func (store *Cache) RetrieveObjOrDestTypeForGivenACLUser(aclType string, orgID string, aclUserType string, aclUsername string, ...) ([]string, common.SyncServiceError) + func (store *Cache) RetrieveObject(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError) + func (store *Cache) RetrieveObjectAndRemovedDestinationPolicyServices(orgID string, objectType string, objectID string) (*common.MetaData, []common.ServiceID, common.SyncServiceError) + func (store *Cache) RetrieveObjectAndStatus(orgID string, objectType string, objectID string) (*common.MetaData, string, common.SyncServiceError) + func (store *Cache) RetrieveObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *Cache) RetrieveObjectRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *Cache) RetrieveObjectStatus(orgID string, objectType string, objectID string) (string, common.SyncServiceError) + func (store *Cache) RetrieveObjects(orgID string, destType string, destID string, resend int) ([]common.MetaData, common.SyncServiceError) + func (store *Cache) RetrieveObjectsWithDestinationPolicy(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *Cache) RetrieveObjectsWithDestinationPolicyByService(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *Cache) RetrieveObjectsWithDestinationPolicyUpdatedSince(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *Cache) RetrieveObjectsWithFilters(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError) + func (store *Cache) RetrieveOrganizationInfo(orgID string) (*common.StoredOrganization, common.SyncServiceError) + func (store *Cache) RetrieveOrganizations() ([]common.StoredOrganization, common.SyncServiceError) + func (store *Cache) RetrievePendingNotifications(orgID string, destType string, destID string) ([]common.Notification, common.SyncServiceError) + func (store *Cache) RetrieveTempObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *Cache) RetrieveTimeOnServer() (time.Time, error) + func (store *Cache) RetrieveUpdatedMessagingGroups(time time.Time) ([]common.MessagingGroup, common.SyncServiceError) + func (store *Cache) RetrieveUpdatedObjects(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError) + func (store *Cache) RetrieveUpdatedOrganizations(time time.Time) ([]common.StoredOrganization, common.SyncServiceError) + func (store *Cache) RetrieveWebhooks(orgID string, objectType string) ([]string, common.SyncServiceError) + func (store *Cache) Stop() + func (store *Cache) StoreDestination(dest common.Destination) common.SyncServiceError + func (store *Cache) StoreObject(metaData common.MetaData, data []byte, status string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *Cache) StoreObjectData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *Cache) StoreObjectTempData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *Cache) StoreOrgToMessagingGroup(orgID string, messagingGroup string) common.SyncServiceError + func (store *Cache) StoreOrganization(org common.Organization) (time.Time, common.SyncServiceError) + func (store *Cache) UpdateDestinationLastPingTime(destination common.Destination) common.SyncServiceError + func (store *Cache) UpdateLeader(leaderID string, version int64) (bool, common.SyncServiceError) + func (store *Cache) UpdateNotificationRecord(notification common.Notification) common.SyncServiceError + func (store *Cache) UpdateNotificationResendTime(notification common.Notification) common.SyncServiceError + func (store *Cache) UpdateObjectDelivering(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *Cache) UpdateObjectDeliveryStatus(status string, message string, orgID string, objectType string, ...) (bool, common.SyncServiceError) + func (store *Cache) UpdateObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *Cache) UpdateObjectSourceDataURI(orgID string, objectType string, objectID string, sourceDataURI string) common.SyncServiceError + func (store *Cache) UpdateObjectStatus(orgID string, objectType string, objectID string, status string) common.SyncServiceError + func (store *Cache) UpdateRemovedDestinationPolicyServices(orgID string, objectType string, objectID string, ...) common.SyncServiceError + type Discarded struct + func (e *Discarded) Error() string + type Error struct + func (e *Error) Error() string + type InMemoryStorage struct + func (store *InMemoryStorage) ActivateObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) AddObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *InMemoryStorage) AddUsersToACL(aclType string, orgID string, key string, usernames []common.ACLentry) common.SyncServiceError + func (store *InMemoryStorage) AddWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *InMemoryStorage) AppendObjectData(orgID string, objectType string, objectID string, dataReader io.Reader, ...) common.SyncServiceError + func (store *InMemoryStorage) CleanObjects() common.SyncServiceError + func (store *InMemoryStorage) Cleanup(isTest bool) common.SyncServiceError + func (store *InMemoryStorage) CloseDataReader(dataReader io.Reader) common.SyncServiceError + func (store *InMemoryStorage) DecrementAndReturnRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *InMemoryStorage) DecrementAndReturnRemainingReceivers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *InMemoryStorage) DeleteDestination(orgID string, destType string, destID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteNotificationRecords(orgID string, objectType string, objectID string, destType string, ...) common.SyncServiceError + func (store *InMemoryStorage) DeleteObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *InMemoryStorage) DeleteOrgToMessagingGroup(orgID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteOrganization(orgID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteOrganizationInfo(orgID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteStoredData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteStoredObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) DeleteWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *InMemoryStorage) DestinationExists(orgID string, destType string, destID string) (bool, common.SyncServiceError) + func (store *InMemoryStorage) GetNumberOfDestinations() (uint32, common.SyncServiceError) + func (store *InMemoryStorage) GetNumberOfStoredObjects() (uint32, common.SyncServiceError) + func (store *InMemoryStorage) GetObjectDestinations(metaData common.MetaData) ([]common.Destination, common.SyncServiceError) + func (store *InMemoryStorage) GetObjectDestinationsList(orgID string, objectType string, objectID string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *InMemoryStorage) GetObjectsForDestination(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError) + func (store *InMemoryStorage) GetObjectsToActivate() ([]common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) Init() common.SyncServiceError + func (store *InMemoryStorage) InsertInitialLeader(leaderID string) (bool, common.SyncServiceError) + func (store *InMemoryStorage) IsConnected() bool + func (store *InMemoryStorage) IsPersistent() bool + func (store *InMemoryStorage) LeaderPeriodicUpdate(leaderID string) (bool, common.SyncServiceError) + func (store *InMemoryStorage) MarkDestinationPolicyReceived(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) MarkObjectDeleted(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) PerformMaintenance() + func (store *InMemoryStorage) ReadObjectData(orgID string, objectType string, objectID string, size int, offset int64) ([]byte, bool, int, common.SyncServiceError) + func (store *InMemoryStorage) RemoveInactiveDestinations(lastTimestamp time.Time) + func (store *InMemoryStorage) RemoveObjectTempData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) RemoveUsersFromACL(aclType string, orgID string, key string, usernames []common.ACLentry) common.SyncServiceError + func (store *InMemoryStorage) ResetObjectRemainingConsumers(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) ResignLeadership(leaderID string) common.SyncServiceError + func (store *InMemoryStorage) RetrieveACL(aclType string, orgID string, key string, aclUserType string) ([]common.ACLentry, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveACLsInOrg(aclType string, orgID string) ([]string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveAllObjects(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveAllObjectsAndUpdateDestinationListForDestination(orgID string, destType string, destID string) ([]common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveConsumedObjects() ([]common.ConsumedObject, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveDestination(orgID string, destType string, destID string) (*common.Destination, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveDestinationProtocol(orgID string, destType string, destID string) (string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveDestinations(orgID string, destType string) ([]common.Destination, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveLeader() (string, int32, time.Time, int64, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveMessagingGroup(orgID string) (string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveNotificationRecord(orgID string, objectType string, objectID string, destType string, ...) (*common.Notification, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveNotifications(orgID string, destType string, destID string, retrieveReceived bool) ([]common.Notification, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjOrDestTypeForGivenACLUser(aclType string, orgID string, aclUserType string, aclUsername string, ...) ([]string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObject(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectAndRemovedDestinationPolicyServices(orgID string, objectType string, objectID string) (*common.MetaData, []common.ServiceID, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectAndStatus(orgID string, objectType string, objectID string) (*common.MetaData, string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectStatus(orgID string, objectType string, objectID string) (string, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjects(orgID string, destType string, destID string, resend int) ([]common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectsWithDestinationPolicy(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectsWithDestinationPolicyByService(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectsWithDestinationPolicyUpdatedSince(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveObjectsWithFilters(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveOrganizationInfo(orgID string) (*common.StoredOrganization, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveOrganizations() ([]common.StoredOrganization, common.SyncServiceError) + func (store *InMemoryStorage) RetrievePendingNotifications(orgID string, destType string, destID string) ([]common.Notification, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveTempObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveTimeOnServer() (time.Time, error) + func (store *InMemoryStorage) RetrieveUpdatedMessagingGroups(time time.Time) ([]common.MessagingGroup, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveUpdatedObjects(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveUpdatedOrganizations(time time.Time) ([]common.StoredOrganization, common.SyncServiceError) + func (store *InMemoryStorage) RetrieveWebhooks(orgID string, objectType string) ([]string, common.SyncServiceError) + func (store *InMemoryStorage) Stop() + func (store *InMemoryStorage) StoreDestination(destination common.Destination) common.SyncServiceError + func (store *InMemoryStorage) StoreObject(metaData common.MetaData, data []byte, status string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *InMemoryStorage) StoreObjectData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *InMemoryStorage) StoreObjectTempData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *InMemoryStorage) StoreOrgToMessagingGroup(orgID string, messagingGroup string) common.SyncServiceError + func (store *InMemoryStorage) StoreOrganization(org common.Organization) (time.Time, common.SyncServiceError) + func (store *InMemoryStorage) UpdateDestinationLastPingTime(destination common.Destination) common.SyncServiceError + func (store *InMemoryStorage) UpdateLeader(leaderID string, version int64) (bool, common.SyncServiceError) + func (store *InMemoryStorage) UpdateNotificationRecord(notification common.Notification) common.SyncServiceError + func (store *InMemoryStorage) UpdateNotificationResendTime(notification common.Notification) common.SyncServiceError + func (store *InMemoryStorage) UpdateObjectDelivering(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *InMemoryStorage) UpdateObjectDeliveryStatus(status string, message string, orgID string, objectType string, ...) (bool, common.SyncServiceError) + func (store *InMemoryStorage) UpdateObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *InMemoryStorage) UpdateObjectSourceDataURI(orgID string, objectType string, objectID string, sourceDataURI string) common.SyncServiceError + func (store *InMemoryStorage) UpdateObjectStatus(orgID string, objectType string, objectID string, status string) common.SyncServiceError + func (store *InMemoryStorage) UpdateRemovedDestinationPolicyServices(orgID string, objectType string, objectID string, ...) common.SyncServiceError + type MongoStorage struct + func (store *MongoStorage) ActivateObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) AddObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *MongoStorage) AddUsersToACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *MongoStorage) AddWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *MongoStorage) AppendObjectData(orgID string, objectType string, objectID string, dataReader io.Reader, ...) common.SyncServiceError + func (store *MongoStorage) CleanObjects() common.SyncServiceError + func (store *MongoStorage) Cleanup(isTest bool) common.SyncServiceError + func (store *MongoStorage) CloseDataReader(dataReader io.Reader) common.SyncServiceError + func (store *MongoStorage) DecrementAndReturnRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *MongoStorage) DecrementAndReturnRemainingReceivers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *MongoStorage) DeleteDestination(orgID string, destType string, destID string) common.SyncServiceError + func (store *MongoStorage) DeleteNotificationRecords(orgID string, objectType string, objectID string, destType string, ...) common.SyncServiceError + func (store *MongoStorage) DeleteObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *MongoStorage) DeleteOrgToMessagingGroup(orgID string) common.SyncServiceError + func (store *MongoStorage) DeleteOrganization(orgID string) common.SyncServiceError + func (store *MongoStorage) DeleteOrganizationInfo(orgID string) common.SyncServiceError + func (store *MongoStorage) DeleteStoredData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) DeleteStoredObject(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) DeleteWebhook(orgID string, objectType string, url string) common.SyncServiceError + func (store *MongoStorage) DestinationExists(orgID string, destType string, destID string) (bool, common.SyncServiceError) + func (store *MongoStorage) GetNumberOfDestinations() (uint32, common.SyncServiceError) + func (store *MongoStorage) GetNumberOfStoredObjects() (uint32, common.SyncServiceError) + func (store *MongoStorage) GetObjectDestinations(metaData common.MetaData) ([]common.Destination, common.SyncServiceError) + func (store *MongoStorage) GetObjectDestinationsList(orgID string, objectType string, objectID string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *MongoStorage) GetObjectsForDestination(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError) + func (store *MongoStorage) GetObjectsToActivate() ([]common.MetaData, common.SyncServiceError) + func (store *MongoStorage) Init() common.SyncServiceError + func (store *MongoStorage) InsertInitialLeader(leaderID string) (bool, common.SyncServiceError) + func (store *MongoStorage) IsConnected() bool + func (store *MongoStorage) IsPersistent() bool + func (store *MongoStorage) LeaderPeriodicUpdate(leaderID string) (bool, common.SyncServiceError) + func (store *MongoStorage) MarkDestinationPolicyReceived(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) MarkObjectDeleted(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) PerformMaintenance() + func (store *MongoStorage) ReadObjectData(orgID string, objectType string, objectID string, size int, offset int64) ([]byte, bool, int, common.SyncServiceError) + func (store *MongoStorage) RemoveInactiveDestinations(lastTimestamp time.Time) + func (store *MongoStorage) RemoveObjectTempData(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) RemoveUsersFromACL(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + func (store *MongoStorage) ResetObjectRemainingConsumers(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) ResignLeadership(leaderID string) common.SyncServiceError + func (store *MongoStorage) RetrieveACL(aclType string, orgID string, key string, aclUserType string) ([]common.ACLentry, common.SyncServiceError) + func (store *MongoStorage) RetrieveACLsInOrg(aclType string, orgID string) ([]string, common.SyncServiceError) + func (store *MongoStorage) RetrieveAllObjects(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *MongoStorage) RetrieveAllObjectsAndUpdateDestinationListForDestination(destOrgID string, destType string, destID string) ([]common.MetaData, common.SyncServiceError) + func (store *MongoStorage) RetrieveConsumedObjects() ([]common.ConsumedObject, common.SyncServiceError) + func (store *MongoStorage) RetrieveDestination(orgID string, destType string, destID string) (*common.Destination, common.SyncServiceError) + func (store *MongoStorage) RetrieveDestinationProtocol(orgID string, destType string, destID string) (string, common.SyncServiceError) + func (store *MongoStorage) RetrieveDestinations(orgID string, destType string) ([]common.Destination, common.SyncServiceError) + func (store *MongoStorage) RetrieveLeader() (string, int32, time.Time, int64, common.SyncServiceError) + func (store *MongoStorage) RetrieveMessagingGroup(orgID string) (string, common.SyncServiceError) + func (store *MongoStorage) RetrieveNotificationRecord(orgID string, objectType string, objectID string, destType string, ...) (*common.Notification, common.SyncServiceError) + func (store *MongoStorage) RetrieveNotifications(orgID string, destType string, destID string, retrieveReceived bool) ([]common.Notification, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjOrDestTypeForGivenACLUser(aclType string, orgID string, aclUserType string, aclUsername string, ...) ([]string, common.SyncServiceError) + func (store *MongoStorage) RetrieveObject(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectAndRemovedDestinationPolicyServices(orgID string, objectType string, objectID string) (*common.MetaData, []common.ServiceID, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectAndStatus(orgID string, objectType string, objectID string) (*common.MetaData, string, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectRemainingConsumers(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectStatus(orgID string, objectType string, objectID string) (string, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjects(orgID string, destType string, destID string, resend int) ([]common.MetaData, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectsWithDestinationPolicy(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectsWithDestinationPolicyByService(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectsWithDestinationPolicyUpdatedSince(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + func (store *MongoStorage) RetrieveObjectsWithFilters(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError) + func (store *MongoStorage) RetrieveOrganizationInfo(orgID string) (*common.StoredOrganization, common.SyncServiceError) + func (store *MongoStorage) RetrieveOrganizations() ([]common.StoredOrganization, common.SyncServiceError) + func (store *MongoStorage) RetrievePendingNotifications(orgID string, destType string, destID string) ([]common.Notification, common.SyncServiceError) + func (store *MongoStorage) RetrieveTempObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + func (store *MongoStorage) RetrieveTimeOnServer() (time.Time, error) + func (store *MongoStorage) RetrieveUpdatedMessagingGroups(time time.Time) ([]common.MessagingGroup, common.SyncServiceError) + func (store *MongoStorage) RetrieveUpdatedObjects(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError) + func (store *MongoStorage) RetrieveUpdatedOrganizations(time time.Time) ([]common.StoredOrganization, common.SyncServiceError) + func (store *MongoStorage) RetrieveWebhooks(orgID string, objectType string) ([]string, common.SyncServiceError) + func (store *MongoStorage) Stop() + func (store *MongoStorage) StoreDestination(destination common.Destination) common.SyncServiceError + func (store *MongoStorage) StoreObject(metaData common.MetaData, data []byte, status string) ([]common.StoreDestinationStatus, common.SyncServiceError) + func (store *MongoStorage) StoreObjectData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *MongoStorage) StoreObjectTempData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + func (store *MongoStorage) StoreOrgToMessagingGroup(orgID string, messagingGroup string) common.SyncServiceError + func (store *MongoStorage) StoreOrganization(org common.Organization) (time.Time, common.SyncServiceError) + func (store *MongoStorage) UpdateDestinationLastPingTime(destination common.Destination) common.SyncServiceError + func (store *MongoStorage) UpdateLeader(leaderID string, version int64) (bool, common.SyncServiceError) + func (store *MongoStorage) UpdateNotificationRecord(notification common.Notification) common.SyncServiceError + func (store *MongoStorage) UpdateNotificationResendTime(notification common.Notification) common.SyncServiceError + func (store *MongoStorage) UpdateObjectDelivering(orgID string, objectType string, objectID string) common.SyncServiceError + func (store *MongoStorage) UpdateObjectDeliveryStatus(status string, message string, orgID string, objectType string, ...) (bool, common.SyncServiceError) + func (store *MongoStorage) UpdateObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + func (store *MongoStorage) UpdateObjectSourceDataURI(orgID string, objectType string, objectID string, sourceDataURI string) common.SyncServiceError + func (store *MongoStorage) UpdateObjectStatus(orgID string, objectType string, objectID string, status string) common.SyncServiceError + func (store *MongoStorage) UpdateRemovedDestinationPolicyServices(orgID string, objectType string, objectID string, ...) common.SyncServiceError + type NotConnected struct + func (e *NotConnected) Error() string + type NotFound struct + func (e *NotFound) Error() string + type Storage interface + ActivateObject func(orgID string, objectType string, objectID string) common.SyncServiceError + AddObjectDestinations func(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + AddUsersToACL func(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + AddWebhook func(orgID string, objectType string, url string) common.SyncServiceError + AppendObjectData func(orgID string, objectType string, objectID string, dataReader io.Reader, ...) common.SyncServiceError + CleanObjects func() common.SyncServiceError + Cleanup func(isTest bool) common.SyncServiceError + CloseDataReader func(dataReader io.Reader) common.SyncServiceError + DecrementAndReturnRemainingConsumers func(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + DecrementAndReturnRemainingReceivers func(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + DeleteDestination func(orgID string, destType string, destID string) common.SyncServiceError + DeleteNotificationRecords func(orgID string, objectType string, objectID string, destType string, ...) common.SyncServiceError + DeleteObjectDestinations func(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + DeleteOrgToMessagingGroup func(orgID string) common.SyncServiceError + DeleteOrganization func(orgID string) common.SyncServiceError + DeleteOrganizationInfo func(orgID string) common.SyncServiceError + DeleteStoredData func(orgID string, objectType string, objectID string) common.SyncServiceError + DeleteStoredObject func(orgID string, objectType string, objectID string) common.SyncServiceError + DeleteWebhook func(orgID string, objectType string, url string) common.SyncServiceError + DestinationExists func(orgID string, destType string, destID string) (bool, common.SyncServiceError) + GetNumberOfDestinations func() (uint32, common.SyncServiceError) + GetNumberOfStoredObjects func() (uint32, common.SyncServiceError) + GetObjectDestinations func(metaData common.MetaData) ([]common.Destination, common.SyncServiceError) + GetObjectDestinationsList func(orgID string, objectType string, objectID string) ([]common.StoreDestinationStatus, common.SyncServiceError) + GetObjectsForDestination func(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError) + GetObjectsToActivate func() ([]common.MetaData, common.SyncServiceError) + Init func() common.SyncServiceError + InsertInitialLeader func(leaderID string) (bool, common.SyncServiceError) + IsConnected func() bool + IsPersistent func() bool + LeaderPeriodicUpdate func(leaderID string) (bool, common.SyncServiceError) + MarkDestinationPolicyReceived func(orgID string, objectType string, objectID string) common.SyncServiceError + MarkObjectDeleted func(orgID string, objectType string, objectID string) common.SyncServiceError + PerformMaintenance func() + ReadObjectData func(orgID string, objectType string, objectID string, size int, offset int64) ([]byte, bool, int, common.SyncServiceError) + RemoveInactiveDestinations func(lastTimestamp time.Time) + RemoveObjectTempData func(orgID string, objectType string, objectID string) common.SyncServiceError + RemoveUsersFromACL func(aclType string, orgID string, key string, users []common.ACLentry) common.SyncServiceError + ResetObjectRemainingConsumers func(orgID string, objectType string, objectID string) common.SyncServiceError + ResignLeadership func(leaderID string) common.SyncServiceError + RetrieveACL func(aclType string, orgID string, key string, aclUserType string) ([]common.ACLentry, common.SyncServiceError) + RetrieveACLsInOrg func(aclType string, orgID string) ([]string, common.SyncServiceError) + RetrieveAllObjects func(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + RetrieveAllObjectsAndUpdateDestinationListForDestination func(orgID string, destType string, destID string) ([]common.MetaData, common.SyncServiceError) + RetrieveConsumedObjects func() ([]common.ConsumedObject, common.SyncServiceError) + RetrieveDestination func(orgID string, destType string, destID string) (*common.Destination, common.SyncServiceError) + RetrieveDestinationProtocol func(orgID string, destType string, destID string) (string, common.SyncServiceError) + RetrieveDestinations func(orgID string, destType string) ([]common.Destination, common.SyncServiceError) + RetrieveLeader func() (string, int32, time.Time, int64, common.SyncServiceError) + RetrieveMessagingGroup func(orgID string) (string, common.SyncServiceError) + RetrieveNotificationRecord func(orgID string, objectType string, objectID string, destType string, ...) (*common.Notification, common.SyncServiceError) + RetrieveNotifications func(orgID string, destType string, destID string, retrieveReceived bool) ([]common.Notification, common.SyncServiceError) + RetrieveObjOrDestTypeForGivenACLUser func(aclType string, orgID string, aclUserType string, aclUsername string, ...) ([]string, common.SyncServiceError) + RetrieveObject func(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError) + RetrieveObjectAndRemovedDestinationPolicyServices func(orgID string, objectType string, objectID string) (*common.MetaData, []common.ServiceID, common.SyncServiceError) + RetrieveObjectAndStatus func(orgID string, objectType string, objectID string) (*common.MetaData, string, common.SyncServiceError) + RetrieveObjectData func(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + RetrieveObjectRemainingConsumers func(orgID string, objectType string, objectID string) (int, common.SyncServiceError) + RetrieveObjectStatus func(orgID string, objectType string, objectID string) (string, common.SyncServiceError) + RetrieveObjects func(orgID string, destType string, destID string, resend int) ([]common.MetaData, common.SyncServiceError) + RetrieveObjectsWithDestinationPolicy func(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + RetrieveObjectsWithDestinationPolicyByService func(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + RetrieveObjectsWithDestinationPolicyUpdatedSince func(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError) + RetrieveObjectsWithFilters func(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError) + RetrieveOrganizationInfo func(orgID string) (*common.StoredOrganization, common.SyncServiceError) + RetrieveOrganizations func() ([]common.StoredOrganization, common.SyncServiceError) + RetrievePendingNotifications func(orgID string, destType string, destID string) ([]common.Notification, common.SyncServiceError) + RetrieveTempObjectData func(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError) + RetrieveTimeOnServer func() (time.Time, error) + RetrieveUpdatedMessagingGroups func(time time.Time) ([]common.MessagingGroup, common.SyncServiceError) + RetrieveUpdatedObjects func(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError) + RetrieveUpdatedOrganizations func(time time.Time) ([]common.StoredOrganization, common.SyncServiceError) + RetrieveWebhooks func(orgID string, objectType string) ([]string, common.SyncServiceError) + Stop func() + StoreDestination func(destination common.Destination) common.SyncServiceError + StoreObject func(metaData common.MetaData, data []byte, status string) ([]common.StoreDestinationStatus, common.SyncServiceError) + StoreObjectData func(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + StoreObjectTempData func(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError) + StoreOrgToMessagingGroup func(orgID string, messagingGroup string) common.SyncServiceError + StoreOrganization func(org common.Organization) (time.Time, common.SyncServiceError) + UpdateDestinationLastPingTime func(destination common.Destination) common.SyncServiceError + UpdateLeader func(leaderID string, version int64) (bool, common.SyncServiceError) + UpdateNotificationRecord func(notification common.Notification) common.SyncServiceError + UpdateNotificationResendTime func(notification common.Notification) common.SyncServiceError + UpdateObjectDelivering func(orgID string, objectType string, objectID string) common.SyncServiceError + UpdateObjectDeliveryStatus func(status string, message string, orgID string, objectType string, ...) (bool, common.SyncServiceError) + UpdateObjectDestinations func(orgID string, objectType string, objectID string, destinationsList []string) (*common.MetaData, string, []common.StoreDestinationStatus, ...) + UpdateObjectSourceDataURI func(orgID string, objectType string, objectID string, sourceDataURI string) common.SyncServiceError + UpdateObjectStatus func(orgID string, objectType string, objectID string, status string) common.SyncServiceError + UpdateRemovedDestinationPolicyServices func(orgID string, objectType string, objectID string, ...) common.SyncServiceError