mcpserver

Documentation

Index

• func NewServer(opts Options) *mcp.Server
• func RequireBearerToken(token string, next http.Handler) http.Handler
• type AssignmentInfo
• type BrokerOutput
• type ClusterMetricsOutput
• type ClusterStatusOutput
• type ComponentState
• type FetchOffsetsInput
• type FetchOffsetsOutput
• type GroupDetails
• type GroupInput
• type GroupSummary
• type GroupSummaryList
• type MemberDetails
• type OffsetDetails
• type Options
• type PartitionDetails
• type S3Status
• type TopicConfigInput
• type TopicConfigList
• type TopicConfigOutput
• type TopicDetail
• type TopicDetailList
• type TopicNameInput
• type TopicSummary
• type TopicSummaryList

Functions

func NewServer

func NewServer(opts Options) *mcp.Server

func RequireBearerToken

func RequireBearerToken(token string, next http.Handler) http.Handler

RequireBearerToken enforces a static bearer token for MCP endpoints. It is intentionally simple and should be replaced by stronger auth over time.

Types

type AssignmentInfo

type AssignmentInfo struct {
	Topic      string  `json:"topic"`
	Partitions []int32 `json:"partitions"`
}

type BrokerOutput

type BrokerOutput struct {
	NodeID int32  `json:"node_id"`
	Host   string `json:"host"`
	Port   int32  `json:"port"`
}

type ClusterMetricsOutput

type ClusterMetricsOutput struct {
	S3State                 string  `json:"s3_state"`
	S3LatencyMS             int     `json:"s3_latency_ms"`
	ProduceRPS              float64 `json:"produce_rps"`
	FetchRPS                float64 `json:"fetch_rps"`
	AdminRequestsTotal      float64 `json:"admin_requests_total"`
	AdminRequestErrorsTotal float64 `json:"admin_request_errors_total"`
	AdminRequestLatencyMS   float64 `json:"admin_request_latency_ms"`
	ObservedAt              string  `json:"observed_at"`
}

type ClusterStatusOutput

type ClusterStatusOutput struct {
	ClusterName  string         `json:"cluster_name,omitempty"`
	ClusterID    string         `json:"cluster_id,omitempty"`
	ControllerID int32          `json:"controller_id"`
	Brokers      []BrokerOutput `json:"brokers"`
	Topics       []TopicSummary `json:"topics"`
	S3           S3Status       `json:"s3"`
	Etcd         ComponentState `json:"etcd"`
	ObservedAt   string         `json:"observed_at"`
}

type ComponentState

type ComponentState struct {
	State string `json:"state"`
}

type FetchOffsetsInput

type FetchOffsetsInput struct {
	GroupID string   `json:"group_id" jsonschema:"Consumer group identifier"`
	Topics  []string `json:"topics" jsonschema:"Optional list of topics to fetch offsets for"`
}

type FetchOffsetsOutput

type FetchOffsetsOutput struct {
	GroupID string          `json:"group_id"`
	Offsets []OffsetDetails `json:"offsets"`
}

type GroupDetails

type GroupDetails struct {
	GroupID            string          `json:"group_id"`
	State              string          `json:"state"`
	ProtocolType       string          `json:"protocol_type"`
	Protocol           string          `json:"protocol"`
	Leader             string          `json:"leader"`
	GenerationID       int32           `json:"generation_id"`
	RebalanceTimeoutMS int32           `json:"rebalance_timeout_ms"`
	Members            []MemberDetails `json:"members"`
}

type GroupInput

type GroupInput struct {
	GroupID string `json:"group_id" jsonschema:"Consumer group identifier"`
}

type GroupSummary

type GroupSummary struct {
	GroupID      string `json:"group_id"`
	State        string `json:"state"`
	ProtocolType string `json:"protocol_type"`
	MemberCount  int    `json:"member_count"`
}

type GroupSummaryList

type GroupSummaryList struct {
	Groups []GroupSummary `json:"groups"`
}

type MemberDetails

type MemberDetails struct {
	MemberID         string           `json:"member_id"`
	ClientID         string           `json:"client_id"`
	ClientHost       string           `json:"client_host"`
	HeartbeatAt      string           `json:"heartbeat_at"`
	Assignments      []AssignmentInfo `json:"assignments"`
	Subscriptions    []string         `json:"subscriptions"`
	SessionTimeoutMS int32            `json:"session_timeout_ms"`
}

type OffsetDetails

type OffsetDetails struct {
	Topic     string `json:"topic"`
	Partition int32  `json:"partition"`
	Offset    int64  `json:"offset"`
	Metadata  string `json:"metadata"`
}

type Options

type Options struct {
	Store   metadata.Store
	Metrics console.MetricsProvider
	Logger  *log.Logger
	Version string
}

type PartitionDetails

type PartitionDetails struct {
	Partition       int32   `json:"partition"`
	LeaderID        int32   `json:"leader_id"`
	LeaderEpoch     int32   `json:"leader_epoch"`
	ReplicaNodes    []int32 `json:"replica_nodes"`
	ISRNodes        []int32 `json:"isr_nodes"`
	OfflineReplicas []int32 `json:"offline_replicas"`
	ErrorCode       int16   `json:"error_code"`
}

type S3Status

type S3Status struct {
	State     string `json:"state"`
	LatencyMS int    `json:"latency_ms"`
}

type TopicConfigInput

type TopicConfigInput struct {
	Topics []string `json:"topics" jsonschema:"Optional list of topics to describe"`
}

type TopicConfigList

type TopicConfigList struct {
	Configs []TopicConfigOutput `json:"configs"`
}

type TopicConfigOutput

type TopicConfigOutput struct {
	Name              string            `json:"name"`
	Exists            bool              `json:"exists"`
	Partitions        int32             `json:"partitions"`
	ReplicationFactor int32             `json:"replication_factor"`
	RetentionMS       int64             `json:"retention_ms"`
	RetentionBytes    int64             `json:"retention_bytes"`
	SegmentBytes      int64             `json:"segment_bytes"`
	CreatedAt         string            `json:"created_at"`
	Config            map[string]string `json:"config"`
}

type TopicDetail

type TopicDetail struct {
	Name       string             `json:"name"`
	ErrorCode  int16              `json:"error_code"`
	Partitions []PartitionDetails `json:"partitions"`
}

type TopicDetailList

type TopicDetailList struct {
	Topics []TopicDetail `json:"topics"`
}

type TopicNameInput

type TopicNameInput struct {
	Names []string `json:"names" jsonschema:"Optional list of topic names to filter"`
}

type TopicSummary

type TopicSummary struct {
	Name           string `json:"name"`
	PartitionCount int    `json:"partition_count"`
	ErrorCode      int16  `json:"error_code"`
}

type TopicSummaryList

type TopicSummaryList struct {
	Topics []TopicSummary `json:"topics"`
}