resultstore

package

v0.0.166 Latest Latest Go to latest Published: Sep 29, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Details

resultstore fetches and process results from ResultStore.

This section is empty.

This section is empty.

func Connect(ctx context.Context, serviceAccountPath string) (*grpc.ClientConn, error)

Connect returns a secure gRPC connection.

Authenticates as the service account if specified otherwise the default user.

func ResultStoreColumnReader(client *DownloadClient, reprocess time.Duration) updater.ColumnReader

ResultStoreColumnReader fetches results since last update from ResultStore and translates them into columns.

func Updater(resultStoreClient *DownloadClient, gcsClient gcs.Client, groupTimeout time.Duration, write bool) updater.GroupUpdater

Updater returns a ResultStore-based GroupUpdater, which knows how to process result data stored in ResultStore.

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

DownloadClient provides a client to download ResultStore results from.

func NewClient(conn *grpc.ClientConn) *DownloadClient

NewClient uses the specified gRPC connection to connect to ResultStore.

func (c *DownloadClient) FetchInvocation(ctx context.Context, log logrus.FieldLogger, invocationID string) (*fetchResult, error)

FetchInvocation returns all details for a given invocation.

func (c *DownloadClient) Search(ctx context.Context, log logrus.FieldLogger, query, projectID string, fields ...string) ([]string, error)

Search finds all the invocations that satisfies the query condition within a project.

type TestResultStatus int64