base

package

Go to main page

Versions in this module

v1

v1.11.0

May 29, 2024

v1.10.1

Jun 30, 2023

v1.10.0

Mar 28, 2023

v1.9.11

Jun 30, 2023

v1.9.10

Feb 17, 2023

v1.9.9

Feb 17, 2023

v1.9.8

Oct 7, 2022

v1.9.7

Sep 8, 2022

v1.9.6

Jul 5, 2022

v1.9.5

Jun 30, 2022

v1.9.4

Jun 30, 2022

v1.9.3

Jun 16, 2022

v1.9.2

Jun 2, 2022

v1.9.1

May 10, 2022

v1.9.0

Apr 21, 2022

v1.8.9

Apr 12, 2022

v1.8.8

Apr 12, 2022

v1.8.7

Apr 11, 2022

v1.8.6

Mar 24, 2022

v1.8.5

Mar 16, 2022

v1.8.4

Feb 14, 2022

Changes in this version

+ func GetListOfObjTypes(objMetaList []common.MetaData) []string

v1.8.3

Feb 3, 2022

v1.8.2

Jan 25, 2022

v1.8.1

Jan 19, 2022

v1.8.0

Jan 11, 2022

v1.7.1

Sep 15, 2021

v1.7.0

Sep 2, 2021

v1.6.12

Oct 12, 2022

v1.6.11

May 16, 2022

v1.6.10

May 11, 2022

v1.6.9

Apr 20, 2022

Changes in this version

+ func GetObjectDataByChunk(orgID string, objectType string, objectID string, startOffset int64, ...) (int64, io.Reader, bool, int, common.SyncServiceError)

v1.6.8

Mar 23, 2022

Changes in this version

+ func PutObjectAllData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError)

+ func PutObjectChunkData(orgID string, objectType string, objectID string, dataReader io.Reader, ...) (bool, common.SyncServiceError)

+ type ObjectVerifyQueue struct

+ func NewObjectVerifyQueue(bufferSize uint64) *ObjectVerifyQueue

+ func (q *ObjectVerifyQueue) Close()

+ func (q *ObjectVerifyQueue) SendObjectToQueue(objectInVerifyQueue common.ObjectInVerifyQueue)

+ type ObjectWorkQueue struct

+ func NewObjectWorkQueue(bufferSize uint64) *ObjectWorkQueue

+ func (q *ObjectWorkQueue) Close()

+ func (q *ObjectWorkQueue) SendObjectToQueue(objectInQueue common.ObjectInQueue)

v1.6.7

Sep 2, 2021

v1.6.5

Aug 5, 2021

Changes in this version

+ func AddObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) common.SyncServiceError

+ func DeleteObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) common.SyncServiceError

v1.6.4

Jun 3, 2021

v1.6.3

May 28, 2021

v1.6.2

May 18, 2021

Changes in this version

+ func VerifyAndStoreData(data io.Reader, orgID string, objectType string, objectID string, ...) (bool, common.SyncServiceError)

v1.6.1

Apr 8, 2021

v1.5.3

Mar 2, 2021

v1.5.2

Jan 28, 2021

v1.5.1

Jan 22, 2021

v1.4.1

Sep 10, 2020

v0

v0.10.13

Jan 20, 2021

v0.10.12

Sep 10, 2020

Changes in this version

+ func GetAccessibleObjects(code int, orgID string, userOrgID string, userID string, ...) ([]common.MetaData, error)

+ func GetAccessibleObjectsDestinationPolicy(code int, orgID string, userOrgID string, userID string, ...) ([]common.ObjectDestinationPolicy, error)

v0.10.11

Mar 6, 2020

Changes in this version

+ var ConfigFile string

+ func ActivateObject(orgID string, objectType string, objectID string) common.SyncServiceError

+ func AddUsersToACL(aclType string, orgID string, key string, usernames []string) common.SyncServiceError

+ func AddWaiterForStartup(channel chan int) error

+ func BlockUntilShutdown()

+ func ConfigStandaloneSyncService()

+ func DeleteObject(orgID string, objectType string, objectID string) common.SyncServiceError

+ func DeleteWebhook(orgID string, objectType string, url string) common.SyncServiceError

+ func GetObject(orgID string, objectType string, objectID string) (*common.MetaData, common.SyncServiceError)

+ func GetObjectData(orgID string, objectType string, objectID string) (io.Reader, common.SyncServiceError)

+ func GetObjectDestinationsStatus(orgID string, objectType string, objectID string) ([]common.DestinationsStatus, common.SyncServiceError)

+ func GetObjectStatus(orgID string, objectType string, objectID string) (string, common.SyncServiceError)

+ func GetObjectsForDestination(orgID string, destType string, destID string) ([]common.ObjectStatus, common.SyncServiceError)

+ func GetRemovedDestinationPolicyServicesFromESS(orgID string, objectType string, objectID string) ([]common.ServiceID, common.SyncServiceError)

+ func ListAllObjects(orgID string, objectType string) ([]common.ObjectDestinationPolicy, common.SyncServiceError)

+ func ListDestinations(orgID string) ([]common.Destination, common.SyncServiceError)

+ func ListObjectsWithDestinationPolicy(orgID string, received bool) ([]common.ObjectDestinationPolicy, common.SyncServiceError)

+ func ListObjectsWithDestinationPolicyByService(orgID, serviceOrgID, serviceName string) ([]common.ObjectDestinationPolicy, common.SyncServiceError)

+ func ListObjectsWithDestinationPolicyUpdatedSince(orgID string, since int64) ([]common.ObjectDestinationPolicy, common.SyncServiceError)

+ func ListObjectsWithFilters(orgID string, destinationPolicy *bool, dpServiceOrgID string, ...) ([]common.MetaData, common.SyncServiceError)

+ func ListUpdatedObjects(orgID string, objectType string, received bool) ([]common.MetaData, common.SyncServiceError)

+ func ObjectConsumed(orgID string, objectType string, objectID string) common.SyncServiceError

+ func ObjectDeleted(userID string, orgID string, objectType string, objectID string) common.SyncServiceError

+ func ObjectPolicyReceived(orgID string, objectType string, objectID string) common.SyncServiceError

+ func ObjectReceived(orgID string, objectType string, objectID string) common.SyncServiceError

+ func PutObjectData(orgID string, objectType string, objectID string, dataReader io.Reader) (bool, common.SyncServiceError)

+ func RegisterWebhook(orgID string, objectType string, webhook string) common.SyncServiceError

+ func RemoveUsersFromACL(aclType string, orgID string, key string, usernames []string) common.SyncServiceError

+ func ResendObjects() common.SyncServiceError

+ func RetrieveACL(aclType string, orgID string, key string) ([]string, common.SyncServiceError)

+ func RetrieveACLsInOrg(aclType string, orgID string) ([]string, common.SyncServiceError)

+ func StandaloneSyncService(auth security.Authentication)

+ func Start(swaggerFile string, registerHandlers bool) common.SyncServiceError

+ func Stop(quiesceTime int, unregisterSelf bool)

+ func UpdateObject(orgID string, objectType string, objectID string, metaData common.MetaData, ...) common.SyncServiceError

+ func UpdateObjectDestinations(orgID string, objectType string, objectID string, destinationsList []string) common.SyncServiceError

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL