Documentation
¶
Index ¶
- Constants
- type ContactService
- type InitService
- type OrganizationService
- type Services
- type SyncCustomerOsDataService
- type SyncService
- func NewDefaultContactSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- func NewDefaultEmailMessageSyncService(repositories *repository.Repositories, services *Services, log logger.Logger) SyncService
- func NewDefaultInteractionEventSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- func NewDefaultIssueSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- func NewDefaultLogEntrySyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- func NewDefaultMeetingSyncService(repositories *repository.Repositories, services *Services, log logger.Logger) SyncService
- func NewDefaultOrderSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- func NewDefaultOrganizationSyncService(repositories *repository.Repositories, services *Services, cfg *config.Config, ...) SyncService
- func NewDefaultUserSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
- type SyncToEventStoreService
- type UserService
Constants ¶
View Source
const ( INBOUND string = "INBOUND" OUTBOUND string = "OUTBOUND" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContactService ¶
type ContactService interface {
GetIdForReferencedContact(ctx context.Context, tenant, externalSystem string, contact entity.ReferencedContact) (string, error)
}
func NewContactService ¶
func NewContactService(repositories *repository.Repositories) ContactService
type InitService ¶
type InitService interface {
Init()
}
func NewInitService ¶
func NewInitService(repositories *repository.Repositories, services *Services, log logger.Logger) InitService
type OrganizationService ¶
type OrganizationService interface {
GetIdForReferencedOrganization(ctx context.Context, tenant, externalSystem string, org entity.ReferencedOrganization) (string, error)
}
func NewOrganizationService ¶
func NewOrganizationService(repositories *repository.Repositories) OrganizationService
type Services ¶
type Services struct {
SyncCustomerOsDataService SyncCustomerOsDataService
SyncToEventStoreService SyncToEventStoreService
InitService InitService
OrganizationService OrganizationService
ContactService ContactService
UserService UserService
UserDefaultSyncService SyncService
OrganizationDefaultSyncService SyncService
ContactDefaultSyncService SyncService
IssueDefaultSyncService SyncService
LogEntryDefaultSyncService SyncService
MeetingDefaultSyncService SyncService
EmailMessageDefaultSyncService SyncService
InteractionEventDefaultSyncService SyncService
OrderDefaultSyncService SyncService
}
func InitServices ¶
func InitServices(cfg *config.Config, log logger.Logger, driver *neo4j.DriverWithContext, controlDb *gorm.DB, airbyteStoreDb *config.RawDataStoreDB, grpcClients *grpc_client.Clients) *Services
type SyncCustomerOsDataService ¶
func NewSyncCustomerOsDataService ¶
func NewSyncCustomerOsDataService(repositories *repository.Repositories, services *Services, cfg *config.Config, log logger.Logger) SyncCustomerOsDataService
type SyncService ¶
type SyncService interface {
Sync(ctx context.Context, sourceService source.SourceDataService, syncDate time.Time, tenant, runId string, batchSize int) (int, int, int)
}
func NewDefaultContactSyncService ¶
func NewDefaultContactSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultEmailMessageSyncService ¶
func NewDefaultEmailMessageSyncService(repositories *repository.Repositories, services *Services, log logger.Logger) SyncService
func NewDefaultInteractionEventSyncService ¶
func NewDefaultInteractionEventSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultIssueSyncService ¶
func NewDefaultIssueSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultLogEntrySyncService ¶
func NewDefaultLogEntrySyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultMeetingSyncService ¶
func NewDefaultMeetingSyncService(repositories *repository.Repositories, services *Services, log logger.Logger) SyncService
func NewDefaultOrderSyncService ¶
func NewDefaultOrderSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultOrganizationSyncService ¶
func NewDefaultOrganizationSyncService(repositories *repository.Repositories, services *Services, cfg *config.Config, log logger.Logger) SyncService
func NewDefaultUserSyncService ¶
func NewDefaultUserSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
type SyncToEventStoreService ¶
type SyncToEventStoreService interface {
SyncEmails(ctx context.Context, batchSize int)
SyncPhoneNumbers(ctx context.Context, batchSize int)
SyncLocations(ctx context.Context, batchSize int)
SyncContacts(ctx context.Context, batchSize int)
SyncOrganizations(ctx context.Context, batchSize int)
SyncOrganizationsLinksWithDomains(ctx context.Context, batchSize int)
}
func NewSyncToEventStoreService ¶
func NewSyncToEventStoreService(repositories *repository.Repositories, services *Services, grpcClients *grpc_client.Clients, log logger.Logger) SyncToEventStoreService
type UserService ¶
type UserService interface {
GetIdForReferencedUser(ctx context.Context, tenant, externalSystem string, user entity.ReferencedUser) (string, error)
}
func NewUserService ¶
func NewUserService(repositories *repository.Repositories) UserService
Source Files
¶
- contact_service.go
- contact_sync_service.go
- email_message_sync_service.go
- init_service.go
- interaction_event_sync_service.go
- issue_sync_service.go
- log_entry_sync_service.go
- meeting_sync_service.go
- order_sync_service.go
- organization_service.go
- organization_sync_service.go
- services.go
- sync_customer_os_data_service.go
- sync_interface.go
- sync_to_event_store_service.go
- user_service.go
- user_sync_service.go
Click to show internal directories.
Click to hide internal directories.