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
- type XDGSCRAMClient
Constants ¶
This section is empty.
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }
View Source
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
Source Files
Click to show internal directories.
Click to hide internal directories.