ipc

type Capabilities struct {
	APIVersion   int      `json:"apiVersion"`
	Capabilities []string `json:"capabilities"`
}

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

type Config struct {
	AppName                string
	APIVersion             int
	Capabilities           []string
	CapabilitiesFunc       func() []string // computed per connection; overrides Capabilities when set
	MaxLineSize            int
	DefaultSubscribeTopics []string
	OnSubscribe            func(topics []string, sub *Subscriber)
	SubscribeHandler       Handler // replaces the built-in subscribe/unsubscribe handling when set
	Bus                    *EventBus
}

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

type Event struct {
	Topic string
	Data  any
}

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

type Handler func(ctx context.Context, w *ConnWriter, req Request, sub *Subscriber)

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

type Request struct {
	ID     int            `json:"id,omitempty"`
	Method string         `json:"method"`
	Params map[string]any `json:"params,omitempty"`
}

type Response[T any] struct {
	ID     int    `json:"id,omitempty"`
	Result *T     `json:"result,omitempty"`
	Error  string `json:"error,omitempty"`
}

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

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