containerserver

type Container interface {
	// GetInfo returns the ContainerInfo struct for the container.
	GetInfo() (*ContainerInfo, error)
	// IsDeleted returns true if the container has been deleted.
	IsDeleted() (bool, error)
	// Delete deletes the container.
	Delete(timestamp string) error
	// ListObjects lists the container's object entries.
	ListObjects(limit int, marker string, endMarker string, prefix string, delimiter string, path *string, reverse bool, storagePolicyIndex int) ([]interface{}, error)
	// GetMetadata returns the container's current metadata.
	GetMetadata() (map[string]string, error)
	// UpdateMetadata applies updates to the container's metadata.
	UpdateMetadata(updates map[string][]string, timestamp string) error
	// PutObject adds a new object to the container.
	PutObject(name string, timestamp string, size int64, contentType string, etag string, storagePolicyIndex int) error
	// DeleteObject deletes an object from the container.
	DeleteObject(name string, timestamp string, storagePolicyIndex int) error
	// ID returns a unique identifier for the container.
	ID() string
	// Close frees any resources associated with the container.
	Close() error
}

type ContainerEngine interface {
	// GET returns a container, given a vars mapping.
	Get(vars map[string]string) (c Container, err error)
	// Return returns a Container to the engine, where it can close or retain them as it sees fit.
	Return(c Container)
	// Create creates a new container.  Returns true if the container was created and a pointer to the container.
	Create(vars map[string]string, putTimestamp string, metadata map[string][]string, policyIndex, defaultPolicyIndex int) (bool, Container, error)
	// Close releases all cached containers and any other retained resources.
	Close()

	// GetByHash returns a replicable database given its hash.  This will probably move from this interface once we
	// have replicator->replicator communication.
	GetByHash(device, hash, partition string) (c ReplicableContainer, err error)
	// Invalidate removes a container from the cache entirely.  This will probably also move, since it's only used by replication.
	Invalidate(c Container)

	// Number of containers that have been Get()ted but not Return()ed
	OpenCount() (count int)
}

type ContainerInfo struct {
	Account                 string              `json:"account"`
	Container               string              `json:"container"`
	CreatedAt               string              `json:"created_at"`
	PutTimestamp            string              `json:"put_timestamp"`
	DeleteTimestamp         string              `json:"delete_timestamp"`
	StatusChangedAt         string              `json:"status_changed_at"`
	ObjectCount             int64               `json:"count"`
	BytesUsed               int64               `json:"bytes_used"`
	ReportedPutTimestamp    string              `json:"-"`
	ReportedDeleteTimestamp string              `json:"-"`
	ReportedObjectCount     int64               `json:"-"`
	ReportedBytesUsed       int64               `json:"-"`
	Hash                    string              `json:"hash"`
	ID                      string              `json:"id"`
	XContainerSyncPoint1    string              `json:"-"`
	XContainerSyncPoint2    string              `json:"-"`
	StoragePolicyIndex      int                 `json:"storage_policy_index"`
	RawMetadata             string              `json:"metadata"`
	Metadata                map[string][]string `json:"-"`
	MaxRow                  int64               `json:"max_row"`

	// This row isn't populated by GetInfo, it only exists for the times this is
	// serialized during replication.
	Point int64 `json:"point"`
	// contains filtered or unexported fields
}

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

type ObjectListingRecord struct {
	XMLName      xml.Name `xml:"object" json:"-"`
	Name         string   `xml:"name" json:"name"`
	LastModified string   `xml:"last_modified" json:"last_modified"`
	Size         int64    `xml:"bytes" json:"bytes"`
	ContentType  string   `xml:"content_type" json:"content_type"`
	ETag         string   `xml:"hash" json:"hash"`
}

type ObjectRecord struct {
	Rowid              int64  `json:"ROWID"`
	Name               string `json:"name"`
	CreatedAt          string `json:"created_at"`
	Size               int64  `json:"size"`
	ContentType        string `json:"content_type"`
	ETag               string `json:"etag"`
	Deleted            int    `json:"deleted"`
	StoragePolicyIndex int    `json:"storage_policy_index"`
}

type PriorityRepJob struct {
	Partition  uint64       `json:"partition"`
	FromDevice *ring.Device `json:"from_device"`
	ToDevice   *ring.Device `json:"to_device"`
}

type ReplicableContainer interface {
	Container
	// MergeItems merges object records into the container, with an optional remoteId.
	MergeItems(records []*ObjectRecord, remoteID string) error
	// ItemsSince returns count object records with a ROWID greater than start.
	ItemsSince(start int64, count int) ([]*ObjectRecord, error)
	// MergeSyncTable updates the container's incoming sync tables with new data.
	MergeSyncTable(records []*SyncRecord) error
	// SyncTable returns the container's current sync table.
	SyncTable() ([]*SyncRecord, error)
	// SyncRemoteData accepts a remote container's current status information and updates local records accordingly.
	SyncRemoteData(maxRow int64, hash, id, createdAt, putTimestamp, deleteTimestamp, metadata string) (*ContainerInfo, error)
	// NewID gives the database a new unique identifier, which is used for incoming_sync entries.
	NewID() error
	// OpenDatabaseFile returns a consistent reader for the underlying database file.
	OpenDatabaseFile() (*os.File, func(), error)
	// CleanupTombstones removes any metadata and object tombstones older than reclaimAge seconds.
	CleanupTombstones(reclaimAge int64) error
	// CheckSyncLinks makes sure container sync symlinks are correct for the database.
	CheckSyncLink() error
	// RingHash returns the container's ring hash.
	RingHash() string
	// Reported records the information as having been reported to an account database.
	Reported(putTimestamp, deleteTimestamp string, objectCount, bytesUsed int64) error
}

type Replicator struct {
	Ring ring.Ring
	// contains filtered or unexported fields
}

type SubdirListingRecord struct {
	XMLName xml.Name `xml:"subdir" json:"-"`
	Name2   string   `xml:"name,attr" json:"-"`
	Name    string   `xml:"name" json:"subdir"`
}

type SyncRecord struct {
	SyncPoint int64  `json:"sync_point"`
	RemoteID  string `json:"remote_id"`
}