kafkaer

Documentation

Index

• Variables
• type AliKafka
  • func (kafka *AliKafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)
• type HuaweiKafka
  • func (kafka *HuaweiKafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)
• type Kafkaer
  • func NewKafkaClient(provider pbtenant.CloudProvider, region tenanter.Region, ...) (kafkaer Kafkaer, err error)
• type TencentCkafka
  • func (kafka *TencentCkafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)

Variables

var (
	ErrKafkaListNotSupported = errors.New("cloud not supported kafka list")
	ErrKafkaerPanic          = errors.New("kafka init panic")
)

Types

type AliKafka

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

func (*AliKafka) ListDetail

func (kafka *AliKafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)

type HuaweiKafka

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

func (*HuaweiKafka) ListDetail

func (kafka *HuaweiKafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)

type Kafkaer

type Kafkaer interface {
	ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (resp *pbkafka.ListDetailResp, err error)
}

func NewKafkaClient

func NewKafkaClient(provider pbtenant.CloudProvider, region tenanter.Region, tenant tenanter.Tenanter) (kafkaer Kafkaer, err error)

type TencentCkafka

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

func (*TencentCkafka) ListDetail

func (kafka *TencentCkafka) ListDetail(ctx context.Context, req *pbkafka.ListDetailReq) (*pbkafka.ListDetailResp, error)