Help us shape the future of Go! Take the 2026 Go Developer Survey

proto

package
v1.1.2 Latest Latest
Warning

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

Go to latest
Published: Oct 28, 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) Enum

func (ExtendedAttributeType) EnumDescriptor deprecated

func (ExtendedAttributeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExtendedAttributeType.Descriptor instead.

func (ExtendedAttributeType) Number

func (ExtendedAttributeType) String

func (x ExtendedAttributeType) String() string

func (ExtendedAttributeType) Type

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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