source

package
v0.0.0-...-064cf75 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 20, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MapJsonToContact

func MapJsonToContact(jsonData, syncId, source string) (entity.ContactData, error)

func MapJsonToEmailMessage

func MapJsonToEmailMessage(jsonData, syncId, source string) (entity.EmailMessageData, error)

func MapJsonToInteractionEvent

func MapJsonToInteractionEvent(jsonData, syncId, source string) (entity.InteractionEventData, error)

func MapJsonToIssue

func MapJsonToIssue(jsonData, syncId, source string) (entity.IssueData, error)

func MapJsonToLogEntry

func MapJsonToLogEntry(jsonData, syncId, source string) (entity.LogEntryData, error)

func MapJsonToMeeting

func MapJsonToMeeting(jsonData, syncId, source string) (entity.MeetingData, error)

func MapJsonToOrder

func MapJsonToOrder(jsonData, syncId, source string) (entity.OrderData, error)

func MapJsonToOrganization

func MapJsonToOrganization(jsonData, syncId, source string) (entity.OrganizationData, error)

func MapJsonToUser

func MapJsonToUser(jsonData, syncId, source string) (entity.UserData, error)

Types

type ProcessingEntity

type ProcessingEntity struct {
	ExternalId  string
	Entity      string
	TableSuffix string
}

type SourceDataService

type SourceDataService interface {
	Init()
	Close()
	SourceId() string
	GetDataForSync(ctx context.Context, dataType common.SyncedEntityType, batchSize int, runId string) []interface{}
	MarkProcessed(ctx context.Context, syncId, runId string, synced, skipped bool, reason string) error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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