xmsgbus

type DecodeFunc[T ITopic] func(ctx context.Context, bs []byte) (T, error)

type EncodeFunc[T ITopic] func(ctx context.Context, dst T) ([]byte, error)

type Event struct {
	Metadata metadata.MD
	Topic    string
	Payload  []byte
}

type IMsgBus interface {
	// Push 推入数据
	Push(ctx context.Context, topic string, bs []byte) error
	// Pop 以阻塞的方式获取数据
	// blockTimeout 为 0 则永久阻塞 直到 context 退出 或 数据到达
	Pop(ctx context.Context, topic, channel string, blockTimeout time.Duration) (data []byte, ackFn func(), err error)
	// AddChannel 为 topic 添加 channel
	AddChannel(ctx context.Context, topic string, channel string) error
	// RemoveChannel 删除 Channel, channel 下的数据也应该被删除
	RemoveChannel(ctx context.Context, topic string, channel string) error
	// ListChannel 列出 Topic 下所有 Channel
	ListChannel(ctx context.Context, topic string) ([]string, error)
}

type IPublisher[T ITopic] interface {
	Publish(ctx context.Context, event T) error
}

type ISharedStorage interface {
	// SetEx 设置一个 值 ，并且设置它的过期时间
	SetEx(ctx context.Context, key string, value interface{}, ttl time.Duration) error
	// Keys 通过 前缀匹配 列出满足条件的 所有 Key
	Keys(ctx context.Context, prefix string) ([]string, error)
	// Del 删除 key
	Del(ctx context.Context, key string) error
}

type ISubscriber[T ITopic] interface {
	Handle(ctx context.Context) error
	// Close 取消订阅，这个操作必须成功
	Close(ctx context.Context)
}

type ITopic interface {
	Topic() string
}

type ITopicManager interface {
	// Register 注册
	Register(ctx context.Context, topic string, channel string, uuid string, ttl time.Duration) error
	// Unregister 取消注册
	Unregister(ctx context.Context, topic string, channel string, uuid string)
}

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

type OTELOption func(o *OTELOptions)

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

type Publisher[T ITopic] struct {
	// contains filtered or unexported fields
}

type PublisherOption[T ITopic] func(o *PublisherOptions[T])

type PublisherOptions[T ITopic] struct {
	Encode EncodeFunc[T]
}

type Subscriber[T ITopic] struct {
	// contains filtered or unexported fields
}

type SubscriberCheckFunc[T ITopic] func(ctx context.Context, dst T) bool

type SubscriberHandleFunc[T ITopic] func(ctx context.Context, dst T) error

type SubscriberOption[T ITopic] func(o *SubscriberOptions[T])

type SubscriberOptions[T ITopic] struct {
	HandleEvent SubscriberHandleFunc[T]
	CheckEvent  SubscriberCheckFunc[T]
	Decode      DecodeFunc[T]
}

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