Documentation
¶
Overview ¶
Package diagnosticpb is internal to LUCI CV for use by CV maintainers.
Index ¶
- Variables
- func FileDescriptorSet() *descriptorpb.FileDescriptorSet
- func RegisterDiagnosticServer(s grpc.ServiceRegistrar, srv DiagnosticServer)
- type DeleteProjectEventsRequest
- func (*DeleteProjectEventsRequest) Descriptor() ([]byte, []int)
- func (x *DeleteProjectEventsRequest) GetLimit() int32
- func (x *DeleteProjectEventsRequest) GetProject() string
- func (*DeleteProjectEventsRequest) ProtoMessage()
- func (x *DeleteProjectEventsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteProjectEventsRequest) Reset()
- func (x *DeleteProjectEventsRequest) String() string
- type DeleteProjectEventsResponse
- func (*DeleteProjectEventsResponse) Descriptor() ([]byte, []int)
- func (x *DeleteProjectEventsResponse) GetEvents() map[string]int64
- func (*DeleteProjectEventsResponse) ProtoMessage()
- func (x *DeleteProjectEventsResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteProjectEventsResponse) Reset()
- func (x *DeleteProjectEventsResponse) String() string
- type DiagnosticClient
- type DiagnosticServer
- type GetCLRequest
- func (*GetCLRequest) Descriptor() ([]byte, []int)
- func (x *GetCLRequest) GetExternalId() string
- func (x *GetCLRequest) GetGerritUrl() string
- func (x *GetCLRequest) GetId() int64
- func (*GetCLRequest) ProtoMessage()
- func (x *GetCLRequest) ProtoReflect() protoreflect.Message
- func (x *GetCLRequest) Reset()
- func (x *GetCLRequest) String() string
- type GetCLResponse
- func (*GetCLResponse) Descriptor() ([]byte, []int)
- func (x *GetCLResponse) GetApplicableConfig() *changelist.ApplicableConfig
- func (x *GetCLResponse) GetDependentMeta() *changelist.DependentMeta
- func (x *GetCLResponse) GetEversion() int64
- func (x *GetCLResponse) GetExternalId() string
- func (x *GetCLResponse) GetId() int64
- func (x *GetCLResponse) GetIncompleteRuns() []string
- func (x *GetCLResponse) GetSnapshot() *changelist.Snapshot
- func (*GetCLResponse) ProtoMessage()
- func (x *GetCLResponse) ProtoReflect() protoreflect.Message
- func (x *GetCLResponse) Reset()
- func (x *GetCLResponse) String() string
- type GetPollerRequest
- type GetPollerResponse
- func (*GetPollerResponse) Descriptor() ([]byte, []int)
- func (x *GetPollerResponse) GetConfigHash() string
- func (x *GetPollerResponse) GetEversion() int64
- func (x *GetPollerResponse) GetProject() string
- func (x *GetPollerResponse) GetSubpollers() *poller.SubPollers
- func (x *GetPollerResponse) GetUpdateTime() *timestamppb.Timestamp
- func (*GetPollerResponse) ProtoMessage()
- func (x *GetPollerResponse) ProtoReflect() protoreflect.Message
- func (x *GetPollerResponse) Reset()
- func (x *GetPollerResponse) String() string
- type GetProjectRequest
- type GetProjectResponse
- func (*GetProjectResponse) Descriptor() ([]byte, []int)
- func (x *GetProjectResponse) GetEvents() []*prjpb.Event
- func (x *GetProjectResponse) GetState() *prjpb.PState
- func (*GetProjectResponse) ProtoMessage()
- func (x *GetProjectResponse) ProtoReflect() protoreflect.Message
- func (x *GetProjectResponse) Reset()
- func (x *GetProjectResponse) String() string
- type GetRunRequest
- type GetRunResponse
- func (*GetRunResponse) Descriptor() ([]byte, []int)
- func (x *GetRunResponse) GetCls() []int64
- func (x *GetRunResponse) GetConfigGroupId() string
- func (x *GetRunResponse) GetCreateTime() *timestamppb.Timestamp
- func (x *GetRunResponse) GetEndTime() *timestamppb.Timestamp
- func (x *GetRunResponse) GetEvents() []*eventpb.Event
- func (x *GetRunResponse) GetEversion() int64
- func (x *GetRunResponse) GetId() string
- func (x *GetRunResponse) GetMode() string
- func (x *GetRunResponse) GetOwner() string
- func (x *GetRunResponse) GetStartTime() *timestamppb.Timestamp
- func (x *GetRunResponse) GetStatus() run.Status
- func (x *GetRunResponse) GetSubmission() *run.Submission
- func (x *GetRunResponse) GetUpdateTime() *timestamppb.Timestamp
- func (*GetRunResponse) ProtoMessage()
- func (x *GetRunResponse) ProtoReflect() protoreflect.Message
- func (x *GetRunResponse) Reset()
- func (x *GetRunResponse) String() string
- type RefreshProjectCLsRequest
- func (*RefreshProjectCLsRequest) Descriptor() ([]byte, []int)
- func (x *RefreshProjectCLsRequest) GetProject() string
- func (*RefreshProjectCLsRequest) ProtoMessage()
- func (x *RefreshProjectCLsRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshProjectCLsRequest) Reset()
- func (x *RefreshProjectCLsRequest) String() string
- type RefreshProjectCLsResponse
- func (*RefreshProjectCLsResponse) Descriptor() ([]byte, []int)
- func (x *RefreshProjectCLsResponse) GetClVersions() map[int64]int64
- func (*RefreshProjectCLsResponse) ProtoMessage()
- func (x *RefreshProjectCLsResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshProjectCLsResponse) Reset()
- func (x *RefreshProjectCLsResponse) String() string
- type SendProjectEventRequest
- func (*SendProjectEventRequest) Descriptor() ([]byte, []int)
- func (x *SendProjectEventRequest) GetEvent() *prjpb.Event
- func (x *SendProjectEventRequest) GetProject() string
- func (*SendProjectEventRequest) ProtoMessage()
- func (x *SendProjectEventRequest) ProtoReflect() protoreflect.Message
- func (x *SendProjectEventRequest) Reset()
- func (x *SendProjectEventRequest) String() string
- type SendRunEventRequest
- func (*SendRunEventRequest) Descriptor() ([]byte, []int)
- func (x *SendRunEventRequest) GetEvent() *eventpb.Event
- func (x *SendRunEventRequest) GetRun() string
- func (*SendRunEventRequest) ProtoMessage()
- func (x *SendRunEventRequest) ProtoReflect() protoreflect.Message
- func (x *SendRunEventRequest) Reset()
- func (x *SendRunEventRequest) String() string
- type UnimplementedDiagnosticServer
- func (UnimplementedDiagnosticServer) DeleteProjectEvents(context.Context, *DeleteProjectEventsRequest) (*DeleteProjectEventsResponse, error)
- func (UnimplementedDiagnosticServer) GetCL(context.Context, *GetCLRequest) (*GetCLResponse, error)
- func (UnimplementedDiagnosticServer) GetPoller(context.Context, *GetPollerRequest) (*GetPollerResponse, error)
- func (UnimplementedDiagnosticServer) GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error)
- func (UnimplementedDiagnosticServer) GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
- func (UnimplementedDiagnosticServer) RefreshProjectCLs(context.Context, *RefreshProjectCLsRequest) (*RefreshProjectCLsResponse, error)
- func (UnimplementedDiagnosticServer) SendProjectEvent(context.Context, *SendProjectEventRequest) (*empty.Empty, error)
- func (UnimplementedDiagnosticServer) SendRunEvent(context.Context, *SendRunEventRequest) (*empty.Empty, error)
- type UnsafeDiagnosticServer
Constants ¶
Variables ¶
var Diagnostic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "diagnostic.Diagnostic", HandlerType: (*DiagnosticServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetProject", Handler: _Diagnostic_GetProject_Handler, }, { MethodName: "GetRun", Handler: _Diagnostic_GetRun_Handler, }, { MethodName: "GetCL", Handler: _Diagnostic_GetCL_Handler, }, { MethodName: "GetPoller", Handler: _Diagnostic_GetPoller_Handler, }, { MethodName: "DeleteProjectEvents", Handler: _Diagnostic_DeleteProjectEvents_Handler, }, { MethodName: "RefreshProjectCLs", Handler: _Diagnostic_RefreshProjectCLs_Handler, }, { MethodName: "SendProjectEvent", Handler: _Diagnostic_SendProjectEvent_Handler, }, { MethodName: "SendRunEvent", Handler: _Diagnostic_SendRunEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "go.chromium.org/luci/cv/api/diagnostic/diagnostic.proto", }
Diagnostic_ServiceDesc is the grpc.ServiceDesc for Diagnostic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_go_chromium_org_luci_cv_api_diagnostic_diagnostic_proto protoreflect.FileDescriptor
Functions ¶
func FileDescriptorSet ¶
func FileDescriptorSet() *descriptorpb.FileDescriptorSet
FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.
Will not return nil.
Do NOT modify the returned descriptor.
func RegisterDiagnosticServer ¶
func RegisterDiagnosticServer(s grpc.ServiceRegistrar, srv DiagnosticServer)
Types ¶
type DeleteProjectEventsRequest ¶
type DeleteProjectEventsRequest struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*DeleteProjectEventsRequest) Descriptor ¶
func (*DeleteProjectEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteProjectEventsRequest.ProtoReflect.Descriptor instead.
func (*DeleteProjectEventsRequest) GetLimit ¶
func (x *DeleteProjectEventsRequest) GetLimit() int32
func (*DeleteProjectEventsRequest) GetProject ¶
func (x *DeleteProjectEventsRequest) GetProject() string
func (*DeleteProjectEventsRequest) ProtoMessage ¶
func (*DeleteProjectEventsRequest) ProtoMessage()
func (*DeleteProjectEventsRequest) ProtoReflect ¶
func (x *DeleteProjectEventsRequest) ProtoReflect() protoreflect.Message
func (*DeleteProjectEventsRequest) Reset ¶
func (x *DeleteProjectEventsRequest) Reset()
func (*DeleteProjectEventsRequest) String ¶
func (x *DeleteProjectEventsRequest) String() string
type DeleteProjectEventsResponse ¶
type DeleteProjectEventsResponse struct { Events map[string]int64 `` /* 154-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteProjectEventsResponse) Descriptor ¶
func (*DeleteProjectEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteProjectEventsResponse.ProtoReflect.Descriptor instead.
func (*DeleteProjectEventsResponse) GetEvents ¶
func (x *DeleteProjectEventsResponse) GetEvents() map[string]int64
func (*DeleteProjectEventsResponse) ProtoMessage ¶
func (*DeleteProjectEventsResponse) ProtoMessage()
func (*DeleteProjectEventsResponse) ProtoReflect ¶
func (x *DeleteProjectEventsResponse) ProtoReflect() protoreflect.Message
func (*DeleteProjectEventsResponse) Reset ¶
func (x *DeleteProjectEventsResponse) Reset()
func (*DeleteProjectEventsResponse) String ¶
func (x *DeleteProjectEventsResponse) String() string
type DiagnosticClient ¶
type DiagnosticClient interface { // GetProject returns current Project state. GetProject(ctx context.Context, in *GetProjectRequest, opts ...grpc.CallOption) (*GetProjectResponse, error) // GetRun returns current Run state. GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*GetRunResponse, error) // GetCL returns current CL state. GetCL(ctx context.Context, in *GetCLRequest, opts ...grpc.CallOption) (*GetCLResponse, error) // GetPoller returns current Poller state. GetPoller(ctx context.Context, in *GetPollerRequest, opts ...grpc.CallOption) (*GetPollerResponse, error) // DeleteProjectEvents deletes all outstanding project events. // Must be called with stopped TQs. // TODO(tandrii): delete this Temporary API. DeleteProjectEvents(ctx context.Context, in *DeleteProjectEventsRequest, opts ...grpc.CallOption) (*DeleteProjectEventsResponse, error) // RefreshProjectCLs refreshes all CLs currently tracked by PM. RefreshProjectCLs(ctx context.Context, in *RefreshProjectCLsRequest, opts ...grpc.CallOption) (*RefreshProjectCLsResponse, error) // SendProjectEvent sends event to a PM. SendProjectEvent(ctx context.Context, in *SendProjectEventRequest, opts ...grpc.CallOption) (*empty.Empty, error) // SendRunEvent sends event to a RM. SendRunEvent(ctx context.Context, in *SendRunEventRequest, opts ...grpc.CallOption) (*empty.Empty, error) }
DiagnosticClient is the client API for Diagnostic 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 NewDiagnosticClient ¶
func NewDiagnosticClient(cc grpc.ClientConnInterface) DiagnosticClient
type DiagnosticServer ¶
type DiagnosticServer interface { // GetProject returns current Project state. GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error) // GetRun returns current Run state. GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error) // GetCL returns current CL state. GetCL(context.Context, *GetCLRequest) (*GetCLResponse, error) // GetPoller returns current Poller state. GetPoller(context.Context, *GetPollerRequest) (*GetPollerResponse, error) // DeleteProjectEvents deletes all outstanding project events. // Must be called with stopped TQs. // TODO(tandrii): delete this Temporary API. DeleteProjectEvents(context.Context, *DeleteProjectEventsRequest) (*DeleteProjectEventsResponse, error) // RefreshProjectCLs refreshes all CLs currently tracked by PM. RefreshProjectCLs(context.Context, *RefreshProjectCLsRequest) (*RefreshProjectCLsResponse, error) // SendProjectEvent sends event to a PM. SendProjectEvent(context.Context, *SendProjectEventRequest) (*empty.Empty, error) // SendRunEvent sends event to a RM. SendRunEvent(context.Context, *SendRunEventRequest) (*empty.Empty, error) // contains filtered or unexported methods }
DiagnosticServer is the server API for Diagnostic service. All implementations must embed UnimplementedDiagnosticServer for forward compatibility
type GetCLRequest ¶
type GetCLRequest struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` ExternalId string `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` GerritUrl string `protobuf:"bytes,3,opt,name=gerrit_url,json=gerritUrl,proto3" json:"gerrit_url,omitempty"` // contains filtered or unexported fields }
func (*GetCLRequest) Descriptor ¶
func (*GetCLRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCLRequest.ProtoReflect.Descriptor instead.
func (*GetCLRequest) GetExternalId ¶
func (x *GetCLRequest) GetExternalId() string
func (*GetCLRequest) GetGerritUrl ¶
func (x *GetCLRequest) GetGerritUrl() string
func (*GetCLRequest) GetId ¶
func (x *GetCLRequest) GetId() int64
func (*GetCLRequest) ProtoMessage ¶
func (*GetCLRequest) ProtoMessage()
func (*GetCLRequest) ProtoReflect ¶
func (x *GetCLRequest) ProtoReflect() protoreflect.Message
func (*GetCLRequest) Reset ¶
func (x *GetCLRequest) Reset()
func (*GetCLRequest) String ¶
func (x *GetCLRequest) String() string
type GetCLResponse ¶
type GetCLResponse struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Eversion int64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"` ExternalId string `protobuf:"bytes,3,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Snapshot *changelist.Snapshot `protobuf:"bytes,4,opt,name=snapshot,proto3" json:"snapshot,omitempty"` ApplicableConfig *changelist.ApplicableConfig `protobuf:"bytes,5,opt,name=applicable_config,json=applicableConfig,proto3" json:"applicable_config,omitempty"` DependentMeta *changelist.DependentMeta `protobuf:"bytes,6,opt,name=dependent_meta,json=dependentMeta,proto3" json:"dependent_meta,omitempty"` IncompleteRuns []string `protobuf:"bytes,7,rep,name=incomplete_runs,json=incompleteRuns,proto3" json:"incomplete_runs,omitempty"` // contains filtered or unexported fields }
GetProjectResponse provides non-atomic snapshot of a project state.
The config hash and status come from different DS entity than PState, and each event comes from its own entity and depends on yet another tombstone entity.
func (*GetCLResponse) Descriptor ¶
func (*GetCLResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCLResponse.ProtoReflect.Descriptor instead.
func (*GetCLResponse) GetApplicableConfig ¶
func (x *GetCLResponse) GetApplicableConfig() *changelist.ApplicableConfig
func (*GetCLResponse) GetDependentMeta ¶
func (x *GetCLResponse) GetDependentMeta() *changelist.DependentMeta
func (*GetCLResponse) GetEversion ¶
func (x *GetCLResponse) GetEversion() int64
func (*GetCLResponse) GetExternalId ¶
func (x *GetCLResponse) GetExternalId() string
func (*GetCLResponse) GetId ¶
func (x *GetCLResponse) GetId() int64
func (*GetCLResponse) GetIncompleteRuns ¶
func (x *GetCLResponse) GetIncompleteRuns() []string
func (*GetCLResponse) GetSnapshot ¶
func (x *GetCLResponse) GetSnapshot() *changelist.Snapshot
func (*GetCLResponse) ProtoMessage ¶
func (*GetCLResponse) ProtoMessage()
func (*GetCLResponse) ProtoReflect ¶
func (x *GetCLResponse) ProtoReflect() protoreflect.Message
func (*GetCLResponse) Reset ¶
func (x *GetCLResponse) Reset()
func (*GetCLResponse) String ¶
func (x *GetCLResponse) String() string
type GetPollerRequest ¶
type GetPollerRequest struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
func (*GetPollerRequest) Descriptor ¶
func (*GetPollerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPollerRequest.ProtoReflect.Descriptor instead.
func (*GetPollerRequest) GetProject ¶
func (x *GetPollerRequest) GetProject() string
func (*GetPollerRequest) ProtoMessage ¶
func (*GetPollerRequest) ProtoMessage()
func (*GetPollerRequest) ProtoReflect ¶
func (x *GetPollerRequest) ProtoReflect() protoreflect.Message
func (*GetPollerRequest) Reset ¶
func (x *GetPollerRequest) Reset()
func (*GetPollerRequest) String ¶
func (x *GetPollerRequest) String() string
type GetPollerResponse ¶
type GetPollerResponse struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` Eversion int64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"` UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` ConfigHash string `protobuf:"bytes,4,opt,name=config_hash,json=configHash,proto3" json:"config_hash,omitempty"` Subpollers *poller.SubPollers `protobuf:"bytes,5,opt,name=subpollers,proto3" json:"subpollers,omitempty"` // contains filtered or unexported fields }
func (*GetPollerResponse) Descriptor ¶
func (*GetPollerResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPollerResponse.ProtoReflect.Descriptor instead.
func (*GetPollerResponse) GetConfigHash ¶
func (x *GetPollerResponse) GetConfigHash() string
func (*GetPollerResponse) GetEversion ¶
func (x *GetPollerResponse) GetEversion() int64
func (*GetPollerResponse) GetProject ¶
func (x *GetPollerResponse) GetProject() string
func (*GetPollerResponse) GetSubpollers ¶
func (x *GetPollerResponse) GetSubpollers() *poller.SubPollers
func (*GetPollerResponse) GetUpdateTime ¶
func (x *GetPollerResponse) GetUpdateTime() *timestamppb.Timestamp
func (*GetPollerResponse) ProtoMessage ¶
func (*GetPollerResponse) ProtoMessage()
func (*GetPollerResponse) ProtoReflect ¶
func (x *GetPollerResponse) ProtoReflect() protoreflect.Message
func (*GetPollerResponse) Reset ¶
func (x *GetPollerResponse) Reset()
func (*GetPollerResponse) String ¶
func (x *GetPollerResponse) String() string
type GetProjectRequest ¶
type GetProjectRequest struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
func (*GetProjectRequest) Descriptor ¶
func (*GetProjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProjectRequest.ProtoReflect.Descriptor instead.
func (*GetProjectRequest) GetProject ¶
func (x *GetProjectRequest) GetProject() string
func (*GetProjectRequest) ProtoMessage ¶
func (*GetProjectRequest) ProtoMessage()
func (*GetProjectRequest) ProtoReflect ¶
func (x *GetProjectRequest) ProtoReflect() protoreflect.Message
func (*GetProjectRequest) Reset ¶
func (x *GetProjectRequest) Reset()
func (*GetProjectRequest) String ¶
func (x *GetProjectRequest) String() string
type GetProjectResponse ¶
type GetProjectResponse struct { State *prjpb.PState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` Events []*prjpb.Event `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
GetProjectResponse provides non-atomic snapshot of a LUCI project.
The project state and outstanding events come from different entities, read in parallel.
func (*GetProjectResponse) Descriptor ¶
func (*GetProjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProjectResponse.ProtoReflect.Descriptor instead.
func (*GetProjectResponse) GetEvents ¶
func (x *GetProjectResponse) GetEvents() []*prjpb.Event
func (*GetProjectResponse) GetState ¶
func (x *GetProjectResponse) GetState() *prjpb.PState
func (*GetProjectResponse) ProtoMessage ¶
func (*GetProjectResponse) ProtoMessage()
func (*GetProjectResponse) ProtoReflect ¶
func (x *GetProjectResponse) ProtoReflect() protoreflect.Message
func (*GetProjectResponse) Reset ¶
func (x *GetProjectResponse) Reset()
func (*GetProjectResponse) String ¶
func (x *GetProjectResponse) String() string
type GetRunRequest ¶
type GetRunRequest struct { Run string `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` // contains filtered or unexported fields }
func (*GetRunRequest) Descriptor ¶
func (*GetRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.
func (*GetRunRequest) GetRun ¶
func (x *GetRunRequest) GetRun() string
func (*GetRunRequest) ProtoMessage ¶
func (*GetRunRequest) ProtoMessage()
func (*GetRunRequest) ProtoReflect ¶
func (x *GetRunRequest) ProtoReflect() protoreflect.Message
func (*GetRunRequest) Reset ¶
func (x *GetRunRequest) Reset()
func (*GetRunRequest) String ¶
func (x *GetRunRequest) String() string
type GetRunResponse ¶
type GetRunResponse struct { // State. Next tag: 13. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Eversion int64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"` Mode string `protobuf:"bytes,3,opt,name=mode,proto3" json:"mode,omitempty"` Status run.Status `protobuf:"varint,4,opt,name=status,proto3,enum=cv.run.Status" json:"status,omitempty"` CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` EndTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Owner string `protobuf:"bytes,9,opt,name=owner,proto3" json:"owner,omitempty"` ConfigGroupId string `protobuf:"bytes,10,opt,name=config_group_id,json=configGroupId,proto3" json:"config_group_id,omitempty"` Cls []int64 `protobuf:"varint,11,rep,packed,name=cls,proto3" json:"cls,omitempty"` Submission *run.Submission `protobuf:"bytes,12,opt,name=submission,proto3" json:"submission,omitempty"` // Events. Events []*eventpb.Event `protobuf:"bytes,61,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
GetRunResponse provides non-atomic snapshot of a Run.
The Run state and outstanding events come from different entities read in parallel.
func (*GetRunResponse) Descriptor ¶
func (*GetRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRunResponse.ProtoReflect.Descriptor instead.
func (*GetRunResponse) GetCls ¶
func (x *GetRunResponse) GetCls() []int64
func (*GetRunResponse) GetConfigGroupId ¶
func (x *GetRunResponse) GetConfigGroupId() string
func (*GetRunResponse) GetCreateTime ¶
func (x *GetRunResponse) GetCreateTime() *timestamppb.Timestamp
func (*GetRunResponse) GetEndTime ¶
func (x *GetRunResponse) GetEndTime() *timestamppb.Timestamp
func (*GetRunResponse) GetEvents ¶
func (x *GetRunResponse) GetEvents() []*eventpb.Event
func (*GetRunResponse) GetEversion ¶
func (x *GetRunResponse) GetEversion() int64
func (*GetRunResponse) GetId ¶
func (x *GetRunResponse) GetId() string
func (*GetRunResponse) GetMode ¶
func (x *GetRunResponse) GetMode() string
func (*GetRunResponse) GetOwner ¶
func (x *GetRunResponse) GetOwner() string
func (*GetRunResponse) GetStartTime ¶
func (x *GetRunResponse) GetStartTime() *timestamppb.Timestamp
func (*GetRunResponse) GetStatus ¶
func (x *GetRunResponse) GetStatus() run.Status
func (*GetRunResponse) GetSubmission ¶
func (x *GetRunResponse) GetSubmission() *run.Submission
func (*GetRunResponse) GetUpdateTime ¶
func (x *GetRunResponse) GetUpdateTime() *timestamppb.Timestamp
func (*GetRunResponse) ProtoMessage ¶
func (*GetRunResponse) ProtoMessage()
func (*GetRunResponse) ProtoReflect ¶
func (x *GetRunResponse) ProtoReflect() protoreflect.Message
func (*GetRunResponse) Reset ¶
func (x *GetRunResponse) Reset()
func (*GetRunResponse) String ¶
func (x *GetRunResponse) String() string
type RefreshProjectCLsRequest ¶
type RefreshProjectCLsRequest struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
func (*RefreshProjectCLsRequest) Descriptor ¶
func (*RefreshProjectCLsRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshProjectCLsRequest.ProtoReflect.Descriptor instead.
func (*RefreshProjectCLsRequest) GetProject ¶
func (x *RefreshProjectCLsRequest) GetProject() string
func (*RefreshProjectCLsRequest) ProtoMessage ¶
func (*RefreshProjectCLsRequest) ProtoMessage()
func (*RefreshProjectCLsRequest) ProtoReflect ¶
func (x *RefreshProjectCLsRequest) ProtoReflect() protoreflect.Message
func (*RefreshProjectCLsRequest) Reset ¶
func (x *RefreshProjectCLsRequest) Reset()
func (*RefreshProjectCLsRequest) String ¶
func (x *RefreshProjectCLsRequest) String() string
type RefreshProjectCLsResponse ¶
type RefreshProjectCLsResponse struct { // Map from CL ID to the EVersion in Datastore before the refresh. ClVersions map[int64]int64 `` /* 181-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RefreshProjectCLsResponse) Descriptor ¶
func (*RefreshProjectCLsResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshProjectCLsResponse.ProtoReflect.Descriptor instead.
func (*RefreshProjectCLsResponse) GetClVersions ¶
func (x *RefreshProjectCLsResponse) GetClVersions() map[int64]int64
func (*RefreshProjectCLsResponse) ProtoMessage ¶
func (*RefreshProjectCLsResponse) ProtoMessage()
func (*RefreshProjectCLsResponse) ProtoReflect ¶
func (x *RefreshProjectCLsResponse) ProtoReflect() protoreflect.Message
func (*RefreshProjectCLsResponse) Reset ¶
func (x *RefreshProjectCLsResponse) Reset()
func (*RefreshProjectCLsResponse) String ¶
func (x *RefreshProjectCLsResponse) String() string
type SendProjectEventRequest ¶
type SendProjectEventRequest struct { Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` Event *prjpb.Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*SendProjectEventRequest) Descriptor ¶
func (*SendProjectEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendProjectEventRequest.ProtoReflect.Descriptor instead.
func (*SendProjectEventRequest) GetEvent ¶
func (x *SendProjectEventRequest) GetEvent() *prjpb.Event
func (*SendProjectEventRequest) GetProject ¶
func (x *SendProjectEventRequest) GetProject() string
func (*SendProjectEventRequest) ProtoMessage ¶
func (*SendProjectEventRequest) ProtoMessage()
func (*SendProjectEventRequest) ProtoReflect ¶
func (x *SendProjectEventRequest) ProtoReflect() protoreflect.Message
func (*SendProjectEventRequest) Reset ¶
func (x *SendProjectEventRequest) Reset()
func (*SendProjectEventRequest) String ¶
func (x *SendProjectEventRequest) String() string
type SendRunEventRequest ¶
type SendRunEventRequest struct { Run string `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` Event *eventpb.Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*SendRunEventRequest) Descriptor ¶
func (*SendRunEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendRunEventRequest.ProtoReflect.Descriptor instead.
func (*SendRunEventRequest) GetEvent ¶
func (x *SendRunEventRequest) GetEvent() *eventpb.Event
func (*SendRunEventRequest) GetRun ¶
func (x *SendRunEventRequest) GetRun() string
func (*SendRunEventRequest) ProtoMessage ¶
func (*SendRunEventRequest) ProtoMessage()
func (*SendRunEventRequest) ProtoReflect ¶
func (x *SendRunEventRequest) ProtoReflect() protoreflect.Message
func (*SendRunEventRequest) Reset ¶
func (x *SendRunEventRequest) Reset()
func (*SendRunEventRequest) String ¶
func (x *SendRunEventRequest) String() string
type UnimplementedDiagnosticServer ¶
type UnimplementedDiagnosticServer struct { }
UnimplementedDiagnosticServer must be embedded to have forward compatible implementations.
func (UnimplementedDiagnosticServer) DeleteProjectEvents ¶
func (UnimplementedDiagnosticServer) DeleteProjectEvents(context.Context, *DeleteProjectEventsRequest) (*DeleteProjectEventsResponse, error)
func (UnimplementedDiagnosticServer) GetCL ¶
func (UnimplementedDiagnosticServer) GetCL(context.Context, *GetCLRequest) (*GetCLResponse, error)
func (UnimplementedDiagnosticServer) GetPoller ¶
func (UnimplementedDiagnosticServer) GetPoller(context.Context, *GetPollerRequest) (*GetPollerResponse, error)
func (UnimplementedDiagnosticServer) GetProject ¶
func (UnimplementedDiagnosticServer) GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error)
func (UnimplementedDiagnosticServer) GetRun ¶
func (UnimplementedDiagnosticServer) GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
func (UnimplementedDiagnosticServer) RefreshProjectCLs ¶
func (UnimplementedDiagnosticServer) RefreshProjectCLs(context.Context, *RefreshProjectCLsRequest) (*RefreshProjectCLsResponse, error)
func (UnimplementedDiagnosticServer) SendProjectEvent ¶
func (UnimplementedDiagnosticServer) SendProjectEvent(context.Context, *SendProjectEventRequest) (*empty.Empty, error)
func (UnimplementedDiagnosticServer) SendRunEvent ¶
func (UnimplementedDiagnosticServer) SendRunEvent(context.Context, *SendRunEventRequest) (*empty.Empty, error)
type UnsafeDiagnosticServer ¶
type UnsafeDiagnosticServer interface {
// contains filtered or unexported methods
}
UnsafeDiagnosticServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiagnosticServer will result in compilation errors.