| 909 | } |
| 910 | |
| 911 | func (c *Client) GetPluginTasks(ctx context.Context) ([]PluginTask, error) { |
| 912 | cmd, errClient := c.commandClient() |
| 913 | if errClient != nil { |
| 914 | return nil, errClient |
| 915 | } |
| 916 | raw, errGet := cmd.Get(ctx, redisKeyPluginTasks).Bytes() |
| 917 | if errors.Is(errGet, redis.Nil) { |
| 918 | return nil, nil |
| 919 | } |
| 920 | if errGet != nil { |
| 921 | return nil, errGet |
| 922 | } |
| 923 | if len(raw) == 0 { |
| 924 | return nil, nil |
| 925 | } |
| 926 | var tasks []PluginTask |
| 927 | if errUnmarshal := json.Unmarshal(raw, &tasks); errUnmarshal != nil { |
| 928 | return nil, errUnmarshal |
| 929 | } |
| 930 | return tasks, nil |
| 931 | } |
| 932 | |
| 933 | func (c *Client) handleSubscriptionPayload(ctx context.Context, channel string, payload string, onConfig func([]byte) error) error { |
| 934 | payload = strings.TrimSpace(payload) |