routing

Documentation

Index

• type CallClient
• type RouteTable
  • func New(ctx context.Context, changes schemaeventsource.EventSource) *RouteTable
  • func (r *RouteTable) Current() RouteView
  • func (r *RouteTable) Subscribe() chan string
  • func (r *RouteTable) Unsubscribe(s chan string)
• type RouteView
  • func (r RouteView) Get(deployment model.DeploymentKey) optional.Option[url.URL]
  • func (r RouteView) GetDeployment(module string) optional.Option[model.DeploymentKey]
  • func (r RouteView) GetForModule(module string) optional.Option[url.URL]
  • func (r RouteView) Schema() *schema.Schema
• type VerbCallRouter
  • func NewVerbRouter(ctx context.Context, changes schemaeventsource.EventSource, ...) *VerbCallRouter
  • func NewVerbRouterFromTable(ctx context.Context, routeTable *RouteTable, timelineClient *timeline.Client) *VerbCallRouter
  • func (s *VerbCallRouter) Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
  • func (s *VerbCallRouter) LookupClient(module string) (client ftlv1connect.VerbServiceClient, deployment model.DeploymentKey, ok bool)

Types

type CallClient

type CallClient interface {
	Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
}

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) Get

func (r RouteView) Get(deployment model.DeploymentKey) optional.Option[url.URL]

Get returns the URL for the given deployment or None if it doesn't exist.

func (RouteView) GetDeployment

func (r RouteView) GetDeployment(module string) optional.Option[model.DeploymentKey]

GetDeployment returns the deployment key for the given module or None if it doesn't exist.

func (RouteView) GetForModule

func (r RouteView) GetForModule(module string) optional.Option[url.URL]

GetForModule returns the URL for the given module or None if it doesn't exist.

func (RouteView) Schema

func (r RouteView) Schema() *schema.Schema

Schema returns the current schema that the routes are based on.

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 *timeline.Client) *VerbCallRouter

func NewVerbRouterFromTable

func NewVerbRouterFromTable(ctx context.Context, routeTable *RouteTable, timelineClient *timeline.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(module string) (client ftlv1connect.VerbServiceClient, deployment model.DeploymentKey, ok bool)