service

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

type Connection struct {

	// PeerAddr is the address of the client envoy, from network layer
	PeerAddr string

	NodeID string

	// Time of connection, for debugging
	Connect time.Time

	// ConID is the connection identifier, used as a key in the connection table.
	// Currently based on the node name and a counter.
	ConID string

	// Metadata key-value pairs extending the Node identifier
	Metadata map[string]string

	// Watched resources for the connection
	Watched map[string][]string

	NonceSent  map[string]string
	NonceAcked map[string]string

	// Only one can be set.
	Stream Stream
	// contains filtered or unexported fields
}

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

type NodeID struct {
	// Type can be sidecar, ingress, router. Other names are possible.
	Type string

	// IPAddress is the declared IP. If missing, the peer address can be used
	IPAddress string

	// WorkloadID identifies the workload. In K8S it is podID.namespace
	WorkloadID string

	// Domain suffix for short hostnames. In k8s it is the namespace.svc.cluster.local
	Domain string
}

type Stream interface {
	// Send will push a message.
	// Message can be mcp.Resources, v2.DiscoveryResponse, sds, etc.
	Send(proto.Message) error

	// Recv is used by the main stream process goroutine to get requests from the endpoint.
	// Can be mcp.RequestResources ,v2.DiscoveryRequest
	Recv() (proto.Message, error)

	// Context returns the context for the connection, for metadata.
	Context() context.Context

	// Process is called by the stream processing goroutine on each received message.
	// Should not block - no new Recv will be called while Process is in progress.
	Process(s *AdsService, con *Connection, message proto.Message) error
}

type TypeHandler func(s *AdsService, con *Connection, rtype string, res []string) error