protobuf

Documentation

Index

• func NewParserProto(inWrapped interface{}, _ bool, logger log.Logger, metrics *stats.SourceStats) (parsers.Parser, error)
• type ParserConfigProtoCommon
  • func (c *ParserConfigProtoCommon) IsAppendOnly() bool
  • func (c *ParserConfigProtoCommon) IsNewParserConfig()
  • func (c *ParserConfigProtoCommon) ToProtoParserConfig(logger log.Logger) (*protoparser.ProtoParserConfig, error)
  • func (c *ParserConfigProtoCommon) Validate() error
• type ParserConfigProtoLb
  • func (c *ParserConfigProtoLb) IsAppendOnly() bool
  • func (c *ParserConfigProtoLb) IsNewParserConfig()
  • func (c *ParserConfigProtoLb) ToProtoParserConfig(logger log.Logger) (*protoparser.ProtoParserConfig, error)
  • func (c *ParserConfigProtoLb) Validate() error
• type ProtoConfigurable

Functions

func NewParserProto

func NewParserProto(inWrapped interface{}, _ bool, logger log.Logger, metrics *stats.SourceStats) (parsers.Parser, error)

Types

type ParserConfigProtoCommon

type ParserConfigProtoCommon struct {
	DescFile         []byte
	DescResourceName string
	MessageName      string

	IncludeColumns []protoparser.ColParams
	PrimaryKeys    []string
	PackageType    protoparser.MessagePackageType

	NullKeysAllowed bool
}

func (*ParserConfigProtoCommon) IsAppendOnly

func (c *ParserConfigProtoCommon) IsAppendOnly() bool

func (*ParserConfigProtoCommon) IsNewParserConfig

func (c *ParserConfigProtoCommon) IsNewParserConfig()

func (*ParserConfigProtoCommon) ToProtoParserConfig

func (c *ParserConfigProtoCommon) ToProtoParserConfig(logger log.Logger) (*protoparser.ProtoParserConfig, error)

func (*ParserConfigProtoCommon) Validate

func (c *ParserConfigProtoCommon) Validate() error

type ParserConfigProtoLb

type ParserConfigProtoLb struct {
	DescFile         []byte
	DescResourceName string
	MessageName      string

	IncludeColumns []protoparser.ColParams
	PrimaryKeys    []string
	PackageType    protoparser.MessagePackageType

	NullKeysAllowed  bool
	AddSystemColumns bool
	SkipDedupKeys    bool
	AddSyntheticKeys bool
}

func (*ParserConfigProtoLb) IsAppendOnly

func (c *ParserConfigProtoLb) IsAppendOnly() bool

func (*ParserConfigProtoLb) IsNewParserConfig

func (c *ParserConfigProtoLb) IsNewParserConfig()

func (*ParserConfigProtoLb) ToProtoParserConfig

func (c *ParserConfigProtoLb) ToProtoParserConfig(logger log.Logger) (*protoparser.ProtoParserConfig, error)

func (*ParserConfigProtoLb) Validate

func (c *ParserConfigProtoLb) Validate() error

type ProtoConfigurable

type ProtoConfigurable interface {
	ToProtoParserConfig(log.Logger) (*protoparser.ProtoParserConfig, error)
}