queue

type CleanupPolicy struct {
	DeletePlaintextAfterSeal   bool
	DeleteCiphertextOnSuccess  bool
	DeleteCiphertextOnFailure  bool
	DeleteCiphertextOnExpiry   bool
	RetainSuccessfulCiphertext bool
	DeleteOnSuccess            bool
	DeleteOnFailure            bool
	DeleteOnExpiry             bool
}

type Codec = EnvelopeCodec

type CodecFunc struct {
	SealFn SealFunc
	OpenFn OpenFunc
}

type Config struct {
	Root, Directory, Path      string
	RootDir, QueueDir, DataDir string
	Codec                      any
	MaxItems                   int
	MaxBytes                   int64
	MaxQueueItems              int
	MaxQueueBytes              int64
	TTL                        time.Duration
	HistoryTTL                 time.Duration
	RetryDelay                 time.Duration
	MaxAttempts                int
	Clock                      func() time.Time
	Cleanup                    CleanupPolicy
	DeletePolicy               DeletePolicy
	DeletePlaintextAfterSeal   bool
	DeleteCiphertextOnSuccess  bool
	DeleteCiphertextOnFailure  bool
	DeleteCiphertextOnExpiry   bool
	RetainSuccessfulCiphertext bool
}

type DeletePolicy string

type DeliveryFunc = Handler

type EnqueueRequest = Request

type Entry = Item

type EnvelopeCodec interface {
	Seal(context.Context, []byte) ([]byte, error)
	Open(context.Context, []byte) ([]byte, error)
}

type EnvelopeOpener interface {
	Open(context.Context, []byte) ([]byte, error)
}

type EnvelopeSealer interface {
	Seal(context.Context, []byte) ([]byte, error)
}

type EnvelopeStore interface {
	PutEnvelope(context.Context, []byte) error
	GetEnvelope(context.Context, string) ([]byte, error)
	DeleteEnvelope(context.Context, string) error
}

type Handler func(context.Context, Item) error

type Item struct {
	ID, UploadID                      string
	TenantID, PluginID, PluginVersion string
	Target, LeaseID, IdempotencyKey   string
	PolicyEpoch                       uint64
	ObjectDigest                      string
	Digest                            string
	Ciphertext, Envelope              []byte
	Payload, EncryptedPayload         []byte
	Size, Bytes                       int64
	State                             State
	Attempt, MaxAttempts              int
	CreatedAt, ExpiresAt, UpdatedAt   time.Time
	AvailableAt                       time.Time
	LastError                         string
}

type Metadata struct {
	TenantID      string
	PluginID      string
	PluginVersion string
	Target        string
	LeaseID       string
	PolicyEpoch   uint64
}

type OpenFunc func(context.Context, []byte) ([]byte, error)

type Queue = Store

type QueueConfig = Config

type Receipt struct {
	ID, UploadID         string
	ObjectDigest, Digest string
	State                State
	Size                 int64
	Attempt, MaxAttempts int
	CreatedAt, ExpiresAt time.Time
}

type Record = Item

type Request struct {
	ID, UploadID                           string
	TenantID, PluginID, PluginVersion      string
	Target, LeaseID, IdempotencyKey        string
	PolicyEpoch                            uint64
	Plaintext                              []byte
	Payload, Data                          []byte
	Ciphertext, Envelope, EncryptedPayload []byte
	CreatedAt, ExpiresAt                   time.Time
	TTL                                    time.Duration
	MaxAttempts                            int
	Metadata                               Metadata
}

type SealFunc func(context.Context, []byte) ([]byte, error)

type State string

type Stats struct {
	Pending, Queued, Retrying, Processing int
	Completed, Failed, Expired, Canceled  int
	Items                                 int
	Bytes                                 int64
	Paused                                bool
	Corrupt                               int
	LastError                             error
}

type Status = Item

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

type StoreConfig = Config