plugins

type BodyBuffer interface {
	io.ReaderAt
	Length() int
	Slices(iter func(view []byte))
	Copy() []byte
	NewReader() io.Reader
}

type BodyStatus int

type Connection struct {
	Type ConnectionType
	// contains filtered or unexported fields
}

type ConnectionAdapter interface {
	SetConnection(*connection.Connection)
}

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

type ConnectionType string

type GrpcPlugin interface {
	Plugin // Embeds base
	NewGrpcInstance(PluginContext, *services.ServiceRegistry) GrpcPluginInstance
}

type GrpcPluginInstance interface {
	PluginInstance
	RequestHeaders(requestHeaders Headers, endOfStream bool) HeadersStatus
	RequestBody(frame BodyBuffer, endOfStream bool) BodyStatus
	ResponseHeaders(responseHeaders Headers, endOfStream bool) HeadersStatus
	ResponseBody(frame BodyBuffer, endOfStream bool) BodyStatus
}

type Header []byte

type HeaderValue interface {
	String() string
	Bytes() []byte
	Equal(str string) bool
}

type Headers interface {
	Get(key string) (HeaderValue, bool)
	Values(key string, iter func(value HeaderValue))
	Set(key, value string)
	Remove(key string)
	All() map[string]string
}

type HeadersStatus int

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

type HttpPlugin interface {
	Plugin // Embeds base
	NewHttpInstance(PluginContext, *services.ServiceRegistry) HttpPluginInstance
}

type HttpPluginInstance interface {
	PluginInstance
	RequestHeaders(requestHeaders Headers, endOfStream bool) HeadersStatus
	RequestBody(frame BodyBuffer, endOfStream bool) BodyStatus
	ResponseHeaders(responseHeaders Headers, endOfStream bool) HeadersStatus
	ResponseBody(frame BodyBuffer, endOfStream bool) BodyStatus
}

type KafkaCommand struct {
	ApiKey        int16          // e.g., 0=Produce, 1=Fetch, 3=Metadata, 18=ApiVersions
	ApiVersion    int16          // Protocol version
	CorrelationID int32          // Correlation ID for request/response matching
	ClientID      string         // Client identifier
	Operation     string         // Human-readable operation name (e.g., "Produce", "Fetch")
	Topics        []string       // Topic names (from Produce/Fetch requests)
	GroupID       string         // Consumer group ID (from JoinGroup/SyncGroup/OffsetCommit)
	Messages      []KafkaMessage // Sample messages from Produce requests
	Timestamp     time.Time
}

type KafkaMessage struct {
	Topic     string // Topic name
	Partition int32  // Partition index
	Key       string // Message key (may be empty)
	Value     string // Message value (truncated at MaxValueSize)
	Truncated bool   // Value was truncated
}

type KafkaPlugin interface {
	Plugin // Embeds base
	NewKafkaInstance(PluginContext, *services.ServiceRegistry) KafkaPluginInstance
}

type KafkaPluginInstance interface {
	PluginInstance
	OnKafkaCommand(cmd *KafkaCommand) KafkaStatus
	OnKafkaResult(res *KafkaResult) KafkaStatus
}

type KafkaResult struct {
	CorrelationID int32          // Correlation ID for request/response matching
	ErrorCode     int16          // Kafka error code (0 = no error)
	ErrorMessage  string         // Human-readable error message
	IsError       bool           // Whether this response contains an error
	Messages      []KafkaMessage // Sample messages from Fetch responses
	Latency       time.Duration  // Round-trip latency from request parse to response parse
}

type KafkaStatus int

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

type ManagerOpt func(*Manager)

type Meta interface {
	connmeta.Service
	RequestID() string

	ReadBytes() int64
	WriteBytes() int64
	SetReadBytes(int64)
	SetWriteBytes(int64)
}

type MySQLCommand struct {
	Type      byte   // Command type (e.g., 0x03 for COM_QUERY)
	Query     string // SQL query text (for COM_QUERY, COM_STMT_PREPARE)
	Timestamp time.Time
}

type MySQLPlugin interface {
	Plugin // Embeds base
	NewMySQLInstance(PluginContext, *services.ServiceRegistry) MySQLPluginInstance
}

type MySQLPluginInstance interface {
	PluginInstance
	OnMySQLCommand(cmd *MySQLCommand) MySQLStatus
	OnMySQLResult(res *MySQLResult) MySQLStatus
}

type MySQLResult struct {
	Type         string // "OK", "Error", "ResultSet", "EOF"
	AffectedRows uint64
	LastInsertID uint64
	ErrorCode    uint16
	ErrorMessage string
	Columns      []string   // Column names
	Rows         [][]string // Row values (string representation)
	RowCount     int        // Total rows (may exceed len(Rows) if truncated)
	Truncated    bool       // True if rows were capped at MaxResultSetRows
}

type MySQLStatus int

type Plugin interface {
	Init(logger *zap.Logger, config yaml.Node)
	Destroy()
	PluginType() PluginType
}

type PluginAccessor interface {
	// Get retrieves a plugin by type
	Get(pluginType PluginType) Plugin
}

type PluginContext interface {
	GetRequestBodyBuffer() BodyBuffer
	GetResponseBodyBuffer() BodyBuffer

	Context() context.Context
	Meta() Meta
}

type PluginInstance interface {
	Destroy()
}

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

type PluginType string

type RedisCommand struct {
	Name      string   // e.g., "GET", "SET"
	Args      []string // e.g., ["mykey"]
	Raw       []byte   // The raw wire bytes
	Timestamp time.Time
}

type RedisPlugin interface {
	Plugin // Embeds base
	NewRedisInstance(PluginContext, *services.ServiceRegistry) RedisPluginInstance
}

type RedisPluginInstance interface {
	PluginInstance
	OnRedisCommand(cmd *RedisCommand) RedisStatus
	OnRedisResult(res *RedisResult) RedisStatus
}

type RedisResult struct {
	Type    string // e.g., "Integer", "BulkString"
	Value   any
	IsError bool
}

type RedisStatus int

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

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