kafka

package
v0.7.0-beta.14 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 30, 2023 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KafkaOperations

type KafkaOperations struct {
	BaseOperations
	// contains filtered or unexported fields
}

func NewKafka

func NewKafka() *KafkaOperations

NewKafka returns a new kafka binding instance.

func (*KafkaOperations) CheckStatusOps

func (kafkaOps *KafkaOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*KafkaOperations) GetLogger

func (kafkaOps *KafkaOperations) GetLogger() logr.Logger

func (*KafkaOperations) GetRunningPort

func (kafkaOps *KafkaOperations) GetRunningPort() int

func (*KafkaOperations) Init

func (kafkaOps *KafkaOperations) Init(metadata component.Properties) error

func (*KafkaOperations) InitDelay

func (kafkaOps *KafkaOperations) InitDelay() error

func (*KafkaOperations) InternalExec

func (kafkaOps *KafkaOperations) InternalExec(ctx context.Context, sql string) (int64, error)

func (*KafkaOperations) InternalQuery

func (kafkaOps *KafkaOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL