messaging

type DefaultMessgingService struct {
	Logger          *zap.Logger
	Client          *redis.Client
	PendingSchedule string
	Settings        map[string]int64 // settings for streaming limit settings. default 10000
}

type GormAction string

type GormObjSyncService struct {
	MessageService MessagingService
	DB             *gorm.DB
	Logger         *zap.Logger
	Sharding       Sharding
}

type GormPayload struct {
	Key     string
	Action  GormAction
	Payload []byte
}

type IDbase interface {
	GetID() uint
}

type MessagingService interface {
	Pub(ctx context.Context, topic string, payload any) error
	Sub(ctx context.Context, topic, consumer string, processor Processor) error
}

type Processor func(ctx context.Context, topic, consumer string, payload []byte) error

type Sharding func(tx *gorm.DB, payload any) (tablename string, err error)