Documentation ¶
Index ¶
- func IsCanceled(ctx context.Context, err error) bool
- func NewUnknownJobError(id string) error
- func NewUnsupportedFrontendCapError(name string) error
- func NewUnsupportedSubrequestError(name string) error
- func WithOp(err error, iface interface{}) error
- func WithSolveError(err error, subject IsSolve_Subject, inputIDs, mountIDs []string) error
- func WithSource(err error, src Source) error
- func WrapVertex(err error, dgst digest.Digest) error
- type ContentCache
- func (*ContentCache) Descriptor() ([]byte, []int)
- func (m *ContentCache) GetIndex() int64
- func (*ContentCache) ProtoMessage()
- func (m *ContentCache) Reset()
- func (m *ContentCache) String() string
- func (m *ContentCache) XXX_DiscardUnknown()
- func (m *ContentCache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContentCache) XXX_Merge(src proto.Message)
- func (m *ContentCache) XXX_Size() int
- func (m *ContentCache) XXX_Unmarshal(b []byte) error
- type ErrorSource
- type FileAction
- func (*FileAction) Descriptor() ([]byte, []int)
- func (m *FileAction) GetIndex() int64
- func (*FileAction) ProtoMessage()
- func (m *FileAction) Reset()
- func (m *FileAction) String() string
- func (m *FileAction) XXX_DiscardUnknown()
- func (m *FileAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileAction) XXX_Merge(src proto.Message)
- func (m *FileAction) XXX_Size() int
- func (m *FileAction) XXX_Unmarshal(b []byte) error
- type FrontendCap
- func (*FrontendCap) Descriptor() ([]byte, []int)
- func (m *FrontendCap) GetName() string
- func (*FrontendCap) ProtoMessage()
- func (m *FrontendCap) Reset()
- func (m *FrontendCap) String() string
- func (v *FrontendCap) WrapError(err error) error
- func (m *FrontendCap) XXX_DiscardUnknown()
- func (m *FrontendCap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FrontendCap) XXX_Merge(src proto.Message)
- func (m *FrontendCap) XXX_Size() int
- func (m *FrontendCap) XXX_Unmarshal(b []byte) error
- type IsSolve_Subject
- type OpError
- type Solve
- func (*Solve) Descriptor() ([]byte, []int)
- func (m *Solve) GetCache() *ContentCache
- func (m *Solve) GetFile() *FileAction
- func (m *Solve) GetInputIDs() []string
- func (m *Solve) GetMountIDs() []string
- func (m *Solve) GetOp() *pb.Op
- func (m *Solve) GetSubject() isSolve_Subject
- func (v *Solve) MarshalJSON() ([]byte, error)
- func (*Solve) ProtoMessage()
- func (m *Solve) Reset()
- func (m *Solve) String() string
- func (v *Solve) UnmarshalJSON(b []byte) error
- func (v *Solve) WrapError(err error) error
- func (m *Solve) XXX_DiscardUnknown()
- func (m *Solve) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Solve) XXX_Merge(src proto.Message)
- func (*Solve) XXX_OneofWrappers() []interface{}
- func (m *Solve) XXX_Size() int
- func (m *Solve) XXX_Unmarshal(b []byte) error
- type SolveError
- type Solve_Cache
- type Solve_File
- type Source
- func (*Source) Descriptor() ([]byte, []int)
- func (m *Source) GetInfo() *pb.SourceInfo
- func (m *Source) GetRanges() []*pb.Range
- func (s *Source) Print(w io.Writer) error
- func (*Source) ProtoMessage()
- func (m *Source) Reset()
- func (m *Source) String() string
- func (s *Source) WrapError(err error) error
- func (m *Source) XXX_DiscardUnknown()
- func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Source) XXX_Merge(src proto.Message)
- func (m *Source) XXX_Size() int
- func (m *Source) XXX_Unmarshal(b []byte) error
- type Subrequest
- func (*Subrequest) Descriptor() ([]byte, []int)
- func (m *Subrequest) GetName() string
- func (*Subrequest) ProtoMessage()
- func (m *Subrequest) Reset()
- func (m *Subrequest) String() string
- func (v *Subrequest) WrapError(err error) error
- func (m *Subrequest) XXX_DiscardUnknown()
- func (m *Subrequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Subrequest) XXX_Merge(src proto.Message)
- func (m *Subrequest) XXX_Size() int
- func (m *Subrequest) XXX_Unmarshal(b []byte) error
- type UnknownJobError
- type UnsupportedFrontendCapError
- type UnsupportedSubrequestError
- type Vertex
- func (*Vertex) Descriptor() ([]byte, []int)
- func (m *Vertex) GetDigest() string
- func (*Vertex) ProtoMessage()
- func (m *Vertex) Reset()
- func (m *Vertex) String() string
- func (v *Vertex) WrapError(err error) error
- func (m *Vertex) XXX_DiscardUnknown()
- func (m *Vertex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Vertex) XXX_Merge(src proto.Message)
- func (m *Vertex) XXX_Size() int
- func (m *Vertex) XXX_Unmarshal(b []byte) error
- type VertexError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewUnknownJobError ¶
func WithSolveError ¶
func WithSolveError(err error, subject IsSolve_Subject, inputIDs, mountIDs []string) error
func WithSource ¶
Types ¶
type ContentCache ¶
type ContentCache struct { // Original index of result that failed the slow cache calculation. Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ContentCache) Descriptor ¶
func (*ContentCache) Descriptor() ([]byte, []int)
func (*ContentCache) GetIndex ¶
func (m *ContentCache) GetIndex() int64
func (*ContentCache) ProtoMessage ¶
func (*ContentCache) ProtoMessage()
func (*ContentCache) Reset ¶
func (m *ContentCache) Reset()
func (*ContentCache) String ¶
func (m *ContentCache) String() string
func (*ContentCache) XXX_DiscardUnknown ¶
func (m *ContentCache) XXX_DiscardUnknown()
func (*ContentCache) XXX_Marshal ¶
func (m *ContentCache) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContentCache) XXX_Merge ¶
func (m *ContentCache) XXX_Merge(src proto.Message)
func (*ContentCache) XXX_Size ¶
func (m *ContentCache) XXX_Size() int
func (*ContentCache) XXX_Unmarshal ¶
func (m *ContentCache) XXX_Unmarshal(b []byte) error
type ErrorSource ¶
type ErrorSource struct { Source // contains filtered or unexported fields }
func (*ErrorSource) ToProto ¶
func (e *ErrorSource) ToProto() grpcerrors.TypedErrorProto
func (*ErrorSource) Unwrap ¶
func (e *ErrorSource) Unwrap() error
type FileAction ¶
type FileAction struct { // Index of the file action that failed the exec. Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FileAction) Descriptor ¶
func (*FileAction) Descriptor() ([]byte, []int)
func (*FileAction) GetIndex ¶
func (m *FileAction) GetIndex() int64
func (*FileAction) ProtoMessage ¶
func (*FileAction) ProtoMessage()
func (*FileAction) Reset ¶
func (m *FileAction) Reset()
func (*FileAction) String ¶
func (m *FileAction) String() string
func (*FileAction) XXX_DiscardUnknown ¶
func (m *FileAction) XXX_DiscardUnknown()
func (*FileAction) XXX_Marshal ¶
func (m *FileAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileAction) XXX_Merge ¶
func (m *FileAction) XXX_Merge(src proto.Message)
func (*FileAction) XXX_Size ¶
func (m *FileAction) XXX_Size() int
func (*FileAction) XXX_Unmarshal ¶
func (m *FileAction) XXX_Unmarshal(b []byte) error
type FrontendCap ¶
type FrontendCap struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FrontendCap) Descriptor ¶
func (*FrontendCap) Descriptor() ([]byte, []int)
func (*FrontendCap) GetName ¶
func (m *FrontendCap) GetName() string
func (*FrontendCap) ProtoMessage ¶
func (*FrontendCap) ProtoMessage()
func (*FrontendCap) Reset ¶
func (m *FrontendCap) Reset()
func (*FrontendCap) String ¶
func (m *FrontendCap) String() string
func (*FrontendCap) WrapError ¶
func (v *FrontendCap) WrapError(err error) error
func (*FrontendCap) XXX_DiscardUnknown ¶
func (m *FrontendCap) XXX_DiscardUnknown()
func (*FrontendCap) XXX_Marshal ¶
func (m *FrontendCap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FrontendCap) XXX_Merge ¶
func (m *FrontendCap) XXX_Merge(src proto.Message)
func (*FrontendCap) XXX_Size ¶
func (m *FrontendCap) XXX_Size() int
func (*FrontendCap) XXX_Unmarshal ¶
func (m *FrontendCap) XXX_Unmarshal(b []byte) error
type IsSolve_Subject ¶
type IsSolve_Subject isSolve_Subject
type Solve ¶
type Solve struct { InputIDs []string `protobuf:"bytes,1,rep,name=inputIDs,proto3" json:"inputIDs,omitempty"` MountIDs []string `protobuf:"bytes,2,rep,name=mountIDs,proto3" json:"mountIDs,omitempty"` Op *pb.Op `protobuf:"bytes,3,opt,name=op,proto3" json:"op,omitempty"` // Types that are valid to be assigned to Subject: // // *Solve_File // *Solve_Cache Subject isSolve_Subject `protobuf_oneof:"subject"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Solve) Descriptor ¶
func (*Solve) GetCache ¶
func (m *Solve) GetCache() *ContentCache
func (*Solve) GetFile ¶
func (m *Solve) GetFile() *FileAction
func (*Solve) GetInputIDs ¶
func (*Solve) GetMountIDs ¶
func (*Solve) GetSubject ¶
func (m *Solve) GetSubject() isSolve_Subject
func (*Solve) MarshalJSON ¶
func (*Solve) ProtoMessage ¶
func (*Solve) ProtoMessage()
func (*Solve) UnmarshalJSON ¶
func (*Solve) XXX_DiscardUnknown ¶
func (m *Solve) XXX_DiscardUnknown()
func (*Solve) XXX_Marshal ¶
func (*Solve) XXX_OneofWrappers ¶
func (*Solve) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Solve) XXX_Unmarshal ¶
type SolveError ¶
SolveError will be returned when an error is encountered during a solve that has an exec op.
func (*SolveError) Error ¶
func (e *SolveError) Error() string
func (*SolveError) ToProto ¶
func (e *SolveError) ToProto() grpcerrors.TypedErrorProto
func (*SolveError) Unwrap ¶
func (e *SolveError) Unwrap() error
type Solve_Cache ¶
type Solve_Cache struct {
Cache *ContentCache `protobuf:"bytes,5,opt,name=cache,proto3,oneof" json:"cache,omitempty"`
}
type Solve_File ¶
type Solve_File struct {
File *FileAction `protobuf:"bytes,4,opt,name=file,proto3,oneof" json:"file,omitempty"`
}
type Source ¶
type Source struct { Info *pb.SourceInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"` Ranges []*pb.Range `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Source) Descriptor ¶
func (*Source) GetInfo ¶
func (m *Source) GetInfo() *pb.SourceInfo
func (*Source) ProtoMessage ¶
func (*Source) ProtoMessage()
func (*Source) XXX_DiscardUnknown ¶
func (m *Source) XXX_DiscardUnknown()
func (*Source) XXX_Marshal ¶
func (*Source) XXX_Unmarshal ¶
type Subrequest ¶
type Subrequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Subrequest) Descriptor ¶
func (*Subrequest) Descriptor() ([]byte, []int)
func (*Subrequest) GetName ¶
func (m *Subrequest) GetName() string
func (*Subrequest) ProtoMessage ¶
func (*Subrequest) ProtoMessage()
func (*Subrequest) Reset ¶
func (m *Subrequest) Reset()
func (*Subrequest) String ¶
func (m *Subrequest) String() string
func (*Subrequest) WrapError ¶
func (v *Subrequest) WrapError(err error) error
func (*Subrequest) XXX_DiscardUnknown ¶
func (m *Subrequest) XXX_DiscardUnknown()
func (*Subrequest) XXX_Marshal ¶
func (m *Subrequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Subrequest) XXX_Merge ¶
func (m *Subrequest) XXX_Merge(src proto.Message)
func (*Subrequest) XXX_Size ¶
func (m *Subrequest) XXX_Size() int
func (*Subrequest) XXX_Unmarshal ¶
func (m *Subrequest) XXX_Unmarshal(b []byte) error
type UnknownJobError ¶
type UnknownJobError struct {
// contains filtered or unexported fields
}
func (*UnknownJobError) Code ¶
func (e *UnknownJobError) Code() codes.Code
func (*UnknownJobError) Error ¶
func (e *UnknownJobError) Error() string
type UnsupportedFrontendCapError ¶
type UnsupportedFrontendCapError struct { FrontendCap // contains filtered or unexported fields }
func (*UnsupportedFrontendCapError) Error ¶
func (e *UnsupportedFrontendCapError) Error() string
func (*UnsupportedFrontendCapError) ToProto ¶
func (e *UnsupportedFrontendCapError) ToProto() grpcerrors.TypedErrorProto
func (*UnsupportedFrontendCapError) Unwrap ¶
func (e *UnsupportedFrontendCapError) Unwrap() error
type UnsupportedSubrequestError ¶
type UnsupportedSubrequestError struct { Subrequest // contains filtered or unexported fields }
func (*UnsupportedSubrequestError) Error ¶
func (e *UnsupportedSubrequestError) Error() string
func (*UnsupportedSubrequestError) ToProto ¶
func (e *UnsupportedSubrequestError) ToProto() grpcerrors.TypedErrorProto
func (*UnsupportedSubrequestError) Unwrap ¶
func (e *UnsupportedSubrequestError) Unwrap() error
type Vertex ¶
type Vertex struct { Digest string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Vertex) Descriptor ¶
func (*Vertex) ProtoMessage ¶
func (*Vertex) ProtoMessage()
func (*Vertex) XXX_DiscardUnknown ¶
func (m *Vertex) XXX_DiscardUnknown()
func (*Vertex) XXX_Marshal ¶
func (*Vertex) XXX_Unmarshal ¶
type VertexError ¶
type VertexError struct { Vertex // contains filtered or unexported fields }
func (*VertexError) ToProto ¶
func (e *VertexError) ToProto() grpcerrors.TypedErrorProto
func (*VertexError) Unwrap ¶
func (e *VertexError) Unwrap() error
Click to show internal directories.
Click to hide internal directories.