confluentschemaregistry

Documentation

Index

• func NewParserConfluentSchemaRegistry(inWrapped interface{}, _ bool, logger log.Logger, _ *stats.SourceStats) (parsers.Parser, error)
• type ParserConfigConfluentSchemaRegistryCommon
  • func (c *ParserConfigConfluentSchemaRegistryCommon) IsAppendOnly() bool
  • func (c *ParserConfigConfluentSchemaRegistryCommon) IsNewParserConfig()
  • func (c *ParserConfigConfluentSchemaRegistryCommon) Validate() error
• type ParserConfigConfluentSchemaRegistryLb
  • func (c *ParserConfigConfluentSchemaRegistryLb) IsAppendOnly() bool
  • func (c *ParserConfigConfluentSchemaRegistryLb) IsNewParserConfig()
  • func (c *ParserConfigConfluentSchemaRegistryLb) Validate() error

Functions

func NewParserConfluentSchemaRegistry

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

Types

type ParserConfigConfluentSchemaRegistryCommon

type ParserConfigConfluentSchemaRegistryCommon struct {
	SchemaRegistryURL string
	SkipAuth          bool
	Username          string
	Password          string
	TLSFile           string
}

func (*ParserConfigConfluentSchemaRegistryCommon) IsAppendOnly

func (c *ParserConfigConfluentSchemaRegistryCommon) IsAppendOnly() bool

func (*ParserConfigConfluentSchemaRegistryCommon) IsNewParserConfig

func (c *ParserConfigConfluentSchemaRegistryCommon) IsNewParserConfig()

func (*ParserConfigConfluentSchemaRegistryCommon) Validate

func (c *ParserConfigConfluentSchemaRegistryCommon) Validate() error

type ParserConfigConfluentSchemaRegistryLb

type ParserConfigConfluentSchemaRegistryLb struct {
	SchemaRegistryURL string
	SkipAuth          bool
	Username          string
	Password          string
	TLSFile           string
}

func (*ParserConfigConfluentSchemaRegistryLb) IsAppendOnly

func (c *ParserConfigConfluentSchemaRegistryLb) IsAppendOnly() bool

func (*ParserConfigConfluentSchemaRegistryLb) IsNewParserConfig

func (c *ParserConfigConfluentSchemaRegistryLb) IsNewParserConfig()

func (*ParserConfigConfluentSchemaRegistryLb) Validate

func (c *ParserConfigConfluentSchemaRegistryLb) Validate() error