Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CallClient ¶
type RouteTable ¶
type RouteTable struct {
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, changes *schemaeventsource.EventSource) *RouteTable
func (*RouteTable) Current ¶
func (r *RouteTable) Current() RouteView
Current returns the current routes.
func (*RouteTable) Subscribe ¶
func (r *RouteTable) Subscribe() chan string
func (*RouteTable) Unsubscribe ¶
func (r *RouteTable) Unsubscribe(s chan string)
type RouteView ¶
type RouteView struct {
// contains filtered or unexported fields
}
func (RouteView) GetDeployment ¶
GetDeployment returns the deployment key for the given module or None if it doesn't exist.
func (RouteView) GetForModule ¶
GetForModule returns the URL for the given module or None if it doesn't exist.
type VerbCallRouter ¶
type VerbCallRouter struct {
// contains filtered or unexported fields
}
VerbCallRouter managed clients for the routing service, so calls to a given module can be routed to the correct instance.
func NewVerbRouter ¶
func NewVerbRouter(ctx context.Context, changes *schemaeventsource.EventSource, timelineClient *timelineclient.Client) *VerbCallRouter
func NewVerbRouterFromTable ¶
func NewVerbRouterFromTable(ctx context.Context, routeTable *RouteTable, timelineClient *timelineclient.Client) *VerbCallRouter
func (*VerbCallRouter) Call ¶
func (s *VerbCallRouter) Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
func (*VerbCallRouter) LookupClient ¶
func (s *VerbCallRouter) LookupClient(ctx context.Context, module string) (client ftlv1connect.VerbServiceClient, deployment key.Deployment, ok bool)
Source Files
Click to show internal directories.
Click to hide internal directories.