storages

type BackendResponse = backend.Response

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

type Cluster struct {
	MethodSet set.Set
	// contains filtered or unexported fields
}

type ClusterStorage interface {
	GetShard(name string) (NamedShardClient, error)
	MergeShards(name string, clusters ...NamedShardClient) NamedShardClient
}

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

type NamedCluster interface {
	http.RoundTripper
	Name() string
	Backends() []*Backend
}

type NamedShardClient interface {
	http.RoundTripper
	Name() string
	Backends() []*StorageClient
}

type ObjectResponsePicker struct {
	BasePicker
	// contains filtered or unexported fields
}

type ReplicationClient struct {
	Backends []*backend.Backend
	// contains filtered or unexported fields
}

type RequestDispatcher struct {
	Backends []*backend.Backend
	// contains filtered or unexported fields
}

type ShardClient struct {
	MethodSet set.Set
	// contains filtered or unexported fields
}

type StorageClient = backend.Backend

type Storages struct {
	ShardClients map[string]NamedShardClient
	Backends     map[string]*StorageClient
	// contains filtered or unexported fields
}

type SyncSender struct {
	AllowedMethods map[string]struct{}
	SyncLog        log.Logger
}