runsv2

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
}

type CreateAutomaticRunAssociationForAssetsResponse struct {
	// contains filtered or unexported fields
}

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
}

type CreateRunResponse struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

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
}

type GetRunResponse struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

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](/ingestion/api#run-proto). Optional.
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type RunServiceClient interface {
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*GetRunResponse, error)
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	CreateRun(ctx context.Context, in *CreateRunRequest, opts ...grpc.CallOption) (*CreateRunResponse, error)
	UpdateRun(ctx context.Context, in *UpdateRunRequest, opts ...grpc.CallOption) (*UpdateRunResponse, error)
	CreateAutomaticRunAssociationForAssets(ctx context.Context, in *CreateAutomaticRunAssociationForAssetsRequest, opts ...grpc.CallOption) (*CreateAutomaticRunAssociationForAssetsResponse, error)
}

type RunServiceServer interface {
	GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	CreateRun(context.Context, *CreateRunRequest) (*CreateRunResponse, error)
	UpdateRun(context.Context, *UpdateRunRequest) (*UpdateRunResponse, error)
	CreateAutomaticRunAssociationForAssets(context.Context, *CreateAutomaticRunAssociationForAssetsRequest) (*CreateAutomaticRunAssociationForAssetsResponse, error)
	// contains filtered or unexported methods
}

type UnimplementedRunServiceServer struct {
}

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

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
}

type UpdateRunResponse struct {
	Run *Run `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}