Documentation ¶
Index ¶
- Variables
- func DoConsume(ctx context.Context, topic string, context string, ...)
- type KafkaDataSourceKaf
- func (kp KafkaDataSourceKaf) ConsumeTopic(topicName string, handleMessage api.MessageHandlerFunc) error
- func (kp KafkaDataSourceKaf) GetConsumerGroups() ([]api.ConsumerGroup, error)
- func (kp KafkaDataSourceKaf) GetContext() string
- func (kp KafkaDataSourceKaf) GetContexts() ([]string, error)
- func (kp KafkaDataSourceKaf) GetTopics() ([]string, error)
- func (kp KafkaDataSourceKaf) Init()
- 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 ¶
Types ¶
type KafkaDataSourceKaf ¶
type KafkaDataSourceKaf struct { }
func (KafkaDataSourceKaf) ConsumeTopic ¶
func (kp KafkaDataSourceKaf) ConsumeTopic(topicName string, handleMessage api.MessageHandlerFunc) 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() ([]string, error)
GetTopics retrieves a list of Kafka topics
func (KafkaDataSourceKaf) Init ¶
func (kp KafkaDataSourceKaf) Init()
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
Click to show internal directories.
Click to hide internal directories.