mcptestmon

Documentation

Index

• type InMemoryClientStatsContext
  • func NewInMemoryClientStatsContext() *InMemoryClientStatsContext
  • func (s *InMemoryClientStatsContext) RecordRecvError(err error, code codes.Code)
  • func (s *InMemoryClientStatsContext) RecordRequestAck(typeURL string)
  • func (s *InMemoryClientStatsContext) RecordRequestNack(typeURL string, err error)
  • func (s *InMemoryClientStatsContext) RecordSendError(err error, code codes.Code)
  • func (s *InMemoryClientStatsContext) RecordStreamCreateSuccess()
• type InMemoryServerStatsContext
  • func NewInMemoryServerStatsContext() *InMemoryServerStatsContext
  • func (s *InMemoryServerStatsContext) RecordRecvError(err error, code codes.Code)
  • func (s *InMemoryServerStatsContext) RecordRequestAck(typeURL string, connectionID int64)
  • func (s *InMemoryServerStatsContext) RecordRequestNack(typeURL string, connectionID int64)
  • func (s *InMemoryServerStatsContext) RecordRequestSize(typeURL string, connectionID int64, size int)
  • func (s *InMemoryServerStatsContext) RecordSendError(err error, code codes.Code)
  • func (s *InMemoryServerStatsContext) SetClientsTotal(clients int64)

Types

type InMemoryClientStatsContext

type InMemoryClientStatsContext struct {
	RequestAcksTotal         map[string]int64
	RequestNacksTotal        map[nackKey]int64
	SendFailuresTotal        map[errorCodeKey]int64
	RecvFailuresTotal        map[errorCodeKey]int64
	StreamCreateSuccessTotal int64
	// contains filtered or unexported fields
}

InMemoryClientStatsContext enables MCP client metric collection which is stored in memory for testing purposes.

func NewInMemoryClientStatsContext

func NewInMemoryClientStatsContext() *InMemoryClientStatsContext

NewInMemoryClientStatsContext creates a new context for tracking metrics in memory.

func (*InMemoryClientStatsContext) RecordRecvError

func (s *InMemoryClientStatsContext) RecordRecvError(err error, code codes.Code)

RecordRecvError records an error during a network recv with its error string and code.

func (*InMemoryClientStatsContext) RecordRequestAck

func (s *InMemoryClientStatsContext) RecordRequestAck(typeURL string)

RecordRequestAck records an ACK message for a type URL on a connection.

func (*InMemoryClientStatsContext) RecordRequestNack

func (s *InMemoryClientStatsContext) RecordRequestNack(typeURL string, err error)

RecordRequestNack records a NACK message for a type URL on a connection.

func (*InMemoryClientStatsContext) RecordSendError

func (s *InMemoryClientStatsContext) RecordSendError(err error, code codes.Code)

RecordSendError records an error during a network send with its error string and code.

func (*InMemoryClientStatsContext) RecordStreamCreateSuccess

func (s *InMemoryClientStatsContext) RecordStreamCreateSuccess()

RecordStreamCreateSuccess records a successful stream connection.

type InMemoryServerStatsContext

type InMemoryServerStatsContext struct {
	ClientsTotal      int64
	RequestSizesBytes map[requestKey][]int64
	RequestAcksTotal  map[requestKey]int64
	RequestNacksTotal map[requestKey]int64
	SendFailuresTotal map[errorCodeKey]int64
	RecvFailuresTotal map[errorCodeKey]int64
	// contains filtered or unexported fields
}

InMemoryServerStatsContext enables MCP server metric collection which is stored in memory for testing purposes.

func NewInMemoryServerStatsContext

func NewInMemoryServerStatsContext() *InMemoryServerStatsContext

NewInMemoryServerStatsContext creates a new context for tracking metrics in memory.

func (*InMemoryServerStatsContext) RecordRecvError

func (s *InMemoryServerStatsContext) RecordRecvError(err error, code codes.Code)

RecordRecvError records an error during a network recv with its error string and code.

func (*InMemoryServerStatsContext) RecordRequestAck

func (s *InMemoryServerStatsContext) RecordRequestAck(typeURL string, connectionID int64)

RecordRequestAck records an ACK message for a type URL on a connection.

func (*InMemoryServerStatsContext) RecordRequestNack

func (s *InMemoryServerStatsContext) RecordRequestNack(typeURL string, connectionID int64)

RecordRequestNack records a NACK message for a type URL on a connection.

func (*InMemoryServerStatsContext) RecordRequestSize

func (s *InMemoryServerStatsContext) RecordRequestSize(typeURL string, connectionID int64, size int)

RecordRequestSize records the size of a request from a connection for a specific type URL.

func (*InMemoryServerStatsContext) RecordSendError

func (s *InMemoryServerStatsContext) RecordSendError(err error, code codes.Code)

RecordSendError records an error during a network send with its error string and code.

func (*InMemoryServerStatsContext) SetClientsTotal

func (s *InMemoryServerStatsContext) SetClientsTotal(clients int64)

SetClientsTotal updates the current client count to the given argument.