cqrs

type EventBusConfig struct {

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

type IEventBus interface {
}

type IEventBusSubscriptionsManager struct {
	OnEventRemoved map[string]chan int
	// contains filtered or unexported fields
}

type JsonMarshaler struct{}

type Marshaler interface {
	Marshal(v interface{}) ([]byte, string, error)
	Unmarshal(msg *message.Message, v reflect.Value) (err error)
}

type OnEventErrorFn func(params OnEventErrorParams)

type OnEventErrorParams struct {
	UId       string
	EventName string
	Message   *message.Message
	Time      time.Time
	Err       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{}

type SubscriptionInfo struct {
	IsDynamic   bool
	HandlerType reflect.Type
}