kafds

Documentation

Index

• Variables
• func DoConsume(ctx context.Context, topic string, consumeFlags api.ConsumeFlags, ...)
• type KafkaDataSourceKaf
  • func (kp KafkaDataSourceKaf) ConsumeTopic(ctx context.Context, topicName string, flags api.ConsumeFlags, ...) error
  • func (kp KafkaDataSourceKaf) GetConsumerGroups() ([]api.ConsumerGroup, error)
  • func (kp KafkaDataSourceKaf) GetContext() string
  • func (kp KafkaDataSourceKaf) GetContexts() ([]string, error)
  • func (kp KafkaDataSourceKaf) GetTopics() (map[string]api.Topic, error)
  • func (kp *KafkaDataSourceKaf) Init(cfgOption string)
  • func (kp KafkaDataSourceKaf) SetContext(contextName string) error
• type OutputFormat
  • func (e *OutputFormat) Set(v string) error
  • func (e *OutputFormat) String() string
  • func (e *OutputFormat) Type() string
• type XDGSCRAMClient
  • func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
  • func (x *XDGSCRAMClient) Done() bool
  • func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Variables

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions

func DoConsume

func DoConsume(ctx context.Context, topic string, consumeFlags api.ConsumeFlags, handleMessage api.MessageHandlerFunc, onError func(err any))

Types

type KafkaDataSourceKaf

type KafkaDataSourceKaf struct {
}

func (KafkaDataSourceKaf) ConsumeTopic

func (kp KafkaDataSourceKaf) ConsumeTopic(ctx context.Context, topicName string, flags api.ConsumeFlags, handleMessage api.MessageHandlerFunc, onError func(err any)) error

func (KafkaDataSourceKaf) GetConsumerGroups

func (kp KafkaDataSourceKaf) GetConsumerGroups() ([]api.ConsumerGroup, error)

func (KafkaDataSourceKaf) GetContext

func (kp KafkaDataSourceKaf) GetContext() string

func (KafkaDataSourceKaf) GetContexts

func (kp KafkaDataSourceKaf) GetContexts() ([]string, error)

GetContexts retrieves a list of Kafka contexts

func (KafkaDataSourceKaf) GetTopics

func (kp KafkaDataSourceKaf) GetTopics() (map[string]api.Topic, error)

GetTopics retrieves a list of Kafka topics

func (*KafkaDataSourceKaf) Init

func (kp *KafkaDataSourceKaf) Init(cfgOption string)

func (KafkaDataSourceKaf) SetContext

func (kp KafkaDataSourceKaf) SetContext(contextName string) error

type OutputFormat

type OutputFormat string

const (
	OutputFormatDefault OutputFormat = "default"
	OutputFormatRaw     OutputFormat = "raw"
	OutputFormatJSON    OutputFormat = "json"
)

func (*OutputFormat) Set

func (e *OutputFormat) Set(v string) error

func (*OutputFormat) String

func (e *OutputFormat) String() string

func (*OutputFormat) Type

func (e *OutputFormat) Type() string

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin

func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step

func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)