Documentation
¶
Index ¶
- Variables
- func RecordFromProto(record *Record) (*integration.Record, error)
- func ResultFromProto(result *Result) (*integration.Result, error)
- type ExtendedAttributeType
- func (ExtendedAttributeType) Descriptor() protoreflect.EnumDescriptor
- func (x ExtendedAttributeType) Enum() *ExtendedAttributeType
- func (ExtendedAttributeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExtendedAttributeType) Number() protoreflect.EnumNumber
- func (x ExtendedAttributeType) String() string
- func (ExtendedAttributeType) Type() protoreflect.EnumType
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FileInfo) GetDev() uint64
- func (x *FileInfo) GetFlags() uint32
- func (x *FileInfo) GetGid() uint64
- func (x *FileInfo) GetGroupname() string
- func (x *FileInfo) GetIno() uint64
- func (x *FileInfo) GetModTime() *timestamppb.Timestamp
- func (x *FileInfo) GetMode() uint32
- func (x *FileInfo) GetName() string
- func (x *FileInfo) GetNlink() uint32
- func (x *FileInfo) GetSize() int64
- func (x *FileInfo) GetUid() uint64
- func (x *FileInfo) GetUsername() string
- func (*FileInfo) ProtoMessage()
- func (x *FileInfo) ProtoReflect() protoreflect.Message
- func (x *FileInfo) Reset()
- func (x *FileInfo) String() string
- type HoldingReaders
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetError() string
- func (x *Record) GetExtendedAttributes() []string
- func (x *Record) GetFileAttributes() uint32
- func (x *Record) GetFileInfo() *FileInfo
- func (x *Record) GetHasReader() bool
- func (x *Record) GetIsXattr() bool
- func (x *Record) GetPathname() string
- func (x *Record) GetTarget() string
- func (x *Record) GetXattrName() string
- func (x *Record) GetXattrType() ExtendedAttributeType
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- type Result
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ExtendedAttributeType_name = map[int32]string{ 0: "EXTENDED_ATTRIBUTE_TYPE_UNSPECIFIED", 1: "EXTENDED_ATTRIBUTE_TYPE_EXTENDED", 2: "EXTENDED_ATTRIBUTE_TYPE_ADS", } ExtendedAttributeType_value = map[string]int32{ "EXTENDED_ATTRIBUTE_TYPE_UNSPECIFIED": 0, "EXTENDED_ATTRIBUTE_TYPE_EXTENDED": 1, "EXTENDED_ATTRIBUTE_TYPE_ADS": 2, } )
Enum value maps for ExtendedAttributeType.
View Source
var (
ErrInvalidRecord = errors.New("invalid record")
)
View Source
var File_connectors_proto protoreflect.FileDescriptor
Functions ¶
func RecordFromProto ¶
func RecordFromProto(record *Record) (*integration.Record, error)
func ResultFromProto ¶
func ResultFromProto(result *Result) (*integration.Result, error)
Types ¶
type ExtendedAttributeType ¶
type ExtendedAttributeType int32
const ( ExtendedAttributeType_EXTENDED_ATTRIBUTE_TYPE_UNSPECIFIED ExtendedAttributeType = 0 ExtendedAttributeType_EXTENDED_ATTRIBUTE_TYPE_EXTENDED ExtendedAttributeType = 1 ExtendedAttributeType_EXTENDED_ATTRIBUTE_TYPE_ADS ExtendedAttributeType = 2 )
func (ExtendedAttributeType) Descriptor ¶
func (ExtendedAttributeType) Descriptor() protoreflect.EnumDescriptor
func (ExtendedAttributeType) Enum ¶
func (x ExtendedAttributeType) Enum() *ExtendedAttributeType
func (ExtendedAttributeType) EnumDescriptor
deprecated
func (ExtendedAttributeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExtendedAttributeType.Descriptor instead.
func (ExtendedAttributeType) Number ¶
func (x ExtendedAttributeType) Number() protoreflect.EnumNumber
func (ExtendedAttributeType) String ¶
func (x ExtendedAttributeType) String() string
func (ExtendedAttributeType) Type ¶
func (ExtendedAttributeType) Type() protoreflect.EnumType
type FileInfo ¶
type FileInfo struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
Mode uint32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
ModTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=mod_time,json=modTime,proto3" json:"mod_time,omitempty"`
Dev uint64 `protobuf:"varint,5,opt,name=dev,proto3" json:"dev,omitempty"`
Ino uint64 `protobuf:"varint,6,opt,name=ino,proto3" json:"ino,omitempty"`
Uid uint64 `protobuf:"varint,7,opt,name=uid,proto3" json:"uid,omitempty"`
Gid uint64 `protobuf:"varint,8,opt,name=gid,proto3" json:"gid,omitempty"`
Nlink uint32 `protobuf:"varint,9,opt,name=nlink,proto3" json:"nlink,omitempty"` // but is really uint16
Username string `protobuf:"bytes,10,opt,name=username,proto3" json:"username,omitempty"`
Groupname string `protobuf:"bytes,11,opt,name=groupname,proto3" json:"groupname,omitempty"`
Flags uint32 `protobuf:"varint,12,opt,name=flags,proto3" json:"flags,omitempty"`
// contains filtered or unexported fields
}
func (*FileInfo) Descriptor
deprecated
func (*FileInfo) GetGroupname ¶
func (*FileInfo) GetModTime ¶
func (x *FileInfo) GetModTime() *timestamppb.Timestamp
func (*FileInfo) GetUsername ¶
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
func (*FileInfo) ProtoReflect ¶
func (x *FileInfo) ProtoReflect() protoreflect.Message
type HoldingReaders ¶
type HoldingReaders struct {
// contains filtered or unexported fields
}
func NewHoldingReaders ¶
func NewHoldingReaders() *HoldingReaders
func (*HoldingReaders) Close ¶
func (h *HoldingReaders) Close() (err error)
func (*HoldingReaders) Get ¶
func (h *HoldingReaders) Get(record *integration.Record) io.ReadCloser
func (*HoldingReaders) Track ¶
func (h *HoldingReaders) Track(record *integration.Record)
type Record ¶
type Record struct {
HasReader bool `protobuf:"varint,1,opt,name=hasReader,proto3" json:"hasReader,omitempty"`
Pathname string `protobuf:"bytes,2,opt,name=pathname,proto3" json:"pathname,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
IsXattr bool `protobuf:"varint,4,opt,name=isXattr,proto3" json:"isXattr,omitempty"`
XattrName string `protobuf:"bytes,5,opt,name=xattrName,proto3" json:"xattrName,omitempty"`
XattrType ExtendedAttributeType `protobuf:"varint,6,opt,name=xattrType,proto3,enum=plakar.connectors.ExtendedAttributeType" json:"xattrType,omitempty"`
Target string `protobuf:"bytes,7,opt,name=target,proto3" json:"target,omitempty"`
FileInfo *FileInfo `protobuf:"bytes,8,opt,name=fileInfo,proto3" json:"fileInfo,omitempty"`
ExtendedAttributes []string `protobuf:"bytes,9,rep,name=extendedAttributes,proto3" json:"extendedAttributes,omitempty"`
FileAttributes uint32 `protobuf:"varint,10,opt,name=fileAttributes,proto3" json:"fileAttributes,omitempty"`
// contains filtered or unexported fields
}
func RecordToProto ¶
func RecordToProto(record *integration.Record) *Record
func (*Record) Descriptor
deprecated
func (*Record) GetExtendedAttributes ¶
func (*Record) GetFileAttributes ¶
func (*Record) GetFileInfo ¶
func (*Record) GetHasReader ¶
func (*Record) GetIsXattr ¶
func (*Record) GetPathname ¶
func (*Record) GetXattrName ¶
func (*Record) GetXattrType ¶
func (x *Record) GetXattrType() ExtendedAttributeType
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
type Result ¶
type Result struct {
Header *Record `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func ResultToProto ¶
func ResultToProto(result *integration.Result) *Result
func (*Result) Descriptor
deprecated
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶
func (x *Result) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.