Documentation ¶
Index ¶
- Variables
- func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
- type Array
- type Binding
- type Bool
- type Bytes
- type CachePath
- type CommandPath
- type DirPath
- type FilePath
- type FilesystemPath
- func (*FilesystemPath) Descriptor() ([]byte, []int)deprecated
- func (x *FilesystemPath) GetDir() *DirPath
- func (x *FilesystemPath) GetFile() *FilePath
- func (m *FilesystemPath) GetPath() isFilesystemPath_Path
- func (*FilesystemPath) ProtoMessage()
- func (x *FilesystemPath) ProtoReflect() protoreflect.Message
- func (x *FilesystemPath) Reset()
- func (x *FilesystemPath) String() string
- type FilesystemPath_Dir
- type FilesystemPath_File
- type HostPath
- type Int
- type LogicalPath
- func (*LogicalPath) Descriptor() ([]byte, []int)deprecated
- func (x *LogicalPath) GetDir() *LogicalPath_Dir
- func (x *LogicalPath) GetFile() *LogicalPath_File
- func (m *LogicalPath) GetPath() isLogicalPath_Path
- func (*LogicalPath) ProtoMessage()
- func (x *LogicalPath) ProtoReflect() protoreflect.Message
- func (x *LogicalPath) Reset()
- func (x *LogicalPath) String() string
- type LogicalPath_Dir
- func (*LogicalPath_Dir) Descriptor() ([]byte, []int)deprecated
- func (x *LogicalPath_Dir) GetEntries() []*LogicalPath
- func (x *LogicalPath_Dir) GetName() string
- func (*LogicalPath_Dir) ProtoMessage()
- func (x *LogicalPath_Dir) ProtoReflect() protoreflect.Message
- func (x *LogicalPath_Dir) Reset()
- func (x *LogicalPath_Dir) String() string
- type LogicalPath_Dir_
- type LogicalPath_File
- func (*LogicalPath_File) Descriptor() ([]byte, []int)deprecated
- func (x *LogicalPath_File) GetContent() []byte
- func (x *LogicalPath_File) GetName() string
- func (*LogicalPath_File) ProtoMessage()
- func (x *LogicalPath_File) ProtoReflect() protoreflect.Message
- func (x *LogicalPath_File) Reset()
- func (x *LogicalPath_File) String() string
- type LogicalPath_File_
- type Memosphere
- type Memosphere_Call
- func (*Memosphere_Call) Descriptor() ([]byte, []int)deprecated
- func (x *Memosphere_Call) GetBinding() string
- func (x *Memosphere_Call) GetResults() []*Memosphere_Result
- func (*Memosphere_Call) ProtoMessage()
- func (x *Memosphere_Call) ProtoReflect() protoreflect.Message
- func (x *Memosphere_Call) Reset()
- func (x *Memosphere_Call) String() string
- type Memosphere_Memo
- func (*Memosphere_Memo) Descriptor() ([]byte, []int)deprecated
- func (x *Memosphere_Memo) GetCalls() []*Memosphere_Call
- func (x *Memosphere_Memo) GetModule() *Thunk
- func (*Memosphere_Memo) ProtoMessage()
- func (x *Memosphere_Memo) ProtoReflect() protoreflect.Message
- func (x *Memosphere_Memo) Reset()
- func (x *Memosphere_Memo) String() string
- type Memosphere_Result
- func (*Memosphere_Result) Descriptor() ([]byte, []int)deprecated
- func (x *Memosphere_Result) GetInput() *Value
- func (x *Memosphere_Result) GetOutput() *Value
- func (*Memosphere_Result) ProtoMessage()
- func (x *Memosphere_Result) ProtoReflect() protoreflect.Message
- func (x *Memosphere_Result) Reset()
- func (x *Memosphere_Result) String() string
- type Message
- type Null
- type Object
- type Platform
- type Progress
- func (*Progress) Descriptor() ([]byte, []int)deprecated
- func (x *Progress) GetLogs() []*VertexLog
- func (x *Progress) GetStatuses() []*VertexStatus
- func (x *Progress) GetVertexes() []*Vertex
- func (*Progress) ProtoMessage()
- func (x *Progress) ProtoReflect() protoreflect.Message
- func (x *Progress) Reset()
- func (x *Progress) String() string
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ReadResponse) GetInner() isReadResponse_Inner
- func (x *ReadResponse) GetOutput() []byte
- func (x *ReadResponse) GetProgress() *Progress
- func (*ReadResponse) ProtoMessage()
- func (x *ReadResponse) ProtoReflect() protoreflect.Message
- func (x *ReadResponse) Reset()
- func (x *ReadResponse) String() string
- type ReadResponse_Output
- type ReadResponse_Progress
- type RunResponse
- func (*RunResponse) Descriptor() ([]byte, []int)deprecated
- func (m *RunResponse) GetInner() isRunResponse_Inner
- func (x *RunResponse) GetProgress() *Progress
- func (*RunResponse) ProtoMessage()
- func (x *RunResponse) ProtoReflect() protoreflect.Message
- func (x *RunResponse) Reset()
- func (x *RunResponse) String() string
- type RunResponse_Progress
- type RuntimeClient
- type RuntimeServer
- type Runtime_ExportClient
- type Runtime_ExportPathClient
- type Runtime_ExportPathServer
- type Runtime_ExportServer
- type Runtime_ReadClient
- type Runtime_ReadServer
- type Runtime_RunClient
- type Runtime_RunServer
- type Secret
- type String
- type Thunk
- func (*Thunk) Descriptor() ([]byte, []int)deprecated
- func (x *Thunk) GetArgs() []*Value
- func (x *Thunk) GetCmd() *ThunkCmd
- func (x *Thunk) GetDir() *ThunkDir
- func (x *Thunk) GetEnv() []*Binding
- func (x *Thunk) GetImage() *ThunkImage
- func (x *Thunk) GetInsecure() bool
- func (x *Thunk) GetLabels() []*Binding
- func (x *Thunk) GetMounts() []*ThunkMount
- func (x *Thunk) GetStdin() []*Value
- func (*Thunk) ProtoMessage()
- func (x *Thunk) ProtoReflect() protoreflect.Message
- func (x *Thunk) Reset()
- func (x *Thunk) String() string
- type ThunkCmd
- func (*ThunkCmd) Descriptor() ([]byte, []int)deprecated
- func (x *ThunkCmd) GetCache() *CachePath
- func (m *ThunkCmd) GetCmd() isThunkCmd_Cmd
- func (x *ThunkCmd) GetCommand() *CommandPath
- func (x *ThunkCmd) GetFile() *FilePath
- func (x *ThunkCmd) GetHost() *HostPath
- func (x *ThunkCmd) GetLogical() *LogicalPath
- func (x *ThunkCmd) GetThunk() *ThunkPath
- func (*ThunkCmd) ProtoMessage()
- func (x *ThunkCmd) ProtoReflect() protoreflect.Message
- func (x *ThunkCmd) Reset()
- func (x *ThunkCmd) String() string
- type ThunkCmd_Cache
- type ThunkCmd_Command
- type ThunkCmd_File
- type ThunkCmd_Host
- type ThunkCmd_Logical
- type ThunkCmd_Thunk
- type ThunkDir
- func (*ThunkDir) Descriptor() ([]byte, []int)deprecated
- func (m *ThunkDir) GetDir() isThunkDir_Dir
- func (x *ThunkDir) GetHost() *HostPath
- func (x *ThunkDir) GetLocal() *DirPath
- func (x *ThunkDir) GetThunk() *ThunkPath
- func (*ThunkDir) ProtoMessage()
- func (x *ThunkDir) ProtoReflect() protoreflect.Message
- func (x *ThunkDir) Reset()
- func (x *ThunkDir) String() string
- type ThunkDir_Host
- type ThunkDir_Local
- type ThunkDir_Thunk
- type ThunkImage
- func (*ThunkImage) Descriptor() ([]byte, []int)deprecated
- func (m *ThunkImage) GetImage() isThunkImage_Image
- func (x *ThunkImage) GetRef() *ThunkImageRef
- func (x *ThunkImage) GetThunk() *Thunk
- func (*ThunkImage) ProtoMessage()
- func (x *ThunkImage) ProtoReflect() protoreflect.Message
- func (x *ThunkImage) Reset()
- func (x *ThunkImage) String() string
- type ThunkImageRef
- func (*ThunkImageRef) Descriptor() ([]byte, []int)deprecated
- func (x *ThunkImageRef) GetDigest() string
- func (x *ThunkImageRef) GetFile() *ThunkPath
- func (x *ThunkImageRef) GetPlatform() *Platform
- func (x *ThunkImageRef) GetRepository() string
- func (m *ThunkImageRef) GetSource() isThunkImageRef_Source
- func (x *ThunkImageRef) GetTag() string
- func (*ThunkImageRef) ProtoMessage()
- func (x *ThunkImageRef) ProtoReflect() protoreflect.Message
- func (x *ThunkImageRef) Reset()
- func (x *ThunkImageRef) String() string
- type ThunkImageRef_File
- type ThunkImageRef_Repository
- type ThunkImage_Ref
- type ThunkImage_Thunk
- type ThunkMount
- func (*ThunkMount) Descriptor() ([]byte, []int)deprecated
- func (x *ThunkMount) GetSource() *ThunkMountSource
- func (x *ThunkMount) GetTarget() *FilesystemPath
- func (*ThunkMount) ProtoMessage()
- func (x *ThunkMount) ProtoReflect() protoreflect.Message
- func (x *ThunkMount) Reset()
- func (x *ThunkMount) String() string
- type ThunkMountSource
- func (*ThunkMountSource) Descriptor() ([]byte, []int)deprecated
- func (x *ThunkMountSource) GetCache() *CachePath
- func (x *ThunkMountSource) GetHost() *HostPath
- func (x *ThunkMountSource) GetLogical() *LogicalPath
- func (x *ThunkMountSource) GetSecret() *Secret
- func (m *ThunkMountSource) GetSource() isThunkMountSource_Source
- func (x *ThunkMountSource) GetThunk() *ThunkPath
- func (*ThunkMountSource) ProtoMessage()
- func (x *ThunkMountSource) ProtoReflect() protoreflect.Message
- func (x *ThunkMountSource) Reset()
- func (x *ThunkMountSource) String() string
- type ThunkMountSource_Cache
- type ThunkMountSource_Host
- type ThunkMountSource_Logical
- type ThunkMountSource_Secret
- type ThunkMountSource_Thunk
- type ThunkPath
- type UnimplementedRuntimeServer
- func (UnimplementedRuntimeServer) Export(*Thunk, Runtime_ExportServer) error
- func (UnimplementedRuntimeServer) ExportPath(*ThunkPath, Runtime_ExportPathServer) error
- func (UnimplementedRuntimeServer) Read(*Thunk, Runtime_ReadServer) error
- func (UnimplementedRuntimeServer) Resolve(context.Context, *ThunkImageRef) (*ThunkImageRef, error)
- func (UnimplementedRuntimeServer) Run(*Thunk, Runtime_RunServer) error
- type UnsafeRuntimeServer
- type Value
- func (*Value) Descriptor() ([]byte, []int)deprecated
- func (x *Value) GetArray() *Array
- func (x *Value) GetBool() *Bool
- func (x *Value) GetCommandPath() *CommandPath
- func (x *Value) GetDirPath() *DirPath
- func (x *Value) GetFilePath() *FilePath
- func (x *Value) GetHostPath() *HostPath
- func (x *Value) GetInt() *Int
- func (x *Value) GetLogicalPath() *LogicalPath
- func (x *Value) GetNull() *Null
- func (x *Value) GetObject() *Object
- func (x *Value) GetSecret() *Secret
- func (x *Value) GetString_() *String
- func (x *Value) GetThunk() *Thunk
- func (x *Value) GetThunkPath() *ThunkPath
- func (m *Value) GetValue() isValue_Value
- func (*Value) ProtoMessage()
- func (x *Value) ProtoReflect() protoreflect.Message
- func (x *Value) Reset()
- func (x *Value) String() string
- type Value_Array
- type Value_Bool
- type Value_CommandPath
- type Value_DirPath
- type Value_FilePath
- type Value_HostPath
- type Value_Int
- type Value_LogicalPath
- type Value_Null
- type Value_Object
- type Value_Secret
- type Value_String_
- type Value_Thunk
- type Value_ThunkPath
- type Vertex
- func (*Vertex) Descriptor() ([]byte, []int)deprecated
- func (x *Vertex) GetCached() bool
- func (x *Vertex) GetCompleted() *timestamppb.Timestamp
- func (x *Vertex) GetDigest() string
- func (x *Vertex) GetError() string
- func (x *Vertex) GetInputs() []string
- func (x *Vertex) GetName() string
- func (x *Vertex) GetStarted() *timestamppb.Timestamp
- func (*Vertex) ProtoMessage()
- func (x *Vertex) ProtoReflect() protoreflect.Message
- func (x *Vertex) Reset()
- func (x *Vertex) String() string
- type VertexLog
- func (*VertexLog) Descriptor() ([]byte, []int)deprecated
- func (x *VertexLog) GetData() []byte
- func (x *VertexLog) GetStream() int64
- func (x *VertexLog) GetTimestamp() *timestamppb.Timestamp
- func (x *VertexLog) GetVertex() string
- func (*VertexLog) ProtoMessage()
- func (x *VertexLog) ProtoReflect() protoreflect.Message
- func (x *VertexLog) Reset()
- func (x *VertexLog) String() string
- type VertexStatus
- func (*VertexStatus) Descriptor() ([]byte, []int)deprecated
- func (x *VertexStatus) GetCompleted() *timestamppb.Timestamp
- func (x *VertexStatus) GetCurrent() int64
- func (x *VertexStatus) GetId() string
- func (x *VertexStatus) GetName() string
- func (x *VertexStatus) GetStarted() *timestamppb.Timestamp
- func (x *VertexStatus) GetTimestamp() *timestamppb.Timestamp
- func (x *VertexStatus) GetTotal() int64
- func (x *VertexStatus) GetVertex() string
- func (*VertexStatus) ProtoMessage()
- func (x *VertexStatus) ProtoReflect() protoreflect.Message
- func (x *VertexStatus) Reset()
- func (x *VertexStatus) String() string
Constants ¶
This section is empty.
Variables ¶
var File_bass_proto protoreflect.FileDescriptor
var File_memo_proto protoreflect.FileDescriptor
var File_progress_proto protoreflect.FileDescriptor
var File_runtime_proto protoreflect.FileDescriptor
var Runtime_ServiceDesc = grpc.ServiceDesc{ ServiceName: "bass.Runtime", HandlerType: (*RuntimeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Resolve", Handler: _Runtime_Resolve_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Run", Handler: _Runtime_Run_Handler, ServerStreams: true, }, { StreamName: "Read", Handler: _Runtime_Read_Handler, ServerStreams: true, }, { StreamName: "Export", Handler: _Runtime_Export_Handler, ServerStreams: true, }, { StreamName: "ExportPath", Handler: _Runtime_ExportPath_Handler, ServerStreams: true, }, }, Metadata: "runtime.proto", }
Runtime_ServiceDesc is the grpc.ServiceDesc for Runtime service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRuntimeServer ¶
func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
Types ¶
type Array ¶
type Array struct { Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*Array) Descriptor
deprecated
func (*Array) ProtoMessage ¶
func (*Array) ProtoMessage()
func (*Array) ProtoReflect ¶
func (x *Array) ProtoReflect() protoreflect.Message
type Binding ¶
type Binding struct { Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"` Value *Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Binding) Descriptor
deprecated
func (*Binding) ProtoMessage ¶
func (*Binding) ProtoMessage()
func (*Binding) ProtoReflect ¶
func (x *Binding) ProtoReflect() protoreflect.Message
type Bool ¶
type Bool struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Bool) Descriptor
deprecated
func (*Bool) ProtoMessage ¶
func (*Bool) ProtoMessage()
func (*Bool) ProtoReflect ¶
func (x *Bool) ProtoReflect() protoreflect.Message
type Bytes ¶
type Bytes struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Bytes) Descriptor
deprecated
func (*Bytes) ProtoMessage ¶
func (*Bytes) ProtoMessage()
func (*Bytes) ProtoReflect ¶
func (x *Bytes) ProtoReflect() protoreflect.Message
type CachePath ¶
type CachePath struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Path *FilesystemPath `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*CachePath) Descriptor
deprecated
func (*CachePath) GetPath ¶
func (x *CachePath) GetPath() *FilesystemPath
func (*CachePath) ProtoMessage ¶
func (*CachePath) ProtoMessage()
func (*CachePath) ProtoReflect ¶
func (x *CachePath) ProtoReflect() protoreflect.Message
type CommandPath ¶
type CommandPath struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*CommandPath) Descriptor
deprecated
func (*CommandPath) Descriptor() ([]byte, []int)
Deprecated: Use CommandPath.ProtoReflect.Descriptor instead.
func (*CommandPath) GetName ¶
func (x *CommandPath) GetName() string
func (*CommandPath) ProtoMessage ¶
func (*CommandPath) ProtoMessage()
func (*CommandPath) ProtoReflect ¶
func (x *CommandPath) ProtoReflect() protoreflect.Message
func (*CommandPath) Reset ¶
func (x *CommandPath) Reset()
func (*CommandPath) String ¶
func (x *CommandPath) String() string
type DirPath ¶
type DirPath struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*DirPath) Descriptor
deprecated
func (*DirPath) ProtoMessage ¶
func (*DirPath) ProtoMessage()
func (*DirPath) ProtoReflect ¶
func (x *DirPath) ProtoReflect() protoreflect.Message
type FilePath ¶
type FilePath struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*FilePath) Descriptor
deprecated
func (*FilePath) ProtoMessage ¶
func (*FilePath) ProtoMessage()
func (*FilePath) ProtoReflect ¶
func (x *FilePath) ProtoReflect() protoreflect.Message
type FilesystemPath ¶
type FilesystemPath struct { // Types that are assignable to Path: // *FilesystemPath_File // *FilesystemPath_Dir Path isFilesystemPath_Path `protobuf_oneof:"path"` // contains filtered or unexported fields }
func (*FilesystemPath) Descriptor
deprecated
func (*FilesystemPath) Descriptor() ([]byte, []int)
Deprecated: Use FilesystemPath.ProtoReflect.Descriptor instead.
func (*FilesystemPath) GetDir ¶
func (x *FilesystemPath) GetDir() *DirPath
func (*FilesystemPath) GetFile ¶
func (x *FilesystemPath) GetFile() *FilePath
func (*FilesystemPath) GetPath ¶
func (m *FilesystemPath) GetPath() isFilesystemPath_Path
func (*FilesystemPath) ProtoMessage ¶
func (*FilesystemPath) ProtoMessage()
func (*FilesystemPath) ProtoReflect ¶
func (x *FilesystemPath) ProtoReflect() protoreflect.Message
func (*FilesystemPath) Reset ¶
func (x *FilesystemPath) Reset()
func (*FilesystemPath) String ¶
func (x *FilesystemPath) String() string
type FilesystemPath_Dir ¶
type FilesystemPath_Dir struct {
Dir *DirPath `protobuf:"bytes,2,opt,name=dir,proto3,oneof"`
}
type FilesystemPath_File ¶
type FilesystemPath_File struct {
File *FilePath `protobuf:"bytes,1,opt,name=file,proto3,oneof"`
}
type HostPath ¶
type HostPath struct { Context string `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"` Path *FilesystemPath `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*HostPath) Descriptor
deprecated
func (*HostPath) GetContext ¶
func (*HostPath) GetPath ¶
func (x *HostPath) GetPath() *FilesystemPath
func (*HostPath) ProtoMessage ¶
func (*HostPath) ProtoMessage()
func (*HostPath) ProtoReflect ¶
func (x *HostPath) ProtoReflect() protoreflect.Message
type Int ¶
type Int struct { Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Int) Descriptor
deprecated
func (*Int) ProtoMessage ¶
func (*Int) ProtoMessage()
func (*Int) ProtoReflect ¶
func (x *Int) ProtoReflect() protoreflect.Message
type LogicalPath ¶
type LogicalPath struct { // Types that are assignable to Path: // *LogicalPath_File_ // *LogicalPath_Dir_ Path isLogicalPath_Path `protobuf_oneof:"path"` // contains filtered or unexported fields }
func (*LogicalPath) Descriptor
deprecated
func (*LogicalPath) Descriptor() ([]byte, []int)
Deprecated: Use LogicalPath.ProtoReflect.Descriptor instead.
func (*LogicalPath) GetDir ¶
func (x *LogicalPath) GetDir() *LogicalPath_Dir
func (*LogicalPath) GetFile ¶
func (x *LogicalPath) GetFile() *LogicalPath_File
func (*LogicalPath) GetPath ¶
func (m *LogicalPath) GetPath() isLogicalPath_Path
func (*LogicalPath) ProtoMessage ¶
func (*LogicalPath) ProtoMessage()
func (*LogicalPath) ProtoReflect ¶
func (x *LogicalPath) ProtoReflect() protoreflect.Message
func (*LogicalPath) Reset ¶
func (x *LogicalPath) Reset()
func (*LogicalPath) String ¶
func (x *LogicalPath) String() string
type LogicalPath_Dir ¶
type LogicalPath_Dir struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Entries []*LogicalPath `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*LogicalPath_Dir) Descriptor
deprecated
func (*LogicalPath_Dir) Descriptor() ([]byte, []int)
Deprecated: Use LogicalPath_Dir.ProtoReflect.Descriptor instead.
func (*LogicalPath_Dir) GetEntries ¶
func (x *LogicalPath_Dir) GetEntries() []*LogicalPath
func (*LogicalPath_Dir) GetName ¶
func (x *LogicalPath_Dir) GetName() string
func (*LogicalPath_Dir) ProtoMessage ¶
func (*LogicalPath_Dir) ProtoMessage()
func (*LogicalPath_Dir) ProtoReflect ¶
func (x *LogicalPath_Dir) ProtoReflect() protoreflect.Message
func (*LogicalPath_Dir) Reset ¶
func (x *LogicalPath_Dir) Reset()
func (*LogicalPath_Dir) String ¶
func (x *LogicalPath_Dir) String() string
type LogicalPath_Dir_ ¶
type LogicalPath_Dir_ struct {
Dir *LogicalPath_Dir `protobuf:"bytes,2,opt,name=dir,proto3,oneof"`
}
type LogicalPath_File ¶
type LogicalPath_File struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*LogicalPath_File) Descriptor
deprecated
func (*LogicalPath_File) Descriptor() ([]byte, []int)
Deprecated: Use LogicalPath_File.ProtoReflect.Descriptor instead.
func (*LogicalPath_File) GetContent ¶
func (x *LogicalPath_File) GetContent() []byte
func (*LogicalPath_File) GetName ¶
func (x *LogicalPath_File) GetName() string
func (*LogicalPath_File) ProtoMessage ¶
func (*LogicalPath_File) ProtoMessage()
func (*LogicalPath_File) ProtoReflect ¶
func (x *LogicalPath_File) ProtoReflect() protoreflect.Message
func (*LogicalPath_File) Reset ¶
func (x *LogicalPath_File) Reset()
func (*LogicalPath_File) String ¶
func (x *LogicalPath_File) String() string
type LogicalPath_File_ ¶
type LogicalPath_File_ struct {
File *LogicalPath_File `protobuf:"bytes,1,opt,name=file,proto3,oneof"`
}
type Memosphere ¶
type Memosphere struct { Memos []*Memosphere_Memo `protobuf:"bytes,1,rep,name=memos,proto3" json:"memos,omitempty"` // contains filtered or unexported fields }
func (*Memosphere) Descriptor
deprecated
func (*Memosphere) Descriptor() ([]byte, []int)
Deprecated: Use Memosphere.ProtoReflect.Descriptor instead.
func (*Memosphere) GetMemos ¶
func (x *Memosphere) GetMemos() []*Memosphere_Memo
func (*Memosphere) ProtoMessage ¶
func (*Memosphere) ProtoMessage()
func (*Memosphere) ProtoReflect ¶
func (x *Memosphere) ProtoReflect() protoreflect.Message
func (*Memosphere) Reset ¶
func (x *Memosphere) Reset()
func (*Memosphere) String ¶
func (x *Memosphere) String() string
type Memosphere_Call ¶
type Memosphere_Call struct { Binding string `protobuf:"bytes,1,opt,name=binding,proto3" json:"binding,omitempty"` Results []*Memosphere_Result `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
func (*Memosphere_Call) Descriptor
deprecated
func (*Memosphere_Call) Descriptor() ([]byte, []int)
Deprecated: Use Memosphere_Call.ProtoReflect.Descriptor instead.
func (*Memosphere_Call) GetBinding ¶
func (x *Memosphere_Call) GetBinding() string
func (*Memosphere_Call) GetResults ¶
func (x *Memosphere_Call) GetResults() []*Memosphere_Result
func (*Memosphere_Call) ProtoMessage ¶
func (*Memosphere_Call) ProtoMessage()
func (*Memosphere_Call) ProtoReflect ¶
func (x *Memosphere_Call) ProtoReflect() protoreflect.Message
func (*Memosphere_Call) Reset ¶
func (x *Memosphere_Call) Reset()
func (*Memosphere_Call) String ¶
func (x *Memosphere_Call) String() string
type Memosphere_Memo ¶
type Memosphere_Memo struct { Module *Thunk `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` Calls []*Memosphere_Call `protobuf:"bytes,2,rep,name=calls,proto3" json:"calls,omitempty"` // contains filtered or unexported fields }
func (*Memosphere_Memo) Descriptor
deprecated
func (*Memosphere_Memo) Descriptor() ([]byte, []int)
Deprecated: Use Memosphere_Memo.ProtoReflect.Descriptor instead.
func (*Memosphere_Memo) GetCalls ¶
func (x *Memosphere_Memo) GetCalls() []*Memosphere_Call
func (*Memosphere_Memo) GetModule ¶
func (x *Memosphere_Memo) GetModule() *Thunk
func (*Memosphere_Memo) ProtoMessage ¶
func (*Memosphere_Memo) ProtoMessage()
func (*Memosphere_Memo) ProtoReflect ¶
func (x *Memosphere_Memo) ProtoReflect() protoreflect.Message
func (*Memosphere_Memo) Reset ¶
func (x *Memosphere_Memo) Reset()
func (*Memosphere_Memo) String ¶
func (x *Memosphere_Memo) String() string
type Memosphere_Result ¶
type Memosphere_Result struct { Input *Value `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"` Output *Value `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` // contains filtered or unexported fields }
func (*Memosphere_Result) Descriptor
deprecated
func (*Memosphere_Result) Descriptor() ([]byte, []int)
Deprecated: Use Memosphere_Result.ProtoReflect.Descriptor instead.
func (*Memosphere_Result) GetInput ¶
func (x *Memosphere_Result) GetInput() *Value
func (*Memosphere_Result) GetOutput ¶
func (x *Memosphere_Result) GetOutput() *Value
func (*Memosphere_Result) ProtoMessage ¶
func (*Memosphere_Result) ProtoMessage()
func (*Memosphere_Result) ProtoReflect ¶
func (x *Memosphere_Result) ProtoReflect() protoreflect.Message
func (*Memosphere_Result) Reset ¶
func (x *Memosphere_Result) Reset()
func (*Memosphere_Result) String ¶
func (x *Memosphere_Result) String() string
type Null ¶
type Null struct {
// contains filtered or unexported fields
}
func (*Null) Descriptor
deprecated
func (*Null) ProtoMessage ¶
func (*Null) ProtoMessage()
func (*Null) ProtoReflect ¶
func (x *Null) ProtoReflect() protoreflect.Message
type Object ¶
type Object struct { Bindings []*Binding `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"` // contains filtered or unexported fields }
func (*Object) Descriptor
deprecated
func (*Object) GetBindings ¶
func (*Object) ProtoMessage ¶
func (*Object) ProtoMessage()
func (*Object) ProtoReflect ¶
func (x *Object) ProtoReflect() protoreflect.Message
type Platform ¶
type Platform struct { Os string `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty"` Arch string `protobuf:"bytes,2,opt,name=arch,proto3" json:"arch,omitempty"` // contains filtered or unexported fields }
func (*Platform) Descriptor
deprecated
func (*Platform) ProtoMessage ¶
func (*Platform) ProtoMessage()
func (*Platform) ProtoReflect ¶
func (x *Platform) ProtoReflect() protoreflect.Message
type Progress ¶
type Progress struct { Vertexes []*Vertex `protobuf:"bytes,1,rep,name=vertexes,proto3" json:"vertexes,omitempty"` Statuses []*VertexStatus `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"` Logs []*VertexLog `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"` // contains filtered or unexported fields }
func (*Progress) Descriptor
deprecated
func (*Progress) GetStatuses ¶
func (x *Progress) GetStatuses() []*VertexStatus
func (*Progress) GetVertexes ¶
func (*Progress) ProtoMessage ¶
func (*Progress) ProtoMessage()
func (*Progress) ProtoReflect ¶
func (x *Progress) ProtoReflect() protoreflect.Message
type ReadResponse ¶ added in v0.6.1
type ReadResponse struct { // Types that are assignable to Inner: // *ReadResponse_Progress // *ReadResponse_Output Inner isReadResponse_Inner `protobuf_oneof:"inner"` // contains filtered or unexported fields }
func (*ReadResponse) Descriptor
deprecated
added in
v0.6.1
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetInner ¶ added in v0.6.1
func (m *ReadResponse) GetInner() isReadResponse_Inner
func (*ReadResponse) GetOutput ¶ added in v0.6.1
func (x *ReadResponse) GetOutput() []byte
func (*ReadResponse) GetProgress ¶ added in v0.6.1
func (x *ReadResponse) GetProgress() *Progress
func (*ReadResponse) ProtoMessage ¶ added in v0.6.1
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶ added in v0.6.1
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶ added in v0.6.1
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶ added in v0.6.1
func (x *ReadResponse) String() string
type ReadResponse_Output ¶ added in v0.6.1
type ReadResponse_Output struct {
Output []byte `protobuf:"bytes,2,opt,name=output,proto3,oneof"`
}
type ReadResponse_Progress ¶ added in v0.6.1
type ReadResponse_Progress struct {
Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3,oneof"`
}
type RunResponse ¶ added in v0.6.1
type RunResponse struct { // Types that are assignable to Inner: // *RunResponse_Progress Inner isRunResponse_Inner `protobuf_oneof:"inner"` // contains filtered or unexported fields }
func (*RunResponse) Descriptor
deprecated
added in
v0.6.1
func (*RunResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.
func (*RunResponse) GetInner ¶ added in v0.6.1
func (m *RunResponse) GetInner() isRunResponse_Inner
func (*RunResponse) GetProgress ¶ added in v0.6.1
func (x *RunResponse) GetProgress() *Progress
func (*RunResponse) ProtoMessage ¶ added in v0.6.1
func (*RunResponse) ProtoMessage()
func (*RunResponse) ProtoReflect ¶ added in v0.6.1
func (x *RunResponse) ProtoReflect() protoreflect.Message
func (*RunResponse) Reset ¶ added in v0.6.1
func (x *RunResponse) Reset()
func (*RunResponse) String ¶ added in v0.6.1
func (x *RunResponse) String() string
type RunResponse_Progress ¶ added in v0.6.1
type RunResponse_Progress struct {
Progress *Progress `protobuf:"bytes,1,opt,name=progress,proto3,oneof"`
}
type RuntimeClient ¶
type RuntimeClient interface { Resolve(ctx context.Context, in *ThunkImageRef, opts ...grpc.CallOption) (*ThunkImageRef, error) Run(ctx context.Context, in *Thunk, opts ...grpc.CallOption) (Runtime_RunClient, error) Read(ctx context.Context, in *Thunk, opts ...grpc.CallOption) (Runtime_ReadClient, error) Export(ctx context.Context, in *Thunk, opts ...grpc.CallOption) (Runtime_ExportClient, error) ExportPath(ctx context.Context, in *ThunkPath, opts ...grpc.CallOption) (Runtime_ExportPathClient, error) }
RuntimeClient is the client API for Runtime 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 NewRuntimeClient ¶
func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient
type RuntimeServer ¶
type RuntimeServer interface { Resolve(context.Context, *ThunkImageRef) (*ThunkImageRef, error) Run(*Thunk, Runtime_RunServer) error Read(*Thunk, Runtime_ReadServer) error Export(*Thunk, Runtime_ExportServer) error ExportPath(*ThunkPath, Runtime_ExportPathServer) error // contains filtered or unexported methods }
RuntimeServer is the server API for Runtime service. All implementations must embed UnimplementedRuntimeServer for forward compatibility
type Runtime_ExportClient ¶
type Runtime_ExportClient interface { Recv() (*Bytes, error) grpc.ClientStream }
type Runtime_ExportPathClient ¶
type Runtime_ExportPathClient interface { Recv() (*Bytes, error) grpc.ClientStream }
type Runtime_ExportPathServer ¶
type Runtime_ExportPathServer interface { Send(*Bytes) error grpc.ServerStream }
type Runtime_ExportServer ¶
type Runtime_ExportServer interface { Send(*Bytes) error grpc.ServerStream }
type Runtime_ReadClient ¶ added in v0.6.1
type Runtime_ReadClient interface { Recv() (*ReadResponse, error) grpc.ClientStream }
type Runtime_ReadServer ¶ added in v0.6.1
type Runtime_ReadServer interface { Send(*ReadResponse) error grpc.ServerStream }
type Runtime_RunClient ¶
type Runtime_RunClient interface { Recv() (*RunResponse, error) grpc.ClientStream }
type Runtime_RunServer ¶
type Runtime_RunServer interface { Send(*RunResponse) error grpc.ServerStream }
type Secret ¶
type Secret struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Secret) Descriptor
deprecated
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶
func (x *Secret) ProtoReflect() protoreflect.Message
type String ¶
type String struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*String) Descriptor
deprecated
func (*String) ProtoMessage ¶
func (*String) ProtoMessage()
func (*String) ProtoReflect ¶
func (x *String) ProtoReflect() protoreflect.Message
type Thunk ¶
type Thunk struct { Image *ThunkImage `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` Insecure bool `protobuf:"varint,2,opt,name=insecure,proto3" json:"insecure,omitempty"` Cmd *ThunkCmd `protobuf:"bytes,3,opt,name=cmd,proto3" json:"cmd,omitempty"` Args []*Value `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"` Stdin []*Value `protobuf:"bytes,5,rep,name=stdin,proto3" json:"stdin,omitempty"` Env []*Binding `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"` Dir *ThunkDir `protobuf:"bytes,7,opt,name=dir,proto3" json:"dir,omitempty"` Mounts []*ThunkMount `protobuf:"bytes,8,rep,name=mounts,proto3" json:"mounts,omitempty"` Labels []*Binding `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*Thunk) Descriptor
deprecated
func (*Thunk) GetImage ¶
func (x *Thunk) GetImage() *ThunkImage
func (*Thunk) GetInsecure ¶
func (*Thunk) GetMounts ¶
func (x *Thunk) GetMounts() []*ThunkMount
func (*Thunk) ProtoMessage ¶
func (*Thunk) ProtoMessage()
func (*Thunk) ProtoReflect ¶
func (x *Thunk) ProtoReflect() protoreflect.Message
type ThunkCmd ¶
type ThunkCmd struct { // Types that are assignable to Cmd: // *ThunkCmd_Command // *ThunkCmd_File // *ThunkCmd_Thunk // *ThunkCmd_Host // *ThunkCmd_Logical // *ThunkCmd_Cache Cmd isThunkCmd_Cmd `protobuf_oneof:"cmd"` // contains filtered or unexported fields }
func (*ThunkCmd) Descriptor
deprecated
func (*ThunkCmd) GetCommand ¶
func (x *ThunkCmd) GetCommand() *CommandPath
func (*ThunkCmd) GetLogical ¶
func (x *ThunkCmd) GetLogical() *LogicalPath
func (*ThunkCmd) ProtoMessage ¶
func (*ThunkCmd) ProtoMessage()
func (*ThunkCmd) ProtoReflect ¶
func (x *ThunkCmd) ProtoReflect() protoreflect.Message
type ThunkCmd_Cache ¶ added in v0.7.0
type ThunkCmd_Cache struct {
Cache *CachePath `protobuf:"bytes,6,opt,name=cache,proto3,oneof"`
}
type ThunkCmd_Command ¶
type ThunkCmd_Command struct {
Command *CommandPath `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}
type ThunkCmd_File ¶
type ThunkCmd_File struct {
File *FilePath `protobuf:"bytes,2,opt,name=file,proto3,oneof"`
}
type ThunkCmd_Host ¶
type ThunkCmd_Host struct {
Host *HostPath `protobuf:"bytes,4,opt,name=host,proto3,oneof"`
}
type ThunkCmd_Logical ¶
type ThunkCmd_Logical struct {
Logical *LogicalPath `protobuf:"bytes,5,opt,name=logical,proto3,oneof"`
}
type ThunkCmd_Thunk ¶
type ThunkCmd_Thunk struct {
Thunk *ThunkPath `protobuf:"bytes,3,opt,name=thunk,proto3,oneof"`
}
type ThunkDir ¶
type ThunkDir struct { // Types that are assignable to Dir: // *ThunkDir_Local // *ThunkDir_Thunk // *ThunkDir_Host Dir isThunkDir_Dir `protobuf_oneof:"dir"` // contains filtered or unexported fields }
func (*ThunkDir) Descriptor
deprecated
func (*ThunkDir) ProtoMessage ¶
func (*ThunkDir) ProtoMessage()
func (*ThunkDir) ProtoReflect ¶
func (x *ThunkDir) ProtoReflect() protoreflect.Message
type ThunkDir_Host ¶
type ThunkDir_Host struct {
Host *HostPath `protobuf:"bytes,14,opt,name=host,proto3,oneof"`
}
type ThunkDir_Local ¶
type ThunkDir_Local struct {
Local *DirPath `protobuf:"bytes,12,opt,name=local,proto3,oneof"`
}
type ThunkDir_Thunk ¶
type ThunkDir_Thunk struct {
Thunk *ThunkPath `protobuf:"bytes,13,opt,name=thunk,proto3,oneof"`
}
type ThunkImage ¶
type ThunkImage struct { // Types that are assignable to Image: // *ThunkImage_Ref // *ThunkImage_Thunk Image isThunkImage_Image `protobuf_oneof:"image"` // contains filtered or unexported fields }
func (*ThunkImage) Descriptor
deprecated
func (*ThunkImage) Descriptor() ([]byte, []int)
Deprecated: Use ThunkImage.ProtoReflect.Descriptor instead.
func (*ThunkImage) GetImage ¶
func (m *ThunkImage) GetImage() isThunkImage_Image
func (*ThunkImage) GetRef ¶
func (x *ThunkImage) GetRef() *ThunkImageRef
func (*ThunkImage) GetThunk ¶
func (x *ThunkImage) GetThunk() *Thunk
func (*ThunkImage) ProtoMessage ¶
func (*ThunkImage) ProtoMessage()
func (*ThunkImage) ProtoReflect ¶
func (x *ThunkImage) ProtoReflect() protoreflect.Message
func (*ThunkImage) Reset ¶
func (x *ThunkImage) Reset()
func (*ThunkImage) String ¶
func (x *ThunkImage) String() string
type ThunkImageRef ¶
type ThunkImageRef struct { Platform *Platform `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"` // Types that are assignable to Source: // *ThunkImageRef_Repository // *ThunkImageRef_File Source isThunkImageRef_Source `protobuf_oneof:"source"` Tag *string `protobuf:"bytes,4,opt,name=tag,proto3,oneof" json:"tag,omitempty"` Digest *string `protobuf:"bytes,5,opt,name=digest,proto3,oneof" json:"digest,omitempty"` // contains filtered or unexported fields }
func (*ThunkImageRef) Descriptor
deprecated
func (*ThunkImageRef) Descriptor() ([]byte, []int)
Deprecated: Use ThunkImageRef.ProtoReflect.Descriptor instead.
func (*ThunkImageRef) GetDigest ¶
func (x *ThunkImageRef) GetDigest() string
func (*ThunkImageRef) GetFile ¶
func (x *ThunkImageRef) GetFile() *ThunkPath
func (*ThunkImageRef) GetPlatform ¶
func (x *ThunkImageRef) GetPlatform() *Platform
func (*ThunkImageRef) GetRepository ¶
func (x *ThunkImageRef) GetRepository() string
func (*ThunkImageRef) GetSource ¶
func (m *ThunkImageRef) GetSource() isThunkImageRef_Source
func (*ThunkImageRef) GetTag ¶
func (x *ThunkImageRef) GetTag() string
func (*ThunkImageRef) ProtoMessage ¶
func (*ThunkImageRef) ProtoMessage()
func (*ThunkImageRef) ProtoReflect ¶
func (x *ThunkImageRef) ProtoReflect() protoreflect.Message
func (*ThunkImageRef) Reset ¶
func (x *ThunkImageRef) Reset()
func (*ThunkImageRef) String ¶
func (x *ThunkImageRef) String() string
type ThunkImageRef_File ¶
type ThunkImageRef_File struct {
File *ThunkPath `protobuf:"bytes,3,opt,name=file,proto3,oneof"`
}
type ThunkImageRef_Repository ¶
type ThunkImageRef_Repository struct {
Repository string `protobuf:"bytes,2,opt,name=repository,proto3,oneof"`
}
type ThunkImage_Ref ¶
type ThunkImage_Ref struct {
Ref *ThunkImageRef `protobuf:"bytes,1,opt,name=ref,proto3,oneof"`
}
type ThunkImage_Thunk ¶
type ThunkImage_Thunk struct {
Thunk *Thunk `protobuf:"bytes,2,opt,name=thunk,proto3,oneof"`
}
type ThunkMount ¶
type ThunkMount struct { Source *ThunkMountSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Target *FilesystemPath `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` // contains filtered or unexported fields }
func (*ThunkMount) Descriptor
deprecated
func (*ThunkMount) Descriptor() ([]byte, []int)
Deprecated: Use ThunkMount.ProtoReflect.Descriptor instead.
func (*ThunkMount) GetSource ¶
func (x *ThunkMount) GetSource() *ThunkMountSource
func (*ThunkMount) GetTarget ¶
func (x *ThunkMount) GetTarget() *FilesystemPath
func (*ThunkMount) ProtoMessage ¶
func (*ThunkMount) ProtoMessage()
func (*ThunkMount) ProtoReflect ¶
func (x *ThunkMount) ProtoReflect() protoreflect.Message
func (*ThunkMount) Reset ¶
func (x *ThunkMount) Reset()
func (*ThunkMount) String ¶
func (x *ThunkMount) String() string
type ThunkMountSource ¶
type ThunkMountSource struct { // Types that are assignable to Source: // *ThunkMountSource_Thunk // *ThunkMountSource_Host // *ThunkMountSource_Logical // *ThunkMountSource_Cache // *ThunkMountSource_Secret Source isThunkMountSource_Source `protobuf_oneof:"source"` // contains filtered or unexported fields }
func (*ThunkMountSource) Descriptor
deprecated
func (*ThunkMountSource) Descriptor() ([]byte, []int)
Deprecated: Use ThunkMountSource.ProtoReflect.Descriptor instead.
func (*ThunkMountSource) GetCache ¶
func (x *ThunkMountSource) GetCache() *CachePath
func (*ThunkMountSource) GetHost ¶
func (x *ThunkMountSource) GetHost() *HostPath
func (*ThunkMountSource) GetLogical ¶
func (x *ThunkMountSource) GetLogical() *LogicalPath
func (*ThunkMountSource) GetSecret ¶
func (x *ThunkMountSource) GetSecret() *Secret
func (*ThunkMountSource) GetSource ¶
func (m *ThunkMountSource) GetSource() isThunkMountSource_Source
func (*ThunkMountSource) GetThunk ¶
func (x *ThunkMountSource) GetThunk() *ThunkPath
func (*ThunkMountSource) ProtoMessage ¶
func (*ThunkMountSource) ProtoMessage()
func (*ThunkMountSource) ProtoReflect ¶
func (x *ThunkMountSource) ProtoReflect() protoreflect.Message
func (*ThunkMountSource) Reset ¶
func (x *ThunkMountSource) Reset()
func (*ThunkMountSource) String ¶
func (x *ThunkMountSource) String() string
type ThunkMountSource_Cache ¶
type ThunkMountSource_Cache struct {
Cache *CachePath `protobuf:"bytes,4,opt,name=cache,proto3,oneof"`
}
type ThunkMountSource_Host ¶
type ThunkMountSource_Host struct {
Host *HostPath `protobuf:"bytes,2,opt,name=host,proto3,oneof"`
}
type ThunkMountSource_Logical ¶
type ThunkMountSource_Logical struct {
Logical *LogicalPath `protobuf:"bytes,3,opt,name=logical,proto3,oneof"`
}
type ThunkMountSource_Secret ¶
type ThunkMountSource_Secret struct {
Secret *Secret `protobuf:"bytes,5,opt,name=secret,proto3,oneof"`
}
type ThunkMountSource_Thunk ¶
type ThunkMountSource_Thunk struct {
Thunk *ThunkPath `protobuf:"bytes,1,opt,name=thunk,proto3,oneof"`
}
type ThunkPath ¶
type ThunkPath struct { Thunk *Thunk `protobuf:"bytes,1,opt,name=thunk,proto3" json:"thunk,omitempty"` Path *FilesystemPath `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*ThunkPath) Descriptor
deprecated
func (*ThunkPath) GetPath ¶
func (x *ThunkPath) GetPath() *FilesystemPath
func (*ThunkPath) ProtoMessage ¶
func (*ThunkPath) ProtoMessage()
func (*ThunkPath) ProtoReflect ¶
func (x *ThunkPath) ProtoReflect() protoreflect.Message
type UnimplementedRuntimeServer ¶
type UnimplementedRuntimeServer struct { }
UnimplementedRuntimeServer must be embedded to have forward compatible implementations.
func (UnimplementedRuntimeServer) Export ¶
func (UnimplementedRuntimeServer) Export(*Thunk, Runtime_ExportServer) error
func (UnimplementedRuntimeServer) ExportPath ¶
func (UnimplementedRuntimeServer) ExportPath(*ThunkPath, Runtime_ExportPathServer) error
func (UnimplementedRuntimeServer) Read ¶ added in v0.6.1
func (UnimplementedRuntimeServer) Read(*Thunk, Runtime_ReadServer) error
func (UnimplementedRuntimeServer) Resolve ¶
func (UnimplementedRuntimeServer) Resolve(context.Context, *ThunkImageRef) (*ThunkImageRef, error)
func (UnimplementedRuntimeServer) Run ¶
func (UnimplementedRuntimeServer) Run(*Thunk, Runtime_RunServer) error
type UnsafeRuntimeServer ¶
type UnsafeRuntimeServer interface {
// contains filtered or unexported methods
}
UnsafeRuntimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServer will result in compilation errors.
type Value ¶
type Value struct { // Types that are assignable to Value: // *Value_Null // *Value_Bool // *Value_Int // *Value_String_ // *Value_Secret // *Value_Array // *Value_Object // *Value_Thunk // *Value_CommandPath // *Value_FilePath // *Value_DirPath // *Value_HostPath // *Value_ThunkPath // *Value_LogicalPath Value isValue_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
func (*Value) GetCommandPath ¶
func (x *Value) GetCommandPath() *CommandPath
func (*Value) GetDirPath ¶
func (*Value) GetFilePath ¶
func (*Value) GetHostPath ¶
func (*Value) GetLogicalPath ¶
func (x *Value) GetLogicalPath() *LogicalPath
func (*Value) GetString_ ¶
func (*Value) GetThunkPath ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type Value_Array ¶
type Value_Array struct {
Array *Array `protobuf:"bytes,6,opt,name=array,proto3,oneof"`
}
type Value_Bool ¶
type Value_Bool struct {
Bool *Bool `protobuf:"bytes,2,opt,name=bool,proto3,oneof"`
}
type Value_CommandPath ¶
type Value_CommandPath struct {
CommandPath *CommandPath `protobuf:"bytes,9,opt,name=command_path,json=commandPath,proto3,oneof"`
}
type Value_DirPath ¶
type Value_DirPath struct {
DirPath *DirPath `protobuf:"bytes,11,opt,name=dir_path,json=dirPath,proto3,oneof"`
}
type Value_FilePath ¶
type Value_FilePath struct {
FilePath *FilePath `protobuf:"bytes,10,opt,name=file_path,json=filePath,proto3,oneof"`
}
type Value_HostPath ¶
type Value_HostPath struct {
HostPath *HostPath `protobuf:"bytes,12,opt,name=host_path,json=hostPath,proto3,oneof"`
}
type Value_LogicalPath ¶
type Value_LogicalPath struct {
LogicalPath *LogicalPath `protobuf:"bytes,14,opt,name=logical_path,json=logicalPath,proto3,oneof"`
}
type Value_Null ¶
type Value_Null struct {
Null *Null `protobuf:"bytes,1,opt,name=null,proto3,oneof"`
}
type Value_Object ¶
type Value_Object struct {
Object *Object `protobuf:"bytes,7,opt,name=object,proto3,oneof"`
}
type Value_Secret ¶
type Value_Secret struct {
Secret *Secret `protobuf:"bytes,5,opt,name=secret,proto3,oneof"`
}
type Value_String_ ¶
type Value_String_ struct {
String_ *String `protobuf:"bytes,4,opt,name=string,proto3,oneof"`
}
type Value_Thunk ¶
type Value_Thunk struct {
Thunk *Thunk `protobuf:"bytes,8,opt,name=thunk,proto3,oneof"`
}
type Value_ThunkPath ¶
type Value_ThunkPath struct {
ThunkPath *ThunkPath `protobuf:"bytes,13,opt,name=thunk_path,json=thunkPath,proto3,oneof"`
}
type Vertex ¶
type Vertex struct { Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"` Inputs []string `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Started *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started,proto3,oneof" json:"started,omitempty"` Completed *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=completed,proto3,oneof" json:"completed,omitempty"` Cached bool `protobuf:"varint,6,opt,name=cached,proto3" json:"cached,omitempty"` Error *string `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"` // contains filtered or unexported fields }
func (*Vertex) Descriptor
deprecated
func (*Vertex) GetCompleted ¶
func (x *Vertex) GetCompleted() *timestamppb.Timestamp
func (*Vertex) GetStarted ¶
func (x *Vertex) GetStarted() *timestamppb.Timestamp
func (*Vertex) ProtoMessage ¶
func (*Vertex) ProtoMessage()
func (*Vertex) ProtoReflect ¶
func (x *Vertex) ProtoReflect() protoreflect.Message
type VertexLog ¶
type VertexLog struct { Vertex string `protobuf:"bytes,1,opt,name=vertex,proto3" json:"vertex,omitempty"` Stream int64 `protobuf:"varint,2,opt,name=stream,proto3" json:"stream,omitempty"` // TODO: smaller int? Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*VertexLog) Descriptor
deprecated
func (*VertexLog) GetTimestamp ¶
func (x *VertexLog) GetTimestamp() *timestamppb.Timestamp
func (*VertexLog) ProtoMessage ¶
func (*VertexLog) ProtoMessage()
func (*VertexLog) ProtoReflect ¶
func (x *VertexLog) ProtoReflect() protoreflect.Message
type VertexStatus ¶
type VertexStatus struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Vertex string `protobuf:"bytes,2,opt,name=vertex,proto3" json:"vertex,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Total int64 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"` Current int64 `protobuf:"varint,5,opt,name=current,proto3" json:"current,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Started *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started,proto3,oneof" json:"started,omitempty"` Completed *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=completed,proto3,oneof" json:"completed,omitempty"` // contains filtered or unexported fields }
func (*VertexStatus) Descriptor
deprecated
func (*VertexStatus) Descriptor() ([]byte, []int)
Deprecated: Use VertexStatus.ProtoReflect.Descriptor instead.
func (*VertexStatus) GetCompleted ¶
func (x *VertexStatus) GetCompleted() *timestamppb.Timestamp
func (*VertexStatus) GetCurrent ¶
func (x *VertexStatus) GetCurrent() int64
func (*VertexStatus) GetId ¶
func (x *VertexStatus) GetId() string
func (*VertexStatus) GetName ¶
func (x *VertexStatus) GetName() string
func (*VertexStatus) GetStarted ¶
func (x *VertexStatus) GetStarted() *timestamppb.Timestamp
func (*VertexStatus) GetTimestamp ¶
func (x *VertexStatus) GetTimestamp() *timestamppb.Timestamp
func (*VertexStatus) GetTotal ¶
func (x *VertexStatus) GetTotal() int64
func (*VertexStatus) GetVertex ¶
func (x *VertexStatus) GetVertex() string
func (*VertexStatus) ProtoMessage ¶
func (*VertexStatus) ProtoMessage()
func (*VertexStatus) ProtoReflect ¶
func (x *VertexStatus) ProtoReflect() protoreflect.Message
func (*VertexStatus) Reset ¶
func (x *VertexStatus) Reset()
func (*VertexStatus) String ¶
func (x *VertexStatus) String() string