turnqueue

package

v0.1.58 Latest Latest Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/agently-core

Links

Open Source Insights

Documentation ¶

Index ¶

type Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Store ¶

type Store struct {
	Invoker dexec.ComponentInvoker
}

Store maps the application's queue caller to the one generated reader and writer for turn_queue. Transaction ownership remains with the host runtime.

func (*Store) List ¶

func (s *Store) List(ctx context.Context, input *read.QueueRowsInput) ([]*read.QueueRowView, error)

func (*Store) Patch ¶

func (s *Store) Patch(ctx context.Context, row *write.TurnQueue) error

func (*Store) PatchMany ¶

func (s *Store) PatchMany(ctx context.Context, rows []*write.TurnQueue) error

PatchMany submits all queue changes to a single generated writer invocation. A late failure rolls back earlier rows under the host's transaction policy.

Source Files ¶

View all Source files

store.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL