proto

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2026 License: ISC Imports: 11 Imported by: 0

Documentation

Index

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetDev 

func (x *FileInfo) GetDev() uint64

func (*FileInfo) GetFlags 

func (x *FileInfo) GetFlags() uint32

func (*FileInfo) GetGid 

func (x *FileInfo) GetGid() uint64

func (*FileInfo) GetGroupname 

func (x *FileInfo) GetGroupname() string

func (*FileInfo) GetIno 

func (x *FileInfo) GetIno() uint64

func (*FileInfo) GetModTime 

func (x *FileInfo) GetModTime() *timestamppb.Timestamp

func (*FileInfo) GetMode 

func (x *FileInfo) GetMode() uint32

func (*FileInfo) GetName 

func (x *FileInfo) GetName() string
func (x *FileInfo) GetNlink() uint32

func (*FileInfo) GetSize 

func (x *FileInfo) GetSize() int64

func (*FileInfo) GetUid 

func (x *FileInfo) GetUid() uint64

func (*FileInfo) GetUsername 

func (x *FileInfo) GetUsername() string

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

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

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetError 

func (x *Record) GetError() string

func (*Record) GetExtendedAttributes 

func (x *Record) GetExtendedAttributes() []string

func (*Record) GetFileAttributes 

func (x *Record) GetFileAttributes() uint32

func (*Record) GetFileInfo 

func (x *Record) GetFileInfo() *FileInfo

func (*Record) GetHasReader 

func (x *Record) GetHasReader() bool

func (*Record) GetIsXattr 

func (x *Record) GetIsXattr() bool

func (*Record) GetPathname 

func (x *Record) GetPathname() string

func (*Record) GetTarget 

func (x *Record) GetTarget() string

func (*Record) GetXattrName 

func (x *Record) GetXattrName() string

func (*Record) GetXattrType 

func (x *Record) GetXattrType() ExtendedAttributeType

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetError 

func (x *Result) GetError() string

func (*Result) GetHeader 

func (x *Result) GetHeader() *Record

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

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

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.