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 (m *ServiceObjectListResponse) GetInfo() map[string]*ServiceObjectInfo

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 

type ServiceServer interface {
	Serve(context.Context, *ServeRequest) (*ServeResponse, error)
	Unserve(context.Context, *ServeRequest) (*GenericResponse, error)
	SetParam(context.Context, *SetParamRequest) (*GenericResponse, error)
	ServiceList(context.Context, *ServiceListRequest) (*ServiceListResponse, error)
	ServiceObjectList(context.Context, *ServiceObjectListRequest) (*ServiceObjectListResponse, error)
}

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) Serve(ctx context.Context, req *ServeRequest) (*ServeResponse, error)

func (*UnimplementedServiceServer) ServiceList 

func (*UnimplementedServiceServer) ServiceList(ctx context.Context, req *ServiceListRequest) (*ServiceListResponse, error)

func (*UnimplementedServiceServer) ServiceObjectList 

func (*UnimplementedServiceServer) ServiceObjectList(ctx context.Context, req *ServiceObjectListRequest) (*ServiceObjectListResponse, error)

func (*UnimplementedServiceServer) SetParam 

func (*UnimplementedServiceServer) SetParam(ctx context.Context, req *SetParamRequest) (*GenericResponse, error)

func (*UnimplementedServiceServer) Unserve 

func (*UnimplementedServiceServer) Unserve(ctx context.Context, req *ServeRequest) (*GenericResponse, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.