rgw

Documentation

Overview

Copyright 2016 The Rook Authors. All rights reserved.

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.

Copyright 2016 The Rook Authors. All rights reserved.

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.

Copyright 2016 The Rook Authors. All rights reserved.

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.

Copyright 2016 The Rook Authors. All rights reserved.

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.

Copyright 2016 The Rook Authors. All rights reserved.

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.

Copyright 2016 The Rook Authors. All rights reserved.

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 EnableObjectStore(context *clusterd.Context) error
• func GetBuiltinUserAccessInfo(etcdClient etcd.KeysAPI) (string, string, error)
• func GetRGWEndpoints(etcdClient etcd.KeysAPI, clusterInventory *inventory.Config) (host, ipEndpoint string, found bool, err error)
• func NewAgent(factory client.ConnectionFactory) *rgwAgent
• func RemoveObjectStore(context *clusterd.Context) error
• func RunAdminCommand(context *clusterd.Context, command, subcommand string, args ...string) (string, error)
• type Leader
  • func NewLeader() *Leader
  • func (r *Leader) Configure(context *clusterd.Context, factory client.ConnectionFactory) error

Constants

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

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

Functions

func EnableObjectStore

func EnableObjectStore(context *clusterd.Context) error

Configure the single instance of object storage in the cluster.

func GetBuiltinUserAccessInfo

func GetBuiltinUserAccessInfo(etcdClient etcd.KeysAPI) (string, string, error)

func GetRGWEndpoints

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

func NewAgent

func NewAgent(factory client.ConnectionFactory) *rgwAgent

func RemoveObjectStore

func RemoveObjectStore(context *clusterd.Context) error

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

func RunAdminCommand

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

Runs the embedded radosgw-admin command and returns its output

Types

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.