engine

Documentation

Index

• Constants
• Variables
• type ConfluentSrImpl
  • func NewConfluentSchemaRegistryImpl(srURL string, caCert string, username string, password string, ...) *ConfluentSrImpl
  • func (p *ConfluentSrImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *ConfluentSrImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem
  • func (p *ConfluentSrImpl) DoBuf(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) []abstract.ChangeItem
  • func (p *ConfluentSrImpl) DoOne(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) ([]byte, []abstract.ChangeItem)
  • func (p *ConfluentSrImpl) DoWithSchemaID(partition abstract.Partition, schemaID uint32, messageName string, buf []byte, ...) ([]byte, []abstract.ChangeItem)
• type JSONProperties

Constants

const (
	JSONTypeArray   jsonType = "array"
	JSONTypeBoolean jsonType = "boolean"
	JSONTypeInteger jsonType = "integer"
	JSONTypeNumber  jsonType = "number"
	JSONTypeNull    jsonType = "null"
	JSONTypeObject  jsonType = "object"
	JSONTypeString  jsonType = "string"
)

Variables

var BuiltInDeps map[string]string //nolint:gochecknoglobals // read-only entity

Types

type ConfluentSrImpl

type ConfluentSrImpl struct {
	SchemaRegistryClient     *confluent.SchemaRegistryClient
	SendSrNotFoundToUnparsed bool
	// contains filtered or unexported fields
}

func NewConfluentSchemaRegistryImpl

func NewConfluentSchemaRegistryImpl(srURL string, caCert string, username string, password string, SendSrNotFoundToUnparsed bool, logger log.Logger) *ConfluentSrImpl

func (*ConfluentSrImpl) Do

func (p *ConfluentSrImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem

func (*ConfluentSrImpl) DoBatch

func (p *ConfluentSrImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

func (*ConfluentSrImpl) DoBuf

func (p *ConfluentSrImpl) DoBuf(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) []abstract.ChangeItem

func (*ConfluentSrImpl) DoOne

func (p *ConfluentSrImpl) DoOne(partition abstract.Partition, buf []byte, offset uint64, writeTime time.Time) ([]byte, []abstract.ChangeItem)

func (*ConfluentSrImpl) DoWithSchemaID

func (p *ConfluentSrImpl) DoWithSchemaID(partition abstract.Partition, schemaID uint32, messageName string, buf []byte, offset uint64, writeTime time.Time, isCloudevents bool) ([]byte, []abstract.ChangeItem)

type JSONProperties

type JSONProperties struct {
	Type       string                     `json:"type"`
	OneOf      []*JSONProperties          `json:"oneOf"`
	Properties map[string]*JSONProperties `json:"properties"`
	Title      string                     `json:"title"`
}