sql

package

v0.1.21 Latest Latest Go to latest Published: Jul 28, 2026 License: Apache-2.0 Imports: 23 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 ¶

func New(ctx context.Context, dao *datly.Service, connectorRef string, ...) (reportstore.Client, error)
func NewAuditSink(store *Store) reportingsvc.AuditSink
func WithInternalAccess(ctx context.Context) context.Context
type Store

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(ctx context.Context, dao *datly.Service, connectorRef string, stateStore workspace.StateStore, fallback reportstore.Client) (reportstore.Client, error)

func NewAuditSink ¶

func NewAuditSink(store *Store) reportingsvc.AuditSink

func WithInternalAccess ¶

func WithInternalAccess(ctx context.Context) context.Context

Types ¶

type Store ¶

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

func (*Store) CreateJob ¶

func (s *Store) CreateJob(ctx context.Context, job *reportjob.Record) error

func (*Store) CreateSharedArtifact ¶

func (s *Store) CreateSharedArtifact(ctx context.Context, artifact *reportshareartifact.Record) error

func (*Store) GetArtifact ¶

func (s *Store) GetArtifact(ctx context.Context, artifactID string) (*reportartifact.Record, error)

func (*Store) GetJob ¶

func (s *Store) GetJob(ctx context.Context, jobID string) (*reportjob.Record, error)

func (*Store) GetSharedArtifact ¶

func (s *Store) GetSharedArtifact(ctx context.Context, artifactID string) (*reportshareartifact.Record, error)

func (*Store) ListArtifacts ¶

func (s *Store) ListArtifacts(ctx context.Context) ([]*reportartifact.Record, error)

func (*Store) ListJobs ¶

func (s *Store) ListJobs(ctx context.Context) ([]*reportjob.Record, error)

func (*Store) ListSharedArtifacts ¶

func (s *Store) ListSharedArtifacts(ctx context.Context) ([]*reportshareartifact.Record, error)

func (*Store) PutArtifact ¶

func (s *Store) PutArtifact(ctx context.Context, artifact *reportartifact.Record) error

func (*Store) UpdateJob ¶

func (s *Store) UpdateJob(ctx context.Context, job *reportjob.Record) error

func (*Store) UpdateSharedArtifact ¶

func (s *Store) UpdateSharedArtifact(ctx context.Context, artifact *reportshareartifact.Record) error

Source Files ¶

View all Source files

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