Documentation
¶
Index ¶
- type KafkaConfig
- type KafkaPlugin
- func (p *KafkaPlugin) GetConnectionInfo() (*plugin.ConnectionInfo, error)
- func (p *KafkaPlugin) GetLogs(ctx context.Context, opts *plugin.LogOptions) ([]string, error)
- func (p *KafkaPlugin) IsReady(ctx context.Context) (bool, error)
- func (p *KafkaPlugin) Launch(ctx context.Context, config map[string]interface{}) error
- func (p *KafkaPlugin) Name() string
- func (p *KafkaPlugin) Stop(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConfig ¶
type KafkaConfig struct {
Image string `json:"image"`
Port string `json:"port"`
Topics []string `json:"topics"`
Partitions int `json:"partitions"`
ContainerName string `json:"container-name"`
}
KafkaConfig holds Kafka-specific configuration
type KafkaPlugin ¶
type KafkaPlugin struct {
// contains filtered or unexported fields
}
KafkaPlugin implements the ServicePlugin interface for a single-node Kafka broker running in KRaft mode.
func NewKafkaPlugin ¶
func NewKafkaPlugin(dockerClient *docker.Client, logger *zap.Logger) *KafkaPlugin
NewKafkaPlugin creates a new Kafka service plugin
func (*KafkaPlugin) GetConnectionInfo ¶
func (p *KafkaPlugin) GetConnectionInfo() (*plugin.ConnectionInfo, error)
GetConnectionInfo returns connection details
func (*KafkaPlugin) GetLogs ¶
func (p *KafkaPlugin) GetLogs(ctx context.Context, opts *plugin.LogOptions) ([]string, error)
GetLogs retrieves service logs
func (*KafkaPlugin) IsReady ¶
func (p *KafkaPlugin) IsReady(ctx context.Context) (bool, error)
IsReady checks if the Kafka broker is accepting requests
Source Files
Click to show internal directories.
Click to hide internal directories.