engine

Documentation

Index

• type CloudEventsImpl
  • func NewCloudEventsImpl(caCert string, username string, password string, passwordFallback string, ...) *CloudEventsImpl
  • func (p *CloudEventsImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *CloudEventsImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

Types

type CloudEventsImpl

type CloudEventsImpl struct {
	SendSrNotFoundToUnparsed bool
	// contains filtered or unexported fields
}

func NewCloudEventsImpl

func NewCloudEventsImpl(caCert string, username string, password string, passwordFallback string, SendSrNotFoundToUnparsed bool, logger log.Logger, urlConverter func(in string) string) *CloudEventsImpl

func (*CloudEventsImpl) Do

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

func (*CloudEventsImpl) DoBatch

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