proxy

Documentation

Index

• type Service
  • func New(controllerModuleService ftlv1connect.ControllerServiceClient, ...) *Service
  • func (r *Service) AcquireLease(ctx context.Context, ...) error
  • func (r *Service) Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
  • func (r *Service) GetDeploymentContext(ctx context.Context, c *connect.Request[ftlv1.GetDeploymentContextRequest], ...) error
  • func (r *Service) Ping(ctx context.Context, c *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)
  • func (r *Service) ProcessList(ctx context.Context, c *connect.Request[ftlv1.ProcessListRequest]) (*connect.Response[ftlv1.ProcessListResponse], error)
  • func (r *Service) RegisterRunner(ctx context.Context, c *connect.ClientStream[ftlv1.RegisterRunnerRequest]) (*connect.Response[ftlv1.RegisterRunnerResponse], error)
  • func (r *Service) Status(ctx context.Context, c *connect.Request[ftlv1.StatusRequest]) (*connect.Response[ftlv1.StatusResponse], error)

Types

type Service

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

func New

func New(controllerModuleService ftlv1connect.ControllerServiceClient,
	leaseClient ftlleaseconnect.LeaseServiceClient,
	timelineClient *timelineclient.Client,
	queryService *query.MultiService,
	bindAddress string,
	localDeployment key.Deployment) *Service

func (*Service) AcquireLease

func (r *Service) AcquireLease(ctx context.Context, c *connect.BidiStream[ftllease.AcquireLeaseRequest, ftllease.AcquireLeaseResponse]) error

func (*Service) Call

func (r *Service) Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)

func (*Service) GetDeploymentContext

func (r *Service) GetDeploymentContext(ctx context.Context, c *connect.Request[ftlv1.GetDeploymentContextRequest], c2 *connect.ServerStream[ftlv1.GetDeploymentContextResponse]) error

func (*Service) Ping

func (r *Service) Ping(ctx context.Context, c *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) ProcessList

func (r *Service) ProcessList(ctx context.Context, c *connect.Request[ftlv1.ProcessListRequest]) (*connect.Response[ftlv1.ProcessListResponse], error)

func (*Service) RegisterRunner

func (r *Service) RegisterRunner(ctx context.Context, c *connect.ClientStream[ftlv1.RegisterRunnerRequest]) (*connect.Response[ftlv1.RegisterRunnerResponse], error)

func (*Service) Status

func (r *Service) Status(ctx context.Context, c *connect.Request[ftlv1.StatusRequest]) (*connect.Response[ftlv1.StatusResponse], error)