schemamirror

func (*MirrorService) Ping ¶ added in v0.504.0

func (s *MirrorService) Ping(context.Context, *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*MirrorService) PushSchema ¶ added in v0.504.0

func (s *MirrorService) PushSchema(ctx context.Context, stream *connect.ClientStream[ftlv1.PushSchemaRequest]) (*connect.Response[ftlv1.PushSchemaResponse], error)

func (*SchemaService) CommitChangeset ¶ added in v0.504.0

func (s *SchemaService) CommitChangeset(context.Context, *connect.Request[ftlv1.CommitChangesetRequest]) (*connect.Response[ftlv1.CommitChangesetResponse], error)

func (*SchemaService) CreateChangeset ¶ added in v0.504.0

func (s *SchemaService) CreateChangeset(context.Context, *connect.Request[ftlv1.CreateChangesetRequest]) (*connect.Response[ftlv1.CreateChangesetResponse], error)

func (*SchemaService) DrainChangeset ¶ added in v0.504.0

func (s *SchemaService) DrainChangeset(context.Context, *connect.Request[ftlv1.DrainChangesetRequest]) (*connect.Response[ftlv1.DrainChangesetResponse], error)

func (*SchemaService) FailChangeset ¶ added in v0.504.0

func (s *SchemaService) FailChangeset(context.Context, *connect.Request[ftlv1.FailChangesetRequest]) (*connect.Response[ftlv1.FailChangesetResponse], error)

func (*SchemaService) FinalizeChangeset ¶ added in v0.504.0

func (s *SchemaService) FinalizeChangeset(context.Context, *connect.Request[ftlv1.FinalizeChangesetRequest]) (*connect.Response[ftlv1.FinalizeChangesetResponse], error)

func (*SchemaService) GetDeployment ¶ added in v0.504.0

func (s *SchemaService) GetDeployment(ctx context.Context, req *connect.Request[ftlv1.GetDeploymentRequest]) (*connect.Response[ftlv1.GetDeploymentResponse], error)

GetDeployment gets a deployment by deployment key

func (*SchemaService) GetDeployments ¶ added in v0.504.0

func (s *SchemaService) GetDeployments(context.Context, *connect.Request[ftlv1.GetDeploymentsRequest]) (*connect.Response[ftlv1.GetDeploymentsResponse], error)

GetDeployments is used to get the schema for all deployments.

func (*SchemaService) GetSchema ¶ added in v0.504.0

func (s *SchemaService) GetSchema(context.Context, *connect.Request[ftlv1.GetSchemaRequest]) (*connect.Response[ftlv1.GetSchemaResponse], error)

GetSchema gets the full schema.

func (*SchemaService) Ping ¶ added in v0.504.0

func (s *SchemaService) Ping(context.Context, *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*SchemaService) PrepareChangeset ¶ added in v0.504.0

func (s *SchemaService) PrepareChangeset(context.Context, *connect.Request[ftlv1.PrepareChangesetRequest]) (*connect.Response[ftlv1.PrepareChangesetResponse], error)

func (*SchemaService) PullSchema ¶ added in v0.504.0

func (s *SchemaService) PullSchema(ctx context.Context, req *connect.Request[ftlv1.PullSchemaRequest], stream *connect.ServerStream[ftlv1.PullSchemaResponse]) error

PullSchema streams changes to the schema.

func (*SchemaService) RollbackChangeset ¶ added in v0.504.0

func (s *SchemaService) RollbackChangeset(context.Context, *connect.Request[ftlv1.RollbackChangesetRequest]) (*connect.Response[ftlv1.RollbackChangesetResponse], error)

func (*SchemaService) UpdateDeploymentRuntime ¶ added in v0.504.0

func (s *SchemaService) UpdateDeploymentRuntime(context.Context, *connect.Request[ftlv1.UpdateDeploymentRuntimeRequest]) (*connect.Response[ftlv1.UpdateDeploymentRuntimeResponse], error)