redis

Documentation

Index

• type NodeStatusUpdate
• type RedisClient
  • func NewRedisClient(url string, logger logrus.FieldLogger) (RedisClient, error)

Types

type NodeStatusUpdate

type NodeStatusUpdate struct {
	RunID     int32          `json:"runId"`
	NodeID    int32          `json:"nodeId"`
	Status    string         `json:"status"`
	Timestamp time.Time      `json:"timestamp"`
	Details   map[string]any `json:"details,omitempty"`
}

type RedisClient

type RedisClient interface {
	InitializeRunningNodeSet(ctx context.Context, runID int32, nodeIDs []int32) error
	GetRunningNodeIDs(ctx context.Context, runID int32) (map[int32]struct{}, error)
	TryAcquireWorkflowRunFinalizationLock(ctx context.Context, runID int32) (bool, error)
	MarkNodeCompleteAndCountRemaining(
		ctx context.Context,
		runID int32,
		nodeID int32,
		nodeStatus string,
	) (*int, error)
	PublishNodeStatusUpdate(
		ctx context.Context,
		runID int32,
		nodeID int32,
		status string,
		details map[string]any,
	) error
	SubscribeWorkflowProgress(ctx context.Context) (<-chan *redis.Message, *redis.PubSub, error)

	// Calendar Events
	TryEventClaim(
		ctx context.Context,
		workflowCalendarID int32,
		eventID string,
		ttl time.Duration,
	) (bool, error)

	Close() error
}

func NewRedisClient

func NewRedisClient(url string, logger logrus.FieldLogger) (RedisClient, error)