retaineddata

type BindRequest struct {
	RetainedID            string    `json:"retained_id"`
	BoundPluginInstanceID string    `json:"bound_plugin_instance_id"`
	Now                   time.Time `json:"now,omitempty"`
}

type DeleteFailedRequest struct {
	RetainedID  string    `json:"retained_id"`
	DeleteError string    `json:"delete_error,omitempty"`
	Now         time.Time `json:"now,omitempty"`
}

type DeleteRequest struct {
	RetainedID string    `json:"retained_id"`
	Now        time.Time `json:"now,omitempty"`
}

type ListRequest struct {
	PublisherID            string `json:"publisher_id,omitempty"`
	PluginID               string `json:"plugin_id,omitempty"`
	SourcePluginInstanceID string `json:"source_plugin_instance_id,omitempty"`
	State                  State  `json:"state,omitempty"`
}

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

type Record struct {
	RetainedID             string            `json:"retained_id"`
	SourcePluginInstanceID string            `json:"source_plugin_instance_id"`
	BoundPluginInstanceID  string            `json:"bound_plugin_instance_id,omitempty"`
	PublisherID            string            `json:"publisher_id"`
	PluginID               string            `json:"plugin_id"`
	Version                string            `json:"version"`
	PackageHash            string            `json:"package_hash"`
	ManifestHash           string            `json:"manifest_hash"`
	State                  State             `json:"state"`
	StorageRetained        bool              `json:"storage_retained"`
	SettingsRetained       bool              `json:"settings_retained"`
	UsageBytes             int64             `json:"usage_bytes,omitempty"`
	DeleteAfter            *time.Time        `json:"delete_after,omitempty"`
	DeleteError            string            `json:"delete_error,omitempty"`
	Metadata               map[string]string `json:"metadata,omitempty"`
	RetainedAt             time.Time         `json:"retained_at"`
	UpdatedAt              time.Time         `json:"updated_at"`
	BoundAt                *time.Time        `json:"bound_at,omitempty"`
	DeletedAt              *time.Time        `json:"deleted_at,omitempty"`
	LastAccessedAt         *time.Time        `json:"last_accessed_at,omitempty"`
}

type RetainRequest struct {
	RetainedID             string            `json:"retained_id"`
	SourcePluginInstanceID string            `json:"source_plugin_instance_id"`
	PublisherID            string            `json:"publisher_id"`
	PluginID               string            `json:"plugin_id"`
	Version                string            `json:"version"`
	PackageHash            string            `json:"package_hash"`
	ManifestHash           string            `json:"manifest_hash"`
	StorageRetained        bool              `json:"storage_retained"`
	SettingsRetained       bool              `json:"settings_retained"`
	UsageBytes             int64             `json:"usage_bytes,omitempty"`
	DeleteAfter            *time.Time        `json:"delete_after,omitempty"`
	Metadata               map[string]string `json:"metadata,omitempty"`
	Now                    time.Time         `json:"now,omitempty"`
}

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

type State string

type Store interface {
	Retain(ctx context.Context, req RetainRequest) (Record, error)
	Get(ctx context.Context, retainedID string) (Record, error)
	List(ctx context.Context, req ListRequest) ([]Record, error)
	MarkBound(ctx context.Context, req BindRequest) (Record, error)
	MarkDeleted(ctx context.Context, req DeleteRequest) (Record, error)
	MarkDeleteFailed(ctx context.Context, req DeleteFailedRequest) (Record, error)
	Touch(ctx context.Context, req TouchRequest) (Record, error)
	ExpireBefore(ctx context.Context, now time.Time) ([]Record, error)
	Delete(ctx context.Context, retainedID string) error
}

type TouchRequest struct {
	RetainedID string    `json:"retained_id"`
	Now        time.Time `json:"now,omitempty"`
}