internal

package
v0.0.0-...-6abc620 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Buildlogger_CreateLog_FullMethodName      = "/cedar.Buildlogger/CreateLog"
	Buildlogger_AppendLogLines_FullMethodName = "/cedar.Buildlogger/AppendLogLines"
	Buildlogger_StreamLogLines_FullMethodName = "/cedar.Buildlogger/StreamLogLines"
	Buildlogger_CloseLog_FullMethodName       = "/cedar.Buildlogger/CloseLog"
)
View Source
const (
	CedarPerformanceMetrics_CreateMetricSeries_FullMethodName = "/cedar.CedarPerformanceMetrics/CreateMetricSeries"
	CedarPerformanceMetrics_AttachArtifacts_FullMethodName    = "/cedar.CedarPerformanceMetrics/AttachArtifacts"
	CedarPerformanceMetrics_AttachRollups_FullMethodName      = "/cedar.CedarPerformanceMetrics/AttachRollups"
	CedarPerformanceMetrics_SendMetrics_FullMethodName        = "/cedar.CedarPerformanceMetrics/SendMetrics"
	CedarPerformanceMetrics_CloseMetrics_FullMethodName       = "/cedar.CedarPerformanceMetrics/CloseMetrics"
)
View Source
const (
	CedarTestResults_CreateTestResultsRecord_FullMethodName = "/cedar.CedarTestResults/CreateTestResultsRecord"
	CedarTestResults_AddTestResults_FullMethodName          = "/cedar.CedarTestResults/AddTestResults"
	CedarTestResults_StreamTestResults_FullMethodName       = "/cedar.CedarTestResults/StreamTestResults"
	CedarTestResults_CloseTestResultsRecord_FullMethodName  = "/cedar.CedarTestResults/CloseTestResultsRecord"
)
View Source
const (
	Health_Check_FullMethodName = "/cedar.Health/Check"
)

Variables

View Source
var (
	LogStorage_name = map[int32]string{
		0: "LOG_STORAGE_S3",
		2: "LOG_STORAGE_LOCAL",
	}
	LogStorage_value = map[string]int32{
		"LOG_STORAGE_S3":    0,
		"LOG_STORAGE_LOCAL": 2,
	}
)

Enum value maps for LogStorage.

View Source
var (
	LogFormat_name = map[int32]string{
		0: "LOG_FORMAT_UNKNOWN",
		1: "LOG_FORMAT_TEXT",
		2: "LOG_FORMAT_JSON",
		3: "LOG_FORMAT_BSON",
	}
	LogFormat_value = map[string]int32{
		"LOG_FORMAT_UNKNOWN": 0,
		"LOG_FORMAT_TEXT":    1,
		"LOG_FORMAT_JSON":    2,
		"LOG_FORMAT_BSON":    3,
	}
)

Enum value maps for LogFormat.

View Source
var (
	DataFormat_name = map[int32]string{
		0: "TEXT",
		1: "FTDC",
		2: "BSON",
		3: "JSON",
		4: "CSV",
	}
	DataFormat_value = map[string]int32{
		"TEXT": 0,
		"FTDC": 1,
		"BSON": 2,
		"JSON": 3,
		"CSV":  4,
	}
)

Enum value maps for DataFormat.

View Source
var (
	CompressionType_name = map[int32]string{
		0: "NONE",
		1: "TARGZ",
		2: "ZIP",
		3: "GZ",
		4: "XZ",
	}
	CompressionType_value = map[string]int32{
		"NONE":  0,
		"TARGZ": 1,
		"ZIP":   2,
		"GZ":    3,
		"XZ":    4,
	}
)

Enum value maps for CompressionType.

View Source
var (
	SchemaType_name = map[int32]string{
		0: "RAW_EVENTS",
		1: "COLLAPSED_EVENTS",
		2: "INTERVAL_SUMMARIZATION",
		3: "HISTOGRAM",
	}
	SchemaType_value = map[string]int32{
		"RAW_EVENTS":             0,
		"COLLAPSED_EVENTS":       1,
		"INTERVAL_SUMMARIZATION": 2,
		"HISTOGRAM":              3,
	}
)

Enum value maps for SchemaType.

View Source
var (
	HealthCheckResponse_ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	HealthCheckResponse_ServingStatus_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for HealthCheckResponse_ServingStatus.

View Source
var (
	StorageLocation_name = map[int32]string{
		0: "UNKNOWN",
		1: "CEDAR_S3",
		2: "PROJECT_S3",
		4: "EPHEMERAL",
		5: "LOCAL",
	}
	StorageLocation_value = map[string]int32{
		"UNKNOWN":    0,
		"CEDAR_S3":   1,
		"PROJECT_S3": 2,
		"EPHEMERAL":  4,
		"LOCAL":      5,
	}
)

Enum value maps for StorageLocation.

View Source
var (
	RollupType_name = map[int32]string{
		0:  "SUM",
		1:  "MEAN",
		2:  "MEDIAN",
		3:  "MAX",
		4:  "MIN",
		5:  "STANDARD_DEVIATION",
		6:  "THROUGHPUT",
		7:  "LATENCY",
		8:  "PERCENTILE_99TH",
		9:  "PERCENTILE_95TH",
		10: "PERCENTILE_90TH",
		11: "PERCENTILE_80TH",
		12: "PERCENTILE_50TH",
	}
	RollupType_value = map[string]int32{
		"SUM":                0,
		"MEAN":               1,
		"MEDIAN":             2,
		"MAX":                3,
		"MIN":                4,
		"STANDARD_DEVIATION": 5,
		"THROUGHPUT":         6,
		"LATENCY":            7,
		"PERCENTILE_99TH":    8,
		"PERCENTILE_95TH":    9,
		"PERCENTILE_90TH":    10,
		"PERCENTILE_80TH":    11,
		"PERCENTILE_50TH":    12,
	}
)

Enum value maps for RollupType.

View Source
var Buildlogger_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedar.Buildlogger",
	HandlerType: (*BuildloggerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateLog",
			Handler:    _Buildlogger_CreateLog_Handler,
		},
		{
			MethodName: "AppendLogLines",
			Handler:    _Buildlogger_AppendLogLines_Handler,
		},
		{
			MethodName: "CloseLog",
			Handler:    _Buildlogger_CloseLog_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamLogLines",
			Handler:       _Buildlogger_StreamLogLines_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "buildlogger.proto",
}

Buildlogger_ServiceDesc is the grpc.ServiceDesc for Buildlogger service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var CedarPerformanceMetrics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedar.CedarPerformanceMetrics",
	HandlerType: (*CedarPerformanceMetricsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateMetricSeries",
			Handler:    _CedarPerformanceMetrics_CreateMetricSeries_Handler,
		},
		{
			MethodName: "AttachArtifacts",
			Handler:    _CedarPerformanceMetrics_AttachArtifacts_Handler,
		},
		{
			MethodName: "AttachRollups",
			Handler:    _CedarPerformanceMetrics_AttachRollups_Handler,
		},
		{
			MethodName: "CloseMetrics",
			Handler:    _CedarPerformanceMetrics_CloseMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendMetrics",
			Handler:       _CedarPerformanceMetrics_SendMetrics_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "perf.proto",
}

CedarPerformanceMetrics_ServiceDesc is the grpc.ServiceDesc for CedarPerformanceMetrics service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var CedarTestResults_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedar.CedarTestResults",
	HandlerType: (*CedarTestResultsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTestResultsRecord",
			Handler:    _CedarTestResults_CreateTestResultsRecord_Handler,
		},
		{
			MethodName: "AddTestResults",
			Handler:    _CedarTestResults_AddTestResults_Handler,
		},
		{
			MethodName: "CloseTestResultsRecord",
			Handler:    _CedarTestResults_CloseTestResultsRecord_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamTestResults",
			Handler:       _CedarTestResults_StreamTestResults_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "test_results.proto",
}

CedarTestResults_ServiceDesc is the grpc.ServiceDesc for CedarTestResults service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_buildlogger_proto protoreflect.FileDescriptor
View Source
var File_formats_proto protoreflect.FileDescriptor
View Source
var File_health_proto protoreflect.FileDescriptor
View Source
var File_test_results_proto protoreflect.FileDescriptor
View Source
var Health_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedar.Health",
	HandlerType: (*HealthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _Health_Check_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "health.proto",
}

Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func AttachBuildloggerService

func AttachBuildloggerService(env cedar.Environment, s *grpc.Server)

AttachBuildloggerService attaches the buildlogger service to the given gRPC server.

func AttachHealthService

func AttachHealthService(services map[string]HealthCheckResponse_ServingStatus, s *grpc.Server)

AttachHealthService attaches the health check service to the given gRPC server.

func AttachPerfService

func AttachPerfService(env cedar.Environment, s *grpc.Server)

AttachPerfService attaches the perf service to the given gRPC server.

func AttachTestResultsService

func AttachTestResultsService(env cedar.Environment, s *grpc.Server)

AttachTestResultsService attaches the test results service to the given gRPC server.

func BuildloggerServiceName

func BuildloggerServiceName() string

BuildloggerServiceName returns the grpc service identifier for this service.

func ExportRollupValues

func ExportRollupValues(r []*RollupValue) []model.PerfRollupValue

func HealthServiceName

func HealthServiceName() string

HealthServiceName returns the grpc service identifier for this service.

func PerfServiceName

func PerfServiceName() string

PerfServiceName returns the grpc service identifier for this service.

func RegisterBuildloggerServer

func RegisterBuildloggerServer(s grpc.ServiceRegistrar, srv BuildloggerServer)

func RegisterCedarPerformanceMetricsServer

func RegisterCedarPerformanceMetricsServer(s grpc.ServiceRegistrar, srv CedarPerformanceMetricsServer)

func RegisterCedarTestResultsServer

func RegisterCedarTestResultsServer(s grpc.ServiceRegistrar, srv CedarTestResultsServer)

func RegisterHealthServer

func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)

func TestResultsServiceName

func TestResultsServiceName() string

TestResultsServiceName returns the grpc service identifier for this service.

Types

type ArtifactData

type ArtifactData struct {
	Id        string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Artifacts []*ArtifactInfo `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactData) Descriptor deprecated

func (*ArtifactData) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactData.ProtoReflect.Descriptor instead.

func (*ArtifactData) GetArtifacts

func (x *ArtifactData) GetArtifacts() []*ArtifactInfo

func (*ArtifactData) GetId

func (x *ArtifactData) GetId() string

func (*ArtifactData) ProtoMessage

func (*ArtifactData) ProtoMessage()

func (*ArtifactData) ProtoReflect

func (x *ArtifactData) ProtoReflect() protoreflect.Message

func (*ArtifactData) Reset

func (x *ArtifactData) Reset()

func (*ArtifactData) String

func (x *ArtifactData) String() string

type ArtifactInfo

type ArtifactInfo struct {
	Location    StorageLocation        `protobuf:"varint,1,opt,name=location,proto3,enum=cedar.StorageLocation" json:"location,omitempty"`
	Bucket      string                 `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix      string                 `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Path        string                 `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	Format      DataFormat             `protobuf:"varint,5,opt,name=format,proto3,enum=cedar.DataFormat" json:"format,omitempty"`
	Compression CompressionType        `protobuf:"varint,6,opt,name=compression,proto3,enum=cedar.CompressionType" json:"compression,omitempty"`
	Schema      SchemaType             `protobuf:"varint,7,opt,name=schema,proto3,enum=cedar.SchemaType" json:"schema,omitempty"`
	Tags        []string               `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactInfo) Descriptor deprecated

func (*ArtifactInfo) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactInfo.ProtoReflect.Descriptor instead.

func (*ArtifactInfo) Export

func (a *ArtifactInfo) Export() *model.ArtifactInfo

func (*ArtifactInfo) GetBucket

func (x *ArtifactInfo) GetBucket() string

func (*ArtifactInfo) GetCompression

func (x *ArtifactInfo) GetCompression() CompressionType

func (*ArtifactInfo) GetCreatedAt

func (x *ArtifactInfo) GetCreatedAt() *timestamppb.Timestamp

func (*ArtifactInfo) GetFormat

func (x *ArtifactInfo) GetFormat() DataFormat

func (*ArtifactInfo) GetLocation

func (x *ArtifactInfo) GetLocation() StorageLocation

func (*ArtifactInfo) GetPath

func (x *ArtifactInfo) GetPath() string

func (*ArtifactInfo) GetPrefix

func (x *ArtifactInfo) GetPrefix() string

func (*ArtifactInfo) GetSchema

func (x *ArtifactInfo) GetSchema() SchemaType

func (*ArtifactInfo) GetTags

func (x *ArtifactInfo) GetTags() []string

func (*ArtifactInfo) ProtoMessage

func (*ArtifactInfo) ProtoMessage()

func (*ArtifactInfo) ProtoReflect

func (x *ArtifactInfo) ProtoReflect() protoreflect.Message

func (*ArtifactInfo) Reset

func (x *ArtifactInfo) Reset()

func (*ArtifactInfo) String

func (x *ArtifactInfo) String() string

type BuildloggerClient

type BuildloggerClient interface {
	CreateLog(ctx context.Context, in *LogData, opts ...grpc.CallOption) (*BuildloggerResponse, error)
	AppendLogLines(ctx context.Context, in *LogLines, opts ...grpc.CallOption) (*BuildloggerResponse, error)
	StreamLogLines(ctx context.Context, opts ...grpc.CallOption) (Buildlogger_StreamLogLinesClient, error)
	CloseLog(ctx context.Context, in *LogEndInfo, opts ...grpc.CallOption) (*BuildloggerResponse, error)
}

BuildloggerClient is the client API for Buildlogger service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type BuildloggerResponse

type BuildloggerResponse struct {
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildloggerResponse) Descriptor deprecated

func (*BuildloggerResponse) Descriptor() ([]byte, []int)

Deprecated: Use BuildloggerResponse.ProtoReflect.Descriptor instead.

func (*BuildloggerResponse) GetLogId

func (x *BuildloggerResponse) GetLogId() string

func (*BuildloggerResponse) ProtoMessage

func (*BuildloggerResponse) ProtoMessage()

func (*BuildloggerResponse) ProtoReflect

func (x *BuildloggerResponse) ProtoReflect() protoreflect.Message

func (*BuildloggerResponse) Reset

func (x *BuildloggerResponse) Reset()

func (*BuildloggerResponse) String

func (x *BuildloggerResponse) String() string

type BuildloggerServer

type BuildloggerServer interface {
	CreateLog(context.Context, *LogData) (*BuildloggerResponse, error)
	AppendLogLines(context.Context, *LogLines) (*BuildloggerResponse, error)
	StreamLogLines(Buildlogger_StreamLogLinesServer) error
	CloseLog(context.Context, *LogEndInfo) (*BuildloggerResponse, error)
	// contains filtered or unexported methods
}

BuildloggerServer is the server API for Buildlogger service. All implementations must embed UnimplementedBuildloggerServer for forward compatibility

type Buildlogger_StreamLogLinesClient

type Buildlogger_StreamLogLinesClient interface {
	Send(*LogLines) error
	CloseAndRecv() (*BuildloggerResponse, error)
	grpc.ClientStream
}

type Buildlogger_StreamLogLinesServer

type Buildlogger_StreamLogLinesServer interface {
	SendAndClose(*BuildloggerResponse) error
	Recv() (*LogLines, error)
	grpc.ServerStream
}

type CedarPerformanceMetricsClient

type CedarPerformanceMetricsClient interface {
	CreateMetricSeries(ctx context.Context, in *ResultData, opts ...grpc.CallOption) (*MetricsResponse, error)
	AttachArtifacts(ctx context.Context, in *ArtifactData, opts ...grpc.CallOption) (*MetricsResponse, error)
	AttachRollups(ctx context.Context, in *RollupData, opts ...grpc.CallOption) (*MetricsResponse, error)
	SendMetrics(ctx context.Context, opts ...grpc.CallOption) (CedarPerformanceMetrics_SendMetricsClient, error)
	CloseMetrics(ctx context.Context, in *MetricsSeriesEnd, opts ...grpc.CallOption) (*MetricsResponse, error)
}

CedarPerformanceMetricsClient is the client API for CedarPerformanceMetrics service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type CedarPerformanceMetricsServer

type CedarPerformanceMetricsServer interface {
	CreateMetricSeries(context.Context, *ResultData) (*MetricsResponse, error)
	AttachArtifacts(context.Context, *ArtifactData) (*MetricsResponse, error)
	AttachRollups(context.Context, *RollupData) (*MetricsResponse, error)
	SendMetrics(CedarPerformanceMetrics_SendMetricsServer) error
	CloseMetrics(context.Context, *MetricsSeriesEnd) (*MetricsResponse, error)
	// contains filtered or unexported methods
}

CedarPerformanceMetricsServer is the server API for CedarPerformanceMetrics service. All implementations must embed UnimplementedCedarPerformanceMetricsServer for forward compatibility

type CedarPerformanceMetrics_SendMetricsClient

type CedarPerformanceMetrics_SendMetricsClient interface {
	Send(*MetricsEvent) error
	CloseAndRecv() (*SendResponse, error)
	grpc.ClientStream
}

type CedarPerformanceMetrics_SendMetricsServer

type CedarPerformanceMetrics_SendMetricsServer interface {
	SendAndClose(*SendResponse) error
	Recv() (*MetricsEvent, error)
	grpc.ServerStream
}

type CedarTestResultsClient

type CedarTestResultsClient interface {
	CreateTestResultsRecord(ctx context.Context, in *TestResultsInfo, opts ...grpc.CallOption) (*TestResultsResponse, error)
	AddTestResults(ctx context.Context, in *TestResults, opts ...grpc.CallOption) (*TestResultsResponse, error)
	StreamTestResults(ctx context.Context, opts ...grpc.CallOption) (CedarTestResults_StreamTestResultsClient, error)
	CloseTestResultsRecord(ctx context.Context, in *TestResultsEndInfo, opts ...grpc.CallOption) (*TestResultsResponse, error)
}

CedarTestResultsClient is the client API for CedarTestResults service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type CedarTestResultsServer

type CedarTestResultsServer interface {
	CreateTestResultsRecord(context.Context, *TestResultsInfo) (*TestResultsResponse, error)
	AddTestResults(context.Context, *TestResults) (*TestResultsResponse, error)
	StreamTestResults(CedarTestResults_StreamTestResultsServer) error
	CloseTestResultsRecord(context.Context, *TestResultsEndInfo) (*TestResultsResponse, error)
	// contains filtered or unexported methods
}

CedarTestResultsServer is the server API for CedarTestResults service. All implementations must embed UnimplementedCedarTestResultsServer for forward compatibility

type CedarTestResults_StreamTestResultsClient

type CedarTestResults_StreamTestResultsClient interface {
	Send(*TestResults) error
	CloseAndRecv() (*TestResultsResponse, error)
	grpc.ClientStream
}

type CedarTestResults_StreamTestResultsServer

type CedarTestResults_StreamTestResultsServer interface {
	SendAndClose(*TestResultsResponse) error
	Recv() (*TestResults, error)
	grpc.ServerStream
}

type CompressionType

type CompressionType int32
const (
	CompressionType_NONE  CompressionType = 0
	CompressionType_TARGZ CompressionType = 1
	CompressionType_ZIP   CompressionType = 2
	CompressionType_GZ    CompressionType = 3
	CompressionType_XZ    CompressionType = 4
)

func (CompressionType) Descriptor

func (CompressionType) Enum

func (x CompressionType) Enum() *CompressionType

func (CompressionType) EnumDescriptor deprecated

func (CompressionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CompressionType.Descriptor instead.

func (CompressionType) Export

func (CompressionType) Number

func (CompressionType) String

func (x CompressionType) String() string

func (CompressionType) Type

type DataFormat

type DataFormat int32
const (
	DataFormat_TEXT DataFormat = 0
	DataFormat_FTDC DataFormat = 1
	DataFormat_BSON DataFormat = 2
	DataFormat_JSON DataFormat = 3
	DataFormat_CSV  DataFormat = 4
)

func (DataFormat) Descriptor

func (DataFormat) Descriptor() protoreflect.EnumDescriptor

func (DataFormat) Enum

func (x DataFormat) Enum() *DataFormat

func (DataFormat) EnumDescriptor deprecated

func (DataFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use DataFormat.Descriptor instead.

func (DataFormat) Export

func (f DataFormat) Export() model.FileDataFormat

func (DataFormat) Number

func (x DataFormat) Number() protoreflect.EnumNumber

func (DataFormat) String

func (x DataFormat) String() string

func (DataFormat) Type

type HealthCheckRequest

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckRequest) Descriptor deprecated

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetService

func (x *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect

func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

func (*HealthCheckRequest) Reset

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String

func (x *HealthCheckRequest) String() string

type HealthCheckResponse

type HealthCheckResponse struct {
	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=cedar.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus

func (*HealthCheckResponse) ProtoMessage

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect

func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message

func (*HealthCheckResponse) Reset

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String

func (x *HealthCheckResponse) String() string

type HealthCheckResponse_ServingStatus

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) Descriptor

func (HealthCheckResponse_ServingStatus) Enum

func (HealthCheckResponse_ServingStatus) EnumDescriptor deprecated

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.

func (HealthCheckResponse_ServingStatus) Number

func (HealthCheckResponse_ServingStatus) String

func (HealthCheckResponse_ServingStatus) Type

type HealthClient

type HealthClient interface {
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

HealthClient is the client API for Health service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHealthClient

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthServer

type HealthServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility

type LogData

type LogData struct {
	Info    *LogInfo   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Storage LogStorage `protobuf:"varint,2,opt,name=storage,proto3,enum=cedar.LogStorage" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

func (*LogData) Descriptor deprecated

func (*LogData) Descriptor() ([]byte, []int)

Deprecated: Use LogData.ProtoReflect.Descriptor instead.

func (*LogData) GetInfo

func (x *LogData) GetInfo() *LogInfo

func (*LogData) GetStorage

func (x *LogData) GetStorage() LogStorage

func (*LogData) ProtoMessage

func (*LogData) ProtoMessage()

func (*LogData) ProtoReflect

func (x *LogData) ProtoReflect() protoreflect.Message

func (*LogData) Reset

func (x *LogData) Reset()

func (*LogData) String

func (x *LogData) String() string

type LogEndInfo

type LogEndInfo struct {
	LogId    string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	ExitCode int32  `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEndInfo) Descriptor deprecated

func (*LogEndInfo) Descriptor() ([]byte, []int)

Deprecated: Use LogEndInfo.ProtoReflect.Descriptor instead.

func (*LogEndInfo) GetExitCode

func (x *LogEndInfo) GetExitCode() int32

func (*LogEndInfo) GetLogId

func (x *LogEndInfo) GetLogId() string

func (*LogEndInfo) ProtoMessage

func (*LogEndInfo) ProtoMessage()

func (*LogEndInfo) ProtoReflect

func (x *LogEndInfo) ProtoReflect() protoreflect.Message

func (*LogEndInfo) Reset

func (x *LogEndInfo) Reset()

func (*LogEndInfo) String

func (x *LogEndInfo) String() string

type LogFormat

type LogFormat int32
const (
	LogFormat_LOG_FORMAT_UNKNOWN LogFormat = 0
	LogFormat_LOG_FORMAT_TEXT    LogFormat = 1
	LogFormat_LOG_FORMAT_JSON    LogFormat = 2
	LogFormat_LOG_FORMAT_BSON    LogFormat = 3
)

func (LogFormat) Descriptor

func (LogFormat) Descriptor() protoreflect.EnumDescriptor

func (LogFormat) Enum

func (x LogFormat) Enum() *LogFormat

func (LogFormat) EnumDescriptor deprecated

func (LogFormat) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogFormat.Descriptor instead.

func (LogFormat) Export

func (l LogFormat) Export() model.LogFormat

Export exports LogFormat to the corresponding LogFormat type in the model package.

func (LogFormat) Number

func (x LogFormat) Number() protoreflect.EnumNumber

func (LogFormat) String

func (x LogFormat) String() string

func (LogFormat) Type

type LogInfo

type LogInfo struct {
	Project   string            `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Version   string            `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Variant   string            `protobuf:"bytes,3,opt,name=variant,proto3" json:"variant,omitempty"`
	TaskName  string            `protobuf:"bytes,4,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	TaskId    string            `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Execution int32             `protobuf:"varint,6,opt,name=execution,proto3" json:"execution,omitempty"`
	TestName  string            `protobuf:"bytes,7,opt,name=test_name,json=testName,proto3" json:"test_name,omitempty"`
	Trial     int32             `protobuf:"varint,8,opt,name=trial,proto3" json:"trial,omitempty"`
	ProcName  string            `protobuf:"bytes,9,opt,name=proc_name,json=procName,proto3" json:"proc_name,omitempty"`
	Format    LogFormat         `protobuf:"varint,10,opt,name=format,proto3,enum=cedar.LogFormat" json:"format,omitempty"`
	Tags      []string          `protobuf:"bytes,11,rep,name=tags,proto3" json:"tags,omitempty"`
	Arguments map[string]string `` /* 160-byte string literal not displayed */
	Mainline  bool              `protobuf:"varint,13,opt,name=mainline,proto3" json:"mainline,omitempty"`
	// contains filtered or unexported fields
}

func (*LogInfo) Descriptor deprecated

func (*LogInfo) Descriptor() ([]byte, []int)

Deprecated: Use LogInfo.ProtoReflect.Descriptor instead.

func (*LogInfo) Export

func (l *LogInfo) Export() model.LogInfo

Export exports LogInfo to the corresponding LogInfo type in the model package.

func (*LogInfo) GetArguments

func (x *LogInfo) GetArguments() map[string]string

func (*LogInfo) GetExecution

func (x *LogInfo) GetExecution() int32

func (*LogInfo) GetFormat

func (x *LogInfo) GetFormat() LogFormat

func (*LogInfo) GetMainline

func (x *LogInfo) GetMainline() bool

func (*LogInfo) GetProcName

func (x *LogInfo) GetProcName() string

func (*LogInfo) GetProject

func (x *LogInfo) GetProject() string

func (*LogInfo) GetTags

func (x *LogInfo) GetTags() []string

func (*LogInfo) GetTaskId

func (x *LogInfo) GetTaskId() string

func (*LogInfo) GetTaskName

func (x *LogInfo) GetTaskName() string

func (*LogInfo) GetTestName

func (x *LogInfo) GetTestName() string

func (*LogInfo) GetTrial

func (x *LogInfo) GetTrial() int32

func (*LogInfo) GetVariant

func (x *LogInfo) GetVariant() string

func (*LogInfo) GetVersion

func (x *LogInfo) GetVersion() string

func (*LogInfo) ProtoMessage

func (*LogInfo) ProtoMessage()

func (*LogInfo) ProtoReflect

func (x *LogInfo) ProtoReflect() protoreflect.Message

func (*LogInfo) Reset

func (x *LogInfo) Reset()

func (*LogInfo) String

func (x *LogInfo) String() string

type LogLine

type LogLine struct {
	Priority  int32                  `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Data      []byte                 `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLine) Descriptor deprecated

func (*LogLine) Descriptor() ([]byte, []int)

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) Export

func (l *LogLine) Export() model.LogLine

Export exports LogLine to the corresponding LogLine type in the model package.

func (*LogLine) GetData

func (x *LogLine) GetData() []byte

func (*LogLine) GetPriority

func (x *LogLine) GetPriority() int32

func (*LogLine) GetTimestamp

func (x *LogLine) GetTimestamp() *timestamppb.Timestamp

func (*LogLine) ProtoMessage

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect

func (x *LogLine) ProtoReflect() protoreflect.Message

func (*LogLine) Reset

func (x *LogLine) Reset()

func (*LogLine) String

func (x *LogLine) String() string

type LogLines

type LogLines struct {
	LogId string     `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	Lines []*LogLine `protobuf:"bytes,2,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLines) Descriptor deprecated

func (*LogLines) Descriptor() ([]byte, []int)

Deprecated: Use LogLines.ProtoReflect.Descriptor instead.

func (*LogLines) GetLines

func (x *LogLines) GetLines() []*LogLine

func (*LogLines) GetLogId

func (x *LogLines) GetLogId() string

func (*LogLines) ProtoMessage

func (*LogLines) ProtoMessage()

func (*LogLines) ProtoReflect

func (x *LogLines) ProtoReflect() protoreflect.Message

func (*LogLines) Reset

func (x *LogLines) Reset()

func (*LogLines) String

func (x *LogLines) String() string

type LogStorage

type LogStorage int32
const (
	LogStorage_LOG_STORAGE_S3    LogStorage = 0
	LogStorage_LOG_STORAGE_LOCAL LogStorage = 2
)

func (LogStorage) Descriptor

func (LogStorage) Descriptor() protoreflect.EnumDescriptor

func (LogStorage) Enum

func (x LogStorage) Enum() *LogStorage

func (LogStorage) EnumDescriptor deprecated

func (LogStorage) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStorage.Descriptor instead.

func (LogStorage) Export

func (l LogStorage) Export() model.PailType

Export exports LogStorage to the corresponding PailType in the model package.

func (LogStorage) Number

func (x LogStorage) Number() protoreflect.EnumNumber

func (LogStorage) String

func (x LogStorage) String() string

func (LogStorage) Type

type MetricsCounters

type MetricsCounters struct {
	Ops    int64 `protobuf:"varint,1,opt,name=ops,proto3" json:"ops,omitempty"`
	Size   int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Errors int64 `protobuf:"varint,3,opt,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsCounters) Descriptor deprecated

func (*MetricsCounters) Descriptor() ([]byte, []int)

Deprecated: Use MetricsCounters.ProtoReflect.Descriptor instead.

func (*MetricsCounters) GetErrors

func (x *MetricsCounters) GetErrors() int64

func (*MetricsCounters) GetOps

func (x *MetricsCounters) GetOps() int64

func (*MetricsCounters) GetSize

func (x *MetricsCounters) GetSize() int64

func (*MetricsCounters) ProtoMessage

func (*MetricsCounters) ProtoMessage()

func (*MetricsCounters) ProtoReflect

func (x *MetricsCounters) ProtoReflect() protoreflect.Message

func (*MetricsCounters) Reset

func (x *MetricsCounters) Reset()

func (*MetricsCounters) String

func (x *MetricsCounters) String() string

type MetricsEvent

type MetricsEvent struct {
	Id    string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Event []*MetricsPoint `protobuf:"bytes,3,rep,name=Event,proto3" json:"Event,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsEvent) Descriptor deprecated

func (*MetricsEvent) Descriptor() ([]byte, []int)

Deprecated: Use MetricsEvent.ProtoReflect.Descriptor instead.

func (*MetricsEvent) GetEvent

func (x *MetricsEvent) GetEvent() []*MetricsPoint

func (*MetricsEvent) GetId

func (x *MetricsEvent) GetId() string

func (*MetricsEvent) ProtoMessage

func (*MetricsEvent) ProtoMessage()

func (*MetricsEvent) ProtoReflect

func (x *MetricsEvent) ProtoReflect() protoreflect.Message

func (*MetricsEvent) Reset

func (x *MetricsEvent) Reset()

func (*MetricsEvent) String

func (x *MetricsEvent) String() string

type MetricsGauges

type MetricsGauges struct {
	State   int64 `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	Workers int64 `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	Failed  bool  `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsGauges) Descriptor deprecated

func (*MetricsGauges) Descriptor() ([]byte, []int)

Deprecated: Use MetricsGauges.ProtoReflect.Descriptor instead.

func (*MetricsGauges) GetFailed

func (x *MetricsGauges) GetFailed() bool

func (*MetricsGauges) GetState

func (x *MetricsGauges) GetState() int64

func (*MetricsGauges) GetWorkers

func (x *MetricsGauges) GetWorkers() int64

func (*MetricsGauges) ProtoMessage

func (*MetricsGauges) ProtoMessage()

func (*MetricsGauges) ProtoReflect

func (x *MetricsGauges) ProtoReflect() protoreflect.Message

func (*MetricsGauges) Reset

func (x *MetricsGauges) Reset()

func (*MetricsGauges) String

func (x *MetricsGauges) String() string

type MetricsPoint

type MetricsPoint struct {
	Time     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=Time,proto3" json:"Time,omitempty"`
	Counters *MetricsCounters       `protobuf:"bytes,2,opt,name=counters,proto3" json:"counters,omitempty"`
	Timers   *MetricsTimers         `protobuf:"bytes,3,opt,name=timers,proto3" json:"timers,omitempty"`
	Gauges   *MetricsGauges         `protobuf:"bytes,4,opt,name=gauges,proto3" json:"gauges,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsPoint) Descriptor deprecated

func (*MetricsPoint) Descriptor() ([]byte, []int)

Deprecated: Use MetricsPoint.ProtoReflect.Descriptor instead.

func (*MetricsPoint) Export

func (m *MetricsPoint) Export() *events.Performance

func (*MetricsPoint) GetCounters

func (x *MetricsPoint) GetCounters() *MetricsCounters

func (*MetricsPoint) GetGauges

func (x *MetricsPoint) GetGauges() *MetricsGauges

func (*MetricsPoint) GetTime

func (x *MetricsPoint) GetTime() *timestamppb.Timestamp

func (*MetricsPoint) GetTimers

func (x *MetricsPoint) GetTimers() *MetricsTimers

func (*MetricsPoint) ProtoMessage

func (*MetricsPoint) ProtoMessage()

func (*MetricsPoint) ProtoReflect

func (x *MetricsPoint) ProtoReflect() protoreflect.Message

func (*MetricsPoint) Reset

func (x *MetricsPoint) Reset()

func (*MetricsPoint) String

func (x *MetricsPoint) String() string

type MetricsResponse

type MetricsResponse struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated

func (*MetricsResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetId

func (x *MetricsResponse) GetId() string

func (*MetricsResponse) GetSuccess

func (x *MetricsResponse) GetSuccess() bool

func (*MetricsResponse) ProtoMessage

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect

func (x *MetricsResponse) ProtoReflect() protoreflect.Message

func (*MetricsResponse) Reset

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String

func (x *MetricsResponse) String() string

type MetricsSeriesEnd

type MetricsSeriesEnd struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IsComplete  bool                   `protobuf:"varint,2,opt,name=is_complete,json=isComplete,proto3" json:"is_complete,omitempty"`
	CompletedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsSeriesEnd) Descriptor deprecated

func (*MetricsSeriesEnd) Descriptor() ([]byte, []int)

Deprecated: Use MetricsSeriesEnd.ProtoReflect.Descriptor instead.

func (*MetricsSeriesEnd) GetCompletedAt

func (x *MetricsSeriesEnd) GetCompletedAt() *timestamppb.Timestamp

func (*MetricsSeriesEnd) GetId

func (x *MetricsSeriesEnd) GetId() string

func (*MetricsSeriesEnd) GetIsComplete

func (x *MetricsSeriesEnd) GetIsComplete() bool

func (*MetricsSeriesEnd) ProtoMessage

func (*MetricsSeriesEnd) ProtoMessage()

func (*MetricsSeriesEnd) ProtoReflect

func (x *MetricsSeriesEnd) ProtoReflect() protoreflect.Message

func (*MetricsSeriesEnd) Reset

func (x *MetricsSeriesEnd) Reset()

func (*MetricsSeriesEnd) String

func (x *MetricsSeriesEnd) String() string

type MetricsTimers

type MetricsTimers struct {
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Total    *durationpb.Duration `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsTimers) Descriptor deprecated

func (*MetricsTimers) Descriptor() ([]byte, []int)

Deprecated: Use MetricsTimers.ProtoReflect.Descriptor instead.

func (*MetricsTimers) GetDuration

func (x *MetricsTimers) GetDuration() *durationpb.Duration

func (*MetricsTimers) GetTotal

func (x *MetricsTimers) GetTotal() *durationpb.Duration

func (*MetricsTimers) ProtoMessage

func (*MetricsTimers) ProtoMessage()

func (*MetricsTimers) ProtoReflect

func (x *MetricsTimers) ProtoReflect() protoreflect.Message

func (*MetricsTimers) Reset

func (x *MetricsTimers) Reset()

func (*MetricsTimers) String

func (x *MetricsTimers) String() string

type ResultData

type ResultData struct {
	Id        *ResultID       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Artifacts []*ArtifactInfo `protobuf:"bytes,2,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
	Rollups   []*RollupValue  `protobuf:"bytes,3,rep,name=rollups,proto3" json:"rollups,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultData) Descriptor deprecated

func (*ResultData) Descriptor() ([]byte, []int)

Deprecated: Use ResultData.ProtoReflect.Descriptor instead.

func (*ResultData) Export

func (r *ResultData) Export() *model.PerformanceResult

func (*ResultData) GetArtifacts

func (x *ResultData) GetArtifacts() []*ArtifactInfo

func (*ResultData) GetId

func (x *ResultData) GetId() *ResultID

func (*ResultData) GetRollups

func (x *ResultData) GetRollups() []*RollupValue

func (*ResultData) ProtoMessage

func (*ResultData) ProtoMessage()

func (*ResultData) ProtoReflect

func (x *ResultData) ProtoReflect() protoreflect.Message

func (*ResultData) Reset

func (x *ResultData) Reset()

func (*ResultData) String

func (x *ResultData) String() string

type ResultID

type ResultID struct {
	Project   string                 `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Version   string                 `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Variant   string                 `protobuf:"bytes,3,opt,name=variant,proto3" json:"variant,omitempty"`
	TaskName  string                 `protobuf:"bytes,4,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Execution int32                  `protobuf:"varint,5,opt,name=execution,proto3" json:"execution,omitempty"`
	TaskId    string                 `protobuf:"bytes,6,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TestName  string                 `protobuf:"bytes,7,opt,name=test_name,json=testName,proto3" json:"test_name,omitempty"`
	Parent    string                 `protobuf:"bytes,8,opt,name=parent,proto3" json:"parent,omitempty"`
	Trial     int32                  `protobuf:"varint,9,opt,name=trial,proto3" json:"trial,omitempty"`
	Tags      []string               `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	Arguments map[string]int32       `` /* 161-byte string literal not displayed */
	Mainline  bool                   `protobuf:"varint,12,opt,name=mainline,proto3" json:"mainline,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Order     int32                  `protobuf:"varint,14,opt,name=order,proto3" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultID) Descriptor deprecated

func (*ResultID) Descriptor() ([]byte, []int)

Deprecated: Use ResultID.ProtoReflect.Descriptor instead.

func (*ResultID) Export

func (m *ResultID) Export() model.PerformanceResultInfo

func (*ResultID) GetArguments

func (x *ResultID) GetArguments() map[string]int32

func (*ResultID) GetCreatedAt

func (x *ResultID) GetCreatedAt() *timestamppb.Timestamp

func (*ResultID) GetExecution

func (x *ResultID) GetExecution() int32

func (*ResultID) GetMainline

func (x *ResultID) GetMainline() bool

func (*ResultID) GetOrder

func (x *ResultID) GetOrder() int32

func (*ResultID) GetParent

func (x *ResultID) GetParent() string

func (*ResultID) GetProject

func (x *ResultID) GetProject() string

func (*ResultID) GetTags

func (x *ResultID) GetTags() []string

func (*ResultID) GetTaskId

func (x *ResultID) GetTaskId() string

func (*ResultID) GetTaskName

func (x *ResultID) GetTaskName() string

func (*ResultID) GetTestName

func (x *ResultID) GetTestName() string

func (*ResultID) GetTrial

func (x *ResultID) GetTrial() int32

func (*ResultID) GetVariant

func (x *ResultID) GetVariant() string

func (*ResultID) GetVersion

func (x *ResultID) GetVersion() string

func (*ResultID) ProtoMessage

func (*ResultID) ProtoMessage()

func (*ResultID) ProtoReflect

func (x *ResultID) ProtoReflect() protoreflect.Message

func (*ResultID) Reset

func (x *ResultID) Reset()

func (*ResultID) String

func (x *ResultID) String() string

type RollupData

type RollupData struct {
	Id      string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Rollups []*RollupValue `protobuf:"bytes,2,rep,name=rollups,proto3" json:"rollups,omitempty"`
	// contains filtered or unexported fields
}

func (*RollupData) Descriptor deprecated

func (*RollupData) Descriptor() ([]byte, []int)

Deprecated: Use RollupData.ProtoReflect.Descriptor instead.

func (*RollupData) GetId

func (x *RollupData) GetId() string

func (*RollupData) GetRollups

func (x *RollupData) GetRollups() []*RollupValue

func (*RollupData) ProtoMessage

func (*RollupData) ProtoMessage()

func (*RollupData) ProtoReflect

func (x *RollupData) ProtoReflect() protoreflect.Message

func (*RollupData) Reset

func (x *RollupData) Reset()

func (*RollupData) String

func (x *RollupData) String() string

type RollupType

type RollupType int32
const (
	RollupType_SUM                RollupType = 0
	RollupType_MEAN               RollupType = 1
	RollupType_MEDIAN             RollupType = 2
	RollupType_MAX                RollupType = 3
	RollupType_MIN                RollupType = 4
	RollupType_STANDARD_DEVIATION RollupType = 5
	RollupType_THROUGHPUT         RollupType = 6
	RollupType_LATENCY            RollupType = 7
	RollupType_PERCENTILE_99TH    RollupType = 8
	RollupType_PERCENTILE_95TH    RollupType = 9
	RollupType_PERCENTILE_90TH    RollupType = 10
	RollupType_PERCENTILE_80TH    RollupType = 11
	RollupType_PERCENTILE_50TH    RollupType = 12
)

func (RollupType) Descriptor

func (RollupType) Descriptor() protoreflect.EnumDescriptor

func (RollupType) Enum

func (x RollupType) Enum() *RollupType

func (RollupType) EnumDescriptor deprecated

func (RollupType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RollupType.Descriptor instead.

func (RollupType) Export

func (t RollupType) Export() model.MetricType

func (RollupType) Number

func (x RollupType) Number() protoreflect.EnumNumber

func (RollupType) String

func (x RollupType) String() string

func (RollupType) Type

type RollupValue

type RollupValue struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Value:
	//
	//	*RollupValue_Int
	//	*RollupValue_Fl
	Value         isRollupValue_Value `protobuf_oneof:"value"`
	Type          RollupType          `protobuf:"varint,4,opt,name=type,proto3,enum=cedar.RollupType" json:"type,omitempty"`
	Version       int64               `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	UserSubmitted bool                `protobuf:"varint,6,opt,name=user_submitted,json=userSubmitted,proto3" json:"user_submitted,omitempty"`
	// contains filtered or unexported fields
}

func (*RollupValue) Descriptor deprecated

func (*RollupValue) Descriptor() ([]byte, []int)

Deprecated: Use RollupValue.ProtoReflect.Descriptor instead.

func (*RollupValue) Export

func (r *RollupValue) Export() model.PerfRollupValue

func (*RollupValue) GetFl

func (x *RollupValue) GetFl() float64

func (*RollupValue) GetInt

func (x *RollupValue) GetInt() int64

func (*RollupValue) GetName

func (x *RollupValue) GetName() string

func (*RollupValue) GetType

func (x *RollupValue) GetType() RollupType

func (*RollupValue) GetUserSubmitted

func (x *RollupValue) GetUserSubmitted() bool

func (*RollupValue) GetValue

func (m *RollupValue) GetValue() isRollupValue_Value

func (*RollupValue) GetVersion

func (x *RollupValue) GetVersion() int64

func (*RollupValue) ProtoMessage

func (*RollupValue) ProtoMessage()

func (*RollupValue) ProtoReflect

func (x *RollupValue) ProtoReflect() protoreflect.Message

func (*RollupValue) Reset

func (x *RollupValue) Reset()

func (*RollupValue) String

func (x *RollupValue) String() string

type RollupValue_Fl

type RollupValue_Fl struct {
	Fl float64 `protobuf:"fixed64,3,opt,name=fl,proto3,oneof"`
}

type RollupValue_Int

type RollupValue_Int struct {
	Int int64 `protobuf:"varint,2,opt,name=int,proto3,oneof"`
}

type RollupValues

type RollupValues []*RollupValue

type SchemaType

type SchemaType int32
const (
	SchemaType_RAW_EVENTS             SchemaType = 0
	SchemaType_COLLAPSED_EVENTS       SchemaType = 1
	SchemaType_INTERVAL_SUMMARIZATION SchemaType = 2
	SchemaType_HISTOGRAM              SchemaType = 3
)

func (SchemaType) Descriptor

func (SchemaType) Descriptor() protoreflect.EnumDescriptor

func (SchemaType) Enum

func (x SchemaType) Enum() *SchemaType

func (SchemaType) EnumDescriptor deprecated

func (SchemaType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SchemaType.Descriptor instead.

func (SchemaType) Export

func (s SchemaType) Export() model.FileSchema

func (SchemaType) Number

func (x SchemaType) Number() protoreflect.EnumNumber

func (SchemaType) String

func (x SchemaType) String() string

func (SchemaType) Type

type SendResponse

type SendResponse struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Count   int64  `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*SendResponse) Descriptor deprecated

func (*SendResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendResponse.ProtoReflect.Descriptor instead.

func (*SendResponse) GetCount

func (x *SendResponse) GetCount() int64

func (*SendResponse) GetId

func (x *SendResponse) GetId() string

func (*SendResponse) GetSuccess

func (x *SendResponse) GetSuccess() bool

func (*SendResponse) ProtoMessage

func (*SendResponse) ProtoMessage()

func (*SendResponse) ProtoReflect

func (x *SendResponse) ProtoReflect() protoreflect.Message

func (*SendResponse) Reset

func (x *SendResponse) Reset()

func (*SendResponse) String

func (x *SendResponse) String() string

type StorageLocation

type StorageLocation int32
const (
	StorageLocation_UNKNOWN    StorageLocation = 0
	StorageLocation_CEDAR_S3   StorageLocation = 1
	StorageLocation_PROJECT_S3 StorageLocation = 2
	StorageLocation_EPHEMERAL  StorageLocation = 4
	StorageLocation_LOCAL      StorageLocation = 5
)

func (StorageLocation) Descriptor

func (StorageLocation) Enum

func (x StorageLocation) Enum() *StorageLocation

func (StorageLocation) EnumDescriptor deprecated

func (StorageLocation) EnumDescriptor() ([]byte, []int)

Deprecated: Use StorageLocation.Descriptor instead.

func (StorageLocation) Export

func (l StorageLocation) Export() model.PailType

func (StorageLocation) Number

func (StorageLocation) String

func (x StorageLocation) String() string

func (StorageLocation) Type

type TestLogInfo

type TestLogInfo struct {
	LogName       string   `protobuf:"bytes,1,opt,name=log_name,json=logName,proto3" json:"log_name,omitempty"`
	LogsToMerge   []string `protobuf:"bytes,2,rep,name=logs_to_merge,json=logsToMerge,proto3" json:"logs_to_merge,omitempty"`
	LineNum       int32    `protobuf:"varint,3,opt,name=line_num,json=lineNum,proto3" json:"line_num,omitempty"`
	RenderingType *string  `protobuf:"bytes,4,opt,name=rendering_type,json=renderingType,proto3,oneof" json:"rendering_type,omitempty"`
	Version       int32    `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*TestLogInfo) Descriptor deprecated

func (*TestLogInfo) Descriptor() ([]byte, []int)

Deprecated: Use TestLogInfo.ProtoReflect.Descriptor instead.

func (*TestLogInfo) Export

func (t *TestLogInfo) Export() *model.TestLogInfo

Export exports TestLogInfo to the corresponding TestLogInfo type in the model package.

func (*TestLogInfo) GetLineNum

func (x *TestLogInfo) GetLineNum() int32

func (*TestLogInfo) GetLogName

func (x *TestLogInfo) GetLogName() string

func (*TestLogInfo) GetLogsToMerge

func (x *TestLogInfo) GetLogsToMerge() []string

func (*TestLogInfo) GetRenderingType

func (x *TestLogInfo) GetRenderingType() string

func (*TestLogInfo) GetVersion

func (x *TestLogInfo) GetVersion() int32

func (*TestLogInfo) ProtoMessage

func (*TestLogInfo) ProtoMessage()

func (*TestLogInfo) ProtoReflect

func (x *TestLogInfo) ProtoReflect() protoreflect.Message

func (*TestLogInfo) Reset

func (x *TestLogInfo) Reset()

func (*TestLogInfo) String

func (x *TestLogInfo) String() string

type TestResult

type TestResult struct {
	TestName        string                 `protobuf:"bytes,1,opt,name=test_name,json=testName,proto3" json:"test_name,omitempty"`
	DisplayTestName string                 `protobuf:"bytes,2,opt,name=display_test_name,json=displayTestName,proto3" json:"display_test_name,omitempty"`
	GroupId         string                 `protobuf:"bytes,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Trial           int32                  `protobuf:"varint,4,opt,name=trial,proto3" json:"trial,omitempty"`
	Status          string                 `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	LogTestName     string                 `protobuf:"bytes,6,opt,name=log_test_name,json=logTestName,proto3" json:"log_test_name,omitempty"`
	LineNum         int32                  `protobuf:"varint,7,opt,name=line_num,json=lineNum,proto3" json:"line_num,omitempty"`
	TaskCreateTime  *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=task_create_time,json=taskCreateTime,proto3" json:"task_create_time,omitempty"`
	TestStartTime   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=test_start_time,json=testStartTime,proto3" json:"test_start_time,omitempty"`
	TestEndTime     *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=test_end_time,json=testEndTime,proto3" json:"test_end_time,omitempty"`
	LogUrl          string                 `protobuf:"bytes,11,opt,name=log_url,json=logUrl,proto3" json:"log_url,omitempty"`
	RawLogUrl       string                 `protobuf:"bytes,12,opt,name=raw_log_url,json=rawLogUrl,proto3" json:"raw_log_url,omitempty"`
	LogInfo         *TestLogInfo           `protobuf:"bytes,13,opt,name=log_info,json=logInfo,proto3" json:"log_info,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResult) Descriptor deprecated

func (*TestResult) Descriptor() ([]byte, []int)

Deprecated: Use TestResult.ProtoReflect.Descriptor instead.

func (*TestResult) Export

func (t *TestResult) Export() model.TestResult

Export exports TestResult to the corresponding TestResult type in the model package.

func (*TestResult) GetDisplayTestName

func (x *TestResult) GetDisplayTestName() string

func (*TestResult) GetGroupId

func (x *TestResult) GetGroupId() string

func (*TestResult) GetLineNum

func (x *TestResult) GetLineNum() int32

func (*TestResult) GetLogInfo

func (x *TestResult) GetLogInfo() *TestLogInfo

func (*TestResult) GetLogTestName

func (x *TestResult) GetLogTestName() string

func (*TestResult) GetLogUrl

func (x *TestResult) GetLogUrl() string

func (*TestResult) GetRawLogUrl

func (x *TestResult) GetRawLogUrl() string

func (*TestResult) GetStatus

func (x *TestResult) GetStatus() string

func (*TestResult) GetTaskCreateTime

func (x *TestResult) GetTaskCreateTime() *timestamppb.Timestamp

func (*TestResult) GetTestEndTime

func (x *TestResult) GetTestEndTime() *timestamppb.Timestamp

func (*TestResult) GetTestName

func (x *TestResult) GetTestName() string

func (*TestResult) GetTestStartTime

func (x *TestResult) GetTestStartTime() *timestamppb.Timestamp

func (*TestResult) GetTrial

func (x *TestResult) GetTrial() int32

func (*TestResult) ProtoMessage

func (*TestResult) ProtoMessage()

func (*TestResult) ProtoReflect

func (x *TestResult) ProtoReflect() protoreflect.Message

func (*TestResult) Reset

func (x *TestResult) Reset()

func (*TestResult) String

func (x *TestResult) String() string

type TestResults

type TestResults struct {
	TestResultsRecordId string        `protobuf:"bytes,1,opt,name=test_results_record_id,json=testResultsRecordId,proto3" json:"test_results_record_id,omitempty"`
	Results             []*TestResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResults) Descriptor deprecated

func (*TestResults) Descriptor() ([]byte, []int)

Deprecated: Use TestResults.ProtoReflect.Descriptor instead.

func (*TestResults) GetResults

func (x *TestResults) GetResults() []*TestResult

func (*TestResults) GetTestResultsRecordId

func (x *TestResults) GetTestResultsRecordId() string

func (*TestResults) ProtoMessage

func (*TestResults) ProtoMessage()

func (*TestResults) ProtoReflect

func (x *TestResults) ProtoReflect() protoreflect.Message

func (*TestResults) Reset

func (x *TestResults) Reset()

func (*TestResults) String

func (x *TestResults) String() string

type TestResultsEndInfo

type TestResultsEndInfo struct {
	TestResultsRecordId string `protobuf:"bytes,1,opt,name=test_results_record_id,json=testResultsRecordId,proto3" json:"test_results_record_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResultsEndInfo) Descriptor deprecated

func (*TestResultsEndInfo) Descriptor() ([]byte, []int)

Deprecated: Use TestResultsEndInfo.ProtoReflect.Descriptor instead.

func (*TestResultsEndInfo) GetTestResultsRecordId

func (x *TestResultsEndInfo) GetTestResultsRecordId() string

func (*TestResultsEndInfo) ProtoMessage

func (*TestResultsEndInfo) ProtoMessage()

func (*TestResultsEndInfo) ProtoReflect

func (x *TestResultsEndInfo) ProtoReflect() protoreflect.Message

func (*TestResultsEndInfo) Reset

func (x *TestResultsEndInfo) Reset()

func (*TestResultsEndInfo) String

func (x *TestResultsEndInfo) String() string

type TestResultsInfo

type TestResultsInfo struct {
	Project         string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Version         string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Variant         string `protobuf:"bytes,3,opt,name=variant,proto3" json:"variant,omitempty"`
	TaskName        string `protobuf:"bytes,4,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	DisplayTaskName string `protobuf:"bytes,5,opt,name=display_task_name,json=displayTaskName,proto3" json:"display_task_name,omitempty"`
	TaskId          string `protobuf:"bytes,6,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	DisplayTaskId   string `protobuf:"bytes,7,opt,name=display_task_id,json=displayTaskId,proto3" json:"display_task_id,omitempty"`
	Execution       int32  `protobuf:"varint,8,opt,name=execution,proto3" json:"execution,omitempty"`
	RequestType     string `protobuf:"bytes,9,opt,name=request_type,json=requestType,proto3" json:"request_type,omitempty"`
	Mainline        bool   `protobuf:"varint,10,opt,name=mainline,proto3" json:"mainline,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResultsInfo) Descriptor deprecated

func (*TestResultsInfo) Descriptor() ([]byte, []int)

Deprecated: Use TestResultsInfo.ProtoReflect.Descriptor instead.

func (*TestResultsInfo) Export

func (t *TestResultsInfo) Export() (model.TestResultsInfo, error)

Export exports TestResultsInfo to the corresponding TestResultsInfo type in the model package.

func (*TestResultsInfo) GetDisplayTaskId

func (x *TestResultsInfo) GetDisplayTaskId() string

func (*TestResultsInfo) GetDisplayTaskName

func (x *TestResultsInfo) GetDisplayTaskName() string

func (*TestResultsInfo) GetExecution

func (x *TestResultsInfo) GetExecution() int32

func (*TestResultsInfo) GetMainline

func (x *TestResultsInfo) GetMainline() bool

func (*TestResultsInfo) GetProject

func (x *TestResultsInfo) GetProject() string

func (*TestResultsInfo) GetRequestType

func (x *TestResultsInfo) GetRequestType() string

func (*TestResultsInfo) GetTaskId

func (x *TestResultsInfo) GetTaskId() string

func (*TestResultsInfo) GetTaskName

func (x *TestResultsInfo) GetTaskName() string

func (*TestResultsInfo) GetVariant

func (x *TestResultsInfo) GetVariant() string

func (*TestResultsInfo) GetVersion

func (x *TestResultsInfo) GetVersion() string

func (*TestResultsInfo) ProtoMessage

func (*TestResultsInfo) ProtoMessage()

func (*TestResultsInfo) ProtoReflect

func (x *TestResultsInfo) ProtoReflect() protoreflect.Message

func (*TestResultsInfo) Reset

func (x *TestResultsInfo) Reset()

func (*TestResultsInfo) String

func (x *TestResultsInfo) String() string

type TestResultsResponse

type TestResultsResponse struct {
	TestResultsRecordId string `protobuf:"bytes,1,opt,name=test_results_record_id,json=testResultsRecordId,proto3" json:"test_results_record_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TestResultsResponse) Descriptor deprecated

func (*TestResultsResponse) Descriptor() ([]byte, []int)

Deprecated: Use TestResultsResponse.ProtoReflect.Descriptor instead.

func (*TestResultsResponse) GetTestResultsRecordId

func (x *TestResultsResponse) GetTestResultsRecordId() string

func (*TestResultsResponse) ProtoMessage

func (*TestResultsResponse) ProtoMessage()

func (*TestResultsResponse) ProtoReflect

func (x *TestResultsResponse) ProtoReflect() protoreflect.Message

func (*TestResultsResponse) Reset

func (x *TestResultsResponse) Reset()

func (*TestResultsResponse) String

func (x *TestResultsResponse) String() string

type UnimplementedBuildloggerServer

type UnimplementedBuildloggerServer struct {
}

UnimplementedBuildloggerServer must be embedded to have forward compatible implementations.

func (UnimplementedBuildloggerServer) AppendLogLines

func (UnimplementedBuildloggerServer) CloseLog

func (UnimplementedBuildloggerServer) CreateLog

func (UnimplementedBuildloggerServer) StreamLogLines

type UnimplementedCedarPerformanceMetricsServer

type UnimplementedCedarPerformanceMetricsServer struct {
}

UnimplementedCedarPerformanceMetricsServer must be embedded to have forward compatible implementations.

func (UnimplementedCedarPerformanceMetricsServer) AttachArtifacts

func (UnimplementedCedarPerformanceMetricsServer) AttachRollups

func (UnimplementedCedarPerformanceMetricsServer) CloseMetrics

func (UnimplementedCedarPerformanceMetricsServer) CreateMetricSeries

func (UnimplementedCedarPerformanceMetricsServer) SendMetrics

type UnimplementedCedarTestResultsServer

type UnimplementedCedarTestResultsServer struct {
}

UnimplementedCedarTestResultsServer must be embedded to have forward compatible implementations.

func (UnimplementedCedarTestResultsServer) AddTestResults

func (UnimplementedCedarTestResultsServer) CloseTestResultsRecord

func (UnimplementedCedarTestResultsServer) CreateTestResultsRecord

func (UnimplementedCedarTestResultsServer) StreamTestResults

type UnimplementedHealthServer

type UnimplementedHealthServer struct {
}

UnimplementedHealthServer must be embedded to have forward compatible implementations.

func (UnimplementedHealthServer) Check

type UnsafeBuildloggerServer

type UnsafeBuildloggerServer interface {
	// contains filtered or unexported methods
}

UnsafeBuildloggerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BuildloggerServer will result in compilation errors.

type UnsafeCedarPerformanceMetricsServer

type UnsafeCedarPerformanceMetricsServer interface {
	// contains filtered or unexported methods
}

UnsafeCedarPerformanceMetricsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CedarPerformanceMetricsServer will result in compilation errors.

type UnsafeCedarTestResultsServer

type UnsafeCedarTestResultsServer interface {
	// contains filtered or unexported methods
}

UnsafeCedarTestResultsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CedarTestResultsServer will result in compilation errors.

type UnsafeHealthServer

type UnsafeHealthServer interface {
	// contains filtered or unexported methods
}

UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.

Jump to

Keyboard shortcuts

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