protoscanner

Documentation

Index

• Constants
• type ProtoScanner
  • func NewProtoScanner(scannerType ProtoScannerType, lineSplitter abstract.LfLineSplitter, ...) (ProtoScanner, error)
• type ProtoScannerType
• type RepeatedScanner
  • func NewRepeatedScanner(data []byte, wrapperDesc protoreflect.MessageDescriptor) (*RepeatedScanner, error)
  • func (s *RepeatedScanner) ApxDataLen() int
  • func (s *RepeatedScanner) Err() error
  • func (s *RepeatedScanner) Message() (protoreflect.Message, error)
  • func (s *RepeatedScanner) RawData() []byte
  • func (s *RepeatedScanner) Scan() (res bool)
• type SplitterScanner
  • func NewSplitterScanner(lineSplitter abstract.LfLineSplitter, data []byte, ...) (*SplitterScanner, error)
  • func (s *SplitterScanner) ApxDataLen() int
  • func (s *SplitterScanner) Err() error
  • func (s *SplitterScanner) Message() (protoreflect.Message, error)
  • func (s *SplitterScanner) RawData() []byte
  • func (s *SplitterScanner) Scan() bool

Constants

const (
	ScannerTypeLineSplitter = ProtoScannerType("lineSplitter")
	ScannerTypeRepeated     = ProtoScannerType("repeated")
)

Types

type ProtoScanner

type ProtoScanner interface {
	Scan() bool
	Message() (protoreflect.Message, error)
	RawData() []byte
	// Approximate raw data len
	ApxDataLen() int
	Err() error
}

func NewProtoScanner

func NewProtoScanner(scannerType ProtoScannerType, lineSplitter abstract.LfLineSplitter, data []byte, msgDesc protoreflect.MessageDescriptor) (ProtoScanner, error)

type ProtoScannerType

type ProtoScannerType string

type RepeatedScanner

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

func NewRepeatedScanner

func NewRepeatedScanner(data []byte, wrapperDesc protoreflect.MessageDescriptor) (*RepeatedScanner, error)

func (*RepeatedScanner) ApxDataLen

func (s *RepeatedScanner) ApxDataLen() int

func (*RepeatedScanner) Err

func (s *RepeatedScanner) Err() error

func (*RepeatedScanner) Message

func (s *RepeatedScanner) Message() (protoreflect.Message, error)

func (*RepeatedScanner) RawData

func (s *RepeatedScanner) RawData() []byte

func (*RepeatedScanner) Scan

func (s *RepeatedScanner) Scan() (res bool)

type SplitterScanner

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

func NewSplitterScanner

func NewSplitterScanner(lineSplitter abstract.LfLineSplitter, data []byte, msgDesc protoreflect.MessageDescriptor) (*SplitterScanner, error)

func (*SplitterScanner) ApxDataLen

func (s *SplitterScanner) ApxDataLen() int

func (*SplitterScanner) Err

func (s *SplitterScanner) Err() error

func (*SplitterScanner) Message

func (s *SplitterScanner) Message() (protoreflect.Message, error)

func (*SplitterScanner) RawData

func (s *SplitterScanner) RawData() []byte

func (*SplitterScanner) Scan

func (s *SplitterScanner) Scan() bool