service

Documentation

Index

• Constants
• type ContactService
  • func NewContactService(repositories *repository.Repositories) ContactService
• type InitService
  • func NewInitService(repositories *repository.Repositories, services *Services, log logger.Logger) InitService
• type OrganizationService
  • func NewOrganizationService(repositories *repository.Repositories) OrganizationService
• type Services
  • func InitServices(cfg *config.Config, log logger.Logger, driver *neo4j.DriverWithContext, ...) *Services
• type SyncCustomerOsDataService
  • func NewSyncCustomerOsDataService(repositories *repository.Repositories, services *Services, cfg *config.Config, ...) 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 NewDefaultOrganizationSyncService(repositories *repository.Repositories, services *Services, cfg *config.Config, ...) SyncService
  • func NewDefaultUserSyncService(repositories *repository.Repositories, cfg *config.Config, log logger.Logger) SyncService
• type UserService
  • func NewUserService(repositories *repository.Repositories) UserService

Constants

const (
	INBOUND  string = "INBOUND"
	OUTBOUND string = "OUTBOUND"
)

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
	InitService                        InitService
	OrganizationService                OrganizationService
	ContactService                     ContactService
	UserService                        UserService
	UserDefaultSyncService             SyncService
	OrganizationDefaultSyncService     SyncService
	ContactDefaultSyncService          SyncService
	IssueDefaultSyncService            SyncService
	LogEntryDefaultSyncService         SyncService
	MeetingDefaultSyncService          SyncService
	EmailMessageDefaultSyncService     SyncService
	InteractionEventDefaultSyncService SyncService
}

func InitServices

func InitServices(cfg *config.Config, log logger.Logger, driver *neo4j.DriverWithContext, postgresDB *commonConfig.PostgresDB, airbyteStoreDb *config.RawDataStoreDB, grpcClients *grpc_client.Clients) *Services

type SyncCustomerOsDataService

type SyncCustomerOsDataService interface {
	Sync(ctx context.Context, runId string)
}

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 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 UserService

type UserService interface {
	GetIdForReferencedUser(ctx context.Context, tenant, externalSystem string, user entity.ReferencedUser) (string, error)
}

func NewUserService

func NewUserService(repositories *repository.Repositories) UserService