external

type CheckKafkaConfig struct {
	BrokerList       []string `json:"-"`
	SecurityProtocol string   `json:"securityProtocol"`
	SASLMechanisms   string   `json:"saslMechanisms"`
	SASLUsername     string   `json:"saslUsername"`
	SASLPassword     string   `json:"saslPassword"`
}

type CheckMinIOArgs struct {
	// S3 / MinIO
	Type           string
	AK             string
	SK             string
	Bucket         string
	Endpoint       string
	UseSSL         bool
	UseIAM         bool
	IAMEndpoint    string
	UseVirtualHost bool
	// SSL Configuration
	CACertificate      []byte
	InsecureSkipVerify bool
}

type ConditionGetter interface {
	GetCondition() v1beta1.MilvusCondition
}

type PulsarClient interface {
	pulsar.Client
}

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

type PulsarReader interface {
	pulsar.Reader
}

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