mirror of
https://github.com/octoleo/restic.git
synced 2024-12-11 21:57:58 +00:00
110 lines
2.8 KiB
Go
110 lines
2.8 KiB
Go
// Copyright...
|
|
|
|
// This example demonstrates opening a Connection and doing some basic operations.
|
|
package swift_test
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/ncw/swift"
|
|
)
|
|
|
|
func ExampleConnection() {
|
|
// Create a v1 auth connection
|
|
c := &swift.Connection{
|
|
// This should be your username
|
|
UserName: "user",
|
|
// This should be your api key
|
|
ApiKey: "key",
|
|
// This should be a v1 auth url, eg
|
|
// Rackspace US https://auth.api.rackspacecloud.com/v1.0
|
|
// Rackspace UK https://lon.auth.api.rackspacecloud.com/v1.0
|
|
// Memset Memstore UK https://auth.storage.memset.com/v1.0
|
|
AuthUrl: "auth_url",
|
|
}
|
|
|
|
// Authenticate
|
|
err := c.Authenticate()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
// List all the containers
|
|
containers, err := c.ContainerNames(nil)
|
|
fmt.Println(containers)
|
|
// etc...
|
|
|
|
// ------ or alternatively create a v2 connection ------
|
|
|
|
// Create a v2 auth connection
|
|
c = &swift.Connection{
|
|
// This is the sub user for the storage - eg "admin"
|
|
UserName: "user",
|
|
// This should be your api key
|
|
ApiKey: "key",
|
|
// This should be a version2 auth url, eg
|
|
// Rackspace v2 https://identity.api.rackspacecloud.com/v2.0
|
|
// Memset Memstore v2 https://auth.storage.memset.com/v2.0
|
|
AuthUrl: "v2_auth_url",
|
|
// Region to use - default is use first region if unset
|
|
Region: "LON",
|
|
// Name of the tenant - this is likely your username
|
|
Tenant: "jim",
|
|
}
|
|
|
|
// as above...
|
|
}
|
|
|
|
var container string
|
|
|
|
func ExampleConnection_ObjectsWalk() {
|
|
c, rollback := makeConnection(nil)
|
|
defer rollback()
|
|
|
|
objects := make([]string, 0)
|
|
err := c.ObjectsWalk(container, nil, func(opts *swift.ObjectsOpts) (interface{}, error) {
|
|
newObjects, err := c.ObjectNames(container, opts)
|
|
if err == nil {
|
|
objects = append(objects, newObjects...)
|
|
}
|
|
return newObjects, err
|
|
})
|
|
fmt.Println("Found all the objects", objects, err)
|
|
}
|
|
|
|
func ExampleConnection_VersionContainerCreate() {
|
|
c, rollback := makeConnection(nil)
|
|
defer rollback()
|
|
|
|
// Use the helper method to create the current and versions container.
|
|
if err := c.VersionContainerCreate("cds", "cd-versions"); err != nil {
|
|
fmt.Print(err.Error())
|
|
}
|
|
}
|
|
|
|
func ExampleConnection_VersionEnable() {
|
|
c, rollback := makeConnection(nil)
|
|
defer rollback()
|
|
|
|
// Build the containers manually and enable them.
|
|
if err := c.ContainerCreate("movie-versions", nil); err != nil {
|
|
fmt.Print(err.Error())
|
|
}
|
|
if err := c.ContainerCreate("movies", nil); err != nil {
|
|
fmt.Print(err.Error())
|
|
}
|
|
if err := c.VersionEnable("movies", "movie-versions"); err != nil {
|
|
fmt.Print(err.Error())
|
|
}
|
|
|
|
// Access the primary container as usual with ObjectCreate(), ObjectPut(), etc.
|
|
// etc...
|
|
}
|
|
|
|
func ExampleConnection_VersionDisable() {
|
|
c, rollback := makeConnection(nil)
|
|
defer rollback()
|
|
|
|
// Disable versioning on a container. Note that this does not delete the versioning container.
|
|
c.VersionDisable("movies")
|
|
}
|