batch

Aug 15, 2026

retracted

Changes in this version

type StoredBatch

+ SessionID string

Jul 25, 2026

retracted

Changes in this version

+ type SQLStore struct

+ func NewSQLStore(ctx context.Context, db sqlx.DB) (*SQLStore, error)

+ func (s *SQLStore) Close() error

+ func (s *SQLStore) Create(ctx context.Context, batch *StoredBatch) error

+ func (s *SQLStore) Delete(ctx context.Context, id string) error

+ func (s *SQLStore) Get(ctx context.Context, id string) (*StoredBatch, error)

+ func (s *SQLStore) List(ctx context.Context, limit int, after string) ([]*StoredBatch, error)

+ func (s *SQLStore) Update(ctx context.Context, batch *StoredBatch) error

Jul 17, 2026

retracted

Changes in this version

type MemoryStore

+ func (s *MemoryStore) Delete(_ context.Context, id string) error

type MongoDBStore

+ func (s *MongoDBStore) Delete(ctx context.Context, id string) error

type PostgreSQLStore

+ func (s *PostgreSQLStore) Delete(ctx context.Context, id string) error

type SQLiteStore

+ func (s *SQLiteStore) Delete(ctx context.Context, id string) error

type Store

+ Delete func(ctx context.Context, id string) error

Jul 15, 2026

retracted

Changes in this version

+ const RequestIDMetadataKey

+ const UsageLoggedAtMetadataKey

+ var ErrNotFound = errors.New("batch not found")

+ type MemoryStore struct

+ func NewMemoryStore() *MemoryStore

+ func (s *MemoryStore) Close() error

+ func (s *MemoryStore) Create(_ context.Context, batch *StoredBatch) error

+ func (s *MemoryStore) Get(_ context.Context, id string) (*StoredBatch, error)

+ func (s *MemoryStore) List(_ context.Context, limit int, after string) ([]*StoredBatch, error)

+ func (s *MemoryStore) Update(_ context.Context, batch *StoredBatch) error

+ type MongoDBStore struct

+ func NewMongoDBStore(database *mongo.Database) (*MongoDBStore, error)

+ func (s *MongoDBStore) Close() error

+ func (s *MongoDBStore) Create(ctx context.Context, batch *StoredBatch) error

+ func (s *MongoDBStore) Get(ctx context.Context, id string) (*StoredBatch, error)

+ func (s *MongoDBStore) List(ctx context.Context, limit int, after string) ([]*StoredBatch, error)

+ func (s *MongoDBStore) Update(ctx context.Context, batch *StoredBatch) error

+ type PostgreSQLStore struct

+ func NewPostgreSQLStore(ctx context.Context, pool *pgxpool.Pool) (*PostgreSQLStore, error)

+ func (s *PostgreSQLStore) Close() error

+ func (s *PostgreSQLStore) Create(ctx context.Context, batch *StoredBatch) error

+ func (s *PostgreSQLStore) Get(ctx context.Context, id string) (*StoredBatch, error)

+ func (s *PostgreSQLStore) List(ctx context.Context, limit int, after string) ([]*StoredBatch, error)

+ func (s *PostgreSQLStore) Update(ctx context.Context, batch *StoredBatch) error

+ type Result struct

+ Storage storage.Storage

+ Store Store

+ func New(ctx context.Context, cfg *config.Config) (*Result, error)

+ func NewWithSharedStorage(ctx context.Context, shared storage.Storage) (*Result, error)

+ func (r *Result) Close() error

+ type SQLiteStore struct

+ func NewSQLiteStore(db *sql.DB) (*SQLiteStore, error)

+ func (s *SQLiteStore) Close() error

+ func (s *SQLiteStore) Create(ctx context.Context, batch *StoredBatch) error

+ func (s *SQLiteStore) Get(ctx context.Context, id string) (*StoredBatch, error)

+ func (s *SQLiteStore) List(ctx context.Context, limit int, after string) ([]*StoredBatch, error)

+ func (s *SQLiteStore) Update(ctx context.Context, batch *StoredBatch) error

+ type Store interface

+ Close func() error

+ Create func(ctx context.Context, batch *StoredBatch) error

+ Get func(ctx context.Context, id string) (*StoredBatch, error)

+ List func(ctx context.Context, limit int, after string) ([]*StoredBatch, error)

+ Update func(ctx context.Context, batch *StoredBatch) error

+ type StoredBatch struct

+ Batch *core.BatchResponse

+ OriginalInputFileID string

+ RequestEndpointByCustomID map[string]string

+ RequestID string

+ RewrittenInputFileID string

+ UsageEnabled *bool

+ UsageLoggedAt *time.Time

+ UserPath string

+ WorkflowVersionID string

+ func (s *StoredBatch) EffectiveUsageEnabled() bool