proxy

Documentation

Overview

Package proxy provides the server-side IPC dispatcher for Remembrances write operations (KB, Events, Code indexing). It bridges the dbproxy infrastructure layer and the rag business-logic layer without creating circular imports.

Index

• type RemembrancesWriteDispatcher
  • func NewRemembrancesWriteDispatcher(svc *rag.RemembrancesService) *RemembrancesWriteDispatcher
  • func (d *RemembrancesWriteDispatcher) DispatchRemembrancesWrite(ctx context.Context, method string, params json.RawMessage) (json.RawMessage, error)

Types

type RemembrancesWriteDispatcher

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

RemembrancesWriteDispatcher implements dbproxy.RemembrancesDispatcher. It routes inbound IPC write requests for KB, Events, and Code indexing to the appropriate methods on the local RemembrancesService.

func NewRemembrancesWriteDispatcher

func NewRemembrancesWriteDispatcher(svc *rag.RemembrancesService) *RemembrancesWriteDispatcher

NewRemembrancesWriteDispatcher creates a dispatcher backed by svc. svc must be the primary instance's RemembrancesService (with RW database access).

func (*RemembrancesWriteDispatcher) DispatchRemembrancesWrite

func (d *RemembrancesWriteDispatcher) DispatchRemembrancesWrite(ctx context.Context, method string, params json.RawMessage) (json.RawMessage, error)

DispatchRemembrancesWrite routes a proxied write request to the appropriate store method.