valkey

type BuildDedicatedResultIn struct {
	ServiceHost string    `saga:"servicehost"`
	Password    string    `saga:"password"`
	ServerID    entity.Id `saga:"serverid"`
}

type BuildDedicatedResultOut struct {
	Done bool
}

type CaptureValkeyRotationResultIn struct {
	RotateServiceHost string `saga:"rotateservicehost"`
	RotateNewPassword string `saga:"rotatenewpassword"`
}

type CaptureValkeyRotationResultOut struct {
	Done bool
}

type CreateDedicatedPoolIn struct {
	ServerName    string            `saga:"servername"`
	AppName       string            `saga:"appname"`
	Password      string            `saga:"password"`
	VariantConfig map[string]string `saga:"variantconfig"`
}

type CreateDedicatedPoolOut struct {
	PoolID entity.Id `saga:"poolid"`
}

type CreateValkeyServerIn struct {
	ServerName  string `saga:"servername"`
	VariantName string `saga:"variantname"`
	Password    string `saga:"password"`
}

type CreateValkeyServerOut struct {
	ServerID entity.Id `saga:"serverid"`
}

type DecodeDedicatedAttrsIn struct {
	AssocEntity *entity.Entity `saga:"assocentity"`
}

type DecodeDedicatedAttrsOut struct {
	DedicatedServerID entity.Id `saga:"dedicatedserverid"`
}

type DecodeValkeyServerRefIn struct {
	AssocEntity *entity.Entity `saga:"assocentity"`
}

type DecodeValkeyServerRefOut struct {
	RotateServerID entity.Id `saga:"rotateserverid"`
}

type DeleteDedicatedServerEntityIn struct {
	DedicatedServerID   entity.Id `saga:"dedicatedserverid"`
	DedicatedServerName string    `saga:"dedicatedservername"`

	ServiceCleanedUp saga.Edge `saga:"dedicated_service_deleted"`
	PoolCleanedUp    saga.Edge `saga:"dedicated_pool_deleted"`
}

type DeleteDedicatedServerEntityOut struct {
	ServerDeleted bool
}

type DeleteOldValkeyPoolIn struct {
	RotateOldPoolID entity.Id `saga:"rotateoldpoolid"`

	PoolReady saga.Edge `saga:"valkey_pool_ready"`
}

type DeleteOldValkeyPoolOut struct {
	RotateOldPoolDeleted bool
}

type GenerateCredentialsIn struct {
	AppName string
}

type GenerateCredentialsOut struct {
	Password    string `saga:"password"`
	ServiceName string `saga:"servicename"`
	ServerName  string `saga:"servername"`
}

type LoadValkeyRotationStateIn struct {
	RotateServerID entity.Id `saga:"rotateserverid"`
}

type LoadValkeyRotationStateOut struct {
	RotateOldPassword string    `saga:"rotateoldpassword"`
	RotateOldPoolID   entity.Id `saga:"rotateoldpoolid"`
	RotateServiceHost string    `saga:"rotateservicehost"`
}

type LookupDedicatedServerIn struct {
	DedicatedServerID entity.Id `saga:"dedicatedserverid"`
}

type LookupDedicatedServerOut struct {
	DedicatedServiceID  entity.Id `saga:"dedicatedserviceid"`
	DedicatedPoolID     entity.Id `saga:"dedicatedpoolid"`
	DedicatedServerName string    `saga:"dedicatedservername"`
}

type Provider struct {
	dbsaga.BaseProvider
}

type ScaleDownOldValkeyPoolIn struct {
	RotateOldPoolID entity.Id `saga:"rotateoldpoolid"`
}

type ScaleDownOldValkeyPoolOut struct {
	// Edge producer: gates the pool swap, so the single-attach disk is released
	// before the new pool tries to attach it.
	RotatePoolScaledDown bool `saga:"valkey_pool_scaled_down"`
}

type SetValkeyServerPasswordIn struct {
	RotateServerID    entity.Id `saga:"rotateserverid"`
	RotateNewPassword string    `saga:"rotatenewpassword"`
	RotateOldPassword string    `saga:"rotateoldpassword"`
}

type SetValkeyServerPasswordOut struct {
	RotatePasswordSet bool
}

type SwapValkeyPoolIn struct {
	RotateServerID    entity.Id `saga:"rotateserverid"`
	RotateOldPoolID   entity.Id `saga:"rotateoldpoolid"`
	RotateNewPassword string    `saga:"rotatenewpassword"`

	PoolScaledDown saga.Edge `saga:"valkey_pool_scaled_down"`
}

type SwapValkeyPoolOut struct {
	RotateNewPoolID entity.Id `saga:"rotatenewpoolid"`
}

type UpdateDedicatedServerIn struct {
	ServerID    entity.Id `saga:"serverid"`
	PoolID      entity.Id `saga:"poolid"`
	ServiceID   entity.Id `saga:"serviceid"`
	ServiceHost string    `saga:"servicehost"`
	VariantName string    `saga:"variantname"`
	Password    string    `saga:"password"`
}

type UpdateDedicatedServerOut struct {
	Updated bool
}

type WaitValkeyPoolReadyIn struct {
	RotateNewPoolID entity.Id `saga:"rotatenewpoolid"`
}

type WaitValkeyPoolReadyOut struct {
	// Edge producer: gates the old-pool delete on the new pool being healthy.
	RotatePoolReady bool `saga:"valkey_pool_ready"`
}