types

type AgentToolchainInfo struct {
	Kind     string   `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
	Target   string   `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"`
	Versions []string `protobuf:"bytes,3,rep,name=Versions,proto3" json:"Versions,omitempty"`
	// contains filtered or unexported fields
}

type AgentToolchainInfoList struct {
	Info []*AgentToolchainInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

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

type BucketList struct {
	Buckets []*Bucket `protobuf:"bytes,1,rep,name=Buckets,proto3" json:"Buckets,omitempty"`
	// contains filtered or unexported fields
}

type CacheClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*Empty, error)
	Pull(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (*CacheObject, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Cache_SyncClient, error)
}

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

type CacheObject struct {
	Data     []byte           `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	Metadata *CacheObjectMeta `protobuf:"bytes,2,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	// contains filtered or unexported fields
}

type CacheObjectManaged struct {
	Size      int64           `protobuf:"varint,1,opt,name=Size,proto3" json:"Size,omitempty"`
	Timestamp int64           `protobuf:"varint,2,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Score     int64           `protobuf:"varint,3,opt,name=Score,proto3" json:"Score,omitempty"`
	Location  StorageLocation `protobuf:"varint,5,opt,name=Location,proto3,enum=types.StorageLocation" json:"Location,omitempty"`
	// contains filtered or unexported fields
}

type CacheObjectMeta struct {
	Tags           map[string]string   `` /* 149-byte string literal not displayed */
	ExpirationDate int64               `protobuf:"varint,4,opt,name=ExpirationDate,proto3" json:"ExpirationDate,omitempty"`
	ManagedFields  *CacheObjectManaged `protobuf:"bytes,5,opt,name=ManagedFields,proto3" json:"ManagedFields,omitempty"`
	// contains filtered or unexported fields
}

type CacheServer interface {
	Push(context.Context, *PushRequest) (*Empty, error)
	Pull(context.Context, *PullRequest) (*CacheObject, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	Sync(*SyncRequest, Cache_SyncServer) error
	// contains filtered or unexported methods
}

type Cache_SyncClient interface {
	Recv() (*CacheObject, error)
	grpc.ClientStream
}

type Cache_SyncServer interface {
	Send(*CacheObject) error
	grpc.ServerStream
}

type CompileRequest struct {
	RequestID          string                 `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Toolchain          *Toolchain             `protobuf:"bytes,2,opt,name=Toolchain,proto3" json:"Toolchain,omitempty"`
	Args               []string               `protobuf:"bytes,3,rep,name=Args,proto3" json:"Args,omitempty"`
	PreprocessedSource []byte                 `protobuf:"bytes,4,opt,name=PreprocessedSource,proto3" json:"PreprocessedSource,omitempty"`
	ManagedFields      *CompileRequestManaged `protobuf:"bytes,5,opt,name=ManagedFields,proto3" json:"ManagedFields,omitempty"`
	// contains filtered or unexported fields
}

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

type CompileResponse struct {
	RequestID      string                 `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	CompileResult  CompileResponse_Result `protobuf:"varint,2,opt,name=CompileResult,proto3,enum=types.CompileResponse_Result" json:"CompileResult,omitempty"`
	CpuSecondsUsed int64                  `protobuf:"varint,3,opt,name=CpuSecondsUsed,proto3" json:"CpuSecondsUsed,omitempty"`
	// Types that are assignable to Data:
	//	*CompileResponse_Error
	//	*CompileResponse_CompiledSource
	//	*CompileResponse_RetryAction
	Data isCompileResponse_Data `protobuf_oneof:"Data"`
	// contains filtered or unexported fields
}

type CompileResponse_CompiledSource struct {
	CompiledSource []byte `protobuf:"bytes,5,opt,name=CompiledSource,proto3,oneof"`
}

type CompileResponse_Error struct {
	Error string `protobuf:"bytes,4,opt,name=Error,proto3,oneof"`
}

type CompileResponse_Result int32

type CompileResponse_RetryAction struct {
	RetryAction RetryAction `protobuf:"varint,6,opt,name=RetryAction,proto3,enum=types.RetryAction,oneof"`
}

type Component int32

type ConsumerdClient interface {
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	GetToolchains(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ToolchainList, error)
}

type ConsumerdServer interface {
	Run(context.Context, *RunRequest) (*RunResponse, error)
	GetToolchains(context.Context, *Empty) (*ToolchainList, error)
	// contains filtered or unexported methods
}

type ElideLocation int

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

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

type KeyList struct {
	Keys []*Key `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	// contains filtered or unexported fields
}

type Metric struct {
	Key   *Key       `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value *anypb.Any `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

type MonitorClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (Monitor_StreamClient, error)
	GetMetric(ctx context.Context, in *Key, opts ...grpc.CallOption) (*Metric, error)
	GetBuckets(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BucketList, error)
	GetKeys(ctx context.Context, in *Bucket, opts ...grpc.CallOption) (*KeyList, error)
	Listen(ctx context.Context, in *Key, opts ...grpc.CallOption) (Monitor_ListenClient, error)
	Whois(ctx context.Context, in *WhoisRequest, opts ...grpc.CallOption) (*WhoisResponse, error)
}

type MonitorServer interface {
	Stream(Monitor_StreamServer) error
	GetMetric(context.Context, *Key) (*Metric, error)
	GetBuckets(context.Context, *Empty) (*BucketList, error)
	GetKeys(context.Context, *Bucket) (*KeyList, error)
	Listen(*Key, Monitor_ListenServer) error
	Whois(context.Context, *WhoisRequest) (*WhoisResponse, error)
	// contains filtered or unexported methods
}

type Monitor_ListenClient interface {
	Recv() (*anypb.Any, error)
	grpc.ClientStream
}

type Monitor_ListenServer interface {
	Send(*anypb.Any) error
	grpc.ServerStream
}

type Monitor_StreamClient interface {
	Send(*Metric) error
	Recv() (*Empty, error)
	grpc.ClientStream
}

type Monitor_StreamServer interface {
	Send(*Empty) error
	Recv() (*Metric, error)
	grpc.ServerStream
}

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

type PushRequest struct {
	Key    *CacheKey    `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Object *CacheObject `protobuf:"bytes,2,opt,name=Object,proto3" json:"Object,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Keys []*CacheKey `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	Results []*CacheObjectMeta `protobuf:"bytes,1,rep,name=Results,proto3" json:"Results,omitempty"`
	// contains filtered or unexported fields
}

type RetryAction int32

type Route struct {
	Toolchain  *Toolchain `protobuf:"bytes,1,opt,name=Toolchain,proto3" json:"Toolchain,omitempty"`
	Consumerds []string   `protobuf:"bytes,2,rep,name=Consumerds,proto3" json:"Consumerds,omitempty"`
	Agents     []string   `protobuf:"bytes,3,rep,name=Agents,proto3" json:"Agents,omitempty"`
	// contains filtered or unexported fields
}

type RouteList struct {
	Routes []*Route `protobuf:"bytes,1,rep,name=Routes,proto3" json:"Routes,omitempty"`
	// contains filtered or unexported fields
}

type RunRequest struct {

	// Types that are assignable to Compiler:
	//	*RunRequest_Path
	//	*RunRequest_Toolchain
	Compiler isRunRequest_Compiler `protobuf_oneof:"Compiler"`
	Args     []string              `protobuf:"bytes,3,rep,name=Args,proto3" json:"Args,omitempty"`
	UID      uint32                `protobuf:"varint,4,opt,name=UID,proto3" json:"UID,omitempty"`
	GID      uint32                `protobuf:"varint,5,opt,name=GID,proto3" json:"GID,omitempty"`
	WorkDir  string                `protobuf:"bytes,6,opt,name=WorkDir,proto3" json:"WorkDir,omitempty"`
	Env      []string              `protobuf:"bytes,7,rep,name=Env,proto3" json:"Env,omitempty"`
	Stdin    []byte                `protobuf:"bytes,8,opt,name=Stdin,proto3" json:"Stdin,omitempty"`
	// contains filtered or unexported fields
}

type RunRequest_Path struct {
	Path string `protobuf:"bytes,1,opt,name=Path,proto3,oneof"`
}

type RunRequest_Toolchain struct {
	Toolchain *Toolchain `protobuf:"bytes,2,opt,name=Toolchain,proto3,oneof"`
}

type RunResponse struct {
	ReturnCode int32  `protobuf:"varint,1,opt,name=ReturnCode,proto3" json:"ReturnCode,omitempty"`
	Stdout     []byte `protobuf:"bytes,2,opt,name=Stdout,proto3" json:"Stdout,omitempty"`
	Stderr     []byte `protobuf:"bytes,3,opt,name=Stderr,proto3" json:"Stderr,omitempty"`
	// contains filtered or unexported fields
}

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

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

type SchedulerClient interface {
	Compile(ctx context.Context, in *CompileRequest, opts ...grpc.CallOption) (*CompileResponse, error)
	StreamIncomingTasks(ctx context.Context, opts ...grpc.CallOption) (Scheduler_StreamIncomingTasksClient, error)
	StreamOutgoingTasks(ctx context.Context, opts ...grpc.CallOption) (Scheduler_StreamOutgoingTasksClient, error)
	GetRoutes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RouteList, error)
}

type SchedulerServer interface {
	Compile(context.Context, *CompileRequest) (*CompileResponse, error)
	StreamIncomingTasks(Scheduler_StreamIncomingTasksServer) error
	StreamOutgoingTasks(Scheduler_StreamOutgoingTasksServer) error
	GetRoutes(context.Context, *Empty) (*RouteList, error)
	// contains filtered or unexported methods
}

type Scheduler_StreamIncomingTasksClient interface {
	Send(*CompileResponse) error
	Recv() (*CompileRequest, error)
	grpc.ClientStream
}

type Scheduler_StreamIncomingTasksServer interface {
	Send(*CompileRequest) error
	Recv() (*CompileResponse, error)
	grpc.ServerStream
}

type Scheduler_StreamOutgoingTasksClient interface {
	Send(*CompileRequest) error
	Recv() (*CompileResponse, error)
	grpc.ClientStream
}

type Scheduler_StreamOutgoingTasksServer interface {
	Send(*CompileResponse) error
	Recv() (*CompileRequest, error)
	grpc.ServerStream
}

type StorageLocation int32

type SyncRequest struct {
	LocalCache         []*CacheKey `protobuf:"bytes,1,rep,name=LocalCache,proto3" json:"LocalCache,omitempty"`
	DesiredCacheSizeKb int64       `protobuf:"varint,2,opt,name=DesiredCacheSizeKb,proto3" json:"DesiredCacheSizeKb,omitempty"`
	// contains filtered or unexported fields
}

type SystemInfo struct {
	Arch         string `protobuf:"bytes,1,opt,name=Arch,proto3" json:"Arch,omitempty"`
	CpuThreads   int32  `protobuf:"varint,2,opt,name=CpuThreads,proto3" json:"CpuThreads,omitempty"`
	SystemMemory uint64 `protobuf:"varint,3,opt,name=SystemMemory,proto3" json:"SystemMemory,omitempty"`
	Hostname     string `protobuf:"bytes,4,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	// contains filtered or unexported fields
}

type Toolchain struct {
	Kind       ToolchainKind `protobuf:"varint,1,opt,name=Kind,proto3,enum=types.ToolchainKind" json:"Kind,omitempty"`
	Lang       ToolchainLang `protobuf:"varint,2,opt,name=Lang,proto3,enum=types.ToolchainLang" json:"Lang,omitempty"`
	Executable string        `protobuf:"bytes,3,opt,name=Executable,proto3" json:"Executable,omitempty"`
	TargetArch string        `protobuf:"bytes,4,opt,name=TargetArch,proto3" json:"TargetArch,omitempty"`
	Version    string        `protobuf:"bytes,5,opt,name=Version,proto3" json:"Version,omitempty"`
	PicDefault bool          `protobuf:"varint,6,opt,name=PicDefault,proto3" json:"PicDefault,omitempty"`
	PieDefault bool          `protobuf:"varint,7,opt,name=PieDefault,proto3" json:"PieDefault,omitempty"`
	// contains filtered or unexported fields
}

type ToolchainKind int32

type ToolchainLang int32

type ToolchainList struct {
	Items []*Toolchain `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCacheServer struct {
}

type UnimplementedConsumerdServer struct {
}

type UnimplementedMonitorServer struct {
}

type UnimplementedSchedulerServer struct {
}

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

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

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

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

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

type WhoisResponse struct {
	UUID      string    `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	Address   string    `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	Component Component `protobuf:"varint,3,opt,name=Component,proto3,enum=types.Component" json:"Component,omitempty"`
	// contains filtered or unexported fields
}