kafka

Documentation

Index

• type DeleteConsumerGroupsOption
• type DeleteTopicsOption
• 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) DeleteConsumerGroupsByOption(ctx context.Context, option DeleteConsumerGroupsOption) error
  • func (k KafkaRepository) DeleteTopics(ctx context.Context, topics []kafka.Topic) error
  • func (k KafkaRepository) DeleteTopicsByOption(ctx context.Context, option DeleteTopicsOption) 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)
  • func (r KafkaRepository) SyncWithDatahub(ctx context.Context, k8sClient client.Client, conn *grpc.ClientConn) error
• type ListConsumerGroupsOption
• type ListTopicsOption

Types

type DeleteConsumerGroupsOption

type DeleteConsumerGroupsOption struct {
	ClusterName            string `datahubcolumntype:"tag" datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace      string `datahubcolumntype:"tag" datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName      string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerNamespace string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_namespace" datahubdatatype:"DATATYPE_STRING"`
}

type DeleteTopicsOption

type DeleteTopicsOption struct {
	ClusterName            string `datahubcolumntype:"tag" datahubcolumn:"cluster_name" datahubdatatype:"DATATYPE_STRING"`
	ExporterNamespace      string `datahubcolumntype:"tag" datahubcolumn:"namespace" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerName      string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_name" datahubdatatype:"DATATYPE_STRING"`
	AlamedaScalerNamespace string `datahubcolumntype:"tag" datahubcolumn:"alameda_scaler_namespace" datahubdatatype:"DATATYPE_STRING"`
}

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) DeleteConsumerGroupsByOption

func (k KafkaRepository) DeleteConsumerGroupsByOption(ctx context.Context, option DeleteConsumerGroupsOption) error

func (KafkaRepository) DeleteTopics

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

func (KafkaRepository) DeleteTopicsByOption

func (k KafkaRepository) DeleteTopicsByOption(ctx context.Context, option DeleteTopicsOption) 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)

func (KafkaRepository) SyncWithDatahub

func (r KafkaRepository) SyncWithDatahub(ctx context.Context, k8sClient client.Client, conn *grpc.ClientConn) error

type ListConsumerGroupsOption

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

type ListTopicsOption

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