rgw

package

v0.3.0 Latest Latest Go to latest Published: Mar 3, 2017 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ikor/rook

Links

Open Source Insights

Documentation ¶

Overview ¶

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index ¶

Constants
func CreateKeyring(conn client.Connection) (string, error)
func CreateUser(context *clusterd.Context, user model.ObjectUser, ...) (*model.ObjectUser, int, error)
func DeleteUser(context *clusterd.Context, id string, ...) (string, int, error)
func EnableObjectStore(etcdClient etcd.KeysAPI) error
func GetBucketStats(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) (map[string]model.ObjectBucketStats, error)
func GetRGWEndpoint(addr string) string
func GetRGWEndpoints(etcdClient etcd.KeysAPI, clusterInventory *inventory.Config) (host, ipEndpoint string, found bool, err error)
func GetUser(context *clusterd.Context, id string, ...) (*model.ObjectUser, int, error)
func ListBuckets(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) ([]model.ObjectBucket, error)
func ListUsers(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) ([]string, int, error)
func NewAgent(factory client.ConnectionFactory) *rgwAgent
func RemoveObjectStore(etcdClient etcd.KeysAPI) error
func Run(context *clusterd.DaemonContext, config *Config) error
func RunAdminCommand(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error), ...) (string, error)
func UpdateUser(context *clusterd.Context, user model.ObjectUser, ...) (*model.ObjectUser, int, error)
type Config
type Leader
- func NewLeader() *Leader
- func (r *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory) error

Constants ¶

View Source

const (
	DNSName = "rook-rgw"
	RGWPort = 53390
)

View Source

const (
	RGWKey         = "rgw"
	ObjectStoreKey = "object"
)

View Source

const (
	RGWErrorNone     = iota
	RGWErrorUnknown  = iota
	RGWErrorNotFound = iota
	RGWErrorBadData  = iota
	RGWErrorParse    = iota
)

Variables ¶

This section is empty.

Functions ¶

func CreateKeyring ¶ added in v0.3.0

func CreateKeyring(conn client.Connection) (string, error)

create a keyring for the rgw client with a limited set of privileges

func CreateUser ¶ added in v0.3.0

func CreateUser(context *clusterd.Context, user model.ObjectUser, getClusterInfo func() (*mon.ClusterInfo, error)) (*model.ObjectUser, int, error)

func DeleteUser ¶ added in v0.3.0

func DeleteUser(context *clusterd.Context, id string, getClusterInfo func() (*mon.ClusterInfo, error)) (string, int, error)

func EnableObjectStore ¶

func EnableObjectStore(etcdClient etcd.KeysAPI) error

Configure the single instance of object storage in the cluster.

func GetBucketStats ¶ added in v0.3.0

func GetBucketStats(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) (map[string]model.ObjectBucketStats, error)

func GetRGWEndpoint ¶ added in v0.3.0

func GetRGWEndpoint(addr string) string

func GetRGWEndpoints ¶ added in v0.2.0

func GetRGWEndpoints(etcdClient etcd.KeysAPI, clusterInventory *inventory.Config) (host, ipEndpoint string, found bool, err error)

func GetUser ¶ added in v0.3.0

func GetUser(context *clusterd.Context, id string, getClusterInfo func() (*mon.ClusterInfo, error)) (*model.ObjectUser, int, error)

func ListBuckets ¶ added in v0.3.0

func ListBuckets(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) ([]model.ObjectBucket, error)

func ListUsers ¶ added in v0.3.0

func ListUsers(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error)) ([]string, int, error)

func NewAgent ¶

func NewAgent(factory client.ConnectionFactory) *rgwAgent

func RemoveObjectStore ¶

func RemoveObjectStore(etcdClient etcd.KeysAPI) error

Remove the single instance of the object store from the cluster. All buckets will be purged..

func Run ¶ added in v0.3.0

func Run(context *clusterd.DaemonContext, config *Config) error

func RunAdminCommand ¶

func RunAdminCommand(context *clusterd.Context, getClusterInfo func() (*mon.ClusterInfo, error), command, subcommand string, args ...string) (string, error)

func UpdateUser ¶ added in v0.3.0

func UpdateUser(context *clusterd.Context, user model.ObjectUser, getClusterInfo func() (*mon.ClusterInfo, error)) (*model.ObjectUser, int, error)

Types ¶

type Config ¶ added in v0.3.0

type Config struct {
	Host        string
	Port        int
	Keyring     string
	InProc      bool
	ClusterInfo *mon.ClusterInfo
	mon.CephLauncher
}

type Leader ¶

type Leader struct {
}

func NewLeader ¶

func NewLeader() *Leader

func (*Leader) Configure ¶

func (r *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory) error

Apply the desired state to the cluster. The context provides all the information needed to make changes to the service. Initialize CephFS. Must be idempotent.

Source Files ¶

View all Source files

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