notify

package

v0.3.7 Latest Latest Go to latest Published: May 21, 2026 License: MIT Imports: 9 Imported by: 0

Details

Package notify coalesces resource-change events into debounced notifications/resources/updated, keyed per resource URI.

View Source

const DefaultDebounce = 500 * time.Millisecond

This section is empty.

This section is empty.

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

func NewPublisher(cfg config.ResourcesConfig, logger *slog.Logger) (*Publisher, error)

func (p *Publisher) Attach(srv *mcp.Server)

Attach binds the MCP server used to send notifications. Call once, before the first Touch.

func (p *Publisher) Close()

func (p *Publisher) HandleSubscribe(_ context.Context, req *mcp.SubscribeRequest) error

func (p *Publisher) HandleUnsubscribe(_ context.Context, _ *mcp.UnsubscribeRequest) error

HandleUnsubscribe is a no-op: the SDK owns subscription state and ResourceUpdated already skips unsubscribed sessions.

func (p *Publisher) Touch(uri string)

Touch records that uri changed.