syncer

type DeltaSyncer interface {
	// StartListeningForSyncRequests
	StartListeningForSyncRequests() // do we need this still?
	// StopListeningForSyncRequests
	StopListeningForSyncRequests() // do we need this still?
	// RegisterLocalTableSyncer
	RegisterLocalSyncer(itemType string, localTableSyncer LocalSyncer)
	// UnregisterLocalTableSyncer
	UnregisterLocalSyncer(itemType string, localTableSyncer LocalSyncer)
	// PublishSyncRequest
	PublishSyncRequest(ctx context.Context, tenantId tenant.Id, itemType string, itemId string, add bool)
	// GetInstanceCount
	GetInstanceCount(ctx context.Context) int
}

type DeltaSyncerGroup struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type InmemoryDeltaSyncer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type LocalSyncer interface {
	// SyncRoute
	SyncItem(ctx context.Context, tid tenant.Id, itemId string, add bool) error
}

type RedisDeltaSyncer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type SyncCommand struct {
	Cmd        string
	ItemType   string
	ItemId     string
	InstanceId string
	Sid        string
	Tenant     tenant.Id
}