Documentation ¶
Index ¶
- Constants
- Variables
- func AttachBuildloggerService(env cedar.Environment, s *grpc.Server)
- func AttachHealthService(services map[string]HealthCheckResponse_ServingStatus, s *grpc.Server)
- func AttachPerfService(env cedar.Environment, s *grpc.Server)
- func AttachTestResultsService(env cedar.Environment, s *grpc.Server)
- func BuildloggerServiceName() string
- func ExportRollupValues(r []*RollupValue) []model.PerfRollupValue
- func HealthServiceName() string
- func PerfServiceName() string
- func RegisterBuildloggerServer(s grpc.ServiceRegistrar, srv BuildloggerServer)
- func RegisterCedarPerformanceMetricsServer(s grpc.ServiceRegistrar, srv CedarPerformanceMetricsServer)
- func RegisterCedarTestResultsServer(s grpc.ServiceRegistrar, srv CedarTestResultsServer)
- func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)
- func TestResultsServiceName() string
- type ArtifactData
- func (*ArtifactData) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactData) GetArtifacts() []*ArtifactInfo
- func (x *ArtifactData) GetId() string
- func (*ArtifactData) ProtoMessage()
- func (x *ArtifactData) ProtoReflect() protoreflect.Message
- func (x *ArtifactData) Reset()
- func (x *ArtifactData) String() string
- type ArtifactInfo
- func (*ArtifactInfo) Descriptor() ([]byte, []int)deprecated
- func (a *ArtifactInfo) Export() *model.ArtifactInfo
- func (x *ArtifactInfo) GetBucket() string
- func (x *ArtifactInfo) GetCompression() CompressionType
- func (x *ArtifactInfo) GetCreatedAt() *timestamppb.Timestamp
- func (x *ArtifactInfo) GetFormat() DataFormat
- func (x *ArtifactInfo) GetLocation() StorageLocation
- func (x *ArtifactInfo) GetPath() string
- func (x *ArtifactInfo) GetPrefix() string
- func (x *ArtifactInfo) GetSchema() SchemaType
- func (x *ArtifactInfo) GetTags() []string
- func (*ArtifactInfo) ProtoMessage()
- func (x *ArtifactInfo) ProtoReflect() protoreflect.Message
- func (x *ArtifactInfo) Reset()
- func (x *ArtifactInfo) String() string
- type BuildloggerClient
- type BuildloggerResponse
- func (*BuildloggerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BuildloggerResponse) GetLogId() string
- func (*BuildloggerResponse) ProtoMessage()
- func (x *BuildloggerResponse) ProtoReflect() protoreflect.Message
- func (x *BuildloggerResponse) Reset()
- func (x *BuildloggerResponse) String() string
- type BuildloggerServer
- type Buildlogger_StreamLogLinesClient
- type Buildlogger_StreamLogLinesServer
- type CedarPerformanceMetricsClient
- type CedarPerformanceMetricsServer
- type CedarPerformanceMetrics_SendMetricsClient
- type CedarPerformanceMetrics_SendMetricsServer
- type CedarTestResultsClient
- type CedarTestResultsServer
- type CedarTestResults_StreamTestResultsClient
- type CedarTestResults_StreamTestResultsServer
- type CompressionType
- func (CompressionType) Descriptor() protoreflect.EnumDescriptor
- func (x CompressionType) Enum() *CompressionType
- func (CompressionType) EnumDescriptor() ([]byte, []int)deprecated
- func (c CompressionType) Export() model.FileCompression
- func (x CompressionType) Number() protoreflect.EnumNumber
- func (x CompressionType) String() string
- func (CompressionType) Type() protoreflect.EnumType
- type DataFormat
- func (DataFormat) Descriptor() protoreflect.EnumDescriptor
- func (x DataFormat) Enum() *DataFormat
- func (DataFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (f DataFormat) Export() model.FileDataFormat
- func (x DataFormat) Number() protoreflect.EnumNumber
- func (x DataFormat) String() string
- func (DataFormat) Type() protoreflect.EnumType
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequest) GetService() string
- func (*HealthCheckRequest) ProtoMessage()
- func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest) Reset()
- func (x *HealthCheckRequest) String() string
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
- func (*HealthCheckResponse) ProtoMessage()
- func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse) Reset()
- func (x *HealthCheckResponse) String() string
- type HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
- func (x HealthCheckResponse_ServingStatus) String() string
- func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
- type HealthClient
- type HealthServer
- type LogData
- type LogEndInfo
- type LogFormat
- func (LogFormat) Descriptor() protoreflect.EnumDescriptor
- func (x LogFormat) Enum() *LogFormat
- func (LogFormat) EnumDescriptor() ([]byte, []int)deprecated
- func (l LogFormat) Export() model.LogFormat
- func (x LogFormat) Number() protoreflect.EnumNumber
- func (x LogFormat) String() string
- func (LogFormat) Type() protoreflect.EnumType
- type LogInfo
- func (*LogInfo) Descriptor() ([]byte, []int)deprecated
- func (l *LogInfo) Export() model.LogInfo
- func (x *LogInfo) GetArguments() map[string]string
- func (x *LogInfo) GetExecution() int32
- func (x *LogInfo) GetFormat() LogFormat
- func (x *LogInfo) GetMainline() bool
- func (x *LogInfo) GetProcName() string
- func (x *LogInfo) GetProject() string
- func (x *LogInfo) GetTags() []string
- func (x *LogInfo) GetTaskId() string
- func (x *LogInfo) GetTaskName() string
- func (x *LogInfo) GetTestName() string
- func (x *LogInfo) GetTrial() int32
- func (x *LogInfo) GetVariant() string
- func (x *LogInfo) GetVersion() string
- func (*LogInfo) ProtoMessage()
- func (x *LogInfo) ProtoReflect() protoreflect.Message
- func (x *LogInfo) Reset()
- func (x *LogInfo) String() string
- type LogLine
- func (*LogLine) Descriptor() ([]byte, []int)deprecated
- func (l *LogLine) Export() model.LogLine
- func (x *LogLine) GetData() []byte
- func (x *LogLine) GetPriority() int32
- func (x *LogLine) GetTimestamp() *timestamppb.Timestamp
- func (*LogLine) ProtoMessage()
- func (x *LogLine) ProtoReflect() protoreflect.Message
- func (x *LogLine) Reset()
- func (x *LogLine) String() string
- type LogLines
- type LogStorage
- func (LogStorage) Descriptor() protoreflect.EnumDescriptor
- func (x LogStorage) Enum() *LogStorage
- func (LogStorage) EnumDescriptor() ([]byte, []int)deprecated
- func (l LogStorage) Export() model.PailType
- func (x LogStorage) Number() protoreflect.EnumNumber
- func (x LogStorage) String() string
- func (LogStorage) Type() protoreflect.EnumType
- type MetricsCounters
- func (*MetricsCounters) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsCounters) GetErrors() int64
- func (x *MetricsCounters) GetOps() int64
- func (x *MetricsCounters) GetSize() int64
- func (*MetricsCounters) ProtoMessage()
- func (x *MetricsCounters) ProtoReflect() protoreflect.Message
- func (x *MetricsCounters) Reset()
- func (x *MetricsCounters) String() string
- type MetricsEvent
- func (*MetricsEvent) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsEvent) GetEvent() []*MetricsPoint
- func (x *MetricsEvent) GetId() string
- func (*MetricsEvent) ProtoMessage()
- func (x *MetricsEvent) ProtoReflect() protoreflect.Message
- func (x *MetricsEvent) Reset()
- func (x *MetricsEvent) String() string
- type MetricsGauges
- func (*MetricsGauges) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsGauges) GetFailed() bool
- func (x *MetricsGauges) GetState() int64
- func (x *MetricsGauges) GetWorkers() int64
- func (*MetricsGauges) ProtoMessage()
- func (x *MetricsGauges) ProtoReflect() protoreflect.Message
- func (x *MetricsGauges) Reset()
- func (x *MetricsGauges) String() string
- type MetricsPoint
- func (*MetricsPoint) Descriptor() ([]byte, []int)deprecated
- func (m *MetricsPoint) Export() *events.Performance
- func (x *MetricsPoint) GetCounters() *MetricsCounters
- func (x *MetricsPoint) GetGauges() *MetricsGauges
- func (x *MetricsPoint) GetTime() *timestamppb.Timestamp
- func (x *MetricsPoint) GetTimers() *MetricsTimers
- func (*MetricsPoint) ProtoMessage()
- func (x *MetricsPoint) ProtoReflect() protoreflect.Message
- func (x *MetricsPoint) Reset()
- func (x *MetricsPoint) String() string
- type MetricsResponse
- func (*MetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsResponse) GetId() string
- func (x *MetricsResponse) GetSuccess() bool
- func (*MetricsResponse) ProtoMessage()
- func (x *MetricsResponse) ProtoReflect() protoreflect.Message
- func (x *MetricsResponse) Reset()
- func (x *MetricsResponse) String() string
- type MetricsSeriesEnd
- func (*MetricsSeriesEnd) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsSeriesEnd) GetCompletedAt() *timestamppb.Timestamp
- func (x *MetricsSeriesEnd) GetId() string
- func (x *MetricsSeriesEnd) GetIsComplete() bool
- func (*MetricsSeriesEnd) ProtoMessage()
- func (x *MetricsSeriesEnd) ProtoReflect() protoreflect.Message
- func (x *MetricsSeriesEnd) Reset()
- func (x *MetricsSeriesEnd) String() string
- type MetricsTimers
- func (*MetricsTimers) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsTimers) GetDuration() *durationpb.Duration
- func (x *MetricsTimers) GetTotal() *durationpb.Duration
- func (*MetricsTimers) ProtoMessage()
- func (x *MetricsTimers) ProtoReflect() protoreflect.Message
- func (x *MetricsTimers) Reset()
- func (x *MetricsTimers) String() string
- type ResultData
- func (*ResultData) Descriptor() ([]byte, []int)deprecated
- func (r *ResultData) Export() *model.PerformanceResult
- func (x *ResultData) GetArtifacts() []*ArtifactInfo
- func (x *ResultData) GetId() *ResultID
- func (x *ResultData) GetRollups() []*RollupValue
- func (*ResultData) ProtoMessage()
- func (x *ResultData) ProtoReflect() protoreflect.Message
- func (x *ResultData) Reset()
- func (x *ResultData) String() string
- type ResultID
- func (*ResultID) Descriptor() ([]byte, []int)deprecated
- func (m *ResultID) Export() model.PerformanceResultInfo
- func (x *ResultID) GetArguments() map[string]int32
- func (x *ResultID) GetCreatedAt() *timestamppb.Timestamp
- func (x *ResultID) GetExecution() int32
- func (x *ResultID) GetMainline() bool
- func (x *ResultID) GetOrder() int32
- func (x *ResultID) GetParent() string
- func (x *ResultID) GetProject() string
- func (x *ResultID) GetTags() []string
- func (x *ResultID) GetTaskId() string
- func (x *ResultID) GetTaskName() string
- func (x *ResultID) GetTestName() string
- func (x *ResultID) GetTrial() int32
- func (x *ResultID) GetVariant() string
- func (x *ResultID) GetVersion() string
- func (*ResultID) ProtoMessage()
- func (x *ResultID) ProtoReflect() protoreflect.Message
- func (x *ResultID) Reset()
- func (x *ResultID) String() string
- type RollupData
- type RollupType
- func (RollupType) Descriptor() protoreflect.EnumDescriptor
- func (x RollupType) Enum() *RollupType
- func (RollupType) EnumDescriptor() ([]byte, []int)deprecated
- func (t RollupType) Export() model.MetricType
- func (x RollupType) Number() protoreflect.EnumNumber
- func (x RollupType) String() string
- func (RollupType) Type() protoreflect.EnumType
- type RollupValue
- func (*RollupValue) Descriptor() ([]byte, []int)deprecated
- func (r *RollupValue) Export() model.PerfRollupValue
- func (x *RollupValue) GetFl() float64
- func (x *RollupValue) GetInt() int64
- func (x *RollupValue) GetName() string
- func (x *RollupValue) GetType() RollupType
- func (x *RollupValue) GetUserSubmitted() bool
- func (m *RollupValue) GetValue() isRollupValue_Value
- func (x *RollupValue) GetVersion() int64
- func (*RollupValue) ProtoMessage()
- func (x *RollupValue) ProtoReflect() protoreflect.Message
- func (x *RollupValue) Reset()
- func (x *RollupValue) String() string
- type RollupValue_Fl
- type RollupValue_Int
- type RollupValues
- type SchemaType
- func (SchemaType) Descriptor() protoreflect.EnumDescriptor
- func (x SchemaType) Enum() *SchemaType
- func (SchemaType) EnumDescriptor() ([]byte, []int)deprecated
- func (s SchemaType) Export() model.FileSchema
- func (x SchemaType) Number() protoreflect.EnumNumber
- func (x SchemaType) String() string
- func (SchemaType) Type() protoreflect.EnumType
- type SendResponse
- func (*SendResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SendResponse) GetCount() int64
- func (x *SendResponse) GetId() string
- func (x *SendResponse) GetSuccess() bool
- func (*SendResponse) ProtoMessage()
- func (x *SendResponse) ProtoReflect() protoreflect.Message
- func (x *SendResponse) Reset()
- func (x *SendResponse) String() string
- type StorageLocation
- func (StorageLocation) Descriptor() protoreflect.EnumDescriptor
- func (x StorageLocation) Enum() *StorageLocation
- func (StorageLocation) EnumDescriptor() ([]byte, []int)deprecated
- func (l StorageLocation) Export() model.PailType
- func (x StorageLocation) Number() protoreflect.EnumNumber
- func (x StorageLocation) String() string
- func (StorageLocation) Type() protoreflect.EnumType
- type TestLogInfo
- func (*TestLogInfo) Descriptor() ([]byte, []int)deprecated
- func (t *TestLogInfo) Export() *model.TestLogInfo
- func (x *TestLogInfo) GetLineNum() int32
- func (x *TestLogInfo) GetLogName() string
- func (x *TestLogInfo) GetLogsToMerge() []string
- func (x *TestLogInfo) GetRenderingType() string
- func (x *TestLogInfo) GetVersion() int32
- func (*TestLogInfo) ProtoMessage()
- func (x *TestLogInfo) ProtoReflect() protoreflect.Message
- func (x *TestLogInfo) Reset()
- func (x *TestLogInfo) String() string
- type TestResult
- func (*TestResult) Descriptor() ([]byte, []int)deprecated
- func (t *TestResult) Export() model.TestResult
- func (x *TestResult) GetDisplayTestName() string
- func (x *TestResult) GetGroupId() string
- func (x *TestResult) GetLineNum() int32
- func (x *TestResult) GetLogInfo() *TestLogInfo
- func (x *TestResult) GetLogTestName() string
- func (x *TestResult) GetLogUrl() string
- func (x *TestResult) GetRawLogUrl() string
- func (x *TestResult) GetStatus() string
- func (x *TestResult) GetTaskCreateTime() *timestamppb.Timestamp
- func (x *TestResult) GetTestEndTime() *timestamppb.Timestamp
- func (x *TestResult) GetTestName() string
- func (x *TestResult) GetTestStartTime() *timestamppb.Timestamp
- func (x *TestResult) GetTrial() int32
- func (*TestResult) ProtoMessage()
- func (x *TestResult) ProtoReflect() protoreflect.Message
- func (x *TestResult) Reset()
- func (x *TestResult) String() string
- type TestResults
- func (*TestResults) Descriptor() ([]byte, []int)deprecated
- func (x *TestResults) GetResults() []*TestResult
- func (x *TestResults) GetTestResultsRecordId() string
- func (*TestResults) ProtoMessage()
- func (x *TestResults) ProtoReflect() protoreflect.Message
- func (x *TestResults) Reset()
- func (x *TestResults) String() string
- type TestResultsEndInfo
- func (*TestResultsEndInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TestResultsEndInfo) GetTestResultsRecordId() string
- func (*TestResultsEndInfo) ProtoMessage()
- func (x *TestResultsEndInfo) ProtoReflect() protoreflect.Message
- func (x *TestResultsEndInfo) Reset()
- func (x *TestResultsEndInfo) String() string
- type TestResultsInfo
- func (*TestResultsInfo) Descriptor() ([]byte, []int)deprecated
- func (t *TestResultsInfo) Export() (model.TestResultsInfo, error)
- func (x *TestResultsInfo) GetDisplayTaskId() string
- func (x *TestResultsInfo) GetDisplayTaskName() string
- func (x *TestResultsInfo) GetExecution() int32
- func (x *TestResultsInfo) GetMainline() bool
- func (x *TestResultsInfo) GetProject() string
- func (x *TestResultsInfo) GetRequestType() string
- func (x *TestResultsInfo) GetTaskId() string
- func (x *TestResultsInfo) GetTaskName() string
- func (x *TestResultsInfo) GetVariant() string
- func (x *TestResultsInfo) GetVersion() string
- func (*TestResultsInfo) ProtoMessage()
- func (x *TestResultsInfo) ProtoReflect() protoreflect.Message
- func (x *TestResultsInfo) Reset()
- func (x *TestResultsInfo) String() string
- type TestResultsResponse
- func (*TestResultsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TestResultsResponse) GetTestResultsRecordId() string
- func (*TestResultsResponse) ProtoMessage()
- func (x *TestResultsResponse) ProtoReflect() protoreflect.Message
- func (x *TestResultsResponse) Reset()
- func (x *TestResultsResponse) String() string
- type UnimplementedBuildloggerServer
- func (UnimplementedBuildloggerServer) AppendLogLines(context.Context, *LogLines) (*BuildloggerResponse, error)
- func (UnimplementedBuildloggerServer) CloseLog(context.Context, *LogEndInfo) (*BuildloggerResponse, error)
- func (UnimplementedBuildloggerServer) CreateLog(context.Context, *LogData) (*BuildloggerResponse, error)
- func (UnimplementedBuildloggerServer) StreamLogLines(Buildlogger_StreamLogLinesServer) error
- type UnimplementedCedarPerformanceMetricsServer
- func (UnimplementedCedarPerformanceMetricsServer) AttachArtifacts(context.Context, *ArtifactData) (*MetricsResponse, error)
- func (UnimplementedCedarPerformanceMetricsServer) AttachRollups(context.Context, *RollupData) (*MetricsResponse, error)
- func (UnimplementedCedarPerformanceMetricsServer) CloseMetrics(context.Context, *MetricsSeriesEnd) (*MetricsResponse, error)
- func (UnimplementedCedarPerformanceMetricsServer) CreateMetricSeries(context.Context, *ResultData) (*MetricsResponse, error)
- func (UnimplementedCedarPerformanceMetricsServer) SendMetrics(CedarPerformanceMetrics_SendMetricsServer) error
- type UnimplementedCedarTestResultsServer
- func (UnimplementedCedarTestResultsServer) AddTestResults(context.Context, *TestResults) (*TestResultsResponse, error)
- func (UnimplementedCedarTestResultsServer) CloseTestResultsRecord(context.Context, *TestResultsEndInfo) (*TestResultsResponse, error)
- func (UnimplementedCedarTestResultsServer) CreateTestResultsRecord(context.Context, *TestResultsInfo) (*TestResultsResponse, error)
- func (UnimplementedCedarTestResultsServer) StreamTestResults(CedarTestResults_StreamTestResultsServer) error
- type UnimplementedHealthServer
- type UnsafeBuildloggerServer
- type UnsafeCedarPerformanceMetricsServer
- type UnsafeCedarTestResultsServer
- type UnsafeHealthServer
Constants ¶
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" )
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" )
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" )
const (
Health_Check_FullMethodName = "/cedar.Health/Check"
)
Variables ¶
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.
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.
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.
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.
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.
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.
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.
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.
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)
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)
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)
var File_buildlogger_proto protoreflect.FileDescriptor
var File_formats_proto protoreflect.FileDescriptor
var File_health_proto protoreflect.FileDescriptor
var File_perf_proto protoreflect.FileDescriptor
var File_test_results_proto protoreflect.FileDescriptor
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.
func NewBuildloggerClient ¶
func NewBuildloggerClient(cc grpc.ClientConnInterface) BuildloggerClient
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.
func NewCedarPerformanceMetricsClient ¶
func NewCedarPerformanceMetricsClient(cc grpc.ClientConnInterface) CedarPerformanceMetricsClient
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.
func NewCedarTestResultsClient ¶
func NewCedarTestResultsClient(cc grpc.ClientConnInterface) CedarTestResultsClient
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) Descriptor() protoreflect.EnumDescriptor
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 (c CompressionType) Export() model.FileCompression
func (CompressionType) Number ¶
func (x CompressionType) Number() protoreflect.EnumNumber
func (CompressionType) String ¶
func (x CompressionType) String() string
func (CompressionType) Type ¶
func (CompressionType) Type() protoreflect.EnumType
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 ¶
func (DataFormat) Type() protoreflect.EnumType
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 (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
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) Descriptor() protoreflect.EnumDescriptor
func (HealthCheckResponse_ServingStatus) Enum ¶
func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
func (HealthCheckResponse_ServingStatus) EnumDescriptor
deprecated
func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.
func (HealthCheckResponse_ServingStatus) Number ¶
func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
func (HealthCheckResponse_ServingStatus) String ¶
func (x HealthCheckResponse_ServingStatus) String() string
func (HealthCheckResponse_ServingStatus) Type ¶
func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
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) GetStorage ¶
func (x *LogData) GetStorage() LogStorage
func (*LogData) ProtoMessage ¶
func (*LogData) ProtoMessage()
func (*LogData) ProtoReflect ¶
func (x *LogData) ProtoReflect() protoreflect.Message
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
func (LogFormat) Descriptor ¶
func (LogFormat) Descriptor() protoreflect.EnumDescriptor
func (LogFormat) EnumDescriptor
deprecated
func (LogFormat) Export ¶
Export exports LogFormat to the corresponding LogFormat type in the model package.
func (LogFormat) Number ¶
func (x LogFormat) Number() protoreflect.EnumNumber
func (LogFormat) Type ¶
func (LogFormat) Type() protoreflect.EnumType
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) Export ¶
Export exports LogInfo to the corresponding LogInfo type in the model package.
func (*LogInfo) GetArguments ¶
func (*LogInfo) GetExecution ¶
func (*LogInfo) GetMainline ¶
func (*LogInfo) GetProcName ¶
func (*LogInfo) GetProject ¶
func (*LogInfo) GetTaskName ¶
func (*LogInfo) GetTestName ¶
func (*LogInfo) GetVariant ¶
func (*LogInfo) GetVersion ¶
func (*LogInfo) ProtoMessage ¶
func (*LogInfo) ProtoMessage()
func (*LogInfo) ProtoReflect ¶
func (x *LogInfo) ProtoReflect() protoreflect.Message
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) Export ¶
Export exports LogLine to the corresponding LogLine type in the model package.
func (*LogLine) GetPriority ¶
func (*LogLine) GetTimestamp ¶
func (x *LogLine) GetTimestamp() *timestamppb.Timestamp
func (*LogLine) ProtoMessage ¶
func (*LogLine) ProtoMessage()
func (*LogLine) ProtoReflect ¶
func (x *LogLine) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*LogLines) ProtoMessage()
func (*LogLines) ProtoReflect ¶
func (x *LogLines) ProtoReflect() protoreflect.Message
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 ¶
func (LogStorage) Type() protoreflect.EnumType
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) Export ¶
func (m *ResultID) Export() model.PerformanceResultInfo
func (*ResultID) GetArguments ¶
func (*ResultID) GetCreatedAt ¶
func (x *ResultID) GetCreatedAt() *timestamppb.Timestamp
func (*ResultID) GetExecution ¶
func (*ResultID) GetMainline ¶
func (*ResultID) GetProject ¶
func (*ResultID) GetTaskName ¶
func (*ResultID) GetTestName ¶
func (*ResultID) GetVariant ¶
func (*ResultID) GetVersion ¶
func (*ResultID) ProtoMessage ¶
func (*ResultID) ProtoMessage()
func (*ResultID) ProtoReflect ¶
func (x *ResultID) ProtoReflect() protoreflect.Message
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 ¶
func (RollupType) Type() protoreflect.EnumType
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 ¶
func (SchemaType) Type() protoreflect.EnumType
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) Descriptor() protoreflect.EnumDescriptor
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 (x StorageLocation) Number() protoreflect.EnumNumber
func (StorageLocation) String ¶
func (x StorageLocation) String() string
func (StorageLocation) Type ¶
func (StorageLocation) Type() protoreflect.EnumType
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) AppendLogLines(context.Context, *LogLines) (*BuildloggerResponse, error)
func (UnimplementedBuildloggerServer) CloseLog ¶
func (UnimplementedBuildloggerServer) CloseLog(context.Context, *LogEndInfo) (*BuildloggerResponse, error)
func (UnimplementedBuildloggerServer) CreateLog ¶
func (UnimplementedBuildloggerServer) CreateLog(context.Context, *LogData) (*BuildloggerResponse, error)
func (UnimplementedBuildloggerServer) StreamLogLines ¶
func (UnimplementedBuildloggerServer) StreamLogLines(Buildlogger_StreamLogLinesServer) error
type UnimplementedCedarPerformanceMetricsServer ¶
type UnimplementedCedarPerformanceMetricsServer struct { }
UnimplementedCedarPerformanceMetricsServer must be embedded to have forward compatible implementations.
func (UnimplementedCedarPerformanceMetricsServer) AttachArtifacts ¶
func (UnimplementedCedarPerformanceMetricsServer) AttachArtifacts(context.Context, *ArtifactData) (*MetricsResponse, error)
func (UnimplementedCedarPerformanceMetricsServer) AttachRollups ¶
func (UnimplementedCedarPerformanceMetricsServer) AttachRollups(context.Context, *RollupData) (*MetricsResponse, error)
func (UnimplementedCedarPerformanceMetricsServer) CloseMetrics ¶
func (UnimplementedCedarPerformanceMetricsServer) CloseMetrics(context.Context, *MetricsSeriesEnd) (*MetricsResponse, error)
func (UnimplementedCedarPerformanceMetricsServer) CreateMetricSeries ¶
func (UnimplementedCedarPerformanceMetricsServer) CreateMetricSeries(context.Context, *ResultData) (*MetricsResponse, error)
func (UnimplementedCedarPerformanceMetricsServer) SendMetrics ¶
func (UnimplementedCedarPerformanceMetricsServer) SendMetrics(CedarPerformanceMetrics_SendMetricsServer) error
type UnimplementedCedarTestResultsServer ¶
type UnimplementedCedarTestResultsServer struct { }
UnimplementedCedarTestResultsServer must be embedded to have forward compatible implementations.
func (UnimplementedCedarTestResultsServer) AddTestResults ¶
func (UnimplementedCedarTestResultsServer) AddTestResults(context.Context, *TestResults) (*TestResultsResponse, error)
func (UnimplementedCedarTestResultsServer) CloseTestResultsRecord ¶
func (UnimplementedCedarTestResultsServer) CloseTestResultsRecord(context.Context, *TestResultsEndInfo) (*TestResultsResponse, error)
func (UnimplementedCedarTestResultsServer) CreateTestResultsRecord ¶
func (UnimplementedCedarTestResultsServer) CreateTestResultsRecord(context.Context, *TestResultsInfo) (*TestResultsResponse, error)
func (UnimplementedCedarTestResultsServer) StreamTestResults ¶
func (UnimplementedCedarTestResultsServer) StreamTestResults(CedarTestResults_StreamTestResultsServer) error
type UnimplementedHealthServer ¶
type UnimplementedHealthServer struct { }
UnimplementedHealthServer must be embedded to have forward compatible implementations.
func (UnimplementedHealthServer) Check ¶
func (UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
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.
Source Files ¶
- buildlogger.ext.go
- buildlogger.pb.go
- buildlogger_grpc.pb.go
- buildlogger_service.go
- formats.ext.go
- formats.pb.go
- health.pb.go
- health_grpc.pb.go
- health_service.go
- perf.ext.go
- perf.pb.go
- perf_grpc.pb.go
- perf_service.go
- test_results.ext.go
- test_results.pb.go
- test_results_grpc.pb.go
- test_results_service.go
- utils.go