types

package
v0.0.0-...-211e212 Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2021 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Clang         = ToolchainKind_ToolchainKind_Clang
	Gnu           = ToolchainKind_ToolchainKind_Gnu
	TestToolchain = ToolchainKind_ToolchainKind_Test
	Sleep         = ToolchainKind_ToolchainKind_Sleep

	C     = ToolchainLang_ToolchainLang_C
	CXX   = ToolchainLang_ToolchainLang_CXX
	Multi = ToolchainLang_ToolchainLang_Multi

	Agent         = Component_Component_Agent
	Scheduler     = Component_Component_Scheduler
	Controller    = Component_Component_Controller
	Consumer      = Component_Component_Consumer
	Consumerd     = Component_Component_Consumerd
	Make          = Component_Component_Make
	CLI           = Component_Component_CLI
	Dashboard     = Component_Component_Dashboard
	Monitor       = Component_Component_Monitor
	Cache         = Component_Component_Cache
	TestComponent = Component_Component_Test

	Unknown = StorageLocation_StorageLocation_Unknown
	Memory  = StorageLocation_StorageLocation_Memory
	Disk    = StorageLocation_StorageLocation_Disk
	S3      = StorageLocation_StorageLocation_S3
)

Variables

View Source 
var (
	StorageLocation_name = map[int32]string{
		0: "StorageLocation_Unknown",
		1: "StorageLocation_Memory",
		2: "StorageLocation_Disk",
		3: "StorageLocation_S3",
	}
	StorageLocation_value = map[string]int32{
		"StorageLocation_Unknown": 0,
		"StorageLocation_Memory":  1,
		"StorageLocation_Disk":    2,
		"StorageLocation_S3":      3,
	}
)

Enum value maps for StorageLocation.

View Source 
var (
	Component_name = map[int32]string{
		0:  "Component_Unknown",
		1:  "Component_Agent",
		2:  "Component_Scheduler",
		3:  "Component_Controller",
		4:  "Component_Consumer",
		5:  "Component_Consumerd",
		6:  "Component_Make",
		7:  "Component_Test",
		8:  "Component_Dashboard",
		9:  "Component_CLI",
		10: "Component_Monitor",
		11: "Component_Cache",
	}
	Component_value = map[string]int32{
		"Component_Unknown":    0,
		"Component_Agent":      1,
		"Component_Scheduler":  2,
		"Component_Controller": 3,
		"Component_Consumer":   4,
		"Component_Consumerd":  5,
		"Component_Make":       6,
		"Component_Test":       7,
		"Component_Dashboard":  8,
		"Component_CLI":        9,
		"Component_Monitor":    10,
		"Component_Cache":      11,
	}
)

Enum value maps for Component.

View Source 
var (
	ToolchainKind_name = map[int32]string{
		0: "ToolchainKind_Unknown",
		1: "ToolchainKind_Gnu",
		2: "ToolchainKind_Clang",
		3: "ToolchainKind_Test",
		4: "ToolchainKind_Sleep",
	}
	ToolchainKind_value = map[string]int32{
		"ToolchainKind_Unknown": 0,
		"ToolchainKind_Gnu":     1,
		"ToolchainKind_Clang":   2,
		"ToolchainKind_Test":    3,
		"ToolchainKind_Sleep":   4,
	}
)

Enum value maps for ToolchainKind.

View Source 
var (
	ToolchainLang_name = map[int32]string{
		0: "ToolchainLang_Unknown",
		1: "ToolchainLang_C",
		2: "ToolchainLang_CXX",
		3: "ToolchainLang_Multi",
	}
	ToolchainLang_value = map[string]int32{
		"ToolchainLang_Unknown": 0,
		"ToolchainLang_C":       1,
		"ToolchainLang_CXX":     2,
		"ToolchainLang_Multi":   3,
	}
)

Enum value maps for ToolchainLang.

View Source 
var (
	RetryAction_name = map[int32]string{
		0: "RetryAction_Unknown",
		1: "Retry",
		2: "DoNotRetry",
	}
	RetryAction_value = map[string]int32{
		"RetryAction_Unknown": 0,
		"Retry":               1,
		"DoNotRetry":          2,
	}
)

Enum value maps for RetryAction.

View Source 
var (
	CompileResponse_Result_name = map[int32]string{
		0: "Success",
		1: "Fail",
		2: "InternalError",
		3: "Defunct",
		4: "Retry",
	}
	CompileResponse_Result_value = map[string]int32{
		"Success":       0,
		"Fail":          1,
		"InternalError": 2,
		"Defunct":       3,
		"Retry":         4,
	}
)

Enum value maps for CompileResponse_Result.

View Source 
var Cache_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "types.Cache",
	HandlerType: (*CacheServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Push",
			Handler:    _Cache_Push_Handler,
		},
		{
			MethodName: "Pull",
			Handler:    _Cache_Pull_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _Cache_Query_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Cache_Sync_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/types/types.proto",
}

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

View Source 
var Consumerd_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "types.Consumerd",
	HandlerType: (*ConsumerdServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Run",
			Handler:    _Consumerd_Run_Handler,
		},
		{
			MethodName: "GetToolchains",
			Handler:    _Consumerd_GetToolchains_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/types/types.proto",
}

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

View Source 
var (
	ErrInvalidFormat = errors.New("Invalid key format, should be of the form bucket.name")
)
View Source 
var File_pkg_types_types_proto protoreflect.FileDescriptor
View Source 
var Monitor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "types.Monitor",
	HandlerType: (*MonitorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMetric",
			Handler:    _Monitor_GetMetric_Handler,
		},
		{
			MethodName: "GetBuckets",
			Handler:    _Monitor_GetBuckets_Handler,
		},
		{
			MethodName: "GetKeys",
			Handler:    _Monitor_GetKeys_Handler,
		},
		{
			MethodName: "Whois",
			Handler:    _Monitor_Whois_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _Monitor_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _Monitor_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/types/types.proto",
}

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

View Source 
var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "types.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Compile",
			Handler:    _Scheduler_Compile_Handler,
		},
		{
			MethodName: "GetRoutes",
			Handler:    _Scheduler_GetRoutes_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamIncomingTasks",
			Handler:       _Scheduler_StreamIncomingTasks_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamOutgoingTasks",
			Handler:       _Scheduler_StreamOutgoingTasks_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/types/types.proto",
}

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

Functions

func FormatShortID 

func FormatShortID(id string, length int, elide ElideLocation) string

FormatShortID formats the given UUID to a specified length with added text elision ('..') in the desired location.

func NewStringSliceEncoder 

func NewStringSliceEncoder(slice []string) stringSliceEncoder

func RegisterCacheServer 

func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)

func RegisterConsumerdServer 

func RegisterConsumerdServer(s grpc.ServiceRegistrar, srv ConsumerdServer)

func RegisterMonitorServer 

func RegisterMonitorServer(s grpc.ServiceRegistrar, srv MonitorServer)

func RegisterSchedulerServer 

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

func ShortID 

func ShortID(uuid string) zapcore.Field

ShortID returns a zap field for a UUID.

Types

type AgentToolchainInfo 

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
}

func (*AgentToolchainInfo) Descriptor deprecated 

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

Deprecated: Use AgentToolchainInfo.ProtoReflect.Descriptor instead.

func (*AgentToolchainInfo) GetKind 

func (x *AgentToolchainInfo) GetKind() string

func (*AgentToolchainInfo) GetTarget 

func (x *AgentToolchainInfo) GetTarget() string

func (*AgentToolchainInfo) GetVersions 

func (x *AgentToolchainInfo) GetVersions() []string

func (*AgentToolchainInfo) ProtoMessage 

func (*AgentToolchainInfo) ProtoMessage()

func (*AgentToolchainInfo) ProtoReflect 

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

func (*AgentToolchainInfo) Reset 

func (x *AgentToolchainInfo) Reset()

func (*AgentToolchainInfo) String 

func (x *AgentToolchainInfo) String() string

type AgentToolchainInfoList 

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

func (*AgentToolchainInfoList) Descriptor deprecated 

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

Deprecated: Use AgentToolchainInfoList.ProtoReflect.Descriptor instead.

func (*AgentToolchainInfoList) GetInfo 

func (x *AgentToolchainInfoList) GetInfo() []*AgentToolchainInfo

func (*AgentToolchainInfoList) ProtoMessage 

func (*AgentToolchainInfoList) ProtoMessage()

func (*AgentToolchainInfoList) ProtoReflect 

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

func (*AgentToolchainInfoList) Reset 

func (x *AgentToolchainInfoList) Reset()

func (*AgentToolchainInfoList) String 

func (x *AgentToolchainInfoList) String() string

type Bucket 

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

func (*Bucket) Descriptor deprecated 

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

Deprecated: Use Bucket.ProtoReflect.Descriptor instead.

func (*Bucket) GetName 

func (x *Bucket) GetName() string

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) ProtoReflect 

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

func (*Bucket) Reset 

func (x *Bucket) Reset()

func (*Bucket) String 

func (x *Bucket) String() string

type BucketList 

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

func (*BucketList) Descriptor deprecated 

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

Deprecated: Use BucketList.ProtoReflect.Descriptor instead.

func (*BucketList) GetBuckets 

func (x *BucketList) GetBuckets() []*Bucket

func (*BucketList) ProtoMessage 

func (*BucketList) ProtoMessage()

func (*BucketList) ProtoReflect 

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

func (*BucketList) Reset 

func (x *BucketList) Reset()

func (*BucketList) String 

func (x *BucketList) String() string

type CacheClient 

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

CacheClient is the client API for Cache 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 NewCacheClient 

func NewCacheClient(cc grpc.ClientConnInterface) CacheClient

type CacheKey 

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

func (*CacheKey) Descriptor deprecated 

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

Deprecated: Use CacheKey.ProtoReflect.Descriptor instead.

func (*CacheKey) GetHash 

func (x *CacheKey) GetHash() string

func (*CacheKey) ProtoMessage 

func (*CacheKey) ProtoMessage()

func (*CacheKey) ProtoReflect 

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

func (*CacheKey) Reset 

func (x *CacheKey) Reset()

func (*CacheKey) String 

func (x *CacheKey) String() string

type CacheObject 

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
}

func (*CacheObject) Descriptor deprecated 

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

Deprecated: Use CacheObject.ProtoReflect.Descriptor instead.

func (*CacheObject) GetData 

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

func (*CacheObject) GetMetadata 

func (x *CacheObject) GetMetadata() *CacheObjectMeta

func (*CacheObject) ProtoMessage 

func (*CacheObject) ProtoMessage()

func (*CacheObject) ProtoReflect 

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

func (*CacheObject) Reset 

func (x *CacheObject) Reset()

func (*CacheObject) String 

func (x *CacheObject) String() string

type CacheObjectManaged 

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
}

func (*CacheObjectManaged) Descriptor deprecated 

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

Deprecated: Use CacheObjectManaged.ProtoReflect.Descriptor instead.

func (*CacheObjectManaged) GetLocation 

func (x *CacheObjectManaged) GetLocation() StorageLocation

func (*CacheObjectManaged) GetScore 

func (x *CacheObjectManaged) GetScore() int64

func (*CacheObjectManaged) GetSize 

func (x *CacheObjectManaged) GetSize() int64

func (*CacheObjectManaged) GetTimestamp 

func (x *CacheObjectManaged) GetTimestamp() int64

func (*CacheObjectManaged) ProtoMessage 

func (*CacheObjectManaged) ProtoMessage()

func (*CacheObjectManaged) ProtoReflect 

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

func (*CacheObjectManaged) Reset 

func (x *CacheObjectManaged) Reset()

func (*CacheObjectManaged) String 

func (x *CacheObjectManaged) String() string

type CacheObjectMeta 

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
}

func (*CacheObjectMeta) Descriptor deprecated 

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

Deprecated: Use CacheObjectMeta.ProtoReflect.Descriptor instead.

func (*CacheObjectMeta) GetExpirationDate 

func (x *CacheObjectMeta) GetExpirationDate() int64

func (*CacheObjectMeta) GetManagedFields 

func (x *CacheObjectMeta) GetManagedFields() *CacheObjectManaged

func (*CacheObjectMeta) GetTags 

func (x *CacheObjectMeta) GetTags() map[string]string

func (*CacheObjectMeta) ProtoMessage 

func (*CacheObjectMeta) ProtoMessage()

func (*CacheObjectMeta) ProtoReflect 

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

func (*CacheObjectMeta) Reset 

func (x *CacheObjectMeta) Reset()

func (*CacheObjectMeta) String 

func (x *CacheObjectMeta) String() string

type CacheServer 

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
}

CacheServer is the server API for Cache service. All implementations must embed UnimplementedCacheServer for forward compatibility

type Cache_SyncClient 

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

type Cache_SyncServer 

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

type CompileRequest 

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
}

func (*CompileRequest) Descriptor deprecated 

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

Deprecated: Use CompileRequest.ProtoReflect.Descriptor instead.

func (*CompileRequest) GetArgs 

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

func (*CompileRequest) GetManagedFields 

func (x *CompileRequest) GetManagedFields() *CompileRequestManaged

func (*CompileRequest) GetPreprocessedSource 

func (x *CompileRequest) GetPreprocessedSource() []byte

func (*CompileRequest) GetRequestID 

func (x *CompileRequest) GetRequestID() string

func (*CompileRequest) GetToolchain 

func (x *CompileRequest) GetToolchain() *Toolchain

func (*CompileRequest) Hash 

func (req *CompileRequest) Hash(hasher md5simd.Hasher)

func (*CompileRequest) ProtoMessage 

func (*CompileRequest) ProtoMessage()

func (*CompileRequest) ProtoReflect 

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

func (*CompileRequest) Reset 

func (x *CompileRequest) Reset()

func (*CompileRequest) String 

func (x *CompileRequest) String() string

type CompileRequestManaged 

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

func (*CompileRequestManaged) Descriptor deprecated 

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

Deprecated: Use CompileRequestManaged.ProtoReflect.Descriptor instead.

func (*CompileRequestManaged) GetComputedHash 

func (x *CompileRequestManaged) GetComputedHash() string

func (*CompileRequestManaged) ProtoMessage 

func (*CompileRequestManaged) ProtoMessage()

func (*CompileRequestManaged) ProtoReflect 

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

func (*CompileRequestManaged) Reset 

func (x *CompileRequestManaged) Reset()

func (*CompileRequestManaged) String 

func (x *CompileRequestManaged) String() string

type CompileResponse 

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
}

func (*CompileResponse) Descriptor deprecated 

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

Deprecated: Use CompileResponse.ProtoReflect.Descriptor instead.

func (*CompileResponse) GetCompileResult 

func (x *CompileResponse) GetCompileResult() CompileResponse_Result

func (*CompileResponse) GetCompiledSource 

func (x *CompileResponse) GetCompiledSource() []byte

func (*CompileResponse) GetCpuSecondsUsed 

func (x *CompileResponse) GetCpuSecondsUsed() int64

func (*CompileResponse) GetData 

func (m *CompileResponse) GetData() isCompileResponse_Data

func (*CompileResponse) GetError 

func (x *CompileResponse) GetError() string

func (*CompileResponse) GetRequestID 

func (x *CompileResponse) GetRequestID() string

func (*CompileResponse) GetRetryAction 

func (x *CompileResponse) GetRetryAction() RetryAction

func (*CompileResponse) MarshalLogObject 

func (r *CompileResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CompileResponse) ProtoMessage 

func (*CompileResponse) ProtoMessage()

func (*CompileResponse) ProtoReflect 

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

func (*CompileResponse) Reset 

func (x *CompileResponse) Reset()

func (*CompileResponse) String 

func (x *CompileResponse) String() string

type CompileResponse_CompiledSource 

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

type CompileResponse_Error 

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

type CompileResponse_Result 

type CompileResponse_Result int32
const (
	CompileResponse_Success       CompileResponse_Result = 0
	CompileResponse_Fail          CompileResponse_Result = 1
	CompileResponse_InternalError CompileResponse_Result = 2
	CompileResponse_Defunct       CompileResponse_Result = 3
	CompileResponse_Retry         CompileResponse_Result = 4
)

func (CompileResponse_Result) Descriptor 

func (CompileResponse_Result) Descriptor() protoreflect.EnumDescriptor

func (CompileResponse_Result) Enum 

func (x CompileResponse_Result) Enum() *CompileResponse_Result

func (CompileResponse_Result) EnumDescriptor deprecated 

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

Deprecated: Use CompileResponse_Result.Descriptor instead.

func (CompileResponse_Result) Number 

func (x CompileResponse_Result) Number() protoreflect.EnumNumber

func (CompileResponse_Result) String 

func (x CompileResponse_Result) String() string

func (CompileResponse_Result) Type 

func (CompileResponse_Result) Type() protoreflect.EnumType

type CompileResponse_RetryAction 

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

type Component 

type Component int32
const (
	Component_Component_Unknown    Component = 0
	Component_Component_Agent      Component = 1
	Component_Component_Scheduler  Component = 2
	Component_Component_Controller Component = 3
	Component_Component_Consumer   Component = 4
	Component_Component_Consumerd  Component = 5
	Component_Component_Make       Component = 6
	Component_Component_Test       Component = 7
	Component_Component_Dashboard  Component = 8
	Component_Component_CLI        Component = 9
	Component_Component_Monitor    Component = 10
	Component_Component_Cache      Component = 11
)

func (Component) Color 

func (c Component) Color() zapkc.Color

Color returns a color for the component, suitable for logging.

func (Component) Descriptor 

func (Component) Descriptor() protoreflect.EnumDescriptor

func (Component) Enum 

func (x Component) Enum() *Component

func (Component) EnumDescriptor deprecated 

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

Deprecated: Use Component.Descriptor instead.

func (Component) Name 

func (c Component) Name() string

Name returns the title-case component name.

func (Component) Number 

func (x Component) Number() protoreflect.EnumNumber

func (Component) ShortName 

func (c Component) ShortName() string

ShortName returns a lowercase, truncated name suitable for logging.

func (Component) String 

func (x Component) String() string

func (Component) Type 

func (Component) Type() protoreflect.EnumType

type ConsumerdClient 

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

ConsumerdClient is the client API for Consumerd 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 NewConsumerdClient 

func NewConsumerdClient(cc grpc.ClientConnInterface) ConsumerdClient

type ConsumerdServer 

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

ConsumerdServer is the server API for Consumerd service. All implementations must embed UnimplementedConsumerdServer for forward compatibility

type ElideLocation 

type ElideLocation int
const (
	ElideCenter ElideLocation = iota
	ElideLeft
	ElideRight
)

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Key 

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
}

func ParseKey 

func ParseKey(canonical string) (*Key, error)

func (*Key) Canonical 

func (k *Key) Canonical() string

Canonical returns a string identifying the key with the associated bucket.

func (*Key) Descriptor deprecated 

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

Deprecated: Use Key.ProtoReflect.Descriptor instead.

func (*Key) GetBucket 

func (x *Key) GetBucket() string

func (*Key) GetName 

func (x *Key) GetName() string

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) ProtoReflect 

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

func (*Key) Reset 

func (x *Key) Reset()

func (*Key) ShortID 

func (k *Key) ShortID() string

func (*Key) String 

func (x *Key) String() string

type KeyList 

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

func (*KeyList) Descriptor deprecated 

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

Deprecated: Use KeyList.ProtoReflect.Descriptor instead.

func (*KeyList) GetKeys 

func (x *KeyList) GetKeys() []*Key

func (*KeyList) ProtoMessage 

func (*KeyList) ProtoMessage()

func (*KeyList) ProtoReflect 

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

func (*KeyList) Reset 

func (x *KeyList) Reset()

func (*KeyList) String 

func (x *KeyList) String() string

type Metric 

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
}

func (*Metric) Descriptor deprecated 

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetKey 

func (x *Metric) GetKey() *Key

func (*Metric) GetValue 

func (x *Metric) GetValue() *anypb.Any

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type MonitorClient 

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

MonitorClient is the client API for Monitor 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 NewMonitorClient 

func NewMonitorClient(cc grpc.ClientConnInterface) MonitorClient

type MonitorServer 

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
}

MonitorServer is the server API for Monitor service. All implementations must embed UnimplementedMonitorServer for forward compatibility

type Monitor_ListenClient 

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

type Monitor_ListenServer 

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

type Monitor_StreamClient 

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

type Monitor_StreamServer 

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

type PullRequest 

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

func (*PullRequest) Descriptor deprecated 

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

Deprecated: Use PullRequest.ProtoReflect.Descriptor instead.

func (*PullRequest) GetKey 

func (x *PullRequest) GetKey() *CacheKey

func (*PullRequest) ProtoMessage 

func (*PullRequest) ProtoMessage()

func (*PullRequest) ProtoReflect 

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

func (*PullRequest) Reset 

func (x *PullRequest) Reset()

func (*PullRequest) String 

func (x *PullRequest) String() string

type PushRequest 

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
}

func (*PushRequest) Descriptor deprecated 

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) GetKey 

func (x *PushRequest) GetKey() *CacheKey

func (*PushRequest) GetObject 

func (x *PushRequest) GetObject() *CacheObject

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect 

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

func (*PushRequest) Reset 

func (x *PushRequest) Reset()

func (*PushRequest) String 

func (x *PushRequest) String() string

type QueryRequest 

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

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetKeys 

func (x *QueryRequest) GetKeys() []*CacheKey

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

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

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetResults 

func (x *QueryResponse) GetResults() []*CacheObjectMeta

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type RetryAction 

type RetryAction int32
const (
	RetryAction_RetryAction_Unknown RetryAction = 0
	RetryAction_Retry               RetryAction = 1
	RetryAction_DoNotRetry          RetryAction = 2
)

func (RetryAction) Descriptor 

func (RetryAction) Descriptor() protoreflect.EnumDescriptor

func (RetryAction) Enum 

func (x RetryAction) Enum() *RetryAction

func (RetryAction) EnumDescriptor deprecated 

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

Deprecated: Use RetryAction.Descriptor instead.

func (RetryAction) Number 

func (x RetryAction) Number() protoreflect.EnumNumber

func (RetryAction) String 

func (x RetryAction) String() string

func (RetryAction) Type 

func (RetryAction) Type() protoreflect.EnumType

type Route 

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
}

func (*Route) Descriptor deprecated 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetAgents 

func (x *Route) GetAgents() []string

func (*Route) GetConsumerds 

func (x *Route) GetConsumerds() []string

func (*Route) GetToolchain 

func (x *Route) GetToolchain() *Toolchain

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

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

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

type RouteList 

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

func (*RouteList) Descriptor deprecated 

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

Deprecated: Use RouteList.ProtoReflect.Descriptor instead.

func (*RouteList) GetRoutes 

func (x *RouteList) GetRoutes() []*Route

func (*RouteList) ProtoMessage 

func (*RouteList) ProtoMessage()

func (*RouteList) ProtoReflect 

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

func (*RouteList) Reset 

func (x *RouteList) Reset()

func (*RouteList) String 

func (x *RouteList) String() string

type RunRequest 

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
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetArgs 

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

func (*RunRequest) GetCompiler 

func (m *RunRequest) GetCompiler() isRunRequest_Compiler

func (*RunRequest) GetEnv 

func (x *RunRequest) GetEnv() []string

func (*RunRequest) GetGID 

func (x *RunRequest) GetGID() uint32

func (*RunRequest) GetPath 

func (x *RunRequest) GetPath() string

func (*RunRequest) GetStdin 

func (x *RunRequest) GetStdin() []byte

func (*RunRequest) GetToolchain 

func (x *RunRequest) GetToolchain() *Toolchain

func (*RunRequest) GetUID 

func (x *RunRequest) GetUID() uint32

func (*RunRequest) GetWorkDir 

func (x *RunRequest) GetWorkDir() string

func (*RunRequest) MarshalLogObject 

func (r *RunRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

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

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunRequest_Path 

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

type RunRequest_Toolchain 

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

type RunResponse 

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
}

func (*RunResponse) Descriptor deprecated 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetReturnCode 

func (x *RunResponse) GetReturnCode() int32

func (*RunResponse) GetStderr 

func (x *RunResponse) GetStderr() []byte

func (*RunResponse) GetStdout 

func (x *RunResponse) GetStdout() []byte

func (*RunResponse) MarshalLogObject 

func (r *RunResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect 

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

func (*RunResponse) Reset 

func (x *RunResponse) Reset()

func (*RunResponse) String 

func (x *RunResponse) String() string

type ScheduleRequest 

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

func (*ScheduleRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleRequest.ProtoReflect.Descriptor instead.

func (*ScheduleRequest) ProtoMessage 

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) ProtoReflect 

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

func (*ScheduleRequest) Reset 

func (x *ScheduleRequest) Reset()

func (*ScheduleRequest) String 

func (x *ScheduleRequest) String() string

type ScheduleResponse 

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

func (*ScheduleResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleResponse.ProtoReflect.Descriptor instead.

func (*ScheduleResponse) ProtoMessage 

func (*ScheduleResponse) ProtoMessage()

func (*ScheduleResponse) ProtoReflect 

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

func (*ScheduleResponse) Reset 

func (x *ScheduleResponse) Reset()

func (*ScheduleResponse) String 

func (x *ScheduleResponse) String() string

type SchedulerClient 

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

SchedulerClient is the client API for Scheduler 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 NewSchedulerClient 

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer 

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
}

SchedulerServer is the server API for Scheduler service. All implementations must embed UnimplementedSchedulerServer for forward compatibility

type Scheduler_StreamIncomingTasksClient 

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

type Scheduler_StreamIncomingTasksServer 

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

type Scheduler_StreamOutgoingTasksClient 

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

type Scheduler_StreamOutgoingTasksServer 

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

type StorageLocation 

type StorageLocation int32
const (
	StorageLocation_StorageLocation_Unknown StorageLocation = 0
	StorageLocation_StorageLocation_Memory  StorageLocation = 1
	StorageLocation_StorageLocation_Disk    StorageLocation = 2
	StorageLocation_StorageLocation_S3      StorageLocation = 3
)

func (StorageLocation) Descriptor 

func (StorageLocation) Descriptor() protoreflect.EnumDescriptor

func (StorageLocation) Enum 

func (x StorageLocation) Enum() *StorageLocation

func (StorageLocation) EnumDescriptor deprecated 

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

Deprecated: Use StorageLocation.Descriptor instead.

func (StorageLocation) Number 

func (x StorageLocation) Number() protoreflect.EnumNumber

func (StorageLocation) String 

func (x StorageLocation) String() string

func (StorageLocation) Type 

func (StorageLocation) Type() protoreflect.EnumType

type SyncRequest 

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
}

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetDesiredCacheSizeKb 

func (x *SyncRequest) GetDesiredCacheSizeKb() int64

func (*SyncRequest) GetLocalCache 

func (x *SyncRequest) GetLocalCache() []*CacheKey

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SystemInfo 

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
}

func (*SystemInfo) Descriptor deprecated 

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

Deprecated: Use SystemInfo.ProtoReflect.Descriptor instead.

func (*SystemInfo) GetArch 

func (x *SystemInfo) GetArch() string

func (*SystemInfo) GetCpuThreads 

func (x *SystemInfo) GetCpuThreads() int32

func (*SystemInfo) GetHostname 

func (x *SystemInfo) GetHostname() string

func (*SystemInfo) GetSystemMemory 

func (x *SystemInfo) GetSystemMemory() uint64

func (*SystemInfo) ProtoMessage 

func (*SystemInfo) ProtoMessage()

func (*SystemInfo) ProtoReflect 

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

func (*SystemInfo) Reset 

func (x *SystemInfo) Reset()

func (*SystemInfo) String 

func (x *SystemInfo) String() string

type Toolchain 

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
}

func (*Toolchain) CommonNames 

func (tc *Toolchain) CommonNames() []string

func (*Toolchain) Descriptor deprecated 

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

Deprecated: Use Toolchain.ProtoReflect.Descriptor instead.

func (*Toolchain) EquivalentTo 

func (tc *Toolchain) EquivalentTo(other *Toolchain) bool

EquivalentTo Compares all fields except executable, because the binaries can live in different locations on different systems.

func (*Toolchain) GetExecutable 

func (x *Toolchain) GetExecutable() string

func (*Toolchain) GetKind 

func (x *Toolchain) GetKind() ToolchainKind

func (*Toolchain) GetLang 

func (x *Toolchain) GetLang() ToolchainLang

func (*Toolchain) GetPicDefault 

func (x *Toolchain) GetPicDefault() bool

func (*Toolchain) GetPieDefault 

func (x *Toolchain) GetPieDefault() bool

func (*Toolchain) GetTargetArch 

func (x *Toolchain) GetTargetArch() string

func (*Toolchain) GetVersion 

func (x *Toolchain) GetVersion() string

func (*Toolchain) Hash 

func (tc *Toolchain) Hash(hasher md5simd.Hasher)

func (*Toolchain) ProtoMessage 

func (*Toolchain) ProtoMessage()

func (*Toolchain) ProtoReflect 

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

func (*Toolchain) Reset 

func (x *Toolchain) Reset()

func (*Toolchain) String 

func (x *Toolchain) String() string

type ToolchainKind 

type ToolchainKind int32
const (
	ToolchainKind_ToolchainKind_Unknown ToolchainKind = 0
	ToolchainKind_ToolchainKind_Gnu     ToolchainKind = 1
	ToolchainKind_ToolchainKind_Clang   ToolchainKind = 2
	ToolchainKind_ToolchainKind_Test    ToolchainKind = 3
	ToolchainKind_ToolchainKind_Sleep   ToolchainKind = 4
)

func (ToolchainKind) Descriptor 

func (ToolchainKind) Descriptor() protoreflect.EnumDescriptor

func (ToolchainKind) Enum 

func (x ToolchainKind) Enum() *ToolchainKind

func (ToolchainKind) EnumDescriptor deprecated 

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

Deprecated: Use ToolchainKind.Descriptor instead.

func (ToolchainKind) Number 

func (x ToolchainKind) Number() protoreflect.EnumNumber

func (ToolchainKind) String 

func (x ToolchainKind) String() string

func (ToolchainKind) Type 

func (ToolchainKind) Type() protoreflect.EnumType

type ToolchainLang 

type ToolchainLang int32
const (
	ToolchainLang_ToolchainLang_Unknown ToolchainLang = 0
	ToolchainLang_ToolchainLang_C       ToolchainLang = 1
	ToolchainLang_ToolchainLang_CXX     ToolchainLang = 2
	ToolchainLang_ToolchainLang_Multi   ToolchainLang = 3
)

func (ToolchainLang) Descriptor 

func (ToolchainLang) Descriptor() protoreflect.EnumDescriptor

func (ToolchainLang) Enum 

func (x ToolchainLang) Enum() *ToolchainLang

func (ToolchainLang) EnumDescriptor deprecated 

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

Deprecated: Use ToolchainLang.Descriptor instead.

func (ToolchainLang) Number 

func (x ToolchainLang) Number() protoreflect.EnumNumber

func (ToolchainLang) String 

func (x ToolchainLang) String() string

func (ToolchainLang) Type 

func (ToolchainLang) Type() protoreflect.EnumType

type ToolchainList 

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

func (*ToolchainList) Descriptor deprecated 

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

Deprecated: Use ToolchainList.ProtoReflect.Descriptor instead.

func (*ToolchainList) GetItems 

func (x *ToolchainList) GetItems() []*Toolchain

func (*ToolchainList) ProtoMessage 

func (*ToolchainList) ProtoMessage()

func (*ToolchainList) ProtoReflect 

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

func (*ToolchainList) Reset 

func (x *ToolchainList) Reset()

func (*ToolchainList) String 

func (x *ToolchainList) String() string

type UnimplementedCacheServer 

type UnimplementedCacheServer struct {
}

UnimplementedCacheServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheServer) Pull 

func (UnimplementedCacheServer) Pull(context.Context, *PullRequest) (*CacheObject, error)

func (UnimplementedCacheServer) Push 

func (UnimplementedCacheServer) Push(context.Context, *PushRequest) (*Empty, error)

func (UnimplementedCacheServer) Query 

func (UnimplementedCacheServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedCacheServer) Sync 

func (UnimplementedCacheServer) Sync(*SyncRequest, Cache_SyncServer) error

type UnimplementedConsumerdServer 

type UnimplementedConsumerdServer struct {
}

UnimplementedConsumerdServer must be embedded to have forward compatible implementations.

func (UnimplementedConsumerdServer) GetToolchains 

func (UnimplementedConsumerdServer) GetToolchains(context.Context, *Empty) (*ToolchainList, error)

func (UnimplementedConsumerdServer) Run 

func (UnimplementedConsumerdServer) Run(context.Context, *RunRequest) (*RunResponse, error)

type UnimplementedMonitorServer 

type UnimplementedMonitorServer struct {
}

UnimplementedMonitorServer must be embedded to have forward compatible implementations.

func (UnimplementedMonitorServer) GetBuckets 

func (UnimplementedMonitorServer) GetBuckets(context.Context, *Empty) (*BucketList, error)

func (UnimplementedMonitorServer) GetKeys 

func (UnimplementedMonitorServer) GetKeys(context.Context, *Bucket) (*KeyList, error)

func (UnimplementedMonitorServer) GetMetric 

func (UnimplementedMonitorServer) GetMetric(context.Context, *Key) (*Metric, error)

func (UnimplementedMonitorServer) Listen 

func (UnimplementedMonitorServer) Listen(*Key, Monitor_ListenServer) error

func (UnimplementedMonitorServer) Stream 

func (UnimplementedMonitorServer) Stream(Monitor_StreamServer) error

func (UnimplementedMonitorServer) Whois 

func (UnimplementedMonitorServer) Whois(context.Context, *WhoisRequest) (*WhoisResponse, error)

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) Compile 

func (UnimplementedSchedulerServer) Compile(context.Context, *CompileRequest) (*CompileResponse, error)

func (UnimplementedSchedulerServer) GetRoutes 

func (UnimplementedSchedulerServer) GetRoutes(context.Context, *Empty) (*RouteList, error)

func (UnimplementedSchedulerServer) StreamIncomingTasks 

func (UnimplementedSchedulerServer) StreamIncomingTasks(Scheduler_StreamIncomingTasksServer) error

func (UnimplementedSchedulerServer) StreamOutgoingTasks 

func (UnimplementedSchedulerServer) StreamOutgoingTasks(Scheduler_StreamOutgoingTasksServer) error

type UnsafeCacheServer 

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

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

type UnsafeConsumerdServer 

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

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

type UnsafeMonitorServer 

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

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

type UnsafeSchedulerServer 

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

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

type WhoisRequest 

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

func (*WhoisRequest) Descriptor deprecated 

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

Deprecated: Use WhoisRequest.ProtoReflect.Descriptor instead.

func (*WhoisRequest) GetUUID 

func (x *WhoisRequest) GetUUID() string

func (*WhoisRequest) ProtoMessage 

func (*WhoisRequest) ProtoMessage()

func (*WhoisRequest) ProtoReflect 

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

func (*WhoisRequest) Reset 

func (x *WhoisRequest) Reset()

func (*WhoisRequest) String 

func (x *WhoisRequest) String() string

type WhoisResponse 

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
}

func (*WhoisResponse) Descriptor deprecated 

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

Deprecated: Use WhoisResponse.ProtoReflect.Descriptor instead.

func (*WhoisResponse) GetAddress 

func (x *WhoisResponse) GetAddress() string

func (*WhoisResponse) GetComponent 

func (x *WhoisResponse) GetComponent() Component

func (*WhoisResponse) GetUUID 

func (x *WhoisResponse) GetUUID() string

func (*WhoisResponse) ProtoMessage 

func (*WhoisResponse) ProtoMessage()

func (*WhoisResponse) ProtoReflect 

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

func (*WhoisResponse) Reset 

func (x *WhoisResponse) Reset()

func (*WhoisResponse) String 

func (x *WhoisResponse) String() string

Source Files

View all Source files

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.