messaging

Jun 26, 2025

Changes in this version

+ type MessagingAdaptor struct

+ ChanAdaaptor *core.ChanAdaptor[T]

+ Topic string

+ func (r *MessagingAdaptor[T]) Adaptor(ctx context.Context, topic, consumer string, payload []byte) error

+ func (r *MessagingAdaptor[T]) AsBridge(service MessagingService)

Apr 18, 2025

Changes in this version

+ var GormCallbackEnabled = true

Mar 13, 2025

Changes in this version

+ func GetMapping() map[string]reflect.Type

Feb 7, 2025

Changes in this version

+ type DispathFn func(ctx context.Context, topic, consumer string, kp *GormPayload, payload any, ...) error

type GormObjSyncService

+ Dispath DispathFn

+ func (ss *GormObjSyncService) Abandoned(kp *GormPayload, errCode, topic, consumer string)

+ func (ss *GormObjSyncService) ProcessGormObject(ctx context.Context, topic, consumer string, kp *GormPayload, payload any, ...) error

type GormPayload

+ SynctAt time.Time

+ func ToKeyAndPayload(raw []byte) (*GormPayload, error)

Nov 27, 2024

Changes in this version

+ var AbandonedChan chan any

+ var ConsumerName string

+ var ResetTopics []string

+ func GetPayloadID(payload any) (uint, bool)

+ type MessagnePending struct

+ Group string

+ Limit int

+ MaxBatch int

+ Schedule string

+ Topic string

Oct 17, 2024

Changes in this version

+ const SyncPageSize

+ func PubEntitiesSince(ctx context.Context, key string, since time.Time) error

+ func QueryEntities[T any](ctx context.Context, db *gorm.DB, logger *zap.Logger, since time.Time, ...) ([]any, error)

+ type QueryFn func(ctx context.Context, db *gorm.DB, logger *zap.Logger, since time.Time, ...) ([]any, error)

Jul 23, 2024

Changes in this version

+ var GormMessagingEnabled = true

Jul 22, 2024

Changes in this version

+ const DefaultAttKey

+ const DefaultDeadLetterDurtion

+ const DefaultMsgLimit

+ const DefaultSchedule

+ const GormActionDelete

+ const GormActionSave

+ var DefaultGormToipc = "scm.gorm.saved"

+ func GetRegisted() []any

+ func PubGormDeleted(ctx context.Context, payload any) error

+ func PubGormSaved(ctx context.Context, payload any) error

+ func Reg(payload any)

+ type DefaultMessgingService struct

+ Client *redis.Client

+ Logger *zap.Logger

+ PendingSchedule string

+ Settings map[string]int64

+ func (msg *DefaultMessgingService) ProcessPendings(ctx context.Context, topic, group string, processor Processor)

+ func (msg *DefaultMessgingService) Pub(ctx context.Context, topic string, payload any) error

+ func (msg *DefaultMessgingService) Sub(ctx context.Context, topic, group string, processor Processor) error

+ type GormAction string

+ type GormObjSyncService struct

+ DB *gorm.DB

+ Logger *zap.Logger

+ MessageService MessagingService

+ Sharding Sharding

+ func NewGormObjSyncService(ms MessagingService, logger *zap.Logger, db *gorm.DB) *GormObjSyncService

+ func (ss *GormObjSyncService) ReceiveGormObjectSaved(ctx context.Context, topic, consumer string, raw []byte) error

+ type GormPayload struct

+ Action GormAction

+ Key string

+ Payload []byte

+ type IDbase interface

+ GetID func() uint

+ type MessagingService interface

+ Pub func(ctx context.Context, topic string, payload any) error

+ Sub func(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)