msk

Documentation

Index

• type Kafka
  • func NewKafkaMaster(ctx ctx.CTX, mskConfig *MSKConfig) (mskSrv Kafka)
• type KafkaConnect
  • func NewKafkaConnect(ctx ctx.CTX, conectConf *MSKConnectConfig) (mskSrv KafkaConnect)
• type MSKConfig
• type MSKConnectConfig

Types

type Kafka

type Kafka interface {
	kafkaiface.KafkaAPI
}

Kafka defineis aws-sdk-go v1 kafka interface

func NewKafkaMaster

func NewKafkaMaster(ctx ctx.CTX, mskConfig *MSKConfig) (mskSrv Kafka)

NewKafkaMaster provide aws-go-sdk-v1 test able solution

type KafkaConnect

type KafkaConnect interface {
	kafkaconnectiface.KafkaConnectAPI
}

KafkaConnect defines aws msk kafka connect interface

func NewKafkaConnect

func NewKafkaConnect(ctx ctx.CTX, conectConf *MSKConnectConfig) (mskSrv KafkaConnect)

NewKafkaConnect to new kafkaConnet API

type MSKConfig

type MSKConfig struct {
	AssumeRoleARN string `json:"assume_role_arn"`
	Region        string `json:"region"`
}

MSKConfig is the contract to New Kafka management

type MSKConnectConfig

type MSKConnectConfig struct {
	IAMUser       *entities.IAMUser `json:"iam_user,omitempty"`
	AssumeRoleARN string            `json:"assume_role_arn"`
	Region        string            `json:"region"`
}

MSKConnectConfig defines kafka