obs

Documentation

Overview

Copyright 2023 Huawei Cloud Computing Technologies Co., Ltd.

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 2023 Huawei Cloud Computing Technologies Co., Ltd.

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 GetBaseMstPath(shardPath, mstName string) string
• func GetLocalMstPath(localPath, mstPath string) string
• func GetShardPath(shardId, IndexId uint64, ptId uint32, startTime, endTime time.Time, ...) string
• func OpenObsFile(path, fileName string, obsOpts *ObsOptions) (fileops.File, error)
• type ObsOptions
  • func (cro *ObsOptions) Clone() *ObsOptions
  • func (cro *ObsOptions) Validate() bool

Constants

const (
	StoreDirName       = "data"
	ColumnStoreDirName = "columnstore"
)

Functions

func GetBaseMstPath

func GetBaseMstPath(shardPath, mstName string) string

"data/dbName/ptID/rpName/shardId_startTime_endTime_indexId/columnstore/mstName"

func GetLocalMstPath

func GetLocalMstPath(localPath, mstPath string) string

"localDataPath/data/dbName/ptID/rpName/shardId_startTime_endTime_indexId/columnstore/mstName"

func GetShardPath

func GetShardPath(shardId, IndexId uint64, ptId uint32, startTime, endTime time.Time, databaseName, rpName string) string

"data/dbName/ptID/rpName/shardId_startTime_endTime_indexId/columnstore"

func OpenObsFile

func OpenObsFile(path, fileName string, obsOpts *ObsOptions) (fileops.File, error)

Types

type ObsOptions

type ObsOptions struct {
	Enabled    bool   `json:"enabled"`
	BucketName string `json:"bucket_name"`
	Endpoint   string `json:"endpoint"`
	Ak         string `json:"ak"`
	Sk         string `json:"sk"`
	BasePath   string `json:"path"`
}

func (*ObsOptions) Clone

func (cro *ObsOptions) Clone() *ObsOptions

func (*ObsOptions) Validate

func (cro *ObsOptions) Validate() bool