redis

Documentation

Index

• Variables
• type Client
  • func New(cfg Config) (*Client, error)
  • func (c *Client) DeleteMessage(ctx context.Context, id uuid.UUID) (err error)
  • func (c *Client) GetMessage(ctx context.Context, id uuid.UUID) (message.Message, error)
  • func (c *Client) GetStatus(ctx context.Context, id uuid.UUID) (message.Status, error)
  • func (c *Client) ListMessageIDs(ctx context.Context, status message.Status) ([]uuid.UUID, error)
  • func (c *Client) SetMessage(ctx context.Context, msg message.Message) (err error)
  • func (c *Client) UpdateMessage(ctx context.Context, msg message.Message) (err error)
• type Config

Variables

var (
	ErrMissingMessageID = errors.New("missing message ID")
	ErrStatusNotFound   = errors.New("status not found")
	ErrMultipleStatuses = errors.New("multiple status keys found")
	ErrLockHeld         = errors.New("lock already held")
	ErrUnlockFailed     = errors.New("failed to release lock")
)

Types

type Client

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

func New

func New(cfg Config) (*Client, error)

func (*Client) DeleteMessage

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

DeleteMessage deletes the message and its status from Redis. It ensures the operation is atomic by acquiring a lock on the key.

func (*Client) GetMessage

func (c *Client) GetMessage(ctx context.Context, id uuid.UUID) (message.Message, error)

func (*Client) GetStatus

func (c *Client) GetStatus(ctx context.Context, id uuid.UUID) (message.Status, error)

func (*Client) ListMessageIDs

func (c *Client) ListMessageIDs(ctx context.Context, status message.Status) ([]uuid.UUID, error)

func (*Client) SetMessage

func (c *Client) SetMessage(ctx context.Context, msg message.Message) (err error)

SetMessage stores the message in Redis and updates its status. It ensures the operation is atomic by acquiring a lock on the key.

func (*Client) UpdateMessage

func (c *Client) UpdateMessage(ctx context.Context, msg message.Message) (err error)

UpdateMessage updates the status, retry count, and updated at of the message. It ensures the operation is atomic by acquiring a lock on the key.

type Config

type Config struct {
	URL     string
	LockTTL time.Duration
}