schemaservice

Feb 12, 2025

Changes in this version

type SchemaState

+ func (r *SchemaState) VerifyEvent(ctx context.Context, event schema.Event) error

Feb 11, 2025

Changes in this version

type Service

+ func (s *Service) RollbackChangeset(ctx context.Context, req *connect.Request[ftlv1.RollbackChangesetRequest]) (*connect.Response[ftlv1.RollbackChangesetResponse], error)

Feb 6, 2025

Changes in this version

type Config

+ Raft raft.RaftConfig

Feb 5, 2025

Changes in this version

+ type CommonSchemaServiceConfig struct

+ type EventWrapper struct

+ Event schema.Event

+ func (e *EventWrapper) UnmarshalBinary(bts []byte) error

+ func (e EventWrapper) MarshalBinary() ([]byte, error)

+ func (e EventWrapper) String() string

type Service

+ Config Config

Feb 4, 2025

Changes in this version

type Service

+ func (s *Service) DrainChangeset(ctx context.Context, req *connect.Request[ftlv1.DrainChangesetRequest]) (*connect.Response[ftlv1.DrainChangesetResponse], error)

+ func (s *Service) FinalizeChangeset(ctx context.Context, req *connect.Request[ftlv1.FinalizeChangesetRequest]) (*connect.Response[ftlv1.FinalizeChangesetResponse], error)

Feb 3, 2025

Changes in this version

type SchemaState

+ func (r *SchemaState) ActiveChangeset() optional.Option[*schema.Changeset]

+ func (r *SchemaState) FindDeployment(deploymentKey key.Deployment) (deployment *schema.Module, changeset optional.Option[key.Changeset], err error)

+ func (r *SchemaState) GetAllActiveDeployments() map[key.Deployment]*schema.Module

+ func (r *SchemaState) GetCanonicalDeploymentSchemas() []*schema.Module

+ func (r *SchemaState) GetCanonicalDeployments() map[key.Deployment]*schema.Module

+ func (r *SchemaState) GetChangeset(changeset key.Changeset) (*schema.Changeset, error)

+ func (r *SchemaState) GetChangesets() map[key.Changeset]*schema.Changeset

+ func (r *SchemaState) Marshal() ([]byte, error)

+ func (r *SchemaState) Unmarshal(data []byte) error

type Service

+ func (s *Service) CommitChangeset(ctx context.Context, req *connect.Request[ftlv1.CommitChangesetRequest]) (*connect.Response[ftlv1.CommitChangesetResponse], error)

+ func (s *Service) CreateChangeset(ctx context.Context, req *connect.Request[ftlv1.CreateChangesetRequest]) (*connect.Response[ftlv1.CreateChangesetResponse], error)

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

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

+ func (s *Service) PrepareChangeset(ctx context.Context, req *connect.Request[ftlv1.PrepareChangesetRequest]) (*connect.Response[ftlv1.PrepareChangesetResponse], error)

Jan 29, 2025

Changes in this version

+ func Start(ctx context.Context, config Config) error

+ type Config struct

+ Bind *url.URL

type SchemaState

+ func NewSchemaState() SchemaState

+ func (r *SchemaState) GetProvisioning(moduleName string) (*schema.Module, error)

+ func (r SchemaState) ApplyEvent(event schema.Event) (SchemaState, error)

type Service

+ func New(ctx context.Context) *Service

+ func (s *Service) GetDeployments(ctx context.Context, req *connect.Request[ftlv1.GetDeploymentsRequest]) (*connect.Response[ftlv1.GetDeploymentsResponse], error)

+ func (s *Service) UpdateSchema(ctx context.Context, req *connect.Request[ftlv1.UpdateSchemaRequest]) (*connect.Response[ftlv1.UpdateSchemaResponse], error)

Jan 24, 2025

Changes in this version

+ func EventExtractor(diff tuple.Pair[SchemaState, SchemaState]) iter.Seq[SchemaEvent]

+ func NewInMemorySchemaState(ctx context.Context) *statemachine.SingleQueryHandle[struct{}, SchemaState, SchemaEvent]

+ type DeploymentActivatedEvent struct

+ ActivatedAt time.Time

+ Key key.Deployment

+ MinReplicas int

+ func (r *DeploymentActivatedEvent) Handle(t SchemaState) (SchemaState, error)

+ type DeploymentCreatedEvent struct

+ Key key.Deployment

+ Schema *schema.Module

+ func (r *DeploymentCreatedEvent) Handle(t SchemaState) (SchemaState, error)

+ type DeploymentDeactivatedEvent struct

+ Key key.Deployment

+ ModuleRemoved bool

+ func (r *DeploymentDeactivatedEvent) Handle(t SchemaState) (SchemaState, error)

+ type DeploymentReplicasUpdatedEvent struct

+ Key key.Deployment

+ Replicas int

+ func (r *DeploymentReplicasUpdatedEvent) Handle(t SchemaState) (SchemaState, error)

+ type DeploymentSchemaUpdatedEvent struct

+ Key key.Deployment

+ Schema *schema.Module

+ func (r *DeploymentSchemaUpdatedEvent) Handle(t SchemaState) (SchemaState, error)

+ type SchemaEvent interface

+ Handle func(view SchemaState) (SchemaState, error)

+ type SchemaState struct

+ func (r *SchemaState) GetActiveDeploymentSchemas() []*schema.Module

+ func (r *SchemaState) GetActiveDeployments() map[key.Deployment]*schema.Module

+ func (r *SchemaState) GetDeployment(deployment key.Deployment) (*schema.Module, error)

+ func (r *SchemaState) GetDeployments() map[key.Deployment]*schema.Module

Jan 23, 2025

Changes in this version

+ type Service struct

+ State *statemachine.SingleQueryHandle[struct{}, state.SchemaState, state.SchemaEvent]

+ func (s *Service) GetSchema(ctx context.Context, c *connect.Request[ftlv1.GetSchemaRequest]) (*connect.Response[ftlv1.GetSchemaResponse], error)

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

+ func (s *Service) PullSchema(ctx context.Context, req *connect.Request[ftlv1.PullSchemaRequest], ...) error

+ func (s *Service) UpdateDeploymentRuntime(ctx context.Context, ...) (*connect.Response[ftlv1.UpdateDeploymentRuntimeResponse], error)