Documentation ¶
Index ¶
- Variables
- type RedisBackend
- func (backend *RedisBackend) Cancel(id string) error
- func (backend *RedisBackend) ClearCancellation(id string) error
- func (backend *RedisBackend) FeedBack(taskStatus *mq.TaskStatus) error
- func (backend *RedisBackend) GetFeedback() (*mq.TaskStatus, error)
- func (backend *RedisBackend) IsCancelled(id string) (bool, error)
- func (backend *RedisBackend) ListChannel() ([]string, error)
- func (backend *RedisBackend) ListSubject(channel string) ([]string, error)
- func (backend *RedisBackend) RegisterChannel(channel string, subjects []string) error
- type RedisBroker
- type RedisConn
Constants ¶
This section is empty.
Variables ¶
View Source
var ChannelNamePrefix = "mq-channel-"
Functions ¶
This section is empty.
Types ¶
type RedisBackend ¶
type RedisBackend struct {
// contains filtered or unexported fields
}
func NewRedisBackend ¶
func NewRedisBackend(pool *redis.Pool, prefix string) *RedisBackend
func (*RedisBackend) Cancel ¶
func (backend *RedisBackend) Cancel(id string) error
func (*RedisBackend) ClearCancellation ¶
func (backend *RedisBackend) ClearCancellation(id string) error
func (*RedisBackend) FeedBack ¶
func (backend *RedisBackend) FeedBack(taskStatus *mq.TaskStatus) error
func (*RedisBackend) GetFeedback ¶
func (backend *RedisBackend) GetFeedback() (*mq.TaskStatus, error)
func (*RedisBackend) IsCancelled ¶
func (backend *RedisBackend) IsCancelled(id string) (bool, error)
func (*RedisBackend) ListChannel ¶
func (backend *RedisBackend) ListChannel() ([]string, error)
func (*RedisBackend) ListSubject ¶
func (backend *RedisBackend) ListSubject(channel string) ([]string, error)
func (*RedisBackend) RegisterChannel ¶
func (backend *RedisBackend) RegisterChannel(channel string, subjects []string) error
type RedisBroker ¶
type RedisBroker struct {
// contains filtered or unexported fields
}
func NewRedisBroker ¶
func NewRedisBroker(pool *redis.Pool, prefix string) *RedisBroker
Click to show internal directories.
Click to hide internal directories.