Documentation ¶
Overview ¶
Package runsv2 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterRunServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RunServiceClient) error
- func RegisterRunServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterRunServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RunServiceServer) error
- func RegisterRunServiceServer(s grpc.ServiceRegistrar, srv RunServiceServer)
- type CreateAutomaticRunAssociationForAssetsRequest
- func (m *CreateAutomaticRunAssociationForAssetsRequest) CloneMessageVT() proto.Message
- func (m *CreateAutomaticRunAssociationForAssetsRequest) CloneVT() *CreateAutomaticRunAssociationForAssetsRequest
- func (*CreateAutomaticRunAssociationForAssetsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CreateAutomaticRunAssociationForAssetsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateAutomaticRunAssociationForAssetsRequest) EqualVT(that *CreateAutomaticRunAssociationForAssetsRequest) bool
- func (x *CreateAutomaticRunAssociationForAssetsRequest) GetAssetNames() []string
- func (x *CreateAutomaticRunAssociationForAssetsRequest) GetRunId() string
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalVT() (dAtA []byte, err error)
- func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateAutomaticRunAssociationForAssetsRequest) ProtoMessage()
- func (x *CreateAutomaticRunAssociationForAssetsRequest) ProtoReflect() protoreflect.Message
- func (x *CreateAutomaticRunAssociationForAssetsRequest) Reset()
- func (m *CreateAutomaticRunAssociationForAssetsRequest) SizeVT() (n int)
- func (x *CreateAutomaticRunAssociationForAssetsRequest) String() string
- func (m *CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVT(dAtA []byte) error
- func (m *CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateAutomaticRunAssociationForAssetsResponse
- func (m *CreateAutomaticRunAssociationForAssetsResponse) CloneMessageVT() proto.Message
- func (m *CreateAutomaticRunAssociationForAssetsResponse) CloneVT() *CreateAutomaticRunAssociationForAssetsResponse
- func (*CreateAutomaticRunAssociationForAssetsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *CreateAutomaticRunAssociationForAssetsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateAutomaticRunAssociationForAssetsResponse) EqualVT(that *CreateAutomaticRunAssociationForAssetsResponse) bool
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalVT() (dAtA []byte, err error)
- func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateAutomaticRunAssociationForAssetsResponse) ProtoMessage()
- func (x *CreateAutomaticRunAssociationForAssetsResponse) ProtoReflect() protoreflect.Message
- func (x *CreateAutomaticRunAssociationForAssetsResponse) Reset()
- func (m *CreateAutomaticRunAssociationForAssetsResponse) SizeVT() (n int)
- func (x *CreateAutomaticRunAssociationForAssetsResponse) String() string
- func (m *CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVT(dAtA []byte) error
- func (m *CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateRunRequest
- func (m *CreateRunRequest) CloneMessageVT() proto.Message
- func (m *CreateRunRequest) CloneVT() *CreateRunRequest
- func (*CreateRunRequest) Descriptor() ([]byte, []int)deprecated
- func (this *CreateRunRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateRunRequest) EqualVT(that *CreateRunRequest) bool
- func (x *CreateRunRequest) GetDescription() string
- func (x *CreateRunRequest) GetName() string
- func (x *CreateRunRequest) GetOrganizationId() string
- func (x *CreateRunRequest) GetStartTime() *timestamppb.Timestamp
- func (x *CreateRunRequest) GetStopTime() *timestamppb.Timestamp
- func (x *CreateRunRequest) GetTags() []string
- func (m *CreateRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateRunRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateRunRequest) MarshalVT() (dAtA []byte, err error)
- func (m *CreateRunRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateRunRequest) ProtoMessage()
- func (x *CreateRunRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRunRequest) Reset()
- func (m *CreateRunRequest) SizeVT() (n int)
- func (x *CreateRunRequest) String() string
- func (m *CreateRunRequest) UnmarshalVT(dAtA []byte) error
- func (m *CreateRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type CreateRunResponse
- func (m *CreateRunResponse) CloneMessageVT() proto.Message
- func (m *CreateRunResponse) CloneVT() *CreateRunResponse
- func (*CreateRunResponse) Descriptor() ([]byte, []int)deprecated
- func (this *CreateRunResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *CreateRunResponse) EqualVT(that *CreateRunResponse) bool
- func (x *CreateRunResponse) GetRun() *Run
- func (m *CreateRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CreateRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *CreateRunResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CreateRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *CreateRunResponse) MarshalVT() (dAtA []byte, err error)
- func (m *CreateRunResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*CreateRunResponse) ProtoMessage()
- func (x *CreateRunResponse) ProtoReflect() protoreflect.Message
- func (x *CreateRunResponse) Reset()
- func (m *CreateRunResponse) SizeVT() (n int)
- func (x *CreateRunResponse) String() string
- func (m *CreateRunResponse) UnmarshalVT(dAtA []byte) error
- func (m *CreateRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type DeleteRunRequest
- func (m *DeleteRunRequest) CloneMessageVT() proto.Message
- func (m *DeleteRunRequest) CloneVT() *DeleteRunRequest
- func (*DeleteRunRequest) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteRunRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteRunRequest) EqualVT(that *DeleteRunRequest) bool
- func (x *DeleteRunRequest) GetRunId() string
- func (m *DeleteRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *DeleteRunRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *DeleteRunRequest) MarshalVT() (dAtA []byte, err error)
- func (m *DeleteRunRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*DeleteRunRequest) ProtoMessage()
- func (x *DeleteRunRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRunRequest) Reset()
- func (m *DeleteRunRequest) SizeVT() (n int)
- func (x *DeleteRunRequest) String() string
- func (m *DeleteRunRequest) UnmarshalVT(dAtA []byte) error
- func (m *DeleteRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type DeleteRunResponse
- func (m *DeleteRunResponse) CloneMessageVT() proto.Message
- func (m *DeleteRunResponse) CloneVT() *DeleteRunResponse
- func (*DeleteRunResponse) Descriptor() ([]byte, []int)deprecated
- func (this *DeleteRunResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *DeleteRunResponse) EqualVT(that *DeleteRunResponse) bool
- func (m *DeleteRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *DeleteRunResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *DeleteRunResponse) MarshalVT() (dAtA []byte, err error)
- func (m *DeleteRunResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*DeleteRunResponse) ProtoMessage()
- func (x *DeleteRunResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteRunResponse) Reset()
- func (m *DeleteRunResponse) SizeVT() (n int)
- func (x *DeleteRunResponse) String() string
- func (m *DeleteRunResponse) UnmarshalVT(dAtA []byte) error
- func (m *DeleteRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type GetRunRequest
- func (m *GetRunRequest) CloneMessageVT() proto.Message
- func (m *GetRunRequest) CloneVT() *GetRunRequest
- func (*GetRunRequest) Descriptor() ([]byte, []int)deprecated
- func (this *GetRunRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetRunRequest) EqualVT(that *GetRunRequest) bool
- func (x *GetRunRequest) GetRunId() string
- func (m *GetRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *GetRunRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *GetRunRequest) MarshalVT() (dAtA []byte, err error)
- func (m *GetRunRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*GetRunRequest) ProtoMessage()
- func (x *GetRunRequest) ProtoReflect() protoreflect.Message
- func (x *GetRunRequest) Reset()
- func (m *GetRunRequest) SizeVT() (n int)
- func (x *GetRunRequest) String() string
- func (m *GetRunRequest) UnmarshalVT(dAtA []byte) error
- func (m *GetRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type GetRunResponse
- func (m *GetRunResponse) CloneMessageVT() proto.Message
- func (m *GetRunResponse) CloneVT() *GetRunResponse
- func (*GetRunResponse) Descriptor() ([]byte, []int)deprecated
- func (this *GetRunResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *GetRunResponse) EqualVT(that *GetRunResponse) bool
- func (x *GetRunResponse) GetRun() *Run
- func (m *GetRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *GetRunResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *GetRunResponse) MarshalVT() (dAtA []byte, err error)
- func (m *GetRunResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*GetRunResponse) ProtoMessage()
- func (x *GetRunResponse) ProtoReflect() protoreflect.Message
- func (x *GetRunResponse) Reset()
- func (m *GetRunResponse) SizeVT() (n int)
- func (x *GetRunResponse) String() string
- func (m *GetRunResponse) UnmarshalVT(dAtA []byte) error
- func (m *GetRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type ListRunsRequest
- func (m *ListRunsRequest) CloneMessageVT() proto.Message
- func (m *ListRunsRequest) CloneVT() *ListRunsRequest
- func (*ListRunsRequest) Descriptor() ([]byte, []int)deprecated
- func (this *ListRunsRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListRunsRequest) EqualVT(that *ListRunsRequest) bool
- func (x *ListRunsRequest) GetFilter() string
- func (x *ListRunsRequest) GetPageSize() uint32
- func (x *ListRunsRequest) GetPageToken() string
- func (m *ListRunsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListRunsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListRunsRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListRunsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListRunsRequest) MarshalVT() (dAtA []byte, err error)
- func (m *ListRunsRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListRunsRequest) ProtoMessage()
- func (x *ListRunsRequest) ProtoReflect() protoreflect.Message
- func (x *ListRunsRequest) Reset()
- func (m *ListRunsRequest) SizeVT() (n int)
- func (x *ListRunsRequest) String() string
- func (m *ListRunsRequest) UnmarshalVT(dAtA []byte) error
- func (m *ListRunsRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type ListRunsResponse
- func (m *ListRunsResponse) CloneMessageVT() proto.Message
- func (m *ListRunsResponse) CloneVT() *ListRunsResponse
- func (*ListRunsResponse) Descriptor() ([]byte, []int)deprecated
- func (this *ListRunsResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *ListRunsResponse) EqualVT(that *ListRunsResponse) bool
- func (x *ListRunsResponse) GetNextPageToken() string
- func (x *ListRunsResponse) GetRuns() []*Run
- func (m *ListRunsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ListRunsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *ListRunsResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ListRunsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *ListRunsResponse) MarshalVT() (dAtA []byte, err error)
- func (m *ListRunsResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*ListRunsResponse) ProtoMessage()
- func (x *ListRunsResponse) ProtoReflect() protoreflect.Message
- func (x *ListRunsResponse) Reset()
- func (m *ListRunsResponse) SizeVT() (n int)
- func (x *ListRunsResponse) String() string
- func (m *ListRunsResponse) UnmarshalVT(dAtA []byte) error
- func (m *ListRunsResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type Run
- func (m *Run) CloneMessageVT() proto.Message
- func (m *Run) CloneVT() *Run
- func (*Run) Descriptor() ([]byte, []int)deprecated
- func (this *Run) EqualMessageVT(thatMsg proto.Message) bool
- func (this *Run) EqualVT(that *Run) bool
- func (x *Run) GetCreatedByUserId() string
- func (x *Run) GetCreatedDate() *timestamppb.Timestamp
- func (x *Run) GetDescription() string
- func (x *Run) GetIsPinned() bool
- func (x *Run) GetModifiedByUserId() string
- func (x *Run) GetModifiedDate() *timestamppb.Timestamp
- func (x *Run) GetName() string
- func (x *Run) GetOrganizationId() string
- func (x *Run) GetRunId() string
- func (x *Run) GetStartTime() *timestamppb.Timestamp
- func (x *Run) GetStopTime() *timestamppb.Timestamp
- func (x *Run) GetTags() []string
- func (m *Run) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Run) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *Run) MarshalToVT(dAtA []byte) (int, error)
- func (m *Run) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *Run) MarshalVT() (dAtA []byte, err error)
- func (m *Run) MarshalVTStrict() (dAtA []byte, err error)
- func (*Run) ProtoMessage()
- func (x *Run) ProtoReflect() protoreflect.Message
- func (x *Run) Reset()
- func (m *Run) SizeVT() (n int)
- func (x *Run) String() string
- func (m *Run) UnmarshalVT(dAtA []byte) error
- func (m *Run) UnmarshalVTUnsafe(dAtA []byte) error
- type RunServiceClient
- type RunServiceServer
- type StopRunRequest
- func (m *StopRunRequest) CloneMessageVT() proto.Message
- func (m *StopRunRequest) CloneVT() *StopRunRequest
- func (*StopRunRequest) Descriptor() ([]byte, []int)deprecated
- func (this *StopRunRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *StopRunRequest) EqualVT(that *StopRunRequest) bool
- func (x *StopRunRequest) GetRunId() string
- func (m *StopRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StopRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *StopRunRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *StopRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *StopRunRequest) MarshalVT() (dAtA []byte, err error)
- func (m *StopRunRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*StopRunRequest) ProtoMessage()
- func (x *StopRunRequest) ProtoReflect() protoreflect.Message
- func (x *StopRunRequest) Reset()
- func (m *StopRunRequest) SizeVT() (n int)
- func (x *StopRunRequest) String() string
- func (m *StopRunRequest) UnmarshalVT(dAtA []byte) error
- func (m *StopRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type StopRunResponse
- func (m *StopRunResponse) CloneMessageVT() proto.Message
- func (m *StopRunResponse) CloneVT() *StopRunResponse
- func (*StopRunResponse) Descriptor() ([]byte, []int)deprecated
- func (this *StopRunResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *StopRunResponse) EqualVT(that *StopRunResponse) bool
- func (m *StopRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StopRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *StopRunResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *StopRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *StopRunResponse) MarshalVT() (dAtA []byte, err error)
- func (m *StopRunResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*StopRunResponse) ProtoMessage()
- func (x *StopRunResponse) ProtoReflect() protoreflect.Message
- func (x *StopRunResponse) Reset()
- func (m *StopRunResponse) SizeVT() (n int)
- func (x *StopRunResponse) String() string
- func (m *StopRunResponse) UnmarshalVT(dAtA []byte) error
- func (m *StopRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
- type UnimplementedRunServiceServer
- func (UnimplementedRunServiceServer) CreateAutomaticRunAssociationForAssets(context.Context, *CreateAutomaticRunAssociationForAssetsRequest) (*CreateAutomaticRunAssociationForAssetsResponse, error)
- func (UnimplementedRunServiceServer) CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error)
- func (UnimplementedRunServiceServer) DeleteRun(context.Context, *DeleteRunRequest) (*DeleteRunResponse, error)
- func (UnimplementedRunServiceServer) GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
- func (UnimplementedRunServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
- func (UnimplementedRunServiceServer) StopRun(context.Context, *StopRunRequest) (*StopRunResponse, error)
- func (UnimplementedRunServiceServer) UpdateRun(context.Context, *UpdateRunRequest) (*UpdateRunResponse, error)
- type UnsafeRunServiceServer
- type UpdateRunRequest
- func (m *UpdateRunRequest) CloneMessageVT() proto.Message
- func (m *UpdateRunRequest) CloneVT() *UpdateRunRequest
- func (*UpdateRunRequest) Descriptor() ([]byte, []int)deprecated
- func (this *UpdateRunRequest) EqualMessageVT(thatMsg proto.Message) bool
- func (this *UpdateRunRequest) EqualVT(that *UpdateRunRequest) bool
- func (x *UpdateRunRequest) GetRun() *Run
- func (x *UpdateRunRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (m *UpdateRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *UpdateRunRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *UpdateRunRequest) MarshalVT() (dAtA []byte, err error)
- func (m *UpdateRunRequest) MarshalVTStrict() (dAtA []byte, err error)
- func (*UpdateRunRequest) ProtoMessage()
- func (x *UpdateRunRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRunRequest) Reset()
- func (m *UpdateRunRequest) SizeVT() (n int)
- func (x *UpdateRunRequest) String() string
- func (m *UpdateRunRequest) UnmarshalVT(dAtA []byte) error
- func (m *UpdateRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
- type UpdateRunResponse
- func (m *UpdateRunResponse) CloneMessageVT() proto.Message
- func (m *UpdateRunResponse) CloneVT() *UpdateRunResponse
- func (*UpdateRunResponse) Descriptor() ([]byte, []int)deprecated
- func (this *UpdateRunResponse) EqualMessageVT(thatMsg proto.Message) bool
- func (this *UpdateRunResponse) EqualVT(that *UpdateRunResponse) bool
- func (x *UpdateRunResponse) GetRun() *Run
- func (m *UpdateRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *UpdateRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
- func (m *UpdateRunResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *UpdateRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
- func (m *UpdateRunResponse) MarshalVT() (dAtA []byte, err error)
- func (m *UpdateRunResponse) MarshalVTStrict() (dAtA []byte, err error)
- func (*UpdateRunResponse) ProtoMessage()
- func (x *UpdateRunResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateRunResponse) Reset()
- func (m *UpdateRunResponse) SizeVT() (n int)
- func (x *UpdateRunResponse) String() string
- func (m *UpdateRunResponse) UnmarshalVT(dAtA []byte) error
- func (m *UpdateRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var File_sift_runs_v2_runs_proto protoreflect.FileDescriptor
var RunService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sift.runs.v2.RunService", HandlerType: (*RunServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetRun", Handler: _RunService_GetRun_Handler, }, { MethodName: "ListRuns", Handler: _RunService_ListRuns_Handler, }, { MethodName: "CreateRun", Handler: _RunService_CreateRun_Handler, }, { MethodName: "UpdateRun", Handler: _RunService_UpdateRun_Handler, }, { MethodName: "DeleteRun", Handler: _RunService_DeleteRun_Handler, }, { MethodName: "StopRun", Handler: _RunService_StopRun_Handler, }, { MethodName: "CreateAutomaticRunAssociationForAssets", Handler: _RunService_CreateAutomaticRunAssociationForAssets_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "sift/runs/v2/runs.proto", }
RunService_ServiceDesc is the grpc.ServiceDesc for RunService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRunServiceHandler ¶
func RegisterRunServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterRunServiceHandler registers the http handlers for service RunService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterRunServiceHandlerClient ¶
func RegisterRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RunServiceClient) error
RegisterRunServiceHandlerClient registers the http handlers for service RunService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RunServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RunServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RunServiceClient" to call the correct interceptors.
func RegisterRunServiceHandlerFromEndpoint ¶
func RegisterRunServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterRunServiceHandlerFromEndpoint is same as RegisterRunServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterRunServiceHandlerServer ¶
func RegisterRunServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RunServiceServer) error
RegisterRunServiceHandlerServer registers the http handlers for service RunService to "mux". UnaryRPC :call RunServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRunServiceHandlerFromEndpoint instead.
func RegisterRunServiceServer ¶
func RegisterRunServiceServer(s grpc.ServiceRegistrar, srv RunServiceServer)
Types ¶
type CreateAutomaticRunAssociationForAssetsRequest ¶
type CreateAutomaticRunAssociationForAssetsRequest struct { // The ID of the run to associate the asset with. RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // A list of asset names to automatically associate with the run. // Any data that is received for these assets will automatically added to the run. // This applies even if the run has concluded, so long as the new data contains // timestamps that are between the `start_time` and `stop_time`. // If any of the assets are already associated with a different run whose run // period (the period between `start_time` and `end_time`) overlaps with the // requested run period, an error will be returned. AssetNames []string `protobuf:"bytes,2,rep,name=asset_names,json=assetNames,proto3" json:"asset_names,omitempty"` // contains filtered or unexported fields }
func (*CreateAutomaticRunAssociationForAssetsRequest) CloneMessageVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) CloneMessageVT() proto.Message
func (*CreateAutomaticRunAssociationForAssetsRequest) Descriptor
deprecated
func (*CreateAutomaticRunAssociationForAssetsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateAutomaticRunAssociationForAssetsRequest.ProtoReflect.Descriptor instead.
func (*CreateAutomaticRunAssociationForAssetsRequest) EqualMessageVT ¶
func (this *CreateAutomaticRunAssociationForAssetsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateAutomaticRunAssociationForAssetsRequest) EqualVT ¶
func (this *CreateAutomaticRunAssociationForAssetsRequest) EqualVT(that *CreateAutomaticRunAssociationForAssetsRequest) bool
func (*CreateAutomaticRunAssociationForAssetsRequest) GetAssetNames ¶
func (x *CreateAutomaticRunAssociationForAssetsRequest) GetAssetNames() []string
func (*CreateAutomaticRunAssociationForAssetsRequest) GetRunId ¶
func (x *CreateAutomaticRunAssociationForAssetsRequest) GetRunId() string
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalToVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalToVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateAutomaticRunAssociationForAssetsRequest) MarshalVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateAutomaticRunAssociationForAssetsRequest) ProtoMessage ¶
func (*CreateAutomaticRunAssociationForAssetsRequest) ProtoMessage()
func (*CreateAutomaticRunAssociationForAssetsRequest) ProtoReflect ¶
func (x *CreateAutomaticRunAssociationForAssetsRequest) ProtoReflect() protoreflect.Message
func (*CreateAutomaticRunAssociationForAssetsRequest) Reset ¶
func (x *CreateAutomaticRunAssociationForAssetsRequest) Reset()
func (*CreateAutomaticRunAssociationForAssetsRequest) SizeVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) SizeVT() (n int)
func (*CreateAutomaticRunAssociationForAssetsRequest) String ¶
func (x *CreateAutomaticRunAssociationForAssetsRequest) String() string
func (*CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVT ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVT(dAtA []byte) error
func (*CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVTUnsafe ¶
func (m *CreateAutomaticRunAssociationForAssetsRequest) UnmarshalVTUnsafe(dAtA []byte) error
type CreateAutomaticRunAssociationForAssetsResponse ¶
type CreateAutomaticRunAssociationForAssetsResponse struct {
// contains filtered or unexported fields
}
func (*CreateAutomaticRunAssociationForAssetsResponse) CloneMessageVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) CloneMessageVT() proto.Message
func (*CreateAutomaticRunAssociationForAssetsResponse) Descriptor
deprecated
func (*CreateAutomaticRunAssociationForAssetsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateAutomaticRunAssociationForAssetsResponse.ProtoReflect.Descriptor instead.
func (*CreateAutomaticRunAssociationForAssetsResponse) EqualMessageVT ¶
func (this *CreateAutomaticRunAssociationForAssetsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateAutomaticRunAssociationForAssetsResponse) EqualVT ¶
func (this *CreateAutomaticRunAssociationForAssetsResponse) EqualVT(that *CreateAutomaticRunAssociationForAssetsResponse) bool
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalToVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalToVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateAutomaticRunAssociationForAssetsResponse) MarshalVTStrict ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateAutomaticRunAssociationForAssetsResponse) ProtoMessage ¶
func (*CreateAutomaticRunAssociationForAssetsResponse) ProtoMessage()
func (*CreateAutomaticRunAssociationForAssetsResponse) ProtoReflect ¶
func (x *CreateAutomaticRunAssociationForAssetsResponse) ProtoReflect() protoreflect.Message
func (*CreateAutomaticRunAssociationForAssetsResponse) Reset ¶
func (x *CreateAutomaticRunAssociationForAssetsResponse) Reset()
func (*CreateAutomaticRunAssociationForAssetsResponse) SizeVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) SizeVT() (n int)
func (*CreateAutomaticRunAssociationForAssetsResponse) String ¶
func (x *CreateAutomaticRunAssociationForAssetsResponse) String() string
func (*CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVT ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVT(dAtA []byte) error
func (*CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVTUnsafe ¶
func (m *CreateAutomaticRunAssociationForAssetsResponse) UnmarshalVTUnsafe(dAtA []byte) error
type CreateRunRequest ¶
type CreateRunRequest struct { // The name that will be assigned to the new run. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // A description about the new run. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // Tags to associate with the new run. Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // The time at which data ingestion begins for this new run. It must be before the `stop_time`, and it must // be provided if a `stop_time` is provided. // Important note: `start_time` will be automatically computed during data ingestion and will be set // based on the timestamp of the data for this run. StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // The time at which data ingestion for this new run concludes. // Important note: `stop_time` will be automatically computed during data ingestion and will be // set based on the timestamp of the data for this run. StopTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=stop_time,json=stopTime,proto3" json:"stop_time,omitempty"` // An organization ID is only required if the user belongs to multiple organizations. OrganizationId string `protobuf:"bytes,7,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"` // contains filtered or unexported fields }
The request of a call to `RunService_CreateRuns` to create a new run.
func (*CreateRunRequest) CloneMessageVT ¶
func (m *CreateRunRequest) CloneMessageVT() proto.Message
func (*CreateRunRequest) CloneVT ¶
func (m *CreateRunRequest) CloneVT() *CreateRunRequest
func (*CreateRunRequest) Descriptor
deprecated
func (*CreateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRunRequest.ProtoReflect.Descriptor instead.
func (*CreateRunRequest) EqualMessageVT ¶
func (this *CreateRunRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateRunRequest) EqualVT ¶
func (this *CreateRunRequest) EqualVT(that *CreateRunRequest) bool
func (*CreateRunRequest) GetDescription ¶
func (x *CreateRunRequest) GetDescription() string
func (*CreateRunRequest) GetName ¶
func (x *CreateRunRequest) GetName() string
func (*CreateRunRequest) GetOrganizationId ¶
func (x *CreateRunRequest) GetOrganizationId() string
func (*CreateRunRequest) GetStartTime ¶
func (x *CreateRunRequest) GetStartTime() *timestamppb.Timestamp
func (*CreateRunRequest) GetStopTime ¶
func (x *CreateRunRequest) GetStopTime() *timestamppb.Timestamp
func (*CreateRunRequest) GetTags ¶
func (x *CreateRunRequest) GetTags() []string
func (*CreateRunRequest) MarshalToSizedBufferVT ¶
func (m *CreateRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateRunRequest) MarshalToSizedBufferVTStrict ¶
func (m *CreateRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateRunRequest) MarshalToVT ¶
func (m *CreateRunRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CreateRunRequest) MarshalToVTStrict ¶
func (m *CreateRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateRunRequest) MarshalVT ¶
func (m *CreateRunRequest) MarshalVT() (dAtA []byte, err error)
func (*CreateRunRequest) MarshalVTStrict ¶
func (m *CreateRunRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateRunRequest) ProtoMessage ¶
func (*CreateRunRequest) ProtoMessage()
func (*CreateRunRequest) ProtoReflect ¶
func (x *CreateRunRequest) ProtoReflect() protoreflect.Message
func (*CreateRunRequest) Reset ¶
func (x *CreateRunRequest) Reset()
func (*CreateRunRequest) SizeVT ¶
func (m *CreateRunRequest) SizeVT() (n int)
func (*CreateRunRequest) String ¶
func (x *CreateRunRequest) String() string
func (*CreateRunRequest) UnmarshalVT ¶
func (m *CreateRunRequest) UnmarshalVT(dAtA []byte) error
func (*CreateRunRequest) UnmarshalVTUnsafe ¶
func (m *CreateRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
type CreateRunResponse ¶
type CreateRunResponse struct { Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` // contains filtered or unexported fields }
The response of a call to `RunService_CreateRuns` containing the newly created run.
func (*CreateRunResponse) CloneMessageVT ¶
func (m *CreateRunResponse) CloneMessageVT() proto.Message
func (*CreateRunResponse) CloneVT ¶
func (m *CreateRunResponse) CloneVT() *CreateRunResponse
func (*CreateRunResponse) Descriptor
deprecated
func (*CreateRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateRunResponse.ProtoReflect.Descriptor instead.
func (*CreateRunResponse) EqualMessageVT ¶
func (this *CreateRunResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*CreateRunResponse) EqualVT ¶
func (this *CreateRunResponse) EqualVT(that *CreateRunResponse) bool
func (*CreateRunResponse) GetRun ¶
func (x *CreateRunResponse) GetRun() *Run
func (*CreateRunResponse) MarshalToSizedBufferVT ¶
func (m *CreateRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CreateRunResponse) MarshalToSizedBufferVTStrict ¶
func (m *CreateRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*CreateRunResponse) MarshalToVT ¶
func (m *CreateRunResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CreateRunResponse) MarshalToVTStrict ¶
func (m *CreateRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*CreateRunResponse) MarshalVT ¶
func (m *CreateRunResponse) MarshalVT() (dAtA []byte, err error)
func (*CreateRunResponse) MarshalVTStrict ¶
func (m *CreateRunResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*CreateRunResponse) ProtoMessage ¶
func (*CreateRunResponse) ProtoMessage()
func (*CreateRunResponse) ProtoReflect ¶
func (x *CreateRunResponse) ProtoReflect() protoreflect.Message
func (*CreateRunResponse) Reset ¶
func (x *CreateRunResponse) Reset()
func (*CreateRunResponse) SizeVT ¶
func (m *CreateRunResponse) SizeVT() (n int)
func (*CreateRunResponse) String ¶
func (x *CreateRunResponse) String() string
func (*CreateRunResponse) UnmarshalVT ¶
func (m *CreateRunResponse) UnmarshalVT(dAtA []byte) error
func (*CreateRunResponse) UnmarshalVTUnsafe ¶
func (m *CreateRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
type DeleteRunRequest ¶
type DeleteRunRequest struct { RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // contains filtered or unexported fields }
The request for a call to `RunService_DeleteRun`.
func (*DeleteRunRequest) CloneMessageVT ¶
func (m *DeleteRunRequest) CloneMessageVT() proto.Message
func (*DeleteRunRequest) CloneVT ¶
func (m *DeleteRunRequest) CloneVT() *DeleteRunRequest
func (*DeleteRunRequest) Descriptor
deprecated
func (*DeleteRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRunRequest.ProtoReflect.Descriptor instead.
func (*DeleteRunRequest) EqualMessageVT ¶
func (this *DeleteRunRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*DeleteRunRequest) EqualVT ¶
func (this *DeleteRunRequest) EqualVT(that *DeleteRunRequest) bool
func (*DeleteRunRequest) GetRunId ¶
func (x *DeleteRunRequest) GetRunId() string
func (*DeleteRunRequest) MarshalToSizedBufferVT ¶
func (m *DeleteRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*DeleteRunRequest) MarshalToSizedBufferVTStrict ¶
func (m *DeleteRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*DeleteRunRequest) MarshalToVT ¶
func (m *DeleteRunRequest) MarshalToVT(dAtA []byte) (int, error)
func (*DeleteRunRequest) MarshalToVTStrict ¶
func (m *DeleteRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*DeleteRunRequest) MarshalVT ¶
func (m *DeleteRunRequest) MarshalVT() (dAtA []byte, err error)
func (*DeleteRunRequest) MarshalVTStrict ¶
func (m *DeleteRunRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*DeleteRunRequest) ProtoMessage ¶
func (*DeleteRunRequest) ProtoMessage()
func (*DeleteRunRequest) ProtoReflect ¶
func (x *DeleteRunRequest) ProtoReflect() protoreflect.Message
func (*DeleteRunRequest) Reset ¶
func (x *DeleteRunRequest) Reset()
func (*DeleteRunRequest) SizeVT ¶
func (m *DeleteRunRequest) SizeVT() (n int)
func (*DeleteRunRequest) String ¶
func (x *DeleteRunRequest) String() string
func (*DeleteRunRequest) UnmarshalVT ¶
func (m *DeleteRunRequest) UnmarshalVT(dAtA []byte) error
func (*DeleteRunRequest) UnmarshalVTUnsafe ¶
func (m *DeleteRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
type DeleteRunResponse ¶
type DeleteRunResponse struct {
// contains filtered or unexported fields
}
The response of a call to `RunService_DeleteRun`.
func (*DeleteRunResponse) CloneMessageVT ¶
func (m *DeleteRunResponse) CloneMessageVT() proto.Message
func (*DeleteRunResponse) CloneVT ¶
func (m *DeleteRunResponse) CloneVT() *DeleteRunResponse
func (*DeleteRunResponse) Descriptor
deprecated
func (*DeleteRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRunResponse.ProtoReflect.Descriptor instead.
func (*DeleteRunResponse) EqualMessageVT ¶
func (this *DeleteRunResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*DeleteRunResponse) EqualVT ¶
func (this *DeleteRunResponse) EqualVT(that *DeleteRunResponse) bool
func (*DeleteRunResponse) MarshalToSizedBufferVT ¶
func (m *DeleteRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*DeleteRunResponse) MarshalToSizedBufferVTStrict ¶
func (m *DeleteRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*DeleteRunResponse) MarshalToVT ¶
func (m *DeleteRunResponse) MarshalToVT(dAtA []byte) (int, error)
func (*DeleteRunResponse) MarshalToVTStrict ¶
func (m *DeleteRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*DeleteRunResponse) MarshalVT ¶
func (m *DeleteRunResponse) MarshalVT() (dAtA []byte, err error)
func (*DeleteRunResponse) MarshalVTStrict ¶
func (m *DeleteRunResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*DeleteRunResponse) ProtoMessage ¶
func (*DeleteRunResponse) ProtoMessage()
func (*DeleteRunResponse) ProtoReflect ¶
func (x *DeleteRunResponse) ProtoReflect() protoreflect.Message
func (*DeleteRunResponse) Reset ¶
func (x *DeleteRunResponse) Reset()
func (*DeleteRunResponse) SizeVT ¶
func (m *DeleteRunResponse) SizeVT() (n int)
func (*DeleteRunResponse) String ¶
func (x *DeleteRunResponse) String() string
func (*DeleteRunResponse) UnmarshalVT ¶
func (m *DeleteRunResponse) UnmarshalVT(dAtA []byte) error
func (*DeleteRunResponse) UnmarshalVTUnsafe ¶
func (m *DeleteRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
type GetRunRequest ¶
type GetRunRequest struct { // The ID of the run to retrieve. RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // contains filtered or unexported fields }
The request for a call to `RunService_GetRun` to retrieve run.
func (*GetRunRequest) CloneMessageVT ¶
func (m *GetRunRequest) CloneMessageVT() proto.Message
func (*GetRunRequest) CloneVT ¶
func (m *GetRunRequest) CloneVT() *GetRunRequest
func (*GetRunRequest) Descriptor
deprecated
func (*GetRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.
func (*GetRunRequest) EqualMessageVT ¶
func (this *GetRunRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*GetRunRequest) EqualVT ¶
func (this *GetRunRequest) EqualVT(that *GetRunRequest) bool
func (*GetRunRequest) GetRunId ¶
func (x *GetRunRequest) GetRunId() string
func (*GetRunRequest) MarshalToSizedBufferVT ¶
func (m *GetRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetRunRequest) MarshalToSizedBufferVTStrict ¶
func (m *GetRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*GetRunRequest) MarshalToVT ¶
func (m *GetRunRequest) MarshalToVT(dAtA []byte) (int, error)
func (*GetRunRequest) MarshalToVTStrict ¶
func (m *GetRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*GetRunRequest) MarshalVT ¶
func (m *GetRunRequest) MarshalVT() (dAtA []byte, err error)
func (*GetRunRequest) MarshalVTStrict ¶
func (m *GetRunRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*GetRunRequest) ProtoMessage ¶
func (*GetRunRequest) ProtoMessage()
func (*GetRunRequest) ProtoReflect ¶
func (x *GetRunRequest) ProtoReflect() protoreflect.Message
func (*GetRunRequest) Reset ¶
func (x *GetRunRequest) Reset()
func (*GetRunRequest) SizeVT ¶
func (m *GetRunRequest) SizeVT() (n int)
func (*GetRunRequest) String ¶
func (x *GetRunRequest) String() string
func (*GetRunRequest) UnmarshalVT ¶
func (m *GetRunRequest) UnmarshalVT(dAtA []byte) error
func (*GetRunRequest) UnmarshalVTUnsafe ¶
func (m *GetRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
type GetRunResponse ¶
type GetRunResponse struct { Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` // contains filtered or unexported fields }
The response of a call to `RunService_GetRun` containing the requested run.
func (*GetRunResponse) CloneMessageVT ¶
func (m *GetRunResponse) CloneMessageVT() proto.Message
func (*GetRunResponse) CloneVT ¶
func (m *GetRunResponse) CloneVT() *GetRunResponse
func (*GetRunResponse) Descriptor
deprecated
func (*GetRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetRunResponse.ProtoReflect.Descriptor instead.
func (*GetRunResponse) EqualMessageVT ¶
func (this *GetRunResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*GetRunResponse) EqualVT ¶
func (this *GetRunResponse) EqualVT(that *GetRunResponse) bool
func (*GetRunResponse) GetRun ¶
func (x *GetRunResponse) GetRun() *Run
func (*GetRunResponse) MarshalToSizedBufferVT ¶
func (m *GetRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetRunResponse) MarshalToSizedBufferVTStrict ¶
func (m *GetRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*GetRunResponse) MarshalToVT ¶
func (m *GetRunResponse) MarshalToVT(dAtA []byte) (int, error)
func (*GetRunResponse) MarshalToVTStrict ¶
func (m *GetRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*GetRunResponse) MarshalVT ¶
func (m *GetRunResponse) MarshalVT() (dAtA []byte, err error)
func (*GetRunResponse) MarshalVTStrict ¶
func (m *GetRunResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*GetRunResponse) ProtoMessage ¶
func (*GetRunResponse) ProtoMessage()
func (*GetRunResponse) ProtoReflect ¶
func (x *GetRunResponse) ProtoReflect() protoreflect.Message
func (*GetRunResponse) Reset ¶
func (x *GetRunResponse) Reset()
func (*GetRunResponse) SizeVT ¶
func (m *GetRunResponse) SizeVT() (n int)
func (*GetRunResponse) String ¶
func (x *GetRunResponse) String() string
func (*GetRunResponse) UnmarshalVT ¶
func (m *GetRunResponse) UnmarshalVT(dAtA []byte) error
func (*GetRunResponse) UnmarshalVTUnsafe ¶
func (m *GetRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
type ListRunsRequest ¶
type ListRunsRequest struct { // The maximum number of runs to return. // The service may return fewer than this value. // If unspecified, at most 50 runs will be returned. // The maximum value is 1000; values above 1000 will be coerced to 1000. PageSize uint32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // A page token, received from a previous `ListRuns` call. // Provide this to retrieve the subsequent page. // When paginating, all other parameters provided to `ListRuns` must match // the call that provided the page token. PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // A [Common Expression Language (CEL)](https://github.com/google/cel-spec) filter string. // Available fields to filter by are `run_id`, `organization_id`, `name`, `description`, `created_by_user_id`, `modified_by_user_id`, // `created_date`, `modified_date`, `start_time`, `stop_time`, `client_key`, and `is_pinned`. // For further information about how to use CELs, please refer to [this guide](https://github.com/google/cel-spec/blob/master/doc/langdef.md#standard-definitions). // For more information about the fields used for filtering, please refer to [this definition](/protocol-buffers/documentation#run). Optional. Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
The request for a call to `RunService_ListRuns` to retrieve runs.
func (*ListRunsRequest) CloneMessageVT ¶
func (m *ListRunsRequest) CloneMessageVT() proto.Message
func (*ListRunsRequest) CloneVT ¶
func (m *ListRunsRequest) CloneVT() *ListRunsRequest
func (*ListRunsRequest) Descriptor
deprecated
func (*ListRunsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.
func (*ListRunsRequest) EqualMessageVT ¶
func (this *ListRunsRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*ListRunsRequest) EqualVT ¶
func (this *ListRunsRequest) EqualVT(that *ListRunsRequest) bool
func (*ListRunsRequest) GetFilter ¶
func (x *ListRunsRequest) GetFilter() string
func (*ListRunsRequest) GetPageSize ¶
func (x *ListRunsRequest) GetPageSize() uint32
func (*ListRunsRequest) GetPageToken ¶
func (x *ListRunsRequest) GetPageToken() string
func (*ListRunsRequest) MarshalToSizedBufferVT ¶
func (m *ListRunsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListRunsRequest) MarshalToSizedBufferVTStrict ¶
func (m *ListRunsRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListRunsRequest) MarshalToVT ¶
func (m *ListRunsRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ListRunsRequest) MarshalToVTStrict ¶
func (m *ListRunsRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListRunsRequest) MarshalVT ¶
func (m *ListRunsRequest) MarshalVT() (dAtA []byte, err error)
func (*ListRunsRequest) MarshalVTStrict ¶
func (m *ListRunsRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*ListRunsRequest) ProtoMessage ¶
func (*ListRunsRequest) ProtoMessage()
func (*ListRunsRequest) ProtoReflect ¶
func (x *ListRunsRequest) ProtoReflect() protoreflect.Message
func (*ListRunsRequest) Reset ¶
func (x *ListRunsRequest) Reset()
func (*ListRunsRequest) SizeVT ¶
func (m *ListRunsRequest) SizeVT() (n int)
func (*ListRunsRequest) String ¶
func (x *ListRunsRequest) String() string
func (*ListRunsRequest) UnmarshalVT ¶
func (m *ListRunsRequest) UnmarshalVT(dAtA []byte) error
func (*ListRunsRequest) UnmarshalVTUnsafe ¶
func (m *ListRunsRequest) UnmarshalVTUnsafe(dAtA []byte) error
type ListRunsResponse ¶
type ListRunsResponse struct { Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"` NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
The response of a call to `RunService_ListRuns` containing requested runs.
func (*ListRunsResponse) CloneMessageVT ¶
func (m *ListRunsResponse) CloneMessageVT() proto.Message
func (*ListRunsResponse) CloneVT ¶
func (m *ListRunsResponse) CloneVT() *ListRunsResponse
func (*ListRunsResponse) Descriptor
deprecated
func (*ListRunsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.
func (*ListRunsResponse) EqualMessageVT ¶
func (this *ListRunsResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*ListRunsResponse) EqualVT ¶
func (this *ListRunsResponse) EqualVT(that *ListRunsResponse) bool
func (*ListRunsResponse) GetNextPageToken ¶
func (x *ListRunsResponse) GetNextPageToken() string
func (*ListRunsResponse) GetRuns ¶
func (x *ListRunsResponse) GetRuns() []*Run
func (*ListRunsResponse) MarshalToSizedBufferVT ¶
func (m *ListRunsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ListRunsResponse) MarshalToSizedBufferVTStrict ¶
func (m *ListRunsResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*ListRunsResponse) MarshalToVT ¶
func (m *ListRunsResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ListRunsResponse) MarshalToVTStrict ¶
func (m *ListRunsResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*ListRunsResponse) MarshalVT ¶
func (m *ListRunsResponse) MarshalVT() (dAtA []byte, err error)
func (*ListRunsResponse) MarshalVTStrict ¶
func (m *ListRunsResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*ListRunsResponse) ProtoMessage ¶
func (*ListRunsResponse) ProtoMessage()
func (*ListRunsResponse) ProtoReflect ¶
func (x *ListRunsResponse) ProtoReflect() protoreflect.Message
func (*ListRunsResponse) Reset ¶
func (x *ListRunsResponse) Reset()
func (*ListRunsResponse) SizeVT ¶
func (m *ListRunsResponse) SizeVT() (n int)
func (*ListRunsResponse) String ¶
func (x *ListRunsResponse) String() string
func (*ListRunsResponse) UnmarshalVT ¶
func (m *ListRunsResponse) UnmarshalVT(dAtA []byte) error
func (*ListRunsResponse) UnmarshalVTUnsafe ¶
func (m *ListRunsResponse) UnmarshalVTUnsafe(dAtA []byte) error
type Run ¶
type Run struct { RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` CreatedDate *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_date,json=createdDate,proto3" json:"created_date,omitempty"` ModifiedDate *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=modified_date,json=modifiedDate,proto3" json:"modified_date,omitempty"` CreatedByUserId string `protobuf:"bytes,4,opt,name=created_by_user_id,json=createdByUserId,proto3" json:"created_by_user_id,omitempty"` ModifiedByUserId string `protobuf:"bytes,5,opt,name=modified_by_user_id,json=modifiedByUserId,proto3" json:"modified_by_user_id,omitempty"` OrganizationId string `protobuf:"bytes,6,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"` StopTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=stop_time,json=stopTime,proto3,oneof" json:"stop_time,omitempty"` IsPinned bool `protobuf:"varint,9,opt,name=is_pinned,json=isPinned,proto3" json:"is_pinned,omitempty"` Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"` Tags []string `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*Run) CloneMessageVT ¶
func (*Run) Descriptor
deprecated
func (*Run) GetCreatedByUserId ¶
func (*Run) GetCreatedDate ¶
func (x *Run) GetCreatedDate() *timestamppb.Timestamp
func (*Run) GetDescription ¶
func (*Run) GetIsPinned ¶
func (*Run) GetModifiedByUserId ¶
func (*Run) GetModifiedDate ¶
func (x *Run) GetModifiedDate() *timestamppb.Timestamp
func (*Run) GetOrganizationId ¶
func (*Run) GetStartTime ¶
func (x *Run) GetStartTime() *timestamppb.Timestamp
func (*Run) GetStopTime ¶
func (x *Run) GetStopTime() *timestamppb.Timestamp
func (*Run) MarshalToSizedBufferVTStrict ¶
func (*Run) MarshalVTStrict ¶
func (*Run) ProtoMessage ¶
func (*Run) ProtoMessage()
func (*Run) ProtoReflect ¶
func (x *Run) ProtoReflect() protoreflect.Message
func (*Run) UnmarshalVT ¶
func (*Run) UnmarshalVTUnsafe ¶
type RunServiceClient ¶
type RunServiceClient interface { // Retrieve a run. GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*GetRunResponse, error) // Retrieve runs using an optional filter. ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error) // Create a run. CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*CreateRunResponse, error) // Updates an existing run using using the list of fields specified in `update_mask`. UpdateRun(ctx context.Context, in *UpdateRunRequest, opts ...grpc.CallOption) (*UpdateRunResponse, error) // Permanently delete a given run. In order for a run to be deleted it must have a set `stop_time`. DeleteRun(ctx context.Context, in *DeleteRunRequest, opts ...grpc.CallOption) (*DeleteRunResponse, error) // Set the stop time of a run to the current time. To set the stop time of a run to an arbitrary time see `UpdateRun`. StopRun(ctx context.Context, in *StopRunRequest, opts ...grpc.CallOption) (*StopRunResponse, error) // Associates a list of assets with a given run. CreateAutomaticRunAssociationForAssets(ctx context.Context, in *CreateAutomaticRunAssociationForAssetsRequest, opts ...grpc.CallOption) (*CreateAutomaticRunAssociationForAssetsResponse, error) }
RunServiceClient is the client API for RunService 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 NewRunServiceClient ¶
func NewRunServiceClient(cc grpc.ClientConnInterface) RunServiceClient
type RunServiceServer ¶
type RunServiceServer interface { // Retrieve a run. GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error) // Retrieve runs using an optional filter. ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error) // Create a run. CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error) // Updates an existing run using using the list of fields specified in `update_mask`. UpdateRun(context.Context, *UpdateRunRequest) (*UpdateRunResponse, error) // Permanently delete a given run. In order for a run to be deleted it must have a set `stop_time`. DeleteRun(context.Context, *DeleteRunRequest) (*DeleteRunResponse, error) // Set the stop time of a run to the current time. To set the stop time of a run to an arbitrary time see `UpdateRun`. StopRun(context.Context, *StopRunRequest) (*StopRunResponse, error) // Associates a list of assets with a given run. CreateAutomaticRunAssociationForAssets(context.Context, *CreateAutomaticRunAssociationForAssetsRequest) (*CreateAutomaticRunAssociationForAssetsResponse, error) // contains filtered or unexported methods }
RunServiceServer is the server API for RunService service. All implementations must embed UnimplementedRunServiceServer for forward compatibility
type StopRunRequest ¶
type StopRunRequest struct { RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // contains filtered or unexported fields }
The request for a call to `RunService_StopRun` to stop a run.
func (*StopRunRequest) CloneMessageVT ¶
func (m *StopRunRequest) CloneMessageVT() proto.Message
func (*StopRunRequest) CloneVT ¶
func (m *StopRunRequest) CloneVT() *StopRunRequest
func (*StopRunRequest) Descriptor
deprecated
func (*StopRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRunRequest.ProtoReflect.Descriptor instead.
func (*StopRunRequest) EqualMessageVT ¶
func (this *StopRunRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*StopRunRequest) EqualVT ¶
func (this *StopRunRequest) EqualVT(that *StopRunRequest) bool
func (*StopRunRequest) GetRunId ¶
func (x *StopRunRequest) GetRunId() string
func (*StopRunRequest) MarshalToSizedBufferVT ¶
func (m *StopRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StopRunRequest) MarshalToSizedBufferVTStrict ¶
func (m *StopRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*StopRunRequest) MarshalToVT ¶
func (m *StopRunRequest) MarshalToVT(dAtA []byte) (int, error)
func (*StopRunRequest) MarshalToVTStrict ¶
func (m *StopRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*StopRunRequest) MarshalVT ¶
func (m *StopRunRequest) MarshalVT() (dAtA []byte, err error)
func (*StopRunRequest) MarshalVTStrict ¶
func (m *StopRunRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*StopRunRequest) ProtoMessage ¶
func (*StopRunRequest) ProtoMessage()
func (*StopRunRequest) ProtoReflect ¶
func (x *StopRunRequest) ProtoReflect() protoreflect.Message
func (*StopRunRequest) Reset ¶
func (x *StopRunRequest) Reset()
func (*StopRunRequest) SizeVT ¶
func (m *StopRunRequest) SizeVT() (n int)
func (*StopRunRequest) String ¶
func (x *StopRunRequest) String() string
func (*StopRunRequest) UnmarshalVT ¶
func (m *StopRunRequest) UnmarshalVT(dAtA []byte) error
func (*StopRunRequest) UnmarshalVTUnsafe ¶
func (m *StopRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
type StopRunResponse ¶
type StopRunResponse struct {
// contains filtered or unexported fields
}
The response of a call to `RunService_StopRun` to stop a run.
func (*StopRunResponse) CloneMessageVT ¶
func (m *StopRunResponse) CloneMessageVT() proto.Message
func (*StopRunResponse) CloneVT ¶
func (m *StopRunResponse) CloneVT() *StopRunResponse
func (*StopRunResponse) Descriptor
deprecated
func (*StopRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopRunResponse.ProtoReflect.Descriptor instead.
func (*StopRunResponse) EqualMessageVT ¶
func (this *StopRunResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*StopRunResponse) EqualVT ¶
func (this *StopRunResponse) EqualVT(that *StopRunResponse) bool
func (*StopRunResponse) MarshalToSizedBufferVT ¶
func (m *StopRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StopRunResponse) MarshalToSizedBufferVTStrict ¶
func (m *StopRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*StopRunResponse) MarshalToVT ¶
func (m *StopRunResponse) MarshalToVT(dAtA []byte) (int, error)
func (*StopRunResponse) MarshalToVTStrict ¶
func (m *StopRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*StopRunResponse) MarshalVT ¶
func (m *StopRunResponse) MarshalVT() (dAtA []byte, err error)
func (*StopRunResponse) MarshalVTStrict ¶
func (m *StopRunResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*StopRunResponse) ProtoMessage ¶
func (*StopRunResponse) ProtoMessage()
func (*StopRunResponse) ProtoReflect ¶
func (x *StopRunResponse) ProtoReflect() protoreflect.Message
func (*StopRunResponse) Reset ¶
func (x *StopRunResponse) Reset()
func (*StopRunResponse) SizeVT ¶
func (m *StopRunResponse) SizeVT() (n int)
func (*StopRunResponse) String ¶
func (x *StopRunResponse) String() string
func (*StopRunResponse) UnmarshalVT ¶
func (m *StopRunResponse) UnmarshalVT(dAtA []byte) error
func (*StopRunResponse) UnmarshalVTUnsafe ¶
func (m *StopRunResponse) UnmarshalVTUnsafe(dAtA []byte) error
type UnimplementedRunServiceServer ¶
type UnimplementedRunServiceServer struct { }
UnimplementedRunServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRunServiceServer) CreateAutomaticRunAssociationForAssets ¶
func (UnimplementedRunServiceServer) CreateAutomaticRunAssociationForAssets(context.Context, *CreateAutomaticRunAssociationForAssetsRequest) (*CreateAutomaticRunAssociationForAssetsResponse, error)
func (UnimplementedRunServiceServer) CreateRun ¶
func (UnimplementedRunServiceServer) CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error)
func (UnimplementedRunServiceServer) DeleteRun ¶
func (UnimplementedRunServiceServer) DeleteRun(context.Context, *DeleteRunRequest) (*DeleteRunResponse, error)
func (UnimplementedRunServiceServer) GetRun ¶
func (UnimplementedRunServiceServer) GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
func (UnimplementedRunServiceServer) ListRuns ¶
func (UnimplementedRunServiceServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
func (UnimplementedRunServiceServer) StopRun ¶
func (UnimplementedRunServiceServer) StopRun(context.Context, *StopRunRequest) (*StopRunResponse, error)
func (UnimplementedRunServiceServer) UpdateRun ¶
func (UnimplementedRunServiceServer) UpdateRun(context.Context, *UpdateRunRequest) (*UpdateRunResponse, error)
type UnsafeRunServiceServer ¶
type UnsafeRunServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRunServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunServiceServer will result in compilation errors.
type UpdateRunRequest ¶
type UpdateRunRequest struct { // The run to update. The run's `run_id` field is used to identify the run to update // and is required. Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` // The list of fields to be updated. The fields available to be updated are `name`, `description`, // `start_time`, `stop_time`, `is_pinned`, and `tags`. // Important Note: When updating the `start_time`, please be aware that if a subsequent data ingestion // commences for this run, the `start_time` will be automatically overwritten and set to the timestamp // corresponding to the beginning of the latest run. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
The request for a call to `RunService_UpdateRun` to update an existing run.
func (*UpdateRunRequest) CloneMessageVT ¶
func (m *UpdateRunRequest) CloneMessageVT() proto.Message
func (*UpdateRunRequest) CloneVT ¶
func (m *UpdateRunRequest) CloneVT() *UpdateRunRequest
func (*UpdateRunRequest) Descriptor
deprecated
func (*UpdateRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRunRequest.ProtoReflect.Descriptor instead.
func (*UpdateRunRequest) EqualMessageVT ¶
func (this *UpdateRunRequest) EqualMessageVT(thatMsg proto.Message) bool
func (*UpdateRunRequest) EqualVT ¶
func (this *UpdateRunRequest) EqualVT(that *UpdateRunRequest) bool
func (*UpdateRunRequest) GetRun ¶
func (x *UpdateRunRequest) GetRun() *Run
func (*UpdateRunRequest) GetUpdateMask ¶
func (x *UpdateRunRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateRunRequest) MarshalToSizedBufferVT ¶
func (m *UpdateRunRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateRunRequest) MarshalToSizedBufferVTStrict ¶
func (m *UpdateRunRequest) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*UpdateRunRequest) MarshalToVT ¶
func (m *UpdateRunRequest) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateRunRequest) MarshalToVTStrict ¶
func (m *UpdateRunRequest) MarshalToVTStrict(dAtA []byte) (int, error)
func (*UpdateRunRequest) MarshalVT ¶
func (m *UpdateRunRequest) MarshalVT() (dAtA []byte, err error)
func (*UpdateRunRequest) MarshalVTStrict ¶
func (m *UpdateRunRequest) MarshalVTStrict() (dAtA []byte, err error)
func (*UpdateRunRequest) ProtoMessage ¶
func (*UpdateRunRequest) ProtoMessage()
func (*UpdateRunRequest) ProtoReflect ¶
func (x *UpdateRunRequest) ProtoReflect() protoreflect.Message
func (*UpdateRunRequest) Reset ¶
func (x *UpdateRunRequest) Reset()
func (*UpdateRunRequest) SizeVT ¶
func (m *UpdateRunRequest) SizeVT() (n int)
func (*UpdateRunRequest) String ¶
func (x *UpdateRunRequest) String() string
func (*UpdateRunRequest) UnmarshalVT ¶
func (m *UpdateRunRequest) UnmarshalVT(dAtA []byte) error
func (*UpdateRunRequest) UnmarshalVTUnsafe ¶
func (m *UpdateRunRequest) UnmarshalVTUnsafe(dAtA []byte) error
type UpdateRunResponse ¶
type UpdateRunResponse struct { Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"` // contains filtered or unexported fields }
The response of a call to `RunService_UpdateRun` containing the updated run.
func (*UpdateRunResponse) CloneMessageVT ¶
func (m *UpdateRunResponse) CloneMessageVT() proto.Message
func (*UpdateRunResponse) CloneVT ¶
func (m *UpdateRunResponse) CloneVT() *UpdateRunResponse
func (*UpdateRunResponse) Descriptor
deprecated
func (*UpdateRunResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRunResponse.ProtoReflect.Descriptor instead.
func (*UpdateRunResponse) EqualMessageVT ¶
func (this *UpdateRunResponse) EqualMessageVT(thatMsg proto.Message) bool
func (*UpdateRunResponse) EqualVT ¶
func (this *UpdateRunResponse) EqualVT(that *UpdateRunResponse) bool
func (*UpdateRunResponse) GetRun ¶
func (x *UpdateRunResponse) GetRun() *Run
func (*UpdateRunResponse) MarshalToSizedBufferVT ¶
func (m *UpdateRunResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*UpdateRunResponse) MarshalToSizedBufferVTStrict ¶
func (m *UpdateRunResponse) MarshalToSizedBufferVTStrict(dAtA []byte) (int, error)
func (*UpdateRunResponse) MarshalToVT ¶
func (m *UpdateRunResponse) MarshalToVT(dAtA []byte) (int, error)
func (*UpdateRunResponse) MarshalToVTStrict ¶
func (m *UpdateRunResponse) MarshalToVTStrict(dAtA []byte) (int, error)
func (*UpdateRunResponse) MarshalVT ¶
func (m *UpdateRunResponse) MarshalVT() (dAtA []byte, err error)
func (*UpdateRunResponse) MarshalVTStrict ¶
func (m *UpdateRunResponse) MarshalVTStrict() (dAtA []byte, err error)
func (*UpdateRunResponse) ProtoMessage ¶
func (*UpdateRunResponse) ProtoMessage()
func (*UpdateRunResponse) ProtoReflect ¶
func (x *UpdateRunResponse) ProtoReflect() protoreflect.Message
func (*UpdateRunResponse) Reset ¶
func (x *UpdateRunResponse) Reset()
func (*UpdateRunResponse) SizeVT ¶
func (m *UpdateRunResponse) SizeVT() (n int)
func (*UpdateRunResponse) String ¶
func (x *UpdateRunResponse) String() string
func (*UpdateRunResponse) UnmarshalVT ¶
func (m *UpdateRunResponse) UnmarshalVT(dAtA []byte) error
func (*UpdateRunResponse) UnmarshalVTUnsafe ¶
func (m *UpdateRunResponse) UnmarshalVTUnsafe(dAtA []byte) error