proto

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2022 License: MIT Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_progress_proto protoreflect.FileDescriptor
View Source
var File_runtime_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Array.ProtoReflect.Descriptor instead.

func (*Array) GetValues

func (x *Array) GetValues() []*Value

func (*Array) ProtoMessage

func (*Array) ProtoMessage()

func (*Array) ProtoReflect

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

func (*Array) Reset

func (x *Array) Reset()

func (*Array) String

func (x *Array) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Binding.ProtoReflect.Descriptor instead.

func (*Binding) GetSymbol

func (x *Binding) GetSymbol() string

func (*Binding) GetValue

func (x *Binding) GetValue() *Value

func (*Binding) ProtoMessage

func (*Binding) ProtoMessage()

func (*Binding) ProtoReflect

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

func (*Binding) Reset

func (x *Binding) Reset()

func (*Binding) String

func (x *Binding) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Bool.ProtoReflect.Descriptor instead.

func (*Bool) GetValue

func (x *Bool) GetValue() bool

func (*Bool) ProtoMessage

func (*Bool) ProtoMessage()

func (*Bool) ProtoReflect

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

func (*Bool) Reset

func (x *Bool) Reset()

func (*Bool) String

func (x *Bool) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Bytes.ProtoReflect.Descriptor instead.

func (*Bytes) GetData

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

func (*Bytes) ProtoMessage

func (*Bytes) ProtoMessage()

func (*Bytes) ProtoReflect

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

func (*Bytes) Reset

func (x *Bytes) Reset()

func (*Bytes) String

func (x *Bytes) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use CachePath.ProtoReflect.Descriptor instead.

func (*CachePath) GetId

func (x *CachePath) GetId() string

func (*CachePath) GetPath

func (x *CachePath) GetPath() *FilesystemPath

func (*CachePath) ProtoMessage

func (*CachePath) ProtoMessage()

func (*CachePath) ProtoReflect

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

func (*CachePath) Reset

func (x *CachePath) Reset()

func (*CachePath) String

func (x *CachePath) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DirPath.ProtoReflect.Descriptor instead.

func (*DirPath) GetPath

func (x *DirPath) GetPath() string

func (*DirPath) ProtoMessage

func (*DirPath) ProtoMessage()

func (*DirPath) ProtoReflect

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

func (*DirPath) Reset

func (x *DirPath) Reset()

func (*DirPath) String

func (x *DirPath) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use FilePath.ProtoReflect.Descriptor instead.

func (*FilePath) GetPath

func (x *FilePath) GetPath() string

func (*FilePath) ProtoMessage

func (*FilePath) ProtoMessage()

func (*FilePath) ProtoReflect

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

func (*FilePath) Reset

func (x *FilePath) Reset()

func (*FilePath) String

func (x *FilePath) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use HostPath.ProtoReflect.Descriptor instead.

func (*HostPath) GetContext

func (x *HostPath) GetContext() string

func (*HostPath) GetPath

func (x *HostPath) GetPath() *FilesystemPath

func (*HostPath) ProtoMessage

func (*HostPath) ProtoMessage()

func (*HostPath) ProtoReflect

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

func (*HostPath) Reset

func (x *HostPath) Reset()

func (*HostPath) String

func (x *HostPath) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Int.ProtoReflect.Descriptor instead.

func (*Int) GetValue

func (x *Int) GetValue() int64

func (*Int) ProtoMessage

func (*Int) ProtoMessage()

func (*Int) ProtoReflect

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

func (*Int) Reset

func (x *Int) Reset()

func (*Int) String

func (x *Int) String() string

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 Message

type Message = proto.Message

type Null

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

func (*Null) Descriptor deprecated

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

Deprecated: Use Null.ProtoReflect.Descriptor instead.

func (*Null) ProtoMessage

func (*Null) ProtoMessage()

func (*Null) ProtoReflect

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

func (*Null) Reset

func (x *Null) Reset()

func (*Null) String

func (x *Null) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) GetBindings

func (x *Object) GetBindings() []*Binding

func (*Object) ProtoMessage

func (*Object) ProtoMessage()

func (*Object) ProtoReflect

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

func (*Object) Reset

func (x *Object) Reset()

func (*Object) String

func (x *Object) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Platform.ProtoReflect.Descriptor instead.

func (*Platform) GetArch

func (x *Platform) GetArch() string

func (*Platform) GetOs

func (x *Platform) GetOs() string

func (*Platform) ProtoMessage

func (*Platform) ProtoMessage()

func (*Platform) ProtoReflect

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

func (*Platform) Reset

func (x *Platform) Reset()

func (*Platform) String

func (x *Platform) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Progress.ProtoReflect.Descriptor instead.

func (*Progress) GetLogs

func (x *Progress) GetLogs() []*VertexLog

func (*Progress) GetStatuses

func (x *Progress) GetStatuses() []*VertexStatus

func (*Progress) GetVertexes

func (x *Progress) GetVertexes() []*Vertex

func (*Progress) ProtoMessage

func (*Progress) ProtoMessage()

func (*Progress) ProtoReflect

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

func (*Progress) Reset

func (x *Progress) Reset()

func (*Progress) String

func (x *Progress) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetName

func (x *Secret) GetName() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

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

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use String.ProtoReflect.Descriptor instead.

func (*String) GetValue

func (x *String) GetValue() string

func (*String) ProtoMessage

func (*String) ProtoMessage()

func (*String) ProtoReflect

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

func (*String) Reset

func (x *String) Reset()

func (*String) String

func (x *String) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Thunk.ProtoReflect.Descriptor instead.

func (*Thunk) GetArgs

func (x *Thunk) GetArgs() []*Value

func (*Thunk) GetCmd

func (x *Thunk) GetCmd() *ThunkCmd

func (*Thunk) GetDir

func (x *Thunk) GetDir() *ThunkDir

func (*Thunk) GetEnv

func (x *Thunk) GetEnv() []*Binding

func (*Thunk) GetImage

func (x *Thunk) GetImage() *ThunkImage

func (*Thunk) GetInsecure

func (x *Thunk) GetInsecure() bool

func (*Thunk) GetLabels

func (x *Thunk) GetLabels() []*Binding

func (*Thunk) GetMounts

func (x *Thunk) GetMounts() []*ThunkMount

func (*Thunk) GetStdin

func (x *Thunk) GetStdin() []*Value

func (*Thunk) ProtoMessage

func (*Thunk) ProtoMessage()

func (*Thunk) ProtoReflect

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

func (*Thunk) Reset

func (x *Thunk) Reset()

func (*Thunk) String

func (x *Thunk) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ThunkCmd.ProtoReflect.Descriptor instead.

func (*ThunkCmd) GetCache added in v0.7.0

func (x *ThunkCmd) GetCache() *CachePath

func (*ThunkCmd) GetCmd

func (m *ThunkCmd) GetCmd() isThunkCmd_Cmd

func (*ThunkCmd) GetCommand

func (x *ThunkCmd) GetCommand() *CommandPath

func (*ThunkCmd) GetFile

func (x *ThunkCmd) GetFile() *FilePath

func (*ThunkCmd) GetHost

func (x *ThunkCmd) GetHost() *HostPath

func (*ThunkCmd) GetLogical

func (x *ThunkCmd) GetLogical() *LogicalPath

func (*ThunkCmd) GetThunk

func (x *ThunkCmd) GetThunk() *ThunkPath

func (*ThunkCmd) ProtoMessage

func (*ThunkCmd) ProtoMessage()

func (*ThunkCmd) ProtoReflect

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

func (*ThunkCmd) Reset

func (x *ThunkCmd) Reset()

func (*ThunkCmd) String

func (x *ThunkCmd) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ThunkDir.ProtoReflect.Descriptor instead.

func (*ThunkDir) GetDir

func (m *ThunkDir) GetDir() isThunkDir_Dir

func (*ThunkDir) GetHost

func (x *ThunkDir) GetHost() *HostPath

func (*ThunkDir) GetLocal

func (x *ThunkDir) GetLocal() *DirPath

func (*ThunkDir) GetThunk

func (x *ThunkDir) GetThunk() *ThunkPath

func (*ThunkDir) ProtoMessage

func (*ThunkDir) ProtoMessage()

func (*ThunkDir) ProtoReflect

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

func (*ThunkDir) Reset

func (x *ThunkDir) Reset()

func (*ThunkDir) String

func (x *ThunkDir) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ThunkPath.ProtoReflect.Descriptor instead.

func (*ThunkPath) GetPath

func (x *ThunkPath) GetPath() *FilesystemPath

func (*ThunkPath) GetThunk

func (x *ThunkPath) GetThunk() *Thunk

func (*ThunkPath) ProtoMessage

func (*ThunkPath) ProtoMessage()

func (*ThunkPath) ProtoReflect

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

func (*ThunkPath) Reset

func (x *ThunkPath) Reset()

func (*ThunkPath) String

func (x *ThunkPath) String() string

type UnimplementedRuntimeServer

type UnimplementedRuntimeServer struct {
}

UnimplementedRuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServer) Export

func (UnimplementedRuntimeServer) ExportPath

func (UnimplementedRuntimeServer) Read added in v0.6.1

func (UnimplementedRuntimeServer) Resolve

func (UnimplementedRuntimeServer) Run

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 NewValue

func NewValue(msg Message) (*Value, error)

func (*Value) Descriptor deprecated

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetArray

func (x *Value) GetArray() *Array

func (*Value) GetBool

func (x *Value) GetBool() *Bool

func (*Value) GetCommandPath

func (x *Value) GetCommandPath() *CommandPath

func (*Value) GetDirPath

func (x *Value) GetDirPath() *DirPath

func (*Value) GetFilePath

func (x *Value) GetFilePath() *FilePath

func (*Value) GetHostPath

func (x *Value) GetHostPath() *HostPath

func (*Value) GetInt

func (x *Value) GetInt() *Int

func (*Value) GetLogicalPath

func (x *Value) GetLogicalPath() *LogicalPath

func (*Value) GetNull

func (x *Value) GetNull() *Null

func (*Value) GetObject

func (x *Value) GetObject() *Object

func (*Value) GetSecret

func (x *Value) GetSecret() *Secret

func (*Value) GetString_

func (x *Value) GetString_() *String

func (*Value) GetThunk

func (x *Value) GetThunk() *Thunk

func (*Value) GetThunkPath

func (x *Value) GetThunkPath() *ThunkPath

func (*Value) GetValue

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) ProtoReflect

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

func (*Value) Reset

func (x *Value) Reset()

func (*Value) String

func (x *Value) String() string

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_Int

type Value_Int struct {
	Int *Int `protobuf:"bytes,3,opt,name=int,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) Descriptor() ([]byte, []int)

Deprecated: Use Vertex.ProtoReflect.Descriptor instead.

func (*Vertex) GetCached

func (x *Vertex) GetCached() bool

func (*Vertex) GetCompleted

func (x *Vertex) GetCompleted() *timestamppb.Timestamp

func (*Vertex) GetDigest

func (x *Vertex) GetDigest() string

func (*Vertex) GetError

func (x *Vertex) GetError() string

func (*Vertex) GetInputs

func (x *Vertex) GetInputs() []string

func (*Vertex) GetName

func (x *Vertex) GetName() string

func (*Vertex) GetStarted

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

func (*Vertex) ProtoMessage

func (*Vertex) ProtoMessage()

func (*Vertex) ProtoReflect

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

func (*Vertex) Reset

func (x *Vertex) Reset()

func (*Vertex) String

func (x *Vertex) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use VertexLog.ProtoReflect.Descriptor instead.

func (*VertexLog) GetData

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

func (*VertexLog) GetStream

func (x *VertexLog) GetStream() int64

func (*VertexLog) GetTimestamp

func (x *VertexLog) GetTimestamp() *timestamppb.Timestamp

func (*VertexLog) GetVertex

func (x *VertexLog) GetVertex() string

func (*VertexLog) ProtoMessage

func (*VertexLog) ProtoMessage()

func (*VertexLog) ProtoReflect

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

func (*VertexLog) Reset

func (x *VertexLog) Reset()

func (*VertexLog) String

func (x *VertexLog) String() string

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL