flex

package module
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 2, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

README

Flex

Flex is a simple workload distribution system.

Synopsis

# Install Flex CLI.
go install github.com/nya3jp/flex/cmd/flex

# Configure Flexhub endpoint and password.
flex configure

# Run a command.
flex run echo 'Hello, world!'

# Upload a binary file and execute it.
flex run -f path/to/some './some --flag1 --flag2'

# Upload a binary file as a package, and tag it.
flex package create -f path/to/some -t somebin

# Enqueue a job without waiting for its completion.
flex job create -p somebin './some --flag1 --flag2'

# Print a list of finished jobs.
flex job list --state=finished

# Print details of the job whose ID is 123.
flex job info 123

Tips

  • Many commands accept --json option that prints outputs in JSON.

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobState_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "FINISHED",
	}
	JobState_value = map[string]int32{
		"UNSPECIFIED": 0,
		"PENDING":     1,
		"RUNNING":     2,
		"FINISHED":    3,
	}
)

Enum value maps for JobState.

View Source 
var (
	FlexletState_name = map[int32]string{
		0: "OFFLINE",
		1: "ONLINE",
	}
	FlexletState_value = map[string]int32{
		"OFFLINE": 0,
		"ONLINE":  1,
	}
)

Enum value maps for FlexletState.

View Source 
var (
	GetJobOutputRequest_JobOutputType_name = map[int32]string{
		0: "STDOUT",
		1: "STDERR",
	}
	GetJobOutputRequest_JobOutputType_value = map[string]int32{
		"STDOUT": 0,
		"STDERR": 1,
	}
)

Enum value maps for GetJobOutputRequest_JobOutputType.

View Source 
var File_flex_proto protoreflect.FileDescriptor
View Source 
var File_flex_service_proto protoreflect.FileDescriptor
View Source 
var FlexService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flex.FlexService",
	HandlerType: (*FlexServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitJob",
			Handler:    _FlexService_SubmitJob_Handler,
		},
		{
			MethodName: "CancelJob",
			Handler:    _FlexService_CancelJob_Handler,
		},
		{
			MethodName: "GetJob",
			Handler:    _FlexService_GetJob_Handler,
		},
		{
			MethodName: "GetJobOutput",
			Handler:    _FlexService_GetJobOutput_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _FlexService_ListJobs_Handler,
		},
		{
			MethodName: "UpdateJobLabels",
			Handler:    _FlexService_UpdateJobLabels_Handler,
		},
		{
			MethodName: "GetPackage",
			Handler:    _FlexService_GetPackage_Handler,
		},
		{
			MethodName: "FetchPackage",
			Handler:    _FlexService_FetchPackage_Handler,
		},
		{
			MethodName: "UpdateTag",
			Handler:    _FlexService_UpdateTag_Handler,
		},
		{
			MethodName: "ListTags",
			Handler:    _FlexService_ListTags_Handler,
		},
		{
			MethodName: "ListFlexlets",
			Handler:    _FlexService_ListFlexlets_Handler,
		},
		{
			MethodName: "GetStats",
			Handler:    _FlexService_GetStats_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InsertPackage",
			Handler:       _FlexService_InsertPackage_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "flex_service.proto",
}

FlexService_ServiceDesc is the grpc.ServiceDesc for FlexService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFlexServiceServer 

func RegisterFlexServiceServer(s grpc.ServiceRegistrar, srv FlexServiceServer)

Types

type CancelJobRequest 

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

func (*CancelJobRequest) Descriptor deprecated 

func (*CancelJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetId 

func (x *CancelJobRequest) GetId() int64

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

func (x *CancelJobRequest) ProtoReflect() protoreflect.Message

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CancelJobResponse 

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

func (*CancelJobResponse) Descriptor deprecated 

func (*CancelJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect 

func (x *CancelJobResponse) ProtoReflect() protoreflect.Message

func (*CancelJobResponse) Reset 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (x *CancelJobResponse) String() string

type FetchPackageRequest 

type FetchPackageRequest struct {

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

func (*FetchPackageRequest) Descriptor deprecated 

func (*FetchPackageRequest) Descriptor() ([]byte, []int)

Deprecated: Use FetchPackageRequest.ProtoReflect.Descriptor instead.

func (*FetchPackageRequest) GetHash 

func (x *FetchPackageRequest) GetHash() string

func (*FetchPackageRequest) GetTag 

func (x *FetchPackageRequest) GetTag() string

func (*FetchPackageRequest) GetType 

func (m *FetchPackageRequest) GetType() isFetchPackageRequest_Type

func (*FetchPackageRequest) ProtoMessage 

func (*FetchPackageRequest) ProtoMessage()

func (*FetchPackageRequest) ProtoReflect 

func (x *FetchPackageRequest) ProtoReflect() protoreflect.Message

func (*FetchPackageRequest) Reset 

func (x *FetchPackageRequest) Reset()

func (*FetchPackageRequest) String 

func (x *FetchPackageRequest) String() string

type FetchPackageRequest_Hash 

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

type FetchPackageRequest_Tag 

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

type FetchPackageResponse 

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

func (*FetchPackageResponse) Descriptor deprecated 

func (*FetchPackageResponse) Descriptor() ([]byte, []int)

Deprecated: Use FetchPackageResponse.ProtoReflect.Descriptor instead.

func (*FetchPackageResponse) GetLocation 

func (x *FetchPackageResponse) GetLocation() *FileLocation

func (*FetchPackageResponse) ProtoMessage 

func (*FetchPackageResponse) ProtoMessage()

func (*FetchPackageResponse) ProtoReflect 

func (x *FetchPackageResponse) ProtoReflect() protoreflect.Message

func (*FetchPackageResponse) Reset 

func (x *FetchPackageResponse) Reset()

func (*FetchPackageResponse) String 

func (x *FetchPackageResponse) String() string

type FileLocation 

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
}

func (*FileLocation) Descriptor deprecated 

func (*FileLocation) Descriptor() ([]byte, []int)

Deprecated: Use FileLocation.ProtoReflect.Descriptor instead.

func (*FileLocation) GetCanonicalUrl 

func (x *FileLocation) GetCanonicalUrl() string

func (*FileLocation) GetPresignedUrl 

func (x *FileLocation) GetPresignedUrl() string

func (*FileLocation) ProtoMessage 

func (*FileLocation) ProtoMessage()

func (*FileLocation) ProtoReflect 

func (x *FileLocation) ProtoReflect() protoreflect.Message

func (*FileLocation) Reset 

func (x *FileLocation) Reset()

func (*FileLocation) String 

func (x *FileLocation) String() string

type FlexServiceClient 

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)
}

FlexServiceClient is the client API for FlexService 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 NewFlexServiceClient 

func NewFlexServiceClient(cc grpc.ClientConnInterface) FlexServiceClient

type FlexServiceServer 

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
}

FlexServiceServer is the server API for FlexService service. All implementations must embed UnimplementedFlexServiceServer for forward compatibility

type FlexService_InsertPackageClient 

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

type FlexService_InsertPackageServer 

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

type Flexlet 

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
}

func (*Flexlet) Descriptor deprecated 

func (*Flexlet) Descriptor() ([]byte, []int)

Deprecated: Use Flexlet.ProtoReflect.Descriptor instead.

func (*Flexlet) GetName 

func (x *Flexlet) GetName() string

func (*Flexlet) GetSpec 

func (x *Flexlet) GetSpec() *FlexletSpec

func (*Flexlet) ProtoMessage 

func (*Flexlet) ProtoMessage()

func (*Flexlet) ProtoReflect 

func (x *Flexlet) ProtoReflect() protoreflect.Message

func (*Flexlet) Reset 

func (x *Flexlet) Reset()

func (*Flexlet) String 

func (x *Flexlet) String() string

type FlexletSpec 

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

func (*FlexletSpec) Descriptor deprecated 

func (*FlexletSpec) Descriptor() ([]byte, []int)

Deprecated: Use FlexletSpec.ProtoReflect.Descriptor instead.

func (*FlexletSpec) GetCores 

func (x *FlexletSpec) GetCores() int32

func (*FlexletSpec) ProtoMessage 

func (*FlexletSpec) ProtoMessage()

func (*FlexletSpec) ProtoReflect 

func (x *FlexletSpec) ProtoReflect() protoreflect.Message

func (*FlexletSpec) Reset 

func (x *FlexletSpec) Reset()

func (*FlexletSpec) String 

func (x *FlexletSpec) String() string

type FlexletState 

type FlexletState int32
const (
	FlexletState_OFFLINE FlexletState = 0
	FlexletState_ONLINE  FlexletState = 1
)

func (FlexletState) Descriptor 

func (FlexletState) Descriptor() protoreflect.EnumDescriptor

func (FlexletState) Enum 

func (x FlexletState) Enum() *FlexletState

func (FlexletState) EnumDescriptor deprecated 

func (FlexletState) EnumDescriptor() ([]byte, []int)

Deprecated: Use FlexletState.Descriptor instead.

func (FlexletState) Number 

func (x FlexletState) Number() protoreflect.EnumNumber

func (FlexletState) String 

func (x FlexletState) String() string

func (FlexletState) Type 

func (FlexletState) Type() protoreflect.EnumType

type FlexletStats 

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
}

func (*FlexletStats) Descriptor deprecated 

func (*FlexletStats) Descriptor() ([]byte, []int)

Deprecated: Use FlexletStats.ProtoReflect.Descriptor instead.

func (*FlexletStats) GetBusyCores 

func (x *FlexletStats) GetBusyCores() int32

func (*FlexletStats) GetIdleCores 

func (x *FlexletStats) GetIdleCores() int32

func (*FlexletStats) GetOfflineFlexlets 

func (x *FlexletStats) GetOfflineFlexlets() int32

func (*FlexletStats) GetOnlineFlexlets 

func (x *FlexletStats) GetOnlineFlexlets() int32

func (*FlexletStats) ProtoMessage 

func (*FlexletStats) ProtoMessage()

func (*FlexletStats) ProtoReflect 

func (x *FlexletStats) ProtoReflect() protoreflect.Message

func (*FlexletStats) Reset 

func (x *FlexletStats) Reset()

func (*FlexletStats) String 

func (x *FlexletStats) String() string

type FlexletStatus 

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
}

func (*FlexletStatus) Descriptor deprecated 

func (*FlexletStatus) Descriptor() ([]byte, []int)

Deprecated: Use FlexletStatus.ProtoReflect.Descriptor instead.

func (*FlexletStatus) GetCurrentJobs 

func (x *FlexletStatus) GetCurrentJobs() []*Job

func (*FlexletStatus) GetFlexlet 

func (x *FlexletStatus) GetFlexlet() *Flexlet

func (*FlexletStatus) GetState 

func (x *FlexletStatus) GetState() FlexletState

func (*FlexletStatus) ProtoMessage 

func (*FlexletStatus) ProtoMessage()

func (*FlexletStatus) ProtoReflect 

func (x *FlexletStatus) ProtoReflect() protoreflect.Message

func (*FlexletStatus) Reset 

func (x *FlexletStatus) Reset()

func (*FlexletStatus) String 

func (x *FlexletStatus) String() string

type GetJobOutputRequest 

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
}

func (*GetJobOutputRequest) Descriptor deprecated 

func (*GetJobOutputRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetJobOutputRequest.ProtoReflect.Descriptor instead.

func (*GetJobOutputRequest) GetId 

func (x *GetJobOutputRequest) GetId() int64

func (*GetJobOutputRequest) GetType 

func (x *GetJobOutputRequest) GetType() GetJobOutputRequest_JobOutputType

func (*GetJobOutputRequest) ProtoMessage 

func (*GetJobOutputRequest) ProtoMessage()

func (*GetJobOutputRequest) ProtoReflect 

func (x *GetJobOutputRequest) ProtoReflect() protoreflect.Message

func (*GetJobOutputRequest) Reset 

func (x *GetJobOutputRequest) Reset()

func (*GetJobOutputRequest) String 

func (x *GetJobOutputRequest) String() string

type GetJobOutputRequest_JobOutputType 

type GetJobOutputRequest_JobOutputType int32
const (
	GetJobOutputRequest_STDOUT GetJobOutputRequest_JobOutputType = 0
	GetJobOutputRequest_STDERR GetJobOutputRequest_JobOutputType = 1
)

func (GetJobOutputRequest_JobOutputType) Descriptor 

func (GetJobOutputRequest_JobOutputType) Descriptor() protoreflect.EnumDescriptor

func (GetJobOutputRequest_JobOutputType) Enum 

func (x GetJobOutputRequest_JobOutputType) Enum() *GetJobOutputRequest_JobOutputType

func (GetJobOutputRequest_JobOutputType) EnumDescriptor deprecated 

func (GetJobOutputRequest_JobOutputType) EnumDescriptor() ([]byte, []int)

Deprecated: Use GetJobOutputRequest_JobOutputType.Descriptor instead.

func (GetJobOutputRequest_JobOutputType) Number 

func (x GetJobOutputRequest_JobOutputType) Number() protoreflect.EnumNumber

func (GetJobOutputRequest_JobOutputType) String 

func (x GetJobOutputRequest_JobOutputType) String() string

func (GetJobOutputRequest_JobOutputType) Type 

func (GetJobOutputRequest_JobOutputType) Type() protoreflect.EnumType

type GetJobOutputResponse 

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

func (*GetJobOutputResponse) Descriptor deprecated 

func (*GetJobOutputResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetJobOutputResponse.ProtoReflect.Descriptor instead.

func (*GetJobOutputResponse) GetLocation 

func (x *GetJobOutputResponse) GetLocation() *FileLocation

func (*GetJobOutputResponse) ProtoMessage 

func (*GetJobOutputResponse) ProtoMessage()

func (*GetJobOutputResponse) ProtoReflect 

func (x *GetJobOutputResponse) ProtoReflect() protoreflect.Message

func (*GetJobOutputResponse) Reset 

func (x *GetJobOutputResponse) Reset()

func (*GetJobOutputResponse) String 

func (x *GetJobOutputResponse) String() string

type GetJobRequest 

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

func (*GetJobRequest) Descriptor deprecated 

func (*GetJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() int64

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

func (x *GetJobRequest) ProtoReflect() protoreflect.Message

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

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

func (*GetJobResponse) Descriptor deprecated 

func (*GetJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *JobStatus

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

func (x *GetJobResponse) ProtoReflect() protoreflect.Message

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

type GetPackageRequest 

type GetPackageRequest struct {

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

func (*GetPackageRequest) Descriptor deprecated 

func (*GetPackageRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPackageRequest.ProtoReflect.Descriptor instead.

func (*GetPackageRequest) GetHash 

func (x *GetPackageRequest) GetHash() string

func (*GetPackageRequest) GetTag 

func (x *GetPackageRequest) GetTag() string

func (*GetPackageRequest) GetType 

func (m *GetPackageRequest) GetType() isGetPackageRequest_Type

func (*GetPackageRequest) ProtoMessage 

func (*GetPackageRequest) ProtoMessage()

func (*GetPackageRequest) ProtoReflect 

func (x *GetPackageRequest) ProtoReflect() protoreflect.Message

func (*GetPackageRequest) Reset 

func (x *GetPackageRequest) Reset()

func (*GetPackageRequest) String 

func (x *GetPackageRequest) String() string

type GetPackageRequest_Hash 

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

type GetPackageRequest_Tag 

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

type GetPackageResponse 

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

func (*GetPackageResponse) Descriptor deprecated 

func (*GetPackageResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPackageResponse.ProtoReflect.Descriptor instead.

func (*GetPackageResponse) GetPackage 

func (x *GetPackageResponse) GetPackage() *Package

func (*GetPackageResponse) ProtoMessage 

func (*GetPackageResponse) ProtoMessage()

func (*GetPackageResponse) ProtoReflect 

func (x *GetPackageResponse) ProtoReflect() protoreflect.Message

func (*GetPackageResponse) Reset 

func (x *GetPackageResponse) Reset()

func (*GetPackageResponse) String 

func (x *GetPackageResponse) String() string

type GetStatsRequest 

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

func (*GetStatsRequest) Descriptor deprecated 

func (*GetStatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatsRequest.ProtoReflect.Descriptor instead.

func (*GetStatsRequest) ProtoMessage 

func (*GetStatsRequest) ProtoMessage()

func (*GetStatsRequest) ProtoReflect 

func (x *GetStatsRequest) ProtoReflect() protoreflect.Message

func (*GetStatsRequest) Reset 

func (x *GetStatsRequest) Reset()

func (*GetStatsRequest) String 

func (x *GetStatsRequest) String() string

type GetStatsResponse 

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

func (*GetStatsResponse) Descriptor deprecated 

func (*GetStatsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatsResponse.ProtoReflect.Descriptor instead.

func (*GetStatsResponse) GetStats 

func (x *GetStatsResponse) GetStats() *Stats

func (*GetStatsResponse) ProtoMessage 

func (*GetStatsResponse) ProtoMessage()

func (*GetStatsResponse) ProtoReflect 

func (x *GetStatsResponse) ProtoReflect() protoreflect.Message

func (*GetStatsResponse) Reset 

func (x *GetStatsResponse) Reset()

func (*GetStatsResponse) String 

func (x *GetStatsResponse) String() string

type InsertPackageRequest 

type InsertPackageRequest struct {

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

func (*InsertPackageRequest) Descriptor deprecated 

func (*InsertPackageRequest) Descriptor() ([]byte, []int)

Deprecated: Use InsertPackageRequest.ProtoReflect.Descriptor instead.

func (*InsertPackageRequest) GetData 

func (x *InsertPackageRequest) GetData() []byte

func (*InsertPackageRequest) GetSpec 

func (x *InsertPackageRequest) GetSpec() *PackageSpec

func (*InsertPackageRequest) GetType 

func (m *InsertPackageRequest) GetType() isInsertPackageRequest_Type

func (*InsertPackageRequest) ProtoMessage 

func (*InsertPackageRequest) ProtoMessage()

func (*InsertPackageRequest) ProtoReflect 

func (x *InsertPackageRequest) ProtoReflect() protoreflect.Message

func (*InsertPackageRequest) Reset 

func (x *InsertPackageRequest) Reset()

func (*InsertPackageRequest) String 

func (x *InsertPackageRequest) String() string

type InsertPackageRequest_Data 

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

type InsertPackageRequest_Spec 

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

type InsertPackageResponse 

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

func (*InsertPackageResponse) Descriptor deprecated 

func (*InsertPackageResponse) Descriptor() ([]byte, []int)

Deprecated: Use InsertPackageResponse.ProtoReflect.Descriptor instead.

func (*InsertPackageResponse) GetHash 

func (x *InsertPackageResponse) GetHash() string

func (*InsertPackageResponse) ProtoMessage 

func (*InsertPackageResponse) ProtoMessage()

func (*InsertPackageResponse) ProtoReflect 

func (x *InsertPackageResponse) ProtoReflect() protoreflect.Message

func (*InsertPackageResponse) Reset 

func (x *InsertPackageResponse) Reset()

func (*InsertPackageResponse) String 

func (x *InsertPackageResponse) String() string

type Job 

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
}

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetId 

func (x *Job) GetId() int64

func (*Job) GetSpec 

func (x *Job) GetSpec() *JobSpec

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobAnnotations 

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

func (*JobAnnotations) Descriptor deprecated 

func (*JobAnnotations) Descriptor() ([]byte, []int)

Deprecated: Use JobAnnotations.ProtoReflect.Descriptor instead.

func (*JobAnnotations) GetLabels 

func (x *JobAnnotations) GetLabels() []string

func (*JobAnnotations) ProtoMessage 

func (*JobAnnotations) ProtoMessage()

func (*JobAnnotations) ProtoReflect 

func (x *JobAnnotations) ProtoReflect() protoreflect.Message

func (*JobAnnotations) Reset 

func (x *JobAnnotations) Reset()

func (*JobAnnotations) String 

func (x *JobAnnotations) String() string

type JobCommand 

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

func (*JobCommand) Descriptor deprecated 

func (*JobCommand) Descriptor() ([]byte, []int)

Deprecated: Use JobCommand.ProtoReflect.Descriptor instead.

func (*JobCommand) GetArgs 

func (x *JobCommand) GetArgs() []string

func (*JobCommand) ProtoMessage 

func (*JobCommand) ProtoMessage()

func (*JobCommand) ProtoReflect 

func (x *JobCommand) ProtoReflect() protoreflect.Message

func (*JobCommand) Reset 

func (x *JobCommand) Reset()

func (*JobCommand) String 

func (x *JobCommand) String() string

type JobConstraints 

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

func (*JobConstraints) Descriptor deprecated 

func (*JobConstraints) Descriptor() ([]byte, []int)

Deprecated: Use JobConstraints.ProtoReflect.Descriptor instead.

func (*JobConstraints) GetPriority 

func (x *JobConstraints) GetPriority() int32

func (*JobConstraints) ProtoMessage 

func (*JobConstraints) ProtoMessage()

func (*JobConstraints) ProtoReflect 

func (x *JobConstraints) ProtoReflect() protoreflect.Message

func (*JobConstraints) Reset 

func (x *JobConstraints) Reset()

func (*JobConstraints) String 

func (x *JobConstraints) String() string

type JobInputs 

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

func (*JobInputs) Descriptor deprecated 

func (*JobInputs) Descriptor() ([]byte, []int)

Deprecated: Use JobInputs.ProtoReflect.Descriptor instead.

func (*JobInputs) GetPackages 

func (x *JobInputs) GetPackages() []*JobPackage

func (*JobInputs) ProtoMessage 

func (*JobInputs) ProtoMessage()

func (*JobInputs) ProtoReflect 

func (x *JobInputs) ProtoReflect() protoreflect.Message

func (*JobInputs) Reset 

func (x *JobInputs) Reset()

func (*JobInputs) String 

func (x *JobInputs) String() string

type JobLimits 

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

func (*JobLimits) Descriptor deprecated 

func (*JobLimits) Descriptor() ([]byte, []int)

Deprecated: Use JobLimits.ProtoReflect.Descriptor instead.

func (*JobLimits) GetTime 

func (x *JobLimits) GetTime() *durationpb.Duration

func (*JobLimits) ProtoMessage 

func (*JobLimits) ProtoMessage()

func (*JobLimits) ProtoReflect 

func (x *JobLimits) ProtoReflect() protoreflect.Message

func (*JobLimits) Reset 

func (x *JobLimits) Reset()

func (*JobLimits) String 

func (x *JobLimits) String() string

type JobPackage 

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
}

func (*JobPackage) Descriptor deprecated 

func (*JobPackage) Descriptor() ([]byte, []int)

Deprecated: Use JobPackage.ProtoReflect.Descriptor instead.

func (*JobPackage) GetHash 

func (x *JobPackage) GetHash() string

func (*JobPackage) GetInstallDir 

func (x *JobPackage) GetInstallDir() string

func (*JobPackage) GetTag 

func (x *JobPackage) GetTag() string

func (*JobPackage) ProtoMessage 

func (*JobPackage) ProtoMessage()

func (*JobPackage) ProtoReflect 

func (x *JobPackage) ProtoReflect() protoreflect.Message

func (*JobPackage) Reset 

func (x *JobPackage) Reset()

func (*JobPackage) String 

func (x *JobPackage) String() string

type JobSpec 

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
}

func (*JobSpec) Descriptor deprecated 

func (*JobSpec) Descriptor() ([]byte, []int)

Deprecated: Use JobSpec.ProtoReflect.Descriptor instead.

func (*JobSpec) GetAnnotations 

func (x *JobSpec) GetAnnotations() *JobAnnotations

func (*JobSpec) GetCommand 

func (x *JobSpec) GetCommand() *JobCommand

func (*JobSpec) GetConstraints 

func (x *JobSpec) GetConstraints() *JobConstraints

func (*JobSpec) GetInputs 

func (x *JobSpec) GetInputs() *JobInputs

func (*JobSpec) GetLimits 

func (x *JobSpec) GetLimits() *JobLimits

func (*JobSpec) ProtoMessage 

func (*JobSpec) ProtoMessage()

func (*JobSpec) ProtoReflect 

func (x *JobSpec) ProtoReflect() protoreflect.Message

func (*JobSpec) Reset 

func (x *JobSpec) Reset()

func (*JobSpec) String 

func (x *JobSpec) String() string

type JobState 

type JobState int32
const (
	JobState_UNSPECIFIED JobState = 0
	JobState_PENDING     JobState = 1
	JobState_RUNNING     JobState = 2
	JobState_FINISHED    JobState = 3
)

func (JobState) Descriptor 

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum 

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated 

func (JobState) EnumDescriptor() ([]byte, []int)

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number 

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String 

func (x JobState) String() string

func (JobState) Type 

func (JobState) Type() protoreflect.EnumType

type JobStats 

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
}

func (*JobStats) Descriptor deprecated 

func (*JobStats) Descriptor() ([]byte, []int)

Deprecated: Use JobStats.ProtoReflect.Descriptor instead.

func (*JobStats) GetPendingJobs 

func (x *JobStats) GetPendingJobs() int32

func (*JobStats) GetRunningJobs 

func (x *JobStats) GetRunningJobs() int32

func (*JobStats) ProtoMessage 

func (*JobStats) ProtoMessage()

func (*JobStats) ProtoReflect 

func (x *JobStats) ProtoReflect() protoreflect.Message

func (*JobStats) Reset 

func (x *JobStats) Reset()

func (*JobStats) String 

func (x *JobStats) String() string

type JobStatus 

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
}

func (*JobStatus) Descriptor deprecated 

func (*JobStatus) Descriptor() ([]byte, []int)

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetCreated 

func (x *JobStatus) GetCreated() *timestamppb.Timestamp

func (*JobStatus) GetFinished 

func (x *JobStatus) GetFinished() *timestamppb.Timestamp

func (*JobStatus) GetFlexletName 

func (x *JobStatus) GetFlexletName() string

func (*JobStatus) GetJob 

func (x *JobStatus) GetJob() *Job

func (*JobStatus) GetResult 

func (x *JobStatus) GetResult() *TaskResult

func (*JobStatus) GetStarted 

func (x *JobStatus) GetStarted() *timestamppb.Timestamp

func (*JobStatus) GetState 

func (x *JobStatus) GetState() JobState

func (*JobStatus) GetTaskId 

func (x *JobStatus) GetTaskId() string

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect 

func (x *JobStatus) ProtoReflect() protoreflect.Message

func (*JobStatus) Reset 

func (x *JobStatus) Reset()

func (*JobStatus) String 

func (x *JobStatus) String() string

type ListFlexletsRequest 

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

func (*ListFlexletsRequest) Descriptor deprecated 

func (*ListFlexletsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListFlexletsRequest.ProtoReflect.Descriptor instead.

func (*ListFlexletsRequest) ProtoMessage 

func (*ListFlexletsRequest) ProtoMessage()

func (*ListFlexletsRequest) ProtoReflect 

func (x *ListFlexletsRequest) ProtoReflect() protoreflect.Message

func (*ListFlexletsRequest) Reset 

func (x *ListFlexletsRequest) Reset()

func (*ListFlexletsRequest) String 

func (x *ListFlexletsRequest) String() string

type ListFlexletsResponse 

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

func (*ListFlexletsResponse) Descriptor deprecated 

func (*ListFlexletsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListFlexletsResponse.ProtoReflect.Descriptor instead.

func (*ListFlexletsResponse) GetFlexlets 

func (x *ListFlexletsResponse) GetFlexlets() []*FlexletStatus

func (*ListFlexletsResponse) ProtoMessage 

func (*ListFlexletsResponse) ProtoMessage()

func (*ListFlexletsResponse) ProtoReflect 

func (x *ListFlexletsResponse) ProtoReflect() protoreflect.Message

func (*ListFlexletsResponse) Reset 

func (x *ListFlexletsResponse) Reset()

func (*ListFlexletsResponse) String 

func (x *ListFlexletsResponse) String() string

type ListJobsRequest 

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
}

func (*ListJobsRequest) Descriptor deprecated 

func (*ListJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetBeforeId 

func (x *ListJobsRequest) GetBeforeId() int64

func (*ListJobsRequest) GetLabel 

func (x *ListJobsRequest) GetLabel() string

func (*ListJobsRequest) GetLimit 

func (x *ListJobsRequest) GetLimit() int64

func (*ListJobsRequest) GetState 

func (x *ListJobsRequest) GetState() JobState

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

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

func (*ListJobsResponse) Descriptor deprecated 

func (*ListJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*JobStatus

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListTagsRequest 

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

func (*ListTagsRequest) Descriptor deprecated 

func (*ListTagsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTagsRequest.ProtoReflect.Descriptor instead.

func (*ListTagsRequest) ProtoMessage 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) ProtoReflect 

func (x *ListTagsRequest) ProtoReflect() protoreflect.Message

func (*ListTagsRequest) Reset 

func (x *ListTagsRequest) Reset()

func (*ListTagsRequest) String 

func (x *ListTagsRequest) String() string

type ListTagsResponse 

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

func (*ListTagsResponse) Descriptor deprecated 

func (*ListTagsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTagsResponse.ProtoReflect.Descriptor instead.

func (*ListTagsResponse) GetTags 

func (x *ListTagsResponse) GetTags() []*Tag

func (*ListTagsResponse) ProtoMessage 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) ProtoReflect 

func (x *ListTagsResponse) ProtoReflect() protoreflect.Message

func (*ListTagsResponse) Reset 

func (x *ListTagsResponse) Reset()

func (*ListTagsResponse) String 

func (x *ListTagsResponse) String() string

type Package 

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
}

func (*Package) Descriptor deprecated 

func (*Package) Descriptor() ([]byte, []int)

Deprecated: Use Package.ProtoReflect.Descriptor instead.

func (*Package) GetHash 

func (x *Package) GetHash() string

func (*Package) GetSpec 

func (x *Package) GetSpec() *PackageSpec

func (*Package) ProtoMessage 

func (*Package) ProtoMessage()

func (*Package) ProtoReflect 

func (x *Package) ProtoReflect() protoreflect.Message

func (*Package) Reset 

func (x *Package) Reset()

func (*Package) String 

func (x *Package) String() string

type PackageSpec 

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

func (*PackageSpec) Descriptor deprecated 

func (*PackageSpec) Descriptor() ([]byte, []int)

Deprecated: Use PackageSpec.ProtoReflect.Descriptor instead.

func (*PackageSpec) ProtoMessage 

func (*PackageSpec) ProtoMessage()

func (*PackageSpec) ProtoReflect 

func (x *PackageSpec) ProtoReflect() protoreflect.Message

func (*PackageSpec) Reset 

func (x *PackageSpec) Reset()

func (*PackageSpec) String 

func (x *PackageSpec) String() string

type Stats 

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
}

func (*Stats) Descriptor deprecated 

func (*Stats) Descriptor() ([]byte, []int)

Deprecated: Use Stats.ProtoReflect.Descriptor instead.

func (*Stats) GetFlexlet 

func (x *Stats) GetFlexlet() *FlexletStats

func (*Stats) GetJob 

func (x *Stats) GetJob() *JobStats

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) ProtoReflect 

func (x *Stats) ProtoReflect() protoreflect.Message

func (*Stats) Reset 

func (x *Stats) Reset()

func (*Stats) String 

func (x *Stats) String() string

type SubmitJobRequest 

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

func (*SubmitJobRequest) Descriptor deprecated 

func (*SubmitJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubmitJobRequest.ProtoReflect.Descriptor instead.

func (*SubmitJobRequest) GetSpec 

func (x *SubmitJobRequest) GetSpec() *JobSpec

func (*SubmitJobRequest) ProtoMessage 

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) ProtoReflect 

func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message

func (*SubmitJobRequest) Reset 

func (x *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String 

func (x *SubmitJobRequest) String() string

type SubmitJobResponse 

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

func (*SubmitJobResponse) Descriptor deprecated 

func (*SubmitJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubmitJobResponse.ProtoReflect.Descriptor instead.

func (*SubmitJobResponse) GetId 

func (x *SubmitJobResponse) GetId() int64

func (*SubmitJobResponse) ProtoMessage 

func (*SubmitJobResponse) ProtoMessage()

func (*SubmitJobResponse) ProtoReflect 

func (x *SubmitJobResponse) ProtoReflect() protoreflect.Message

func (*SubmitJobResponse) Reset 

func (x *SubmitJobResponse) Reset()

func (*SubmitJobResponse) String 

func (x *SubmitJobResponse) String() string

type Tag 

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
}

func (*Tag) Descriptor deprecated 

func (*Tag) Descriptor() ([]byte, []int)

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetHash 

func (x *Tag) GetHash() string

func (*Tag) GetName 

func (x *Tag) GetName() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

func (x *Tag) ProtoReflect() protoreflect.Message

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) String 

func (x *Tag) String() string

type TaskResult 

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
}

func (*TaskResult) Descriptor deprecated 

func (*TaskResult) Descriptor() ([]byte, []int)

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetExitCode 

func (x *TaskResult) GetExitCode() int32

func (*TaskResult) GetMessage 

func (x *TaskResult) GetMessage() string

func (*TaskResult) GetTime 

func (x *TaskResult) GetTime() *durationpb.Duration

func (*TaskResult) ProtoMessage 

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect 

func (x *TaskResult) ProtoReflect() protoreflect.Message

func (*TaskResult) Reset 

func (x *TaskResult) Reset()

func (*TaskResult) String 

func (x *TaskResult) String() string

type UnimplementedFlexServiceServer 

type UnimplementedFlexServiceServer struct {
}

UnimplementedFlexServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFlexServiceServer) CancelJob 

func (UnimplementedFlexServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)

func (UnimplementedFlexServiceServer) FetchPackage 

func (UnimplementedFlexServiceServer) FetchPackage(context.Context, *FetchPackageRequest) (*FetchPackageResponse, error)

func (UnimplementedFlexServiceServer) GetJob 

func (UnimplementedFlexServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)

func (UnimplementedFlexServiceServer) GetJobOutput 

func (UnimplementedFlexServiceServer) GetJobOutput(context.Context, *GetJobOutputRequest) (*GetJobOutputResponse, error)

func (UnimplementedFlexServiceServer) GetPackage 

func (UnimplementedFlexServiceServer) GetPackage(context.Context, *GetPackageRequest) (*GetPackageResponse, error)

func (UnimplementedFlexServiceServer) GetStats 

func (UnimplementedFlexServiceServer) GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)

func (UnimplementedFlexServiceServer) InsertPackage 

func (UnimplementedFlexServiceServer) InsertPackage(FlexService_InsertPackageServer) error

func (UnimplementedFlexServiceServer) ListFlexlets 

func (UnimplementedFlexServiceServer) ListFlexlets(context.Context, *ListFlexletsRequest) (*ListFlexletsResponse, error)

func (UnimplementedFlexServiceServer) ListJobs 

func (UnimplementedFlexServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

func (UnimplementedFlexServiceServer) ListTags 

func (UnimplementedFlexServiceServer) ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error)

func (UnimplementedFlexServiceServer) SubmitJob 

func (UnimplementedFlexServiceServer) SubmitJob(context.Context, *SubmitJobRequest) (*SubmitJobResponse, error)

func (UnimplementedFlexServiceServer) UpdateJobLabels 

func (UnimplementedFlexServiceServer) UpdateJobLabels(context.Context, *UpdateJobLabelsRequest) (*UpdateJobLabelsResponse, error)

func (UnimplementedFlexServiceServer) UpdateTag 

func (UnimplementedFlexServiceServer) UpdateTag(context.Context, *UpdateTagRequest) (*UpdateTagResponse, error)

type UnsafeFlexServiceServer 

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

UnsafeFlexServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlexServiceServer will result in compilation errors.

type UpdateJobLabelsRequest 

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
}

func (*UpdateJobLabelsRequest) Descriptor deprecated 

func (*UpdateJobLabelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateJobLabelsRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobLabelsRequest) GetAdds 

func (x *UpdateJobLabelsRequest) GetAdds() []string

func (*UpdateJobLabelsRequest) GetDels 

func (x *UpdateJobLabelsRequest) GetDels() []string

func (*UpdateJobLabelsRequest) GetId 

func (x *UpdateJobLabelsRequest) GetId() int64

func (*UpdateJobLabelsRequest) ProtoMessage 

func (*UpdateJobLabelsRequest) ProtoMessage()

func (*UpdateJobLabelsRequest) ProtoReflect 

func (x *UpdateJobLabelsRequest) ProtoReflect() protoreflect.Message

func (*UpdateJobLabelsRequest) Reset 

func (x *UpdateJobLabelsRequest) Reset()

func (*UpdateJobLabelsRequest) String 

func (x *UpdateJobLabelsRequest) String() string

type UpdateJobLabelsResponse 

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

func (*UpdateJobLabelsResponse) Descriptor deprecated 

func (*UpdateJobLabelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateJobLabelsResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobLabelsResponse) ProtoMessage 

func (*UpdateJobLabelsResponse) ProtoMessage()

func (*UpdateJobLabelsResponse) ProtoReflect 

func (x *UpdateJobLabelsResponse) ProtoReflect() protoreflect.Message

func (*UpdateJobLabelsResponse) Reset 

func (x *UpdateJobLabelsResponse) Reset()

func (*UpdateJobLabelsResponse) String 

func (x *UpdateJobLabelsResponse) String() string

type UpdateTagRequest 

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

func (*UpdateTagRequest) Descriptor deprecated 

func (*UpdateTagRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTagRequest.ProtoReflect.Descriptor instead.

func (*UpdateTagRequest) GetTag 

func (x *UpdateTagRequest) GetTag() *Tag

func (*UpdateTagRequest) ProtoMessage 

func (*UpdateTagRequest) ProtoMessage()

func (*UpdateTagRequest) ProtoReflect 

func (x *UpdateTagRequest) ProtoReflect() protoreflect.Message

func (*UpdateTagRequest) Reset 

func (x *UpdateTagRequest) Reset()

func (*UpdateTagRequest) String 

func (x *UpdateTagRequest) String() string

type UpdateTagResponse 

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

func (*UpdateTagResponse) Descriptor deprecated 

func (*UpdateTagResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTagResponse.ProtoReflect.Descriptor instead.

func (*UpdateTagResponse) ProtoMessage 

func (*UpdateTagResponse) ProtoMessage()

func (*UpdateTagResponse) ProtoReflect 

func (x *UpdateTagResponse) ProtoReflect() protoreflect.Message

func (*UpdateTagResponse) Reset 

func (x *UpdateTagResponse) Reset()

func (*UpdateTagResponse) String 

func (x *UpdateTagResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
cmd
flex
flex/internal/detar
flex/internal/formatter
flexbot
flexhub
flexhub/internal/database
flexhub/internal/filestorage
flexhub/internal/restfix
flexhub/internal/server
flexhub/internal/waitqueue
flexlet
flexlet/internal/filecache
flexlet/internal/flexlet
flexlet/internal/run
loadtest
testfs
internal
concurrent
ctxutil
flexletpb
grpcutil
hashutil
pubsub

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.