queue

package

v0.0.17 Latest Latest Go to latest Published: May 14, 2026 License: MIT Imports: 13 Imported by: 0

Details

View Source

const (
	Actions = "Action"

	DirectQueue = "DirectQueue"
	MainQueue   = "MainQueue"
	BackupQueue = "BackupQueue"
)

View Source

var ErrInvalidQueueID = errors.New("invalid queue id")

ErrInvalidQueueID is returned when an unrecognized queue ID is provided.

func DirectInstructionToAction(i *types.DirectInstruction) (*types.Action, error)

DirectInstructionToAction converts a DirectInstruction into an Action with a randomly generated ID.

func PrepareDirectAction(opType op.Type, opCommand op.Command, msg []byte) (*types.Action, error)

PrepareDirectAction prepares an action with direct instruction.

With type "direct" and submission tag "submit".

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

ActionQueues manages direct, main, and backup Redis-backed queues for action submission.

func NewActionQueues(client *redis.Client) *ActionQueues

NewActionQueues creates a new ActionQueues backed by the given Redis client.

func (as *ActionQueues) Dequeue(ctx context.Context, queueID processorutils.QueueID) (*types.Action, error)

Dequeue dequeues action from indicated queue. If no action is available, wrapped ErrEmptyQueue is dequeued.

func (as *ActionQueues) Enqueue(ctx context.Context, action *types.Action, queueID processorutils.QueueID) error

Enqueue stores the action and appends its submission ID to the indicated queue.

func (as *ActionQueues) QueueLength(ctx context.Context) (int64, error)

QueueLength returns the number of elements in the main queue.

type ActionSubmissionID struct {
	ActionID      common.Hash
	SubmissionTag types.SubmissionTag
}

ActionSubmissionID uniquely identifies an action by its action ID and submission tag.

func (id *ActionSubmissionID) String() string

String returns a combined string representation of the action ID and submission tag.