Documentation
¶
Overview ¶
Package kafka provides Kafka MCP tool builders.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaConnectToolBuilder ¶
type KafkaConnectToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaConnectToolBuilder implements the ToolBuilder interface for Kafka Connect It provides functionality to build Kafka Connect administration tools /nolint:revive
func NewKafkaConnectToolBuilder ¶
func NewKafkaConnectToolBuilder() *KafkaConnectToolBuilder
NewKafkaConnectToolBuilder creates a new Kafka Connect tool builder instance
func (*KafkaConnectToolBuilder) BuildTools ¶
func (b *KafkaConnectToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka Connect tool list This is the core method implementing the ToolBuilder interface
type KafkaConsumeToolBuilder ¶
type KafkaConsumeToolBuilder struct {
*builders.BaseToolBuilder
// contains filtered or unexported fields
}
KafkaConsumeToolBuilder implements the ToolBuilder interface for Kafka client consume operations It provides functionality to build Kafka consumer tools /nolint:revive
func NewKafkaConsumeToolBuilder ¶
func NewKafkaConsumeToolBuilder() *KafkaConsumeToolBuilder
NewKafkaConsumeToolBuilder creates a new Kafka consume tool builder instance
func (*KafkaConsumeToolBuilder) BuildTools ¶
func (b *KafkaConsumeToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka consume tool list This is the core method implementing the ToolBuilder interface
type KafkaGroupsToolBuilder ¶
type KafkaGroupsToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaGroupsToolBuilder implements the ToolBuilder interface for Kafka Consumer Groups /nolint:revive
func NewKafkaGroupsToolBuilder ¶
func NewKafkaGroupsToolBuilder() *KafkaGroupsToolBuilder
NewKafkaGroupsToolBuilder creates a new Kafka Groups tool builder instance
func (*KafkaGroupsToolBuilder) BuildTools ¶
func (b *KafkaGroupsToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka Groups tool list
type KafkaPartitionsToolBuilder ¶
type KafkaPartitionsToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaPartitionsToolBuilder implements the ToolBuilder interface for Kafka Partitions /nolint:revive
func NewKafkaPartitionsToolBuilder ¶
func NewKafkaPartitionsToolBuilder() *KafkaPartitionsToolBuilder
NewKafkaPartitionsToolBuilder creates a new Kafka Partitions tool builder instance
func (*KafkaPartitionsToolBuilder) BuildTools ¶
func (b *KafkaPartitionsToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka Partitions tool list
type KafkaProduceToolBuilder ¶
type KafkaProduceToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaProduceToolBuilder implements the ToolBuilder interface for Kafka client produce operations It provides functionality to build Kafka producer tools /nolint:revive
func NewKafkaProduceToolBuilder ¶
func NewKafkaProduceToolBuilder() *KafkaProduceToolBuilder
NewKafkaProduceToolBuilder creates a new Kafka produce tool builder instance
func (*KafkaProduceToolBuilder) BuildTools ¶
func (b *KafkaProduceToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka produce tool list This is the core method implementing the ToolBuilder interface
type KafkaSchemaRegistryToolBuilder ¶
type KafkaSchemaRegistryToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaSchemaRegistryToolBuilder implements the ToolBuilder interface for Kafka Schema Registry /nolint:revive
func NewKafkaSchemaRegistryToolBuilder ¶
func NewKafkaSchemaRegistryToolBuilder() *KafkaSchemaRegistryToolBuilder
NewKafkaSchemaRegistryToolBuilder creates a new Kafka Schema Registry tool builder instance
func (*KafkaSchemaRegistryToolBuilder) BuildTools ¶
func (b *KafkaSchemaRegistryToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka Schema Registry tool list
type KafkaTopicsToolBuilder ¶
type KafkaTopicsToolBuilder struct {
*builders.BaseToolBuilder
}
KafkaTopicsToolBuilder implements the ToolBuilder interface for Kafka Topics /nolint:revive
func NewKafkaTopicsToolBuilder ¶
func NewKafkaTopicsToolBuilder() *KafkaTopicsToolBuilder
NewKafkaTopicsToolBuilder creates a new Kafka Topics tool builder instance
func (*KafkaTopicsToolBuilder) BuildTools ¶
func (b *KafkaTopicsToolBuilder) BuildTools(_ context.Context, config builders.ToolBuildConfig) ([]server.ServerTool, error)
BuildTools builds the Kafka Topics tool list
Source Files