accountserver

package

Go to main page

Versions in this module

v1

v1.2.0

Apr 2, 2018

Changes in this version

+ func SendPriRepJob(job *PriorityRepJob, client *http.Client) (string, bool)

+ type PriorityRepJob struct

+ FromDevice *ring.Device

+ Partition uint64

+ ToDevice *ring.Device

v1.0.0

Jan 31, 2018

v0

v0.0.5

Jan 18, 2018

v0.0.4

Jan 17, 2018

v0.0.3

Jan 17, 2018

v0.0.2

Jan 17, 2018

Changes in this version

+ func NewReplicator(serverconf conf.Config, flags *flag.FlagSet, cnf srv.ConfigLoader) (*srv.IpPort, srv.Server, srv.LowLevelLogger, error)

+ func NewServer(serverconf conf.Config, flags *flag.FlagSet, cnf srv.ConfigLoader) (*srv.IpPort, srv.Server, srv.LowLevelLogger, error)

type AccountServer

+ func (server *AccountServer) Background(flags *flag.FlagSet) chan struct{}

+ func (server *AccountServer) Type() string

type Replicator

+ func (server *Replicator) Background(flags *flag.FlagSet) chan struct{}

+ func (server *Replicator) Finalize()

+ func (server *Replicator) GetHandler(config conf.Config, metricsPrefix string) http.Handler

+ func (server *Replicator) HealthcheckHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *Replicator) LogRequest(next http.Handler) http.Handler

+ func (server *Replicator) Type() string

v0.0.1

Jul 7, 2017

Changes in this version

+ var ErrorInvalidMetadata = fmt.Errorf("Invalid metadata value")

+ var ErrorNoSuchAccount = fmt.Errorf("No such account.")

+ var GetHashPrefixAndSuffix = conf.GetHashPrefixAndSuffix

+ var GetRing = ring.GetRing

+ func GetReplicator(serverconf conf.Config, flags *flag.FlagSet) (srv.Daemon, srv.LowLevelLogger, error)

+ func GetServer(serverconf conf.Config, flags *flag.FlagSet) (bindIP string, bindPort int, serv srv.Server, logger srv.LowLevelLogger, ...)

+ type Account interface

+ Close func() error

+ Delete func(timestamp string) error

+ GetInfo func() (*AccountInfo, error)

+ GetMetadata func() (map[string]string, error)

+ ID func() string

+ IsDeleted func() (bool, error)

+ ListContainers func(limit int, marker string, endMarker string, prefix string, delimiter string, ...) ([]interface{}, error)

+ PolicyStats func() ([]*PolicyStat, error)

+ PutContainer func(name string, putTimestamp string, deleteTimestamp string, objectCount int64, ...) error

+ UpdateMetadata func(updates map[string][]string) error

+ type AccountEngine interface

+ Close func()

+ Create func(vars map[string]string, putTimestamp string, metadata map[string][]string) (bool, Account, error)

+ Get func(vars map[string]string) (c Account, err error)

+ GetByHash func(device, hash, partition string) (c ReplicableAccount, err error)

+ Invalidate func(c Account)

+ Return func(c Account)

+ type AccountInfo struct

+ Account string

+ BytesUsed int64

+ ContainerCount int64

+ CreatedAt string

+ DeleteTimestamp string

+ Hash string

+ ID string

+ MaxRow int64

+ Metadata map[string][]string

+ ObjectCount int64

+ Point int64

+ PutTimestamp string

+ RawMetadata string

+ StatusChangedAt string

+ type AccountServer struct

+ func (server *AccountServer) AccountDeleteHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) AccountGetHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) AccountPostHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) AccountPutHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) AccountReplicateHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) AcquireDevice(next http.Handler) http.Handler

+ func (server *AccountServer) ContainerPutHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) DiskUsageHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) Finalize()

+ func (server *AccountServer) GetHandler(config conf.Config) http.Handler

+ func (server *AccountServer) HealthcheckHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) LogRequest(next http.Handler) http.Handler

+ func (server *AccountServer) ReconHandler(writer http.ResponseWriter, request *http.Request)

+ func (server *AccountServer) TmpUploadHandler(writer http.ResponseWriter, request *http.Request)

+ type ContainerListingRecord struct

+ Bytes int64

+ Count int64

+ LastModified string

+ Name string

+ XMLName xml.Name

+ type ContainerRecord struct

+ BytesUsed int64

+ DeleteTimestamp string

+ Deleted int

+ Name string

+ ObjectCount int64

+ PutTimestamp string

+ Rowid int64

+ StoragePolicyIndex int

+ type PolicyStat struct

+ BytesUsed int64

+ ContainerCount int64

+ ObjectCount int64

+ StoragePolicyIndex int

+ type ReplicableAccount interface

+ CleanupTombstones func(reclaimAge int64) error

+ ItemsSince func(start int64, count int) ([]*ContainerRecord, error)

+ MergeItems func(records []*ContainerRecord, remoteID string) error

+ MergeSyncTable func(records []*SyncRecord) error

+ NewID func() error

+ OpenDatabaseFile func() (*os.File, func(), error)

+ RingHash func() string

+ SyncRemoteData func(maxRow int64, ...) (*AccountInfo, error)

+ SyncTable func() ([]*SyncRecord, error)

+ type Replicator struct

+ Ring ring.Ring

+ func (r *Replicator) Run()

+ func (r *Replicator) RunForever()

+ type SubdirListingRecord struct

+ Name string

+ Name2 string

+ XMLName xml.Name

+ type SyncRecord struct

+ RemoteID string

+ SyncPoint int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL