redis

package

v0.1.0 Latest Latest Go to latest Published: Apr 18, 2026 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrKeyNotFound = redis.Nil
)

This section is empty.

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

func New(redisCfg *config.RedisConfig) (*Client, error)

func (c *Client) ClearIncident(ctx context.Context, monitorID uuid.UUID) error

func (c *Client) ClearIncidentIfExists(ctx context.Context, monitorID uuid.UUID) (bool, error)

func (c *Client) ClearRetry(ctx context.Context, monitorID uuid.UUID) error

func (c *Client) Close() error

func (c *Client) DelMonitor(ctx context.Context, id uuid.UUID) error

func (c *Client) DelSchedule(ctx context.Context, monitorID string) error

func (c *Client) DelStatus(ctx context.Context, monitorID uuid.UUID) error

func (c *Client) GetIncident(ctx context.Context, monitorID uuid.UUID) (map[string]string, error)

func (c *Client) GetIncidentAlerted(ctx context.Context, monitorID uuid.UUID) (bool, error)

func (c *Client) GetMonitor(ctx context.Context, id uuid.UUID) (monitor.Monitor, bool)

func (c *Client) GetStatus(ctx context.Context, monitorID uuid.UUID) (map[string]string, error)

func (c *Client) IncrementIncident(ctx context.Context, monitorID uuid.UUID) (int64, bool, error)

func (c *Client) IncrementRetry(ctx context.Context, monitorID uuid.UUID) (int64, error)

func (c *Client) MarkDBIncidentCreated(ctx context.Context, monitorID uuid.UUID) error

func (c *Client) MarkIncidentAlerted(ctx context.Context, monitorID uuid.UUID) error

func (c *Client) MarkIncidentAlertedIfNotSet(ctx context.Context, monitorID uuid.UUID) (bool, error)

func (c *Client) MarkIncidentRecoveredAlertedIfNotSet(ctx context.Context, monitorID uuid.UUID) (bool, error)

func (c *Client) PopDue(ctx context.Context, batchCount int) ([]redis.Z, error)

func (c *Client) Schedule(ctx context.Context, monitorID string, runAt time.Time) error

func (c *Client) ScheduleBatch(ctx context.Context, items []redis.Z) error

func (c *Client) SetMonitor(ctx context.Context, m monitor.Monitor) error

func (c *Client) StoreStatus(ctx context.Context, monitorID uuid.UUID, statusCode int, latencyMs int64, checkedAt time.Time) error

Path	Synopsis
resend