dcomponent

type AsyncTask[T any] struct {
	// contains filtered or unexported fields
}

type Broker[T any] interface {
	Produce(ctx context.Context, task T) error
	Subscribe(ctx context.Context, cb func(task T))
}

type Cache interface {
	//Set save the data to the cache
	Set(ctx context.Context, key string, value interface{}, expire time.Duration) error
	//SetNX save the data to the cache if not exist
	SetNX(ctx context.Context, key string, value interface{}, expire time.Duration) error
	//SetHash save the data to hash cache
	SetHash(ctx context.Context, key, field string, value interface{}) error
	//UpdateExpire update the data expire time
	UpdateExpire(ctx context.Context, key string, expire time.Duration) error
	//Get get data from cache
	Get(ctx context.Context, key string, value interface{}) error
	MGet(ctx context.Context, keys []string, value interface{}) error
	//GetHash get the data to hash cache
	GetHash(ctx context.Context, key, field string, value interface{}) error
	//Keys get the keys match pattern
	Keys(ctx context.Context, pattern string) ([]string, error)
	//Exist Judge whether the key is existed
	Exist(ctx context.Context, key string) (bool, error)
	//SetAdd save unsorted list data to the cache
	SetAdd(ctx context.Context, key string, member interface{}) error
	//IsSetMember Judge whether the element is existed in the unsorted set
	IsSetMember(ctx context.Context, key string, member interface{}) (bool, error)
	//DelSetMember delete the member form the  unsorted list
	DelSetMember(ctx context.Context, key string, member ...interface{}) error
	//SetList save sorted list data to the cache
	SetList(ctx context.Context, key string, value interface{}) error
	//GetList get sorted list data from the cache
	GetList(ctx context.Context, key string, value interface{}) error
	//Delete delete cache
	Delete(ctx context.Context, key ...string) error
	//Name cache name
	Name() string
}

type DLock interface {
	Lock(key string, timeout time.Duration) error
	TryLock(key string, timeout time.Duration) (bool, error)
	Unlock(key string) error
}

type I18nTranslator interface {
	//Add add translation to i18n server
	Add(ctx context.Context, lang, key, trans string) error
	//Delete delete translation from i18n server
	Delete(ctx context.Context, lang, key string) error
	//Update update translation from i18n server
	Update(ctx context.Context, lang, key, trans string) error
	//TranslateKey translate key to language lang
	TranslateKey(ctx context.Context, lang, key string) string
	//Translate translate object i to language lang
	Translate(ctx context.Context, lang string, i interface{})
}

type Publisher interface {
	Product(ctx context.Context, topic string, message interface{}, messageExpiration time.Duration) error //Product 生产者模型，pub message,qos: Transient (0 or 1) or Persistent (2)
	Publish(ctx context.Context, topic string, message interface{}, messageExpiration time.Duration) error //广播模式
}

type RpcPublisher interface {
	RpcPublish(ctx context.Context, topic, replyTopic string, message, replyMessage interface{}, timeout time.Duration) error
}

type RpcSubscriber interface {
	RpcSubscribe(ctx context.Context, topic string, message interface{}, handler interface{})
}

type Subscriber interface {
	Consume(ctx context.Context, topic string, message interface{}, handler interface{})   //Consume 消费者模型
	Subscribe(ctx context.Context, topic string, message interface{}, handler interface{}) //话题订阅模式
}