kafka

Documentation

Index

• type KafkaRepository
  • func NewKafkaRepository(datahubClient datahub.DatahubServiceClient, logger *log.Scope) KafkaRepository
  • func (k KafkaRepository) CreateConsumerGroups(ctx context.Context, consumerGroups []kafka.ConsumerGroup) error
  • func (k KafkaRepository) CreateTopics(ctx context.Context, topics []kafka.Topic) error
  • func (k KafkaRepository) DeleteConsumerGroups(ctx context.Context, consumerGroups []kafka.ConsumerGroup) error
  • func (k KafkaRepository) DeleteTopics(ctx context.Context, topics []kafka.Topic) error
  • func (k KafkaRepository) ListConsumerGroups(ctx context.Context, option ListConsumerGroupsOption) ([]kafka.ConsumerGroup, error)
  • func (k KafkaRepository) ListTopics(ctx context.Context, option ListTopicsOption) ([]kafka.Topic, error)
• type ListConsumerGroupsOption
• type ListTopicsOption

Types

type KafkaRepository

type KafkaRepository struct {
	// contains filtered or unexported fields
}

func NewKafkaRepository

func NewKafkaRepository(datahubClient datahub.DatahubServiceClient, logger *log.Scope) KafkaRepository

func (KafkaRepository) CreateConsumerGroups

func (k KafkaRepository) CreateConsumerGroups(ctx context.Context, consumerGroups []kafka.ConsumerGroup) error

func (KafkaRepository) CreateTopics

func (k KafkaRepository) CreateTopics(ctx context.Context, topics []kafka.Topic) error

func (KafkaRepository) DeleteConsumerGroups

func (k KafkaRepository) DeleteConsumerGroups(ctx context.Context, consumerGroups []kafka.ConsumerGroup) error

func (KafkaRepository) DeleteTopics

func (k KafkaRepository) DeleteTopics(ctx context.Context, topics []kafka.Topic) error

func (KafkaRepository) ListConsumerGroups

func (k KafkaRepository) ListConsumerGroups(ctx context.Context, option ListConsumerGroupsOption) ([]kafka.ConsumerGroup, error)

func (KafkaRepository) ListTopics

func (k KafkaRepository) ListTopics(ctx context.Context, option ListTopicsOption) ([]kafka.Topic, error)

type ListConsumerGroupsOption

type ListConsumerGroupsOption struct {
	ClusterName       string `datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace string `datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName string `datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
}

type ListTopicsOption

type ListTopicsOption struct {
	ClusterName       string `datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace string `datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName string `datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
}