pubsub

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

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

type Publisher interface {
	Publish(ctx context.Context, key string, value []byte) (err error)
}

type RedisLpushBrpop struct {
	Addr     string
	Password string
	Db       string
}

type Subscriber interface {
	Subscribe(ctx context.Context, key string, callBack func(value []byte, err error))
}