recorder

Documentation

Overview

Package recorder implements a binary that hosts luci.resultdb.v1.Recorder service.

Index

• Constants
• func InitServer(srv *server.Server, opt Options) error
• func NewRecorderServer(opts Options, casClient repb.ContentAddressableStorageClient) *pb.DecoratedRecorder
• type Options

Constants

const LookbackWindow = 1024

LookbackWindow is used when chunking. It specifies how many bytes we should look back to find new line/white space characters to split the chunks.

const MaxBatchCreateArtifactSize = 10 * 1024 * 1024

TODO(crbug.com/1177213) - make this configurable.

const MaxShardContentSize = bq.RowMaxBytes - 10*1024

MaxShardContentSize is the maximum content size in BQ row. Artifacts content bigger than this size needs to be sharded. Leave 10 KB for other fields, the rest is content.

const TestMagicOverdueDeadlineUnixSecs = 904924800

TestMagicOverdueDeadlineUnixSecs is a magic value used by tests to set an invocation's deadline in the past.

Functions

func InitServer

func InitServer(srv *server.Server, opt Options) error

InitServer initializes a recorder server.

func NewRecorderServer

func NewRecorderServer(opts Options, casClient repb.ContentAddressableStorageClient) *pb.DecoratedRecorder

Types

type Options

type Options struct {
	// Duration since invocation creation after which to delete expected test
	// results.
	ExpectedResultsExpiration time.Duration

	// ArtifactRBEInstance is the name of the RBE instance to use for artifact
	// storage. Example: "projects/luci-resultdb/instances/artifacts".
	ArtifactRBEInstance string

	// MaxArtifactContentStreamLength is the maximum size of an artifact content
	// to accept via streaming API.
	MaxArtifactContentStreamLength int64
}

Options is recorder server configuration.