database

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 27, 2026

Changes in this version

+ const InstanceMonitorRefreshInterval

+ const ResourceTypeReplicationSlot

+ const ResourceTypeServiceInstance

+ const ServiceInstanceMonitorRefreshInterval

+ const TargetSessionAttrsAny

+ const TargetSessionAttrsPreferStandby

+ const TargetSessionAttrsPrimary

+ const TargetSessionAttrsReadWrite

+ const TargetSessionAttrsStandby

+ var ErrServiceInstanceNotFound = errors.New("service instance not found")

+ func GenerateDatabaseNetworkID(databaseID string) string

+ func GenerateServiceInstanceID(databaseID, serviceID, hostID string) string

+ func GenerateServiceUsername(serviceID string, mode string) string

+ func ReplicationSlotResourceIdentifier(providerNode, subscriberNode string) resource.Identifier

+ type BuildServiceHostListParams struct

+ NodeInstances []*NodeInstances

+ ServiceHostID string

+ TargetNodes []string

+ TargetSessionAttrs string

type ConnectionInfo

+ ClientAddresses []string

type Database

+ ServiceInstances []*ServiceInstance

+ type DatabaseConnection struct

+ TargetNodes []string

+ TargetSessionAttrs string

+ func (r *DatabaseConnection) Clone() *DatabaseConnection

+ type HealthCheckResult struct

+ CheckedAt time.Time

+ Message string

+ Status string

type InstanceResource

+ func (r *InstanceResource) TypeDependencies() []resource.Type

type InstanceSpec

+ PatroniPort *int

+ func (s *InstanceSpec) CopySettingsFrom(current *InstanceSpec)

+ type InstanceSpecStore struct

+ func NewInstanceSpecStore(client *clientv3.Client, root string) *InstanceSpecStore

+ func (s *InstanceSpecStore) DatabasePrefix(databaseID string) string

+ func (s *InstanceSpecStore) DeleteByDatabaseID(databaseID string) storage.DeleteOp

+ func (s *InstanceSpecStore) DeleteByKey(databaseID, instanceID string) storage.DeleteOp

+ func (s *InstanceSpecStore) GetAll() storage.GetMultipleOp[*StoredInstanceSpec]

+ func (s *InstanceSpecStore) GetByDatabaseID(databaseID string) storage.GetMultipleOp[*StoredInstanceSpec]

+ func (s *InstanceSpecStore) GetByKey(databaseID, instanceID string) storage.GetOp[*StoredInstanceSpec]

+ func (s *InstanceSpecStore) Key(databaseID, instanceID string) string

+ func (s *InstanceSpecStore) Prefix() string

+ func (s *InstanceSpecStore) Update(item *StoredInstanceSpec) storage.PutOp[*StoredInstanceSpec]

type InstanceState

+ const InstanceStateDeleting

+ func (i InstanceState) IsInProgress() bool

type InstanceStatus

+ Addresses []string

type InstanceStatusStore

+ func (s *InstanceStatusStore) DeleteByDatabaseID(databaseID string) storage.DeleteOp

type InstanceStore

+ func (s *InstanceStore) DeleteByDatabaseID(databaseID string) storage.DeleteOp

type InstanceUpdateOptions

+ Now time.Time

type LagTrackerCommitTimestampResource

+ func (r *LagTrackerCommitTimestampResource) TypeDependencies() []resource.Type

+ type MCPServiceConfig struct

+ AllowWrites *bool

+ AnthropicAPIKey *string

+ DisableCountRows *bool

+ DisableExecuteExplain *bool

+ DisableGenerateEmbedding *bool

+ DisableGetSchemaInfo *bool

+ DisableQueryDatabase *bool

+ DisableSearchKnowledgebase *bool

+ DisableSimilaritySearch *bool

+ EmbeddingAPIKey *string

+ EmbeddingModel *string

+ EmbeddingProvider *string

+ InitToken *string

+ InitUsers []MCPServiceUser

+ LLMEnabled *bool

+ LLMMaxTokens *int

+ LLMModel string

+ LLMProvider string

+ LLMTemperature *float64

+ OllamaURL *string

+ OpenAIAPIKey *string

+ PoolMaxConns *int

+ func ParseMCPServiceConfig(config map[string]any, isUpdate bool) (*MCPServiceConfig, []error)

+ type MCPServiceUser struct

+ Password string

+ Username string

type Node

+ PatroniPort *int

type NodeResource

+ func (n *NodeResource) TypeDependencies() []resource.Type

type Orchestrator

+ GenerateServiceInstanceResources func(spec *ServiceInstanceSpec) (*ServiceInstanceResources, error)

+ GetServiceInstanceStatus func(ctx context.Context, serviceInstanceID string) (*ServiceInstanceStatus, error)

+ type PortMapping struct

+ ContainerPort int

+ HostPort *int

+ Name string

+ type PostgRESTServiceConfig struct

+ DBAnonRole string

+ DBPool int

+ DBSchemas string

+ JWTAud *string

+ JWTRoleClaimKey *string

+ JWTSecret *string

+ MaxRows int

+ ServerCORSAllowedOrigins *string

+ func ParsePostgRESTServiceConfig(config map[string]any) (*PostgRESTServiceConfig, []error)

type ReplicationSlotAdvanceFromCTSResource

+ func (r *ReplicationSlotAdvanceFromCTSResource) TypeDependencies() []resource.Type

type ReplicationSlotCreateResource

+ func (r *ReplicationSlotCreateResource) TypeDependencies() []resource.Type

+ type ReplicationSlotResource struct

+ ProviderNode string

+ SubscriberNode string

+ func (r *ReplicationSlotResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotResource) Dependencies() []resource.Identifier

+ func (r *ReplicationSlotResource) DiffIgnore() []string

+ func (r *ReplicationSlotResource) Executor() resource.Executor

+ func (r *ReplicationSlotResource) Identifier() resource.Identifier

+ func (r *ReplicationSlotResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotResource) ResourceVersion() string

+ func (r *ReplicationSlotResource) TypeDependencies() []resource.Type

+ func (r *ReplicationSlotResource) Update(ctx context.Context, rc *resource.Context) error

type Service

+ func (s *Service) DeleteInstanceSpec(ctx context.Context, databaseID, instanceID string) error

+ func (s *Service) DeleteServiceInstance(ctx context.Context, databaseID, serviceInstanceID string) error

+ func (s *Service) GetAllServiceInstances(ctx context.Context) ([]*ServiceInstance, error)

+ func (s *Service) GetInstanceConnectionInfo(ctx context.Context, databaseID, instanceID string) (*ConnectionInfo, error)

+ func (s *Service) GetServiceInstance(ctx context.Context, databaseID, serviceInstanceID string) (*ServiceInstance, error)

+ func (s *Service) GetServiceInstances(ctx context.Context, databaseID string) ([]*ServiceInstance, error)

+ func (s *Service) ReconcileInstanceSpec(ctx context.Context, spec *InstanceSpec) (*InstanceSpec, error)

+ func (s *Service) SetServiceInstanceState(ctx context.Context, databaseID, serviceInstanceID string, ...) error

+ func (s *Service) UpdateServiceInstance(ctx context.Context, opts *ServiceInstanceUpdateOptions) error

+ func (s *Service) UpdateServiceInstanceState(ctx context.Context, serviceInstanceID string, ...) error

+ func (s *Service) UpdateServiceInstanceStatus(ctx context.Context, databaseID string, serviceInstanceID string, ...) error

+ type ServiceConnectionInfo struct

+ Hosts []ServiceHostEntry

+ TargetSessionAttrs string

+ func BuildServiceHostList(params *BuildServiceHostListParams) (*ServiceConnectionInfo, error)

+ type ServiceHostEntry struct

+ Host string

+ Port int

+ type ServiceInstance struct

+ CreatedAt time.Time

+ Credentials *ServiceUser

+ DatabaseID string

+ Error string

+ HostID string

+ ServiceID string

+ ServiceInstanceID string

+ State ServiceInstanceState

+ Status *ServiceInstanceStatus

+ UpdatedAt time.Time

+ type ServiceInstanceResources struct

+ Resources []*resource.ResourceData

+ ServiceInstance *ServiceInstance

+ type ServiceInstanceSpec struct

+ CohortMemberID string

+ Credentials *ServiceUser

+ DatabaseHosts []ServiceHostEntry

+ DatabaseID string

+ DatabaseName string

+ DatabaseNetworkID string

+ DatabaseNodes []*NodeInstances

+ HostID string

+ NodeName string

+ PgEdgeVersion *host.PgEdgeVersion

+ Port *int

+ ServiceInstanceID string

+ ServiceSpec *ServiceSpec

+ TargetSessionAttrs string

+ type ServiceInstanceState string

+ const ServiceInstanceStateCreating

+ const ServiceInstanceStateDeleting

+ const ServiceInstanceStateFailed

+ const ServiceInstanceStateRunning

+ type ServiceInstanceStateUpdate struct

+ DatabaseID string

+ Error string

+ State ServiceInstanceState

+ Status *ServiceInstanceStatus

+ type ServiceInstanceStatus struct

+ Addresses []string

+ ContainerID *string

+ HealthCheck *HealthCheckResult

+ ImageVersion *string

+ LastHealthAt *time.Time

+ Ports []PortMapping

+ ServiceReady *bool

+ type ServiceInstanceStatusStore struct

+ func NewServiceInstanceStatusStore(client *clientv3.Client, root string) *ServiceInstanceStatusStore

+ func (s *ServiceInstanceStatusStore) DatabasePrefix(databaseID string) string

+ func (s *ServiceInstanceStatusStore) DeleteByKey(databaseID, serviceInstanceID string) storage.DeleteOp

+ func (s *ServiceInstanceStatusStore) GetAll() storage.GetMultipleOp[*StoredServiceInstanceStatus]

+ func (s *ServiceInstanceStatusStore) GetByDatabaseID(databaseID string) storage.GetMultipleOp[*StoredServiceInstanceStatus]

+ func (s *ServiceInstanceStatusStore) GetByKey(databaseID, serviceInstanceID string) storage.GetOp[*StoredServiceInstanceStatus]

+ func (s *ServiceInstanceStatusStore) Key(databaseID, serviceInstanceID string) string

+ func (s *ServiceInstanceStatusStore) Prefix() string

+ func (s *ServiceInstanceStatusStore) Put(item *StoredServiceInstanceStatus) storage.PutOp[*StoredServiceInstanceStatus]

+ type ServiceInstanceStore struct

+ func NewServiceInstanceStore(client *clientv3.Client, root string) *ServiceInstanceStore

+ func (s *ServiceInstanceStore) DatabasePrefix(databaseID string) string

+ func (s *ServiceInstanceStore) DeleteByKey(databaseID, serviceInstanceID string) storage.DeleteOp

+ func (s *ServiceInstanceStore) GetAll() storage.GetMultipleOp[*StoredServiceInstance]

+ func (s *ServiceInstanceStore) GetByDatabaseID(databaseID string) storage.GetMultipleOp[*StoredServiceInstance]

+ func (s *ServiceInstanceStore) GetByKey(databaseID, serviceInstanceID string) storage.GetOp[*StoredServiceInstance]

+ func (s *ServiceInstanceStore) Key(databaseID, serviceInstanceID string) string

+ func (s *ServiceInstanceStore) Prefix() string

+ func (s *ServiceInstanceStore) Put(item *StoredServiceInstance) storage.PutOp[*StoredServiceInstance]

+ type ServiceInstanceUpdateOptions struct

+ DatabaseID string

+ Error string

+ HostID string

+ ServiceID string

+ ServiceInstanceID string

+ State ServiceInstanceState

+ type ServiceSpec struct

+ CPUs *float64

+ Config map[string]any

+ DatabaseConnection *DatabaseConnection

+ HostIDs []string

+ MemoryBytes *uint64

+ OrchestratorOpts *OrchestratorOpts

+ Port *int

+ ServiceID string

+ ServiceType string

+ Version string

+ func (s *ServiceSpec) Clone() *ServiceSpec

+ type ServiceUser struct

+ Password string

+ Role string

+ Username string

type Spec

+ PatroniPort *int

+ Services []*ServiceSpec

type Store

+ InstanceSpec *InstanceSpecStore

+ ServiceInstance *ServiceInstanceStore

+ ServiceInstanceStatus *ServiceInstanceStatusStore

+ type StoredInstanceSpec struct

+ Spec *InstanceSpec

+ type StoredServiceInstance struct

+ CreatedAt time.Time

+ DatabaseID string

+ Error string

+ HostID string

+ ServiceID string

+ ServiceInstanceID string

+ State ServiceInstanceState

+ UpdatedAt time.Time

+ func NewStoredServiceInstance(opts *ServiceInstanceUpdateOptions) *StoredServiceInstance

+ func (s *StoredServiceInstance) Update(opts *ServiceInstanceUpdateOptions)

+ type StoredServiceInstanceStatus struct

+ DatabaseID string

+ ServiceInstanceID string

+ Status *ServiceInstanceStatus

type SubscriptionResource

+ func (s *SubscriptionResource) TypeDependencies() []resource.Type

type SwitchoverResource

+ func (s *SwitchoverResource) TypeDependencies() []resource.Type

type SyncEventResource

+ func (r *SyncEventResource) TypeDependencies() []resource.Type

type WaitForSyncEventResource

+ func (r *WaitForSyncEventResource) TypeDependencies() []resource.Type

v0.7.0-rc.1

Mar 25, 2026

v0.6.2

Dec 22, 2025

Changes in this version

type InstanceSpec

+ InPlaceRestore bool

v0.6.2-rc.1

Dec 22, 2025

v0.6.1

Dec 19, 2025

v0.6.1-rc.1

Dec 19, 2025

v0.6.0

Dec 17, 2025

Changes in this version

type Service

+ func (s *Service) GetDatabasesByHostId(ctx context.Context, hostID string) ([]*Database, error)

type Spec

+ func (s *Spec) RemoveHost(hostId string) (ok bool)

v0.6.0-rc.1

Dec 17, 2025

v0.5.1

Nov 24, 2025

Changes in this version

+ const InstanceMoniterRefreshInterval

+ type InstanceSpecChange struct

+ Current *InstanceSpec

+ Previous *InstanceSpec

v0.5.1-rc.1

Nov 24, 2025

v0.5.0

Nov 6, 2025

Changes in this version

+ const ResourceTypeInstance

+ const ResourceTypeLagTrackerCommitTS

+ const ResourceTypeNode

+ const ResourceTypeReplicationSlotAdvanceFromCTS

+ const ResourceTypeReplicationSlotCreate

+ const ResourceTypeSubscription

+ const ResourceTypeSwitchover

+ const ResourceTypeSyncEvent

+ const ResourceTypeWaitForSyncEvent

+ var ErrDatabaseAlreadyExists = errors.New("database already exists")

+ var ErrDatabaseNotFound = errors.New("database not found")

+ var ErrDatabaseNotModifiable = errors.New("database not modifiable")

+ var ErrInstanceNotFound = errors.New("instance not found")

+ var ErrInstanceStopped = errors.New("instance stopped")

+ var ErrInvalidDatabaseUpdate = errors.New("invalid database update")

+ var ErrInvalidSourceNode = errors.New("invalid source node")

+ var ErrNodeNotInDBSpec = errors.New("node not in db spec")

+ func ConnectToInstance(ctx context.Context, opts *ConnectionOptions) (*pgx.Conn, error)

+ func DatabaseStateModifiable(state DatabaseState) bool

+ func GetPrimaryInstanceID(ctx context.Context, patroniClient *patroni.Client, timeout time.Duration) (string, error)

+ func InstanceIDFor(hostID, databaseID, nodeName string) string

+ func InstanceResourceIdentifier(instanceID string) resource.Identifier

+ func LagTrackerCommitTSIdentifier(originNode, receiverNode string) resource.Identifier

+ func NodeResourceIdentifier(nodeName string) resource.Identifier

+ func Provide(i *do.Injector)

+ func RegisterResourceTypes(registry *resource.Registry)

+ func ReplicationSlotAdvanceFromCTSResourceIdentifier(providerNode, subscriberNode string) resource.Identifier

+ func ReplicationSlotCreateResourceIdentifier(databaseName, providerNode, subscriberNode string) resource.Identifier

+ func SubscriptionResourceIdentifier(providerNode, subscriberNode string) resource.Identifier

+ func SwitchoverResourceIdentifier(nodeName string) resource.Identifier

+ func SyncEventResourceIdentifier(providerNode, subscriberNode string) resource.Identifier

+ func ValidateChangedSpec(current, updated *Spec) error

+ func WaitForPatroniRunning(ctx context.Context, patroniClient *patroni.Client, timeout time.Duration) error

+ func WaitForSyncEventResourceIdentifier(providerNode, subscriberNode string) resource.Identifier

+ type BackupConfig struct

+ Repositories []*pgbackrest.Repository

+ Schedules []*BackupSchedule

+ func (b *BackupConfig) Clone() *BackupConfig

+ func (b *BackupConfig) DefaultOptionalFieldsFrom(other *BackupConfig)

+ type BackupSchedule struct

+ CronExpression string

+ ID string

+ Type BackupScheduleType

+ func (b *BackupSchedule) Clone() *BackupSchedule

+ type BackupScheduleType string

+ const BackupScheduleTypeFull

+ const BackupScheduleTypeIncremental

+ type ConnectionInfo struct

+ AdminHost string

+ AdminPort int

+ ClientHost string

+ ClientIPv4Address string

+ ClientPort int

+ InstanceHostname string

+ PatroniPort int

+ PeerHost string

+ PeerPort int

+ PeerSSLCert string

+ PeerSSLKey string

+ PeerSSLRootCert string

+ func (c *ConnectionInfo) AdminDSN(dbName string) *postgres.DSN

+ func (c *ConnectionInfo) PatroniURL() *url.URL

+ func (c *ConnectionInfo) PeerDSN(dbName string) *postgres.DSN

+ type ConnectionOptions struct

+ DSN *postgres.DSN

+ TLS *tls.Config

+ type Database struct

+ CreatedAt time.Time

+ DatabaseID string

+ Instances []*Instance

+ Spec *Spec

+ State DatabaseState

+ TenantID *string

+ UpdatedAt time.Time

+ type DatabaseState string

+ const DatabaseStateAvailable

+ const DatabaseStateBackingUp

+ const DatabaseStateCreating

+ const DatabaseStateDegraded

+ const DatabaseStateDeleting

+ const DatabaseStateFailed

+ const DatabaseStateModifying

+ const DatabaseStateRestoring

+ const DatabaseStateStopped

+ const DatabaseStateUnknown

+ type DatabaseStore struct

+ func NewDatabaseStore(client *clientv3.Client, root string) *DatabaseStore

+ func (s *DatabaseStore) Create(item *StoredDatabase) storage.PutOp[*StoredDatabase]

+ func (s *DatabaseStore) Delete(item *StoredDatabase) storage.DeleteValueOp[*StoredDatabase]

+ func (s *DatabaseStore) ExistsByKey(databaseID string) storage.ExistsOp

+ func (s *DatabaseStore) GetAll() storage.GetMultipleOp[*StoredDatabase]

+ func (s *DatabaseStore) GetByKey(databaseID string) storage.GetOp[*StoredDatabase]

+ func (s *DatabaseStore) GetByKeys(databaseIDs ...string) storage.GetMultipleOp[*StoredDatabase]

+ func (s *DatabaseStore) Key(databaseID string) string

+ func (s *DatabaseStore) Prefix() string

+ func (s *DatabaseStore) Update(item *StoredDatabase) storage.PutOp[*StoredDatabase]

+ type Extension struct

+ Name string

+ Version string

+ type ExtraNetworkSpec struct

+ Aliases []string

+ DriverOpts map[string]string

+ ID string

+ type ExtraVolumesSpec struct

+ DestinationPath string

+ HostPath string

+ type Instance struct

+ CreatedAt time.Time

+ DatabaseID string

+ Error string

+ HostID string

+ InstanceID string

+ NodeName string

+ State InstanceState

+ Status *InstanceStatus

+ UpdatedAt time.Time

+ type InstanceResource struct

+ ConnectionInfo *ConnectionInfo

+ InstanceHostname string

+ OrchestratorDependencies []resource.Identifier

+ PrimaryInstanceID string

+ Spec *InstanceSpec

+ func GetAllInstances(ctx context.Context, rc *resource.Context, nodeName string) ([]*InstanceResource, error)

+ func GetPrimaryInstance(ctx context.Context, rc *resource.Context, nodeName string) (*InstanceResource, error)

+ func (r *InstanceResource) Connection(ctx context.Context, rc *resource.Context, dbName string) (*pgx.Conn, error)

+ func (r *InstanceResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *InstanceResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *InstanceResource) Dependencies() []resource.Identifier

+ func (r *InstanceResource) DiffIgnore() []string

+ func (r *InstanceResource) Executor() resource.Executor

+ func (r *InstanceResource) Identifier() resource.Identifier

+ func (r *InstanceResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *InstanceResource) ResourceVersion() string

+ func (r *InstanceResource) Update(ctx context.Context, rc *resource.Context) error

+ func (r *InstanceResource) Validate() error

+ type InstanceResources struct

+ Instance *InstanceResource

+ Resources []*resource.ResourceData

+ func NewInstanceResources(instance *InstanceResource, resources []resource.Resource) (*InstanceResources, error)

+ func (r *InstanceResources) DatabaseID() string

+ func (r *InstanceResources) DatabaseName() string

+ func (r *InstanceResources) HostID() string

+ func (r *InstanceResources) InstanceID() string

+ func (r *InstanceResources) NodeName() string

+ func (r *InstanceResources) State() (*resource.State, error)

+ type InstanceSpec struct

+ BackupConfig *BackupConfig

+ CPUs float64

+ ClusterSize int

+ DatabaseID string

+ DatabaseName string

+ DatabaseUsers []*User

+ HostID string

+ InstanceID string

+ MemoryBytes uint64

+ NodeName string

+ NodeOrdinal int

+ OrchestratorOpts *OrchestratorOpts

+ PgEdgeVersion *host.PgEdgeVersion

+ Port *int

+ PostgreSQLConf map[string]any

+ RestoreConfig *RestoreConfig

+ TenantID *string

+ func (s *InstanceSpec) Clone() *InstanceSpec

+ type InstanceState string

+ const InstanceStateAvailable

+ const InstanceStateBackingUp

+ const InstanceStateCreating

+ const InstanceStateDegraded

+ const InstanceStateFailed

+ const InstanceStateModifying

+ const InstanceStateStopped

+ const InstanceStateUnknown

+ type InstanceStatus struct

+ Error *string

+ Hostname *string

+ IPv4Address *string

+ PatroniPaused *bool

+ PatroniState *patroni.State

+ PendingRestart *bool

+ Port *int

+ PostgresVersion *string

+ ReadOnly *string

+ Role *patroni.InstanceRole

+ SpockVersion *string

+ StatusUpdatedAt *time.Time

+ Stopped *bool

+ Subscriptions []SubscriptionStatus

+ func (s *InstanceStatus) IsPrimary() bool

+ type InstanceStatusStore struct

+ func NewInstanceStatusStore(client *clientv3.Client, root string) *InstanceStatusStore

+ func (s *InstanceStatusStore) DatabasePrefix(databaseID string) string

+ func (s *InstanceStatusStore) DeleteByKey(databaseID, instanceID string) storage.DeleteOp

+ func (s *InstanceStatusStore) GetAll() storage.GetMultipleOp[*StoredInstanceStatus]

+ func (s *InstanceStatusStore) GetByDatabaseID(databaseID string) storage.GetMultipleOp[*StoredInstanceStatus]

+ func (s *InstanceStatusStore) GetByKey(databaseID, instanceID string) storage.GetOp[*StoredInstanceStatus]

+ func (s *InstanceStatusStore) Key(databaseID, instanceID string) string

+ func (s *InstanceStatusStore) Prefix() string

+ func (s *InstanceStatusStore) Put(item *StoredInstanceStatus) storage.PutOp[*StoredInstanceStatus]

+ type InstanceStore struct

+ func NewInstanceStore(client *clientv3.Client, root string) *InstanceStore

+ func (s *InstanceStore) DatabasePrefix(databaseID string) string

+ func (s *InstanceStore) DeleteByKey(databaseID, instanceID string) storage.DeleteOp

+ func (s *InstanceStore) GetAll() storage.GetMultipleOp[*StoredInstance]

+ func (s *InstanceStore) GetByDatabaseID(databaseID string) storage.GetMultipleOp[*StoredInstance]

+ func (s *InstanceStore) GetByKey(databaseID, instanceID string) storage.GetOp[*StoredInstance]

+ func (s *InstanceStore) Key(databaseID, instanceID string) string

+ func (s *InstanceStore) Prefix() string

+ func (s *InstanceStore) Put(item *StoredInstance) storage.PutOp[*StoredInstance]

+ type InstanceUpdateOptions struct

+ DatabaseID string

+ Error string

+ HostID string

+ InstanceID string

+ NodeName string

+ State InstanceState

+ type LagTrackerCommitTimestampResource struct

+ CommitTimestamp *time.Time

+ ExtraDependencies []resource.Identifier

+ OriginNode string

+ ReceiverNode string

+ func NewLagTrackerCommitTimestampResource(originNode, receiverNode string) *LagTrackerCommitTimestampResource

+ func (r *LagTrackerCommitTimestampResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *LagTrackerCommitTimestampResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *LagTrackerCommitTimestampResource) Dependencies() []resource.Identifier

+ func (r *LagTrackerCommitTimestampResource) DiffIgnore() []string

+ func (r *LagTrackerCommitTimestampResource) Executor() resource.Executor

+ func (r *LagTrackerCommitTimestampResource) Identifier() resource.Identifier

+ func (r *LagTrackerCommitTimestampResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *LagTrackerCommitTimestampResource) ResourceVersion() string

+ func (r *LagTrackerCommitTimestampResource) Update(ctx context.Context, rc *resource.Context) error

+ type Node struct

+ BackupConfig *BackupConfig

+ CPUs float64

+ HostIDs []string

+ MemoryBytes uint64

+ Name string

+ OrchestratorOpts *OrchestratorOpts

+ Port *int

+ PostgreSQLConf map[string]any

+ PostgresVersion string

+ RestoreConfig *RestoreConfig

+ SourceNode string

+ func (n *Node) Clone() *Node

+ func (n *Node) DefaultOptionalFieldsFrom(other *Node)

+ type NodeInstances struct

+ Instances []*InstanceSpec

+ NodeName string

+ RestoreConfig *RestoreConfig

+ SourceNode string

+ func (n *NodeInstances) InstanceIDs() []string

+ type NodeResource struct

+ InstanceIDs []string

+ Name string

+ PrimaryInstanceID string

+ func (n *NodeResource) Create(ctx context.Context, rc *resource.Context) error

+ func (n *NodeResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (n *NodeResource) Dependencies() []resource.Identifier

+ func (n *NodeResource) DiffIgnore() []string

+ func (n *NodeResource) Executor() resource.Executor

+ func (n *NodeResource) Identifier() resource.Identifier

+ func (n *NodeResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (n *NodeResource) ResourceVersion() string

+ func (n *NodeResource) Update(ctx context.Context, rc *resource.Context) error

+ type Orchestrator interface

+ CreatePgBackRestBackup func(ctx context.Context, w io.Writer, instanceID string, ...) error

+ GenerateInstanceResources func(spec *InstanceSpec) (*InstanceResources, error)

+ GenerateInstanceRestoreResources func(spec *InstanceSpec, taskID uuid.UUID) (*InstanceResources, error)

+ GetInstanceConnectionInfo func(ctx context.Context, databaseID, instanceID string) (*ConnectionInfo, error)

+ StartInstance func(ctx context.Context, instanceID string) error

+ StopInstance func(ctx context.Context, instanceID string) error

+ ValidateInstanceSpecs func(ctx context.Context, specs []*InstanceSpec) ([]*ValidationResult, error)

+ type OrchestratorOpts struct

+ Swarm *SwarmOpts

+ func (o *OrchestratorOpts) Clone() *OrchestratorOpts

+ type ReplicationSlotAdvanceFromCTSResource struct

+ ProviderNode string

+ SubscriberNode string

+ func (r *ReplicationSlotAdvanceFromCTSResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotAdvanceFromCTSResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotAdvanceFromCTSResource) Dependencies() []resource.Identifier

+ func (r *ReplicationSlotAdvanceFromCTSResource) DiffIgnore() []string

+ func (r *ReplicationSlotAdvanceFromCTSResource) Executor() resource.Executor

+ func (r *ReplicationSlotAdvanceFromCTSResource) Identifier() resource.Identifier

+ func (r *ReplicationSlotAdvanceFromCTSResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotAdvanceFromCTSResource) ResourceVersion() string

+ func (r *ReplicationSlotAdvanceFromCTSResource) Update(ctx context.Context, rc *resource.Context) error

+ type ReplicationSlotCreateResource struct

+ DatabaseName string

+ ProviderNode string

+ SubscriberNode string

+ func (r *ReplicationSlotCreateResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotCreateResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotCreateResource) Dependencies() []resource.Identifier

+ func (r *ReplicationSlotCreateResource) DiffIgnore() []string

+ func (r *ReplicationSlotCreateResource) Executor() resource.Executor

+ func (r *ReplicationSlotCreateResource) Identifier() resource.Identifier

+ func (r *ReplicationSlotCreateResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *ReplicationSlotCreateResource) ResourceVersion() string

+ func (r *ReplicationSlotCreateResource) Update(ctx context.Context, rc *resource.Context) error

+ type RestoreConfig struct

+ Repository *pgbackrest.Repository

+ RestoreOptions map[string]string

+ SourceDatabaseID string

+ SourceDatabaseName string

+ SourceNodeName string

+ func (r *RestoreConfig) Clone() *RestoreConfig

+ func (r *RestoreConfig) DefaultOptionalFieldsFrom(other *RestoreConfig)

+ type Service struct

+ func NewService(orchestrator Orchestrator, store *Store, hostSvc *host.Service) *Service

+ func (s *Service) CreateDatabase(ctx context.Context, spec *Spec) (*Database, error)

+ func (s *Service) DeleteDatabase(ctx context.Context, databaseID string) error

+ func (s *Service) DeleteInstance(ctx context.Context, databaseID, instanceID string) error

+ func (s *Service) GetAllInstances(ctx context.Context) ([]*Instance, error)

+ func (s *Service) GetDatabase(ctx context.Context, databaseID string) (*Database, error)

+ func (s *Service) GetDatabases(ctx context.Context) ([]*Database, error)

+ func (s *Service) GetInstance(ctx context.Context, databaseID, instanceID string) (*Instance, error)

+ func (s *Service) GetInstances(ctx context.Context, databaseID string) ([]*Instance, error)

+ func (s *Service) GetStoredInstanceState(ctx context.Context, databaseID, instanceID string) (InstanceState, error)

+ func (s *Service) InstanceCountForHost(ctx context.Context, hostID string) (int, error)

+ func (s *Service) PopulateSpecDefaults(ctx context.Context, spec *Spec) error

+ func (s *Service) UpdateDatabase(ctx context.Context, state DatabaseState, spec *Spec) (*Database, error)

+ func (s *Service) UpdateDatabaseState(ctx context.Context, databaseID string, from, to DatabaseState) error

+ func (s *Service) UpdateInstance(ctx context.Context, opts *InstanceUpdateOptions) error

+ func (s *Service) UpdateInstanceStatus(ctx context.Context, databaseID string, instanceID string, ...) error

+ type Spec struct

+ BackupConfig *BackupConfig

+ CPUs float64

+ DatabaseID string

+ DatabaseName string

+ DatabaseUsers []*User

+ MemoryBytes uint64

+ Nodes []*Node

+ OrchestratorOpts *OrchestratorOpts

+ Port *int

+ PostgreSQLConf map[string]any

+ PostgresVersion string

+ RestoreConfig *RestoreConfig

+ SpockVersion string

+ TenantID *string

+ func (s *Spec) Clone() *Spec

+ func (s *Spec) DefaultOptionalFieldsFrom(other *Spec)

+ func (s *Spec) Node(name string) (*Node, error)

+ func (s *Spec) NodeInstances() ([]*NodeInstances, error)

+ func (s *Spec) NodeNames() []string

+ func (s *Spec) NormalizeBackupConfig()

+ func (s *Spec) RemoveBackupConfigFrom(nodes ...string)

+ func (s *Spec) ValidateNodeNames(names ...string) error

+ type SpecStore struct

+ func NewSpecStore(client *clientv3.Client, root string) *SpecStore

+ func (s *SpecStore) Create(item *StoredSpec) storage.PutOp[*StoredSpec]

+ func (s *SpecStore) Delete(item *StoredSpec) storage.DeleteValueOp[*StoredSpec]

+ func (s *SpecStore) ExistsByKey(databaseID string) storage.ExistsOp

+ func (s *SpecStore) GetAll() storage.GetMultipleOp[*StoredSpec]

+ func (s *SpecStore) GetByKey(databaseID string) storage.GetOp[*StoredSpec]

+ func (s *SpecStore) GetByKeys(databaseIDs ...string) storage.GetMultipleOp[*StoredSpec]

+ func (s *SpecStore) Key(databaseID string) string

+ func (s *SpecStore) Prefix() string

+ func (s *SpecStore) Update(item *StoredSpec) storage.PutOp[*StoredSpec]

+ type Store struct

+ Database *DatabaseStore

+ Instance *InstanceStore

+ InstanceStatus *InstanceStatusStore

+ Spec *SpecStore

+ func NewStore(client *clientv3.Client, root string) *Store

+ func (s *Store) Txn(ops ...storage.TxnOperation) storage.Txn

+ type StoredDatabase struct

+ CreatedAt time.Time

+ DatabaseID string

+ State DatabaseState

+ TenantID *string

+ UpdatedAt time.Time

+ type StoredInstance struct

+ CreatedAt time.Time

+ DatabaseID string

+ Error string

+ HostID string

+ InstanceID string

+ NodeName string

+ State InstanceState

+ UpdateAt time.Time

+ func NewStoredInstance(opts *InstanceUpdateOptions) *StoredInstance

+ func (i *StoredInstance) Update(opts *InstanceUpdateOptions)

+ type StoredInstanceStatus struct

+ DatabaseID string

+ InstanceID string

+ Status *InstanceStatus

+ type StoredSpec struct

+ type SubscriptionResource struct

+ Disabled bool

+ ExtraDependencies []resource.Identifier

+ NeedsUpdate bool

+ ProviderNode string

+ SubscriberNode string

+ SyncData bool

+ SyncStructure bool

+ func (s *SubscriptionResource) AddDependentResource(dep resource.Identifier)

+ func (s *SubscriptionResource) Create(ctx context.Context, rc *resource.Context) error

+ func (s *SubscriptionResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (s *SubscriptionResource) Dependencies() []resource.Identifier

+ func (s *SubscriptionResource) DiffIgnore() []string

+ func (s *SubscriptionResource) Executor() resource.Executor

+ func (s *SubscriptionResource) Identifier() resource.Identifier

+ func (s *SubscriptionResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (s *SubscriptionResource) ResourceVersion() string

+ func (s *SubscriptionResource) Update(ctx context.Context, rc *resource.Context) error

+ type SubscriptionStatus struct

+ Name string

+ ProviderNode string

+ Status string

+ type SwarmOpts struct

+ ExtraLabels map[string]string

+ ExtraNetworks []ExtraNetworkSpec

+ ExtraVolumes []ExtraVolumesSpec

+ func (d *SwarmOpts) Clone() *SwarmOpts

+ type SwitchoverResource struct

+ HostID string

+ InstanceID string

+ TargetRole patroni.InstanceRole

+ func (s *SwitchoverResource) Create(ctx context.Context, rc *resource.Context) error

+ func (s *SwitchoverResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (s *SwitchoverResource) Dependencies() []resource.Identifier

+ func (s *SwitchoverResource) DiffIgnore() []string

+ func (s *SwitchoverResource) Executor() resource.Executor

+ func (s *SwitchoverResource) Identifier() resource.Identifier

+ func (s *SwitchoverResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (s *SwitchoverResource) ResourceVersion() string

+ func (s *SwitchoverResource) Update(ctx context.Context, rc *resource.Context) error

+ type SyncEventResource struct

+ ExtraDependencies []resource.Identifier

+ ProviderNode string

+ SubscriberNode string

+ SyncEventLsn string

+ func (r *SyncEventResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *SyncEventResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *SyncEventResource) Dependencies() []resource.Identifier

+ func (r *SyncEventResource) DiffIgnore() []string

+ func (r *SyncEventResource) Executor() resource.Executor

+ func (r *SyncEventResource) Identifier() resource.Identifier

+ func (r *SyncEventResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *SyncEventResource) ResourceVersion() string

+ func (r *SyncEventResource) Update(ctx context.Context, rc *resource.Context) error

+ type User struct

+ Attributes []string

+ DBOwner bool

+ Password string

+ Roles []string

+ Username string

+ func (u *User) Clone() *User

+ func (u *User) DefaultOptionalFieldsFrom(other *User)

+ type ValidationResult struct

+ Errors []string

+ HostID string

+ InstanceID string

+ NodeName string

+ Valid bool

+ type WaitForSyncEventResource struct

+ ProviderNode string

+ SubscriberNode string

+ func (r *WaitForSyncEventResource) Create(ctx context.Context, rc *resource.Context) error

+ func (r *WaitForSyncEventResource) Delete(ctx context.Context, rc *resource.Context) error

+ func (r *WaitForSyncEventResource) Dependencies() []resource.Identifier

+ func (r *WaitForSyncEventResource) DiffIgnore() []string

+ func (r *WaitForSyncEventResource) Executor() resource.Executor

+ func (r *WaitForSyncEventResource) Identifier() resource.Identifier

+ func (r *WaitForSyncEventResource) Refresh(ctx context.Context, rc *resource.Context) error

+ func (r *WaitForSyncEventResource) ResourceVersion() string

+ func (r *WaitForSyncEventResource) Update(ctx context.Context, rc *resource.Context) error

v0.5.0-rc.2

Nov 6, 2025

v0.5.0-rc.1

Nov 5, 2025

v0.4.0

Oct 10, 2025

v0.4.0-rc.2

Oct 9, 2025

v0.4.0-rc.1

Oct 6, 2025

v0.3.0

Aug 19, 2025

v0.3.0-rc.1

Aug 19, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL