flex

type CancelJobRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

type FetchPackageRequest struct {

	// Types that are assignable to Type:
	//	*FetchPackageRequest_Hash
	//	*FetchPackageRequest_Tag
	Type isFetchPackageRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type FetchPackageRequest_Hash struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3,oneof"`
}

type FetchPackageRequest_Tag struct {
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3,oneof"`
}

type FetchPackageResponse struct {
	Location *FileLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

type FileLocation struct {
	CanonicalUrl string `protobuf:"bytes,1,opt,name=canonical_url,json=canonicalUrl,proto3" json:"canonical_url,omitempty"`
	PresignedUrl string `protobuf:"bytes,2,opt,name=presigned_url,json=presignedUrl,proto3" json:"presigned_url,omitempty"`
	// contains filtered or unexported fields
}

type FlexServiceClient interface {
	SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*SubmitJobResponse, error)
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	GetJobOutput(ctx context.Context, in *GetJobOutputRequest, opts ...grpc.CallOption) (*GetJobOutputResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	UpdateJobLabels(ctx context.Context, in *UpdateJobLabelsRequest, opts ...grpc.CallOption) (*UpdateJobLabelsResponse, error)
	InsertPackage(ctx context.Context, opts ...grpc.CallOption) (FlexService_InsertPackageClient, error)
	GetPackage(ctx context.Context, in *GetPackageRequest, opts ...grpc.CallOption) (*GetPackageResponse, error)
	FetchPackage(ctx context.Context, in *FetchPackageRequest, opts ...grpc.CallOption) (*FetchPackageResponse, error)
	UpdateTag(ctx context.Context, in *UpdateTagRequest, opts ...grpc.CallOption) (*UpdateTagResponse, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (*ListTagsResponse, error)
	ListFlexlets(ctx context.Context, in *ListFlexletsRequest, opts ...grpc.CallOption) (*ListFlexletsResponse, error)
	GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)
}

type FlexServiceServer interface {
	SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error)
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	GetJobOutput(context.Context, *GetJobOutputRequest) (*GetJobOutputResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	UpdateJobLabels(context.Context, *UpdateJobLabelsRequest) (*UpdateJobLabelsResponse, error)
	InsertPackage(FlexService_InsertPackageServer) error
	GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error)
	FetchPackage(context.Context, *FetchPackageRequest) (*FetchPackageResponse, error)
	UpdateTag(context.Context, *UpdateTagRequest) (*UpdateTagResponse, error)
	ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error)
	ListFlexlets(context.Context, *ListFlexletsRequest) (*ListFlexletsResponse, error)
	GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)
	// contains filtered or unexported methods
}

type FlexService_InsertPackageClient interface {
	Send(*InsertPackageRequest) error
	CloseAndRecv() (*InsertPackageResponse, error)
	grpc.ClientStream
}

type FlexService_InsertPackageServer interface {
	SendAndClose(*InsertPackageResponse) error
	Recv() (*InsertPackageRequest, error)
	grpc.ServerStream
}

type Flexlet struct {
	Name string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Spec *FlexletSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type FlexletSpec struct {
	Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
	// contains filtered or unexported fields
}

type FlexletState int32

type FlexletStats struct {
	OnlineFlexlets  int32 `protobuf:"varint,1,opt,name=online_flexlets,json=onlineFlexlets,proto3" json:"online_flexlets,omitempty"`
	OfflineFlexlets int32 `protobuf:"varint,2,opt,name=offline_flexlets,json=offlineFlexlets,proto3" json:"offline_flexlets,omitempty"`
	BusyCores       int32 `protobuf:"varint,3,opt,name=busy_cores,json=busyCores,proto3" json:"busy_cores,omitempty"`
	IdleCores       int32 `protobuf:"varint,4,opt,name=idle_cores,json=idleCores,proto3" json:"idle_cores,omitempty"`
	// contains filtered or unexported fields
}

type FlexletStatus struct {
	Flexlet     *Flexlet     `protobuf:"bytes,1,opt,name=flexlet,proto3" json:"flexlet,omitempty"`
	State       FlexletState `protobuf:"varint,2,opt,name=state,proto3,enum=flex.FlexletState" json:"state,omitempty"`
	CurrentJobs []*Job       `protobuf:"bytes,3,rep,name=current_jobs,json=currentJobs,proto3" json:"current_jobs,omitempty"`
	// contains filtered or unexported fields
}

type GetJobOutputRequest struct {
	Id   int64                             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type GetJobOutputRequest_JobOutputType `protobuf:"varint,2,opt,name=type,proto3,enum=flex.GetJobOutputRequest_JobOutputType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type GetJobOutputRequest_JobOutputType int32

type GetJobOutputResponse struct {
	Location *FileLocation `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// contains filtered or unexported fields
}

type GetJobRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetJobResponse struct {
	Job *JobStatus `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

type GetPackageRequest struct {

	// Types that are assignable to Type:
	//	*GetPackageRequest_Hash
	//	*GetPackageRequest_Tag
	Type isGetPackageRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type GetPackageRequest_Hash struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3,oneof"`
}

type GetPackageRequest_Tag struct {
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3,oneof"`
}

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

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

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

type InsertPackageRequest struct {

	// Types that are assignable to Type:
	//	*InsertPackageRequest_Spec
	//	*InsertPackageRequest_Data
	Type isInsertPackageRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type InsertPackageRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type InsertPackageRequest_Spec struct {
	Spec *PackageSpec `protobuf:"bytes,1,opt,name=spec,proto3,oneof"`
}

type InsertPackageResponse struct {
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Id   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec *JobSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type JobAnnotations struct {
	Labels []string `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

type JobCommand struct {
	Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

type JobConstraints struct {
	Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

type JobInputs struct {
	Packages []*JobPackage `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

type JobLimits struct {
	Time *durationpb.Duration `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type JobPackage struct {
	Hash       string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Tag        string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	InstallDir string `protobuf:"bytes,3,opt,name=install_dir,json=installDir,proto3" json:"install_dir,omitempty"`
	// contains filtered or unexported fields
}

type JobSpec struct {
	Command     *JobCommand     `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Inputs      *JobInputs      `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Limits      *JobLimits      `protobuf:"bytes,3,opt,name=limits,proto3" json:"limits,omitempty"`
	Constraints *JobConstraints `protobuf:"bytes,4,opt,name=constraints,proto3" json:"constraints,omitempty"`
	Annotations *JobAnnotations `protobuf:"bytes,5,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

type JobState int32

type JobStats struct {
	PendingJobs int32 `protobuf:"varint,1,opt,name=pending_jobs,json=pendingJobs,proto3" json:"pending_jobs,omitempty"`
	RunningJobs int32 `protobuf:"varint,2,opt,name=running_jobs,json=runningJobs,proto3" json:"running_jobs,omitempty"`
	// contains filtered or unexported fields
}

type JobStatus struct {
	Job         *Job                   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	State       JobState               `protobuf:"varint,2,opt,name=state,proto3,enum=flex.JobState" json:"state,omitempty"`
	TaskId      string                 `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	FlexletName string                 `protobuf:"bytes,4,opt,name=flexlet_name,json=flexletName,proto3" json:"flexlet_name,omitempty"`
	Result      *TaskResult            `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	Created     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	Started     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started,proto3" json:"started,omitempty"`
	Finished    *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finished,proto3" json:"finished,omitempty"`
	// contains filtered or unexported fields
}

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

type ListFlexletsResponse struct {
	Flexlets []*FlexletStatus `protobuf:"bytes,1,rep,name=flexlets,proto3" json:"flexlets,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsRequest struct {
	Limit    int64    `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	BeforeId int64    `protobuf:"varint,2,opt,name=before_id,json=beforeId,proto3" json:"before_id,omitempty"`
	State    JobState `protobuf:"varint,3,opt,name=state,proto3,enum=flex.JobState" json:"state,omitempty"`
	Label    string   `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsResponse struct {
	Jobs []*JobStatus `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

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

type ListTagsResponse struct {
	Tags []*Tag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type Package struct {
	Hash string       `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Spec *PackageSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

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

type Stats struct {
	Job     *JobStats     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Flexlet *FlexletStats `protobuf:"bytes,2,opt,name=flexlet,proto3" json:"flexlet,omitempty"`
	// contains filtered or unexported fields
}

type SubmitJobRequest struct {
	Spec *JobSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type SubmitJobResponse struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Tag struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hash string `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

type TaskResult struct {
	ExitCode int32                `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Message  string               `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Time     *durationpb.Duration `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFlexServiceServer struct {
}

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

type UpdateJobLabelsRequest struct {
	Id   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Adds []string `protobuf:"bytes,2,rep,name=adds,proto3" json:"adds,omitempty"`
	Dels []string `protobuf:"bytes,3,rep,name=dels,proto3" json:"dels,omitempty"`
	// contains filtered or unexported fields
}

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

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

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