cqrs

type EventBusConfig struct {

	// 错误重试次数
	Retry int
	// 在发布事件前触发
	OnPublishBefore OnEventSendFn
	// 在发布事件后触发
	OnPublishAfter OnEventSendFn
	// 触发发布错误
	OnError OnEventErrorFn
	// 序列化器
	Marshaler Marshaler
}

type Handler struct {
	E              event.IntegrationEvent // event_interface
	UnSubscription chan int
	OnSubscription chan int
}

type IEventBus interface {
	// Subscribe 事件模型订阅
	Subscribe(ctx context.Context, e event.IntegrationEvent, h event.IDynamicIntegrationEventHandler)
	// SubscribeDynamic 根据事件名称进行订阅
	SubscribeDynamic(ctx context.Context, e string, h event.IDynamicIntegrationEventHandler)
	// SubscribeToDelay 延时订阅
	SubscribeToDelay(e event.IntegrationEvent, h event.IDynamicIntegrationEventHandler)
	// UnSubscribe 取消订阅
	UnSubscribe(e event.IntegrationEvent)
	// UnsubscribeDynamic 根据事件名称取消订阅
	UnsubscribeDynamic(e string)
	// Publish 推送事件
	Publish(e ...event.IntegrationEvent)
	// PublishToDelay 延时发布
	PublishToDelay(time time.Duration, e ...event.IntegrationEvent)
	// Disposable 销毁资源
	Disposable() error
}

type IEventBusSubscriptionsManager struct {
	// contains filtered or unexported fields
}

type JsonMarshaler struct{}

type Marshaler interface {
	Marshal(v interface{}) (*message.Message, error)
	Unmarshal(msg *message.Message, v interface{}) (err error)
}

type OnEventErrorFn func(params OnEventErrorParams)

type OnEventErrorParams struct {
	UId       uuid.UUID
	EventName string
	Message   *message.Message
	// contains filtered or unexported fields
}

type OnEventRemove func(eventName string) error

type OnEventSendFn func(params OnEventSendParams) error

type OnEventSendParams struct {
	UId       uuid.UUID
	EventName string
	Message   *message.Message
	// contains filtered or unexported fields
}

type ProtobufMarshaler struct{}