request

type AstraBundleConfig struct {
	SecureConnectionBundleBase64 string `mapstructure:"secure-connection-bundle-base64"`
	GatewayUser                  string `mapstructure:"gateway-user"`
	GatewayPassword              string `mapstructure:"gateway-password"`
}

type AstraCqlStoreConfig struct {
	GatewayHost string
	GatewayPort string
	GatewayUser string
	GatewayPass string
	TlsConfig   *tls.Config
}

type Buffer interface {
	Get(requestId string, algorithmName string) (*models.CheckpointedRequest, error)
	GetBuffered(host string) (iter.Seq2[*models.CheckpointedRequest, error], error)
	GetTagged(tag string) (iter.Seq2[*models.CheckpointedRequest, error], error)
	Update(checkpoint *models.CheckpointedRequest) error
	GetBufferedEntry(checkpoint *models.CheckpointedRequest) (*models.SubmissionBufferEntry, error)
	Add(requestId string, algorithmName string, request *models.AlgorithmRequest, config *v1.NexusAlgorithmSpec, workgroup *v1.NexusAlgorithmWorkgroupSpec, parent *metav1.OwnerReference, isDryRun bool) error
	Start(submitter pipeline.StageActor[*BufferOutput, types.UID])
}

type BufferConfig struct {
	PayloadStoragePath         string        `mapstructure:"payload-storage-path,omitempty"`
	PayloadValidFor            time.Duration `mapstructure:"payload-valid-for,omitempty"`
	FailureRateBaseDelay       time.Duration `mapstructure:"failure-rate-base-delay,omitempty"`
	FailureRateMaxDelay        time.Duration `mapstructure:"failure-rate-max-delay,omitempty"`
	RateLimitElementsPerSecond int           `mapstructure:"rate-limit-elements-per-second,omitempty"`
	RateLimitElementsBurst     int           `mapstructure:"rate-limit-elements-burst,omitempty"`
	Workers                    int           `mapstructure:"workers,omitempty"`
}

type BufferInput struct {
	Checkpoint        *models.CheckpointedRequest
	ResolvedWorkgroup *v1.NexusAlgorithmWorkgroupSpec
	ResolvedParent    *metav1.OwnerReference
	SerializedPayload *[]byte
	Config            *v1.NexusAlgorithmSpec
	IsDryRun          bool
}

type BufferOutput struct {
	Checkpoint      *models.CheckpointedRequest
	Entry           *models.SubmissionBufferEntry
	Workgroup       *v1.NexusAlgorithmWorkgroupSpec
	ParentReference *metav1.OwnerReference
	IsDryRun        bool
}

type CheckpointStore interface {
	UpsertCheckpoint(checkpoint *models.CheckpointedRequest) error
	ReadCheckpoint(algorithm string, id string) (*models.CheckpointedRequest, error)
	ReadBufferedCheckpointsByHost(host string) (iter.Seq2[*models.CheckpointedRequest, error], error)
	ReadCheckpointsByTag(requestTag string) (iter.Seq2[*models.CheckpointedRequest, error], error)
}

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

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

type MemoryPassthroughBuffer struct {
	Checkpoints     []*models.CheckpointedRequest
	BufferedEntries []*models.SubmissionBufferEntry
	// contains filtered or unexported fields
}

type MetadataStore interface {
	UpsertMetadata(entry *models.SubmissionBufferEntry) error
	ReadMetadata(checkpoint *models.CheckpointedRequest) (*models.SubmissionBufferEntry, error)
}

type S3BufferConfig struct {
	BufferConfig    *BufferConfig `mapstructure:"buffer-config,omitempty"`
	AccessKeyID     string        `mapstructure:"access-key-id,omitempty"`
	SecretAccessKey string        `mapstructure:"secret-access-key,omitempty"`
	Region          string        `mapstructure:"region,omitempty"`
	Endpoint        string        `mapstructure:"endpoint,omitempty"`
}

type ScyllaCqlStoreConfig struct {
	Hosts    []string `mapstructure:"hosts"`
	Port     string   `mapstructure:"port"`
	User     string   `mapstructure:"user"`
	Password string   `mapstructure:"password"`
	LocalDC  string   `mapstructure:"local-dc"`
}