gfspserver

package
v0.2.4-alpha.10 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2023 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApproval        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApproval          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupApproval = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthAuthenticator        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthenticator          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuthenticator = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDownload        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDownload          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDownload = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthManage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowManage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupManage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthP2P        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowP2P          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupP2P = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQueryTask        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryTask          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryTask = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRcmgr        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRcmgr          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRcmgr = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthReceive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReceive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReceive = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSign        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSign          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSign = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthUpload        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUpload          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupUpload = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterGfSpApprovalServiceServer 

func RegisterGfSpApprovalServiceServer(s grpc1.Server, srv GfSpApprovalServiceServer)

func RegisterGfSpAuthenticationServiceServer 

func RegisterGfSpAuthenticationServiceServer(s grpc1.Server, srv GfSpAuthenticationServiceServer)

func RegisterGfSpDownloadServiceServer 

func RegisterGfSpDownloadServiceServer(s grpc1.Server, srv GfSpDownloadServiceServer)

func RegisterGfSpManageServiceServer 

func RegisterGfSpManageServiceServer(s grpc1.Server, srv GfSpManageServiceServer)

func RegisterGfSpP2PServiceServer 

func RegisterGfSpP2PServiceServer(s grpc1.Server, srv GfSpP2PServiceServer)

func RegisterGfSpQueryTaskServiceServer 

func RegisterGfSpQueryTaskServiceServer(s grpc1.Server, srv GfSpQueryTaskServiceServer)

func RegisterGfSpReceiveServiceServer 

func RegisterGfSpReceiveServiceServer(s grpc1.Server, srv GfSpReceiveServiceServer)

func RegisterGfSpResourceServiceServer 

func RegisterGfSpResourceServiceServer(s grpc1.Server, srv GfSpResourceServiceServer)

func RegisterGfSpSignServiceServer 

func RegisterGfSpSignServiceServer(s grpc1.Server, srv GfSpSignServiceServer)

func RegisterGfSpUploadServiceServer 

func RegisterGfSpUploadServiceServer(s grpc1.Server, srv GfSpUploadServiceServer)

Types

type GetAuthNonceRequest 

type GetAuthNonceRequest struct {
	// account_id is the account address of user
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// domain is the DApp domain for this nonce
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
}

GetAuthNonceRequest is request type for the GetAuthNonce RPC method.

func (*GetAuthNonceRequest) Descriptor 

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

func (*GetAuthNonceRequest) GetAccountId 

func (m *GetAuthNonceRequest) GetAccountId() string

func (*GetAuthNonceRequest) GetDomain 

func (m *GetAuthNonceRequest) GetDomain() string

func (*GetAuthNonceRequest) Marshal 

func (m *GetAuthNonceRequest) Marshal() (dAtA []byte, err error)

func (*GetAuthNonceRequest) MarshalTo 

func (m *GetAuthNonceRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAuthNonceRequest) MarshalToSizedBuffer 

func (m *GetAuthNonceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAuthNonceRequest) ProtoMessage 

func (*GetAuthNonceRequest) ProtoMessage()

func (*GetAuthNonceRequest) Reset 

func (m *GetAuthNonceRequest) Reset()

func (*GetAuthNonceRequest) Size 

func (m *GetAuthNonceRequest) Size() (n int)

func (*GetAuthNonceRequest) String 

func (m *GetAuthNonceRequest) String() string

func (*GetAuthNonceRequest) Unmarshal 

func (m *GetAuthNonceRequest) Unmarshal(dAtA []byte) error

func (*GetAuthNonceRequest) XXX_DiscardUnknown 

func (m *GetAuthNonceRequest) XXX_DiscardUnknown()

func (*GetAuthNonceRequest) XXX_Marshal 

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

func (*GetAuthNonceRequest) XXX_Merge 

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

func (*GetAuthNonceRequest) XXX_Size 

func (m *GetAuthNonceRequest) XXX_Size() int

func (*GetAuthNonceRequest) XXX_Unmarshal 

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

type GetAuthNonceResponse 

type GetAuthNonceResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// current_nonce defines the current nonce value, which the current_public_key is tied to
	CurrentNonce int32 `protobuf:"varint,2,opt,name=current_nonce,json=currentNonce,proto3" json:"current_nonce,omitempty"`
	// next_nonce defines the next nonce value , for which the DApp or client can update their auth public key
	NextNonce int32 `protobuf:"varint,3,opt,name=next_nonce,json=nextNonce,proto3" json:"next_nonce,omitempty"`
	// current_public_key defines the current user EDDSA public key
	CurrentPublicKey string `protobuf:"bytes,4,opt,name=current_public_key,json=currentPublicKey,proto3" json:"current_public_key,omitempty"`
	// expiry_date is the expiry timestamp of the current public key
	ExpiryDate int64 `protobuf:"varint,5,opt,name=expiry_date,json=expiryDate,proto3" json:"expiry_date,omitempty"`
}

GetAuthNonceResponse is response type for the GetAuthNonce RPC method.

func (*GetAuthNonceResponse) Descriptor 

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

func (*GetAuthNonceResponse) GetCurrentNonce 

func (m *GetAuthNonceResponse) GetCurrentNonce() int32

func (*GetAuthNonceResponse) GetCurrentPublicKey 

func (m *GetAuthNonceResponse) GetCurrentPublicKey() string

func (*GetAuthNonceResponse) GetErr 

func (m *GetAuthNonceResponse) GetErr() *gfsperrors.GfSpError

func (*GetAuthNonceResponse) GetExpiryDate 

func (m *GetAuthNonceResponse) GetExpiryDate() int64

func (*GetAuthNonceResponse) GetNextNonce 

func (m *GetAuthNonceResponse) GetNextNonce() int32

func (*GetAuthNonceResponse) Marshal 

func (m *GetAuthNonceResponse) Marshal() (dAtA []byte, err error)

func (*GetAuthNonceResponse) MarshalTo 

func (m *GetAuthNonceResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAuthNonceResponse) MarshalToSizedBuffer 

func (m *GetAuthNonceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAuthNonceResponse) ProtoMessage 

func (*GetAuthNonceResponse) ProtoMessage()

func (*GetAuthNonceResponse) Reset 

func (m *GetAuthNonceResponse) Reset()

func (*GetAuthNonceResponse) Size 

func (m *GetAuthNonceResponse) Size() (n int)

func (*GetAuthNonceResponse) String 

func (m *GetAuthNonceResponse) String() string

func (*GetAuthNonceResponse) Unmarshal 

func (m *GetAuthNonceResponse) Unmarshal(dAtA []byte) error

func (*GetAuthNonceResponse) XXX_DiscardUnknown 

func (m *GetAuthNonceResponse) XXX_DiscardUnknown()

func (*GetAuthNonceResponse) XXX_Marshal 

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

func (*GetAuthNonceResponse) XXX_Merge 

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

func (*GetAuthNonceResponse) XXX_Size 

func (m *GetAuthNonceResponse) XXX_Size() int

func (*GetAuthNonceResponse) XXX_Unmarshal 

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

type GfSpApprovalServiceClient 

type GfSpApprovalServiceClient interface {
	GfSpAskApproval(ctx context.Context, in *GfSpAskApprovalRequest, opts ...grpc.CallOption) (*GfSpAskApprovalResponse, error)
}

GfSpApprovalServiceClient is the client API for GfSpApprovalService service.

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

func NewGfSpApprovalServiceClient 

func NewGfSpApprovalServiceClient(cc grpc1.ClientConn) GfSpApprovalServiceClient

type GfSpApprovalServiceServer 

type GfSpApprovalServiceServer interface {
	GfSpAskApproval(context.Context, *GfSpAskApprovalRequest) (*GfSpAskApprovalResponse, error)
}

GfSpApprovalServiceServer is the server API for GfSpApprovalService service.

type GfSpAskApprovalRequest 

type GfSpAskApprovalRequest struct {
	// Types that are valid to be assigned to Request:
	//	*GfSpAskApprovalRequest_CreateBucketApprovalTask
	//	*GfSpAskApprovalRequest_MigrateBucketApprovalTask
	//	*GfSpAskApprovalRequest_CreateObjectApprovalTask
	Request isGfSpAskApprovalRequest_Request `protobuf_oneof:"request"`
}

func (*GfSpAskApprovalRequest) Descriptor 

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

func (*GfSpAskApprovalRequest) GetCreateBucketApprovalTask 

func (m *GfSpAskApprovalRequest) GetCreateBucketApprovalTask() *gfsptask.GfSpCreateBucketApprovalTask

func (*GfSpAskApprovalRequest) GetCreateObjectApprovalTask 

func (m *GfSpAskApprovalRequest) GetCreateObjectApprovalTask() *gfsptask.GfSpCreateObjectApprovalTask

func (*GfSpAskApprovalRequest) GetMigrateBucketApprovalTask 

func (m *GfSpAskApprovalRequest) GetMigrateBucketApprovalTask() *gfsptask.GfSpMigrateBucketApprovalTask

func (*GfSpAskApprovalRequest) GetRequest 

func (m *GfSpAskApprovalRequest) GetRequest() isGfSpAskApprovalRequest_Request

func (*GfSpAskApprovalRequest) Marshal 

func (m *GfSpAskApprovalRequest) Marshal() (dAtA []byte, err error)

func (*GfSpAskApprovalRequest) MarshalTo 

func (m *GfSpAskApprovalRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest) MarshalToSizedBuffer 

func (m *GfSpAskApprovalRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest) ProtoMessage 

func (*GfSpAskApprovalRequest) ProtoMessage()

func (*GfSpAskApprovalRequest) Reset 

func (m *GfSpAskApprovalRequest) Reset()

func (*GfSpAskApprovalRequest) Size 

func (m *GfSpAskApprovalRequest) Size() (n int)

func (*GfSpAskApprovalRequest) String 

func (m *GfSpAskApprovalRequest) String() string

func (*GfSpAskApprovalRequest) Unmarshal 

func (m *GfSpAskApprovalRequest) Unmarshal(dAtA []byte) error

func (*GfSpAskApprovalRequest) XXX_DiscardUnknown 

func (m *GfSpAskApprovalRequest) XXX_DiscardUnknown()

func (*GfSpAskApprovalRequest) XXX_Marshal 

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

func (*GfSpAskApprovalRequest) XXX_Merge 

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

func (*GfSpAskApprovalRequest) XXX_OneofWrappers 

func (*GfSpAskApprovalRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpAskApprovalRequest) XXX_Size 

func (m *GfSpAskApprovalRequest) XXX_Size() int

func (*GfSpAskApprovalRequest) XXX_Unmarshal 

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

type GfSpAskApprovalRequest_CreateBucketApprovalTask 

type GfSpAskApprovalRequest_CreateBucketApprovalTask struct {
	CreateBucketApprovalTask *gfsptask.GfSpCreateBucketApprovalTask `` /* 143-byte string literal not displayed */
}

func (*GfSpAskApprovalRequest_CreateBucketApprovalTask) MarshalTo 

func (m *GfSpAskApprovalRequest_CreateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_CreateBucketApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalRequest_CreateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_CreateBucketApprovalTask) Size 

func (m *GfSpAskApprovalRequest_CreateBucketApprovalTask) Size() (n int)

type GfSpAskApprovalRequest_CreateObjectApprovalTask 

type GfSpAskApprovalRequest_CreateObjectApprovalTask struct {
	CreateObjectApprovalTask *gfsptask.GfSpCreateObjectApprovalTask `` /* 143-byte string literal not displayed */
}

func (*GfSpAskApprovalRequest_CreateObjectApprovalTask) MarshalTo 

func (m *GfSpAskApprovalRequest_CreateObjectApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_CreateObjectApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalRequest_CreateObjectApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_CreateObjectApprovalTask) Size 

func (m *GfSpAskApprovalRequest_CreateObjectApprovalTask) Size() (n int)

type GfSpAskApprovalRequest_MigrateBucketApprovalTask 

type GfSpAskApprovalRequest_MigrateBucketApprovalTask struct {
	MigrateBucketApprovalTask *gfsptask.GfSpMigrateBucketApprovalTask `` /* 146-byte string literal not displayed */
}

func (*GfSpAskApprovalRequest_MigrateBucketApprovalTask) MarshalTo 

func (m *GfSpAskApprovalRequest_MigrateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_MigrateBucketApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalRequest_MigrateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalRequest_MigrateBucketApprovalTask) Size 

func (m *GfSpAskApprovalRequest_MigrateBucketApprovalTask) Size() (n int)

type GfSpAskApprovalResponse 

type GfSpAskApprovalResponse struct {
	Err     *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Allowed bool                  `protobuf:"varint,2,opt,name=allowed,proto3" json:"allowed,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*GfSpAskApprovalResponse_CreateBucketApprovalTask
	//	*GfSpAskApprovalResponse_MigrateBucketApprovalTask
	//	*GfSpAskApprovalResponse_CreateObjectApprovalTask
	Response isGfSpAskApprovalResponse_Response `protobuf_oneof:"response"`
}

func (*GfSpAskApprovalResponse) Descriptor 

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

func (*GfSpAskApprovalResponse) GetAllowed 

func (m *GfSpAskApprovalResponse) GetAllowed() bool

func (*GfSpAskApprovalResponse) GetCreateBucketApprovalTask 

func (m *GfSpAskApprovalResponse) GetCreateBucketApprovalTask() *gfsptask.GfSpCreateBucketApprovalTask

func (*GfSpAskApprovalResponse) GetCreateObjectApprovalTask 

func (m *GfSpAskApprovalResponse) GetCreateObjectApprovalTask() *gfsptask.GfSpCreateObjectApprovalTask

func (*GfSpAskApprovalResponse) GetErr 

func (m *GfSpAskApprovalResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpAskApprovalResponse) GetMigrateBucketApprovalTask 

func (m *GfSpAskApprovalResponse) GetMigrateBucketApprovalTask() *gfsptask.GfSpMigrateBucketApprovalTask

func (*GfSpAskApprovalResponse) GetResponse 

func (m *GfSpAskApprovalResponse) GetResponse() isGfSpAskApprovalResponse_Response

func (*GfSpAskApprovalResponse) Marshal 

func (m *GfSpAskApprovalResponse) Marshal() (dAtA []byte, err error)

func (*GfSpAskApprovalResponse) MarshalTo 

func (m *GfSpAskApprovalResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse) MarshalToSizedBuffer 

func (m *GfSpAskApprovalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse) ProtoMessage 

func (*GfSpAskApprovalResponse) ProtoMessage()

func (*GfSpAskApprovalResponse) Reset 

func (m *GfSpAskApprovalResponse) Reset()

func (*GfSpAskApprovalResponse) Size 

func (m *GfSpAskApprovalResponse) Size() (n int)

func (*GfSpAskApprovalResponse) String 

func (m *GfSpAskApprovalResponse) String() string

func (*GfSpAskApprovalResponse) Unmarshal 

func (m *GfSpAskApprovalResponse) Unmarshal(dAtA []byte) error

func (*GfSpAskApprovalResponse) XXX_DiscardUnknown 

func (m *GfSpAskApprovalResponse) XXX_DiscardUnknown()

func (*GfSpAskApprovalResponse) XXX_Marshal 

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

func (*GfSpAskApprovalResponse) XXX_Merge 

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

func (*GfSpAskApprovalResponse) XXX_OneofWrappers 

func (*GfSpAskApprovalResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpAskApprovalResponse) XXX_Size 

func (m *GfSpAskApprovalResponse) XXX_Size() int

func (*GfSpAskApprovalResponse) XXX_Unmarshal 

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

type GfSpAskApprovalResponse_CreateBucketApprovalTask 

type GfSpAskApprovalResponse_CreateBucketApprovalTask struct {
	CreateBucketApprovalTask *gfsptask.GfSpCreateBucketApprovalTask `` /* 143-byte string literal not displayed */
}

func (*GfSpAskApprovalResponse_CreateBucketApprovalTask) MarshalTo 

func (m *GfSpAskApprovalResponse_CreateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_CreateBucketApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalResponse_CreateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_CreateBucketApprovalTask) Size 

func (m *GfSpAskApprovalResponse_CreateBucketApprovalTask) Size() (n int)

type GfSpAskApprovalResponse_CreateObjectApprovalTask 

type GfSpAskApprovalResponse_CreateObjectApprovalTask struct {
	CreateObjectApprovalTask *gfsptask.GfSpCreateObjectApprovalTask `` /* 143-byte string literal not displayed */
}

func (*GfSpAskApprovalResponse_CreateObjectApprovalTask) MarshalTo 

func (m *GfSpAskApprovalResponse_CreateObjectApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_CreateObjectApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalResponse_CreateObjectApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_CreateObjectApprovalTask) Size 

func (m *GfSpAskApprovalResponse_CreateObjectApprovalTask) Size() (n int)

type GfSpAskApprovalResponse_MigrateBucketApprovalTask 

type GfSpAskApprovalResponse_MigrateBucketApprovalTask struct {
	MigrateBucketApprovalTask *gfsptask.GfSpMigrateBucketApprovalTask `` /* 146-byte string literal not displayed */
}

func (*GfSpAskApprovalResponse_MigrateBucketApprovalTask) MarshalTo 

func (m *GfSpAskApprovalResponse_MigrateBucketApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_MigrateBucketApprovalTask) MarshalToSizedBuffer 

func (m *GfSpAskApprovalResponse_MigrateBucketApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskApprovalResponse_MigrateBucketApprovalTask) Size 

func (m *GfSpAskApprovalResponse_MigrateBucketApprovalTask) Size() (n int)

type GfSpAskSecondaryReplicatePieceApprovalRequest 

type GfSpAskSecondaryReplicatePieceApprovalRequest struct {
	ReplicatePieceApprovalTask *gfsptask.GfSpReplicatePieceApprovalTask `` /* 143-byte string literal not displayed */
	Min                        int32                                    `protobuf:"varint,2,opt,name=min,proto3" json:"min,omitempty"`
	Max                        int32                                    `protobuf:"varint,3,opt,name=max,proto3" json:"max,omitempty"`
	Timeout                    int64                                    `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) Descriptor 

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

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) GetMax 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) GetMax() int32

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) GetMin 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) GetMin() int32

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) GetReplicatePieceApprovalTask 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) GetReplicatePieceApprovalTask() *gfsptask.GfSpReplicatePieceApprovalTask

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) GetTimeout 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) GetTimeout() int64

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) Marshal 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) Marshal() (dAtA []byte, err error)

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) MarshalTo 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) MarshalToSizedBuffer 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) ProtoMessage 

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) ProtoMessage()

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) Reset 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) Reset()

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) Size 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) Size() (n int)

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) String 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) String() string

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) Unmarshal 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) Unmarshal(dAtA []byte) error

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_DiscardUnknown 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_DiscardUnknown()

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_Marshal 

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

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_Merge 

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

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_Size 

func (m *GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_Size() int

func (*GfSpAskSecondaryReplicatePieceApprovalRequest) XXX_Unmarshal 

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

type GfSpAskSecondaryReplicatePieceApprovalResponse 

type GfSpAskSecondaryReplicatePieceApprovalResponse struct {
	Err           *gfsperrors.GfSpError                      `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	ApprovedTasks []*gfsptask.GfSpReplicatePieceApprovalTask `protobuf:"bytes,2,rep,name=approved_tasks,json=approvedTasks,proto3" json:"approved_tasks,omitempty"`
}

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) Descriptor 

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

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) GetApprovedTasks 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) GetApprovedTasks() []*gfsptask.GfSpReplicatePieceApprovalTask

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) GetErr 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) Marshal 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) Marshal() (dAtA []byte, err error)

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) MarshalTo 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) MarshalToSizedBuffer 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) ProtoMessage 

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) ProtoMessage()

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) Reset 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) Reset()

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) Size 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) Size() (n int)

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) String 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) String() string

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) Unmarshal 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) Unmarshal(dAtA []byte) error

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_DiscardUnknown 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_DiscardUnknown()

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_Marshal 

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

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_Merge 

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

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_Size 

func (m *GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_Size() int

func (*GfSpAskSecondaryReplicatePieceApprovalResponse) XXX_Unmarshal 

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

type GfSpAskTaskRequest 

type GfSpAskTaskRequest struct {
	NodeLimit *gfsplimit.GfSpLimit `protobuf:"bytes,1,opt,name=node_limit,json=nodeLimit,proto3" json:"node_limit,omitempty"`
}

func (*GfSpAskTaskRequest) Descriptor 

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

func (*GfSpAskTaskRequest) GetNodeLimit 

func (m *GfSpAskTaskRequest) GetNodeLimit() *gfsplimit.GfSpLimit

func (*GfSpAskTaskRequest) Marshal 

func (m *GfSpAskTaskRequest) Marshal() (dAtA []byte, err error)

func (*GfSpAskTaskRequest) MarshalTo 

func (m *GfSpAskTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskRequest) MarshalToSizedBuffer 

func (m *GfSpAskTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskRequest) ProtoMessage 

func (*GfSpAskTaskRequest) ProtoMessage()

func (*GfSpAskTaskRequest) Reset 

func (m *GfSpAskTaskRequest) Reset()

func (*GfSpAskTaskRequest) Size 

func (m *GfSpAskTaskRequest) Size() (n int)

func (*GfSpAskTaskRequest) String 

func (m *GfSpAskTaskRequest) String() string

func (*GfSpAskTaskRequest) Unmarshal 

func (m *GfSpAskTaskRequest) Unmarshal(dAtA []byte) error

func (*GfSpAskTaskRequest) XXX_DiscardUnknown 

func (m *GfSpAskTaskRequest) XXX_DiscardUnknown()

func (*GfSpAskTaskRequest) XXX_Marshal 

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

func (*GfSpAskTaskRequest) XXX_Merge 

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

func (*GfSpAskTaskRequest) XXX_Size 

func (m *GfSpAskTaskRequest) XXX_Size() int

func (*GfSpAskTaskRequest) XXX_Unmarshal 

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

type GfSpAskTaskResponse 

type GfSpAskTaskResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*GfSpAskTaskResponse_ReplicatePieceTask
	//	*GfSpAskTaskResponse_SealObjectTask
	//	*GfSpAskTaskResponse_ReceivePieceTask
	//	*GfSpAskTaskResponse_GcObjectTask
	//	*GfSpAskTaskResponse_GcZombiePieceTask
	//	*GfSpAskTaskResponse_GcMetaTask
	//	*GfSpAskTaskResponse_RecoverPieceTask
	//	*GfSpAskTaskResponse_MigrateGvgTask
	Response isGfSpAskTaskResponse_Response `protobuf_oneof:"response"`
}

func (*GfSpAskTaskResponse) Descriptor 

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

func (*GfSpAskTaskResponse) GetErr 

func (m *GfSpAskTaskResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpAskTaskResponse) GetGcMetaTask 

func (m *GfSpAskTaskResponse) GetGcMetaTask() *gfsptask.GfSpGCMetaTask

func (*GfSpAskTaskResponse) GetGcObjectTask 

func (m *GfSpAskTaskResponse) GetGcObjectTask() *gfsptask.GfSpGCObjectTask

func (*GfSpAskTaskResponse) GetGcZombiePieceTask 

func (m *GfSpAskTaskResponse) GetGcZombiePieceTask() *gfsptask.GfSpGCZombiePieceTask

func (*GfSpAskTaskResponse) GetMigrateGvgTask 

func (m *GfSpAskTaskResponse) GetMigrateGvgTask() *gfsptask.GfSpMigrateGVGTask

func (*GfSpAskTaskResponse) GetReceivePieceTask 

func (m *GfSpAskTaskResponse) GetReceivePieceTask() *gfsptask.GfSpReceivePieceTask

func (*GfSpAskTaskResponse) GetRecoverPieceTask 

func (m *GfSpAskTaskResponse) GetRecoverPieceTask() *gfsptask.GfSpRecoverPieceTask

func (*GfSpAskTaskResponse) GetReplicatePieceTask 

func (m *GfSpAskTaskResponse) GetReplicatePieceTask() *gfsptask.GfSpReplicatePieceTask

func (*GfSpAskTaskResponse) GetResponse 

func (m *GfSpAskTaskResponse) GetResponse() isGfSpAskTaskResponse_Response

func (*GfSpAskTaskResponse) GetSealObjectTask 

func (m *GfSpAskTaskResponse) GetSealObjectTask() *gfsptask.GfSpSealObjectTask

func (*GfSpAskTaskResponse) Marshal 

func (m *GfSpAskTaskResponse) Marshal() (dAtA []byte, err error)

func (*GfSpAskTaskResponse) MarshalTo 

func (m *GfSpAskTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse) ProtoMessage 

func (*GfSpAskTaskResponse) ProtoMessage()

func (*GfSpAskTaskResponse) Reset 

func (m *GfSpAskTaskResponse) Reset()

func (*GfSpAskTaskResponse) Size 

func (m *GfSpAskTaskResponse) Size() (n int)

func (*GfSpAskTaskResponse) String 

func (m *GfSpAskTaskResponse) String() string

func (*GfSpAskTaskResponse) Unmarshal 

func (m *GfSpAskTaskResponse) Unmarshal(dAtA []byte) error

func (*GfSpAskTaskResponse) XXX_DiscardUnknown 

func (m *GfSpAskTaskResponse) XXX_DiscardUnknown()

func (*GfSpAskTaskResponse) XXX_Marshal 

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

func (*GfSpAskTaskResponse) XXX_Merge 

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

func (*GfSpAskTaskResponse) XXX_OneofWrappers 

func (*GfSpAskTaskResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpAskTaskResponse) XXX_Size 

func (m *GfSpAskTaskResponse) XXX_Size() int

func (*GfSpAskTaskResponse) XXX_Unmarshal 

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

type GfSpAskTaskResponse_GcMetaTask 

type GfSpAskTaskResponse_GcMetaTask struct {
	GcMetaTask *gfsptask.GfSpGCMetaTask `protobuf:"bytes,7,opt,name=gc_meta_task,json=gcMetaTask,proto3,oneof" json:"gc_meta_task,omitempty"`
}

func (*GfSpAskTaskResponse_GcMetaTask) MarshalTo 

func (m *GfSpAskTaskResponse_GcMetaTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcMetaTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_GcMetaTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcMetaTask) Size 

func (m *GfSpAskTaskResponse_GcMetaTask) Size() (n int)

type GfSpAskTaskResponse_GcObjectTask 

type GfSpAskTaskResponse_GcObjectTask struct {
	GcObjectTask *gfsptask.GfSpGCObjectTask `protobuf:"bytes,5,opt,name=gc_object_task,json=gcObjectTask,proto3,oneof" json:"gc_object_task,omitempty"`
}

func (*GfSpAskTaskResponse_GcObjectTask) MarshalTo 

func (m *GfSpAskTaskResponse_GcObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcObjectTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_GcObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcObjectTask) Size 

func (m *GfSpAskTaskResponse_GcObjectTask) Size() (n int)

type GfSpAskTaskResponse_GcZombiePieceTask 

type GfSpAskTaskResponse_GcZombiePieceTask struct {
	GcZombiePieceTask *gfsptask.GfSpGCZombiePieceTask `protobuf:"bytes,6,opt,name=gc_zombie_piece_task,json=gcZombiePieceTask,proto3,oneof" json:"gc_zombie_piece_task,omitempty"`
}

func (*GfSpAskTaskResponse_GcZombiePieceTask) MarshalTo 

func (m *GfSpAskTaskResponse_GcZombiePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcZombiePieceTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_GcZombiePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_GcZombiePieceTask) Size 

func (m *GfSpAskTaskResponse_GcZombiePieceTask) Size() (n int)

type GfSpAskTaskResponse_MigrateGvgTask 

type GfSpAskTaskResponse_MigrateGvgTask struct {
	MigrateGvgTask *gfsptask.GfSpMigrateGVGTask `protobuf:"bytes,9,opt,name=migrate_gvg_task,json=migrateGvgTask,proto3,oneof" json:"migrate_gvg_task,omitempty"`
}

func (*GfSpAskTaskResponse_MigrateGvgTask) MarshalTo 

func (m *GfSpAskTaskResponse_MigrateGvgTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_MigrateGvgTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_MigrateGvgTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_MigrateGvgTask) Size 

func (m *GfSpAskTaskResponse_MigrateGvgTask) Size() (n int)

type GfSpAskTaskResponse_ReceivePieceTask 

type GfSpAskTaskResponse_ReceivePieceTask struct {
	ReceivePieceTask *gfsptask.GfSpReceivePieceTask `protobuf:"bytes,4,opt,name=receive_piece_task,json=receivePieceTask,proto3,oneof" json:"receive_piece_task,omitempty"`
}

func (*GfSpAskTaskResponse_ReceivePieceTask) MarshalTo 

func (m *GfSpAskTaskResponse_ReceivePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_ReceivePieceTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_ReceivePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_ReceivePieceTask) Size 

func (m *GfSpAskTaskResponse_ReceivePieceTask) Size() (n int)

type GfSpAskTaskResponse_RecoverPieceTask 

type GfSpAskTaskResponse_RecoverPieceTask struct {
	RecoverPieceTask *gfsptask.GfSpRecoverPieceTask `protobuf:"bytes,8,opt,name=recover_piece_task,json=recoverPieceTask,proto3,oneof" json:"recover_piece_task,omitempty"`
}

func (*GfSpAskTaskResponse_RecoverPieceTask) MarshalTo 

func (m *GfSpAskTaskResponse_RecoverPieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_RecoverPieceTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_RecoverPieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_RecoverPieceTask) Size 

func (m *GfSpAskTaskResponse_RecoverPieceTask) Size() (n int)

type GfSpAskTaskResponse_ReplicatePieceTask 

type GfSpAskTaskResponse_ReplicatePieceTask struct {
	ReplicatePieceTask *gfsptask.GfSpReplicatePieceTask `protobuf:"bytes,2,opt,name=replicate_piece_task,json=replicatePieceTask,proto3,oneof" json:"replicate_piece_task,omitempty"`
}

func (*GfSpAskTaskResponse_ReplicatePieceTask) MarshalTo 

func (m *GfSpAskTaskResponse_ReplicatePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_ReplicatePieceTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_ReplicatePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_ReplicatePieceTask) Size 

func (m *GfSpAskTaskResponse_ReplicatePieceTask) Size() (n int)

type GfSpAskTaskResponse_SealObjectTask 

type GfSpAskTaskResponse_SealObjectTask struct {
	SealObjectTask *gfsptask.GfSpSealObjectTask `protobuf:"bytes,3,opt,name=seal_object_task,json=sealObjectTask,proto3,oneof" json:"seal_object_task,omitempty"`
}

func (*GfSpAskTaskResponse_SealObjectTask) MarshalTo 

func (m *GfSpAskTaskResponse_SealObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_SealObjectTask) MarshalToSizedBuffer 

func (m *GfSpAskTaskResponse_SealObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAskTaskResponse_SealObjectTask) Size 

func (m *GfSpAskTaskResponse_SealObjectTask) Size() (n int)

type GfSpAuthenticationRequest 

type GfSpAuthenticationRequest struct {
	AuthType    int32  `protobuf:"varint,1,opt,name=auth_type,json=authType,proto3" json:"auth_type,omitempty"`
	UserAccount string `protobuf:"bytes,2,opt,name=user_account,json=userAccount,proto3" json:"user_account,omitempty"`
	BucketName  string `protobuf:"bytes,3,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	ObjectName  string `protobuf:"bytes,4,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
}

func (*GfSpAuthenticationRequest) Descriptor 

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

func (*GfSpAuthenticationRequest) GetAuthType 

func (m *GfSpAuthenticationRequest) GetAuthType() int32

func (*GfSpAuthenticationRequest) GetBucketName 

func (m *GfSpAuthenticationRequest) GetBucketName() string

func (*GfSpAuthenticationRequest) GetObjectName 

func (m *GfSpAuthenticationRequest) GetObjectName() string

func (*GfSpAuthenticationRequest) GetUserAccount 

func (m *GfSpAuthenticationRequest) GetUserAccount() string

func (*GfSpAuthenticationRequest) Marshal 

func (m *GfSpAuthenticationRequest) Marshal() (dAtA []byte, err error)

func (*GfSpAuthenticationRequest) MarshalTo 

func (m *GfSpAuthenticationRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAuthenticationRequest) MarshalToSizedBuffer 

func (m *GfSpAuthenticationRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAuthenticationRequest) ProtoMessage 

func (*GfSpAuthenticationRequest) ProtoMessage()

func (*GfSpAuthenticationRequest) Reset 

func (m *GfSpAuthenticationRequest) Reset()

func (*GfSpAuthenticationRequest) Size 

func (m *GfSpAuthenticationRequest) Size() (n int)

func (*GfSpAuthenticationRequest) String 

func (m *GfSpAuthenticationRequest) String() string

func (*GfSpAuthenticationRequest) Unmarshal 

func (m *GfSpAuthenticationRequest) Unmarshal(dAtA []byte) error

func (*GfSpAuthenticationRequest) XXX_DiscardUnknown 

func (m *GfSpAuthenticationRequest) XXX_DiscardUnknown()

func (*GfSpAuthenticationRequest) XXX_Marshal 

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

func (*GfSpAuthenticationRequest) XXX_Merge 

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

func (*GfSpAuthenticationRequest) XXX_Size 

func (m *GfSpAuthenticationRequest) XXX_Size() int

func (*GfSpAuthenticationRequest) XXX_Unmarshal 

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

type GfSpAuthenticationResponse 

type GfSpAuthenticationResponse struct {
	Err     *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Allowed bool                  `protobuf:"varint,2,opt,name=allowed,proto3" json:"allowed,omitempty"`
}

func (*GfSpAuthenticationResponse) Descriptor 

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

func (*GfSpAuthenticationResponse) GetAllowed 

func (m *GfSpAuthenticationResponse) GetAllowed() bool

func (*GfSpAuthenticationResponse) GetErr 

func (m *GfSpAuthenticationResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpAuthenticationResponse) Marshal 

func (m *GfSpAuthenticationResponse) Marshal() (dAtA []byte, err error)

func (*GfSpAuthenticationResponse) MarshalTo 

func (m *GfSpAuthenticationResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpAuthenticationResponse) MarshalToSizedBuffer 

func (m *GfSpAuthenticationResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpAuthenticationResponse) ProtoMessage 

func (*GfSpAuthenticationResponse) ProtoMessage()

func (*GfSpAuthenticationResponse) Reset 

func (m *GfSpAuthenticationResponse) Reset()

func (*GfSpAuthenticationResponse) Size 

func (m *GfSpAuthenticationResponse) Size() (n int)

func (*GfSpAuthenticationResponse) String 

func (m *GfSpAuthenticationResponse) String() string

func (*GfSpAuthenticationResponse) Unmarshal 

func (m *GfSpAuthenticationResponse) Unmarshal(dAtA []byte) error

func (*GfSpAuthenticationResponse) XXX_DiscardUnknown 

func (m *GfSpAuthenticationResponse) XXX_DiscardUnknown()

func (*GfSpAuthenticationResponse) XXX_Marshal 

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

func (*GfSpAuthenticationResponse) XXX_Merge 

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

func (*GfSpAuthenticationResponse) XXX_Size 

func (m *GfSpAuthenticationResponse) XXX_Size() int

func (*GfSpAuthenticationResponse) XXX_Unmarshal 

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

type GfSpAuthenticationServiceClient 

type GfSpAuthenticationServiceClient interface {
	GfSpVerifyAuthentication(ctx context.Context, in *GfSpAuthenticationRequest, opts ...grpc.CallOption) (*GfSpAuthenticationResponse, error)
	// GetAuthNonce get the auth nonce for which the Dapp or client can generate EDDSA key pairs.
	GetAuthNonce(ctx context.Context, in *GetAuthNonceRequest, opts ...grpc.CallOption) (*GetAuthNonceResponse, error)
	// UpdateUserPublicKey updates the user public key once the Dapp or client generates the EDDSA key pairs.
	UpdateUserPublicKey(ctx context.Context, in *UpdateUserPublicKeyRequest, opts ...grpc.CallOption) (*UpdateUserPublicKeyResponse, error)
	// VerifyGNFD1EddsaSignature verifies the signature signed by user's EDDSA private key.
	VerifyGNFD1EddsaSignature(ctx context.Context, in *VerifyGNFD1EddsaSignatureRequest, opts ...grpc.CallOption) (*VerifyGNFD1EddsaSignatureResponse, error)
}

GfSpAuthenticationServiceClient is the client API for GfSpAuthenticationService service.

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

func NewGfSpAuthenticationServiceClient 

func NewGfSpAuthenticationServiceClient(cc grpc1.ClientConn) GfSpAuthenticationServiceClient

type GfSpAuthenticationServiceServer 

type GfSpAuthenticationServiceServer interface {
	GfSpVerifyAuthentication(context.Context, *GfSpAuthenticationRequest) (*GfSpAuthenticationResponse, error)
	// GetAuthNonce get the auth nonce for which the Dapp or client can generate EDDSA key pairs.
	GetAuthNonce(context.Context, *GetAuthNonceRequest) (*GetAuthNonceResponse, error)
	// UpdateUserPublicKey updates the user public key once the Dapp or client generates the EDDSA key pairs.
	UpdateUserPublicKey(context.Context, *UpdateUserPublicKeyRequest) (*UpdateUserPublicKeyResponse, error)
	// VerifyGNFD1EddsaSignature verifies the signature signed by user's EDDSA private key.
	VerifyGNFD1EddsaSignature(context.Context, *VerifyGNFD1EddsaSignatureRequest) (*VerifyGNFD1EddsaSignatureResponse, error)
}

GfSpAuthenticationServiceServer is the server API for GfSpAuthenticationService service.

type GfSpBeginTaskRequest 

type GfSpBeginTaskRequest struct {
	// Types that are valid to be assigned to Request:
	//	*GfSpBeginTaskRequest_UploadObjectTask
	//	*GfSpBeginTaskRequest_ResumableUploadObjectTask
	Request isGfSpBeginTaskRequest_Request `protobuf_oneof:"request"`
}

func (*GfSpBeginTaskRequest) Descriptor 

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

func (*GfSpBeginTaskRequest) GetRequest 

func (m *GfSpBeginTaskRequest) GetRequest() isGfSpBeginTaskRequest_Request

func (*GfSpBeginTaskRequest) GetResumableUploadObjectTask 

func (m *GfSpBeginTaskRequest) GetResumableUploadObjectTask() *gfsptask.GfSpResumableUploadObjectTask

func (*GfSpBeginTaskRequest) GetUploadObjectTask 

func (m *GfSpBeginTaskRequest) GetUploadObjectTask() *gfsptask.GfSpUploadObjectTask

func (*GfSpBeginTaskRequest) Marshal 

func (m *GfSpBeginTaskRequest) Marshal() (dAtA []byte, err error)

func (*GfSpBeginTaskRequest) MarshalTo 

func (m *GfSpBeginTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest) MarshalToSizedBuffer 

func (m *GfSpBeginTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest) ProtoMessage 

func (*GfSpBeginTaskRequest) ProtoMessage()

func (*GfSpBeginTaskRequest) Reset 

func (m *GfSpBeginTaskRequest) Reset()

func (*GfSpBeginTaskRequest) Size 

func (m *GfSpBeginTaskRequest) Size() (n int)

func (*GfSpBeginTaskRequest) String 

func (m *GfSpBeginTaskRequest) String() string

func (*GfSpBeginTaskRequest) Unmarshal 

func (m *GfSpBeginTaskRequest) Unmarshal(dAtA []byte) error

func (*GfSpBeginTaskRequest) XXX_DiscardUnknown 

func (m *GfSpBeginTaskRequest) XXX_DiscardUnknown()

func (*GfSpBeginTaskRequest) XXX_Marshal 

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

func (*GfSpBeginTaskRequest) XXX_Merge 

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

func (*GfSpBeginTaskRequest) XXX_OneofWrappers 

func (*GfSpBeginTaskRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpBeginTaskRequest) XXX_Size 

func (m *GfSpBeginTaskRequest) XXX_Size() int

func (*GfSpBeginTaskRequest) XXX_Unmarshal 

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

type GfSpBeginTaskRequest_ResumableUploadObjectTask 

type GfSpBeginTaskRequest_ResumableUploadObjectTask struct {
	ResumableUploadObjectTask *gfsptask.GfSpResumableUploadObjectTask `` /* 146-byte string literal not displayed */
}

func (*GfSpBeginTaskRequest_ResumableUploadObjectTask) MarshalTo 

func (m *GfSpBeginTaskRequest_ResumableUploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest_ResumableUploadObjectTask) MarshalToSizedBuffer 

func (m *GfSpBeginTaskRequest_ResumableUploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest_ResumableUploadObjectTask) Size 

func (m *GfSpBeginTaskRequest_ResumableUploadObjectTask) Size() (n int)

type GfSpBeginTaskRequest_UploadObjectTask 

type GfSpBeginTaskRequest_UploadObjectTask struct {
	UploadObjectTask *gfsptask.GfSpUploadObjectTask `protobuf:"bytes,1,opt,name=upload_object_task,json=uploadObjectTask,proto3,oneof" json:"upload_object_task,omitempty"`
}

func (*GfSpBeginTaskRequest_UploadObjectTask) MarshalTo 

func (m *GfSpBeginTaskRequest_UploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest_UploadObjectTask) MarshalToSizedBuffer 

func (m *GfSpBeginTaskRequest_UploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBeginTaskRequest_UploadObjectTask) Size 

func (m *GfSpBeginTaskRequest_UploadObjectTask) Size() (n int)

type GfSpBeginTaskResponse 

type GfSpBeginTaskResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpBeginTaskResponse) Descriptor 

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

func (*GfSpBeginTaskResponse) GetErr 

func (m *GfSpBeginTaskResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpBeginTaskResponse) Marshal 

func (m *GfSpBeginTaskResponse) Marshal() (dAtA []byte, err error)

func (*GfSpBeginTaskResponse) MarshalTo 

func (m *GfSpBeginTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBeginTaskResponse) MarshalToSizedBuffer 

func (m *GfSpBeginTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBeginTaskResponse) ProtoMessage 

func (*GfSpBeginTaskResponse) ProtoMessage()

func (*GfSpBeginTaskResponse) Reset 

func (m *GfSpBeginTaskResponse) Reset()

func (*GfSpBeginTaskResponse) Size 

func (m *GfSpBeginTaskResponse) Size() (n int)

func (*GfSpBeginTaskResponse) String 

func (m *GfSpBeginTaskResponse) String() string

func (*GfSpBeginTaskResponse) Unmarshal 

func (m *GfSpBeginTaskResponse) Unmarshal(dAtA []byte) error

func (*GfSpBeginTaskResponse) XXX_DiscardUnknown 

func (m *GfSpBeginTaskResponse) XXX_DiscardUnknown()

func (*GfSpBeginTaskResponse) XXX_Marshal 

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

func (*GfSpBeginTaskResponse) XXX_Merge 

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

func (*GfSpBeginTaskResponse) XXX_Size 

func (m *GfSpBeginTaskResponse) XXX_Size() int

func (*GfSpBeginTaskResponse) XXX_Unmarshal 

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

type GfSpBucketMigrate 

type GfSpBucketMigrate struct {
	BucketName string            `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	BucketId   uint64            `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	Finished   uint32            `protobuf:"varint,3,opt,name=finished,proto3" json:"finished,omitempty"`
	GvgTask    []*GfSpMigrateGVG `protobuf:"bytes,4,rep,name=gvg_task,json=gvgTask,proto3" json:"gvg_task,omitempty"`
}

func (*GfSpBucketMigrate) Descriptor 

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

func (*GfSpBucketMigrate) GetBucketId 

func (m *GfSpBucketMigrate) GetBucketId() uint64

func (*GfSpBucketMigrate) GetBucketName 

func (m *GfSpBucketMigrate) GetBucketName() string

func (*GfSpBucketMigrate) GetFinished 

func (m *GfSpBucketMigrate) GetFinished() uint32

func (*GfSpBucketMigrate) GetGvgTask 

func (m *GfSpBucketMigrate) GetGvgTask() []*GfSpMigrateGVG

func (*GfSpBucketMigrate) Marshal 

func (m *GfSpBucketMigrate) Marshal() (dAtA []byte, err error)

func (*GfSpBucketMigrate) MarshalTo 

func (m *GfSpBucketMigrate) MarshalTo(dAtA []byte) (int, error)

func (*GfSpBucketMigrate) MarshalToSizedBuffer 

func (m *GfSpBucketMigrate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpBucketMigrate) ProtoMessage 

func (*GfSpBucketMigrate) ProtoMessage()

func (*GfSpBucketMigrate) Reset 

func (m *GfSpBucketMigrate) Reset()

func (*GfSpBucketMigrate) Size 

func (m *GfSpBucketMigrate) Size() (n int)

func (*GfSpBucketMigrate) String 

func (m *GfSpBucketMigrate) String() string

func (*GfSpBucketMigrate) Unmarshal 

func (m *GfSpBucketMigrate) Unmarshal(dAtA []byte) error

func (*GfSpBucketMigrate) XXX_DiscardUnknown 

func (m *GfSpBucketMigrate) XXX_DiscardUnknown()

func (*GfSpBucketMigrate) XXX_Marshal 

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

func (*GfSpBucketMigrate) XXX_Merge 

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

func (*GfSpBucketMigrate) XXX_Size 

func (m *GfSpBucketMigrate) XXX_Size() int

func (*GfSpBucketMigrate) XXX_Unmarshal 

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

type GfSpCreateGlobalVirtualGroup 

type GfSpCreateGlobalVirtualGroup struct {
	VirtualGroupFamilyId uint32      `` /* 126-byte string literal not displayed */
	PrimarySpAddress     string      `protobuf:"bytes,2,opt,name=primary_sp_address,json=primarySpAddress,proto3" json:"primary_sp_address,omitempty"`
	SecondarySpIds       []uint32    `protobuf:"varint,3,rep,packed,name=secondary_sp_ids,json=secondarySpIds,proto3" json:"secondary_sp_ids,omitempty"`
	Deposit              *types.Coin `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit,omitempty"`
}

TODO: use chain MsgCreateGlobalVirtualGroup replace it.

func (*GfSpCreateGlobalVirtualGroup) Descriptor 

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

func (*GfSpCreateGlobalVirtualGroup) GetDeposit 

func (m *GfSpCreateGlobalVirtualGroup) GetDeposit() *types.Coin

func (*GfSpCreateGlobalVirtualGroup) GetPrimarySpAddress 

func (m *GfSpCreateGlobalVirtualGroup) GetPrimarySpAddress() string

func (*GfSpCreateGlobalVirtualGroup) GetSecondarySpIds 

func (m *GfSpCreateGlobalVirtualGroup) GetSecondarySpIds() []uint32

func (*GfSpCreateGlobalVirtualGroup) GetVirtualGroupFamilyId 

func (m *GfSpCreateGlobalVirtualGroup) GetVirtualGroupFamilyId() uint32

func (*GfSpCreateGlobalVirtualGroup) Marshal 

func (m *GfSpCreateGlobalVirtualGroup) Marshal() (dAtA []byte, err error)

func (*GfSpCreateGlobalVirtualGroup) MarshalTo 

func (m *GfSpCreateGlobalVirtualGroup) MarshalTo(dAtA []byte) (int, error)

func (*GfSpCreateGlobalVirtualGroup) MarshalToSizedBuffer 

func (m *GfSpCreateGlobalVirtualGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpCreateGlobalVirtualGroup) ProtoMessage 

func (*GfSpCreateGlobalVirtualGroup) ProtoMessage()

func (*GfSpCreateGlobalVirtualGroup) Reset 

func (m *GfSpCreateGlobalVirtualGroup) Reset()

func (*GfSpCreateGlobalVirtualGroup) Size 

func (m *GfSpCreateGlobalVirtualGroup) Size() (n int)

func (*GfSpCreateGlobalVirtualGroup) String 

func (m *GfSpCreateGlobalVirtualGroup) String() string

func (*GfSpCreateGlobalVirtualGroup) Unmarshal 

func (m *GfSpCreateGlobalVirtualGroup) Unmarshal(dAtA []byte) error

func (*GfSpCreateGlobalVirtualGroup) XXX_DiscardUnknown 

func (m *GfSpCreateGlobalVirtualGroup) XXX_DiscardUnknown()

func (*GfSpCreateGlobalVirtualGroup) XXX_Marshal 

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

func (*GfSpCreateGlobalVirtualGroup) XXX_Merge 

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

func (*GfSpCreateGlobalVirtualGroup) XXX_Size 

func (m *GfSpCreateGlobalVirtualGroup) XXX_Size() int

func (*GfSpCreateGlobalVirtualGroup) XXX_Unmarshal 

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

type GfSpDoneReplicatePieceRequest 

type GfSpDoneReplicatePieceRequest struct {
	ReceivePieceTask *gfsptask.GfSpReceivePieceTask `protobuf:"bytes,1,opt,name=receive_piece_task,json=receivePieceTask,proto3" json:"receive_piece_task,omitempty"`
}

func (*GfSpDoneReplicatePieceRequest) Descriptor 

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

func (*GfSpDoneReplicatePieceRequest) GetReceivePieceTask 

func (m *GfSpDoneReplicatePieceRequest) GetReceivePieceTask() *gfsptask.GfSpReceivePieceTask

func (*GfSpDoneReplicatePieceRequest) Marshal 

func (m *GfSpDoneReplicatePieceRequest) Marshal() (dAtA []byte, err error)

func (*GfSpDoneReplicatePieceRequest) MarshalTo 

func (m *GfSpDoneReplicatePieceRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDoneReplicatePieceRequest) MarshalToSizedBuffer 

func (m *GfSpDoneReplicatePieceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDoneReplicatePieceRequest) ProtoMessage 

func (*GfSpDoneReplicatePieceRequest) ProtoMessage()

func (*GfSpDoneReplicatePieceRequest) Reset 

func (m *GfSpDoneReplicatePieceRequest) Reset()

func (*GfSpDoneReplicatePieceRequest) Size 

func (m *GfSpDoneReplicatePieceRequest) Size() (n int)

func (*GfSpDoneReplicatePieceRequest) String 

func (m *GfSpDoneReplicatePieceRequest) String() string

func (*GfSpDoneReplicatePieceRequest) Unmarshal 

func (m *GfSpDoneReplicatePieceRequest) Unmarshal(dAtA []byte) error

func (*GfSpDoneReplicatePieceRequest) XXX_DiscardUnknown 

func (m *GfSpDoneReplicatePieceRequest) XXX_DiscardUnknown()

func (*GfSpDoneReplicatePieceRequest) XXX_Marshal 

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

func (*GfSpDoneReplicatePieceRequest) XXX_Merge 

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

func (*GfSpDoneReplicatePieceRequest) XXX_Size 

func (m *GfSpDoneReplicatePieceRequest) XXX_Size() int

func (*GfSpDoneReplicatePieceRequest) XXX_Unmarshal 

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

type GfSpDoneReplicatePieceResponse 

type GfSpDoneReplicatePieceResponse struct {
	Err           *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	IntegrityHash []byte                `protobuf:"bytes,2,opt,name=integrity_hash,json=integrityHash,proto3" json:"integrity_hash,omitempty"`
	Signature     []byte                `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
}

func (*GfSpDoneReplicatePieceResponse) Descriptor 

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

func (*GfSpDoneReplicatePieceResponse) GetErr 

func (m *GfSpDoneReplicatePieceResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpDoneReplicatePieceResponse) GetIntegrityHash 

func (m *GfSpDoneReplicatePieceResponse) GetIntegrityHash() []byte

func (*GfSpDoneReplicatePieceResponse) GetSignature 

func (m *GfSpDoneReplicatePieceResponse) GetSignature() []byte

func (*GfSpDoneReplicatePieceResponse) Marshal 

func (m *GfSpDoneReplicatePieceResponse) Marshal() (dAtA []byte, err error)

func (*GfSpDoneReplicatePieceResponse) MarshalTo 

func (m *GfSpDoneReplicatePieceResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDoneReplicatePieceResponse) MarshalToSizedBuffer 

func (m *GfSpDoneReplicatePieceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDoneReplicatePieceResponse) ProtoMessage 

func (*GfSpDoneReplicatePieceResponse) ProtoMessage()

func (*GfSpDoneReplicatePieceResponse) Reset 

func (m *GfSpDoneReplicatePieceResponse) Reset()

func (*GfSpDoneReplicatePieceResponse) Size 

func (m *GfSpDoneReplicatePieceResponse) Size() (n int)

func (*GfSpDoneReplicatePieceResponse) String 

func (m *GfSpDoneReplicatePieceResponse) String() string

func (*GfSpDoneReplicatePieceResponse) Unmarshal 

func (m *GfSpDoneReplicatePieceResponse) Unmarshal(dAtA []byte) error

func (*GfSpDoneReplicatePieceResponse) XXX_DiscardUnknown 

func (m *GfSpDoneReplicatePieceResponse) XXX_DiscardUnknown()

func (*GfSpDoneReplicatePieceResponse) XXX_Marshal 

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

func (*GfSpDoneReplicatePieceResponse) XXX_Merge 

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

func (*GfSpDoneReplicatePieceResponse) XXX_Size 

func (m *GfSpDoneReplicatePieceResponse) XXX_Size() int

func (*GfSpDoneReplicatePieceResponse) XXX_Unmarshal 

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

type GfSpDownloadObjectRequest 

type GfSpDownloadObjectRequest struct {
	DownloadObjectTask *gfsptask.GfSpDownloadObjectTask `protobuf:"bytes,1,opt,name=download_object_task,json=downloadObjectTask,proto3" json:"download_object_task,omitempty"`
}

func (*GfSpDownloadObjectRequest) Descriptor 

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

func (*GfSpDownloadObjectRequest) GetDownloadObjectTask 

func (m *GfSpDownloadObjectRequest) GetDownloadObjectTask() *gfsptask.GfSpDownloadObjectTask

func (*GfSpDownloadObjectRequest) Marshal 

func (m *GfSpDownloadObjectRequest) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadObjectRequest) MarshalTo 

func (m *GfSpDownloadObjectRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadObjectRequest) MarshalToSizedBuffer 

func (m *GfSpDownloadObjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadObjectRequest) ProtoMessage 

func (*GfSpDownloadObjectRequest) ProtoMessage()

func (*GfSpDownloadObjectRequest) Reset 

func (m *GfSpDownloadObjectRequest) Reset()

func (*GfSpDownloadObjectRequest) Size 

func (m *GfSpDownloadObjectRequest) Size() (n int)

func (*GfSpDownloadObjectRequest) String 

func (m *GfSpDownloadObjectRequest) String() string

func (*GfSpDownloadObjectRequest) Unmarshal 

func (m *GfSpDownloadObjectRequest) Unmarshal(dAtA []byte) error

func (*GfSpDownloadObjectRequest) XXX_DiscardUnknown 

func (m *GfSpDownloadObjectRequest) XXX_DiscardUnknown()

func (*GfSpDownloadObjectRequest) XXX_Marshal 

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

func (*GfSpDownloadObjectRequest) XXX_Merge 

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

func (*GfSpDownloadObjectRequest) XXX_Size 

func (m *GfSpDownloadObjectRequest) XXX_Size() int

func (*GfSpDownloadObjectRequest) XXX_Unmarshal 

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

type GfSpDownloadObjectResponse 

type GfSpDownloadObjectResponse struct {
	Err  *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Data []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*GfSpDownloadObjectResponse) Descriptor 

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

func (*GfSpDownloadObjectResponse) GetData 

func (m *GfSpDownloadObjectResponse) GetData() []byte

func (*GfSpDownloadObjectResponse) GetErr 

func (m *GfSpDownloadObjectResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpDownloadObjectResponse) Marshal 

func (m *GfSpDownloadObjectResponse) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadObjectResponse) MarshalTo 

func (m *GfSpDownloadObjectResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadObjectResponse) MarshalToSizedBuffer 

func (m *GfSpDownloadObjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadObjectResponse) ProtoMessage 

func (*GfSpDownloadObjectResponse) ProtoMessage()

func (*GfSpDownloadObjectResponse) Reset 

func (m *GfSpDownloadObjectResponse) Reset()

func (*GfSpDownloadObjectResponse) Size 

func (m *GfSpDownloadObjectResponse) Size() (n int)

func (*GfSpDownloadObjectResponse) String 

func (m *GfSpDownloadObjectResponse) String() string

func (*GfSpDownloadObjectResponse) Unmarshal 

func (m *GfSpDownloadObjectResponse) Unmarshal(dAtA []byte) error

func (*GfSpDownloadObjectResponse) XXX_DiscardUnknown 

func (m *GfSpDownloadObjectResponse) XXX_DiscardUnknown()

func (*GfSpDownloadObjectResponse) XXX_Marshal 

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

func (*GfSpDownloadObjectResponse) XXX_Merge 

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

func (*GfSpDownloadObjectResponse) XXX_Size 

func (m *GfSpDownloadObjectResponse) XXX_Size() int

func (*GfSpDownloadObjectResponse) XXX_Unmarshal 

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

type GfSpDownloadPieceRequest 

type GfSpDownloadPieceRequest struct {
	DownloadPieceTask *gfsptask.GfSpDownloadPieceTask `protobuf:"bytes,1,opt,name=download_piece_task,json=downloadPieceTask,proto3" json:"download_piece_task,omitempty"`
}

func (*GfSpDownloadPieceRequest) Descriptor 

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

func (*GfSpDownloadPieceRequest) GetDownloadPieceTask 

func (m *GfSpDownloadPieceRequest) GetDownloadPieceTask() *gfsptask.GfSpDownloadPieceTask

func (*GfSpDownloadPieceRequest) Marshal 

func (m *GfSpDownloadPieceRequest) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadPieceRequest) MarshalTo 

func (m *GfSpDownloadPieceRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadPieceRequest) MarshalToSizedBuffer 

func (m *GfSpDownloadPieceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadPieceRequest) ProtoMessage 

func (*GfSpDownloadPieceRequest) ProtoMessage()

func (*GfSpDownloadPieceRequest) Reset 

func (m *GfSpDownloadPieceRequest) Reset()

func (*GfSpDownloadPieceRequest) Size 

func (m *GfSpDownloadPieceRequest) Size() (n int)

func (*GfSpDownloadPieceRequest) String 

func (m *GfSpDownloadPieceRequest) String() string

func (*GfSpDownloadPieceRequest) Unmarshal 

func (m *GfSpDownloadPieceRequest) Unmarshal(dAtA []byte) error

func (*GfSpDownloadPieceRequest) XXX_DiscardUnknown 

func (m *GfSpDownloadPieceRequest) XXX_DiscardUnknown()

func (*GfSpDownloadPieceRequest) XXX_Marshal 

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

func (*GfSpDownloadPieceRequest) XXX_Merge 

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

func (*GfSpDownloadPieceRequest) XXX_Size 

func (m *GfSpDownloadPieceRequest) XXX_Size() int

func (*GfSpDownloadPieceRequest) XXX_Unmarshal 

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

type GfSpDownloadPieceResponse 

type GfSpDownloadPieceResponse struct {
	Err  *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Data []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*GfSpDownloadPieceResponse) Descriptor 

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

func (*GfSpDownloadPieceResponse) GetData 

func (m *GfSpDownloadPieceResponse) GetData() []byte

func (*GfSpDownloadPieceResponse) GetErr 

func (m *GfSpDownloadPieceResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpDownloadPieceResponse) Marshal 

func (m *GfSpDownloadPieceResponse) Marshal() (dAtA []byte, err error)

func (*GfSpDownloadPieceResponse) MarshalTo 

func (m *GfSpDownloadPieceResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpDownloadPieceResponse) MarshalToSizedBuffer 

func (m *GfSpDownloadPieceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpDownloadPieceResponse) ProtoMessage 

func (*GfSpDownloadPieceResponse) ProtoMessage()

func (*GfSpDownloadPieceResponse) Reset 

func (m *GfSpDownloadPieceResponse) Reset()

func (*GfSpDownloadPieceResponse) Size 

func (m *GfSpDownloadPieceResponse) Size() (n int)

func (*GfSpDownloadPieceResponse) String 

func (m *GfSpDownloadPieceResponse) String() string

func (*GfSpDownloadPieceResponse) Unmarshal 

func (m *GfSpDownloadPieceResponse) Unmarshal(dAtA []byte) error

func (*GfSpDownloadPieceResponse) XXX_DiscardUnknown 

func (m *GfSpDownloadPieceResponse) XXX_DiscardUnknown()

func (*GfSpDownloadPieceResponse) XXX_Marshal 

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

func (*GfSpDownloadPieceResponse) XXX_Merge 

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

func (*GfSpDownloadPieceResponse) XXX_Size 

func (m *GfSpDownloadPieceResponse) XXX_Size() int

func (*GfSpDownloadPieceResponse) XXX_Unmarshal 

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

type GfSpDownloadServiceClient 

type GfSpDownloadServiceClient interface {
	GfSpDownloadObject(ctx context.Context, in *GfSpDownloadObjectRequest, opts ...grpc.CallOption) (*GfSpDownloadObjectResponse, error)
	GfSpDownloadPiece(ctx context.Context, in *GfSpDownloadPieceRequest, opts ...grpc.CallOption) (*GfSpDownloadPieceResponse, error)
	GfSpGetChallengeInfo(ctx context.Context, in *GfSpGetChallengeInfoRequest, opts ...grpc.CallOption) (*GfSpGetChallengeInfoResponse, error)
}

GfSpDownloadServiceClient is the client API for GfSpDownloadService service.

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

func NewGfSpDownloadServiceClient 

func NewGfSpDownloadServiceClient(cc grpc1.ClientConn) GfSpDownloadServiceClient

type GfSpDownloadServiceServer 

type GfSpDownloadServiceServer interface {
	GfSpDownloadObject(context.Context, *GfSpDownloadObjectRequest) (*GfSpDownloadObjectResponse, error)
	GfSpDownloadPiece(context.Context, *GfSpDownloadPieceRequest) (*GfSpDownloadPieceResponse, error)
	GfSpGetChallengeInfo(context.Context, *GfSpGetChallengeInfoRequest) (*GfSpGetChallengeInfoResponse, error)
}

GfSpDownloadServiceServer is the server API for GfSpDownloadService service.

type GfSpGetChallengeInfoRequest 

type GfSpGetChallengeInfoRequest struct {
	ChallengePieceTask *gfsptask.GfSpChallengePieceTask `protobuf:"bytes,1,opt,name=challenge_piece_task,json=challengePieceTask,proto3" json:"challenge_piece_task,omitempty"`
}

func (*GfSpGetChallengeInfoRequest) Descriptor 

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

func (*GfSpGetChallengeInfoRequest) GetChallengePieceTask 

func (m *GfSpGetChallengeInfoRequest) GetChallengePieceTask() *gfsptask.GfSpChallengePieceTask

func (*GfSpGetChallengeInfoRequest) Marshal 

func (m *GfSpGetChallengeInfoRequest) Marshal() (dAtA []byte, err error)

func (*GfSpGetChallengeInfoRequest) MarshalTo 

func (m *GfSpGetChallengeInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGetChallengeInfoRequest) MarshalToSizedBuffer 

func (m *GfSpGetChallengeInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGetChallengeInfoRequest) ProtoMessage 

func (*GfSpGetChallengeInfoRequest) ProtoMessage()

func (*GfSpGetChallengeInfoRequest) Reset 

func (m *GfSpGetChallengeInfoRequest) Reset()

func (*GfSpGetChallengeInfoRequest) Size 

func (m *GfSpGetChallengeInfoRequest) Size() (n int)

func (*GfSpGetChallengeInfoRequest) String 

func (m *GfSpGetChallengeInfoRequest) String() string

func (*GfSpGetChallengeInfoRequest) Unmarshal 

func (m *GfSpGetChallengeInfoRequest) Unmarshal(dAtA []byte) error

func (*GfSpGetChallengeInfoRequest) XXX_DiscardUnknown 

func (m *GfSpGetChallengeInfoRequest) XXX_DiscardUnknown()

func (*GfSpGetChallengeInfoRequest) XXX_Marshal 

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

func (*GfSpGetChallengeInfoRequest) XXX_Merge 

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

func (*GfSpGetChallengeInfoRequest) XXX_Size 

func (m *GfSpGetChallengeInfoRequest) XXX_Size() int

func (*GfSpGetChallengeInfoRequest) XXX_Unmarshal 

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

type GfSpGetChallengeInfoResponse 

type GfSpGetChallengeInfoResponse struct {
	Err           *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Data          []byte                `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	IntegrityHash []byte                `protobuf:"bytes,3,opt,name=integrity_hash,json=integrityHash,proto3" json:"integrity_hash,omitempty"`
	Checksums     [][]byte              `protobuf:"bytes,4,rep,name=checksums,proto3" json:"checksums,omitempty"`
}

func (*GfSpGetChallengeInfoResponse) Descriptor 

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

func (*GfSpGetChallengeInfoResponse) GetChecksums 

func (m *GfSpGetChallengeInfoResponse) GetChecksums() [][]byte

func (*GfSpGetChallengeInfoResponse) GetData 

func (m *GfSpGetChallengeInfoResponse) GetData() []byte

func (*GfSpGetChallengeInfoResponse) GetErr 

func (m *GfSpGetChallengeInfoResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpGetChallengeInfoResponse) GetIntegrityHash 

func (m *GfSpGetChallengeInfoResponse) GetIntegrityHash() []byte

func (*GfSpGetChallengeInfoResponse) Marshal 

func (m *GfSpGetChallengeInfoResponse) Marshal() (dAtA []byte, err error)

func (*GfSpGetChallengeInfoResponse) MarshalTo 

func (m *GfSpGetChallengeInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpGetChallengeInfoResponse) MarshalToSizedBuffer 

func (m *GfSpGetChallengeInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpGetChallengeInfoResponse) ProtoMessage 

func (*GfSpGetChallengeInfoResponse) ProtoMessage()

func (*GfSpGetChallengeInfoResponse) Reset 

func (m *GfSpGetChallengeInfoResponse) Reset()

func (*GfSpGetChallengeInfoResponse) Size 

func (m *GfSpGetChallengeInfoResponse) Size() (n int)

func (*GfSpGetChallengeInfoResponse) String 

func (m *GfSpGetChallengeInfoResponse) String() string

func (*GfSpGetChallengeInfoResponse) Unmarshal 

func (m *GfSpGetChallengeInfoResponse) Unmarshal(dAtA []byte) error

func (*GfSpGetChallengeInfoResponse) XXX_DiscardUnknown 

func (m *GfSpGetChallengeInfoResponse) XXX_DiscardUnknown()

func (*GfSpGetChallengeInfoResponse) XXX_Marshal 

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

func (*GfSpGetChallengeInfoResponse) XXX_Merge 

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

func (*GfSpGetChallengeInfoResponse) XXX_Size 

func (m *GfSpGetChallengeInfoResponse) XXX_Size() int

func (*GfSpGetChallengeInfoResponse) XXX_Unmarshal 

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

type GfSpManageServiceClient 

type GfSpManageServiceClient interface {
	GfSpBeginTask(ctx context.Context, in *GfSpBeginTaskRequest, opts ...grpc.CallOption) (*GfSpBeginTaskResponse, error)
	GfSpAskTask(ctx context.Context, in *GfSpAskTaskRequest, opts ...grpc.CallOption) (*GfSpAskTaskResponse, error)
	GfSpReportTask(ctx context.Context, in *GfSpReportTaskRequest, opts ...grpc.CallOption) (*GfSpReportTaskResponse, error)
	GfSpPickVirtualGroupFamily(ctx context.Context, in *GfSpPickVirtualGroupFamilyRequest, opts ...grpc.CallOption) (*GfSpPickVirtualGroupFamilyResponse, error)
	GfSpNotifyMigrateSwapOut(ctx context.Context, in *GfSpNotifyMigrateSwapOutRequest, opts ...grpc.CallOption) (*GfSpNotifyMigrateSwapOutResponse, error)
}

GfSpManageServiceClient is the client API for GfSpManageService service.

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

func NewGfSpManageServiceClient 

func NewGfSpManageServiceClient(cc grpc1.ClientConn) GfSpManageServiceClient

type GfSpManageServiceServer 

type GfSpManageServiceServer interface {
	GfSpBeginTask(context.Context, *GfSpBeginTaskRequest) (*GfSpBeginTaskResponse, error)
	GfSpAskTask(context.Context, *GfSpAskTaskRequest) (*GfSpAskTaskResponse, error)
	GfSpReportTask(context.Context, *GfSpReportTaskRequest) (*GfSpReportTaskResponse, error)
	GfSpPickVirtualGroupFamily(context.Context, *GfSpPickVirtualGroupFamilyRequest) (*GfSpPickVirtualGroupFamilyResponse, error)
	GfSpNotifyMigrateSwapOut(context.Context, *GfSpNotifyMigrateSwapOutRequest) (*GfSpNotifyMigrateSwapOutResponse, error)
}

GfSpManageServiceServer is the server API for GfSpManageService service.

type GfSpMigrateGVG 

type GfSpMigrateGVG struct {
	DestGvgId            uint32 `protobuf:"varint,1,opt,name=dest_gvg_id,json=destGvgId,proto3" json:"dest_gvg_id,omitempty"`
	SrcGvgId             uint32 `protobuf:"varint,2,opt,name=src_gvg_id,json=srcGvgId,proto3" json:"src_gvg_id,omitempty"`
	LastMigratedObjectId uint64 `` /* 126-byte string literal not displayed */
	Status               int32  `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
}

func (*GfSpMigrateGVG) Descriptor 

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

func (*GfSpMigrateGVG) GetDestGvgId 

func (m *GfSpMigrateGVG) GetDestGvgId() uint32

func (*GfSpMigrateGVG) GetLastMigratedObjectId 

func (m *GfSpMigrateGVG) GetLastMigratedObjectId() uint64

func (*GfSpMigrateGVG) GetSrcGvgId 

func (m *GfSpMigrateGVG) GetSrcGvgId() uint32

func (*GfSpMigrateGVG) GetStatus 

func (m *GfSpMigrateGVG) GetStatus() int32

func (*GfSpMigrateGVG) Marshal 

func (m *GfSpMigrateGVG) Marshal() (dAtA []byte, err error)

func (*GfSpMigrateGVG) MarshalTo 

func (m *GfSpMigrateGVG) MarshalTo(dAtA []byte) (int, error)

func (*GfSpMigrateGVG) MarshalToSizedBuffer 

func (m *GfSpMigrateGVG) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpMigrateGVG) ProtoMessage 

func (*GfSpMigrateGVG) ProtoMessage()

func (*GfSpMigrateGVG) Reset 

func (m *GfSpMigrateGVG) Reset()

func (*GfSpMigrateGVG) Size 

func (m *GfSpMigrateGVG) Size() (n int)

func (*GfSpMigrateGVG) String 

func (m *GfSpMigrateGVG) String() string

func (*GfSpMigrateGVG) Unmarshal 

func (m *GfSpMigrateGVG) Unmarshal(dAtA []byte) error

func (*GfSpMigrateGVG) XXX_DiscardUnknown 

func (m *GfSpMigrateGVG) XXX_DiscardUnknown()

func (*GfSpMigrateGVG) XXX_Marshal 

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

func (*GfSpMigrateGVG) XXX_Merge 

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

func (*GfSpMigrateGVG) XXX_Size 

func (m *GfSpMigrateGVG) XXX_Size() int

func (*GfSpMigrateGVG) XXX_Unmarshal 

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

type GfSpNotifyMigrateSwapOutRequest 

type GfSpNotifyMigrateSwapOutRequest struct {
	SwapOut *types.MsgSwapOut `protobuf:"bytes,1,opt,name=swap_out,json=swapOut,proto3" json:"swap_out,omitempty"`
}

func (*GfSpNotifyMigrateSwapOutRequest) Descriptor 

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

func (*GfSpNotifyMigrateSwapOutRequest) GetSwapOut 

func (m *GfSpNotifyMigrateSwapOutRequest) GetSwapOut() *types.MsgSwapOut

func (*GfSpNotifyMigrateSwapOutRequest) Marshal 

func (m *GfSpNotifyMigrateSwapOutRequest) Marshal() (dAtA []byte, err error)

func (*GfSpNotifyMigrateSwapOutRequest) MarshalTo 

func (m *GfSpNotifyMigrateSwapOutRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpNotifyMigrateSwapOutRequest) MarshalToSizedBuffer 

func (m *GfSpNotifyMigrateSwapOutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpNotifyMigrateSwapOutRequest) ProtoMessage 

func (*GfSpNotifyMigrateSwapOutRequest) ProtoMessage()

func (*GfSpNotifyMigrateSwapOutRequest) Reset 

func (m *GfSpNotifyMigrateSwapOutRequest) Reset()

func (*GfSpNotifyMigrateSwapOutRequest) Size 

func (m *GfSpNotifyMigrateSwapOutRequest) Size() (n int)

func (*GfSpNotifyMigrateSwapOutRequest) String 

func (m *GfSpNotifyMigrateSwapOutRequest) String() string

func (*GfSpNotifyMigrateSwapOutRequest) Unmarshal 

func (m *GfSpNotifyMigrateSwapOutRequest) Unmarshal(dAtA []byte) error

func (*GfSpNotifyMigrateSwapOutRequest) XXX_DiscardUnknown 

func (m *GfSpNotifyMigrateSwapOutRequest) XXX_DiscardUnknown()

func (*GfSpNotifyMigrateSwapOutRequest) XXX_Marshal 

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

func (*GfSpNotifyMigrateSwapOutRequest) XXX_Merge 

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

func (*GfSpNotifyMigrateSwapOutRequest) XXX_Size 

func (m *GfSpNotifyMigrateSwapOutRequest) XXX_Size() int

func (*GfSpNotifyMigrateSwapOutRequest) XXX_Unmarshal 

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

type GfSpNotifyMigrateSwapOutResponse 

type GfSpNotifyMigrateSwapOutResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpNotifyMigrateSwapOutResponse) Descriptor 

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

func (*GfSpNotifyMigrateSwapOutResponse) GetErr 

func (m *GfSpNotifyMigrateSwapOutResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpNotifyMigrateSwapOutResponse) Marshal 

func (m *GfSpNotifyMigrateSwapOutResponse) Marshal() (dAtA []byte, err error)

func (*GfSpNotifyMigrateSwapOutResponse) MarshalTo 

func (m *GfSpNotifyMigrateSwapOutResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpNotifyMigrateSwapOutResponse) MarshalToSizedBuffer 

func (m *GfSpNotifyMigrateSwapOutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpNotifyMigrateSwapOutResponse) ProtoMessage 

func (*GfSpNotifyMigrateSwapOutResponse) ProtoMessage()

func (*GfSpNotifyMigrateSwapOutResponse) Reset 

func (m *GfSpNotifyMigrateSwapOutResponse) Reset()

func (*GfSpNotifyMigrateSwapOutResponse) Size 

func (m *GfSpNotifyMigrateSwapOutResponse) Size() (n int)

func (*GfSpNotifyMigrateSwapOutResponse) String 

func (m *GfSpNotifyMigrateSwapOutResponse) String() string

func (*GfSpNotifyMigrateSwapOutResponse) Unmarshal 

func (m *GfSpNotifyMigrateSwapOutResponse) Unmarshal(dAtA []byte) error

func (*GfSpNotifyMigrateSwapOutResponse) XXX_DiscardUnknown 

func (m *GfSpNotifyMigrateSwapOutResponse) XXX_DiscardUnknown()

func (*GfSpNotifyMigrateSwapOutResponse) XXX_Marshal 

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

func (*GfSpNotifyMigrateSwapOutResponse) XXX_Merge 

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

func (*GfSpNotifyMigrateSwapOutResponse) XXX_Size 

func (m *GfSpNotifyMigrateSwapOutResponse) XXX_Size() int

func (*GfSpNotifyMigrateSwapOutResponse) XXX_Unmarshal 

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

type GfSpP2PServiceClient 

type GfSpP2PServiceClient interface {
	GfSpAskSecondaryReplicatePieceApproval(ctx context.Context, in *GfSpAskSecondaryReplicatePieceApprovalRequest, opts ...grpc.CallOption) (*GfSpAskSecondaryReplicatePieceApprovalResponse, error)
	GfSpQueryP2PBootstrap(ctx context.Context, in *GfSpQueryP2PNodeRequest, opts ...grpc.CallOption) (*GfSpQueryP2PNodeResponse, error)
}

GfSpP2PServiceClient is the client API for GfSpP2PService service.

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

func NewGfSpP2PServiceClient 

func NewGfSpP2PServiceClient(cc grpc1.ClientConn) GfSpP2PServiceClient

type GfSpP2PServiceServer 

type GfSpP2PServiceServer interface {
	GfSpAskSecondaryReplicatePieceApproval(context.Context, *GfSpAskSecondaryReplicatePieceApprovalRequest) (*GfSpAskSecondaryReplicatePieceApprovalResponse, error)
	GfSpQueryP2PBootstrap(context.Context, *GfSpQueryP2PNodeRequest) (*GfSpQueryP2PNodeResponse, error)
}

GfSpP2PServiceServer is the server API for GfSpP2PService service.

type GfSpPickVirtualGroupFamilyRequest 

type GfSpPickVirtualGroupFamilyRequest struct {
	CreateBucketApprovalTask *gfsptask.GfSpCreateBucketApprovalTask `` /* 137-byte string literal not displayed */
}

func (*GfSpPickVirtualGroupFamilyRequest) Descriptor 

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

func (*GfSpPickVirtualGroupFamilyRequest) GetCreateBucketApprovalTask 

func (m *GfSpPickVirtualGroupFamilyRequest) GetCreateBucketApprovalTask() *gfsptask.GfSpCreateBucketApprovalTask

func (*GfSpPickVirtualGroupFamilyRequest) Marshal 

func (m *GfSpPickVirtualGroupFamilyRequest) Marshal() (dAtA []byte, err error)

func (*GfSpPickVirtualGroupFamilyRequest) MarshalTo 

func (m *GfSpPickVirtualGroupFamilyRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpPickVirtualGroupFamilyRequest) MarshalToSizedBuffer 

func (m *GfSpPickVirtualGroupFamilyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpPickVirtualGroupFamilyRequest) ProtoMessage 

func (*GfSpPickVirtualGroupFamilyRequest) ProtoMessage()

func (*GfSpPickVirtualGroupFamilyRequest) Reset 

func (m *GfSpPickVirtualGroupFamilyRequest) Reset()

func (*GfSpPickVirtualGroupFamilyRequest) Size 

func (m *GfSpPickVirtualGroupFamilyRequest) Size() (n int)

func (*GfSpPickVirtualGroupFamilyRequest) String 

func (m *GfSpPickVirtualGroupFamilyRequest) String() string

func (*GfSpPickVirtualGroupFamilyRequest) Unmarshal 

func (m *GfSpPickVirtualGroupFamilyRequest) Unmarshal(dAtA []byte) error

func (*GfSpPickVirtualGroupFamilyRequest) XXX_DiscardUnknown 

func (m *GfSpPickVirtualGroupFamilyRequest) XXX_DiscardUnknown()

func (*GfSpPickVirtualGroupFamilyRequest) XXX_Marshal 

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

func (*GfSpPickVirtualGroupFamilyRequest) XXX_Merge 

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

func (*GfSpPickVirtualGroupFamilyRequest) XXX_Size 

func (m *GfSpPickVirtualGroupFamilyRequest) XXX_Size() int

func (*GfSpPickVirtualGroupFamilyRequest) XXX_Unmarshal 

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

type GfSpPickVirtualGroupFamilyResponse 

type GfSpPickVirtualGroupFamilyResponse struct {
	Err   *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	VgfId uint32                `protobuf:"varint,2,opt,name=vgf_id,json=vgfId,proto3" json:"vgf_id,omitempty"`
}

func (*GfSpPickVirtualGroupFamilyResponse) Descriptor 

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

func (*GfSpPickVirtualGroupFamilyResponse) GetErr 

func (m *GfSpPickVirtualGroupFamilyResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpPickVirtualGroupFamilyResponse) GetVgfId 

func (m *GfSpPickVirtualGroupFamilyResponse) GetVgfId() uint32

func (*GfSpPickVirtualGroupFamilyResponse) Marshal 

func (m *GfSpPickVirtualGroupFamilyResponse) Marshal() (dAtA []byte, err error)

func (*GfSpPickVirtualGroupFamilyResponse) MarshalTo 

func (m *GfSpPickVirtualGroupFamilyResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpPickVirtualGroupFamilyResponse) MarshalToSizedBuffer 

func (m *GfSpPickVirtualGroupFamilyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpPickVirtualGroupFamilyResponse) ProtoMessage 

func (*GfSpPickVirtualGroupFamilyResponse) ProtoMessage()

func (*GfSpPickVirtualGroupFamilyResponse) Reset 

func (m *GfSpPickVirtualGroupFamilyResponse) Reset()

func (*GfSpPickVirtualGroupFamilyResponse) Size 

func (m *GfSpPickVirtualGroupFamilyResponse) Size() (n int)

func (*GfSpPickVirtualGroupFamilyResponse) String 

func (m *GfSpPickVirtualGroupFamilyResponse) String() string

func (*GfSpPickVirtualGroupFamilyResponse) Unmarshal 

func (m *GfSpPickVirtualGroupFamilyResponse) Unmarshal(dAtA []byte) error

func (*GfSpPickVirtualGroupFamilyResponse) XXX_DiscardUnknown 

func (m *GfSpPickVirtualGroupFamilyResponse) XXX_DiscardUnknown()

func (*GfSpPickVirtualGroupFamilyResponse) XXX_Marshal 

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

func (*GfSpPickVirtualGroupFamilyResponse) XXX_Merge 

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

func (*GfSpPickVirtualGroupFamilyResponse) XXX_Size 

func (m *GfSpPickVirtualGroupFamilyResponse) XXX_Size() int

func (*GfSpPickVirtualGroupFamilyResponse) XXX_Unmarshal 

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

type GfSpQueryBucketMigrateRequest 

type GfSpQueryBucketMigrateRequest struct {
}

func (*GfSpQueryBucketMigrateRequest) Descriptor 

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

func (*GfSpQueryBucketMigrateRequest) Marshal 

func (m *GfSpQueryBucketMigrateRequest) Marshal() (dAtA []byte, err error)

func (*GfSpQueryBucketMigrateRequest) MarshalTo 

func (m *GfSpQueryBucketMigrateRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryBucketMigrateRequest) MarshalToSizedBuffer 

func (m *GfSpQueryBucketMigrateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryBucketMigrateRequest) ProtoMessage 

func (*GfSpQueryBucketMigrateRequest) ProtoMessage()

func (*GfSpQueryBucketMigrateRequest) Reset 

func (m *GfSpQueryBucketMigrateRequest) Reset()

func (*GfSpQueryBucketMigrateRequest) Size 

func (m *GfSpQueryBucketMigrateRequest) Size() (n int)

func (*GfSpQueryBucketMigrateRequest) String 

func (m *GfSpQueryBucketMigrateRequest) String() string

func (*GfSpQueryBucketMigrateRequest) Unmarshal 

func (m *GfSpQueryBucketMigrateRequest) Unmarshal(dAtA []byte) error

func (*GfSpQueryBucketMigrateRequest) XXX_DiscardUnknown 

func (m *GfSpQueryBucketMigrateRequest) XXX_DiscardUnknown()

func (*GfSpQueryBucketMigrateRequest) XXX_Marshal 

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

func (*GfSpQueryBucketMigrateRequest) XXX_Merge 

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

func (*GfSpQueryBucketMigrateRequest) XXX_Size 

func (m *GfSpQueryBucketMigrateRequest) XXX_Size() int

func (*GfSpQueryBucketMigrateRequest) XXX_Unmarshal 

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

type GfSpQueryBucketMigrateResponse 

type GfSpQueryBucketMigrateResponse struct {
	Err           *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	BucketMigrate []*GfSpBucketMigrate  `protobuf:"bytes,2,rep,name=bucket_migrate,json=bucketMigrate,proto3" json:"bucket_migrate,omitempty"`
	SelfSpId      uint32                `protobuf:"varint,3,opt,name=self_sp_id,json=selfSpId,proto3" json:"self_sp_id,omitempty"`
}

func (*GfSpQueryBucketMigrateResponse) Descriptor 

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

func (*GfSpQueryBucketMigrateResponse) GetBucketMigrate 

func (m *GfSpQueryBucketMigrateResponse) GetBucketMigrate() []*GfSpBucketMigrate

func (*GfSpQueryBucketMigrateResponse) GetErr 

func (m *GfSpQueryBucketMigrateResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpQueryBucketMigrateResponse) GetSelfSpId 

func (m *GfSpQueryBucketMigrateResponse) GetSelfSpId() uint32

func (*GfSpQueryBucketMigrateResponse) Marshal 

func (m *GfSpQueryBucketMigrateResponse) Marshal() (dAtA []byte, err error)

func (*GfSpQueryBucketMigrateResponse) MarshalTo 

func (m *GfSpQueryBucketMigrateResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryBucketMigrateResponse) MarshalToSizedBuffer 

func (m *GfSpQueryBucketMigrateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryBucketMigrateResponse) ProtoMessage 

func (*GfSpQueryBucketMigrateResponse) ProtoMessage()

func (*GfSpQueryBucketMigrateResponse) Reset 

func (m *GfSpQueryBucketMigrateResponse) Reset()

func (*GfSpQueryBucketMigrateResponse) Size 

func (m *GfSpQueryBucketMigrateResponse) Size() (n int)

func (*GfSpQueryBucketMigrateResponse) String 

func (m *GfSpQueryBucketMigrateResponse) String() string

func (*GfSpQueryBucketMigrateResponse) Unmarshal 

func (m *GfSpQueryBucketMigrateResponse) Unmarshal(dAtA []byte) error

func (*GfSpQueryBucketMigrateResponse) XXX_DiscardUnknown 

func (m *GfSpQueryBucketMigrateResponse) XXX_DiscardUnknown()

func (*GfSpQueryBucketMigrateResponse) XXX_Marshal 

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

func (*GfSpQueryBucketMigrateResponse) XXX_Merge 

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

func (*GfSpQueryBucketMigrateResponse) XXX_Size 

func (m *GfSpQueryBucketMigrateResponse) XXX_Size() int

func (*GfSpQueryBucketMigrateResponse) XXX_Unmarshal 

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

type GfSpQueryP2PNodeRequest 

type GfSpQueryP2PNodeRequest struct {
}

func (*GfSpQueryP2PNodeRequest) Descriptor 

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

func (*GfSpQueryP2PNodeRequest) Marshal 

func (m *GfSpQueryP2PNodeRequest) Marshal() (dAtA []byte, err error)

func (*GfSpQueryP2PNodeRequest) MarshalTo 

func (m *GfSpQueryP2PNodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryP2PNodeRequest) MarshalToSizedBuffer 

func (m *GfSpQueryP2PNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryP2PNodeRequest) ProtoMessage 

func (*GfSpQueryP2PNodeRequest) ProtoMessage()

func (*GfSpQueryP2PNodeRequest) Reset 

func (m *GfSpQueryP2PNodeRequest) Reset()

func (*GfSpQueryP2PNodeRequest) Size 

func (m *GfSpQueryP2PNodeRequest) Size() (n int)

func (*GfSpQueryP2PNodeRequest) String 

func (m *GfSpQueryP2PNodeRequest) String() string

func (*GfSpQueryP2PNodeRequest) Unmarshal 

func (m *GfSpQueryP2PNodeRequest) Unmarshal(dAtA []byte) error

func (*GfSpQueryP2PNodeRequest) XXX_DiscardUnknown 

func (m *GfSpQueryP2PNodeRequest) XXX_DiscardUnknown()

func (*GfSpQueryP2PNodeRequest) XXX_Marshal 

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

func (*GfSpQueryP2PNodeRequest) XXX_Merge 

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

func (*GfSpQueryP2PNodeRequest) XXX_Size 

func (m *GfSpQueryP2PNodeRequest) XXX_Size() int

func (*GfSpQueryP2PNodeRequest) XXX_Unmarshal 

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

type GfSpQueryP2PNodeResponse 

type GfSpQueryP2PNodeResponse struct {
	Err   *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Nodes []string              `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*GfSpQueryP2PNodeResponse) Descriptor 

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

func (*GfSpQueryP2PNodeResponse) GetErr 

func (m *GfSpQueryP2PNodeResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpQueryP2PNodeResponse) GetNodes 

func (m *GfSpQueryP2PNodeResponse) GetNodes() []string

func (*GfSpQueryP2PNodeResponse) Marshal 

func (m *GfSpQueryP2PNodeResponse) Marshal() (dAtA []byte, err error)

func (*GfSpQueryP2PNodeResponse) MarshalTo 

func (m *GfSpQueryP2PNodeResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryP2PNodeResponse) MarshalToSizedBuffer 

func (m *GfSpQueryP2PNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryP2PNodeResponse) ProtoMessage 

func (*GfSpQueryP2PNodeResponse) ProtoMessage()

func (*GfSpQueryP2PNodeResponse) Reset 

func (m *GfSpQueryP2PNodeResponse) Reset()

func (*GfSpQueryP2PNodeResponse) Size 

func (m *GfSpQueryP2PNodeResponse) Size() (n int)

func (*GfSpQueryP2PNodeResponse) String 

func (m *GfSpQueryP2PNodeResponse) String() string

func (*GfSpQueryP2PNodeResponse) Unmarshal 

func (m *GfSpQueryP2PNodeResponse) Unmarshal(dAtA []byte) error

func (*GfSpQueryP2PNodeResponse) XXX_DiscardUnknown 

func (m *GfSpQueryP2PNodeResponse) XXX_DiscardUnknown()

func (*GfSpQueryP2PNodeResponse) XXX_Marshal 

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

func (*GfSpQueryP2PNodeResponse) XXX_Merge 

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

func (*GfSpQueryP2PNodeResponse) XXX_Size 

func (m *GfSpQueryP2PNodeResponse) XXX_Size() int

func (*GfSpQueryP2PNodeResponse) XXX_Unmarshal 

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

type GfSpQueryResourceLimitRequest 

type GfSpQueryResourceLimitRequest struct {
	Module []string `protobuf:"bytes,1,rep,name=module,proto3" json:"module,omitempty"`
}

func (*GfSpQueryResourceLimitRequest) Descriptor 

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

func (*GfSpQueryResourceLimitRequest) GetModule 

func (m *GfSpQueryResourceLimitRequest) GetModule() []string

func (*GfSpQueryResourceLimitRequest) Marshal 

func (m *GfSpQueryResourceLimitRequest) Marshal() (dAtA []byte, err error)

func (*GfSpQueryResourceLimitRequest) MarshalTo 

func (m *GfSpQueryResourceLimitRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryResourceLimitRequest) MarshalToSizedBuffer 

func (m *GfSpQueryResourceLimitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryResourceLimitRequest) ProtoMessage 

func (*GfSpQueryResourceLimitRequest) ProtoMessage()

func (*GfSpQueryResourceLimitRequest) Reset 

func (m *GfSpQueryResourceLimitRequest) Reset()

func (*GfSpQueryResourceLimitRequest) Size 

func (m *GfSpQueryResourceLimitRequest) Size() (n int)

func (*GfSpQueryResourceLimitRequest) String 

func (m *GfSpQueryResourceLimitRequest) String() string

func (*GfSpQueryResourceLimitRequest) Unmarshal 

func (m *GfSpQueryResourceLimitRequest) Unmarshal(dAtA []byte) error

func (*GfSpQueryResourceLimitRequest) XXX_DiscardUnknown 

func (m *GfSpQueryResourceLimitRequest) XXX_DiscardUnknown()

func (*GfSpQueryResourceLimitRequest) XXX_Marshal 

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

func (*GfSpQueryResourceLimitRequest) XXX_Merge 

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

func (*GfSpQueryResourceLimitRequest) XXX_Size 

func (m *GfSpQueryResourceLimitRequest) XXX_Size() int

func (*GfSpQueryResourceLimitRequest) XXX_Unmarshal 

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

type GfSpQueryResourceLimitResponse 

type GfSpQueryResourceLimitResponse struct {
	Err    *gfsperrors.GfSpError           `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Limits map[string]*gfsplimit.GfSpLimit `` /* 153-byte string literal not displayed */
}

func (*GfSpQueryResourceLimitResponse) Descriptor 

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

func (*GfSpQueryResourceLimitResponse) GetErr 

func (m *GfSpQueryResourceLimitResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpQueryResourceLimitResponse) GetLimits 

func (m *GfSpQueryResourceLimitResponse) GetLimits() map[string]*gfsplimit.GfSpLimit

func (*GfSpQueryResourceLimitResponse) Marshal 

func (m *GfSpQueryResourceLimitResponse) Marshal() (dAtA []byte, err error)

func (*GfSpQueryResourceLimitResponse) MarshalTo 

func (m *GfSpQueryResourceLimitResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryResourceLimitResponse) MarshalToSizedBuffer 

func (m *GfSpQueryResourceLimitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryResourceLimitResponse) ProtoMessage 

func (*GfSpQueryResourceLimitResponse) ProtoMessage()

func (*GfSpQueryResourceLimitResponse) Reset 

func (m *GfSpQueryResourceLimitResponse) Reset()

func (*GfSpQueryResourceLimitResponse) Size 

func (m *GfSpQueryResourceLimitResponse) Size() (n int)

func (*GfSpQueryResourceLimitResponse) String 

func (m *GfSpQueryResourceLimitResponse) String() string

func (*GfSpQueryResourceLimitResponse) Unmarshal 

func (m *GfSpQueryResourceLimitResponse) Unmarshal(dAtA []byte) error

func (*GfSpQueryResourceLimitResponse) XXX_DiscardUnknown 

func (m *GfSpQueryResourceLimitResponse) XXX_DiscardUnknown()

func (*GfSpQueryResourceLimitResponse) XXX_Marshal 

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

func (*GfSpQueryResourceLimitResponse) XXX_Merge 

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

func (*GfSpQueryResourceLimitResponse) XXX_Size 

func (m *GfSpQueryResourceLimitResponse) XXX_Size() int

func (*GfSpQueryResourceLimitResponse) XXX_Unmarshal 

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

type GfSpQuerySpExitRequest 

type GfSpQuerySpExitRequest struct {
}

func (*GfSpQuerySpExitRequest) Descriptor 

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

func (*GfSpQuerySpExitRequest) Marshal 

func (m *GfSpQuerySpExitRequest) Marshal() (dAtA []byte, err error)

func (*GfSpQuerySpExitRequest) MarshalTo 

func (m *GfSpQuerySpExitRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQuerySpExitRequest) MarshalToSizedBuffer 

func (m *GfSpQuerySpExitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQuerySpExitRequest) ProtoMessage 

func (*GfSpQuerySpExitRequest) ProtoMessage()

func (*GfSpQuerySpExitRequest) Reset 

func (m *GfSpQuerySpExitRequest) Reset()

func (*GfSpQuerySpExitRequest) Size 

func (m *GfSpQuerySpExitRequest) Size() (n int)

func (*GfSpQuerySpExitRequest) String 

func (m *GfSpQuerySpExitRequest) String() string

func (*GfSpQuerySpExitRequest) Unmarshal 

func (m *GfSpQuerySpExitRequest) Unmarshal(dAtA []byte) error

func (*GfSpQuerySpExitRequest) XXX_DiscardUnknown 

func (m *GfSpQuerySpExitRequest) XXX_DiscardUnknown()

func (*GfSpQuerySpExitRequest) XXX_Marshal 

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

func (*GfSpQuerySpExitRequest) XXX_Merge 

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

func (*GfSpQuerySpExitRequest) XXX_Size 

func (m *GfSpQuerySpExitRequest) XXX_Size() int

func (*GfSpQuerySpExitRequest) XXX_Unmarshal 

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

type GfSpQuerySpExitResponse 

type GfSpQuerySpExitResponse struct {
	Err         *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	SwapOutSrc  []*SwapOutUnit        `protobuf:"bytes,2,rep,name=swap_out_src,json=swapOutSrc,proto3" json:"swap_out_src,omitempty"`
	SwapOutDest []*SwapOutUnit        `protobuf:"bytes,3,rep,name=swap_out_dest,json=swapOutDest,proto3" json:"swap_out_dest,omitempty"`
	SelfSpId    uint32                `protobuf:"varint,4,opt,name=self_sp_id,json=selfSpId,proto3" json:"self_sp_id,omitempty"`
}

func (*GfSpQuerySpExitResponse) Descriptor 

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

func (*GfSpQuerySpExitResponse) GetErr 

func (m *GfSpQuerySpExitResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpQuerySpExitResponse) GetSelfSpId 

func (m *GfSpQuerySpExitResponse) GetSelfSpId() uint32

func (*GfSpQuerySpExitResponse) GetSwapOutDest 

func (m *GfSpQuerySpExitResponse) GetSwapOutDest() []*SwapOutUnit

func (*GfSpQuerySpExitResponse) GetSwapOutSrc 

func (m *GfSpQuerySpExitResponse) GetSwapOutSrc() []*SwapOutUnit

func (*GfSpQuerySpExitResponse) Marshal 

func (m *GfSpQuerySpExitResponse) Marshal() (dAtA []byte, err error)

func (*GfSpQuerySpExitResponse) MarshalTo 

func (m *GfSpQuerySpExitResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQuerySpExitResponse) MarshalToSizedBuffer 

func (m *GfSpQuerySpExitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQuerySpExitResponse) ProtoMessage 

func (*GfSpQuerySpExitResponse) ProtoMessage()

func (*GfSpQuerySpExitResponse) Reset 

func (m *GfSpQuerySpExitResponse) Reset()

func (*GfSpQuerySpExitResponse) Size 

func (m *GfSpQuerySpExitResponse) Size() (n int)

func (*GfSpQuerySpExitResponse) String 

func (m *GfSpQuerySpExitResponse) String() string

func (*GfSpQuerySpExitResponse) Unmarshal 

func (m *GfSpQuerySpExitResponse) Unmarshal(dAtA []byte) error

func (*GfSpQuerySpExitResponse) XXX_DiscardUnknown 

func (m *GfSpQuerySpExitResponse) XXX_DiscardUnknown()

func (*GfSpQuerySpExitResponse) XXX_Marshal 

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

func (*GfSpQuerySpExitResponse) XXX_Merge 

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

func (*GfSpQuerySpExitResponse) XXX_Size 

func (m *GfSpQuerySpExitResponse) XXX_Size() int

func (*GfSpQuerySpExitResponse) XXX_Unmarshal 

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

type GfSpQueryTaskServiceClient 

type GfSpQueryTaskServiceClient interface {
	GfSpQueryTasks(ctx context.Context, in *GfSpQueryTasksRequest, opts ...grpc.CallOption) (*GfSpQueryTasksResponse, error)
	GfSpQueryBucketMigrate(ctx context.Context, in *GfSpQueryBucketMigrateRequest, opts ...grpc.CallOption) (*GfSpQueryBucketMigrateResponse, error)
	GfSpQuerySpExit(ctx context.Context, in *GfSpQuerySpExitRequest, opts ...grpc.CallOption) (*GfSpQuerySpExitResponse, error)
}

GfSpQueryTaskServiceClient is the client API for GfSpQueryTaskService service.

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

func NewGfSpQueryTaskServiceClient 

func NewGfSpQueryTaskServiceClient(cc grpc1.ClientConn) GfSpQueryTaskServiceClient

type GfSpQueryTaskServiceServer 

type GfSpQueryTaskServiceServer interface {
	GfSpQueryTasks(context.Context, *GfSpQueryTasksRequest) (*GfSpQueryTasksResponse, error)
	GfSpQueryBucketMigrate(context.Context, *GfSpQueryBucketMigrateRequest) (*GfSpQueryBucketMigrateResponse, error)
	GfSpQuerySpExit(context.Context, *GfSpQuerySpExitRequest) (*GfSpQuerySpExitResponse, error)
}

GfSpQueryTaskServiceServer is the server API for GfSpQueryTaskService service.

type GfSpQueryTasksRequest 

type GfSpQueryTasksRequest struct {
	TaskSubKey string `protobuf:"bytes,1,opt,name=task_sub_key,json=taskSubKey,proto3" json:"task_sub_key,omitempty"`
}

func (*GfSpQueryTasksRequest) Descriptor 

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

func (*GfSpQueryTasksRequest) GetTaskSubKey 

func (m *GfSpQueryTasksRequest) GetTaskSubKey() string

func (*GfSpQueryTasksRequest) Marshal 

func (m *GfSpQueryTasksRequest) Marshal() (dAtA []byte, err error)

func (*GfSpQueryTasksRequest) MarshalTo 

func (m *GfSpQueryTasksRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryTasksRequest) MarshalToSizedBuffer 

func (m *GfSpQueryTasksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryTasksRequest) ProtoMessage 

func (*GfSpQueryTasksRequest) ProtoMessage()

func (*GfSpQueryTasksRequest) Reset 

func (m *GfSpQueryTasksRequest) Reset()

func (*GfSpQueryTasksRequest) Size 

func (m *GfSpQueryTasksRequest) Size() (n int)

func (*GfSpQueryTasksRequest) String 

func (m *GfSpQueryTasksRequest) String() string

func (*GfSpQueryTasksRequest) Unmarshal 

func (m *GfSpQueryTasksRequest) Unmarshal(dAtA []byte) error

func (*GfSpQueryTasksRequest) XXX_DiscardUnknown 

func (m *GfSpQueryTasksRequest) XXX_DiscardUnknown()

func (*GfSpQueryTasksRequest) XXX_Marshal 

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

func (*GfSpQueryTasksRequest) XXX_Merge 

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

func (*GfSpQueryTasksRequest) XXX_Size 

func (m *GfSpQueryTasksRequest) XXX_Size() int

func (*GfSpQueryTasksRequest) XXX_Unmarshal 

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

type GfSpQueryTasksResponse 

type GfSpQueryTasksResponse struct {
	Err      *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	TaskInfo []string              `protobuf:"bytes,2,rep,name=task_info,json=taskInfo,proto3" json:"task_info,omitempty"`
}

func (*GfSpQueryTasksResponse) Descriptor 

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

func (*GfSpQueryTasksResponse) GetErr 

func (m *GfSpQueryTasksResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpQueryTasksResponse) GetTaskInfo 

func (m *GfSpQueryTasksResponse) GetTaskInfo() []string

func (*GfSpQueryTasksResponse) Marshal 

func (m *GfSpQueryTasksResponse) Marshal() (dAtA []byte, err error)

func (*GfSpQueryTasksResponse) MarshalTo 

func (m *GfSpQueryTasksResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpQueryTasksResponse) MarshalToSizedBuffer 

func (m *GfSpQueryTasksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpQueryTasksResponse) ProtoMessage 

func (*GfSpQueryTasksResponse) ProtoMessage()

func (*GfSpQueryTasksResponse) Reset 

func (m *GfSpQueryTasksResponse) Reset()

func (*GfSpQueryTasksResponse) Size 

func (m *GfSpQueryTasksResponse) Size() (n int)

func (*GfSpQueryTasksResponse) String 

func (m *GfSpQueryTasksResponse) String() string

func (*GfSpQueryTasksResponse) Unmarshal 

func (m *GfSpQueryTasksResponse) Unmarshal(dAtA []byte) error

func (*GfSpQueryTasksResponse) XXX_DiscardUnknown 

func (m *GfSpQueryTasksResponse) XXX_DiscardUnknown()

func (*GfSpQueryTasksResponse) XXX_Marshal 

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

func (*GfSpQueryTasksResponse) XXX_Merge 

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

func (*GfSpQueryTasksResponse) XXX_Size 

func (m *GfSpQueryTasksResponse) XXX_Size() int

func (*GfSpQueryTasksResponse) XXX_Unmarshal 

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

type GfSpReceiveServiceClient 

type GfSpReceiveServiceClient interface {
	GfSpReplicatePiece(ctx context.Context, in *GfSpReplicatePieceRequest, opts ...grpc.CallOption) (*GfSpReplicatePieceResponse, error)
	GfSpDoneReplicatePiece(ctx context.Context, in *GfSpDoneReplicatePieceRequest, opts ...grpc.CallOption) (*GfSpDoneReplicatePieceResponse, error)
}

GfSpReceiveServiceClient is the client API for GfSpReceiveService service.

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

func NewGfSpReceiveServiceClient 

func NewGfSpReceiveServiceClient(cc grpc1.ClientConn) GfSpReceiveServiceClient

type GfSpReceiveServiceServer 

type GfSpReceiveServiceServer interface {
	GfSpReplicatePiece(context.Context, *GfSpReplicatePieceRequest) (*GfSpReplicatePieceResponse, error)
	GfSpDoneReplicatePiece(context.Context, *GfSpDoneReplicatePieceRequest) (*GfSpDoneReplicatePieceResponse, error)
}

GfSpReceiveServiceServer is the server API for GfSpReceiveService service.

type GfSpReplicatePieceRequest 

type GfSpReplicatePieceRequest struct {
	ReceivePieceTask *gfsptask.GfSpReceivePieceTask `protobuf:"bytes,1,opt,name=receive_piece_task,json=receivePieceTask,proto3" json:"receive_piece_task,omitempty"`
	PieceData        []byte                         `protobuf:"bytes,2,opt,name=piece_data,json=pieceData,proto3" json:"piece_data,omitempty"`
}

func (*GfSpReplicatePieceRequest) Descriptor 

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

func (*GfSpReplicatePieceRequest) GetPieceData 

func (m *GfSpReplicatePieceRequest) GetPieceData() []byte

func (*GfSpReplicatePieceRequest) GetReceivePieceTask 

func (m *GfSpReplicatePieceRequest) GetReceivePieceTask() *gfsptask.GfSpReceivePieceTask

func (*GfSpReplicatePieceRequest) Marshal 

func (m *GfSpReplicatePieceRequest) Marshal() (dAtA []byte, err error)

func (*GfSpReplicatePieceRequest) MarshalTo 

func (m *GfSpReplicatePieceRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReplicatePieceRequest) MarshalToSizedBuffer 

func (m *GfSpReplicatePieceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReplicatePieceRequest) ProtoMessage 

func (*GfSpReplicatePieceRequest) ProtoMessage()

func (*GfSpReplicatePieceRequest) Reset 

func (m *GfSpReplicatePieceRequest) Reset()

func (*GfSpReplicatePieceRequest) Size 

func (m *GfSpReplicatePieceRequest) Size() (n int)

func (*GfSpReplicatePieceRequest) String 

func (m *GfSpReplicatePieceRequest) String() string

func (*GfSpReplicatePieceRequest) Unmarshal 

func (m *GfSpReplicatePieceRequest) Unmarshal(dAtA []byte) error

func (*GfSpReplicatePieceRequest) XXX_DiscardUnknown 

func (m *GfSpReplicatePieceRequest) XXX_DiscardUnknown()

func (*GfSpReplicatePieceRequest) XXX_Marshal 

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

func (*GfSpReplicatePieceRequest) XXX_Merge 

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

func (*GfSpReplicatePieceRequest) XXX_Size 

func (m *GfSpReplicatePieceRequest) XXX_Size() int

func (*GfSpReplicatePieceRequest) XXX_Unmarshal 

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

type GfSpReplicatePieceResponse 

type GfSpReplicatePieceResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpReplicatePieceResponse) Descriptor 

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

func (*GfSpReplicatePieceResponse) GetErr 

func (m *GfSpReplicatePieceResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpReplicatePieceResponse) Marshal 

func (m *GfSpReplicatePieceResponse) Marshal() (dAtA []byte, err error)

func (*GfSpReplicatePieceResponse) MarshalTo 

func (m *GfSpReplicatePieceResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReplicatePieceResponse) MarshalToSizedBuffer 

func (m *GfSpReplicatePieceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReplicatePieceResponse) ProtoMessage 

func (*GfSpReplicatePieceResponse) ProtoMessage()

func (*GfSpReplicatePieceResponse) Reset 

func (m *GfSpReplicatePieceResponse) Reset()

func (*GfSpReplicatePieceResponse) Size 

func (m *GfSpReplicatePieceResponse) Size() (n int)

func (*GfSpReplicatePieceResponse) String 

func (m *GfSpReplicatePieceResponse) String() string

func (*GfSpReplicatePieceResponse) Unmarshal 

func (m *GfSpReplicatePieceResponse) Unmarshal(dAtA []byte) error

func (*GfSpReplicatePieceResponse) XXX_DiscardUnknown 

func (m *GfSpReplicatePieceResponse) XXX_DiscardUnknown()

func (*GfSpReplicatePieceResponse) XXX_Marshal 

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

func (*GfSpReplicatePieceResponse) XXX_Merge 

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

func (*GfSpReplicatePieceResponse) XXX_Size 

func (m *GfSpReplicatePieceResponse) XXX_Size() int

func (*GfSpReplicatePieceResponse) XXX_Unmarshal 

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

type GfSpReportTaskRequest 

type GfSpReportTaskRequest struct {
	// Types that are valid to be assigned to Request:
	//	*GfSpReportTaskRequest_UploadObjectTask
	//	*GfSpReportTaskRequest_ReplicatePieceTask
	//	*GfSpReportTaskRequest_SealObjectTask
	//	*GfSpReportTaskRequest_GcObjectTask
	//	*GfSpReportTaskRequest_GcZombiePieceTask
	//	*GfSpReportTaskRequest_GcMetaTask
	//	*GfSpReportTaskRequest_DownloadObjectTask
	//	*GfSpReportTaskRequest_ChallengePieceTask
	//	*GfSpReportTaskRequest_ReceivePieceTask
	//	*GfSpReportTaskRequest_ResumableUploadObjectTask
	//	*GfSpReportTaskRequest_RecoverPieceTask
	//	*GfSpReportTaskRequest_MigrateGvgTask
	Request isGfSpReportTaskRequest_Request `protobuf_oneof:"request"`
}

func (*GfSpReportTaskRequest) Descriptor 

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

func (*GfSpReportTaskRequest) GetChallengePieceTask 

func (m *GfSpReportTaskRequest) GetChallengePieceTask() *gfsptask.GfSpChallengePieceTask

func (*GfSpReportTaskRequest) GetDownloadObjectTask 

func (m *GfSpReportTaskRequest) GetDownloadObjectTask() *gfsptask.GfSpDownloadObjectTask

func (*GfSpReportTaskRequest) GetGcMetaTask 

func (m *GfSpReportTaskRequest) GetGcMetaTask() *gfsptask.GfSpGCMetaTask

func (*GfSpReportTaskRequest) GetGcObjectTask 

func (m *GfSpReportTaskRequest) GetGcObjectTask() *gfsptask.GfSpGCObjectTask

func (*GfSpReportTaskRequest) GetGcZombiePieceTask 

func (m *GfSpReportTaskRequest) GetGcZombiePieceTask() *gfsptask.GfSpGCZombiePieceTask

func (*GfSpReportTaskRequest) GetMigrateGvgTask 

func (m *GfSpReportTaskRequest) GetMigrateGvgTask() *gfsptask.GfSpMigrateGVGTask

func (*GfSpReportTaskRequest) GetReceivePieceTask 

func (m *GfSpReportTaskRequest) GetReceivePieceTask() *gfsptask.GfSpReceivePieceTask

func (*GfSpReportTaskRequest) GetRecoverPieceTask 

func (m *GfSpReportTaskRequest) GetRecoverPieceTask() *gfsptask.GfSpRecoverPieceTask

func (*GfSpReportTaskRequest) GetReplicatePieceTask 

func (m *GfSpReportTaskRequest) GetReplicatePieceTask() *gfsptask.GfSpReplicatePieceTask

func (*GfSpReportTaskRequest) GetRequest 

func (m *GfSpReportTaskRequest) GetRequest() isGfSpReportTaskRequest_Request

func (*GfSpReportTaskRequest) GetResumableUploadObjectTask 

func (m *GfSpReportTaskRequest) GetResumableUploadObjectTask() *gfsptask.GfSpResumableUploadObjectTask

func (*GfSpReportTaskRequest) GetSealObjectTask 

func (m *GfSpReportTaskRequest) GetSealObjectTask() *gfsptask.GfSpSealObjectTask

func (*GfSpReportTaskRequest) GetUploadObjectTask 

func (m *GfSpReportTaskRequest) GetUploadObjectTask() *gfsptask.GfSpUploadObjectTask

func (*GfSpReportTaskRequest) Marshal 

func (m *GfSpReportTaskRequest) Marshal() (dAtA []byte, err error)

func (*GfSpReportTaskRequest) MarshalTo 

func (m *GfSpReportTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest) ProtoMessage 

func (*GfSpReportTaskRequest) ProtoMessage()

func (*GfSpReportTaskRequest) Reset 

func (m *GfSpReportTaskRequest) Reset()

func (*GfSpReportTaskRequest) Size 

func (m *GfSpReportTaskRequest) Size() (n int)

func (*GfSpReportTaskRequest) String 

func (m *GfSpReportTaskRequest) String() string

func (*GfSpReportTaskRequest) Unmarshal 

func (m *GfSpReportTaskRequest) Unmarshal(dAtA []byte) error

func (*GfSpReportTaskRequest) XXX_DiscardUnknown 

func (m *GfSpReportTaskRequest) XXX_DiscardUnknown()

func (*GfSpReportTaskRequest) XXX_Marshal 

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

func (*GfSpReportTaskRequest) XXX_Merge 

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

func (*GfSpReportTaskRequest) XXX_OneofWrappers 

func (*GfSpReportTaskRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpReportTaskRequest) XXX_Size 

func (m *GfSpReportTaskRequest) XXX_Size() int

func (*GfSpReportTaskRequest) XXX_Unmarshal 

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

type GfSpReportTaskRequest_ChallengePieceTask 

type GfSpReportTaskRequest_ChallengePieceTask struct {
	ChallengePieceTask *gfsptask.GfSpChallengePieceTask `protobuf:"bytes,8,opt,name=challenge_piece_task,json=challengePieceTask,proto3,oneof" json:"challenge_piece_task,omitempty"`
}

func (*GfSpReportTaskRequest_ChallengePieceTask) MarshalTo 

func (m *GfSpReportTaskRequest_ChallengePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ChallengePieceTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_ChallengePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ChallengePieceTask) Size 

func (m *GfSpReportTaskRequest_ChallengePieceTask) Size() (n int)

type GfSpReportTaskRequest_DownloadObjectTask 

type GfSpReportTaskRequest_DownloadObjectTask struct {
	DownloadObjectTask *gfsptask.GfSpDownloadObjectTask `protobuf:"bytes,7,opt,name=download_object_task,json=downloadObjectTask,proto3,oneof" json:"download_object_task,omitempty"`
}

func (*GfSpReportTaskRequest_DownloadObjectTask) MarshalTo 

func (m *GfSpReportTaskRequest_DownloadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_DownloadObjectTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_DownloadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_DownloadObjectTask) Size 

func (m *GfSpReportTaskRequest_DownloadObjectTask) Size() (n int)

type GfSpReportTaskRequest_GcMetaTask 

type GfSpReportTaskRequest_GcMetaTask struct {
	GcMetaTask *gfsptask.GfSpGCMetaTask `protobuf:"bytes,6,opt,name=gc_meta_task,json=gcMetaTask,proto3,oneof" json:"gc_meta_task,omitempty"`
}

func (*GfSpReportTaskRequest_GcMetaTask) MarshalTo 

func (m *GfSpReportTaskRequest_GcMetaTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcMetaTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_GcMetaTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcMetaTask) Size 

func (m *GfSpReportTaskRequest_GcMetaTask) Size() (n int)

type GfSpReportTaskRequest_GcObjectTask 

type GfSpReportTaskRequest_GcObjectTask struct {
	GcObjectTask *gfsptask.GfSpGCObjectTask `protobuf:"bytes,4,opt,name=gc_object_task,json=gcObjectTask,proto3,oneof" json:"gc_object_task,omitempty"`
}

func (*GfSpReportTaskRequest_GcObjectTask) MarshalTo 

func (m *GfSpReportTaskRequest_GcObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcObjectTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_GcObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcObjectTask) Size 

func (m *GfSpReportTaskRequest_GcObjectTask) Size() (n int)

type GfSpReportTaskRequest_GcZombiePieceTask 

type GfSpReportTaskRequest_GcZombiePieceTask struct {
	GcZombiePieceTask *gfsptask.GfSpGCZombiePieceTask `protobuf:"bytes,5,opt,name=gc_zombie_piece_task,json=gcZombiePieceTask,proto3,oneof" json:"gc_zombie_piece_task,omitempty"`
}

func (*GfSpReportTaskRequest_GcZombiePieceTask) MarshalTo 

func (m *GfSpReportTaskRequest_GcZombiePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcZombiePieceTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_GcZombiePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_GcZombiePieceTask) Size 

func (m *GfSpReportTaskRequest_GcZombiePieceTask) Size() (n int)

type GfSpReportTaskRequest_MigrateGvgTask 

type GfSpReportTaskRequest_MigrateGvgTask struct {
	MigrateGvgTask *gfsptask.GfSpMigrateGVGTask `protobuf:"bytes,12,opt,name=migrate_gvg_task,json=migrateGvgTask,proto3,oneof" json:"migrate_gvg_task,omitempty"`
}

func (*GfSpReportTaskRequest_MigrateGvgTask) MarshalTo 

func (m *GfSpReportTaskRequest_MigrateGvgTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_MigrateGvgTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_MigrateGvgTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_MigrateGvgTask) Size 

func (m *GfSpReportTaskRequest_MigrateGvgTask) Size() (n int)

type GfSpReportTaskRequest_ReceivePieceTask 

type GfSpReportTaskRequest_ReceivePieceTask struct {
	ReceivePieceTask *gfsptask.GfSpReceivePieceTask `protobuf:"bytes,9,opt,name=receive_piece_task,json=receivePieceTask,proto3,oneof" json:"receive_piece_task,omitempty"`
}

func (*GfSpReportTaskRequest_ReceivePieceTask) MarshalTo 

func (m *GfSpReportTaskRequest_ReceivePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ReceivePieceTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_ReceivePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ReceivePieceTask) Size 

func (m *GfSpReportTaskRequest_ReceivePieceTask) Size() (n int)

type GfSpReportTaskRequest_RecoverPieceTask 

type GfSpReportTaskRequest_RecoverPieceTask struct {
	RecoverPieceTask *gfsptask.GfSpRecoverPieceTask `protobuf:"bytes,11,opt,name=recover_piece_task,json=recoverPieceTask,proto3,oneof" json:"recover_piece_task,omitempty"`
}

func (*GfSpReportTaskRequest_RecoverPieceTask) MarshalTo 

func (m *GfSpReportTaskRequest_RecoverPieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_RecoverPieceTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_RecoverPieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_RecoverPieceTask) Size 

func (m *GfSpReportTaskRequest_RecoverPieceTask) Size() (n int)

type GfSpReportTaskRequest_ReplicatePieceTask 

type GfSpReportTaskRequest_ReplicatePieceTask struct {
	ReplicatePieceTask *gfsptask.GfSpReplicatePieceTask `protobuf:"bytes,2,opt,name=replicate_piece_task,json=replicatePieceTask,proto3,oneof" json:"replicate_piece_task,omitempty"`
}

func (*GfSpReportTaskRequest_ReplicatePieceTask) MarshalTo 

func (m *GfSpReportTaskRequest_ReplicatePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ReplicatePieceTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_ReplicatePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ReplicatePieceTask) Size 

func (m *GfSpReportTaskRequest_ReplicatePieceTask) Size() (n int)

type GfSpReportTaskRequest_ResumableUploadObjectTask 

type GfSpReportTaskRequest_ResumableUploadObjectTask struct {
	ResumableUploadObjectTask *gfsptask.GfSpResumableUploadObjectTask `` /* 147-byte string literal not displayed */
}

func (*GfSpReportTaskRequest_ResumableUploadObjectTask) MarshalTo 

func (m *GfSpReportTaskRequest_ResumableUploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ResumableUploadObjectTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_ResumableUploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_ResumableUploadObjectTask) Size 

func (m *GfSpReportTaskRequest_ResumableUploadObjectTask) Size() (n int)

type GfSpReportTaskRequest_SealObjectTask 

type GfSpReportTaskRequest_SealObjectTask struct {
	SealObjectTask *gfsptask.GfSpSealObjectTask `protobuf:"bytes,3,opt,name=seal_object_task,json=sealObjectTask,proto3,oneof" json:"seal_object_task,omitempty"`
}

func (*GfSpReportTaskRequest_SealObjectTask) MarshalTo 

func (m *GfSpReportTaskRequest_SealObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_SealObjectTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_SealObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_SealObjectTask) Size 

func (m *GfSpReportTaskRequest_SealObjectTask) Size() (n int)

type GfSpReportTaskRequest_UploadObjectTask 

type GfSpReportTaskRequest_UploadObjectTask struct {
	UploadObjectTask *gfsptask.GfSpUploadObjectTask `protobuf:"bytes,1,opt,name=upload_object_task,json=uploadObjectTask,proto3,oneof" json:"upload_object_task,omitempty"`
}

func (*GfSpReportTaskRequest_UploadObjectTask) MarshalTo 

func (m *GfSpReportTaskRequest_UploadObjectTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_UploadObjectTask) MarshalToSizedBuffer 

func (m *GfSpReportTaskRequest_UploadObjectTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskRequest_UploadObjectTask) Size 

func (m *GfSpReportTaskRequest_UploadObjectTask) Size() (n int)

type GfSpReportTaskResponse 

type GfSpReportTaskResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpReportTaskResponse) Descriptor 

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

func (*GfSpReportTaskResponse) GetErr 

func (m *GfSpReportTaskResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpReportTaskResponse) Marshal 

func (m *GfSpReportTaskResponse) Marshal() (dAtA []byte, err error)

func (*GfSpReportTaskResponse) MarshalTo 

func (m *GfSpReportTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpReportTaskResponse) MarshalToSizedBuffer 

func (m *GfSpReportTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpReportTaskResponse) ProtoMessage 

func (*GfSpReportTaskResponse) ProtoMessage()

func (*GfSpReportTaskResponse) Reset 

func (m *GfSpReportTaskResponse) Reset()

func (*GfSpReportTaskResponse) Size 

func (m *GfSpReportTaskResponse) Size() (n int)

func (*GfSpReportTaskResponse) String 

func (m *GfSpReportTaskResponse) String() string

func (*GfSpReportTaskResponse) Unmarshal 

func (m *GfSpReportTaskResponse) Unmarshal(dAtA []byte) error

func (*GfSpReportTaskResponse) XXX_DiscardUnknown 

func (m *GfSpReportTaskResponse) XXX_DiscardUnknown()

func (*GfSpReportTaskResponse) XXX_Marshal 

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

func (*GfSpReportTaskResponse) XXX_Merge 

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

func (*GfSpReportTaskResponse) XXX_Size 

func (m *GfSpReportTaskResponse) XXX_Size() int

func (*GfSpReportTaskResponse) XXX_Unmarshal 

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

type GfSpResourceServiceClient 

type GfSpResourceServiceClient interface {
	GfSpSetResourceLimit(ctx context.Context, in *GfSpSetResourceLimitRequest, opts ...grpc.CallOption) (*GfSpSetResourceLimitResponse, error)
	GfSpQueryResourceLimit(ctx context.Context, in *GfSpQueryResourceLimitRequest, opts ...grpc.CallOption) (*GfSpQueryResourceLimitResponse, error)
}

GfSpResourceServiceClient is the client API for GfSpResourceService service.

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

func NewGfSpResourceServiceClient 

func NewGfSpResourceServiceClient(cc grpc1.ClientConn) GfSpResourceServiceClient

type GfSpResourceServiceServer 

type GfSpResourceServiceServer interface {
	GfSpSetResourceLimit(context.Context, *GfSpSetResourceLimitRequest) (*GfSpSetResourceLimitResponse, error)
	GfSpQueryResourceLimit(context.Context, *GfSpQueryResourceLimitRequest) (*GfSpQueryResourceLimitResponse, error)
}

GfSpResourceServiceServer is the server API for GfSpResourceService service.

type GfSpResumableUploadObjectRequest 

type GfSpResumableUploadObjectRequest struct {
	ResumableUploadObjectTask *gfsptask.GfSpResumableUploadObjectTask `` /* 140-byte string literal not displayed */
	Payload                   []byte                                  `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*GfSpResumableUploadObjectRequest) Descriptor 

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

func (*GfSpResumableUploadObjectRequest) GetPayload 

func (m *GfSpResumableUploadObjectRequest) GetPayload() []byte

func (*GfSpResumableUploadObjectRequest) GetResumableUploadObjectTask 

func (m *GfSpResumableUploadObjectRequest) GetResumableUploadObjectTask() *gfsptask.GfSpResumableUploadObjectTask

func (*GfSpResumableUploadObjectRequest) Marshal 

func (m *GfSpResumableUploadObjectRequest) Marshal() (dAtA []byte, err error)

func (*GfSpResumableUploadObjectRequest) MarshalTo 

func (m *GfSpResumableUploadObjectRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectRequest) MarshalToSizedBuffer 

func (m *GfSpResumableUploadObjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectRequest) ProtoMessage 

func (*GfSpResumableUploadObjectRequest) ProtoMessage()

func (*GfSpResumableUploadObjectRequest) Reset 

func (m *GfSpResumableUploadObjectRequest) Reset()

func (*GfSpResumableUploadObjectRequest) Size 

func (m *GfSpResumableUploadObjectRequest) Size() (n int)

func (*GfSpResumableUploadObjectRequest) String 

func (m *GfSpResumableUploadObjectRequest) String() string

func (*GfSpResumableUploadObjectRequest) Unmarshal 

func (m *GfSpResumableUploadObjectRequest) Unmarshal(dAtA []byte) error

func (*GfSpResumableUploadObjectRequest) XXX_DiscardUnknown 

func (m *GfSpResumableUploadObjectRequest) XXX_DiscardUnknown()

func (*GfSpResumableUploadObjectRequest) XXX_Marshal 

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

func (*GfSpResumableUploadObjectRequest) XXX_Merge 

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

func (*GfSpResumableUploadObjectRequest) XXX_Size 

func (m *GfSpResumableUploadObjectRequest) XXX_Size() int

func (*GfSpResumableUploadObjectRequest) XXX_Unmarshal 

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

type GfSpResumableUploadObjectResponse 

type GfSpResumableUploadObjectResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpResumableUploadObjectResponse) Descriptor 

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

func (*GfSpResumableUploadObjectResponse) GetErr 

func (m *GfSpResumableUploadObjectResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpResumableUploadObjectResponse) Marshal 

func (m *GfSpResumableUploadObjectResponse) Marshal() (dAtA []byte, err error)

func (*GfSpResumableUploadObjectResponse) MarshalTo 

func (m *GfSpResumableUploadObjectResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectResponse) MarshalToSizedBuffer 

func (m *GfSpResumableUploadObjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpResumableUploadObjectResponse) ProtoMessage 

func (*GfSpResumableUploadObjectResponse) ProtoMessage()

func (*GfSpResumableUploadObjectResponse) Reset 

func (m *GfSpResumableUploadObjectResponse) Reset()

func (*GfSpResumableUploadObjectResponse) Size 

func (m *GfSpResumableUploadObjectResponse) Size() (n int)

func (*GfSpResumableUploadObjectResponse) String 

func (m *GfSpResumableUploadObjectResponse) String() string

func (*GfSpResumableUploadObjectResponse) Unmarshal 

func (m *GfSpResumableUploadObjectResponse) Unmarshal(dAtA []byte) error

func (*GfSpResumableUploadObjectResponse) XXX_DiscardUnknown 

func (m *GfSpResumableUploadObjectResponse) XXX_DiscardUnknown()

func (*GfSpResumableUploadObjectResponse) XXX_Marshal 

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

func (*GfSpResumableUploadObjectResponse) XXX_Merge 

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

func (*GfSpResumableUploadObjectResponse) XXX_Size 

func (m *GfSpResumableUploadObjectResponse) XXX_Size() int

func (*GfSpResumableUploadObjectResponse) XXX_Unmarshal 

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

type GfSpSetResourceLimitRequest 

type GfSpSetResourceLimitRequest struct {
	Limits map[string]*gfsplimit.GfSpLimit `` /* 153-byte string literal not displayed */
}

func (*GfSpSetResourceLimitRequest) Descriptor 

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

func (*GfSpSetResourceLimitRequest) GetLimits 

func (m *GfSpSetResourceLimitRequest) GetLimits() map[string]*gfsplimit.GfSpLimit

func (*GfSpSetResourceLimitRequest) Marshal 

func (m *GfSpSetResourceLimitRequest) Marshal() (dAtA []byte, err error)

func (*GfSpSetResourceLimitRequest) MarshalTo 

func (m *GfSpSetResourceLimitRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSetResourceLimitRequest) MarshalToSizedBuffer 

func (m *GfSpSetResourceLimitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSetResourceLimitRequest) ProtoMessage 

func (*GfSpSetResourceLimitRequest) ProtoMessage()

func (*GfSpSetResourceLimitRequest) Reset 

func (m *GfSpSetResourceLimitRequest) Reset()

func (*GfSpSetResourceLimitRequest) Size 

func (m *GfSpSetResourceLimitRequest) Size() (n int)

func (*GfSpSetResourceLimitRequest) String 

func (m *GfSpSetResourceLimitRequest) String() string

func (*GfSpSetResourceLimitRequest) Unmarshal 

func (m *GfSpSetResourceLimitRequest) Unmarshal(dAtA []byte) error

func (*GfSpSetResourceLimitRequest) XXX_DiscardUnknown 

func (m *GfSpSetResourceLimitRequest) XXX_DiscardUnknown()

func (*GfSpSetResourceLimitRequest) XXX_Marshal 

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

func (*GfSpSetResourceLimitRequest) XXX_Merge 

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

func (*GfSpSetResourceLimitRequest) XXX_Size 

func (m *GfSpSetResourceLimitRequest) XXX_Size() int

func (*GfSpSetResourceLimitRequest) XXX_Unmarshal 

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

type GfSpSetResourceLimitResponse 

type GfSpSetResourceLimitResponse struct {
	Err          *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	SuccessLists []string              `protobuf:"bytes,2,rep,name=success_lists,json=successLists,proto3" json:"success_lists,omitempty"`
}

func (*GfSpSetResourceLimitResponse) Descriptor 

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

func (*GfSpSetResourceLimitResponse) GetErr 

func (m *GfSpSetResourceLimitResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpSetResourceLimitResponse) GetSuccessLists 

func (m *GfSpSetResourceLimitResponse) GetSuccessLists() []string

func (*GfSpSetResourceLimitResponse) Marshal 

func (m *GfSpSetResourceLimitResponse) Marshal() (dAtA []byte, err error)

func (*GfSpSetResourceLimitResponse) MarshalTo 

func (m *GfSpSetResourceLimitResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSetResourceLimitResponse) MarshalToSizedBuffer 

func (m *GfSpSetResourceLimitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSetResourceLimitResponse) ProtoMessage 

func (*GfSpSetResourceLimitResponse) ProtoMessage()

func (*GfSpSetResourceLimitResponse) Reset 

func (m *GfSpSetResourceLimitResponse) Reset()

func (*GfSpSetResourceLimitResponse) Size 

func (m *GfSpSetResourceLimitResponse) Size() (n int)

func (*GfSpSetResourceLimitResponse) String 

func (m *GfSpSetResourceLimitResponse) String() string

func (*GfSpSetResourceLimitResponse) Unmarshal 

func (m *GfSpSetResourceLimitResponse) Unmarshal(dAtA []byte) error

func (*GfSpSetResourceLimitResponse) XXX_DiscardUnknown 

func (m *GfSpSetResourceLimitResponse) XXX_DiscardUnknown()

func (*GfSpSetResourceLimitResponse) XXX_Marshal 

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

func (*GfSpSetResourceLimitResponse) XXX_Merge 

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

func (*GfSpSetResourceLimitResponse) XXX_Size 

func (m *GfSpSetResourceLimitResponse) XXX_Size() int

func (*GfSpSetResourceLimitResponse) XXX_Unmarshal 

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

type GfSpSignRequest 

type GfSpSignRequest struct {
	// Types that are valid to be assigned to Request:
	//	*GfSpSignRequest_CreateBucketInfo
	//	*GfSpSignRequest_MigrateBucketInfo
	//	*GfSpSignRequest_CreateObjectInfo
	//	*GfSpSignRequest_SealObjectInfo
	//	*GfSpSignRequest_DiscontinueBucketInfo
	//	*GfSpSignRequest_SignSecondarySealBls
	//	*GfSpSignRequest_PingMsg
	//	*GfSpSignRequest_PongMsg
	//	*GfSpSignRequest_GfspReplicatePieceApprovalTask
	//	*GfSpSignRequest_GfspReceivePieceTask
	//	*GfSpSignRequest_GfspRecoverPieceTask
	//	*GfSpSignRequest_RejectObjectInfo
	//	*GfSpSignRequest_CreateGlobalVirtualGroup
	//	*GfSpSignRequest_GfspMigratePieceTask
	//	*GfSpSignRequest_CompleteMigrateBucket
	//	*GfSpSignRequest_SignSecondarySpMigrationBucket
	//	*GfSpSignRequest_SwapOut
	//	*GfSpSignRequest_SignSwapOut
	//	*GfSpSignRequest_CompleteSwapOut
	//	*GfSpSignRequest_SpExit
	//	*GfSpSignRequest_CompleteSpExit
	//	*GfSpSignRequest_SpStoragePrice
	Request isGfSpSignRequest_Request `protobuf_oneof:"request"`
}

func (*GfSpSignRequest) Descriptor 

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

func (*GfSpSignRequest) GetCompleteMigrateBucket 

func (m *GfSpSignRequest) GetCompleteMigrateBucket() *types1.MsgCompleteMigrateBucket

func (*GfSpSignRequest) GetCompleteSpExit 

func (m *GfSpSignRequest) GetCompleteSpExit() *types2.MsgCompleteStorageProviderExit

func (*GfSpSignRequest) GetCompleteSwapOut 

func (m *GfSpSignRequest) GetCompleteSwapOut() *types2.MsgCompleteSwapOut

func (*GfSpSignRequest) GetCreateBucketInfo 

func (m *GfSpSignRequest) GetCreateBucketInfo() *types1.MsgCreateBucket

func (*GfSpSignRequest) GetCreateGlobalVirtualGroup 

func (m *GfSpSignRequest) GetCreateGlobalVirtualGroup() *GfSpCreateGlobalVirtualGroup

func (*GfSpSignRequest) GetCreateObjectInfo 

func (m *GfSpSignRequest) GetCreateObjectInfo() *types1.MsgCreateObject

func (*GfSpSignRequest) GetDiscontinueBucketInfo 

func (m *GfSpSignRequest) GetDiscontinueBucketInfo() *types1.MsgDiscontinueBucket

func (*GfSpSignRequest) GetGfspMigratePieceTask 

func (m *GfSpSignRequest) GetGfspMigratePieceTask() *gfsptask.GfSpMigratePieceTask

func (*GfSpSignRequest) GetGfspReceivePieceTask 

func (m *GfSpSignRequest) GetGfspReceivePieceTask() *gfsptask.GfSpReceivePieceTask

func (*GfSpSignRequest) GetGfspRecoverPieceTask 

func (m *GfSpSignRequest) GetGfspRecoverPieceTask() *gfsptask.GfSpRecoverPieceTask

func (*GfSpSignRequest) GetGfspReplicatePieceApprovalTask 

func (m *GfSpSignRequest) GetGfspReplicatePieceApprovalTask() *gfsptask.GfSpReplicatePieceApprovalTask

func (*GfSpSignRequest) GetMigrateBucketInfo 

func (m *GfSpSignRequest) GetMigrateBucketInfo() *types1.MsgMigrateBucket

func (*GfSpSignRequest) GetPingMsg 

func (m *GfSpSignRequest) GetPingMsg() *gfspp2p.GfSpPing

func (*GfSpSignRequest) GetPongMsg 

func (m *GfSpSignRequest) GetPongMsg() *gfspp2p.GfSpPong

func (*GfSpSignRequest) GetRejectObjectInfo 

func (m *GfSpSignRequest) GetRejectObjectInfo() *types1.MsgRejectSealObject

func (*GfSpSignRequest) GetRequest 

func (m *GfSpSignRequest) GetRequest() isGfSpSignRequest_Request

func (*GfSpSignRequest) GetSealObjectInfo 

func (m *GfSpSignRequest) GetSealObjectInfo() *types1.MsgSealObject

func (*GfSpSignRequest) GetSignSecondarySealBls 

func (m *GfSpSignRequest) GetSignSecondarySealBls() *GfSpSignSecondarySealBls

func (*GfSpSignRequest) GetSignSecondarySpMigrationBucket 

func (m *GfSpSignRequest) GetSignSecondarySpMigrationBucket() *types1.SecondarySpMigrationBucketSignDoc

func (*GfSpSignRequest) GetSignSwapOut 

func (m *GfSpSignRequest) GetSignSwapOut() *types2.MsgSwapOut

func (*GfSpSignRequest) GetSpExit 

func (m *GfSpSignRequest) GetSpExit() *types2.MsgStorageProviderExit

func (*GfSpSignRequest) GetSpStoragePrice 

func (m *GfSpSignRequest) GetSpStoragePrice() *types3.MsgUpdateSpStoragePrice

func (*GfSpSignRequest) GetSwapOut 

func (m *GfSpSignRequest) GetSwapOut() *types2.MsgSwapOut

func (*GfSpSignRequest) Marshal 

func (m *GfSpSignRequest) Marshal() (dAtA []byte, err error)

func (*GfSpSignRequest) MarshalTo 

func (m *GfSpSignRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest) MarshalToSizedBuffer 

func (m *GfSpSignRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest) ProtoMessage 

func (*GfSpSignRequest) ProtoMessage()

func (*GfSpSignRequest) Reset 

func (m *GfSpSignRequest) Reset()

func (*GfSpSignRequest) Size 

func (m *GfSpSignRequest) Size() (n int)

func (*GfSpSignRequest) String 

func (m *GfSpSignRequest) String() string

func (*GfSpSignRequest) Unmarshal 

func (m *GfSpSignRequest) Unmarshal(dAtA []byte) error

func (*GfSpSignRequest) XXX_DiscardUnknown 

func (m *GfSpSignRequest) XXX_DiscardUnknown()

func (*GfSpSignRequest) XXX_Marshal 

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

func (*GfSpSignRequest) XXX_Merge 

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

func (*GfSpSignRequest) XXX_OneofWrappers 

func (*GfSpSignRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GfSpSignRequest) XXX_Size 

func (m *GfSpSignRequest) XXX_Size() int

func (*GfSpSignRequest) XXX_Unmarshal 

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

type GfSpSignRequest_CompleteMigrateBucket 

type GfSpSignRequest_CompleteMigrateBucket struct {
	CompleteMigrateBucket *types1.MsgCompleteMigrateBucket `` /* 133-byte string literal not displayed */
}

func (*GfSpSignRequest_CompleteMigrateBucket) MarshalTo 

func (m *GfSpSignRequest_CompleteMigrateBucket) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteMigrateBucket) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CompleteMigrateBucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteMigrateBucket) Size 

func (m *GfSpSignRequest_CompleteMigrateBucket) Size() (n int)

type GfSpSignRequest_CompleteSpExit 

type GfSpSignRequest_CompleteSpExit struct {
	CompleteSpExit *types2.MsgCompleteStorageProviderExit `protobuf:"bytes,21,opt,name=complete_sp_exit,json=completeSpExit,proto3,oneof" json:"complete_sp_exit,omitempty"`
}

func (*GfSpSignRequest_CompleteSpExit) MarshalTo 

func (m *GfSpSignRequest_CompleteSpExit) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteSpExit) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CompleteSpExit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteSpExit) Size 

func (m *GfSpSignRequest_CompleteSpExit) Size() (n int)

type GfSpSignRequest_CompleteSwapOut 

type GfSpSignRequest_CompleteSwapOut struct {
	CompleteSwapOut *types2.MsgCompleteSwapOut `protobuf:"bytes,19,opt,name=complete_swap_out,json=completeSwapOut,proto3,oneof" json:"complete_swap_out,omitempty"`
}

func (*GfSpSignRequest_CompleteSwapOut) MarshalTo 

func (m *GfSpSignRequest_CompleteSwapOut) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteSwapOut) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CompleteSwapOut) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CompleteSwapOut) Size 

func (m *GfSpSignRequest_CompleteSwapOut) Size() (n int)

type GfSpSignRequest_CreateBucketInfo 

type GfSpSignRequest_CreateBucketInfo struct {
	CreateBucketInfo *types1.MsgCreateBucket `protobuf:"bytes,1,opt,name=create_bucket_info,json=createBucketInfo,proto3,oneof" json:"create_bucket_info,omitempty"`
}

func (*GfSpSignRequest_CreateBucketInfo) MarshalTo 

func (m *GfSpSignRequest_CreateBucketInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateBucketInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CreateBucketInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateBucketInfo) Size 

func (m *GfSpSignRequest_CreateBucketInfo) Size() (n int)

type GfSpSignRequest_CreateGlobalVirtualGroup 

type GfSpSignRequest_CreateGlobalVirtualGroup struct {
	CreateGlobalVirtualGroup *GfSpCreateGlobalVirtualGroup `` /* 144-byte string literal not displayed */
}

func (*GfSpSignRequest_CreateGlobalVirtualGroup) MarshalTo 

func (m *GfSpSignRequest_CreateGlobalVirtualGroup) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateGlobalVirtualGroup) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CreateGlobalVirtualGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateGlobalVirtualGroup) Size 

func (m *GfSpSignRequest_CreateGlobalVirtualGroup) Size() (n int)

type GfSpSignRequest_CreateObjectInfo 

type GfSpSignRequest_CreateObjectInfo struct {
	CreateObjectInfo *types1.MsgCreateObject `protobuf:"bytes,3,opt,name=create_object_info,json=createObjectInfo,proto3,oneof" json:"create_object_info,omitempty"`
}

func (*GfSpSignRequest_CreateObjectInfo) MarshalTo 

func (m *GfSpSignRequest_CreateObjectInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateObjectInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_CreateObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_CreateObjectInfo) Size 

func (m *GfSpSignRequest_CreateObjectInfo) Size() (n int)

type GfSpSignRequest_DiscontinueBucketInfo 

type GfSpSignRequest_DiscontinueBucketInfo struct {
	DiscontinueBucketInfo *types1.MsgDiscontinueBucket `` /* 132-byte string literal not displayed */
}

func (*GfSpSignRequest_DiscontinueBucketInfo) MarshalTo 

func (m *GfSpSignRequest_DiscontinueBucketInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_DiscontinueBucketInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_DiscontinueBucketInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_DiscontinueBucketInfo) Size 

func (m *GfSpSignRequest_DiscontinueBucketInfo) Size() (n int)

type GfSpSignRequest_GfspMigratePieceTask 

type GfSpSignRequest_GfspMigratePieceTask struct {
	GfspMigratePieceTask *gfsptask.GfSpMigratePieceTask `` /* 132-byte string literal not displayed */
}

func (*GfSpSignRequest_GfspMigratePieceTask) MarshalTo 

func (m *GfSpSignRequest_GfspMigratePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspMigratePieceTask) MarshalToSizedBuffer 

func (m *GfSpSignRequest_GfspMigratePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspMigratePieceTask) Size 

func (m *GfSpSignRequest_GfspMigratePieceTask) Size() (n int)

type GfSpSignRequest_GfspReceivePieceTask 

type GfSpSignRequest_GfspReceivePieceTask struct {
	GfspReceivePieceTask *gfsptask.GfSpReceivePieceTask `` /* 132-byte string literal not displayed */
}

func (*GfSpSignRequest_GfspReceivePieceTask) MarshalTo 

func (m *GfSpSignRequest_GfspReceivePieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspReceivePieceTask) MarshalToSizedBuffer 

func (m *GfSpSignRequest_GfspReceivePieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspReceivePieceTask) Size 

func (m *GfSpSignRequest_GfspReceivePieceTask) Size() (n int)

type GfSpSignRequest_GfspRecoverPieceTask 

type GfSpSignRequest_GfspRecoverPieceTask struct {
	GfspRecoverPieceTask *gfsptask.GfSpRecoverPieceTask `` /* 132-byte string literal not displayed */
}

func (*GfSpSignRequest_GfspRecoverPieceTask) MarshalTo 

func (m *GfSpSignRequest_GfspRecoverPieceTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspRecoverPieceTask) MarshalToSizedBuffer 

func (m *GfSpSignRequest_GfspRecoverPieceTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspRecoverPieceTask) Size 

func (m *GfSpSignRequest_GfspRecoverPieceTask) Size() (n int)

type GfSpSignRequest_GfspReplicatePieceApprovalTask 

type GfSpSignRequest_GfspReplicatePieceApprovalTask struct {
	GfspReplicatePieceApprovalTask *gfsptask.GfSpReplicatePieceApprovalTask `` /* 163-byte string literal not displayed */
}

func (*GfSpSignRequest_GfspReplicatePieceApprovalTask) MarshalTo 

func (m *GfSpSignRequest_GfspReplicatePieceApprovalTask) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspReplicatePieceApprovalTask) MarshalToSizedBuffer 

func (m *GfSpSignRequest_GfspReplicatePieceApprovalTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_GfspReplicatePieceApprovalTask) Size 

func (m *GfSpSignRequest_GfspReplicatePieceApprovalTask) Size() (n int)

type GfSpSignRequest_MigrateBucketInfo 

type GfSpSignRequest_MigrateBucketInfo struct {
	MigrateBucketInfo *types1.MsgMigrateBucket `protobuf:"bytes,2,opt,name=migrate_bucket_info,json=migrateBucketInfo,proto3,oneof" json:"migrate_bucket_info,omitempty"`
}

func (*GfSpSignRequest_MigrateBucketInfo) MarshalTo 

func (m *GfSpSignRequest_MigrateBucketInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_MigrateBucketInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_MigrateBucketInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_MigrateBucketInfo) Size 

func (m *GfSpSignRequest_MigrateBucketInfo) Size() (n int)

type GfSpSignRequest_PingMsg 

type GfSpSignRequest_PingMsg struct {
	PingMsg *gfspp2p.GfSpPing `protobuf:"bytes,7,opt,name=ping_msg,json=pingMsg,proto3,oneof" json:"ping_msg,omitempty"`
}

func (*GfSpSignRequest_PingMsg) MarshalTo 

func (m *GfSpSignRequest_PingMsg) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_PingMsg) MarshalToSizedBuffer 

func (m *GfSpSignRequest_PingMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_PingMsg) Size 

func (m *GfSpSignRequest_PingMsg) Size() (n int)

type GfSpSignRequest_PongMsg 

type GfSpSignRequest_PongMsg struct {
	PongMsg *gfspp2p.GfSpPong `protobuf:"bytes,8,opt,name=pong_msg,json=pongMsg,proto3,oneof" json:"pong_msg,omitempty"`
}

func (*GfSpSignRequest_PongMsg) MarshalTo 

func (m *GfSpSignRequest_PongMsg) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_PongMsg) MarshalToSizedBuffer 

func (m *GfSpSignRequest_PongMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_PongMsg) Size 

func (m *GfSpSignRequest_PongMsg) Size() (n int)

type GfSpSignRequest_RejectObjectInfo 

type GfSpSignRequest_RejectObjectInfo struct {
	RejectObjectInfo *types1.MsgRejectSealObject `protobuf:"bytes,12,opt,name=reject_object_info,json=rejectObjectInfo,proto3,oneof" json:"reject_object_info,omitempty"`
}

func (*GfSpSignRequest_RejectObjectInfo) MarshalTo 

func (m *GfSpSignRequest_RejectObjectInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_RejectObjectInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_RejectObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_RejectObjectInfo) Size 

func (m *GfSpSignRequest_RejectObjectInfo) Size() (n int)

type GfSpSignRequest_SealObjectInfo 

type GfSpSignRequest_SealObjectInfo struct {
	SealObjectInfo *types1.MsgSealObject `protobuf:"bytes,4,opt,name=seal_object_info,json=sealObjectInfo,proto3,oneof" json:"seal_object_info,omitempty"`
}

func (*GfSpSignRequest_SealObjectInfo) MarshalTo 

func (m *GfSpSignRequest_SealObjectInfo) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SealObjectInfo) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SealObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SealObjectInfo) Size 

func (m *GfSpSignRequest_SealObjectInfo) Size() (n int)

type GfSpSignRequest_SignSecondarySealBls 

type GfSpSignRequest_SignSecondarySealBls struct {
	SignSecondarySealBls *GfSpSignSecondarySealBls `` /* 131-byte string literal not displayed */
}

func (*GfSpSignRequest_SignSecondarySealBls) MarshalTo 

func (m *GfSpSignRequest_SignSecondarySealBls) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSecondarySealBls) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SignSecondarySealBls) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSecondarySealBls) Size 

func (m *GfSpSignRequest_SignSecondarySealBls) Size() (n int)

type GfSpSignRequest_SignSecondarySpMigrationBucket 

type GfSpSignRequest_SignSecondarySpMigrationBucket struct {
	SignSecondarySpMigrationBucket *types1.SecondarySpMigrationBucketSignDoc `` /* 164-byte string literal not displayed */
}

func (*GfSpSignRequest_SignSecondarySpMigrationBucket) MarshalTo 

func (m *GfSpSignRequest_SignSecondarySpMigrationBucket) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSecondarySpMigrationBucket) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SignSecondarySpMigrationBucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSecondarySpMigrationBucket) Size 

func (m *GfSpSignRequest_SignSecondarySpMigrationBucket) Size() (n int)

type GfSpSignRequest_SignSwapOut 

type GfSpSignRequest_SignSwapOut struct {
	SignSwapOut *types2.MsgSwapOut `protobuf:"bytes,18,opt,name=sign_swap_out,json=signSwapOut,proto3,oneof" json:"sign_swap_out,omitempty"`
}

func (*GfSpSignRequest_SignSwapOut) MarshalTo 

func (m *GfSpSignRequest_SignSwapOut) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSwapOut) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SignSwapOut) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SignSwapOut) Size 

func (m *GfSpSignRequest_SignSwapOut) Size() (n int)

type GfSpSignRequest_SpExit 

type GfSpSignRequest_SpExit struct {
	SpExit *types2.MsgStorageProviderExit `protobuf:"bytes,20,opt,name=sp_exit,json=spExit,proto3,oneof" json:"sp_exit,omitempty"`
}

func (*GfSpSignRequest_SpExit) MarshalTo 

func (m *GfSpSignRequest_SpExit) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SpExit) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SpExit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SpExit) Size 

func (m *GfSpSignRequest_SpExit) Size() (n int)

type GfSpSignRequest_SpStoragePrice 

type GfSpSignRequest_SpStoragePrice struct {
	SpStoragePrice *types3.MsgUpdateSpStoragePrice `protobuf:"bytes,22,opt,name=sp_storage_price,json=spStoragePrice,proto3,oneof" json:"sp_storage_price,omitempty"`
}

func (*GfSpSignRequest_SpStoragePrice) MarshalTo 

func (m *GfSpSignRequest_SpStoragePrice) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SpStoragePrice) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SpStoragePrice) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SpStoragePrice) Size 

func (m *GfSpSignRequest_SpStoragePrice) Size() (n int)

type GfSpSignRequest_SwapOut 

type GfSpSignRequest_SwapOut struct {
	SwapOut *types2.MsgSwapOut `protobuf:"bytes,17,opt,name=swap_out,json=swapOut,proto3,oneof" json:"swap_out,omitempty"`
}

func (*GfSpSignRequest_SwapOut) MarshalTo 

func (m *GfSpSignRequest_SwapOut) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignRequest_SwapOut) MarshalToSizedBuffer 

func (m *GfSpSignRequest_SwapOut) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignRequest_SwapOut) Size 

func (m *GfSpSignRequest_SwapOut) Size() (n int)

type GfSpSignResponse 

type GfSpSignResponse struct {
	Err       *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Signature []byte                `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	TxHash    string                `protobuf:"bytes,3,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

func (*GfSpSignResponse) Descriptor 

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

func (*GfSpSignResponse) GetErr 

func (m *GfSpSignResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpSignResponse) GetSignature 

func (m *GfSpSignResponse) GetSignature() []byte

func (*GfSpSignResponse) GetTxHash 

func (m *GfSpSignResponse) GetTxHash() string

func (*GfSpSignResponse) Marshal 

func (m *GfSpSignResponse) Marshal() (dAtA []byte, err error)

func (*GfSpSignResponse) MarshalTo 

func (m *GfSpSignResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignResponse) MarshalToSizedBuffer 

func (m *GfSpSignResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignResponse) ProtoMessage 

func (*GfSpSignResponse) ProtoMessage()

func (*GfSpSignResponse) Reset 

func (m *GfSpSignResponse) Reset()

func (*GfSpSignResponse) Size 

func (m *GfSpSignResponse) Size() (n int)

func (*GfSpSignResponse) String 

func (m *GfSpSignResponse) String() string

func (*GfSpSignResponse) Unmarshal 

func (m *GfSpSignResponse) Unmarshal(dAtA []byte) error

func (*GfSpSignResponse) XXX_DiscardUnknown 

func (m *GfSpSignResponse) XXX_DiscardUnknown()

func (*GfSpSignResponse) XXX_Marshal 

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

func (*GfSpSignResponse) XXX_Merge 

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

func (*GfSpSignResponse) XXX_Size 

func (m *GfSpSignResponse) XXX_Size() int

func (*GfSpSignResponse) XXX_Unmarshal 

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

type GfSpSignSecondarySealBls 

type GfSpSignSecondarySealBls struct {
	ObjectId             uint64   `protobuf:"varint,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	GlobalVirtualGroupId uint32   `` /* 126-byte string literal not displayed */
	Checksums            [][]byte `protobuf:"bytes,3,rep,name=checksums,proto3" json:"checksums,omitempty"`
}

func (*GfSpSignSecondarySealBls) Descriptor 

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

func (*GfSpSignSecondarySealBls) GetChecksums 

func (m *GfSpSignSecondarySealBls) GetChecksums() [][]byte

func (*GfSpSignSecondarySealBls) GetGlobalVirtualGroupId 

func (m *GfSpSignSecondarySealBls) GetGlobalVirtualGroupId() uint32

func (*GfSpSignSecondarySealBls) GetObjectId 

func (m *GfSpSignSecondarySealBls) GetObjectId() uint64

func (*GfSpSignSecondarySealBls) Marshal 

func (m *GfSpSignSecondarySealBls) Marshal() (dAtA []byte, err error)

func (*GfSpSignSecondarySealBls) MarshalTo 

func (m *GfSpSignSecondarySealBls) MarshalTo(dAtA []byte) (int, error)

func (*GfSpSignSecondarySealBls) MarshalToSizedBuffer 

func (m *GfSpSignSecondarySealBls) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpSignSecondarySealBls) ProtoMessage 

func (*GfSpSignSecondarySealBls) ProtoMessage()

func (*GfSpSignSecondarySealBls) Reset 

func (m *GfSpSignSecondarySealBls) Reset()

func (*GfSpSignSecondarySealBls) Size 

func (m *GfSpSignSecondarySealBls) Size() (n int)

func (*GfSpSignSecondarySealBls) String 

func (m *GfSpSignSecondarySealBls) String() string

func (*GfSpSignSecondarySealBls) Unmarshal 

func (m *GfSpSignSecondarySealBls) Unmarshal(dAtA []byte) error

func (*GfSpSignSecondarySealBls) XXX_DiscardUnknown 

func (m *GfSpSignSecondarySealBls) XXX_DiscardUnknown()

func (*GfSpSignSecondarySealBls) XXX_Marshal 

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

func (*GfSpSignSecondarySealBls) XXX_Merge 

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

func (*GfSpSignSecondarySealBls) XXX_Size 

func (m *GfSpSignSecondarySealBls) XXX_Size() int

func (*GfSpSignSecondarySealBls) XXX_Unmarshal 

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

type GfSpSignServiceClient 

type GfSpSignServiceClient interface {
	GfSpSign(ctx context.Context, in *GfSpSignRequest, opts ...grpc.CallOption) (*GfSpSignResponse, error)
}

GfSpSignServiceClient is the client API for GfSpSignService service.

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

func NewGfSpSignServiceClient 

func NewGfSpSignServiceClient(cc grpc1.ClientConn) GfSpSignServiceClient

type GfSpSignServiceServer 

type GfSpSignServiceServer interface {
	GfSpSign(context.Context, *GfSpSignRequest) (*GfSpSignResponse, error)
}

GfSpSignServiceServer is the server API for GfSpSignService service.

type GfSpUploadObjectRequest 

type GfSpUploadObjectRequest struct {
	UploadObjectTask *gfsptask.GfSpUploadObjectTask `protobuf:"bytes,1,opt,name=upload_object_task,json=uploadObjectTask,proto3" json:"upload_object_task,omitempty"`
	Payload          []byte                         `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*GfSpUploadObjectRequest) Descriptor 

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

func (*GfSpUploadObjectRequest) GetPayload 

func (m *GfSpUploadObjectRequest) GetPayload() []byte

func (*GfSpUploadObjectRequest) GetUploadObjectTask 

func (m *GfSpUploadObjectRequest) GetUploadObjectTask() *gfsptask.GfSpUploadObjectTask

func (*GfSpUploadObjectRequest) Marshal 

func (m *GfSpUploadObjectRequest) Marshal() (dAtA []byte, err error)

func (*GfSpUploadObjectRequest) MarshalTo 

func (m *GfSpUploadObjectRequest) MarshalTo(dAtA []byte) (int, error)

func (*GfSpUploadObjectRequest) MarshalToSizedBuffer 

func (m *GfSpUploadObjectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpUploadObjectRequest) ProtoMessage 

func (*GfSpUploadObjectRequest) ProtoMessage()

func (*GfSpUploadObjectRequest) Reset 

func (m *GfSpUploadObjectRequest) Reset()

func (*GfSpUploadObjectRequest) Size 

func (m *GfSpUploadObjectRequest) Size() (n int)

func (*GfSpUploadObjectRequest) String 

func (m *GfSpUploadObjectRequest) String() string

func (*GfSpUploadObjectRequest) Unmarshal 

func (m *GfSpUploadObjectRequest) Unmarshal(dAtA []byte) error

func (*GfSpUploadObjectRequest) XXX_DiscardUnknown 

func (m *GfSpUploadObjectRequest) XXX_DiscardUnknown()

func (*GfSpUploadObjectRequest) XXX_Marshal 

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

func (*GfSpUploadObjectRequest) XXX_Merge 

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

func (*GfSpUploadObjectRequest) XXX_Size 

func (m *GfSpUploadObjectRequest) XXX_Size() int

func (*GfSpUploadObjectRequest) XXX_Unmarshal 

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

type GfSpUploadObjectResponse 

type GfSpUploadObjectResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GfSpUploadObjectResponse) Descriptor 

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

func (*GfSpUploadObjectResponse) GetErr 

func (m *GfSpUploadObjectResponse) GetErr() *gfsperrors.GfSpError

func (*GfSpUploadObjectResponse) Marshal 

func (m *GfSpUploadObjectResponse) Marshal() (dAtA []byte, err error)

func (*GfSpUploadObjectResponse) MarshalTo 

func (m *GfSpUploadObjectResponse) MarshalTo(dAtA []byte) (int, error)

func (*GfSpUploadObjectResponse) MarshalToSizedBuffer 

func (m *GfSpUploadObjectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GfSpUploadObjectResponse) ProtoMessage 

func (*GfSpUploadObjectResponse) ProtoMessage()

func (*GfSpUploadObjectResponse) Reset 

func (m *GfSpUploadObjectResponse) Reset()

func (*GfSpUploadObjectResponse) Size 

func (m *GfSpUploadObjectResponse) Size() (n int)

func (*GfSpUploadObjectResponse) String 

func (m *GfSpUploadObjectResponse) String() string

func (*GfSpUploadObjectResponse) Unmarshal 

func (m *GfSpUploadObjectResponse) Unmarshal(dAtA []byte) error

func (*GfSpUploadObjectResponse) XXX_DiscardUnknown 

func (m *GfSpUploadObjectResponse) XXX_DiscardUnknown()

func (*GfSpUploadObjectResponse) XXX_Marshal 

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

func (*GfSpUploadObjectResponse) XXX_Merge 

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

func (*GfSpUploadObjectResponse) XXX_Size 

func (m *GfSpUploadObjectResponse) XXX_Size() int

func (*GfSpUploadObjectResponse) XXX_Unmarshal 

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

type GfSpUploadServiceClient 

type GfSpUploadServiceClient interface {
	GfSpUploadObject(ctx context.Context, opts ...grpc.CallOption) (GfSpUploadService_GfSpUploadObjectClient, error)
	// TODO(chris): It is recommended to use the segment buffer as a single request instead of the GRPC stream, as the performance
	//  of the GRPC stream is not satisfactory.
	GfSpResumableUploadObject(ctx context.Context, opts ...grpc.CallOption) (GfSpUploadService_GfSpResumableUploadObjectClient, error)
}

GfSpUploadServiceClient is the client API for GfSpUploadService service.

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

func NewGfSpUploadServiceClient 

func NewGfSpUploadServiceClient(cc grpc1.ClientConn) GfSpUploadServiceClient

type GfSpUploadServiceServer 

type GfSpUploadServiceServer interface {
	GfSpUploadObject(GfSpUploadService_GfSpUploadObjectServer) error
	// TODO(chris): It is recommended to use the segment buffer as a single request instead of the GRPC stream, as the performance
	//  of the GRPC stream is not satisfactory.
	GfSpResumableUploadObject(GfSpUploadService_GfSpResumableUploadObjectServer) error
}

GfSpUploadServiceServer is the server API for GfSpUploadService service.

type GfSpUploadService_GfSpResumableUploadObjectClient 

type GfSpUploadService_GfSpResumableUploadObjectClient interface {
	Send(*GfSpResumableUploadObjectRequest) error
	CloseAndRecv() (*GfSpResumableUploadObjectResponse, error)
	grpc.ClientStream
}

type GfSpUploadService_GfSpResumableUploadObjectServer 

type GfSpUploadService_GfSpResumableUploadObjectServer interface {
	SendAndClose(*GfSpResumableUploadObjectResponse) error
	Recv() (*GfSpResumableUploadObjectRequest, error)
	grpc.ServerStream
}

type GfSpUploadService_GfSpUploadObjectClient 

type GfSpUploadService_GfSpUploadObjectClient interface {
	Send(*GfSpUploadObjectRequest) error
	CloseAndRecv() (*GfSpUploadObjectResponse, error)
	grpc.ClientStream
}

type GfSpUploadService_GfSpUploadObjectServer 

type GfSpUploadService_GfSpUploadObjectServer interface {
	SendAndClose(*GfSpUploadObjectResponse) error
	Recv() (*GfSpUploadObjectRequest, error)
	grpc.ServerStream
}

type SwapOutUnit 

type SwapOutUnit struct {
	SwapOutKey    string            `protobuf:"bytes,1,opt,name=swap_out_key,json=swapOutKey,proto3" json:"swap_out_key,omitempty"`
	Status        int32             `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	SuccessorSpId uint32            `protobuf:"varint,3,opt,name=successor_sp_id,json=successorSpId,proto3" json:"successor_sp_id,omitempty"`
	GvgTask       []*GfSpMigrateGVG `protobuf:"bytes,4,rep,name=gvg_task,json=gvgTask,proto3" json:"gvg_task,omitempty"`
}

func (*SwapOutUnit) Descriptor 

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

func (*SwapOutUnit) GetGvgTask 

func (m *SwapOutUnit) GetGvgTask() []*GfSpMigrateGVG

func (*SwapOutUnit) GetStatus 

func (m *SwapOutUnit) GetStatus() int32

func (*SwapOutUnit) GetSuccessorSpId 

func (m *SwapOutUnit) GetSuccessorSpId() uint32

func (*SwapOutUnit) GetSwapOutKey 

func (m *SwapOutUnit) GetSwapOutKey() string

func (*SwapOutUnit) Marshal 

func (m *SwapOutUnit) Marshal() (dAtA []byte, err error)

func (*SwapOutUnit) MarshalTo 

func (m *SwapOutUnit) MarshalTo(dAtA []byte) (int, error)

func (*SwapOutUnit) MarshalToSizedBuffer 

func (m *SwapOutUnit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SwapOutUnit) ProtoMessage 

func (*SwapOutUnit) ProtoMessage()

func (*SwapOutUnit) Reset 

func (m *SwapOutUnit) Reset()

func (*SwapOutUnit) Size 

func (m *SwapOutUnit) Size() (n int)

func (*SwapOutUnit) String 

func (m *SwapOutUnit) String() string

func (*SwapOutUnit) Unmarshal 

func (m *SwapOutUnit) Unmarshal(dAtA []byte) error

func (*SwapOutUnit) XXX_DiscardUnknown 

func (m *SwapOutUnit) XXX_DiscardUnknown()

func (*SwapOutUnit) XXX_Marshal 

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

func (*SwapOutUnit) XXX_Merge 

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

func (*SwapOutUnit) XXX_Size 

func (m *SwapOutUnit) XXX_Size() int

func (*SwapOutUnit) XXX_Unmarshal 

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

type UnimplementedGfSpApprovalServiceServer 

type UnimplementedGfSpApprovalServiceServer struct {
}

UnimplementedGfSpApprovalServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpApprovalServiceServer) GfSpAskApproval 

func (*UnimplementedGfSpApprovalServiceServer) GfSpAskApproval(ctx context.Context, req *GfSpAskApprovalRequest) (*GfSpAskApprovalResponse, error)

type UnimplementedGfSpAuthenticationServiceServer 

type UnimplementedGfSpAuthenticationServiceServer struct {
}

UnimplementedGfSpAuthenticationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpAuthenticationServiceServer) GetAuthNonce 

func (*UnimplementedGfSpAuthenticationServiceServer) GetAuthNonce(ctx context.Context, req *GetAuthNonceRequest) (*GetAuthNonceResponse, error)

func (*UnimplementedGfSpAuthenticationServiceServer) GfSpVerifyAuthentication 

func (*UnimplementedGfSpAuthenticationServiceServer) GfSpVerifyAuthentication(ctx context.Context, req *GfSpAuthenticationRequest) (*GfSpAuthenticationResponse, error)

func (*UnimplementedGfSpAuthenticationServiceServer) UpdateUserPublicKey 

func (*UnimplementedGfSpAuthenticationServiceServer) UpdateUserPublicKey(ctx context.Context, req *UpdateUserPublicKeyRequest) (*UpdateUserPublicKeyResponse, error)

func (*UnimplementedGfSpAuthenticationServiceServer) VerifyGNFD1EddsaSignature 

func (*UnimplementedGfSpAuthenticationServiceServer) VerifyGNFD1EddsaSignature(ctx context.Context, req *VerifyGNFD1EddsaSignatureRequest) (*VerifyGNFD1EddsaSignatureResponse, error)

type UnimplementedGfSpDownloadServiceServer 

type UnimplementedGfSpDownloadServiceServer struct {
}

UnimplementedGfSpDownloadServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpDownloadServiceServer) GfSpDownloadObject 

func (*UnimplementedGfSpDownloadServiceServer) GfSpDownloadObject(ctx context.Context, req *GfSpDownloadObjectRequest) (*GfSpDownloadObjectResponse, error)

func (*UnimplementedGfSpDownloadServiceServer) GfSpDownloadPiece 

func (*UnimplementedGfSpDownloadServiceServer) GfSpDownloadPiece(ctx context.Context, req *GfSpDownloadPieceRequest) (*GfSpDownloadPieceResponse, error)

func (*UnimplementedGfSpDownloadServiceServer) GfSpGetChallengeInfo 

func (*UnimplementedGfSpDownloadServiceServer) GfSpGetChallengeInfo(ctx context.Context, req *GfSpGetChallengeInfoRequest) (*GfSpGetChallengeInfoResponse, error)

type UnimplementedGfSpManageServiceServer 

type UnimplementedGfSpManageServiceServer struct {
}

UnimplementedGfSpManageServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpManageServiceServer) GfSpAskTask 

func (*UnimplementedGfSpManageServiceServer) GfSpAskTask(ctx context.Context, req *GfSpAskTaskRequest) (*GfSpAskTaskResponse, error)

func (*UnimplementedGfSpManageServiceServer) GfSpBeginTask 

func (*UnimplementedGfSpManageServiceServer) GfSpBeginTask(ctx context.Context, req *GfSpBeginTaskRequest) (*GfSpBeginTaskResponse, error)

func (*UnimplementedGfSpManageServiceServer) GfSpNotifyMigrateSwapOut 

func (*UnimplementedGfSpManageServiceServer) GfSpNotifyMigrateSwapOut(ctx context.Context, req *GfSpNotifyMigrateSwapOutRequest) (*GfSpNotifyMigrateSwapOutResponse, error)

func (*UnimplementedGfSpManageServiceServer) GfSpPickVirtualGroupFamily 

func (*UnimplementedGfSpManageServiceServer) GfSpPickVirtualGroupFamily(ctx context.Context, req *GfSpPickVirtualGroupFamilyRequest) (*GfSpPickVirtualGroupFamilyResponse, error)

func (*UnimplementedGfSpManageServiceServer) GfSpReportTask 

func (*UnimplementedGfSpManageServiceServer) GfSpReportTask(ctx context.Context, req *GfSpReportTaskRequest) (*GfSpReportTaskResponse, error)

type UnimplementedGfSpP2PServiceServer 

type UnimplementedGfSpP2PServiceServer struct {
}

UnimplementedGfSpP2PServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpP2PServiceServer) GfSpAskSecondaryReplicatePieceApproval 

func (*UnimplementedGfSpP2PServiceServer) GfSpAskSecondaryReplicatePieceApproval(ctx context.Context, req *GfSpAskSecondaryReplicatePieceApprovalRequest) (*GfSpAskSecondaryReplicatePieceApprovalResponse, error)

func (*UnimplementedGfSpP2PServiceServer) GfSpQueryP2PBootstrap 

func (*UnimplementedGfSpP2PServiceServer) GfSpQueryP2PBootstrap(ctx context.Context, req *GfSpQueryP2PNodeRequest) (*GfSpQueryP2PNodeResponse, error)

type UnimplementedGfSpQueryTaskServiceServer 

type UnimplementedGfSpQueryTaskServiceServer struct {
}

UnimplementedGfSpQueryTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQueryBucketMigrate 

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQueryBucketMigrate(ctx context.Context, req *GfSpQueryBucketMigrateRequest) (*GfSpQueryBucketMigrateResponse, error)

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQuerySpExit 

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQuerySpExit(ctx context.Context, req *GfSpQuerySpExitRequest) (*GfSpQuerySpExitResponse, error)

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQueryTasks 

func (*UnimplementedGfSpQueryTaskServiceServer) GfSpQueryTasks(ctx context.Context, req *GfSpQueryTasksRequest) (*GfSpQueryTasksResponse, error)

type UnimplementedGfSpReceiveServiceServer 

type UnimplementedGfSpReceiveServiceServer struct {
}

UnimplementedGfSpReceiveServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpReceiveServiceServer) GfSpDoneReplicatePiece 

func (*UnimplementedGfSpReceiveServiceServer) GfSpDoneReplicatePiece(ctx context.Context, req *GfSpDoneReplicatePieceRequest) (*GfSpDoneReplicatePieceResponse, error)

func (*UnimplementedGfSpReceiveServiceServer) GfSpReplicatePiece 

func (*UnimplementedGfSpReceiveServiceServer) GfSpReplicatePiece(ctx context.Context, req *GfSpReplicatePieceRequest) (*GfSpReplicatePieceResponse, error)

type UnimplementedGfSpResourceServiceServer 

type UnimplementedGfSpResourceServiceServer struct {
}

UnimplementedGfSpResourceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpResourceServiceServer) GfSpQueryResourceLimit 

func (*UnimplementedGfSpResourceServiceServer) GfSpQueryResourceLimit(ctx context.Context, req *GfSpQueryResourceLimitRequest) (*GfSpQueryResourceLimitResponse, error)

func (*UnimplementedGfSpResourceServiceServer) GfSpSetResourceLimit 

func (*UnimplementedGfSpResourceServiceServer) GfSpSetResourceLimit(ctx context.Context, req *GfSpSetResourceLimitRequest) (*GfSpSetResourceLimitResponse, error)

type UnimplementedGfSpSignServiceServer 

type UnimplementedGfSpSignServiceServer struct {
}

UnimplementedGfSpSignServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpSignServiceServer) GfSpSign 

func (*UnimplementedGfSpSignServiceServer) GfSpSign(ctx context.Context, req *GfSpSignRequest) (*GfSpSignResponse, error)

type UnimplementedGfSpUploadServiceServer 

type UnimplementedGfSpUploadServiceServer struct {
}

UnimplementedGfSpUploadServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpUploadServiceServer) GfSpResumableUploadObject 

func (*UnimplementedGfSpUploadServiceServer) GfSpResumableUploadObject(srv GfSpUploadService_GfSpResumableUploadObjectServer) error

func (*UnimplementedGfSpUploadServiceServer) GfSpUploadObject 

func (*UnimplementedGfSpUploadServiceServer) GfSpUploadObject(srv GfSpUploadService_GfSpUploadObjectServer) error

type UpdateUserPublicKeyRequest 

type UpdateUserPublicKeyRequest struct {
	// account_id is the account address of user
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// domain is the DApp domain for which the public key is updated
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// current_nonce is the current_nonce value for which the existing public key is matching
	CurrentNonce int32 `protobuf:"varint,3,opt,name=current_nonce,json=currentNonce,proto3" json:"current_nonce,omitempty"`
	// nonce is the nonce value for which the public key is updated
	Nonce int32 `protobuf:"varint,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// user_public_key is the public key value to update in SP database
	UserPublicKey string `protobuf:"bytes,5,opt,name=user_public_key,json=userPublicKey,proto3" json:"user_public_key,omitempty"`
	// expiry_date is the expiry timestamp of the public key
	ExpiryDate int64 `protobuf:"varint,6,opt,name=expiry_date,json=expiryDate,proto3" json:"expiry_date,omitempty"`
}

UpdateUserPublicKeyRequest is request type for the UpdateUserPublicKey RPC method.

func (*UpdateUserPublicKeyRequest) Descriptor 

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

func (*UpdateUserPublicKeyRequest) GetAccountId 

func (m *UpdateUserPublicKeyRequest) GetAccountId() string

func (*UpdateUserPublicKeyRequest) GetCurrentNonce 

func (m *UpdateUserPublicKeyRequest) GetCurrentNonce() int32

func (*UpdateUserPublicKeyRequest) GetDomain 

func (m *UpdateUserPublicKeyRequest) GetDomain() string

func (*UpdateUserPublicKeyRequest) GetExpiryDate 

func (m *UpdateUserPublicKeyRequest) GetExpiryDate() int64

func (*UpdateUserPublicKeyRequest) GetNonce 

func (m *UpdateUserPublicKeyRequest) GetNonce() int32

func (*UpdateUserPublicKeyRequest) GetUserPublicKey 

func (m *UpdateUserPublicKeyRequest) GetUserPublicKey() string

func (*UpdateUserPublicKeyRequest) Marshal 

func (m *UpdateUserPublicKeyRequest) Marshal() (dAtA []byte, err error)

func (*UpdateUserPublicKeyRequest) MarshalTo 

func (m *UpdateUserPublicKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateUserPublicKeyRequest) MarshalToSizedBuffer 

func (m *UpdateUserPublicKeyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateUserPublicKeyRequest) ProtoMessage 

func (*UpdateUserPublicKeyRequest) ProtoMessage()

func (*UpdateUserPublicKeyRequest) Reset 

func (m *UpdateUserPublicKeyRequest) Reset()

func (*UpdateUserPublicKeyRequest) Size 

func (m *UpdateUserPublicKeyRequest) Size() (n int)

func (*UpdateUserPublicKeyRequest) String 

func (m *UpdateUserPublicKeyRequest) String() string

func (*UpdateUserPublicKeyRequest) Unmarshal 

func (m *UpdateUserPublicKeyRequest) Unmarshal(dAtA []byte) error

func (*UpdateUserPublicKeyRequest) XXX_DiscardUnknown 

func (m *UpdateUserPublicKeyRequest) XXX_DiscardUnknown()

func (*UpdateUserPublicKeyRequest) XXX_Marshal 

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

func (*UpdateUserPublicKeyRequest) XXX_Merge 

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

func (*UpdateUserPublicKeyRequest) XXX_Size 

func (m *UpdateUserPublicKeyRequest) XXX_Size() int

func (*UpdateUserPublicKeyRequest) XXX_Unmarshal 

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

type UpdateUserPublicKeyResponse 

type UpdateUserPublicKeyResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// result defines the result of if the user public key is updated
	Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
}

UpdateUserPublicKeyResponse is response type for the UpdateUserPublicKey RPC method.

func (*UpdateUserPublicKeyResponse) Descriptor 

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

func (*UpdateUserPublicKeyResponse) GetErr 

func (m *UpdateUserPublicKeyResponse) GetErr() *gfsperrors.GfSpError

func (*UpdateUserPublicKeyResponse) GetResult 

func (m *UpdateUserPublicKeyResponse) GetResult() bool

func (*UpdateUserPublicKeyResponse) Marshal 

func (m *UpdateUserPublicKeyResponse) Marshal() (dAtA []byte, err error)

func (*UpdateUserPublicKeyResponse) MarshalTo 

func (m *UpdateUserPublicKeyResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateUserPublicKeyResponse) MarshalToSizedBuffer 

func (m *UpdateUserPublicKeyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateUserPublicKeyResponse) ProtoMessage 

func (*UpdateUserPublicKeyResponse) ProtoMessage()

func (*UpdateUserPublicKeyResponse) Reset 

func (m *UpdateUserPublicKeyResponse) Reset()

func (*UpdateUserPublicKeyResponse) Size 

func (m *UpdateUserPublicKeyResponse) Size() (n int)

func (*UpdateUserPublicKeyResponse) String 

func (m *UpdateUserPublicKeyResponse) String() string

func (*UpdateUserPublicKeyResponse) Unmarshal 

func (m *UpdateUserPublicKeyResponse) Unmarshal(dAtA []byte) error

func (*UpdateUserPublicKeyResponse) XXX_DiscardUnknown 

func (m *UpdateUserPublicKeyResponse) XXX_DiscardUnknown()

func (*UpdateUserPublicKeyResponse) XXX_Marshal 

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

func (*UpdateUserPublicKeyResponse) XXX_Merge 

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

func (*UpdateUserPublicKeyResponse) XXX_Size 

func (m *UpdateUserPublicKeyResponse) XXX_Size() int

func (*UpdateUserPublicKeyResponse) XXX_Unmarshal 

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

type VerifyGNFD1EddsaSignatureRequest 

type VerifyGNFD1EddsaSignatureRequest struct {
	// account_id is the account address of user
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// domain is the DApp domain for which the public key is updated
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// off_chain_sig is the off chain signature signed by user's eddsa seed private key
	OffChainSig string `protobuf:"bytes,3,opt,name=off_chain_sig,json=offChainSig,proto3" json:"off_chain_sig,omitempty"`
	// real_msg_to_sign is the msg that the off_chain_sig is signed for
	RealMsgToSign []byte `protobuf:"bytes,4,opt,name=real_msg_to_sign,json=realMsgToSign,proto3" json:"real_msg_to_sign,omitempty"`
}

VerifyGNFD1EddsaSignatureRequest is request type for the VerifyGNFD1EddsaSignature RPC method.

func (*VerifyGNFD1EddsaSignatureRequest) Descriptor 

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

func (*VerifyGNFD1EddsaSignatureRequest) GetAccountId 

func (m *VerifyGNFD1EddsaSignatureRequest) GetAccountId() string

func (*VerifyGNFD1EddsaSignatureRequest) GetDomain 

func (m *VerifyGNFD1EddsaSignatureRequest) GetDomain() string

func (*VerifyGNFD1EddsaSignatureRequest) GetOffChainSig 

func (m *VerifyGNFD1EddsaSignatureRequest) GetOffChainSig() string

func (*VerifyGNFD1EddsaSignatureRequest) GetRealMsgToSign 

func (m *VerifyGNFD1EddsaSignatureRequest) GetRealMsgToSign() []byte

func (*VerifyGNFD1EddsaSignatureRequest) Marshal 

func (m *VerifyGNFD1EddsaSignatureRequest) Marshal() (dAtA []byte, err error)

func (*VerifyGNFD1EddsaSignatureRequest) MarshalTo 

func (m *VerifyGNFD1EddsaSignatureRequest) MarshalTo(dAtA []byte) (int, error)

func (*VerifyGNFD1EddsaSignatureRequest) MarshalToSizedBuffer 

func (m *VerifyGNFD1EddsaSignatureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyGNFD1EddsaSignatureRequest) ProtoMessage 

func (*VerifyGNFD1EddsaSignatureRequest) ProtoMessage()

func (*VerifyGNFD1EddsaSignatureRequest) Reset 

func (m *VerifyGNFD1EddsaSignatureRequest) Reset()

func (*VerifyGNFD1EddsaSignatureRequest) Size 

func (m *VerifyGNFD1EddsaSignatureRequest) Size() (n int)

func (*VerifyGNFD1EddsaSignatureRequest) String 

func (m *VerifyGNFD1EddsaSignatureRequest) String() string

func (*VerifyGNFD1EddsaSignatureRequest) Unmarshal 

func (m *VerifyGNFD1EddsaSignatureRequest) Unmarshal(dAtA []byte) error

func (*VerifyGNFD1EddsaSignatureRequest) XXX_DiscardUnknown 

func (m *VerifyGNFD1EddsaSignatureRequest) XXX_DiscardUnknown()

func (*VerifyGNFD1EddsaSignatureRequest) XXX_Marshal 

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

func (*VerifyGNFD1EddsaSignatureRequest) XXX_Merge 

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

func (*VerifyGNFD1EddsaSignatureRequest) XXX_Size 

func (m *VerifyGNFD1EddsaSignatureRequest) XXX_Size() int

func (*VerifyGNFD1EddsaSignatureRequest) XXX_Unmarshal 

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

type VerifyGNFD1EddsaSignatureResponse 

type VerifyGNFD1EddsaSignatureResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// result defines the result of if the OffChainSignature is verified
	Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
}

VerifyGNFD1EddsaSignatureResponse is response type for the VerifyOffChainSignature RPC method.

func (*VerifyGNFD1EddsaSignatureResponse) Descriptor 

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

func (*VerifyGNFD1EddsaSignatureResponse) GetErr 

func (m *VerifyGNFD1EddsaSignatureResponse) GetErr() *gfsperrors.GfSpError

func (*VerifyGNFD1EddsaSignatureResponse) GetResult 

func (m *VerifyGNFD1EddsaSignatureResponse) GetResult() bool

func (*VerifyGNFD1EddsaSignatureResponse) Marshal 

func (m *VerifyGNFD1EddsaSignatureResponse) Marshal() (dAtA []byte, err error)

func (*VerifyGNFD1EddsaSignatureResponse) MarshalTo 

func (m *VerifyGNFD1EddsaSignatureResponse) MarshalTo(dAtA []byte) (int, error)

func (*VerifyGNFD1EddsaSignatureResponse) MarshalToSizedBuffer 

func (m *VerifyGNFD1EddsaSignatureResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyGNFD1EddsaSignatureResponse) ProtoMessage 

func (*VerifyGNFD1EddsaSignatureResponse) ProtoMessage()

func (*VerifyGNFD1EddsaSignatureResponse) Reset 

func (m *VerifyGNFD1EddsaSignatureResponse) Reset()

func (*VerifyGNFD1EddsaSignatureResponse) Size 

func (m *VerifyGNFD1EddsaSignatureResponse) Size() (n int)

func (*VerifyGNFD1EddsaSignatureResponse) String 

func (m *VerifyGNFD1EddsaSignatureResponse) String() string

func (*VerifyGNFD1EddsaSignatureResponse) Unmarshal 

func (m *VerifyGNFD1EddsaSignatureResponse) Unmarshal(dAtA []byte) error

func (*VerifyGNFD1EddsaSignatureResponse) XXX_DiscardUnknown 

func (m *VerifyGNFD1EddsaSignatureResponse) XXX_DiscardUnknown()

func (*VerifyGNFD1EddsaSignatureResponse) XXX_Marshal 

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

func (*VerifyGNFD1EddsaSignatureResponse) XXX_Merge 

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

func (*VerifyGNFD1EddsaSignatureResponse) XXX_Size 

func (m *VerifyGNFD1EddsaSignatureResponse) XXX_Size() int

func (*VerifyGNFD1EddsaSignatureResponse) XXX_Unmarshal 

func (m *VerifyGNFD1EddsaSignatureResponse) 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.