kafka

Documentation

Index

• type KafkaOperations
  • func NewKafka() *KafkaOperations
  • func (kafkaOps *KafkaOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (kafkaOps *KafkaOperations) GetLogger() logr.Logger
  • func (kafkaOps *KafkaOperations) GetRunningPort() int
  • func (kafkaOps *KafkaOperations) Init(metadata component.Properties) error
  • func (kafkaOps *KafkaOperations) InitDelay() error
  • func (kafkaOps *KafkaOperations) InternalExec(ctx context.Context, sql string) (int64, error)
  • func (kafkaOps *KafkaOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)

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)