blob: 060beb300500d8f5d8a0fc1259826f1d74fe4f14 [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: go.chromium.org/luci/resultdb/proto/rpc/v1/recorder.proto
package resultpb
import prpc "go.chromium.org/luci/grpc/prpc"
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
empty "github.com/golang/protobuf/ptypes/empty"
_ "google.golang.org/genproto/googleapis/api/annotations"
field_mask "google.golang.org/genproto/protobuf/field_mask"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// A request message for CreateInvocation.
type CreateInvocationRequest struct {
// Invocation identifier, becomes a part of the invocation.name.
// LUCI systems MAY create invocations with nicely formatted IDs, such as
// "build-1234567890". All other clients MUST use GUIDs.
//
// Regex: ^[a-z][a-z0-9_\-]*$.
InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
// Invocation data to insert.
Invocation *Invocation `protobuf:"bytes,2,opt,name=invocation,proto3" json:"invocation,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CreateInvocationRequest) Reset() { *m = CreateInvocationRequest{} }
func (m *CreateInvocationRequest) String() string { return proto.CompactTextString(m) }
func (*CreateInvocationRequest) ProtoMessage() {}
func (*CreateInvocationRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{0}
}
func (m *CreateInvocationRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateInvocationRequest.Unmarshal(m, b)
}
func (m *CreateInvocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateInvocationRequest.Marshal(b, m, deterministic)
}
func (m *CreateInvocationRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CreateInvocationRequest.Merge(m, src)
}
func (m *CreateInvocationRequest) XXX_Size() int {
return xxx_messageInfo_CreateInvocationRequest.Size(m)
}
func (m *CreateInvocationRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CreateInvocationRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CreateInvocationRequest proto.InternalMessageInfo
func (m *CreateInvocationRequest) GetInvocationId() string {
if m != nil {
return m.InvocationId
}
return ""
}
func (m *CreateInvocationRequest) GetInvocation() *Invocation {
if m != nil {
return m.Invocation
}
return nil
}
func (m *CreateInvocationRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A request message for BatchCreateInvocations
type BatchCreateInvocationsRequest struct {
// requests[i].request_id MUST be either empty or equal to request_id in
// this message.
//
// Up to 500 requests.
Requests []*CreateInvocationRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided, so it is
// strongly recommended to populate this field.
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateInvocationsRequest) Reset() { *m = BatchCreateInvocationsRequest{} }
func (m *BatchCreateInvocationsRequest) String() string { return proto.CompactTextString(m) }
func (*BatchCreateInvocationsRequest) ProtoMessage() {}
func (*BatchCreateInvocationsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{1}
}
func (m *BatchCreateInvocationsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateInvocationsRequest.Unmarshal(m, b)
}
func (m *BatchCreateInvocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateInvocationsRequest.Marshal(b, m, deterministic)
}
func (m *BatchCreateInvocationsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateInvocationsRequest.Merge(m, src)
}
func (m *BatchCreateInvocationsRequest) XXX_Size() int {
return xxx_messageInfo_BatchCreateInvocationsRequest.Size(m)
}
func (m *BatchCreateInvocationsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateInvocationsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateInvocationsRequest proto.InternalMessageInfo
func (m *BatchCreateInvocationsRequest) GetRequests() []*CreateInvocationRequest {
if m != nil {
return m.Requests
}
return nil
}
func (m *BatchCreateInvocationsRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A response message for BatchCreateInvocations RPC.
type BatchCreateInvocationsResponse struct {
// Invocations created.
Invocations []*Invocation `protobuf:"bytes,1,rep,name=invocations,proto3" json:"invocations,omitempty"`
// One token per each created invocation.
// These are passed in the response instead of as metadata, because large
// batches increase the size of the response headers beyond allowed limits and
// cause failures like crbug.com/1064496
// update_tokens[i] corresponds to invocations[i].
// *Do not log these values*.
UpdateTokens []string `protobuf:"bytes,2,rep,name=update_tokens,json=updateTokens,proto3" json:"update_tokens,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateInvocationsResponse) Reset() { *m = BatchCreateInvocationsResponse{} }
func (m *BatchCreateInvocationsResponse) String() string { return proto.CompactTextString(m) }
func (*BatchCreateInvocationsResponse) ProtoMessage() {}
func (*BatchCreateInvocationsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{2}
}
func (m *BatchCreateInvocationsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateInvocationsResponse.Unmarshal(m, b)
}
func (m *BatchCreateInvocationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateInvocationsResponse.Marshal(b, m, deterministic)
}
func (m *BatchCreateInvocationsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateInvocationsResponse.Merge(m, src)
}
func (m *BatchCreateInvocationsResponse) XXX_Size() int {
return xxx_messageInfo_BatchCreateInvocationsResponse.Size(m)
}
func (m *BatchCreateInvocationsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateInvocationsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateInvocationsResponse proto.InternalMessageInfo
func (m *BatchCreateInvocationsResponse) GetInvocations() []*Invocation {
if m != nil {
return m.Invocations
}
return nil
}
func (m *BatchCreateInvocationsResponse) GetUpdateTokens() []string {
if m != nil {
return m.UpdateTokens
}
return nil
}
// A request message for UpdateInvocation RPC.
type UpdateInvocationRequest struct {
// Invocation to update.
Invocation *Invocation `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
// The list of fields to be updated.
UpdateMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *UpdateInvocationRequest) Reset() { *m = UpdateInvocationRequest{} }
func (m *UpdateInvocationRequest) String() string { return proto.CompactTextString(m) }
func (*UpdateInvocationRequest) ProtoMessage() {}
func (*UpdateInvocationRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{3}
}
func (m *UpdateInvocationRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateInvocationRequest.Unmarshal(m, b)
}
func (m *UpdateInvocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UpdateInvocationRequest.Marshal(b, m, deterministic)
}
func (m *UpdateInvocationRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_UpdateInvocationRequest.Merge(m, src)
}
func (m *UpdateInvocationRequest) XXX_Size() int {
return xxx_messageInfo_UpdateInvocationRequest.Size(m)
}
func (m *UpdateInvocationRequest) XXX_DiscardUnknown() {
xxx_messageInfo_UpdateInvocationRequest.DiscardUnknown(m)
}
var xxx_messageInfo_UpdateInvocationRequest proto.InternalMessageInfo
func (m *UpdateInvocationRequest) GetInvocation() *Invocation {
if m != nil {
return m.Invocation
}
return nil
}
func (m *UpdateInvocationRequest) GetUpdateMask() *field_mask.FieldMask {
if m != nil {
return m.UpdateMask
}
return nil
}
// A request message for FinalizeInvocation RPC.
type FinalizeInvocationRequest struct {
// Name of the invocation to finalize.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *FinalizeInvocationRequest) Reset() { *m = FinalizeInvocationRequest{} }
func (m *FinalizeInvocationRequest) String() string { return proto.CompactTextString(m) }
func (*FinalizeInvocationRequest) ProtoMessage() {}
func (*FinalizeInvocationRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{4}
}
func (m *FinalizeInvocationRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FinalizeInvocationRequest.Unmarshal(m, b)
}
func (m *FinalizeInvocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FinalizeInvocationRequest.Marshal(b, m, deterministic)
}
func (m *FinalizeInvocationRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_FinalizeInvocationRequest.Merge(m, src)
}
func (m *FinalizeInvocationRequest) XXX_Size() int {
return xxx_messageInfo_FinalizeInvocationRequest.Size(m)
}
func (m *FinalizeInvocationRequest) XXX_DiscardUnknown() {
xxx_messageInfo_FinalizeInvocationRequest.DiscardUnknown(m)
}
var xxx_messageInfo_FinalizeInvocationRequest proto.InternalMessageInfo
func (m *FinalizeInvocationRequest) GetName() string {
if m != nil {
return m.Name
}
return ""
}
// A request message for UpdateIncludedInvocations RPC.
type UpdateIncludedInvocationsRequest struct {
// Name of the invocation to add/remove inclusions to/from,
// see Invocation.name.
// For example, name of the buildbucket build invocation that should include
// a swarming task invocation.
IncludingInvocation string `protobuf:"bytes,1,opt,name=including_invocation,json=includingInvocation,proto3" json:"including_invocation,omitempty"`
// Names of the invocations to include, see Invocation.name.
// If any of these invocations are already included, they will be silently
// ignored for idempotency.
AddInvocations []string `protobuf:"bytes,2,rep,name=add_invocations,json=addInvocations,proto3" json:"add_invocations,omitempty"`
// Names of the previously included invocations to remove, see
// Invocation.name.
// If any of these invocations are not included already, they will be silently
// ignored for idempotency.
RemoveInvocations []string `protobuf:"bytes,3,rep,name=remove_invocations,json=removeInvocations,proto3" json:"remove_invocations,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *UpdateIncludedInvocationsRequest) Reset() { *m = UpdateIncludedInvocationsRequest{} }
func (m *UpdateIncludedInvocationsRequest) String() string { return proto.CompactTextString(m) }
func (*UpdateIncludedInvocationsRequest) ProtoMessage() {}
func (*UpdateIncludedInvocationsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{5}
}
func (m *UpdateIncludedInvocationsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdateIncludedInvocationsRequest.Unmarshal(m, b)
}
func (m *UpdateIncludedInvocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UpdateIncludedInvocationsRequest.Marshal(b, m, deterministic)
}
func (m *UpdateIncludedInvocationsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_UpdateIncludedInvocationsRequest.Merge(m, src)
}
func (m *UpdateIncludedInvocationsRequest) XXX_Size() int {
return xxx_messageInfo_UpdateIncludedInvocationsRequest.Size(m)
}
func (m *UpdateIncludedInvocationsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_UpdateIncludedInvocationsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_UpdateIncludedInvocationsRequest proto.InternalMessageInfo
func (m *UpdateIncludedInvocationsRequest) GetIncludingInvocation() string {
if m != nil {
return m.IncludingInvocation
}
return ""
}
func (m *UpdateIncludedInvocationsRequest) GetAddInvocations() []string {
if m != nil {
return m.AddInvocations
}
return nil
}
func (m *UpdateIncludedInvocationsRequest) GetRemoveInvocations() []string {
if m != nil {
return m.RemoveInvocations
}
return nil
}
// A request message for CreateTestResult RPC.
type CreateTestResultRequest struct {
// Name of the parent invocation, see Invocation.name.
Invocation string `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
// The test result to create.
// Test id and result id are used to dedupe requests, i.e.
// if a test result with the same test id and result id already exists in
// the invocation, then the requests succeeds as opposed to returns with
// ALREADY_EXISTS error.
TestResult *TestResult `protobuf:"bytes,2,opt,name=test_result,json=testResult,proto3" json:"test_result,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided, so it is
// strongly recommended to populate this field.
//
// Impl note: this field is used to compute the spanner-level result id, which
// will encode tuple (request_id, index_of_request)", where
// - request_id is a random GUID if not provided by the user
// - index_of_request is 0 in CreateTestResult RPC, or index of the request
// in BatchCreateTestResultsRequest in the batch RPC.
// TODO(jchinlee): remove this impl note when it is converted into code.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CreateTestResultRequest) Reset() { *m = CreateTestResultRequest{} }
func (m *CreateTestResultRequest) String() string { return proto.CompactTextString(m) }
func (*CreateTestResultRequest) ProtoMessage() {}
func (*CreateTestResultRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{6}
}
func (m *CreateTestResultRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateTestResultRequest.Unmarshal(m, b)
}
func (m *CreateTestResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateTestResultRequest.Marshal(b, m, deterministic)
}
func (m *CreateTestResultRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CreateTestResultRequest.Merge(m, src)
}
func (m *CreateTestResultRequest) XXX_Size() int {
return xxx_messageInfo_CreateTestResultRequest.Size(m)
}
func (m *CreateTestResultRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CreateTestResultRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CreateTestResultRequest proto.InternalMessageInfo
func (m *CreateTestResultRequest) GetInvocation() string {
if m != nil {
return m.Invocation
}
return ""
}
func (m *CreateTestResultRequest) GetTestResult() *TestResult {
if m != nil {
return m.TestResult
}
return nil
}
func (m *CreateTestResultRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A request message for BatchCreateTestResults RPC.
type BatchCreateTestResultsRequest struct {
// Name of the parent invocation, see Invocation.name.
Invocation string `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
// Requests to create test results.
// requests[i].invocation MUST be either empty or equal to invocation in this
// message.
// requests[i].request_id MUST be either empty or equal to request_id in
// this message.
//
// Up to 500 requests.
Requests []*CreateTestResultRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided, so it is
// strongly recommended to populate this field.
//
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateTestResultsRequest) Reset() { *m = BatchCreateTestResultsRequest{} }
func (m *BatchCreateTestResultsRequest) String() string { return proto.CompactTextString(m) }
func (*BatchCreateTestResultsRequest) ProtoMessage() {}
func (*BatchCreateTestResultsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{7}
}
func (m *BatchCreateTestResultsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateTestResultsRequest.Unmarshal(m, b)
}
func (m *BatchCreateTestResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateTestResultsRequest.Marshal(b, m, deterministic)
}
func (m *BatchCreateTestResultsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateTestResultsRequest.Merge(m, src)
}
func (m *BatchCreateTestResultsRequest) XXX_Size() int {
return xxx_messageInfo_BatchCreateTestResultsRequest.Size(m)
}
func (m *BatchCreateTestResultsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateTestResultsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateTestResultsRequest proto.InternalMessageInfo
func (m *BatchCreateTestResultsRequest) GetInvocation() string {
if m != nil {
return m.Invocation
}
return ""
}
func (m *BatchCreateTestResultsRequest) GetRequests() []*CreateTestResultRequest {
if m != nil {
return m.Requests
}
return nil
}
func (m *BatchCreateTestResultsRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A response message for BatchCreateTestResults RPC.
type BatchCreateTestResultsResponse struct {
// Test results created.
TestResults []*TestResult `protobuf:"bytes,1,rep,name=test_results,json=testResults,proto3" json:"test_results,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateTestResultsResponse) Reset() { *m = BatchCreateTestResultsResponse{} }
func (m *BatchCreateTestResultsResponse) String() string { return proto.CompactTextString(m) }
func (*BatchCreateTestResultsResponse) ProtoMessage() {}
func (*BatchCreateTestResultsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{8}
}
func (m *BatchCreateTestResultsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateTestResultsResponse.Unmarshal(m, b)
}
func (m *BatchCreateTestResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateTestResultsResponse.Marshal(b, m, deterministic)
}
func (m *BatchCreateTestResultsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateTestResultsResponse.Merge(m, src)
}
func (m *BatchCreateTestResultsResponse) XXX_Size() int {
return xxx_messageInfo_BatchCreateTestResultsResponse.Size(m)
}
func (m *BatchCreateTestResultsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateTestResultsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateTestResultsResponse proto.InternalMessageInfo
func (m *BatchCreateTestResultsResponse) GetTestResults() []*TestResult {
if m != nil {
return m.TestResults
}
return nil
}
// A request message for CreateTestExoneration RPC.
type CreateTestExonerationRequest struct {
// Name of the parent invocation, see Invocation.name.
Invocation string `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
// The TestExoneration to create.
TestExoneration *TestExoneration `protobuf:"bytes,2,opt,name=test_exoneration,json=testExoneration,proto3" json:"test_exoneration,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CreateTestExonerationRequest) Reset() { *m = CreateTestExonerationRequest{} }
func (m *CreateTestExonerationRequest) String() string { return proto.CompactTextString(m) }
func (*CreateTestExonerationRequest) ProtoMessage() {}
func (*CreateTestExonerationRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{9}
}
func (m *CreateTestExonerationRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_CreateTestExonerationRequest.Unmarshal(m, b)
}
func (m *CreateTestExonerationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_CreateTestExonerationRequest.Marshal(b, m, deterministic)
}
func (m *CreateTestExonerationRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CreateTestExonerationRequest.Merge(m, src)
}
func (m *CreateTestExonerationRequest) XXX_Size() int {
return xxx_messageInfo_CreateTestExonerationRequest.Size(m)
}
func (m *CreateTestExonerationRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CreateTestExonerationRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CreateTestExonerationRequest proto.InternalMessageInfo
func (m *CreateTestExonerationRequest) GetInvocation() string {
if m != nil {
return m.Invocation
}
return ""
}
func (m *CreateTestExonerationRequest) GetTestExoneration() *TestExoneration {
if m != nil {
return m.TestExoneration
}
return nil
}
func (m *CreateTestExonerationRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A request message for BatchCreateTestExonerations RPC.
type BatchCreateTestExonerationsRequest struct {
// Name of the parent invocation, see Invocation.name.
Invocation string `protobuf:"bytes,1,opt,name=invocation,proto3" json:"invocation,omitempty"`
// Requests to create TestExonerations.
// requests[i].invocation MUST be either empty or equal to invocation in this
// message.
// requests[i].request_id MUST be either empty or equal to request_id in
// this message.
//
// Up to 500 requests.
Requests []*CreateTestExonerationRequest `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"`
// A unique identifier for this request. Restricted to 36 ASCII characters.
// A random UUID is recommended.
// This request is only idempotent if a `request_id` is provided, so it is
// strongly recommended to populate this field.
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateTestExonerationsRequest) Reset() { *m = BatchCreateTestExonerationsRequest{} }
func (m *BatchCreateTestExonerationsRequest) String() string { return proto.CompactTextString(m) }
func (*BatchCreateTestExonerationsRequest) ProtoMessage() {}
func (*BatchCreateTestExonerationsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{10}
}
func (m *BatchCreateTestExonerationsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateTestExonerationsRequest.Unmarshal(m, b)
}
func (m *BatchCreateTestExonerationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateTestExonerationsRequest.Marshal(b, m, deterministic)
}
func (m *BatchCreateTestExonerationsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateTestExonerationsRequest.Merge(m, src)
}
func (m *BatchCreateTestExonerationsRequest) XXX_Size() int {
return xxx_messageInfo_BatchCreateTestExonerationsRequest.Size(m)
}
func (m *BatchCreateTestExonerationsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateTestExonerationsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateTestExonerationsRequest proto.InternalMessageInfo
func (m *BatchCreateTestExonerationsRequest) GetInvocation() string {
if m != nil {
return m.Invocation
}
return ""
}
func (m *BatchCreateTestExonerationsRequest) GetRequests() []*CreateTestExonerationRequest {
if m != nil {
return m.Requests
}
return nil
}
func (m *BatchCreateTestExonerationsRequest) GetRequestId() string {
if m != nil {
return m.RequestId
}
return ""
}
// A response message for BatchCreateTestExonerations RPC.
type BatchCreateTestExonerationsResponse struct {
// Test exonerations created.
TestExonerations []*TestExoneration `protobuf:"bytes,1,rep,name=test_exonerations,json=testExonerations,proto3" json:"test_exonerations,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *BatchCreateTestExonerationsResponse) Reset() { *m = BatchCreateTestExonerationsResponse{} }
func (m *BatchCreateTestExonerationsResponse) String() string { return proto.CompactTextString(m) }
func (*BatchCreateTestExonerationsResponse) ProtoMessage() {}
func (*BatchCreateTestExonerationsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_16d7c422285c4f93, []int{11}
}
func (m *BatchCreateTestExonerationsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_BatchCreateTestExonerationsResponse.Unmarshal(m, b)
}
func (m *BatchCreateTestExonerationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_BatchCreateTestExonerationsResponse.Marshal(b, m, deterministic)
}
func (m *BatchCreateTestExonerationsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_BatchCreateTestExonerationsResponse.Merge(m, src)
}
func (m *BatchCreateTestExonerationsResponse) XXX_Size() int {
return xxx_messageInfo_BatchCreateTestExonerationsResponse.Size(m)
}
func (m *BatchCreateTestExonerationsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_BatchCreateTestExonerationsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_BatchCreateTestExonerationsResponse proto.InternalMessageInfo
func (m *BatchCreateTestExonerationsResponse) GetTestExonerations() []*TestExoneration {
if m != nil {
return m.TestExonerations
}
return nil
}
func init() {
proto.RegisterType((*CreateInvocationRequest)(nil), "luci.resultdb.rpc.v1.CreateInvocationRequest")
proto.RegisterType((*BatchCreateInvocationsRequest)(nil), "luci.resultdb.rpc.v1.BatchCreateInvocationsRequest")
proto.RegisterType((*BatchCreateInvocationsResponse)(nil), "luci.resultdb.rpc.v1.BatchCreateInvocationsResponse")
proto.RegisterType((*UpdateInvocationRequest)(nil), "luci.resultdb.rpc.v1.UpdateInvocationRequest")
proto.RegisterType((*FinalizeInvocationRequest)(nil), "luci.resultdb.rpc.v1.FinalizeInvocationRequest")
proto.RegisterType((*UpdateIncludedInvocationsRequest)(nil), "luci.resultdb.rpc.v1.UpdateIncludedInvocationsRequest")
proto.RegisterType((*CreateTestResultRequest)(nil), "luci.resultdb.rpc.v1.CreateTestResultRequest")
proto.RegisterType((*BatchCreateTestResultsRequest)(nil), "luci.resultdb.rpc.v1.BatchCreateTestResultsRequest")
proto.RegisterType((*BatchCreateTestResultsResponse)(nil), "luci.resultdb.rpc.v1.BatchCreateTestResultsResponse")
proto.RegisterType((*CreateTestExonerationRequest)(nil), "luci.resultdb.rpc.v1.CreateTestExonerationRequest")
proto.RegisterType((*BatchCreateTestExonerationsRequest)(nil), "luci.resultdb.rpc.v1.BatchCreateTestExonerationsRequest")
proto.RegisterType((*BatchCreateTestExonerationsResponse)(nil), "luci.resultdb.rpc.v1.BatchCreateTestExonerationsResponse")
}
func init() {
proto.RegisterFile("go.chromium.org/luci/resultdb/proto/rpc/v1/recorder.proto", fileDescriptor_16d7c422285c4f93)
}
var fileDescriptor_16d7c422285c4f93 = []byte{
// 824 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0x4d, 0x6f, 0xd3, 0x4a,
0x14, 0x8d, 0x93, 0xa7, 0xa7, 0xe6, 0xa6, 0x7d, 0x6d, 0xe7, 0x95, 0x36, 0x75, 0x29, 0x44, 0xae,
0x10, 0xd9, 0xd4, 0x56, 0xd3, 0x52, 0x51, 0x95, 0x05, 0xa4, 0x6a, 0xa5, 0x2c, 0x60, 0x61, 0xb5,
0x1b, 0x36, 0x91, 0x63, 0x4f, 0x53, 0xab, 0x89, 0xc7, 0xd8, 0x4e, 0x44, 0xd9, 0xb3, 0x60, 0xcf,
0x96, 0x1d, 0x6c, 0x59, 0xb0, 0x40, 0xf0, 0x6f, 0xf8, 0x29, 0xc8, 0x9e, 0x71, 0x3c, 0xf1, 0x47,
0x6c, 0x77, 0x97, 0xdc, 0xb9, 0x77, 0xee, 0x99, 0x73, 0xee, 0x87, 0xe1, 0x64, 0x48, 0x64, 0xfd,
0xc6, 0x21, 0x63, 0x73, 0x32, 0x96, 0x89, 0x33, 0x54, 0x46, 0x13, 0xdd, 0x54, 0x1c, 0xec, 0x4e,
0x46, 0x9e, 0x31, 0x50, 0x6c, 0x87, 0x78, 0x44, 0x71, 0x6c, 0x5d, 0x99, 0x1e, 0x28, 0x0e, 0xd6,
0x89, 0x63, 0x60, 0x47, 0x0e, 0xac, 0x68, 0xc3, 0x77, 0x95, 0x43, 0x57, 0xd9, 0xb1, 0x75, 0x79,
0x7a, 0x20, 0x3e, 0x1e, 0x12, 0x32, 0x1c, 0x61, 0x45, 0xb3, 0x4d, 0xe5, 0xda, 0xc4, 0x23, 0xa3,
0x3f, 0xc0, 0x37, 0xda, 0xd4, 0x24, 0x2c, 0x4c, 0xdc, 0x61, 0x0e, 0xc1, 0xbf, 0xc1, 0xe4, 0x5a,
0xc1, 0x63, 0xdb, 0xbb, 0x63, 0x87, 0xad, 0xf8, 0x21, 0xbd, 0x62, 0xac, 0xb9, 0xb7, 0xcc, 0xe3,
0xb4, 0x04, 0x60, 0xd3, 0x9a, 0x12, 0x5d, 0xf3, 0x4c, 0x62, 0xb1, 0xe0, 0x17, 0x25, 0x82, 0x3d,
0xec, 0x7a, 0x7d, 0x7a, 0x44, 0xa3, 0xa5, 0xaf, 0x02, 0x6c, 0x9d, 0x39, 0x58, 0xf3, 0x70, 0x6f,
0x76, 0xb1, 0x8a, 0xdf, 0x4d, 0xb0, 0xeb, 0xa1, 0x36, 0xac, 0x44, 0xd9, 0xfa, 0xa6, 0xd1, 0x14,
0x5a, 0x42, 0xbb, 0xde, 0xad, 0xfd, 0x79, 0x55, 0x55, 0x97, 0xa3, 0x93, 0x9e, 0x81, 0x5e, 0x02,
0x44, 0xff, 0x9b, 0xd5, 0x96, 0xd0, 0x6e, 0x74, 0x5a, 0x72, 0x1a, 0x97, 0x32, 0x97, 0x86, 0x8b,
0x41, 0xbb, 0x00, 0x0e, 0x4d, 0xeb, 0x27, 0xaa, 0xf9, 0x89, 0xd4, 0x3a, 0xb3, 0xf4, 0x0c, 0xe9,
0x93, 0x00, 0xbb, 0x5d, 0xcd, 0xd3, 0x6f, 0xe2, 0x58, 0xdd, 0x10, 0x6c, 0x0f, 0x96, 0x98, 0xbb,
0xdb, 0x14, 0x5a, 0xb5, 0x76, 0xa3, 0xb3, 0x9f, 0x0e, 0x20, 0xe3, 0xb5, 0xea, 0x2c, 0x3c, 0x86,
0xa5, 0x9a, 0x82, 0xe5, 0x51, 0x16, 0x16, 0xd7, 0x26, 0x96, 0x8b, 0x51, 0x17, 0x1a, 0xd1, 0xdb,
0x42, 0x3c, 0xf9, 0x84, 0xf0, 0x41, 0x68, 0x0f, 0x56, 0x26, 0xb6, 0xa1, 0x79, 0xb8, 0xef, 0x91,
0x5b, 0x6c, 0xb9, 0xcd, 0x6a, 0xab, 0xd6, 0xae, 0xab, 0xcb, 0xd4, 0x78, 0x19, 0xd8, 0xa4, 0x2f,
0x02, 0x6c, 0x5d, 0x05, 0x86, 0xa4, 0x7c, 0xe7, 0x73, 0xa2, 0x08, 0xc5, 0x44, 0xa1, 0xea, 0xf2,
0xca, 0x9c, 0x42, 0x83, 0xe1, 0xf0, 0x2b, 0x96, 0x89, 0x2b, 0xca, 0xb4, 0xa8, 0xe5, 0xb0, 0xa8,
0xe5, 0x0b, 0xbf, 0xa8, 0x5f, 0x6b, 0xee, 0xad, 0x0a, 0xd4, 0xdd, 0xff, 0x2d, 0x1d, 0xc1, 0xf6,
0x85, 0x69, 0x69, 0x23, 0xf3, 0x43, 0x0a, 0xc0, 0x2d, 0xf8, 0xc7, 0xd2, 0xc6, 0x98, 0x2f, 0xab,
0xc0, 0x20, 0xfd, 0x10, 0xa0, 0x15, 0xbe, 0x4a, 0x1f, 0x4d, 0x0c, 0x6c, 0xa4, 0x08, 0x7e, 0x0c,
0x1b, 0x66, 0x70, 0x6a, 0x5a, 0xc3, 0x7e, 0xec, 0xa1, 0xec, 0xb6, 0xff, 0x67, 0x0e, 0x51, 0x3c,
0x7a, 0x0a, 0xab, 0x9a, 0x61, 0xf4, 0x79, 0x7d, 0x28, 0xb3, 0xff, 0x69, 0x06, 0x9f, 0x07, 0xed,
0x03, 0x72, 0xf0, 0x98, 0x4c, 0xf1, 0x9c, 0x6f, 0x2d, 0xf0, 0x5d, 0xa7, 0x27, 0x9c, 0xbb, 0xf4,
0x6d, 0xd6, 0x49, 0x97, 0x7e, 0x39, 0x05, 0x0c, 0x87, 0x58, 0xf7, 0x12, 0x52, 0xd4, 0x93, 0x44,
0x5f, 0x40, 0x83, 0xeb, 0xcf, 0xc5, 0x5d, 0x14, 0xa5, 0x60, 0xf7, 0x78, 0x33, 0x43, 0x5e, 0x2b,
0x7d, 0x9f, 0x6f, 0xa5, 0xe8, 0x26, 0xb7, 0x14, 0x5a, 0xbe, 0xdf, 0xaa, 0xf9, 0xfd, 0x96, 0xe0,
0x24, 0xb3, 0xdf, 0x12, 0x80, 0xf1, 0x5c, 0xbb, 0xcd, 0xe1, 0x65, 0xed, 0x76, 0x06, 0xcb, 0x1c,
0x73, 0x39, 0xfd, 0xc6, 0x21, 0x69, 0x44, 0xac, 0xb9, 0xd2, 0x6f, 0x01, 0x1e, 0x46, 0x29, 0xce,
0xdf, 0x13, 0x0b, 0x3b, 0x73, 0xe5, 0x5a, 0x88, 0x96, 0x2b, 0x58, 0x0b, 0xa0, 0xe0, 0x28, 0x9e,
0x29, 0xf9, 0x24, 0x1b, 0x0e, 0x97, 0x8c, 0xde, 0xb8, 0xea, 0xcd, 0x5b, 0xf3, 0x28, 0xfa, 0x25,
0x80, 0x14, 0xe3, 0x88, 0x8b, 0x2e, 0x27, 0xec, 0x9b, 0x84, 0xb0, 0x9d, 0x3c, 0x61, 0x93, 0x64,
0x15, 0x57, 0xf7, 0x0e, 0xf6, 0x16, 0x22, 0x67, 0x12, 0xab, 0xb0, 0x1e, 0xe7, 0x35, 0xd4, 0xb9,
0x18, 0xb1, 0xea, 0x5a, 0x8c, 0x53, 0xb7, 0xf3, 0x73, 0x09, 0x96, 0x54, 0xb6, 0xff, 0x11, 0x86,
0xb5, 0xf8, 0x3c, 0x47, 0xe5, 0x36, 0x88, 0x98, 0x3b, 0x5c, 0xa5, 0x0a, 0xfa, 0x28, 0xc0, 0x66,
0xfa, 0xf2, 0x40, 0x87, 0xe9, 0xe1, 0x0b, 0xd7, 0x9e, 0x78, 0x54, 0x2e, 0x88, 0xb2, 0x29, 0x55,
0xfc, 0xe7, 0xc6, 0xf7, 0x46, 0xd6, 0x73, 0x33, 0xf6, 0x4b, 0xa1, 0xe7, 0x9a, 0x80, 0x92, 0xf3,
0x1f, 0x29, 0xe9, 0x91, 0x99, 0x9b, 0xa2, 0x50, 0xaa, 0x31, 0x6c, 0x67, 0xee, 0x0c, 0x74, 0xbc,
0xf8, 0x69, 0x59, 0x4b, 0x46, 0xdc, 0x4c, 0xec, 0xb9, 0x73, 0xff, 0xcb, 0x8e, 0x12, 0x18, 0x1f,
0x48, 0xa8, 0xdc, 0x04, 0x14, 0x73, 0x07, 0x54, 0xb2, 0x5e, 0xb8, 0xe9, 0x57, 0xa0, 0x5e, 0x92,
0xb3, 0xbd, 0x40, 0xbd, 0xa4, 0x0c, 0x58, 0xa9, 0x82, 0x3c, 0x78, 0x90, 0xda, 0xa1, 0xe8, 0x1e,
0xc3, 0x41, 0x2c, 0xd6, 0xb1, 0x52, 0x05, 0x7d, 0x16, 0x60, 0x67, 0xc1, 0x74, 0x40, 0xcf, 0x0b,
0xbd, 0x26, 0x65, 0x14, 0x8a, 0x27, 0xf7, 0x88, 0x0c, 0xc9, 0xe8, 0x3e, 0x7b, 0x7b, 0x58, 0xfc,
0xa3, 0xfb, 0x94, 0x5a, 0xed, 0xc1, 0xe0, 0xdf, 0xc0, 0x7c, 0xf8, 0x37, 0x00, 0x00, 0xff, 0xff,
0xbf, 0xb3, 0xcf, 0xff, 0xa0, 0x0c, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6
// RecorderClient is the client API for Recorder service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type RecorderClient interface {
// Creates a new invocation.
// The request specifies the invocation id and its contents.
//
// The response header metadata contains "update-token" required for future
// updates, including finalization.
//
// If invocation with the given ID already exists, returns ALREADY_EXISTS
// error code.
CreateInvocation(ctx context.Context, in *CreateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error)
// Creates multiple invocations in a single rpc.
//
// The response header metadata contains a multi-valued "update-token"
// required for future updates, including finalization. The tokens will be
// given in the same order as BatchCreateInvocationRequest.requests.
BatchCreateInvocations(ctx context.Context, in *BatchCreateInvocationsRequest, opts ...grpc.CallOption) (*BatchCreateInvocationsResponse, error)
// Updates an existing non-finalized invocation.
UpdateInvocation(ctx context.Context, in *UpdateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error)
// Transitions the given invocation to the state FINALIZED.
FinalizeInvocation(ctx context.Context, in *FinalizeInvocationRequest, opts ...grpc.CallOption) (*Invocation, error)
// Updates inclusions for a non-finalized invocation.
UpdateIncludedInvocations(ctx context.Context, in *UpdateIncludedInvocationsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
// Appends a test result to a non-finalized invocation.
CreateTestResult(ctx context.Context, in *CreateTestResultRequest, opts ...grpc.CallOption) (*TestResult, error)
// Atomically appends a batch of test results to a non-finalized invocation.
BatchCreateTestResults(ctx context.Context, in *BatchCreateTestResultsRequest, opts ...grpc.CallOption) (*BatchCreateTestResultsResponse, error)
// Appends a test exoneration to a non-finalized invocation.
CreateTestExoneration(ctx context.Context, in *CreateTestExonerationRequest, opts ...grpc.CallOption) (*TestExoneration, error)
// Atomically appends a batch of test exonerations to a non-finalized
// invocation.
BatchCreateTestExonerations(ctx context.Context, in *BatchCreateTestExonerationsRequest, opts ...grpc.CallOption) (*BatchCreateTestExonerationsResponse, error)
}
type recorderPRPCClient struct {
client *prpc.Client
}
func NewRecorderPRPCClient(client *prpc.Client) RecorderClient {
return &recorderPRPCClient{client}
}
func (c *recorderPRPCClient) CreateInvocation(ctx context.Context, in *CreateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "CreateInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) BatchCreateInvocations(ctx context.Context, in *BatchCreateInvocationsRequest, opts ...grpc.CallOption) (*BatchCreateInvocationsResponse, error) {
out := new(BatchCreateInvocationsResponse)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "BatchCreateInvocations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) UpdateInvocation(ctx context.Context, in *UpdateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "UpdateInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) FinalizeInvocation(ctx context.Context, in *FinalizeInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "FinalizeInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) UpdateIncludedInvocations(ctx context.Context, in *UpdateIncludedInvocationsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
out := new(empty.Empty)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "UpdateIncludedInvocations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) CreateTestResult(ctx context.Context, in *CreateTestResultRequest, opts ...grpc.CallOption) (*TestResult, error) {
out := new(TestResult)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "CreateTestResult", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) BatchCreateTestResults(ctx context.Context, in *BatchCreateTestResultsRequest, opts ...grpc.CallOption) (*BatchCreateTestResultsResponse, error) {
out := new(BatchCreateTestResultsResponse)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "BatchCreateTestResults", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) CreateTestExoneration(ctx context.Context, in *CreateTestExonerationRequest, opts ...grpc.CallOption) (*TestExoneration, error) {
out := new(TestExoneration)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "CreateTestExoneration", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderPRPCClient) BatchCreateTestExonerations(ctx context.Context, in *BatchCreateTestExonerationsRequest, opts ...grpc.CallOption) (*BatchCreateTestExonerationsResponse, error) {
out := new(BatchCreateTestExonerationsResponse)
err := c.client.Call(ctx, "luci.resultdb.rpc.v1.Recorder", "BatchCreateTestExonerations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
type recorderClient struct {
cc grpc.ClientConnInterface
}
func NewRecorderClient(cc grpc.ClientConnInterface) RecorderClient {
return &recorderClient{cc}
}
func (c *recorderClient) CreateInvocation(ctx context.Context, in *CreateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/CreateInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) BatchCreateInvocations(ctx context.Context, in *BatchCreateInvocationsRequest, opts ...grpc.CallOption) (*BatchCreateInvocationsResponse, error) {
out := new(BatchCreateInvocationsResponse)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/BatchCreateInvocations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) UpdateInvocation(ctx context.Context, in *UpdateInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/UpdateInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) FinalizeInvocation(ctx context.Context, in *FinalizeInvocationRequest, opts ...grpc.CallOption) (*Invocation, error) {
out := new(Invocation)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/FinalizeInvocation", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) UpdateIncludedInvocations(ctx context.Context, in *UpdateIncludedInvocationsRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
out := new(empty.Empty)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/UpdateIncludedInvocations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) CreateTestResult(ctx context.Context, in *CreateTestResultRequest, opts ...grpc.CallOption) (*TestResult, error) {
out := new(TestResult)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/CreateTestResult", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) BatchCreateTestResults(ctx context.Context, in *BatchCreateTestResultsRequest, opts ...grpc.CallOption) (*BatchCreateTestResultsResponse, error) {
out := new(BatchCreateTestResultsResponse)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/BatchCreateTestResults", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) CreateTestExoneration(ctx context.Context, in *CreateTestExonerationRequest, opts ...grpc.CallOption) (*TestExoneration, error) {
out := new(TestExoneration)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/CreateTestExoneration", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *recorderClient) BatchCreateTestExonerations(ctx context.Context, in *BatchCreateTestExonerationsRequest, opts ...grpc.CallOption) (*BatchCreateTestExonerationsResponse, error) {
out := new(BatchCreateTestExonerationsResponse)
err := c.cc.Invoke(ctx, "/luci.resultdb.rpc.v1.Recorder/BatchCreateTestExonerations", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// RecorderServer is the server API for Recorder service.
type RecorderServer interface {
// Creates a new invocation.
// The request specifies the invocation id and its contents.
//
// The response header metadata contains "update-token" required for future
// updates, including finalization.
//
// If invocation with the given ID already exists, returns ALREADY_EXISTS
// error code.
CreateInvocation(context.Context, *CreateInvocationRequest) (*Invocation, error)
// Creates multiple invocations in a single rpc.
//
// The response header metadata contains a multi-valued "update-token"
// required for future updates, including finalization. The tokens will be
// given in the same order as BatchCreateInvocationRequest.requests.
BatchCreateInvocations(context.Context, *BatchCreateInvocationsRequest) (*BatchCreateInvocationsResponse, error)
// Updates an existing non-finalized invocation.
UpdateInvocation(context.Context, *UpdateInvocationRequest) (*Invocation, error)
// Transitions the given invocation to the state FINALIZED.
FinalizeInvocation(context.Context, *FinalizeInvocationRequest) (*Invocation, error)
// Updates inclusions for a non-finalized invocation.
UpdateIncludedInvocations(context.Context, *UpdateIncludedInvocationsRequest) (*empty.Empty, error)
// Appends a test result to a non-finalized invocation.
CreateTestResult(context.Context, *CreateTestResultRequest) (*TestResult, error)
// Atomically appends a batch of test results to a non-finalized invocation.
BatchCreateTestResults(context.Context, *BatchCreateTestResultsRequest) (*BatchCreateTestResultsResponse, error)
// Appends a test exoneration to a non-finalized invocation.
CreateTestExoneration(context.Context, *CreateTestExonerationRequest) (*TestExoneration, error)
// Atomically appends a batch of test exonerations to a non-finalized
// invocation.
BatchCreateTestExonerations(context.Context, *BatchCreateTestExonerationsRequest) (*BatchCreateTestExonerationsResponse, error)
}
// UnimplementedRecorderServer can be embedded to have forward compatible implementations.
type UnimplementedRecorderServer struct {
}
func (*UnimplementedRecorderServer) CreateInvocation(ctx context.Context, req *CreateInvocationRequest) (*Invocation, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateInvocation not implemented")
}
func (*UnimplementedRecorderServer) BatchCreateInvocations(ctx context.Context, req *BatchCreateInvocationsRequest) (*BatchCreateInvocationsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BatchCreateInvocations not implemented")
}
func (*UnimplementedRecorderServer) UpdateInvocation(ctx context.Context, req *UpdateInvocationRequest) (*Invocation, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateInvocation not implemented")
}
func (*UnimplementedRecorderServer) FinalizeInvocation(ctx context.Context, req *FinalizeInvocationRequest) (*Invocation, error) {
return nil, status.Errorf(codes.Unimplemented, "method FinalizeInvocation not implemented")
}
func (*UnimplementedRecorderServer) UpdateIncludedInvocations(ctx context.Context, req *UpdateIncludedInvocationsRequest) (*empty.Empty, error) {
return nil, status.Errorf(codes.Unimplemented, "method UpdateIncludedInvocations not implemented")
}
func (*UnimplementedRecorderServer) CreateTestResult(ctx context.Context, req *CreateTestResultRequest) (*TestResult, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateTestResult not implemented")
}
func (*UnimplementedRecorderServer) BatchCreateTestResults(ctx context.Context, req *BatchCreateTestResultsRequest) (*BatchCreateTestResultsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BatchCreateTestResults not implemented")
}
func (*UnimplementedRecorderServer) CreateTestExoneration(ctx context.Context, req *CreateTestExonerationRequest) (*TestExoneration, error) {
return nil, status.Errorf(codes.Unimplemented, "method CreateTestExoneration not implemented")
}
func (*UnimplementedRecorderServer) BatchCreateTestExonerations(ctx context.Context, req *BatchCreateTestExonerationsRequest) (*BatchCreateTestExonerationsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method BatchCreateTestExonerations not implemented")
}
func RegisterRecorderServer(s prpc.Registrar, srv RecorderServer) {
s.RegisterService(&_Recorder_serviceDesc, srv)
}
func _Recorder_CreateInvocation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateInvocationRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).CreateInvocation(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/CreateInvocation",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).CreateInvocation(ctx, req.(*CreateInvocationRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_BatchCreateInvocations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BatchCreateInvocationsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).BatchCreateInvocations(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/BatchCreateInvocations",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).BatchCreateInvocations(ctx, req.(*BatchCreateInvocationsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_UpdateInvocation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateInvocationRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).UpdateInvocation(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/UpdateInvocation",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).UpdateInvocation(ctx, req.(*UpdateInvocationRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_FinalizeInvocation_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(FinalizeInvocationRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).FinalizeInvocation(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/FinalizeInvocation",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).FinalizeInvocation(ctx, req.(*FinalizeInvocationRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_UpdateIncludedInvocations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdateIncludedInvocationsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).UpdateIncludedInvocations(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/UpdateIncludedInvocations",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).UpdateIncludedInvocations(ctx, req.(*UpdateIncludedInvocationsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_CreateTestResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateTestResultRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).CreateTestResult(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/CreateTestResult",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).CreateTestResult(ctx, req.(*CreateTestResultRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_BatchCreateTestResults_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BatchCreateTestResultsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).BatchCreateTestResults(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/BatchCreateTestResults",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).BatchCreateTestResults(ctx, req.(*BatchCreateTestResultsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_CreateTestExoneration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateTestExonerationRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).CreateTestExoneration(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/CreateTestExoneration",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).CreateTestExoneration(ctx, req.(*CreateTestExonerationRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Recorder_BatchCreateTestExonerations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(BatchCreateTestExonerationsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(RecorderServer).BatchCreateTestExonerations(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/luci.resultdb.rpc.v1.Recorder/BatchCreateTestExonerations",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(RecorderServer).BatchCreateTestExonerations(ctx, req.(*BatchCreateTestExonerationsRequest))
}
return interceptor(ctx, in, info, handler)
}
var _Recorder_serviceDesc = grpc.ServiceDesc{
ServiceName: "luci.resultdb.rpc.v1.Recorder",
HandlerType: (*RecorderServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CreateInvocation",
Handler: _Recorder_CreateInvocation_Handler,
},
{
MethodName: "BatchCreateInvocations",
Handler: _Recorder_BatchCreateInvocations_Handler,
},
{
MethodName: "UpdateInvocation",
Handler: _Recorder_UpdateInvocation_Handler,
},
{
MethodName: "FinalizeInvocation",
Handler: _Recorder_FinalizeInvocation_Handler,
},
{
MethodName: "UpdateIncludedInvocations",
Handler: _Recorder_UpdateIncludedInvocations_Handler,
},
{
MethodName: "CreateTestResult",
Handler: _Recorder_CreateTestResult_Handler,
},
{
MethodName: "BatchCreateTestResults",
Handler: _Recorder_BatchCreateTestResults_Handler,
},
{
MethodName: "CreateTestExoneration",
Handler: _Recorder_CreateTestExoneration_Handler,
},
{
MethodName: "BatchCreateTestExonerations",
Handler: _Recorder_BatchCreateTestExonerations_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "go.chromium.org/luci/resultdb/proto/rpc/v1/recorder.proto",
}