serviceImpl

Documentation

Overview

* Copyright (c) 2015-2018 Nexenta Systems, Inc. * * This file is part of EdgeFS Project * (see https://github.com/Nexenta/edgefs). * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you 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 BuildGrpcEndpoints(eps *map[string]int, service string, namespace string)
• func DeleteServiceLunISCSI(service, cluster, tenant, bucket, lun string, lunId uint32) error
• func DeleteServiceObjectNFS(sname string, cluster string, tenant string, bucket string, oldExportId uint32) error
• func ISCSIAddLun(eps map[string]int, ...) error
• func ISCSIRemoveLun(eps map[string]int, ...) error
• func InsertServiceObjectISCSI(sname, cluster, tenant, bucket, object string, newLunId uint32, ...) error
• func InsertServiceObjectNFS(sname string, cluster string, tenant string, bucket string, newExportId uint32) error
• func NFSAddExport(eps map[string]int, msg *proto.ServeRequest, exportId uint32) error
• func NFSRemoveExport(eps map[string]int, msg *proto.ServeRequest, exportId uint32) error
• func NewExportIdNFS(sname string, cluster string, tenant string, bucket string) (uint32, error)
• func NewLunIdISCSI(sname, cluster, tenant, bucket, lun string) (uint32, error)
• func OldExportIdNFS(sname string, cluster string, tenant string, bucket string) (uint32, error)
• func ServiceServeISCSI(sname string, opath string, opts map[string]string) error
• func ServiceServeISGW(sname string, bpath string) error
• func ServiceServeNFS(sname string, bpath string) error
• func ServiceServeS3(sname string, tpath string) error
• type ServiceImpl
  • func (s *ServiceImpl) Serve(ctx context.Context, msg *proto.ServeRequest) (*proto.ServeResponse, error)
  • func (s *ServiceImpl) ServiceCreate(ctx context.Context, msg *proto.ServiceCreateRequest) (*proto.GenericResponse, error)
  • func (s *ServiceImpl) ServiceDelete(ctx context.Context, msg *proto.ServiceDeleteRequest) (*proto.GenericResponse, error)
  • func (s *ServiceImpl) ServiceList(ctx context.Context, msg *proto.ServiceListRequest) (*proto.ServiceListResponse, error)
  • func (s *ServiceImpl) ServiceObjectList(ctx context.Context, msg *proto.ServiceObjectListRequest) (*proto.ServiceObjectListResponse, error)
  • func (s *ServiceImpl) ServiceShow(ctx context.Context, msg *proto.ServiceShowRequest) (*proto.ServiceShowResponse, error)
  • func (s *ServiceImpl) SetParam(ctx context.Context, msg *proto.SetParamRequest) (*proto.GenericResponse, error)
  • func (s *ServiceImpl) Unserve(ctx context.Context, msg *proto.ServeRequest) (*proto.GenericResponse, error)
• type VolumeSettings

Constants

const (
	VOLSIZE_KEY   = "X-volsize"
	BLOCKSIZE_KEY = "X-blocksize"
	CHUNKSIZE_KEY = "ccow-chunkmap-chunk-size"
)

Functions

func BuildGrpcEndpoints

func BuildGrpcEndpoints(eps *map[string]int, service string, namespace string)

func DeleteServiceLunISCSI

func DeleteServiceLunISCSI(service, cluster, tenant, bucket, lun string, lunId uint32) error

func DeleteServiceObjectNFS

func DeleteServiceObjectNFS(sname string, cluster string, tenant string, bucket string, oldExportId uint32) error

func ISCSIAddLun

func ISCSIAddLun(eps map[string]int, serviceName, clusterName, tenantName, bucketName, objectName string, lunNumber uint32) error

func ISCSIRemoveLun

func ISCSIRemoveLun(eps map[string]int, serviceName, clusterName, tenantName, bucketName, objectName string, lunNumber uint32) error

func InsertServiceObjectISCSI

func InsertServiceObjectISCSI(sname, cluster, tenant, bucket, object string, newLunId uint32, settings VolumeSettings) error

func InsertServiceObjectNFS

func InsertServiceObjectNFS(sname string, cluster string, tenant string, bucket string, newExportId uint32) error

func NFSAddExport

func NFSAddExport(eps map[string]int, msg *proto.ServeRequest, exportId uint32) error

func NFSRemoveExport

func NFSRemoveExport(eps map[string]int, msg *proto.ServeRequest, exportId uint32) error

func NewExportIdNFS

func NewExportIdNFS(sname string, cluster string, tenant string, bucket string) (uint32, error)

func NewLunIdISCSI

func NewLunIdISCSI(sname, cluster, tenant, bucket, lun string) (uint32, error)

func OldExportIdNFS

func OldExportIdNFS(sname string, cluster string, tenant string, bucket string) (uint32, error)

func ServiceServeISCSI

func ServiceServeISCSI(sname string, opath string, opts map[string]string) error

func ServiceServeISGW

func ServiceServeISGW(sname string, bpath string) error

func ServiceServeNFS

func ServiceServeNFS(sname string, bpath string) error

func ServiceServeS3

func ServiceServeS3(sname string, tpath string) error

Types

type ServiceImpl

type ServiceImpl struct {
}

func (*ServiceImpl) Serve

func (s *ServiceImpl) Serve(ctx context.Context, msg *proto.ServeRequest) (*proto.ServeResponse, error)

func (*ServiceImpl) ServiceCreate

func (s *ServiceImpl) ServiceCreate(ctx context.Context, msg *proto.ServiceCreateRequest) (*proto.GenericResponse, error)

func (*ServiceImpl) ServiceDelete

func (s *ServiceImpl) ServiceDelete(ctx context.Context, msg *proto.ServiceDeleteRequest) (*proto.GenericResponse, error)

func (*ServiceImpl) ServiceList

func (s *ServiceImpl) ServiceList(ctx context.Context, msg *proto.ServiceListRequest) (*proto.ServiceListResponse, error)

func (*ServiceImpl) ServiceObjectList

func (s *ServiceImpl) ServiceObjectList(ctx context.Context, msg *proto.ServiceObjectListRequest) (*proto.ServiceObjectListResponse, error)

func (*ServiceImpl) ServiceShow

func (s *ServiceImpl) ServiceShow(ctx context.Context, msg *proto.ServiceShowRequest) (*proto.ServiceShowResponse, error)

func (*ServiceImpl) SetParam

func (s *ServiceImpl) SetParam(ctx context.Context, msg *proto.SetParamRequest) (*proto.GenericResponse, error)

func (*ServiceImpl) Unserve

func (s *ServiceImpl) Unserve(ctx context.Context, msg *proto.ServeRequest) (*proto.GenericResponse, error)

type VolumeSettings

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