service

package
v1.1.31 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 31, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ProtocolType_name = map[int32]string{
	0: "UNKNOWN",
	1: "NFS",
	2: "S3",
	3: "ISCSI",
	4: "NBD",
	5: "ISGW",
}
View Source
var ProtocolType_value = map[string]int32{
	"UNKNOWN": 0,
	"NFS":     1,
	"S3":      2,
	"ISCSI":   3,
	"NBD":     4,
	"ISGW":    5,
}

Functions

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type GenericResponse

type GenericResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenericResponse) Descriptor

func (*GenericResponse) Descriptor() ([]byte, []int)

func (*GenericResponse) ProtoMessage

func (*GenericResponse) ProtoMessage()

func (*GenericResponse) Reset

func (m *GenericResponse) Reset()

func (*GenericResponse) String

func (m *GenericResponse) String() string

func (*GenericResponse) XXX_DiscardUnknown

func (m *GenericResponse) XXX_DiscardUnknown()

func (*GenericResponse) XXX_Marshal

func (m *GenericResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenericResponse) XXX_Merge

func (m *GenericResponse) XXX_Merge(src proto.Message)

func (*GenericResponse) XXX_Size

func (m *GenericResponse) XXX_Size() int

func (*GenericResponse) XXX_Unmarshal

func (m *GenericResponse) XXX_Unmarshal(b []byte) error

type ProtocolType

type ProtocolType int32
const (
	ProtocolType_UNKNOWN ProtocolType = 0
	ProtocolType_NFS     ProtocolType = 1
	ProtocolType_S3      ProtocolType = 2
	ProtocolType_ISCSI   ProtocolType = 3
	ProtocolType_NBD     ProtocolType = 4
	ProtocolType_ISGW    ProtocolType = 5
)

func (ProtocolType) EnumDescriptor

func (ProtocolType) EnumDescriptor() ([]byte, []int)

func (ProtocolType) String

func (x ProtocolType) String() string

type ServeRequest

type ServeRequest struct {
	Type                 ProtocolType    `protobuf:"varint,1,opt,name=type,proto3,enum=service.ProtocolType" json:"type,omitempty"`
	Service              string          `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	K8SService           string          `protobuf:"bytes,3,opt,name=k8sService,proto3" json:"k8sService,omitempty"`
	K8SNamespace         string          `protobuf:"bytes,4,opt,name=k8sNamespace,proto3" json:"k8sNamespace,omitempty"`
	Cluster              string          `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Tenant               string          `protobuf:"bytes,6,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Bucket               string          `protobuf:"bytes,7,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Object               string          `protobuf:"bytes,8,opt,name=object,proto3" json:"object,omitempty"`
	VolumeId             uint32          `protobuf:"varint,9,opt,name=volumeId,proto3" json:"volumeId,omitempty"`
	VolumeSettings       *VolumeSettings `protobuf:"bytes,10,opt,name=volumeSettings,proto3" json:"volumeSettings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ServeRequest) Descriptor

func (*ServeRequest) Descriptor() ([]byte, []int)

func (*ServeRequest) GetBucket

func (m *ServeRequest) GetBucket() string

func (*ServeRequest) GetCluster

func (m *ServeRequest) GetCluster() string

func (*ServeRequest) GetK8SNamespace

func (m *ServeRequest) GetK8SNamespace() string

func (*ServeRequest) GetK8SService

func (m *ServeRequest) GetK8SService() string

func (*ServeRequest) GetObject

func (m *ServeRequest) GetObject() string

func (*ServeRequest) GetService

func (m *ServeRequest) GetService() string

func (*ServeRequest) GetTenant

func (m *ServeRequest) GetTenant() string

func (*ServeRequest) GetType

func (m *ServeRequest) GetType() ProtocolType

func (*ServeRequest) GetVolumeId

func (m *ServeRequest) GetVolumeId() uint32

func (*ServeRequest) GetVolumeSettings

func (m *ServeRequest) GetVolumeSettings() *VolumeSettings

func (*ServeRequest) ProtoMessage

func (*ServeRequest) ProtoMessage()

func (*ServeRequest) Reset

func (m *ServeRequest) Reset()

func (*ServeRequest) String

func (m *ServeRequest) String() string

func (*ServeRequest) XXX_DiscardUnknown

func (m *ServeRequest) XXX_DiscardUnknown()

func (*ServeRequest) XXX_Marshal

func (m *ServeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServeRequest) XXX_Merge

func (m *ServeRequest) XXX_Merge(src proto.Message)

func (*ServeRequest) XXX_Size

func (m *ServeRequest) XXX_Size() int

func (*ServeRequest) XXX_Unmarshal

func (m *ServeRequest) XXX_Unmarshal(b []byte) error

type ServeResponse

type ServeResponse struct {
	VolumePath           string   `protobuf:"bytes,1,opt,name=volumePath,proto3" json:"volumePath,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServeResponse) Descriptor

func (*ServeResponse) Descriptor() ([]byte, []int)

func (*ServeResponse) GetVolumePath

func (m *ServeResponse) GetVolumePath() string

func (*ServeResponse) ProtoMessage

func (*ServeResponse) ProtoMessage()

func (*ServeResponse) Reset

func (m *ServeResponse) Reset()

func (*ServeResponse) String

func (m *ServeResponse) String() string

func (*ServeResponse) XXX_DiscardUnknown

func (m *ServeResponse) XXX_DiscardUnknown()

func (*ServeResponse) XXX_Marshal

func (m *ServeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServeResponse) XXX_Merge

func (m *ServeResponse) XXX_Merge(src proto.Message)

func (*ServeResponse) XXX_Size

func (m *ServeResponse) XXX_Size() int

func (*ServeResponse) XXX_Unmarshal

func (m *ServeResponse) XXX_Unmarshal(b []byte) error

type ServiceClient

type ServiceClient interface {
	Serve(ctx context.Context, in *ServeRequest, opts ...grpc.CallOption) (*ServeResponse, error)
	Unserve(ctx context.Context, in *ServeRequest, opts ...grpc.CallOption) (*GenericResponse, error)
	SetParam(ctx context.Context, in *SetParamRequest, opts ...grpc.CallOption) (*GenericResponse, error)
	ServiceList(ctx context.Context, in *ServiceListRequest, opts ...grpc.CallOption) (*ServiceListResponse, error)
	ServiceObjectList(ctx context.Context, in *ServiceObjectListRequest, opts ...grpc.CallOption) (*ServiceObjectListResponse, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceClient

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceInfo

type ServiceInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	//iscsi
	Iqn                  string       `protobuf:"bytes,2,opt,name=iqn,proto3" json:"iqn,omitempty"`
	Type                 ProtocolType `protobuf:"varint,3,opt,name=type,proto3,enum=service.ProtocolType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ServiceInfo) Descriptor

func (*ServiceInfo) Descriptor() ([]byte, []int)

func (*ServiceInfo) GetIqn

func (m *ServiceInfo) GetIqn() string

func (*ServiceInfo) GetName

func (m *ServiceInfo) GetName() string

func (*ServiceInfo) GetType

func (m *ServiceInfo) GetType() ProtocolType

func (*ServiceInfo) ProtoMessage

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String

func (m *ServiceInfo) String() string

func (*ServiceInfo) XXX_DiscardUnknown

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal

func (m *ServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInfo) XXX_Merge

func (m *ServiceInfo) XXX_Merge(src proto.Message)

func (*ServiceInfo) XXX_Size

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal

func (m *ServiceInfo) XXX_Unmarshal(b []byte) error

type ServiceListRequest

type ServiceListRequest struct {
	Pattern              string       `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Count                int32        `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Type                 ProtocolType `protobuf:"varint,3,opt,name=type,proto3,enum=service.ProtocolType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ServiceListRequest) Descriptor

func (*ServiceListRequest) Descriptor() ([]byte, []int)

func (*ServiceListRequest) GetCount

func (m *ServiceListRequest) GetCount() int32

func (*ServiceListRequest) GetPattern

func (m *ServiceListRequest) GetPattern() string

func (*ServiceListRequest) GetType

func (m *ServiceListRequest) GetType() ProtocolType

func (*ServiceListRequest) ProtoMessage

func (*ServiceListRequest) ProtoMessage()

func (*ServiceListRequest) Reset

func (m *ServiceListRequest) Reset()

func (*ServiceListRequest) String

func (m *ServiceListRequest) String() string

func (*ServiceListRequest) XXX_DiscardUnknown

func (m *ServiceListRequest) XXX_DiscardUnknown()

func (*ServiceListRequest) XXX_Marshal

func (m *ServiceListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceListRequest) XXX_Merge

func (m *ServiceListRequest) XXX_Merge(src proto.Message)

func (*ServiceListRequest) XXX_Size

func (m *ServiceListRequest) XXX_Size() int

func (*ServiceListRequest) XXX_Unmarshal

func (m *ServiceListRequest) XXX_Unmarshal(b []byte) error

type ServiceListResponse

type ServiceListResponse struct {
	Info                 map[string]*ServiceInfo `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ServiceListResponse) Descriptor

func (*ServiceListResponse) Descriptor() ([]byte, []int)

func (*ServiceListResponse) GetInfo

func (m *ServiceListResponse) GetInfo() map[string]*ServiceInfo

func (*ServiceListResponse) ProtoMessage

func (*ServiceListResponse) ProtoMessage()

func (*ServiceListResponse) Reset

func (m *ServiceListResponse) Reset()

func (*ServiceListResponse) String

func (m *ServiceListResponse) String() string

func (*ServiceListResponse) XXX_DiscardUnknown

func (m *ServiceListResponse) XXX_DiscardUnknown()

func (*ServiceListResponse) XXX_Marshal

func (m *ServiceListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceListResponse) XXX_Merge

func (m *ServiceListResponse) XXX_Merge(src proto.Message)

func (*ServiceListResponse) XXX_Size

func (m *ServiceListResponse) XXX_Size() int

func (*ServiceListResponse) XXX_Unmarshal

func (m *ServiceListResponse) XXX_Unmarshal(b []byte) error

type ServiceObjectInfo

type ServiceObjectInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceObjectInfo) Descriptor

func (*ServiceObjectInfo) Descriptor() ([]byte, []int)

func (*ServiceObjectInfo) GetName

func (m *ServiceObjectInfo) GetName() string

func (*ServiceObjectInfo) ProtoMessage

func (*ServiceObjectInfo) ProtoMessage()

func (*ServiceObjectInfo) Reset

func (m *ServiceObjectInfo) Reset()

func (*ServiceObjectInfo) String

func (m *ServiceObjectInfo) String() string

func (*ServiceObjectInfo) XXX_DiscardUnknown

func (m *ServiceObjectInfo) XXX_DiscardUnknown()

func (*ServiceObjectInfo) XXX_Marshal

func (m *ServiceObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceObjectInfo) XXX_Merge

func (m *ServiceObjectInfo) XXX_Merge(src proto.Message)

func (*ServiceObjectInfo) XXX_Size

func (m *ServiceObjectInfo) XXX_Size() int

func (*ServiceObjectInfo) XXX_Unmarshal

func (m *ServiceObjectInfo) XXX_Unmarshal(b []byte) error

type ServiceObjectListRequest

type ServiceObjectListRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Pattern              string   `protobuf:"bytes,2,opt,name=pattern,proto3" json:"pattern,omitempty"`
	Count                int32    `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceObjectListRequest) Descriptor

func (*ServiceObjectListRequest) Descriptor() ([]byte, []int)

func (*ServiceObjectListRequest) GetCount

func (m *ServiceObjectListRequest) GetCount() int32

func (*ServiceObjectListRequest) GetPattern

func (m *ServiceObjectListRequest) GetPattern() string

func (*ServiceObjectListRequest) GetService

func (m *ServiceObjectListRequest) GetService() string

func (*ServiceObjectListRequest) ProtoMessage

func (*ServiceObjectListRequest) ProtoMessage()

func (*ServiceObjectListRequest) Reset

func (m *ServiceObjectListRequest) Reset()

func (*ServiceObjectListRequest) String

func (m *ServiceObjectListRequest) String() string

func (*ServiceObjectListRequest) XXX_DiscardUnknown

func (m *ServiceObjectListRequest) XXX_DiscardUnknown()

func (*ServiceObjectListRequest) XXX_Marshal

func (m *ServiceObjectListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceObjectListRequest) XXX_Merge

func (m *ServiceObjectListRequest) XXX_Merge(src proto.Message)

func (*ServiceObjectListRequest) XXX_Size

func (m *ServiceObjectListRequest) XXX_Size() int

func (*ServiceObjectListRequest) XXX_Unmarshal

func (m *ServiceObjectListRequest) XXX_Unmarshal(b []byte) error

type ServiceObjectListResponse

type ServiceObjectListResponse struct {
	Info                 map[string]*ServiceObjectInfo `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ServiceObjectListResponse) Descriptor

func (*ServiceObjectListResponse) Descriptor() ([]byte, []int)

func (*ServiceObjectListResponse) GetInfo

func (*ServiceObjectListResponse) ProtoMessage

func (*ServiceObjectListResponse) ProtoMessage()

func (*ServiceObjectListResponse) Reset

func (m *ServiceObjectListResponse) Reset()

func (*ServiceObjectListResponse) String

func (m *ServiceObjectListResponse) String() string

func (*ServiceObjectListResponse) XXX_DiscardUnknown

func (m *ServiceObjectListResponse) XXX_DiscardUnknown()

func (*ServiceObjectListResponse) XXX_Marshal

func (m *ServiceObjectListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceObjectListResponse) XXX_Merge

func (m *ServiceObjectListResponse) XXX_Merge(src proto.Message)

func (*ServiceObjectListResponse) XXX_Size

func (m *ServiceObjectListResponse) XXX_Size() int

func (*ServiceObjectListResponse) XXX_Unmarshal

func (m *ServiceObjectListResponse) XXX_Unmarshal(b []byte) error

type ServiceServer

ServiceServer is the server API for Service service.

type SetParamRequest

type SetParamRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Tenant               string   `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetParamRequest) Descriptor

func (*SetParamRequest) Descriptor() ([]byte, []int)

func (*SetParamRequest) GetService

func (m *SetParamRequest) GetService() string

func (*SetParamRequest) GetTenant

func (m *SetParamRequest) GetTenant() string

func (*SetParamRequest) ProtoMessage

func (*SetParamRequest) ProtoMessage()

func (*SetParamRequest) Reset

func (m *SetParamRequest) Reset()

func (*SetParamRequest) String

func (m *SetParamRequest) String() string

func (*SetParamRequest) XXX_DiscardUnknown

func (m *SetParamRequest) XXX_DiscardUnknown()

func (*SetParamRequest) XXX_Marshal

func (m *SetParamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetParamRequest) XXX_Merge

func (m *SetParamRequest) XXX_Merge(src proto.Message)

func (*SetParamRequest) XXX_Size

func (m *SetParamRequest) XXX_Size() int

func (*SetParamRequest) XXX_Unmarshal

func (m *SetParamRequest) XXX_Unmarshal(b []byte) error

type UnimplementedServiceServer

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServer) Serve

func (*UnimplementedServiceServer) ServiceList

func (*UnimplementedServiceServer) ServiceObjectList

func (*UnimplementedServiceServer) SetParam

func (*UnimplementedServiceServer) Unserve

type VolumeSettings

type VolumeSettings struct {
	IsClonedObject bool `protobuf:"varint,1,opt,name=isClonedObject,proto3" json:"isClonedObject,omitempty"`
	//volume size in bytes
	VolumeSize           int64    `protobuf:"varint,2,opt,name=volumeSize,proto3" json:"volumeSize,omitempty"`
	ChunkSize            int32    `protobuf:"varint,3,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	BlockSize            int32    `protobuf:"varint,4,opt,name=blockSize,proto3" json:"blockSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VolumeSettings) Descriptor

func (*VolumeSettings) Descriptor() ([]byte, []int)

func (*VolumeSettings) GetBlockSize

func (m *VolumeSettings) GetBlockSize() int32

func (*VolumeSettings) GetChunkSize

func (m *VolumeSettings) GetChunkSize() int32

func (*VolumeSettings) GetIsClonedObject

func (m *VolumeSettings) GetIsClonedObject() bool

func (*VolumeSettings) GetVolumeSize

func (m *VolumeSettings) GetVolumeSize() int64

func (*VolumeSettings) ProtoMessage

func (*VolumeSettings) ProtoMessage()

func (*VolumeSettings) Reset

func (m *VolumeSettings) Reset()

func (*VolumeSettings) String

func (m *VolumeSettings) String() string

func (*VolumeSettings) XXX_DiscardUnknown

func (m *VolumeSettings) XXX_DiscardUnknown()

func (*VolumeSettings) XXX_Marshal

func (m *VolumeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VolumeSettings) XXX_Merge

func (m *VolumeSettings) XXX_Merge(src proto.Message)

func (*VolumeSettings) XXX_Size

func (m *VolumeSettings) XXX_Size() int

func (*VolumeSettings) XXX_Unmarshal

func (m *VolumeSettings) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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