types

package
v0.2.5-alpha.1 Latest Latest
Warning

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

Go to latest
Published: Sep 6, 2023 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterGfSpMetadataServiceServer

func RegisterGfSpMetadataServiceServer(s grpc1.Server, srv GfSpMetadataServiceServer)

Types

type BlockSyncerInfo

type BlockSyncerInfo struct {
	BsBlockHeight             int64    `protobuf:"varint,1,opt,name=bs_block_height,json=bsBlockHeight,proto3" json:"bs_block_height,omitempty"`
	BsBlockHash               string   `protobuf:"bytes,2,opt,name=bs_block_hash,json=bsBlockHash,proto3" json:"bs_block_hash,omitempty"`
	BsUpdateTime              int64    `protobuf:"varint,3,opt,name=bs_update_time,json=bsUpdateTime,proto3" json:"bs_update_time,omitempty"`
	BsMysqlVersion            string   `protobuf:"bytes,4,opt,name=bs_mysql_version,json=bsMysqlVersion,proto3" json:"bs_mysql_version,omitempty"`
	BsDefaultCharacterSetName string   `` /* 142-byte string literal not displayed */
	BsDefaultCollationName    string   `` /* 131-byte string literal not displayed */
	BsModules                 []string `protobuf:"bytes,7,rep,name=bs_modules,json=bsModules,proto3" json:"bs_modules,omitempty"`
	BsWorkers                 uint32   `protobuf:"varint,8,opt,name=bs_workers,json=bsWorkers,proto3" json:"bs_workers,omitempty"`
	BsEnableDualDb            bool     `protobuf:"varint,9,opt,name=bs_enable_dual_db,json=bsEnableDualDb,proto3" json:"bs_enable_dual_db,omitempty"`
}

BlockSyncerInfo is the debug info for block syncer

func (*BlockSyncerInfo) Descriptor

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

func (*BlockSyncerInfo) GetBsBlockHash

func (m *BlockSyncerInfo) GetBsBlockHash() string

func (*BlockSyncerInfo) GetBsBlockHeight

func (m *BlockSyncerInfo) GetBsBlockHeight() int64

func (*BlockSyncerInfo) GetBsDefaultCharacterSetName

func (m *BlockSyncerInfo) GetBsDefaultCharacterSetName() string

func (*BlockSyncerInfo) GetBsDefaultCollationName

func (m *BlockSyncerInfo) GetBsDefaultCollationName() string

func (*BlockSyncerInfo) GetBsEnableDualDb

func (m *BlockSyncerInfo) GetBsEnableDualDb() bool

func (*BlockSyncerInfo) GetBsModules

func (m *BlockSyncerInfo) GetBsModules() []string

func (*BlockSyncerInfo) GetBsMysqlVersion

func (m *BlockSyncerInfo) GetBsMysqlVersion() string

func (*BlockSyncerInfo) GetBsUpdateTime

func (m *BlockSyncerInfo) GetBsUpdateTime() int64

func (*BlockSyncerInfo) GetBsWorkers

func (m *BlockSyncerInfo) GetBsWorkers() uint32

func (*BlockSyncerInfo) Marshal

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

func (*BlockSyncerInfo) MarshalTo

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

func (*BlockSyncerInfo) MarshalToSizedBuffer

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

func (*BlockSyncerInfo) ProtoMessage

func (*BlockSyncerInfo) ProtoMessage()

func (*BlockSyncerInfo) Reset

func (m *BlockSyncerInfo) Reset()

func (*BlockSyncerInfo) Size

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

func (*BlockSyncerInfo) String

func (m *BlockSyncerInfo) String() string

func (*BlockSyncerInfo) Unmarshal

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

func (*BlockSyncerInfo) XXX_DiscardUnknown

func (m *BlockSyncerInfo) XXX_DiscardUnknown()

func (*BlockSyncerInfo) XXX_Marshal

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

func (*BlockSyncerInfo) XXX_Merge

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

func (*BlockSyncerInfo) XXX_Size

func (m *BlockSyncerInfo) XXX_Size() int

func (*BlockSyncerInfo) XXX_Unmarshal

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

type Bucket

type Bucket struct {
	// bucket_info defines the information of the bucket.
	BucketInfo *types.BucketInfo `protobuf:"bytes,1,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	// removed defines the bucket is deleted or not
	Removed bool `protobuf:"varint,2,opt,name=removed,proto3" json:"removed,omitempty"`
	// delete_at defines the block number when the bucket deleted.
	DeleteAt int64 `protobuf:"varint,3,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`
	// delete_reason defines the deleted reason of bucket
	DeleteReason string `protobuf:"bytes,4,opt,name=delete_reason,json=deleteReason,proto3" json:"delete_reason,omitempty"`
	// operator defines the operator address of bucket
	Operator string `protobuf:"bytes,5,opt,name=operator,proto3" json:"operator,omitempty"`
	// create_tx_hash defines the creation transaction hash of object
	CreateTxHash string `protobuf:"bytes,6,opt,name=create_tx_hash,json=createTxHash,proto3" json:"create_tx_hash,omitempty"`
	// update_tx_hash defines the update transaction hash of object
	UpdateTxHash string `protobuf:"bytes,7,opt,name=update_tx_hash,json=updateTxHash,proto3" json:"update_tx_hash,omitempty"`
	// update_at defines the block number when the object updated
	UpdateAt int64 `protobuf:"varint,8,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	// update_time defines the block number when the object updated
	UpdateTime int64 `protobuf:"varint,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
}

Bucket is the structure for user bucket

func (*Bucket) Descriptor

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

func (*Bucket) GetBucketInfo

func (m *Bucket) GetBucketInfo() *types.BucketInfo

func (*Bucket) GetCreateTxHash

func (m *Bucket) GetCreateTxHash() string

func (*Bucket) GetDeleteAt

func (m *Bucket) GetDeleteAt() int64

func (*Bucket) GetDeleteReason

func (m *Bucket) GetDeleteReason() string

func (*Bucket) GetOperator

func (m *Bucket) GetOperator() string

func (*Bucket) GetRemoved

func (m *Bucket) GetRemoved() bool

func (*Bucket) GetUpdateAt

func (m *Bucket) GetUpdateAt() int64

func (*Bucket) GetUpdateTime

func (m *Bucket) GetUpdateTime() int64

func (*Bucket) GetUpdateTxHash

func (m *Bucket) GetUpdateTxHash() string

func (*Bucket) Marshal

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

func (*Bucket) MarshalTo

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

func (*Bucket) MarshalToSizedBuffer

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

func (*Bucket) ProtoMessage

func (*Bucket) ProtoMessage()

func (*Bucket) Reset

func (m *Bucket) Reset()

func (*Bucket) Size

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

func (*Bucket) String

func (m *Bucket) String() string

func (*Bucket) Unmarshal

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

func (*Bucket) XXX_DiscardUnknown

func (m *Bucket) XXX_DiscardUnknown()

func (*Bucket) XXX_Marshal

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

func (*Bucket) XXX_Merge

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

func (*Bucket) XXX_Size

func (m *Bucket) XXX_Size() int

func (*Bucket) XXX_Unmarshal

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

type ChainInfo

type ChainInfo struct {
	ChainId      string   `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ChainAddress []string `protobuf:"bytes,2,rep,name=chain_address,json=chainAddress,proto3" json:"chain_address,omitempty"`
}

func (*ChainInfo) Descriptor

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

func (*ChainInfo) GetChainAddress

func (m *ChainInfo) GetChainAddress() []string

func (*ChainInfo) GetChainId

func (m *ChainInfo) GetChainId() string

func (*ChainInfo) Marshal

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

func (*ChainInfo) MarshalTo

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

func (*ChainInfo) MarshalToSizedBuffer

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

func (*ChainInfo) ProtoMessage

func (*ChainInfo) ProtoMessage()

func (*ChainInfo) Reset

func (m *ChainInfo) Reset()

func (*ChainInfo) Size

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

func (*ChainInfo) String

func (m *ChainInfo) String() string

func (*ChainInfo) Unmarshal

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

func (*ChainInfo) XXX_DiscardUnknown

func (m *ChainInfo) XXX_DiscardUnknown()

func (*ChainInfo) XXX_Marshal

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

func (*ChainInfo) XXX_Merge

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

func (*ChainInfo) XXX_Size

func (m *ChainInfo) XXX_Size() int

func (*ChainInfo) XXX_Unmarshal

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

type GfSpGetBucketByBucketIDRequest

type GfSpGetBucketByBucketIDRequest struct {
	// bucket_id is the unique identifier of bucket
	BucketId int64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// include_private indicates whether this request can get the private buckets information
	IncludePrivate bool `protobuf:"varint,2,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetBucketByBucketIDRequest is request type for the GfSpGetBucketByBucketID RPC method

func (*GfSpGetBucketByBucketIDRequest) Descriptor

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

func (*GfSpGetBucketByBucketIDRequest) GetBucketId

func (m *GfSpGetBucketByBucketIDRequest) GetBucketId() int64

func (*GfSpGetBucketByBucketIDRequest) GetIncludePrivate

func (m *GfSpGetBucketByBucketIDRequest) GetIncludePrivate() bool

func (*GfSpGetBucketByBucketIDRequest) Marshal

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

func (*GfSpGetBucketByBucketIDRequest) MarshalTo

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

func (*GfSpGetBucketByBucketIDRequest) MarshalToSizedBuffer

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

func (*GfSpGetBucketByBucketIDRequest) ProtoMessage

func (*GfSpGetBucketByBucketIDRequest) ProtoMessage()

func (*GfSpGetBucketByBucketIDRequest) Reset

func (m *GfSpGetBucketByBucketIDRequest) Reset()

func (*GfSpGetBucketByBucketIDRequest) Size

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

func (*GfSpGetBucketByBucketIDRequest) String

func (*GfSpGetBucketByBucketIDRequest) Unmarshal

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

func (*GfSpGetBucketByBucketIDRequest) XXX_DiscardUnknown

func (m *GfSpGetBucketByBucketIDRequest) XXX_DiscardUnknown()

func (*GfSpGetBucketByBucketIDRequest) XXX_Marshal

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

func (*GfSpGetBucketByBucketIDRequest) XXX_Merge

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

func (*GfSpGetBucketByBucketIDRequest) XXX_Size

func (m *GfSpGetBucketByBucketIDRequest) XXX_Size() int

func (*GfSpGetBucketByBucketIDRequest) XXX_Unmarshal

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

type GfSpGetBucketByBucketIDResponse

type GfSpGetBucketByBucketIDResponse struct {
	// bucket defines the information of a bucket
	Bucket *Bucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
}

GfSpGetBucketByBucketIDResponse is response type for the GfSpGetBucketByBucketID RPC method.

func (*GfSpGetBucketByBucketIDResponse) Descriptor

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

func (*GfSpGetBucketByBucketIDResponse) GetBucket

func (m *GfSpGetBucketByBucketIDResponse) GetBucket() *Bucket

func (*GfSpGetBucketByBucketIDResponse) Marshal

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

func (*GfSpGetBucketByBucketIDResponse) MarshalTo

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

func (*GfSpGetBucketByBucketIDResponse) MarshalToSizedBuffer

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

func (*GfSpGetBucketByBucketIDResponse) ProtoMessage

func (*GfSpGetBucketByBucketIDResponse) ProtoMessage()

func (*GfSpGetBucketByBucketIDResponse) Reset

func (*GfSpGetBucketByBucketIDResponse) Size

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

func (*GfSpGetBucketByBucketIDResponse) String

func (*GfSpGetBucketByBucketIDResponse) Unmarshal

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

func (*GfSpGetBucketByBucketIDResponse) XXX_DiscardUnknown

func (m *GfSpGetBucketByBucketIDResponse) XXX_DiscardUnknown()

func (*GfSpGetBucketByBucketIDResponse) XXX_Marshal

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

func (*GfSpGetBucketByBucketIDResponse) XXX_Merge

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

func (*GfSpGetBucketByBucketIDResponse) XXX_Size

func (m *GfSpGetBucketByBucketIDResponse) XXX_Size() int

func (*GfSpGetBucketByBucketIDResponse) XXX_Unmarshal

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

type GfSpGetBucketByBucketNameRequest

type GfSpGetBucketByBucketNameRequest struct {
	// bucket_name is the name of the bucket
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// include_private indicates whether this request can get the private buckets information
	IncludePrivate bool `protobuf:"varint,2,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetBucketByBucketNameRequest is request type for the GfSpGetBucketByBucketName RPC method

func (*GfSpGetBucketByBucketNameRequest) Descriptor

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

func (*GfSpGetBucketByBucketNameRequest) GetBucketName

func (m *GfSpGetBucketByBucketNameRequest) GetBucketName() string

func (*GfSpGetBucketByBucketNameRequest) GetIncludePrivate

func (m *GfSpGetBucketByBucketNameRequest) GetIncludePrivate() bool

func (*GfSpGetBucketByBucketNameRequest) Marshal

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

func (*GfSpGetBucketByBucketNameRequest) MarshalTo

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

func (*GfSpGetBucketByBucketNameRequest) MarshalToSizedBuffer

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

func (*GfSpGetBucketByBucketNameRequest) ProtoMessage

func (*GfSpGetBucketByBucketNameRequest) ProtoMessage()

func (*GfSpGetBucketByBucketNameRequest) Reset

func (*GfSpGetBucketByBucketNameRequest) Size

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

func (*GfSpGetBucketByBucketNameRequest) String

func (*GfSpGetBucketByBucketNameRequest) Unmarshal

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

func (*GfSpGetBucketByBucketNameRequest) XXX_DiscardUnknown

func (m *GfSpGetBucketByBucketNameRequest) XXX_DiscardUnknown()

func (*GfSpGetBucketByBucketNameRequest) XXX_Marshal

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

func (*GfSpGetBucketByBucketNameRequest) XXX_Merge

func (*GfSpGetBucketByBucketNameRequest) XXX_Size

func (m *GfSpGetBucketByBucketNameRequest) XXX_Size() int

func (*GfSpGetBucketByBucketNameRequest) XXX_Unmarshal

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

type GfSpGetBucketByBucketNameResponse

type GfSpGetBucketByBucketNameResponse struct {
	// bucket defines the information of a bucket
	Bucket *Bucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
}

GfSpGetBucketByBucketNameResponse is response type for the GfSpGetBucketByBucketName RPC method.

func (*GfSpGetBucketByBucketNameResponse) Descriptor

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

func (*GfSpGetBucketByBucketNameResponse) GetBucket

func (m *GfSpGetBucketByBucketNameResponse) GetBucket() *Bucket

func (*GfSpGetBucketByBucketNameResponse) Marshal

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

func (*GfSpGetBucketByBucketNameResponse) MarshalTo

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

func (*GfSpGetBucketByBucketNameResponse) MarshalToSizedBuffer

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

func (*GfSpGetBucketByBucketNameResponse) ProtoMessage

func (*GfSpGetBucketByBucketNameResponse) ProtoMessage()

func (*GfSpGetBucketByBucketNameResponse) Reset

func (*GfSpGetBucketByBucketNameResponse) Size

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

func (*GfSpGetBucketByBucketNameResponse) String

func (*GfSpGetBucketByBucketNameResponse) Unmarshal

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

func (*GfSpGetBucketByBucketNameResponse) XXX_DiscardUnknown

func (m *GfSpGetBucketByBucketNameResponse) XXX_DiscardUnknown()

func (*GfSpGetBucketByBucketNameResponse) XXX_Marshal

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

func (*GfSpGetBucketByBucketNameResponse) XXX_Merge

func (*GfSpGetBucketByBucketNameResponse) XXX_Size

func (m *GfSpGetBucketByBucketNameResponse) XXX_Size() int

func (*GfSpGetBucketByBucketNameResponse) XXX_Unmarshal

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

type GfSpGetBucketMetaRequest

type GfSpGetBucketMetaRequest struct {
	// bucket_name is the name of the bucket
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// include_private indicates whether this request can get the private buckets information
	IncludePrivate bool `protobuf:"varint,2,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetBucketMetaRequest is request type for the GfSpGetBucketMeta RPC method

func (*GfSpGetBucketMetaRequest) Descriptor

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

func (*GfSpGetBucketMetaRequest) GetBucketName

func (m *GfSpGetBucketMetaRequest) GetBucketName() string

func (*GfSpGetBucketMetaRequest) GetIncludePrivate

func (m *GfSpGetBucketMetaRequest) GetIncludePrivate() bool

func (*GfSpGetBucketMetaRequest) Marshal

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

func (*GfSpGetBucketMetaRequest) MarshalTo

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

func (*GfSpGetBucketMetaRequest) MarshalToSizedBuffer

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

func (*GfSpGetBucketMetaRequest) ProtoMessage

func (*GfSpGetBucketMetaRequest) ProtoMessage()

func (*GfSpGetBucketMetaRequest) Reset

func (m *GfSpGetBucketMetaRequest) Reset()

func (*GfSpGetBucketMetaRequest) Size

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

func (*GfSpGetBucketMetaRequest) String

func (m *GfSpGetBucketMetaRequest) String() string

func (*GfSpGetBucketMetaRequest) Unmarshal

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

func (*GfSpGetBucketMetaRequest) XXX_DiscardUnknown

func (m *GfSpGetBucketMetaRequest) XXX_DiscardUnknown()

func (*GfSpGetBucketMetaRequest) XXX_Marshal

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

func (*GfSpGetBucketMetaRequest) XXX_Merge

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

func (*GfSpGetBucketMetaRequest) XXX_Size

func (m *GfSpGetBucketMetaRequest) XXX_Size() int

func (*GfSpGetBucketMetaRequest) XXX_Unmarshal

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

type GfSpGetBucketMetaResponse

type GfSpGetBucketMetaResponse struct {
	// bucket defines the information of a bucket
	Bucket *Bucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// stream_record defines stream payment record of a stream account
	StreamRecord *types2.StreamRecord `protobuf:"bytes,2,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record,omitempty"`
}

GfSpGetBucketMetaResponse is response type for the GfSpGetBucketMeta RPC method

func (*GfSpGetBucketMetaResponse) Descriptor

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

func (*GfSpGetBucketMetaResponse) GetBucket

func (m *GfSpGetBucketMetaResponse) GetBucket() *Bucket

func (*GfSpGetBucketMetaResponse) GetStreamRecord

func (m *GfSpGetBucketMetaResponse) GetStreamRecord() *types2.StreamRecord

func (*GfSpGetBucketMetaResponse) Marshal

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

func (*GfSpGetBucketMetaResponse) MarshalTo

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

func (*GfSpGetBucketMetaResponse) MarshalToSizedBuffer

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

func (*GfSpGetBucketMetaResponse) ProtoMessage

func (*GfSpGetBucketMetaResponse) ProtoMessage()

func (*GfSpGetBucketMetaResponse) Reset

func (m *GfSpGetBucketMetaResponse) Reset()

func (*GfSpGetBucketMetaResponse) Size

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

func (*GfSpGetBucketMetaResponse) String

func (m *GfSpGetBucketMetaResponse) String() string

func (*GfSpGetBucketMetaResponse) Unmarshal

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

func (*GfSpGetBucketMetaResponse) XXX_DiscardUnknown

func (m *GfSpGetBucketMetaResponse) XXX_DiscardUnknown()

func (*GfSpGetBucketMetaResponse) XXX_Marshal

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

func (*GfSpGetBucketMetaResponse) XXX_Merge

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

func (*GfSpGetBucketMetaResponse) XXX_Size

func (m *GfSpGetBucketMetaResponse) XXX_Size() int

func (*GfSpGetBucketMetaResponse) XXX_Unmarshal

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

type GfSpGetBucketReadQuotaRequest

type GfSpGetBucketReadQuotaRequest struct {
	// bucket info from the greenfield chain
	BucketInfo *types.BucketInfo `protobuf:"bytes,1,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	// year_month is the query bucket quota's month, like "2023-03"
	YearMonth string `protobuf:"bytes,2,opt,name=year_month,json=yearMonth,proto3" json:"year_month,omitempty"`
}

GfSpGetBucketReadQuotaRequest is request type for the GfSpGetBucketReadQuota RPC method.

func (*GfSpGetBucketReadQuotaRequest) Descriptor

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

func (*GfSpGetBucketReadQuotaRequest) GetBucketInfo

func (m *GfSpGetBucketReadQuotaRequest) GetBucketInfo() *types.BucketInfo

func (*GfSpGetBucketReadQuotaRequest) GetYearMonth

func (m *GfSpGetBucketReadQuotaRequest) GetYearMonth() string

func (*GfSpGetBucketReadQuotaRequest) Marshal

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

func (*GfSpGetBucketReadQuotaRequest) MarshalTo

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

func (*GfSpGetBucketReadQuotaRequest) MarshalToSizedBuffer

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

func (*GfSpGetBucketReadQuotaRequest) ProtoMessage

func (*GfSpGetBucketReadQuotaRequest) ProtoMessage()

func (*GfSpGetBucketReadQuotaRequest) Reset

func (m *GfSpGetBucketReadQuotaRequest) Reset()

func (*GfSpGetBucketReadQuotaRequest) Size

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

func (*GfSpGetBucketReadQuotaRequest) String

func (*GfSpGetBucketReadQuotaRequest) Unmarshal

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

func (*GfSpGetBucketReadQuotaRequest) XXX_DiscardUnknown

func (m *GfSpGetBucketReadQuotaRequest) XXX_DiscardUnknown()

func (*GfSpGetBucketReadQuotaRequest) XXX_Marshal

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

func (*GfSpGetBucketReadQuotaRequest) XXX_Merge

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

func (*GfSpGetBucketReadQuotaRequest) XXX_Size

func (m *GfSpGetBucketReadQuotaRequest) XXX_Size() int

func (*GfSpGetBucketReadQuotaRequest) XXX_Unmarshal

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

type GfSpGetBucketReadQuotaResponse

type GfSpGetBucketReadQuotaResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// charged_quota_size is the greenfield chain bucket info's read quota size
	ChargedQuotaSize uint64 `protobuf:"varint,2,opt,name=charged_quota_size,json=chargedQuotaSize,proto3" json:"charged_quota_size,omitempty"`
	// sp_free_quota_size is the sp default free quota
	SpFreeQuotaSize uint64 `protobuf:"varint,3,opt,name=sp_free_quota_size,json=spFreeQuotaSize,proto3" json:"sp_free_quota_size,omitempty"`
	// consumed_size is currently consumed size
	ConsumedSize uint64 `protobuf:"varint,4,opt,name=consumed_size,json=consumedSize,proto3" json:"consumed_size,omitempty"`
	// free_quota_consume_siz is currently consumed size
	FreeQuotaConsumeSize uint64 `` /* 126-byte string literal not displayed */
}

GfSpGetBucketReadQuotaResponse is response type for the GfSpGetBucketReadQuota RPC method.

func (*GfSpGetBucketReadQuotaResponse) Descriptor

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

func (*GfSpGetBucketReadQuotaResponse) GetChargedQuotaSize

func (m *GfSpGetBucketReadQuotaResponse) GetChargedQuotaSize() uint64

func (*GfSpGetBucketReadQuotaResponse) GetConsumedSize

func (m *GfSpGetBucketReadQuotaResponse) GetConsumedSize() uint64

func (*GfSpGetBucketReadQuotaResponse) GetErr

func (*GfSpGetBucketReadQuotaResponse) GetFreeQuotaConsumeSize

func (m *GfSpGetBucketReadQuotaResponse) GetFreeQuotaConsumeSize() uint64

func (*GfSpGetBucketReadQuotaResponse) GetSpFreeQuotaSize

func (m *GfSpGetBucketReadQuotaResponse) GetSpFreeQuotaSize() uint64

func (*GfSpGetBucketReadQuotaResponse) Marshal

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

func (*GfSpGetBucketReadQuotaResponse) MarshalTo

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

func (*GfSpGetBucketReadQuotaResponse) MarshalToSizedBuffer

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

func (*GfSpGetBucketReadQuotaResponse) ProtoMessage

func (*GfSpGetBucketReadQuotaResponse) ProtoMessage()

func (*GfSpGetBucketReadQuotaResponse) Reset

func (m *GfSpGetBucketReadQuotaResponse) Reset()

func (*GfSpGetBucketReadQuotaResponse) Size

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

func (*GfSpGetBucketReadQuotaResponse) String

func (*GfSpGetBucketReadQuotaResponse) Unmarshal

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

func (*GfSpGetBucketReadQuotaResponse) XXX_DiscardUnknown

func (m *GfSpGetBucketReadQuotaResponse) XXX_DiscardUnknown()

func (*GfSpGetBucketReadQuotaResponse) XXX_Marshal

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

func (*GfSpGetBucketReadQuotaResponse) XXX_Merge

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

func (*GfSpGetBucketReadQuotaResponse) XXX_Size

func (m *GfSpGetBucketReadQuotaResponse) XXX_Size() int

func (*GfSpGetBucketReadQuotaResponse) XXX_Unmarshal

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

type GfSpGetEndpointBySpIDRequest

type GfSpGetEndpointBySpIDRequest struct {
	// sp_id is the id of the sp
	SpId uint32 `protobuf:"varint,1,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpGetEndpointBySpIDRequest is request type for the GfSpGetEndpointBySpID RPC method

func (*GfSpGetEndpointBySpIDRequest) Descriptor

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

func (*GfSpGetEndpointBySpIDRequest) GetSpId

func (m *GfSpGetEndpointBySpIDRequest) GetSpId() uint32

func (*GfSpGetEndpointBySpIDRequest) Marshal

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

func (*GfSpGetEndpointBySpIDRequest) MarshalTo

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

func (*GfSpGetEndpointBySpIDRequest) MarshalToSizedBuffer

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

func (*GfSpGetEndpointBySpIDRequest) ProtoMessage

func (*GfSpGetEndpointBySpIDRequest) ProtoMessage()

func (*GfSpGetEndpointBySpIDRequest) Reset

func (m *GfSpGetEndpointBySpIDRequest) Reset()

func (*GfSpGetEndpointBySpIDRequest) Size

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

func (*GfSpGetEndpointBySpIDRequest) String

func (*GfSpGetEndpointBySpIDRequest) Unmarshal

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

func (*GfSpGetEndpointBySpIDRequest) XXX_DiscardUnknown

func (m *GfSpGetEndpointBySpIDRequest) XXX_DiscardUnknown()

func (*GfSpGetEndpointBySpIDRequest) XXX_Marshal

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

func (*GfSpGetEndpointBySpIDRequest) XXX_Merge

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

func (*GfSpGetEndpointBySpIDRequest) XXX_Size

func (m *GfSpGetEndpointBySpIDRequest) XXX_Size() int

func (*GfSpGetEndpointBySpIDRequest) XXX_Unmarshal

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

type GfSpGetEndpointBySpIDResponse

type GfSpGetEndpointBySpIDResponse struct {
	// endpoint defines endpoint of a sp
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
}

GfSpGetEndpointBySpIDResponse is response type for the GfSpGetEndpointBySpID RPC method.

func (*GfSpGetEndpointBySpIDResponse) Descriptor

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

func (*GfSpGetEndpointBySpIDResponse) GetEndpoint

func (m *GfSpGetEndpointBySpIDResponse) GetEndpoint() string

func (*GfSpGetEndpointBySpIDResponse) Marshal

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

func (*GfSpGetEndpointBySpIDResponse) MarshalTo

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

func (*GfSpGetEndpointBySpIDResponse) MarshalToSizedBuffer

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

func (*GfSpGetEndpointBySpIDResponse) ProtoMessage

func (*GfSpGetEndpointBySpIDResponse) ProtoMessage()

func (*GfSpGetEndpointBySpIDResponse) Reset

func (m *GfSpGetEndpointBySpIDResponse) Reset()

func (*GfSpGetEndpointBySpIDResponse) Size

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

func (*GfSpGetEndpointBySpIDResponse) String

func (*GfSpGetEndpointBySpIDResponse) Unmarshal

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

func (*GfSpGetEndpointBySpIDResponse) XXX_DiscardUnknown

func (m *GfSpGetEndpointBySpIDResponse) XXX_DiscardUnknown()

func (*GfSpGetEndpointBySpIDResponse) XXX_Marshal

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

func (*GfSpGetEndpointBySpIDResponse) XXX_Merge

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

func (*GfSpGetEndpointBySpIDResponse) XXX_Size

func (m *GfSpGetEndpointBySpIDResponse) XXX_Size() int

func (*GfSpGetEndpointBySpIDResponse) XXX_Unmarshal

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

type GfSpGetGlobalVirtualGroupByGvgIDRequest

type GfSpGetGlobalVirtualGroupByGvgIDRequest struct {
	// gvg_id is the unique identification for gvg
	GvgId uint32 `protobuf:"varint,1,opt,name=gvg_id,json=gvgId,proto3" json:"gvg_id,omitempty"`
}

GfSpGetGlobalVirtualGroupByGvgIDRequest is request type for the GfSpQueryGlobalVirtualGroup RPC method

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) Descriptor

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) GetGvgId

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) Marshal

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) MarshalTo

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) MarshalToSizedBuffer

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) ProtoMessage

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) Reset

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) Size

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) String

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) Unmarshal

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_DiscardUnknown

func (m *GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_DiscardUnknown()

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_Marshal

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

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_Merge

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_Size

func (*GfSpGetGlobalVirtualGroupByGvgIDRequest) XXX_Unmarshal

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

type GfSpGetGlobalVirtualGroupByGvgIDResponse

type GfSpGetGlobalVirtualGroupByGvgIDResponse struct {
	// global_virtual_group defines a global virtual group consists of one primary SP (SP) and multiple secondary SP
	GlobalVirtualGroup *types1.GlobalVirtualGroup `protobuf:"bytes,1,opt,name=global_virtual_group,json=globalVirtualGroup,proto3" json:"global_virtual_group,omitempty"`
}

GfSpGetGlobalVirtualGroupByGvgIDResponse is response type for the GfSpQueryGlobalVirtualGroup RPC method

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) Descriptor

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

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) GetGlobalVirtualGroup

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) Marshal

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

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) MarshalTo

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

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) MarshalToSizedBuffer

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

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) ProtoMessage

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) Reset

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) Size

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) String

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) Unmarshal

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_DiscardUnknown

func (m *GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_DiscardUnknown()

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_Marshal

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

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_Merge

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_Size

func (*GfSpGetGlobalVirtualGroupByGvgIDResponse) XXX_Unmarshal

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

type GfSpGetGlobalVirtualGroupRequest

type GfSpGetGlobalVirtualGroupRequest struct {
	// bucket_id is the unique identification for bucket
	BucketId uint64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// lvg_id and bucket_id are the unique identification for lvg
	LvgId uint32 `protobuf:"varint,2,opt,name=lvg_id,json=lvgId,proto3" json:"lvg_id,omitempty"`
}

GfSpGetGlobalVirtualGroupRequest is request type for the GfSpGetGlobalVirtualGroup RPC method

func (*GfSpGetGlobalVirtualGroupRequest) Descriptor

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

func (*GfSpGetGlobalVirtualGroupRequest) GetBucketId

func (m *GfSpGetGlobalVirtualGroupRequest) GetBucketId() uint64

func (*GfSpGetGlobalVirtualGroupRequest) GetLvgId

func (*GfSpGetGlobalVirtualGroupRequest) Marshal

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

func (*GfSpGetGlobalVirtualGroupRequest) MarshalTo

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

func (*GfSpGetGlobalVirtualGroupRequest) MarshalToSizedBuffer

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

func (*GfSpGetGlobalVirtualGroupRequest) ProtoMessage

func (*GfSpGetGlobalVirtualGroupRequest) ProtoMessage()

func (*GfSpGetGlobalVirtualGroupRequest) Reset

func (*GfSpGetGlobalVirtualGroupRequest) Size

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

func (*GfSpGetGlobalVirtualGroupRequest) String

func (*GfSpGetGlobalVirtualGroupRequest) Unmarshal

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

func (*GfSpGetGlobalVirtualGroupRequest) XXX_DiscardUnknown

func (m *GfSpGetGlobalVirtualGroupRequest) XXX_DiscardUnknown()

func (*GfSpGetGlobalVirtualGroupRequest) XXX_Marshal

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

func (*GfSpGetGlobalVirtualGroupRequest) XXX_Merge

func (*GfSpGetGlobalVirtualGroupRequest) XXX_Size

func (m *GfSpGetGlobalVirtualGroupRequest) XXX_Size() int

func (*GfSpGetGlobalVirtualGroupRequest) XXX_Unmarshal

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

type GfSpGetGlobalVirtualGroupResponse

type GfSpGetGlobalVirtualGroupResponse struct {
	// gvg defines the gvg info
	Gvg *types1.GlobalVirtualGroup `protobuf:"bytes,1,opt,name=gvg,proto3" json:"gvg,omitempty"`
}

GfSpGetGlobalVirtualGroupResponse is response type for the GfSpGetGlobalVirtualGroup RPC method

func (*GfSpGetGlobalVirtualGroupResponse) Descriptor

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

func (*GfSpGetGlobalVirtualGroupResponse) GetGvg

func (*GfSpGetGlobalVirtualGroupResponse) Marshal

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

func (*GfSpGetGlobalVirtualGroupResponse) MarshalTo

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

func (*GfSpGetGlobalVirtualGroupResponse) MarshalToSizedBuffer

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

func (*GfSpGetGlobalVirtualGroupResponse) ProtoMessage

func (*GfSpGetGlobalVirtualGroupResponse) ProtoMessage()

func (*GfSpGetGlobalVirtualGroupResponse) Reset

func (*GfSpGetGlobalVirtualGroupResponse) Size

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

func (*GfSpGetGlobalVirtualGroupResponse) String

func (*GfSpGetGlobalVirtualGroupResponse) Unmarshal

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

func (*GfSpGetGlobalVirtualGroupResponse) XXX_DiscardUnknown

func (m *GfSpGetGlobalVirtualGroupResponse) XXX_DiscardUnknown()

func (*GfSpGetGlobalVirtualGroupResponse) XXX_Marshal

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

func (*GfSpGetGlobalVirtualGroupResponse) XXX_Merge

func (*GfSpGetGlobalVirtualGroupResponse) XXX_Size

func (m *GfSpGetGlobalVirtualGroupResponse) XXX_Size() int

func (*GfSpGetGlobalVirtualGroupResponse) XXX_Unmarshal

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

type GfSpGetGroupListRequest

type GfSpGetGroupListRequest struct {
	// name defines the query group name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// prefix defines the prefix of the group name
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// source_type defines which chain the user should send the bucket management transactions to
	SourceType string `protobuf:"bytes,3,opt,name=source_type,json=sourceType,proto3" json:"source_type,omitempty"`
	// limit defines the maximum number of results that should be returned in response
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// offset defines the position in the list from where to start returning results
	Offset int64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	// include_removed indicates whether this request can get the removed groups information
	IncludeRemoved bool `protobuf:"varint,6,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpGetGroupListRequest is request type for the GetGroupList RPC method.

func (*GfSpGetGroupListRequest) Descriptor

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

func (*GfSpGetGroupListRequest) GetIncludeRemoved

func (m *GfSpGetGroupListRequest) GetIncludeRemoved() bool

func (*GfSpGetGroupListRequest) GetLimit

func (m *GfSpGetGroupListRequest) GetLimit() int64

func (*GfSpGetGroupListRequest) GetName

func (m *GfSpGetGroupListRequest) GetName() string

func (*GfSpGetGroupListRequest) GetOffset

func (m *GfSpGetGroupListRequest) GetOffset() int64

func (*GfSpGetGroupListRequest) GetPrefix

func (m *GfSpGetGroupListRequest) GetPrefix() string

func (*GfSpGetGroupListRequest) GetSourceType

func (m *GfSpGetGroupListRequest) GetSourceType() string

func (*GfSpGetGroupListRequest) Marshal

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

func (*GfSpGetGroupListRequest) MarshalTo

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

func (*GfSpGetGroupListRequest) MarshalToSizedBuffer

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

func (*GfSpGetGroupListRequest) ProtoMessage

func (*GfSpGetGroupListRequest) ProtoMessage()

func (*GfSpGetGroupListRequest) Reset

func (m *GfSpGetGroupListRequest) Reset()

func (*GfSpGetGroupListRequest) Size

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

func (*GfSpGetGroupListRequest) String

func (m *GfSpGetGroupListRequest) String() string

func (*GfSpGetGroupListRequest) Unmarshal

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

func (*GfSpGetGroupListRequest) XXX_DiscardUnknown

func (m *GfSpGetGroupListRequest) XXX_DiscardUnknown()

func (*GfSpGetGroupListRequest) XXX_Marshal

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

func (*GfSpGetGroupListRequest) XXX_Merge

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

func (*GfSpGetGroupListRequest) XXX_Size

func (m *GfSpGetGroupListRequest) XXX_Size() int

func (*GfSpGetGroupListRequest) XXX_Unmarshal

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

type GfSpGetGroupListResponse

type GfSpGetGroupListResponse struct {
	// groups defines the response of group list
	Groups []*Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// count defines total groups amount
	Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

GfSpGetGroupListResponse is response type for the GetGroupList RPC method.

func (*GfSpGetGroupListResponse) Descriptor

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

func (*GfSpGetGroupListResponse) GetCount

func (m *GfSpGetGroupListResponse) GetCount() int64

func (*GfSpGetGroupListResponse) GetGroups

func (m *GfSpGetGroupListResponse) GetGroups() []*Group

func (*GfSpGetGroupListResponse) Marshal

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

func (*GfSpGetGroupListResponse) MarshalTo

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

func (*GfSpGetGroupListResponse) MarshalToSizedBuffer

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

func (*GfSpGetGroupListResponse) ProtoMessage

func (*GfSpGetGroupListResponse) ProtoMessage()

func (*GfSpGetGroupListResponse) Reset

func (m *GfSpGetGroupListResponse) Reset()

func (*GfSpGetGroupListResponse) Size

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

func (*GfSpGetGroupListResponse) String

func (m *GfSpGetGroupListResponse) String() string

func (*GfSpGetGroupListResponse) Unmarshal

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

func (*GfSpGetGroupListResponse) XXX_DiscardUnknown

func (m *GfSpGetGroupListResponse) XXX_DiscardUnknown()

func (*GfSpGetGroupListResponse) XXX_Marshal

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

func (*GfSpGetGroupListResponse) XXX_Merge

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

func (*GfSpGetGroupListResponse) XXX_Size

func (m *GfSpGetGroupListResponse) XXX_Size() int

func (*GfSpGetGroupListResponse) XXX_Unmarshal

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

type GfSpGetGroupMembersRequest

type GfSpGetGroupMembersRequest struct {
	// group_id is the id of group
	GroupId uint64 `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// limit sets the limit of keys returned in the response
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// start_after is where you want to start listing from
	StartAfter string `protobuf:"bytes,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
}

GfSpGetGroupMembersRequest is request type for the GfSpGetGroupMembers RPC method

func (*GfSpGetGroupMembersRequest) Descriptor

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

func (*GfSpGetGroupMembersRequest) GetGroupId

func (m *GfSpGetGroupMembersRequest) GetGroupId() uint64

func (*GfSpGetGroupMembersRequest) GetLimit

func (m *GfSpGetGroupMembersRequest) GetLimit() uint32

func (*GfSpGetGroupMembersRequest) GetStartAfter

func (m *GfSpGetGroupMembersRequest) GetStartAfter() string

func (*GfSpGetGroupMembersRequest) Marshal

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

func (*GfSpGetGroupMembersRequest) MarshalTo

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

func (*GfSpGetGroupMembersRequest) MarshalToSizedBuffer

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

func (*GfSpGetGroupMembersRequest) ProtoMessage

func (*GfSpGetGroupMembersRequest) ProtoMessage()

func (*GfSpGetGroupMembersRequest) Reset

func (m *GfSpGetGroupMembersRequest) Reset()

func (*GfSpGetGroupMembersRequest) Size

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

func (*GfSpGetGroupMembersRequest) String

func (m *GfSpGetGroupMembersRequest) String() string

func (*GfSpGetGroupMembersRequest) Unmarshal

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

func (*GfSpGetGroupMembersRequest) XXX_DiscardUnknown

func (m *GfSpGetGroupMembersRequest) XXX_DiscardUnknown()

func (*GfSpGetGroupMembersRequest) XXX_Marshal

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

func (*GfSpGetGroupMembersRequest) XXX_Merge

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

func (*GfSpGetGroupMembersRequest) XXX_Size

func (m *GfSpGetGroupMembersRequest) XXX_Size() int

func (*GfSpGetGroupMembersRequest) XXX_Unmarshal

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

type GfSpGetGroupMembersResponse

type GfSpGetGroupMembersResponse struct {
	// group defines the response of group members
	Groups []*GroupMember `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GfSpGetGroupMembersResponse is response type for the GfSpGetGroupMembers RPC method

func (*GfSpGetGroupMembersResponse) Descriptor

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

func (*GfSpGetGroupMembersResponse) GetGroups

func (m *GfSpGetGroupMembersResponse) GetGroups() []*GroupMember

func (*GfSpGetGroupMembersResponse) Marshal

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

func (*GfSpGetGroupMembersResponse) MarshalTo

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

func (*GfSpGetGroupMembersResponse) MarshalToSizedBuffer

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

func (*GfSpGetGroupMembersResponse) ProtoMessage

func (*GfSpGetGroupMembersResponse) ProtoMessage()

func (*GfSpGetGroupMembersResponse) Reset

func (m *GfSpGetGroupMembersResponse) Reset()

func (*GfSpGetGroupMembersResponse) Size

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

func (*GfSpGetGroupMembersResponse) String

func (m *GfSpGetGroupMembersResponse) String() string

func (*GfSpGetGroupMembersResponse) Unmarshal

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

func (*GfSpGetGroupMembersResponse) XXX_DiscardUnknown

func (m *GfSpGetGroupMembersResponse) XXX_DiscardUnknown()

func (*GfSpGetGroupMembersResponse) XXX_Marshal

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

func (*GfSpGetGroupMembersResponse) XXX_Merge

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

func (*GfSpGetGroupMembersResponse) XXX_Size

func (m *GfSpGetGroupMembersResponse) XXX_Size() int

func (*GfSpGetGroupMembersResponse) XXX_Unmarshal

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

type GfSpGetObjectMetaRequest

type GfSpGetObjectMetaRequest struct {
	// object_name is the name of the object
	ObjectName string `protobuf:"bytes,1,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// bucket_name is the name of the bucket
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// include_private indicates whether this request can get the private objects information
	IncludePrivate bool `protobuf:"varint,3,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetObjectMetaRequest is request type for the GfSpGetObjectMeta RPC method

func (*GfSpGetObjectMetaRequest) Descriptor

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

func (*GfSpGetObjectMetaRequest) GetBucketName

func (m *GfSpGetObjectMetaRequest) GetBucketName() string

func (*GfSpGetObjectMetaRequest) GetIncludePrivate

func (m *GfSpGetObjectMetaRequest) GetIncludePrivate() bool

func (*GfSpGetObjectMetaRequest) GetObjectName

func (m *GfSpGetObjectMetaRequest) GetObjectName() string

func (*GfSpGetObjectMetaRequest) Marshal

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

func (*GfSpGetObjectMetaRequest) MarshalTo

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

func (*GfSpGetObjectMetaRequest) MarshalToSizedBuffer

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

func (*GfSpGetObjectMetaRequest) ProtoMessage

func (*GfSpGetObjectMetaRequest) ProtoMessage()

func (*GfSpGetObjectMetaRequest) Reset

func (m *GfSpGetObjectMetaRequest) Reset()

func (*GfSpGetObjectMetaRequest) Size

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

func (*GfSpGetObjectMetaRequest) String

func (m *GfSpGetObjectMetaRequest) String() string

func (*GfSpGetObjectMetaRequest) Unmarshal

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

func (*GfSpGetObjectMetaRequest) XXX_DiscardUnknown

func (m *GfSpGetObjectMetaRequest) XXX_DiscardUnknown()

func (*GfSpGetObjectMetaRequest) XXX_Marshal

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

func (*GfSpGetObjectMetaRequest) XXX_Merge

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

func (*GfSpGetObjectMetaRequest) XXX_Size

func (m *GfSpGetObjectMetaRequest) XXX_Size() int

func (*GfSpGetObjectMetaRequest) XXX_Unmarshal

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

type GfSpGetObjectMetaResponse

type GfSpGetObjectMetaResponse struct {
	// object defines the information of an object
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

GfSpGetObjectMetaResponse is response type for the GfSpGetObjectMeta RPC method.

func (*GfSpGetObjectMetaResponse) Descriptor

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

func (*GfSpGetObjectMetaResponse) GetObject

func (m *GfSpGetObjectMetaResponse) GetObject() *Object

func (*GfSpGetObjectMetaResponse) Marshal

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

func (*GfSpGetObjectMetaResponse) MarshalTo

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

func (*GfSpGetObjectMetaResponse) MarshalToSizedBuffer

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

func (*GfSpGetObjectMetaResponse) ProtoMessage

func (*GfSpGetObjectMetaResponse) ProtoMessage()

func (*GfSpGetObjectMetaResponse) Reset

func (m *GfSpGetObjectMetaResponse) Reset()

func (*GfSpGetObjectMetaResponse) Size

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

func (*GfSpGetObjectMetaResponse) String

func (m *GfSpGetObjectMetaResponse) String() string

func (*GfSpGetObjectMetaResponse) Unmarshal

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

func (*GfSpGetObjectMetaResponse) XXX_DiscardUnknown

func (m *GfSpGetObjectMetaResponse) XXX_DiscardUnknown()

func (*GfSpGetObjectMetaResponse) XXX_Marshal

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

func (*GfSpGetObjectMetaResponse) XXX_Merge

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

func (*GfSpGetObjectMetaResponse) XXX_Size

func (m *GfSpGetObjectMetaResponse) XXX_Size() int

func (*GfSpGetObjectMetaResponse) XXX_Unmarshal

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

type GfSpGetPaymentByBucketIDRequest

type GfSpGetPaymentByBucketIDRequest struct {
	// bucket_id is the unique identifier of bucket
	BucketId int64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// include_private indicates whether this request can get the private buckets information
	IncludePrivate bool `protobuf:"varint,2,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetPaymentByBucketIDRequest is request type for the GfSpGetPaymentByBucketID RPC method

func (*GfSpGetPaymentByBucketIDRequest) Descriptor

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

func (*GfSpGetPaymentByBucketIDRequest) GetBucketId

func (m *GfSpGetPaymentByBucketIDRequest) GetBucketId() int64

func (*GfSpGetPaymentByBucketIDRequest) GetIncludePrivate

func (m *GfSpGetPaymentByBucketIDRequest) GetIncludePrivate() bool

func (*GfSpGetPaymentByBucketIDRequest) Marshal

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

func (*GfSpGetPaymentByBucketIDRequest) MarshalTo

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

func (*GfSpGetPaymentByBucketIDRequest) MarshalToSizedBuffer

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

func (*GfSpGetPaymentByBucketIDRequest) ProtoMessage

func (*GfSpGetPaymentByBucketIDRequest) ProtoMessage()

func (*GfSpGetPaymentByBucketIDRequest) Reset

func (*GfSpGetPaymentByBucketIDRequest) Size

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

func (*GfSpGetPaymentByBucketIDRequest) String

func (*GfSpGetPaymentByBucketIDRequest) Unmarshal

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

func (*GfSpGetPaymentByBucketIDRequest) XXX_DiscardUnknown

func (m *GfSpGetPaymentByBucketIDRequest) XXX_DiscardUnknown()

func (*GfSpGetPaymentByBucketIDRequest) XXX_Marshal

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

func (*GfSpGetPaymentByBucketIDRequest) XXX_Merge

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

func (*GfSpGetPaymentByBucketIDRequest) XXX_Size

func (m *GfSpGetPaymentByBucketIDRequest) XXX_Size() int

func (*GfSpGetPaymentByBucketIDRequest) XXX_Unmarshal

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

type GfSpGetPaymentByBucketIDResponse

type GfSpGetPaymentByBucketIDResponse struct {
	// stream_record defines stream payment record of a stream account
	StreamRecord *types2.StreamRecord `protobuf:"bytes,1,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record,omitempty"`
}

GfSpGetPaymentByBucketIDResponse is response type for the GfSpGetPaymentByBucketID RPC method.

func (*GfSpGetPaymentByBucketIDResponse) Descriptor

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

func (*GfSpGetPaymentByBucketIDResponse) GetStreamRecord

func (*GfSpGetPaymentByBucketIDResponse) Marshal

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

func (*GfSpGetPaymentByBucketIDResponse) MarshalTo

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

func (*GfSpGetPaymentByBucketIDResponse) MarshalToSizedBuffer

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

func (*GfSpGetPaymentByBucketIDResponse) ProtoMessage

func (*GfSpGetPaymentByBucketIDResponse) ProtoMessage()

func (*GfSpGetPaymentByBucketIDResponse) Reset

func (*GfSpGetPaymentByBucketIDResponse) Size

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

func (*GfSpGetPaymentByBucketIDResponse) String

func (*GfSpGetPaymentByBucketIDResponse) Unmarshal

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

func (*GfSpGetPaymentByBucketIDResponse) XXX_DiscardUnknown

func (m *GfSpGetPaymentByBucketIDResponse) XXX_DiscardUnknown()

func (*GfSpGetPaymentByBucketIDResponse) XXX_Marshal

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

func (*GfSpGetPaymentByBucketIDResponse) XXX_Merge

func (*GfSpGetPaymentByBucketIDResponse) XXX_Size

func (m *GfSpGetPaymentByBucketIDResponse) XXX_Size() int

func (*GfSpGetPaymentByBucketIDResponse) XXX_Unmarshal

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

type GfSpGetPaymentByBucketNameRequest

type GfSpGetPaymentByBucketNameRequest struct {
	// bucket_name is the name of the bucket
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// include_private indicates whether this request can get the private buckets information
	IncludePrivate bool `protobuf:"varint,2,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpGetPaymentByBucketNameRequest is request type for the GfSpGetPaymentByBucketName RPC method

func (*GfSpGetPaymentByBucketNameRequest) Descriptor

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

func (*GfSpGetPaymentByBucketNameRequest) GetBucketName

func (m *GfSpGetPaymentByBucketNameRequest) GetBucketName() string

func (*GfSpGetPaymentByBucketNameRequest) GetIncludePrivate

func (m *GfSpGetPaymentByBucketNameRequest) GetIncludePrivate() bool

func (*GfSpGetPaymentByBucketNameRequest) Marshal

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

func (*GfSpGetPaymentByBucketNameRequest) MarshalTo

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

func (*GfSpGetPaymentByBucketNameRequest) MarshalToSizedBuffer

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

func (*GfSpGetPaymentByBucketNameRequest) ProtoMessage

func (*GfSpGetPaymentByBucketNameRequest) ProtoMessage()

func (*GfSpGetPaymentByBucketNameRequest) Reset

func (*GfSpGetPaymentByBucketNameRequest) Size

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

func (*GfSpGetPaymentByBucketNameRequest) String

func (*GfSpGetPaymentByBucketNameRequest) Unmarshal

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

func (*GfSpGetPaymentByBucketNameRequest) XXX_DiscardUnknown

func (m *GfSpGetPaymentByBucketNameRequest) XXX_DiscardUnknown()

func (*GfSpGetPaymentByBucketNameRequest) XXX_Marshal

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

func (*GfSpGetPaymentByBucketNameRequest) XXX_Merge

func (*GfSpGetPaymentByBucketNameRequest) XXX_Size

func (m *GfSpGetPaymentByBucketNameRequest) XXX_Size() int

func (*GfSpGetPaymentByBucketNameRequest) XXX_Unmarshal

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

type GfSpGetPaymentByBucketNameResponse

type GfSpGetPaymentByBucketNameResponse struct {
	// stream_record defines stream payment record of a stream account
	StreamRecord *types2.StreamRecord `protobuf:"bytes,1,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record,omitempty"`
}

GfSpGetPaymentByBucketNameResponse is response type for the GfSpGetPaymentByBucketName RPC method.

func (*GfSpGetPaymentByBucketNameResponse) Descriptor

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

func (*GfSpGetPaymentByBucketNameResponse) GetStreamRecord

func (*GfSpGetPaymentByBucketNameResponse) Marshal

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

func (*GfSpGetPaymentByBucketNameResponse) MarshalTo

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

func (*GfSpGetPaymentByBucketNameResponse) MarshalToSizedBuffer

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

func (*GfSpGetPaymentByBucketNameResponse) ProtoMessage

func (*GfSpGetPaymentByBucketNameResponse) ProtoMessage()

func (*GfSpGetPaymentByBucketNameResponse) Reset

func (*GfSpGetPaymentByBucketNameResponse) Size

func (*GfSpGetPaymentByBucketNameResponse) String

func (*GfSpGetPaymentByBucketNameResponse) Unmarshal

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

func (*GfSpGetPaymentByBucketNameResponse) XXX_DiscardUnknown

func (m *GfSpGetPaymentByBucketNameResponse) XXX_DiscardUnknown()

func (*GfSpGetPaymentByBucketNameResponse) XXX_Marshal

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

func (*GfSpGetPaymentByBucketNameResponse) XXX_Merge

func (*GfSpGetPaymentByBucketNameResponse) XXX_Size

func (*GfSpGetPaymentByBucketNameResponse) XXX_Unmarshal

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

type GfSpGetSPInfoRequest

type GfSpGetSPInfoRequest struct {
	// operator_address is the unique identification address for operator
	OperatorAddress string `protobuf:"bytes,1,opt,name=operator_address,json=operatorAddress,proto3" json:"operator_address,omitempty"`
}

GfSpGetSPInfoRequest is request type for the GfSpGetSPInfo RPC method

func (*GfSpGetSPInfoRequest) Descriptor

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

func (*GfSpGetSPInfoRequest) GetOperatorAddress

func (m *GfSpGetSPInfoRequest) GetOperatorAddress() string

func (*GfSpGetSPInfoRequest) Marshal

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

func (*GfSpGetSPInfoRequest) MarshalTo

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

func (*GfSpGetSPInfoRequest) MarshalToSizedBuffer

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

func (*GfSpGetSPInfoRequest) ProtoMessage

func (*GfSpGetSPInfoRequest) ProtoMessage()

func (*GfSpGetSPInfoRequest) Reset

func (m *GfSpGetSPInfoRequest) Reset()

func (*GfSpGetSPInfoRequest) Size

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

func (*GfSpGetSPInfoRequest) String

func (m *GfSpGetSPInfoRequest) String() string

func (*GfSpGetSPInfoRequest) Unmarshal

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

func (*GfSpGetSPInfoRequest) XXX_DiscardUnknown

func (m *GfSpGetSPInfoRequest) XXX_DiscardUnknown()

func (*GfSpGetSPInfoRequest) XXX_Marshal

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

func (*GfSpGetSPInfoRequest) XXX_Merge

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

func (*GfSpGetSPInfoRequest) XXX_Size

func (m *GfSpGetSPInfoRequest) XXX_Size() int

func (*GfSpGetSPInfoRequest) XXX_Unmarshal

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

type GfSpGetSPInfoResponse

type GfSpGetSPInfoResponse struct {
	// sp defines the meta info of storage provider
	StorageProvider *types5.StorageProvider `protobuf:"bytes,1,opt,name=storage_provider,json=storageProvider,proto3" json:"storage_provider,omitempty"`
}

GfSpGetSPInfoResponse is response type for the GfSpGetSPInfo RPC method

func (*GfSpGetSPInfoResponse) Descriptor

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

func (*GfSpGetSPInfoResponse) GetStorageProvider

func (m *GfSpGetSPInfoResponse) GetStorageProvider() *types5.StorageProvider

func (*GfSpGetSPInfoResponse) Marshal

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

func (*GfSpGetSPInfoResponse) MarshalTo

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

func (*GfSpGetSPInfoResponse) MarshalToSizedBuffer

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

func (*GfSpGetSPInfoResponse) ProtoMessage

func (*GfSpGetSPInfoResponse) ProtoMessage()

func (*GfSpGetSPInfoResponse) Reset

func (m *GfSpGetSPInfoResponse) Reset()

func (*GfSpGetSPInfoResponse) Size

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

func (*GfSpGetSPInfoResponse) String

func (m *GfSpGetSPInfoResponse) String() string

func (*GfSpGetSPInfoResponse) Unmarshal

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

func (*GfSpGetSPInfoResponse) XXX_DiscardUnknown

func (m *GfSpGetSPInfoResponse) XXX_DiscardUnknown()

func (*GfSpGetSPInfoResponse) XXX_Marshal

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

func (*GfSpGetSPInfoResponse) XXX_Merge

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

func (*GfSpGetSPInfoResponse) XXX_Size

func (m *GfSpGetSPInfoResponse) XXX_Size() int

func (*GfSpGetSPInfoResponse) XXX_Unmarshal

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

type GfSpGetStatusRequest

type GfSpGetStatusRequest struct {
}

func (*GfSpGetStatusRequest) Descriptor

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

func (*GfSpGetStatusRequest) Marshal

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

func (*GfSpGetStatusRequest) MarshalTo

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

func (*GfSpGetStatusRequest) MarshalToSizedBuffer

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

func (*GfSpGetStatusRequest) ProtoMessage

func (*GfSpGetStatusRequest) ProtoMessage()

func (*GfSpGetStatusRequest) Reset

func (m *GfSpGetStatusRequest) Reset()

func (*GfSpGetStatusRequest) Size

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

func (*GfSpGetStatusRequest) String

func (m *GfSpGetStatusRequest) String() string

func (*GfSpGetStatusRequest) Unmarshal

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

func (*GfSpGetStatusRequest) XXX_DiscardUnknown

func (m *GfSpGetStatusRequest) XXX_DiscardUnknown()

func (*GfSpGetStatusRequest) XXX_Marshal

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

func (*GfSpGetStatusRequest) XXX_Merge

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

func (*GfSpGetStatusRequest) XXX_Size

func (m *GfSpGetStatusRequest) XXX_Size() int

func (*GfSpGetStatusRequest) XXX_Unmarshal

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

type GfSpGetStatusResponse

type GfSpGetStatusResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*GfSpGetStatusResponse) Descriptor

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

func (*GfSpGetStatusResponse) GetStatus

func (m *GfSpGetStatusResponse) GetStatus() *Status

func (*GfSpGetStatusResponse) Marshal

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

func (*GfSpGetStatusResponse) MarshalTo

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

func (*GfSpGetStatusResponse) MarshalToSizedBuffer

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

func (*GfSpGetStatusResponse) ProtoMessage

func (*GfSpGetStatusResponse) ProtoMessage()

func (*GfSpGetStatusResponse) Reset

func (m *GfSpGetStatusResponse) Reset()

func (*GfSpGetStatusResponse) Size

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

func (*GfSpGetStatusResponse) String

func (m *GfSpGetStatusResponse) String() string

func (*GfSpGetStatusResponse) Unmarshal

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

func (*GfSpGetStatusResponse) XXX_DiscardUnknown

func (m *GfSpGetStatusResponse) XXX_DiscardUnknown()

func (*GfSpGetStatusResponse) XXX_Marshal

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

func (*GfSpGetStatusResponse) XXX_Merge

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

func (*GfSpGetStatusResponse) XXX_Size

func (m *GfSpGetStatusResponse) XXX_Size() int

func (*GfSpGetStatusResponse) XXX_Unmarshal

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

type GfSpGetUserBucketsCountRequest

type GfSpGetUserBucketsCountRequest 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"`
	// include_removed indicates whether this request can get the removed buckets information
	IncludeRemoved bool `protobuf:"varint,2,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpGetUserBucketsCountRequest is request type for the GfSpGetUserBucketsCount RPC method.

func (*GfSpGetUserBucketsCountRequest) Descriptor

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

func (*GfSpGetUserBucketsCountRequest) GetAccountId

func (m *GfSpGetUserBucketsCountRequest) GetAccountId() string

func (*GfSpGetUserBucketsCountRequest) GetIncludeRemoved

func (m *GfSpGetUserBucketsCountRequest) GetIncludeRemoved() bool

func (*GfSpGetUserBucketsCountRequest) Marshal

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

func (*GfSpGetUserBucketsCountRequest) MarshalTo

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

func (*GfSpGetUserBucketsCountRequest) MarshalToSizedBuffer

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

func (*GfSpGetUserBucketsCountRequest) ProtoMessage

func (*GfSpGetUserBucketsCountRequest) ProtoMessage()

func (*GfSpGetUserBucketsCountRequest) Reset

func (m *GfSpGetUserBucketsCountRequest) Reset()

func (*GfSpGetUserBucketsCountRequest) Size

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

func (*GfSpGetUserBucketsCountRequest) String

func (*GfSpGetUserBucketsCountRequest) Unmarshal

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

func (*GfSpGetUserBucketsCountRequest) XXX_DiscardUnknown

func (m *GfSpGetUserBucketsCountRequest) XXX_DiscardUnknown()

func (*GfSpGetUserBucketsCountRequest) XXX_Marshal

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

func (*GfSpGetUserBucketsCountRequest) XXX_Merge

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

func (*GfSpGetUserBucketsCountRequest) XXX_Size

func (m *GfSpGetUserBucketsCountRequest) XXX_Size() int

func (*GfSpGetUserBucketsCountRequest) XXX_Unmarshal

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

type GfSpGetUserBucketsCountResponse

type GfSpGetUserBucketsCountResponse struct {
	// count defines total count of user buckets
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

GfSpGetUserBucketsCountResponse is response type for the GfSpGetUserBucketsCount RPC method.

func (*GfSpGetUserBucketsCountResponse) Descriptor

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

func (*GfSpGetUserBucketsCountResponse) GetCount

func (m *GfSpGetUserBucketsCountResponse) GetCount() int64

func (*GfSpGetUserBucketsCountResponse) Marshal

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

func (*GfSpGetUserBucketsCountResponse) MarshalTo

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

func (*GfSpGetUserBucketsCountResponse) MarshalToSizedBuffer

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

func (*GfSpGetUserBucketsCountResponse) ProtoMessage

func (*GfSpGetUserBucketsCountResponse) ProtoMessage()

func (*GfSpGetUserBucketsCountResponse) Reset

func (*GfSpGetUserBucketsCountResponse) Size

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

func (*GfSpGetUserBucketsCountResponse) String

func (*GfSpGetUserBucketsCountResponse) Unmarshal

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

func (*GfSpGetUserBucketsCountResponse) XXX_DiscardUnknown

func (m *GfSpGetUserBucketsCountResponse) XXX_DiscardUnknown()

func (*GfSpGetUserBucketsCountResponse) XXX_Marshal

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

func (*GfSpGetUserBucketsCountResponse) XXX_Merge

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

func (*GfSpGetUserBucketsCountResponse) XXX_Size

func (m *GfSpGetUserBucketsCountResponse) XXX_Size() int

func (*GfSpGetUserBucketsCountResponse) XXX_Unmarshal

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

type GfSpGetUserBucketsRequest

type GfSpGetUserBucketsRequest 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"`
	// include_removed indicates whether this request can get the removed buckets information
	IncludeRemoved bool `protobuf:"varint,2,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpGetUserBucketsRequest is request type for the GfSpGetUserBuckets RPC method.

func (*GfSpGetUserBucketsRequest) Descriptor

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

func (*GfSpGetUserBucketsRequest) GetAccountId

func (m *GfSpGetUserBucketsRequest) GetAccountId() string

func (*GfSpGetUserBucketsRequest) GetIncludeRemoved

func (m *GfSpGetUserBucketsRequest) GetIncludeRemoved() bool

func (*GfSpGetUserBucketsRequest) Marshal

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

func (*GfSpGetUserBucketsRequest) MarshalTo

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

func (*GfSpGetUserBucketsRequest) MarshalToSizedBuffer

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

func (*GfSpGetUserBucketsRequest) ProtoMessage

func (*GfSpGetUserBucketsRequest) ProtoMessage()

func (*GfSpGetUserBucketsRequest) Reset

func (m *GfSpGetUserBucketsRequest) Reset()

func (*GfSpGetUserBucketsRequest) Size

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

func (*GfSpGetUserBucketsRequest) String

func (m *GfSpGetUserBucketsRequest) String() string

func (*GfSpGetUserBucketsRequest) Unmarshal

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

func (*GfSpGetUserBucketsRequest) XXX_DiscardUnknown

func (m *GfSpGetUserBucketsRequest) XXX_DiscardUnknown()

func (*GfSpGetUserBucketsRequest) XXX_Marshal

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

func (*GfSpGetUserBucketsRequest) XXX_Merge

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

func (*GfSpGetUserBucketsRequest) XXX_Size

func (m *GfSpGetUserBucketsRequest) XXX_Size() int

func (*GfSpGetUserBucketsRequest) XXX_Unmarshal

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

type GfSpGetUserBucketsResponse

type GfSpGetUserBucketsResponse struct {
	// buckets defines the list of bucket
	Buckets []*VGFInfoBucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
}

GfSpGetUserBucketsResponse is response type for the GfSpGetUserBuckets RPC method.

func (*GfSpGetUserBucketsResponse) Descriptor

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

func (*GfSpGetUserBucketsResponse) GetBuckets

func (m *GfSpGetUserBucketsResponse) GetBuckets() []*VGFInfoBucket

func (*GfSpGetUserBucketsResponse) Marshal

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

func (*GfSpGetUserBucketsResponse) MarshalTo

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

func (*GfSpGetUserBucketsResponse) MarshalToSizedBuffer

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

func (*GfSpGetUserBucketsResponse) ProtoMessage

func (*GfSpGetUserBucketsResponse) ProtoMessage()

func (*GfSpGetUserBucketsResponse) Reset

func (m *GfSpGetUserBucketsResponse) Reset()

func (*GfSpGetUserBucketsResponse) Size

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

func (*GfSpGetUserBucketsResponse) String

func (m *GfSpGetUserBucketsResponse) String() string

func (*GfSpGetUserBucketsResponse) Unmarshal

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

func (*GfSpGetUserBucketsResponse) XXX_DiscardUnknown

func (m *GfSpGetUserBucketsResponse) XXX_DiscardUnknown()

func (*GfSpGetUserBucketsResponse) XXX_Marshal

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

func (*GfSpGetUserBucketsResponse) XXX_Merge

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

func (*GfSpGetUserBucketsResponse) XXX_Size

func (m *GfSpGetUserBucketsResponse) XXX_Size() int

func (*GfSpGetUserBucketsResponse) XXX_Unmarshal

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

type GfSpGetUserGroupsRequest

type GfSpGetUserGroupsRequest 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"`
	// limit sets the limit of keys returned in the response
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
}

GfSpGetUserGroupsRequest is request type for the GfSpGetUserGroups RPC method

func (*GfSpGetUserGroupsRequest) Descriptor

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

func (*GfSpGetUserGroupsRequest) GetAccountId

func (m *GfSpGetUserGroupsRequest) GetAccountId() string

func (*GfSpGetUserGroupsRequest) GetLimit

func (m *GfSpGetUserGroupsRequest) GetLimit() uint32

func (*GfSpGetUserGroupsRequest) GetStartAfter

func (m *GfSpGetUserGroupsRequest) GetStartAfter() uint64

func (*GfSpGetUserGroupsRequest) Marshal

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

func (*GfSpGetUserGroupsRequest) MarshalTo

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

func (*GfSpGetUserGroupsRequest) MarshalToSizedBuffer

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

func (*GfSpGetUserGroupsRequest) ProtoMessage

func (*GfSpGetUserGroupsRequest) ProtoMessage()

func (*GfSpGetUserGroupsRequest) Reset

func (m *GfSpGetUserGroupsRequest) Reset()

func (*GfSpGetUserGroupsRequest) Size

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

func (*GfSpGetUserGroupsRequest) String

func (m *GfSpGetUserGroupsRequest) String() string

func (*GfSpGetUserGroupsRequest) Unmarshal

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

func (*GfSpGetUserGroupsRequest) XXX_DiscardUnknown

func (m *GfSpGetUserGroupsRequest) XXX_DiscardUnknown()

func (*GfSpGetUserGroupsRequest) XXX_Marshal

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

func (*GfSpGetUserGroupsRequest) XXX_Merge

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

func (*GfSpGetUserGroupsRequest) XXX_Size

func (m *GfSpGetUserGroupsRequest) XXX_Size() int

func (*GfSpGetUserGroupsRequest) XXX_Unmarshal

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

type GfSpGetUserGroupsResponse

type GfSpGetUserGroupsResponse struct {
	// groups defines the response of group list
	Groups []*GroupMember `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GfSpGetUserGroupsResponse is response type for the GfSpGetUserGroups RPC method

func (*GfSpGetUserGroupsResponse) Descriptor

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

func (*GfSpGetUserGroupsResponse) GetGroups

func (m *GfSpGetUserGroupsResponse) GetGroups() []*GroupMember

func (*GfSpGetUserGroupsResponse) Marshal

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

func (*GfSpGetUserGroupsResponse) MarshalTo

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

func (*GfSpGetUserGroupsResponse) MarshalToSizedBuffer

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

func (*GfSpGetUserGroupsResponse) ProtoMessage

func (*GfSpGetUserGroupsResponse) ProtoMessage()

func (*GfSpGetUserGroupsResponse) Reset

func (m *GfSpGetUserGroupsResponse) Reset()

func (*GfSpGetUserGroupsResponse) Size

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

func (*GfSpGetUserGroupsResponse) String

func (m *GfSpGetUserGroupsResponse) String() string

func (*GfSpGetUserGroupsResponse) Unmarshal

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

func (*GfSpGetUserGroupsResponse) XXX_DiscardUnknown

func (m *GfSpGetUserGroupsResponse) XXX_DiscardUnknown()

func (*GfSpGetUserGroupsResponse) XXX_Marshal

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

func (*GfSpGetUserGroupsResponse) XXX_Merge

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

func (*GfSpGetUserGroupsResponse) XXX_Size

func (m *GfSpGetUserGroupsResponse) XXX_Size() int

func (*GfSpGetUserGroupsResponse) XXX_Unmarshal

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

type GfSpGetUserOwnedGroupsRequest

type GfSpGetUserOwnedGroupsRequest 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"`
	// limit sets the limit of keys returned in the response
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
}

GfSpGetUserOwnedGroupsRequest is request type for the GfSpGetUserOwnedGroups RPC method

func (*GfSpGetUserOwnedGroupsRequest) Descriptor

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

func (*GfSpGetUserOwnedGroupsRequest) GetAccountId

func (m *GfSpGetUserOwnedGroupsRequest) GetAccountId() string

func (*GfSpGetUserOwnedGroupsRequest) GetLimit

func (m *GfSpGetUserOwnedGroupsRequest) GetLimit() uint32

func (*GfSpGetUserOwnedGroupsRequest) GetStartAfter

func (m *GfSpGetUserOwnedGroupsRequest) GetStartAfter() uint64

func (*GfSpGetUserOwnedGroupsRequest) Marshal

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

func (*GfSpGetUserOwnedGroupsRequest) MarshalTo

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

func (*GfSpGetUserOwnedGroupsRequest) MarshalToSizedBuffer

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

func (*GfSpGetUserOwnedGroupsRequest) ProtoMessage

func (*GfSpGetUserOwnedGroupsRequest) ProtoMessage()

func (*GfSpGetUserOwnedGroupsRequest) Reset

func (m *GfSpGetUserOwnedGroupsRequest) Reset()

func (*GfSpGetUserOwnedGroupsRequest) Size

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

func (*GfSpGetUserOwnedGroupsRequest) String

func (*GfSpGetUserOwnedGroupsRequest) Unmarshal

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

func (*GfSpGetUserOwnedGroupsRequest) XXX_DiscardUnknown

func (m *GfSpGetUserOwnedGroupsRequest) XXX_DiscardUnknown()

func (*GfSpGetUserOwnedGroupsRequest) XXX_Marshal

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

func (*GfSpGetUserOwnedGroupsRequest) XXX_Merge

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

func (*GfSpGetUserOwnedGroupsRequest) XXX_Size

func (m *GfSpGetUserOwnedGroupsRequest) XXX_Size() int

func (*GfSpGetUserOwnedGroupsRequest) XXX_Unmarshal

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

type GfSpGetUserOwnedGroupsResponse

type GfSpGetUserOwnedGroupsResponse struct {
	// groups defines the response of group list
	Groups []*GroupMember `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GfSpGetUserOwnedGroupsResponse is response type for the GfSpGetUserOwnedGroups RPC method

func (*GfSpGetUserOwnedGroupsResponse) Descriptor

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

func (*GfSpGetUserOwnedGroupsResponse) GetGroups

func (m *GfSpGetUserOwnedGroupsResponse) GetGroups() []*GroupMember

func (*GfSpGetUserOwnedGroupsResponse) Marshal

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

func (*GfSpGetUserOwnedGroupsResponse) MarshalTo

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

func (*GfSpGetUserOwnedGroupsResponse) MarshalToSizedBuffer

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

func (*GfSpGetUserOwnedGroupsResponse) ProtoMessage

func (*GfSpGetUserOwnedGroupsResponse) ProtoMessage()

func (*GfSpGetUserOwnedGroupsResponse) Reset

func (m *GfSpGetUserOwnedGroupsResponse) Reset()

func (*GfSpGetUserOwnedGroupsResponse) Size

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

func (*GfSpGetUserOwnedGroupsResponse) String

func (*GfSpGetUserOwnedGroupsResponse) Unmarshal

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

func (*GfSpGetUserOwnedGroupsResponse) XXX_DiscardUnknown

func (m *GfSpGetUserOwnedGroupsResponse) XXX_DiscardUnknown()

func (*GfSpGetUserOwnedGroupsResponse) XXX_Marshal

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

func (*GfSpGetUserOwnedGroupsResponse) XXX_Merge

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

func (*GfSpGetUserOwnedGroupsResponse) XXX_Size

func (m *GfSpGetUserOwnedGroupsResponse) XXX_Size() int

func (*GfSpGetUserOwnedGroupsResponse) XXX_Unmarshal

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

type GfSpGetVirtualGroupFamilyRequest

type GfSpGetVirtualGroupFamilyRequest struct {
	// vgf_id is the unique identification for vgf
	VgfId uint32 `protobuf:"varint,1,opt,name=vgf_id,json=vgfId,proto3" json:"vgf_id,omitempty"`
}

GfSpGetVirtualGroupFamilyRequest is request type for the GfSpGetVirtualGroupFamily RPC method

func (*GfSpGetVirtualGroupFamilyRequest) Descriptor

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

func (*GfSpGetVirtualGroupFamilyRequest) GetVgfId

func (*GfSpGetVirtualGroupFamilyRequest) Marshal

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

func (*GfSpGetVirtualGroupFamilyRequest) MarshalTo

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

func (*GfSpGetVirtualGroupFamilyRequest) MarshalToSizedBuffer

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

func (*GfSpGetVirtualGroupFamilyRequest) ProtoMessage

func (*GfSpGetVirtualGroupFamilyRequest) ProtoMessage()

func (*GfSpGetVirtualGroupFamilyRequest) Reset

func (*GfSpGetVirtualGroupFamilyRequest) Size

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

func (*GfSpGetVirtualGroupFamilyRequest) String

func (*GfSpGetVirtualGroupFamilyRequest) Unmarshal

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

func (*GfSpGetVirtualGroupFamilyRequest) XXX_DiscardUnknown

func (m *GfSpGetVirtualGroupFamilyRequest) XXX_DiscardUnknown()

func (*GfSpGetVirtualGroupFamilyRequest) XXX_Marshal

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

func (*GfSpGetVirtualGroupFamilyRequest) XXX_Merge

func (*GfSpGetVirtualGroupFamilyRequest) XXX_Size

func (m *GfSpGetVirtualGroupFamilyRequest) XXX_Size() int

func (*GfSpGetVirtualGroupFamilyRequest) XXX_Unmarshal

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

type GfSpGetVirtualGroupFamilyResponse

type GfSpGetVirtualGroupFamilyResponse struct {
	// vgf defines the vgf info
	Vgf *types1.GlobalVirtualGroupFamily `protobuf:"bytes,1,opt,name=vgf,proto3" json:"vgf,omitempty"`
}

GfSpGetVirtualGroupFamilyResponse is response type for the GfSpGetVirtualGroupFamily RPC method

func (*GfSpGetVirtualGroupFamilyResponse) Descriptor

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

func (*GfSpGetVirtualGroupFamilyResponse) GetVgf

func (*GfSpGetVirtualGroupFamilyResponse) Marshal

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

func (*GfSpGetVirtualGroupFamilyResponse) MarshalTo

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

func (*GfSpGetVirtualGroupFamilyResponse) MarshalToSizedBuffer

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

func (*GfSpGetVirtualGroupFamilyResponse) ProtoMessage

func (*GfSpGetVirtualGroupFamilyResponse) ProtoMessage()

func (*GfSpGetVirtualGroupFamilyResponse) Reset

func (*GfSpGetVirtualGroupFamilyResponse) Size

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

func (*GfSpGetVirtualGroupFamilyResponse) String

func (*GfSpGetVirtualGroupFamilyResponse) Unmarshal

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

func (*GfSpGetVirtualGroupFamilyResponse) XXX_DiscardUnknown

func (m *GfSpGetVirtualGroupFamilyResponse) XXX_DiscardUnknown()

func (*GfSpGetVirtualGroupFamilyResponse) XXX_Marshal

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

func (*GfSpGetVirtualGroupFamilyResponse) XXX_Merge

func (*GfSpGetVirtualGroupFamilyResponse) XXX_Size

func (m *GfSpGetVirtualGroupFamilyResponse) XXX_Size() int

func (*GfSpGetVirtualGroupFamilyResponse) XXX_Unmarshal

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

type GfSpListBucketReadRecordRequest

type GfSpListBucketReadRecordRequest struct {
	// bucket info from the greenfield chain
	BucketInfo *types.BucketInfo `protobuf:"bytes,1,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	// start_timestamp_us is the list request's left side, like [start_timestamp_us, end_timestamp_us)
	StartTimestampUs int64 `protobuf:"varint,2,opt,name=start_timestamp_us,json=startTimestampUs,proto3" json:"start_timestamp_us,omitempty"`
	// start_timestamp_us is the list request's right side, like [start_timestamp_us, end_timestamp_us)
	EndTimestampUs int64 `protobuf:"varint,3,opt,name=end_timestamp_us,json=endTimestampUs,proto3" json:"end_timestamp_us,omitempty"`
	// max_record_num is used to limit max list records
	MaxRecordNum int64 `protobuf:"varint,4,opt,name=max_record_num,json=maxRecordNum,proto3" json:"max_record_num,omitempty"`
}

ListBucketReadRecordRequest is request type for the ListBucketReadRecord RPC method.

func (*GfSpListBucketReadRecordRequest) Descriptor

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

func (*GfSpListBucketReadRecordRequest) GetBucketInfo

func (m *GfSpListBucketReadRecordRequest) GetBucketInfo() *types.BucketInfo

func (*GfSpListBucketReadRecordRequest) GetEndTimestampUs

func (m *GfSpListBucketReadRecordRequest) GetEndTimestampUs() int64

func (*GfSpListBucketReadRecordRequest) GetMaxRecordNum

func (m *GfSpListBucketReadRecordRequest) GetMaxRecordNum() int64

func (*GfSpListBucketReadRecordRequest) GetStartTimestampUs

func (m *GfSpListBucketReadRecordRequest) GetStartTimestampUs() int64

func (*GfSpListBucketReadRecordRequest) Marshal

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

func (*GfSpListBucketReadRecordRequest) MarshalTo

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

func (*GfSpListBucketReadRecordRequest) MarshalToSizedBuffer

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

func (*GfSpListBucketReadRecordRequest) ProtoMessage

func (*GfSpListBucketReadRecordRequest) ProtoMessage()

func (*GfSpListBucketReadRecordRequest) Reset

func (*GfSpListBucketReadRecordRequest) Size

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

func (*GfSpListBucketReadRecordRequest) String

func (*GfSpListBucketReadRecordRequest) Unmarshal

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

func (*GfSpListBucketReadRecordRequest) XXX_DiscardUnknown

func (m *GfSpListBucketReadRecordRequest) XXX_DiscardUnknown()

func (*GfSpListBucketReadRecordRequest) XXX_Marshal

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

func (*GfSpListBucketReadRecordRequest) XXX_Merge

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

func (*GfSpListBucketReadRecordRequest) XXX_Size

func (m *GfSpListBucketReadRecordRequest) XXX_Size() int

func (*GfSpListBucketReadRecordRequest) XXX_Unmarshal

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

type GfSpListBucketReadRecordResponse

type GfSpListBucketReadRecordResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// read_records are the read record list
	ReadRecords []*ReadRecord `protobuf:"bytes,2,rep,name=read_records,json=readRecords,proto3" json:"read_records,omitempty"`
	// next_start_timestamp_us is used to fetch next batch, When the list is completed, it is 0.
	NextStartTimestampUs int64 `` /* 126-byte string literal not displayed */
}

ListBucketReadRecordResponse is response type for the ListBucketReadRecord RPC method.

func (*GfSpListBucketReadRecordResponse) Descriptor

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

func (*GfSpListBucketReadRecordResponse) GetErr

func (*GfSpListBucketReadRecordResponse) GetNextStartTimestampUs

func (m *GfSpListBucketReadRecordResponse) GetNextStartTimestampUs() int64

func (*GfSpListBucketReadRecordResponse) GetReadRecords

func (m *GfSpListBucketReadRecordResponse) GetReadRecords() []*ReadRecord

func (*GfSpListBucketReadRecordResponse) Marshal

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

func (*GfSpListBucketReadRecordResponse) MarshalTo

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

func (*GfSpListBucketReadRecordResponse) MarshalToSizedBuffer

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

func (*GfSpListBucketReadRecordResponse) ProtoMessage

func (*GfSpListBucketReadRecordResponse) ProtoMessage()

func (*GfSpListBucketReadRecordResponse) Reset

func (*GfSpListBucketReadRecordResponse) Size

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

func (*GfSpListBucketReadRecordResponse) String

func (*GfSpListBucketReadRecordResponse) Unmarshal

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

func (*GfSpListBucketReadRecordResponse) XXX_DiscardUnknown

func (m *GfSpListBucketReadRecordResponse) XXX_DiscardUnknown()

func (*GfSpListBucketReadRecordResponse) XXX_Marshal

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

func (*GfSpListBucketReadRecordResponse) XXX_Merge

func (*GfSpListBucketReadRecordResponse) XXX_Size

func (m *GfSpListBucketReadRecordResponse) XXX_Size() int

func (*GfSpListBucketReadRecordResponse) XXX_Unmarshal

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

type GfSpListBucketsByIDsRequest

type GfSpListBucketsByIDsRequest struct {
	// bucket_id is the list of unique identifier for buckets
	BucketIds []uint64 `protobuf:"varint,1,rep,packed,name=bucket_ids,json=bucketIds,proto3" json:"bucket_ids,omitempty"`
	// include_removed indicates whether this request can get the removed buckets information
	IncludeRemoved bool `protobuf:"varint,2,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpGetBucketByIDsRequest is request type for the GfSpListBucketsByIDs RPC method

func (*GfSpListBucketsByIDsRequest) Descriptor

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

func (*GfSpListBucketsByIDsRequest) GetBucketIds

func (m *GfSpListBucketsByIDsRequest) GetBucketIds() []uint64

func (*GfSpListBucketsByIDsRequest) GetIncludeRemoved

func (m *GfSpListBucketsByIDsRequest) GetIncludeRemoved() bool

func (*GfSpListBucketsByIDsRequest) Marshal

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

func (*GfSpListBucketsByIDsRequest) MarshalTo

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

func (*GfSpListBucketsByIDsRequest) MarshalToSizedBuffer

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

func (*GfSpListBucketsByIDsRequest) ProtoMessage

func (*GfSpListBucketsByIDsRequest) ProtoMessage()

func (*GfSpListBucketsByIDsRequest) Reset

func (m *GfSpListBucketsByIDsRequest) Reset()

func (*GfSpListBucketsByIDsRequest) Size

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

func (*GfSpListBucketsByIDsRequest) String

func (m *GfSpListBucketsByIDsRequest) String() string

func (*GfSpListBucketsByIDsRequest) Unmarshal

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

func (*GfSpListBucketsByIDsRequest) XXX_DiscardUnknown

func (m *GfSpListBucketsByIDsRequest) XXX_DiscardUnknown()

func (*GfSpListBucketsByIDsRequest) XXX_Marshal

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

func (*GfSpListBucketsByIDsRequest) XXX_Merge

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

func (*GfSpListBucketsByIDsRequest) XXX_Size

func (m *GfSpListBucketsByIDsRequest) XXX_Size() int

func (*GfSpListBucketsByIDsRequest) XXX_Unmarshal

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

type GfSpListBucketsByIDsResponse

type GfSpListBucketsByIDsResponse struct {
	// buckets defines the information of a bucket map
	Buckets map[uint64]*Bucket `` /* 156-byte string literal not displayed */
}

GfSpGetBucketByIDsResponse is response type for the GfSpListBucketsByIDs RPC method.

func (*GfSpListBucketsByIDsResponse) Descriptor

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

func (*GfSpListBucketsByIDsResponse) GetBuckets

func (m *GfSpListBucketsByIDsResponse) GetBuckets() map[uint64]*Bucket

func (*GfSpListBucketsByIDsResponse) Marshal

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

func (*GfSpListBucketsByIDsResponse) MarshalTo

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

func (*GfSpListBucketsByIDsResponse) MarshalToSizedBuffer

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

func (*GfSpListBucketsByIDsResponse) ProtoMessage

func (*GfSpListBucketsByIDsResponse) ProtoMessage()

func (*GfSpListBucketsByIDsResponse) Reset

func (m *GfSpListBucketsByIDsResponse) Reset()

func (*GfSpListBucketsByIDsResponse) Size

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

func (*GfSpListBucketsByIDsResponse) String

func (*GfSpListBucketsByIDsResponse) Unmarshal

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

func (*GfSpListBucketsByIDsResponse) XXX_DiscardUnknown

func (m *GfSpListBucketsByIDsResponse) XXX_DiscardUnknown()

func (*GfSpListBucketsByIDsResponse) XXX_Marshal

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

func (*GfSpListBucketsByIDsResponse) XXX_Merge

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

func (*GfSpListBucketsByIDsResponse) XXX_Size

func (m *GfSpListBucketsByIDsResponse) XXX_Size() int

func (*GfSpListBucketsByIDsResponse) XXX_Unmarshal

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

type GfSpListDeletedObjectsByBlockNumberRangeRequest

type GfSpListDeletedObjectsByBlockNumberRangeRequest struct {
	// start_block_number defines the start of range
	// [start_block_number, end_block_number], start_block_number > end_block_number is invalid
	StartBlockNumber int64 `protobuf:"varint,1,opt,name=start_block_number,json=startBlockNumber,proto3" json:"start_block_number,omitempty"`
	// end_block_number defines the end of range
	// end_block_number < 0 or start_block_number > end_block_number is invalid
	EndBlockNumber int64 `protobuf:"varint,2,opt,name=end_block_number,json=endBlockNumber,proto3" json:"end_block_number,omitempty"`
	// include_private indicates whether this request can get the private objects information
	IncludePrivate bool `protobuf:"varint,3,opt,name=include_private,json=includePrivate,proto3" json:"include_private,omitempty"`
}

GfSpListDeletedObjectsByBlockNumberRangeRequest is request type for the GfSpListDeletedObjectsByBlockNumberRange RPC method

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) Descriptor

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) GetEndBlockNumber

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) GetIncludePrivate

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) GetStartBlockNumber

func (m *GfSpListDeletedObjectsByBlockNumberRangeRequest) GetStartBlockNumber() int64

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) Marshal

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

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) MarshalTo

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) MarshalToSizedBuffer

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

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) ProtoMessage

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) Reset

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) Size

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) String

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) Unmarshal

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_DiscardUnknown

func (m *GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_DiscardUnknown()

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_Marshal

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

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_Merge

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_Size

func (*GfSpListDeletedObjectsByBlockNumberRangeRequest) XXX_Unmarshal

type GfSpListDeletedObjectsByBlockNumberRangeResponse

type GfSpListDeletedObjectsByBlockNumberRangeResponse struct {
	// objects defines the list of object
	Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// latest_block_number defines the response objects latest block number
	EndBlockNumber int64 `protobuf:"varint,2,opt,name=end_block_number,json=endBlockNumber,proto3" json:"end_block_number,omitempty"`
}

GfSpListDeletedObjectsByBlockNumberRangeResponse is response type for the GfSpListDeletedObjectsByBlockNumberRange RPC method.

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) Descriptor

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) GetEndBlockNumber

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) GetObjects

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) Marshal

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

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) MarshalTo

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) MarshalToSizedBuffer

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

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) ProtoMessage

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) Reset

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) Size

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) String

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) Unmarshal

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_DiscardUnknown

func (m *GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_DiscardUnknown()

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_Marshal

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

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_Merge

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_Size

func (*GfSpListDeletedObjectsByBlockNumberRangeResponse) XXX_Unmarshal

type GfSpListExpiredBucketsBySpRequest

type GfSpListExpiredBucketsBySpRequest struct {
	// create_at defines the create timestamp of bucket
	CreateAt int64 `protobuf:"varint,1,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// primary_sp_id defines the primary sp id of bucket
	PrimarySpId uint32 `protobuf:"varint,2,opt,name=primary_sp_id,json=primarySpId,proto3" json:"primary_sp_id,omitempty"`
	// limit defines the return number limit of bucket
	Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
}

GfSpListExpiredBucketsBySpRequest is the request type for the GfSpListExpiredBucketsBySp RPC method.

func (*GfSpListExpiredBucketsBySpRequest) Descriptor

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

func (*GfSpListExpiredBucketsBySpRequest) GetCreateAt

func (m *GfSpListExpiredBucketsBySpRequest) GetCreateAt() int64

func (*GfSpListExpiredBucketsBySpRequest) GetLimit

func (*GfSpListExpiredBucketsBySpRequest) GetPrimarySpId

func (m *GfSpListExpiredBucketsBySpRequest) GetPrimarySpId() uint32

func (*GfSpListExpiredBucketsBySpRequest) Marshal

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

func (*GfSpListExpiredBucketsBySpRequest) MarshalTo

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

func (*GfSpListExpiredBucketsBySpRequest) MarshalToSizedBuffer

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

func (*GfSpListExpiredBucketsBySpRequest) ProtoMessage

func (*GfSpListExpiredBucketsBySpRequest) ProtoMessage()

func (*GfSpListExpiredBucketsBySpRequest) Reset

func (*GfSpListExpiredBucketsBySpRequest) Size

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

func (*GfSpListExpiredBucketsBySpRequest) String

func (*GfSpListExpiredBucketsBySpRequest) Unmarshal

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

func (*GfSpListExpiredBucketsBySpRequest) XXX_DiscardUnknown

func (m *GfSpListExpiredBucketsBySpRequest) XXX_DiscardUnknown()

func (*GfSpListExpiredBucketsBySpRequest) XXX_Marshal

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

func (*GfSpListExpiredBucketsBySpRequest) XXX_Merge

func (*GfSpListExpiredBucketsBySpRequest) XXX_Size

func (m *GfSpListExpiredBucketsBySpRequest) XXX_Size() int

func (*GfSpListExpiredBucketsBySpRequest) XXX_Unmarshal

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

type GfSpListExpiredBucketsBySpResponse

type GfSpListExpiredBucketsBySpResponse struct {
	// buckets defines the list of expired bucket
	Buckets []*Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
}

GfSpListExpiredBucketsBySpResponse is the response type for the GfSpListExpiredBucketsBySp RPC method.

func (*GfSpListExpiredBucketsBySpResponse) Descriptor

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

func (*GfSpListExpiredBucketsBySpResponse) GetBuckets

func (m *GfSpListExpiredBucketsBySpResponse) GetBuckets() []*Bucket

func (*GfSpListExpiredBucketsBySpResponse) Marshal

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

func (*GfSpListExpiredBucketsBySpResponse) MarshalTo

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

func (*GfSpListExpiredBucketsBySpResponse) MarshalToSizedBuffer

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

func (*GfSpListExpiredBucketsBySpResponse) ProtoMessage

func (*GfSpListExpiredBucketsBySpResponse) ProtoMessage()

func (*GfSpListExpiredBucketsBySpResponse) Reset

func (*GfSpListExpiredBucketsBySpResponse) Size

func (*GfSpListExpiredBucketsBySpResponse) String

func (*GfSpListExpiredBucketsBySpResponse) Unmarshal

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

func (*GfSpListExpiredBucketsBySpResponse) XXX_DiscardUnknown

func (m *GfSpListExpiredBucketsBySpResponse) XXX_DiscardUnknown()

func (*GfSpListExpiredBucketsBySpResponse) XXX_Marshal

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

func (*GfSpListExpiredBucketsBySpResponse) XXX_Merge

func (*GfSpListExpiredBucketsBySpResponse) XXX_Size

func (*GfSpListExpiredBucketsBySpResponse) XXX_Unmarshal

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

type GfSpListGlobalVirtualGroupsByBucketRequest

type GfSpListGlobalVirtualGroupsByBucketRequest struct {
	// bucket_id is the unique identification for bucket
	BucketId uint64 `protobuf:"varint,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
}

GfSpListGlobalVirtualGroupsByBucketRequest is request type for the ListGlobalVirtualGroupsByBucket RPC method

func (*GfSpListGlobalVirtualGroupsByBucketRequest) Descriptor

func (*GfSpListGlobalVirtualGroupsByBucketRequest) GetBucketId

func (*GfSpListGlobalVirtualGroupsByBucketRequest) Marshal

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

func (*GfSpListGlobalVirtualGroupsByBucketRequest) MarshalTo

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

func (*GfSpListGlobalVirtualGroupsByBucketRequest) MarshalToSizedBuffer

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

func (*GfSpListGlobalVirtualGroupsByBucketRequest) ProtoMessage

func (*GfSpListGlobalVirtualGroupsByBucketRequest) Reset

func (*GfSpListGlobalVirtualGroupsByBucketRequest) Size

func (*GfSpListGlobalVirtualGroupsByBucketRequest) String

func (*GfSpListGlobalVirtualGroupsByBucketRequest) Unmarshal

func (*GfSpListGlobalVirtualGroupsByBucketRequest) XXX_DiscardUnknown

func (m *GfSpListGlobalVirtualGroupsByBucketRequest) XXX_DiscardUnknown()

func (*GfSpListGlobalVirtualGroupsByBucketRequest) XXX_Marshal

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

func (*GfSpListGlobalVirtualGroupsByBucketRequest) XXX_Merge

func (*GfSpListGlobalVirtualGroupsByBucketRequest) XXX_Size

func (*GfSpListGlobalVirtualGroupsByBucketRequest) XXX_Unmarshal

type GfSpListGlobalVirtualGroupsByBucketResponse

type GfSpListGlobalVirtualGroupsByBucketResponse struct {
	// groups defines a list of gvg info
	Groups []*types1.GlobalVirtualGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GfSpListGlobalVirtualGroupsByBucketResponse is response type for the ListGlobalVirtualGroupsByBucket RPC method

func (*GfSpListGlobalVirtualGroupsByBucketResponse) Descriptor

func (*GfSpListGlobalVirtualGroupsByBucketResponse) GetGroups

func (*GfSpListGlobalVirtualGroupsByBucketResponse) Marshal

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

func (*GfSpListGlobalVirtualGroupsByBucketResponse) MarshalTo

func (*GfSpListGlobalVirtualGroupsByBucketResponse) MarshalToSizedBuffer

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

func (*GfSpListGlobalVirtualGroupsByBucketResponse) ProtoMessage

func (*GfSpListGlobalVirtualGroupsByBucketResponse) Reset

func (*GfSpListGlobalVirtualGroupsByBucketResponse) Size

func (*GfSpListGlobalVirtualGroupsByBucketResponse) String

func (*GfSpListGlobalVirtualGroupsByBucketResponse) Unmarshal

func (*GfSpListGlobalVirtualGroupsByBucketResponse) XXX_DiscardUnknown

func (m *GfSpListGlobalVirtualGroupsByBucketResponse) XXX_DiscardUnknown()

func (*GfSpListGlobalVirtualGroupsByBucketResponse) XXX_Marshal

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

func (*GfSpListGlobalVirtualGroupsByBucketResponse) XXX_Merge

func (*GfSpListGlobalVirtualGroupsByBucketResponse) XXX_Size

func (*GfSpListGlobalVirtualGroupsByBucketResponse) XXX_Unmarshal

type GfSpListGlobalVirtualGroupsBySecondarySPRequest

type GfSpListGlobalVirtualGroupsBySecondarySPRequest struct {
	// sp_id is the unique identification for sp
	SpId uint32 `protobuf:"varint,1,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpListGlobalVirtualGroupsBySecondarySPRequest is request type for the GfSpListGlobalVirtualGroupsBySecondarySP RPC method

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) Descriptor

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) GetSpId

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) Marshal

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) MarshalTo

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) MarshalToSizedBuffer

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) ProtoMessage

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) Reset

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) Size

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) String

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) Unmarshal

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_DiscardUnknown

func (m *GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_DiscardUnknown()

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_Marshal

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_Merge

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_Size

func (*GfSpListGlobalVirtualGroupsBySecondarySPRequest) XXX_Unmarshal

type GfSpListGlobalVirtualGroupsBySecondarySPResponse

type GfSpListGlobalVirtualGroupsBySecondarySPResponse struct {
	// groups defines a list of gvg info
	Groups []*types1.GlobalVirtualGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GfSpListGlobalVirtualGroupsBySecondarySPResponse is response type for the GfSpListGlobalVirtualGroupsBySecondarySP RPC method

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) Descriptor

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) GetGroups

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) Marshal

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) MarshalTo

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) MarshalToSizedBuffer

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) ProtoMessage

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) Reset

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) Size

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) String

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) Unmarshal

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_DiscardUnknown

func (m *GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_DiscardUnknown()

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_Marshal

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

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_Merge

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_Size

func (*GfSpListGlobalVirtualGroupsBySecondarySPResponse) XXX_Unmarshal

type GfSpListGroupsByIDsRequest added in v0.2.5

type GfSpListGroupsByIDsRequest struct {
	// group_ids is the list of unique identifier for groups
	GroupIds []uint64 `protobuf:"varint,1,rep,packed,name=group_ids,json=groupIds,proto3" json:"group_ids,omitempty"`
}

GfSpListGroupsByIDsRequest is request type for the GfSpListGroupsByIDs RPC method

func (*GfSpListGroupsByIDsRequest) Descriptor added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) GetGroupIds added in v0.2.5

func (m *GfSpListGroupsByIDsRequest) GetGroupIds() []uint64

func (*GfSpListGroupsByIDsRequest) Marshal added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) MarshalTo added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) ProtoMessage added in v0.2.5

func (*GfSpListGroupsByIDsRequest) ProtoMessage()

func (*GfSpListGroupsByIDsRequest) Reset added in v0.2.5

func (m *GfSpListGroupsByIDsRequest) Reset()

func (*GfSpListGroupsByIDsRequest) Size added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) String added in v0.2.5

func (m *GfSpListGroupsByIDsRequest) String() string

func (*GfSpListGroupsByIDsRequest) Unmarshal added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListGroupsByIDsRequest) XXX_DiscardUnknown()

func (*GfSpListGroupsByIDsRequest) XXX_Marshal added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) XXX_Merge added in v0.2.5

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

func (*GfSpListGroupsByIDsRequest) XXX_Size added in v0.2.5

func (m *GfSpListGroupsByIDsRequest) XXX_Size() int

func (*GfSpListGroupsByIDsRequest) XXX_Unmarshal added in v0.2.5

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

type GfSpListGroupsByIDsResponse added in v0.2.5

type GfSpListGroupsByIDsResponse struct {
	// groups defines the information of a group map
	Groups map[uint64]*Group `` /* 154-byte string literal not displayed */
}

GfSpListGroupsByIDsResponse is response type for the GfSpListGroupsByIDs RPC method.

func (*GfSpListGroupsByIDsResponse) Descriptor added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) GetGroups added in v0.2.5

func (m *GfSpListGroupsByIDsResponse) GetGroups() map[uint64]*Group

func (*GfSpListGroupsByIDsResponse) Marshal added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) MarshalTo added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) ProtoMessage added in v0.2.5

func (*GfSpListGroupsByIDsResponse) ProtoMessage()

func (*GfSpListGroupsByIDsResponse) Reset added in v0.2.5

func (m *GfSpListGroupsByIDsResponse) Reset()

func (*GfSpListGroupsByIDsResponse) Size added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) String added in v0.2.5

func (m *GfSpListGroupsByIDsResponse) String() string

func (*GfSpListGroupsByIDsResponse) Unmarshal added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListGroupsByIDsResponse) XXX_DiscardUnknown()

func (*GfSpListGroupsByIDsResponse) XXX_Marshal added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) XXX_Merge added in v0.2.5

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

func (*GfSpListGroupsByIDsResponse) XXX_Size added in v0.2.5

func (m *GfSpListGroupsByIDsResponse) XXX_Size() int

func (*GfSpListGroupsByIDsResponse) XXX_Unmarshal added in v0.2.5

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

type GfSpListMigrateBucketEventsRequest

type GfSpListMigrateBucketEventsRequest struct {
	// block_id is the unique identification for block
	BlockId uint64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// sp_id is the unique identification for sp
	SpId uint32 `protobuf:"varint,2,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpListMigrateBucketEventsRequest is request type for the GfSpListMigrateBucketEvents RPC method

func (*GfSpListMigrateBucketEventsRequest) Descriptor

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

func (*GfSpListMigrateBucketEventsRequest) GetBlockId

func (*GfSpListMigrateBucketEventsRequest) GetSpId

func (*GfSpListMigrateBucketEventsRequest) Marshal

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

func (*GfSpListMigrateBucketEventsRequest) MarshalTo

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

func (*GfSpListMigrateBucketEventsRequest) MarshalToSizedBuffer

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

func (*GfSpListMigrateBucketEventsRequest) ProtoMessage

func (*GfSpListMigrateBucketEventsRequest) ProtoMessage()

func (*GfSpListMigrateBucketEventsRequest) Reset

func (*GfSpListMigrateBucketEventsRequest) Size

func (*GfSpListMigrateBucketEventsRequest) String

func (*GfSpListMigrateBucketEventsRequest) Unmarshal

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

func (*GfSpListMigrateBucketEventsRequest) XXX_DiscardUnknown

func (m *GfSpListMigrateBucketEventsRequest) XXX_DiscardUnknown()

func (*GfSpListMigrateBucketEventsRequest) XXX_Marshal

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

func (*GfSpListMigrateBucketEventsRequest) XXX_Merge

func (*GfSpListMigrateBucketEventsRequest) XXX_Size

func (*GfSpListMigrateBucketEventsRequest) XXX_Unmarshal

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

type GfSpListMigrateBucketEventsResponse

type GfSpListMigrateBucketEventsResponse struct {
	// ListMigrateBucketEvents is the combination of migrate bucket events
	Events []*ListMigrateBucketEvents `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
}

GfSpListMigrateBucketEventsResponse is response type for the GfSpListMigrateBucketEvents RPC method

func (*GfSpListMigrateBucketEventsResponse) Descriptor

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

func (*GfSpListMigrateBucketEventsResponse) GetEvents

func (*GfSpListMigrateBucketEventsResponse) Marshal

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

func (*GfSpListMigrateBucketEventsResponse) MarshalTo

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

func (*GfSpListMigrateBucketEventsResponse) MarshalToSizedBuffer

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

func (*GfSpListMigrateBucketEventsResponse) ProtoMessage

func (*GfSpListMigrateBucketEventsResponse) ProtoMessage()

func (*GfSpListMigrateBucketEventsResponse) Reset

func (*GfSpListMigrateBucketEventsResponse) Size

func (*GfSpListMigrateBucketEventsResponse) String

func (*GfSpListMigrateBucketEventsResponse) Unmarshal

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

func (*GfSpListMigrateBucketEventsResponse) XXX_DiscardUnknown

func (m *GfSpListMigrateBucketEventsResponse) XXX_DiscardUnknown()

func (*GfSpListMigrateBucketEventsResponse) XXX_Marshal

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

func (*GfSpListMigrateBucketEventsResponse) XXX_Merge

func (*GfSpListMigrateBucketEventsResponse) XXX_Size

func (*GfSpListMigrateBucketEventsResponse) XXX_Unmarshal

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

type GfSpListObjectPoliciesRequest added in v0.2.5

type GfSpListObjectPoliciesRequest struct {
	// object_name defines the name of object
	ObjectName string `protobuf:"bytes,1,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// bucket_name defines the name of bucket
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// action_type defines the requested action type of permission
	ActionType types4.ActionType `` /* 130-byte string literal not displayed */
	// limit sets the limit of keys returned in the response
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,5,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
}

GfSpListObjectPoliciesRequest is request type for the GfSpListObjectPolicies RPC method

func (*GfSpListObjectPoliciesRequest) Descriptor added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) GetActionType added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) GetActionType() types4.ActionType

func (*GfSpListObjectPoliciesRequest) GetBucketName added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) GetBucketName() string

func (*GfSpListObjectPoliciesRequest) GetLimit added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) GetLimit() uint32

func (*GfSpListObjectPoliciesRequest) GetObjectName added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) GetObjectName() string

func (*GfSpListObjectPoliciesRequest) GetStartAfter added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) GetStartAfter() uint64

func (*GfSpListObjectPoliciesRequest) Marshal added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) MarshalTo added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) ProtoMessage added in v0.2.5

func (*GfSpListObjectPoliciesRequest) ProtoMessage()

func (*GfSpListObjectPoliciesRequest) Reset added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) Reset()

func (*GfSpListObjectPoliciesRequest) Size added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) String added in v0.2.5

func (*GfSpListObjectPoliciesRequest) Unmarshal added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) XXX_DiscardUnknown()

func (*GfSpListObjectPoliciesRequest) XXX_Marshal added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) XXX_Merge added in v0.2.5

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

func (*GfSpListObjectPoliciesRequest) XXX_Size added in v0.2.5

func (m *GfSpListObjectPoliciesRequest) XXX_Size() int

func (*GfSpListObjectPoliciesRequest) XXX_Unmarshal added in v0.2.5

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

type GfSpListObjectPoliciesResponse added in v0.2.5

type GfSpListObjectPoliciesResponse struct {
	Policies []*Policy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
}

GfSpListObjectPoliciesResponse is response type for the GfSpListObjectPolicies RPC method

func (*GfSpListObjectPoliciesResponse) Descriptor added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) GetPolicies added in v0.2.5

func (m *GfSpListObjectPoliciesResponse) GetPolicies() []*Policy

func (*GfSpListObjectPoliciesResponse) Marshal added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) MarshalTo added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) ProtoMessage added in v0.2.5

func (*GfSpListObjectPoliciesResponse) ProtoMessage()

func (*GfSpListObjectPoliciesResponse) Reset added in v0.2.5

func (m *GfSpListObjectPoliciesResponse) Reset()

func (*GfSpListObjectPoliciesResponse) Size added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) String added in v0.2.5

func (*GfSpListObjectPoliciesResponse) Unmarshal added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListObjectPoliciesResponse) XXX_DiscardUnknown()

func (*GfSpListObjectPoliciesResponse) XXX_Marshal added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) XXX_Merge added in v0.2.5

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

func (*GfSpListObjectPoliciesResponse) XXX_Size added in v0.2.5

func (m *GfSpListObjectPoliciesResponse) XXX_Size() int

func (*GfSpListObjectPoliciesResponse) XXX_Unmarshal added in v0.2.5

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

type GfSpListObjectsByBucketNameRequest

type GfSpListObjectsByBucketNameRequest struct {
	// bucket_name is the name of the bucket
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// account_id is the account address of user
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// max_keys sets the maximum number of keys returned in the response
	MaxKeys uint64 `protobuf:"varint,3,opt,name=max_keys,json=maxKeys,proto3" json:"max_keys,omitempty"`
	// start_after is where you want to start listing from
	StartAfter string `protobuf:"bytes,4,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// continuation_token indicates that the list is being continued on this bucket with a token
	ContinuationToken string `protobuf:"bytes,5,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
	// delimiter is a character you use to group keys
	Delimiter string `protobuf:"bytes,6,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// prefix limits the response to keys that begin with the specified prefix
	Prefix string `protobuf:"bytes,7,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// include_removed indicates whether this request can get the removed objects information
	IncludeRemoved bool `protobuf:"varint,8,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpListObjectsByBucketNameRequest is request type for the GfSpListObjectsByBucketName RPC method

func (*GfSpListObjectsByBucketNameRequest) Descriptor

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

func (*GfSpListObjectsByBucketNameRequest) GetAccountId

func (m *GfSpListObjectsByBucketNameRequest) GetAccountId() string

func (*GfSpListObjectsByBucketNameRequest) GetBucketName

func (m *GfSpListObjectsByBucketNameRequest) GetBucketName() string

func (*GfSpListObjectsByBucketNameRequest) GetContinuationToken

func (m *GfSpListObjectsByBucketNameRequest) GetContinuationToken() string

func (*GfSpListObjectsByBucketNameRequest) GetDelimiter

func (m *GfSpListObjectsByBucketNameRequest) GetDelimiter() string

func (*GfSpListObjectsByBucketNameRequest) GetIncludeRemoved

func (m *GfSpListObjectsByBucketNameRequest) GetIncludeRemoved() bool

func (*GfSpListObjectsByBucketNameRequest) GetMaxKeys

func (*GfSpListObjectsByBucketNameRequest) GetPrefix

func (*GfSpListObjectsByBucketNameRequest) GetStartAfter

func (m *GfSpListObjectsByBucketNameRequest) GetStartAfter() string

func (*GfSpListObjectsByBucketNameRequest) Marshal

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

func (*GfSpListObjectsByBucketNameRequest) MarshalTo

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

func (*GfSpListObjectsByBucketNameRequest) MarshalToSizedBuffer

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

func (*GfSpListObjectsByBucketNameRequest) ProtoMessage

func (*GfSpListObjectsByBucketNameRequest) ProtoMessage()

func (*GfSpListObjectsByBucketNameRequest) Reset

func (*GfSpListObjectsByBucketNameRequest) Size

func (*GfSpListObjectsByBucketNameRequest) String

func (*GfSpListObjectsByBucketNameRequest) Unmarshal

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

func (*GfSpListObjectsByBucketNameRequest) XXX_DiscardUnknown

func (m *GfSpListObjectsByBucketNameRequest) XXX_DiscardUnknown()

func (*GfSpListObjectsByBucketNameRequest) XXX_Marshal

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

func (*GfSpListObjectsByBucketNameRequest) XXX_Merge

func (*GfSpListObjectsByBucketNameRequest) XXX_Size

func (*GfSpListObjectsByBucketNameRequest) XXX_Unmarshal

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

type GfSpListObjectsByBucketNameResponse

type GfSpListObjectsByBucketNameResponse struct {
	// objects defines the list of object
	Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// key_count is the number of keys returned with this request
	KeyCount uint64 `protobuf:"varint,2,opt,name=key_count,json=keyCount,proto3" json:"key_count,omitempty"`
	// max_keys sets the maximum number of keys returned in the response
	MaxKeys uint64 `protobuf:"varint,3,opt,name=max_keys,json=maxKeys,proto3" json:"max_keys,omitempty"`
	// is_truncated set to false if all of the results were returned. set to true if more keys are available to return
	IsTruncated bool `protobuf:"varint,4,opt,name=is_truncated,json=isTruncated,proto3" json:"is_truncated,omitempty"`
	// next_continuation_token is sent when is_truncated is true, which means there are more keys in the bucket that can be listed
	NextContinuationToken string `` /* 126-byte string literal not displayed */
	// name of the bucket
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// prefix is the prefix used during the query.
	Prefix string `protobuf:"bytes,7,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// delimiter is the delimiter used during the query
	Delimiter string `protobuf:"bytes,8,opt,name=delimiter,proto3" json:"delimiter,omitempty"`
	// common_prefixes a list of strings representing common prefixes. common_prefixes are those parts of object key names that fall between the specified delimiters
	CommonPrefixes []string `protobuf:"bytes,9,rep,name=common_prefixes,json=commonPrefixes,proto3" json:"common_prefixes,omitempty"`
	// continuationToken is the continuation token used during the query
	ContinuationToken string `protobuf:"bytes,10,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
}

GfSpListObjectsByBucketNameResponse is response type for the GfSpListObjectsByBucketName RPC method.

func (*GfSpListObjectsByBucketNameResponse) Descriptor

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

func (*GfSpListObjectsByBucketNameResponse) GetCommonPrefixes

func (m *GfSpListObjectsByBucketNameResponse) GetCommonPrefixes() []string

func (*GfSpListObjectsByBucketNameResponse) GetContinuationToken

func (m *GfSpListObjectsByBucketNameResponse) GetContinuationToken() string

func (*GfSpListObjectsByBucketNameResponse) GetDelimiter

func (m *GfSpListObjectsByBucketNameResponse) GetDelimiter() string

func (*GfSpListObjectsByBucketNameResponse) GetIsTruncated

func (m *GfSpListObjectsByBucketNameResponse) GetIsTruncated() bool

func (*GfSpListObjectsByBucketNameResponse) GetKeyCount

func (*GfSpListObjectsByBucketNameResponse) GetMaxKeys

func (*GfSpListObjectsByBucketNameResponse) GetName

func (*GfSpListObjectsByBucketNameResponse) GetNextContinuationToken

func (m *GfSpListObjectsByBucketNameResponse) GetNextContinuationToken() string

func (*GfSpListObjectsByBucketNameResponse) GetObjects

func (m *GfSpListObjectsByBucketNameResponse) GetObjects() []*Object

func (*GfSpListObjectsByBucketNameResponse) GetPrefix

func (*GfSpListObjectsByBucketNameResponse) Marshal

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

func (*GfSpListObjectsByBucketNameResponse) MarshalTo

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

func (*GfSpListObjectsByBucketNameResponse) MarshalToSizedBuffer

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

func (*GfSpListObjectsByBucketNameResponse) ProtoMessage

func (*GfSpListObjectsByBucketNameResponse) ProtoMessage()

func (*GfSpListObjectsByBucketNameResponse) Reset

func (*GfSpListObjectsByBucketNameResponse) Size

func (*GfSpListObjectsByBucketNameResponse) String

func (*GfSpListObjectsByBucketNameResponse) Unmarshal

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

func (*GfSpListObjectsByBucketNameResponse) XXX_DiscardUnknown

func (m *GfSpListObjectsByBucketNameResponse) XXX_DiscardUnknown()

func (*GfSpListObjectsByBucketNameResponse) XXX_Marshal

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

func (*GfSpListObjectsByBucketNameResponse) XXX_Merge

func (*GfSpListObjectsByBucketNameResponse) XXX_Size

func (*GfSpListObjectsByBucketNameResponse) XXX_Unmarshal

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

type GfSpListObjectsByGVGAndBucketForGCRequest

type GfSpListObjectsByGVGAndBucketForGCRequest struct {
	// gvg_id is the unique identification for gvg
	GvgId uint32 `protobuf:"varint,1,opt,name=gvg_id,json=gvgId,proto3" json:"gvg_id,omitempty"`
	// bucket_id is the unique identification for bucket
	BucketId uint64 `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// defines the number of results that should be returned in response, the maximum is 1000, default 50
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

GfSpListObjectByGVGAndBucketForGCRequest is request type for the GfSpListObjectByGVGAndBucketForGC RPC method

func (*GfSpListObjectsByGVGAndBucketForGCRequest) Descriptor

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

func (*GfSpListObjectsByGVGAndBucketForGCRequest) GetBucketId

func (*GfSpListObjectsByGVGAndBucketForGCRequest) GetGvgId

func (*GfSpListObjectsByGVGAndBucketForGCRequest) GetLimit

func (*GfSpListObjectsByGVGAndBucketForGCRequest) GetStartAfter

func (*GfSpListObjectsByGVGAndBucketForGCRequest) Marshal

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

func (*GfSpListObjectsByGVGAndBucketForGCRequest) MarshalTo

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

func (*GfSpListObjectsByGVGAndBucketForGCRequest) MarshalToSizedBuffer

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

func (*GfSpListObjectsByGVGAndBucketForGCRequest) ProtoMessage

func (*GfSpListObjectsByGVGAndBucketForGCRequest) Reset

func (*GfSpListObjectsByGVGAndBucketForGCRequest) Size

func (*GfSpListObjectsByGVGAndBucketForGCRequest) String

func (*GfSpListObjectsByGVGAndBucketForGCRequest) Unmarshal

func (*GfSpListObjectsByGVGAndBucketForGCRequest) XXX_DiscardUnknown

func (m *GfSpListObjectsByGVGAndBucketForGCRequest) XXX_DiscardUnknown()

func (*GfSpListObjectsByGVGAndBucketForGCRequest) XXX_Marshal

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

func (*GfSpListObjectsByGVGAndBucketForGCRequest) XXX_Merge

func (*GfSpListObjectsByGVGAndBucketForGCRequest) XXX_Size

func (*GfSpListObjectsByGVGAndBucketForGCRequest) XXX_Unmarshal

type GfSpListObjectsByGVGAndBucketForGCResponse

type GfSpListObjectsByGVGAndBucketForGCResponse struct {
	// object defines object related bucket and gvg info
	Objects []*ObjectDetails `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
}

GfSpListObjectByGVGAndBucketForGCResponse is response type for the GfSpListObjectByGVGAndBucketForGC RPC method

func (*GfSpListObjectsByGVGAndBucketForGCResponse) Descriptor

func (*GfSpListObjectsByGVGAndBucketForGCResponse) GetObjects

func (*GfSpListObjectsByGVGAndBucketForGCResponse) Marshal

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

func (*GfSpListObjectsByGVGAndBucketForGCResponse) MarshalTo

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

func (*GfSpListObjectsByGVGAndBucketForGCResponse) MarshalToSizedBuffer

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

func (*GfSpListObjectsByGVGAndBucketForGCResponse) ProtoMessage

func (*GfSpListObjectsByGVGAndBucketForGCResponse) Reset

func (*GfSpListObjectsByGVGAndBucketForGCResponse) Size

func (*GfSpListObjectsByGVGAndBucketForGCResponse) String

func (*GfSpListObjectsByGVGAndBucketForGCResponse) Unmarshal

func (*GfSpListObjectsByGVGAndBucketForGCResponse) XXX_DiscardUnknown

func (m *GfSpListObjectsByGVGAndBucketForGCResponse) XXX_DiscardUnknown()

func (*GfSpListObjectsByGVGAndBucketForGCResponse) XXX_Marshal

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

func (*GfSpListObjectsByGVGAndBucketForGCResponse) XXX_Merge

func (*GfSpListObjectsByGVGAndBucketForGCResponse) XXX_Size

func (*GfSpListObjectsByGVGAndBucketForGCResponse) XXX_Unmarshal

type GfSpListObjectsByIDsRequest

type GfSpListObjectsByIDsRequest struct {
	// object_ids is the list of unique identifier for objects
	ObjectIds []uint64 `protobuf:"varint,1,rep,packed,name=object_ids,json=objectIds,proto3" json:"object_ids,omitempty"`
	// include_removed indicates whether this request can get the removed objects information
	IncludeRemoved bool `protobuf:"varint,2,opt,name=include_removed,json=includeRemoved,proto3" json:"include_removed,omitempty"`
}

GfSpListObjectsByIDsRequest is request type for the GfSpListObjectsByIDs RPC method

func (*GfSpListObjectsByIDsRequest) Descriptor

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

func (*GfSpListObjectsByIDsRequest) GetIncludeRemoved

func (m *GfSpListObjectsByIDsRequest) GetIncludeRemoved() bool

func (*GfSpListObjectsByIDsRequest) GetObjectIds

func (m *GfSpListObjectsByIDsRequest) GetObjectIds() []uint64

func (*GfSpListObjectsByIDsRequest) Marshal

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

func (*GfSpListObjectsByIDsRequest) MarshalTo

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

func (*GfSpListObjectsByIDsRequest) MarshalToSizedBuffer

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

func (*GfSpListObjectsByIDsRequest) ProtoMessage

func (*GfSpListObjectsByIDsRequest) ProtoMessage()

func (*GfSpListObjectsByIDsRequest) Reset

func (m *GfSpListObjectsByIDsRequest) Reset()

func (*GfSpListObjectsByIDsRequest) Size

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

func (*GfSpListObjectsByIDsRequest) String

func (m *GfSpListObjectsByIDsRequest) String() string

func (*GfSpListObjectsByIDsRequest) Unmarshal

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

func (*GfSpListObjectsByIDsRequest) XXX_DiscardUnknown

func (m *GfSpListObjectsByIDsRequest) XXX_DiscardUnknown()

func (*GfSpListObjectsByIDsRequest) XXX_Marshal

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

func (*GfSpListObjectsByIDsRequest) XXX_Merge

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

func (*GfSpListObjectsByIDsRequest) XXX_Size

func (m *GfSpListObjectsByIDsRequest) XXX_Size() int

func (*GfSpListObjectsByIDsRequest) XXX_Unmarshal

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

type GfSpListObjectsByIDsResponse

type GfSpListObjectsByIDsResponse struct {
	// objects defines the information of a object map
	Objects map[uint64]*Object `` /* 156-byte string literal not displayed */
}

GfSpListObjectsByIDsRequest is response type for the GfSpListObjectsByIDs RPC method.

func (*GfSpListObjectsByIDsResponse) Descriptor

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

func (*GfSpListObjectsByIDsResponse) GetObjects

func (m *GfSpListObjectsByIDsResponse) GetObjects() map[uint64]*Object

func (*GfSpListObjectsByIDsResponse) Marshal

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

func (*GfSpListObjectsByIDsResponse) MarshalTo

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

func (*GfSpListObjectsByIDsResponse) MarshalToSizedBuffer

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

func (*GfSpListObjectsByIDsResponse) ProtoMessage

func (*GfSpListObjectsByIDsResponse) ProtoMessage()

func (*GfSpListObjectsByIDsResponse) Reset

func (m *GfSpListObjectsByIDsResponse) Reset()

func (*GfSpListObjectsByIDsResponse) Size

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

func (*GfSpListObjectsByIDsResponse) String

func (*GfSpListObjectsByIDsResponse) Unmarshal

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

func (*GfSpListObjectsByIDsResponse) XXX_DiscardUnknown

func (m *GfSpListObjectsByIDsResponse) XXX_DiscardUnknown()

func (*GfSpListObjectsByIDsResponse) XXX_Marshal

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

func (*GfSpListObjectsByIDsResponse) XXX_Merge

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

func (*GfSpListObjectsByIDsResponse) XXX_Size

func (m *GfSpListObjectsByIDsResponse) XXX_Size() int

func (*GfSpListObjectsByIDsResponse) XXX_Unmarshal

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

type GfSpListObjectsInGVGAndBucketRequest

type GfSpListObjectsInGVGAndBucketRequest struct {
	// gvg_id is the unique identification for gvg
	GvgId uint32 `protobuf:"varint,1,opt,name=gvg_id,json=gvgId,proto3" json:"gvg_id,omitempty"`
	// bucket_id is the unique identification for bucket
	BucketId uint64 `protobuf:"varint,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// defines the number of results that should be returned in response, the maximum is 1000, default 50
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

GfSpListObjectsInGVGAndBucketRequest is request type for the GfSpListObjectsInGVGAndBucket RPC method

func (*GfSpListObjectsInGVGAndBucketRequest) Descriptor

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

func (*GfSpListObjectsInGVGAndBucketRequest) GetBucketId

func (*GfSpListObjectsInGVGAndBucketRequest) GetGvgId

func (*GfSpListObjectsInGVGAndBucketRequest) GetLimit

func (*GfSpListObjectsInGVGAndBucketRequest) GetStartAfter

func (m *GfSpListObjectsInGVGAndBucketRequest) GetStartAfter() uint64

func (*GfSpListObjectsInGVGAndBucketRequest) Marshal

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

func (*GfSpListObjectsInGVGAndBucketRequest) MarshalTo

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

func (*GfSpListObjectsInGVGAndBucketRequest) MarshalToSizedBuffer

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

func (*GfSpListObjectsInGVGAndBucketRequest) ProtoMessage

func (*GfSpListObjectsInGVGAndBucketRequest) ProtoMessage()

func (*GfSpListObjectsInGVGAndBucketRequest) Reset

func (*GfSpListObjectsInGVGAndBucketRequest) Size

func (*GfSpListObjectsInGVGAndBucketRequest) String

func (*GfSpListObjectsInGVGAndBucketRequest) Unmarshal

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

func (*GfSpListObjectsInGVGAndBucketRequest) XXX_DiscardUnknown

func (m *GfSpListObjectsInGVGAndBucketRequest) XXX_DiscardUnknown()

func (*GfSpListObjectsInGVGAndBucketRequest) XXX_Marshal

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

func (*GfSpListObjectsInGVGAndBucketRequest) XXX_Merge

func (*GfSpListObjectsInGVGAndBucketRequest) XXX_Size

func (*GfSpListObjectsInGVGAndBucketRequest) XXX_Unmarshal

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

type GfSpListObjectsInGVGAndBucketResponse

type GfSpListObjectsInGVGAndBucketResponse struct {
	// object defines object related bucket and gvg info
	Objects []*ObjectDetails `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
}

GfSpListObjectsInGVGAndBucketResponse is response type for the GfSpListObjectsInGVGAndBucket RPC method

func (*GfSpListObjectsInGVGAndBucketResponse) Descriptor

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

func (*GfSpListObjectsInGVGAndBucketResponse) GetObjects

func (*GfSpListObjectsInGVGAndBucketResponse) Marshal

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

func (*GfSpListObjectsInGVGAndBucketResponse) MarshalTo

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

func (*GfSpListObjectsInGVGAndBucketResponse) MarshalToSizedBuffer

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

func (*GfSpListObjectsInGVGAndBucketResponse) ProtoMessage

func (*GfSpListObjectsInGVGAndBucketResponse) ProtoMessage()

func (*GfSpListObjectsInGVGAndBucketResponse) Reset

func (*GfSpListObjectsInGVGAndBucketResponse) Size

func (*GfSpListObjectsInGVGAndBucketResponse) String

func (*GfSpListObjectsInGVGAndBucketResponse) Unmarshal

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

func (*GfSpListObjectsInGVGAndBucketResponse) XXX_DiscardUnknown

func (m *GfSpListObjectsInGVGAndBucketResponse) XXX_DiscardUnknown()

func (*GfSpListObjectsInGVGAndBucketResponse) XXX_Marshal

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

func (*GfSpListObjectsInGVGAndBucketResponse) XXX_Merge

func (*GfSpListObjectsInGVGAndBucketResponse) XXX_Size

func (*GfSpListObjectsInGVGAndBucketResponse) XXX_Unmarshal

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

type GfSpListObjectsInGVGRequest

type GfSpListObjectsInGVGRequest struct {
	// gvg_id is the unique identification for gvg
	GvgId uint32 `protobuf:"varint,1,opt,name=gvg_id,json=gvgId,proto3" json:"gvg_id,omitempty"`
	// start_after is where you want to start listing from
	StartAfter uint64 `protobuf:"varint,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// defines the number of results that should be returned in response, the maximum is 1000, default 50
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

GfSpListObjectsInGVGRequest is request type for the GfSpListObjectsInGVG RPC method

func (*GfSpListObjectsInGVGRequest) Descriptor

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

func (*GfSpListObjectsInGVGRequest) GetGvgId

func (m *GfSpListObjectsInGVGRequest) GetGvgId() uint32

func (*GfSpListObjectsInGVGRequest) GetLimit

func (m *GfSpListObjectsInGVGRequest) GetLimit() uint32

func (*GfSpListObjectsInGVGRequest) GetStartAfter

func (m *GfSpListObjectsInGVGRequest) GetStartAfter() uint64

func (*GfSpListObjectsInGVGRequest) Marshal

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

func (*GfSpListObjectsInGVGRequest) MarshalTo

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

func (*GfSpListObjectsInGVGRequest) MarshalToSizedBuffer

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

func (*GfSpListObjectsInGVGRequest) ProtoMessage

func (*GfSpListObjectsInGVGRequest) ProtoMessage()

func (*GfSpListObjectsInGVGRequest) Reset

func (m *GfSpListObjectsInGVGRequest) Reset()

func (*GfSpListObjectsInGVGRequest) Size

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

func (*GfSpListObjectsInGVGRequest) String

func (m *GfSpListObjectsInGVGRequest) String() string

func (*GfSpListObjectsInGVGRequest) Unmarshal

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

func (*GfSpListObjectsInGVGRequest) XXX_DiscardUnknown

func (m *GfSpListObjectsInGVGRequest) XXX_DiscardUnknown()

func (*GfSpListObjectsInGVGRequest) XXX_Marshal

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

func (*GfSpListObjectsInGVGRequest) XXX_Merge

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

func (*GfSpListObjectsInGVGRequest) XXX_Size

func (m *GfSpListObjectsInGVGRequest) XXX_Size() int

func (*GfSpListObjectsInGVGRequest) XXX_Unmarshal

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

type GfSpListObjectsInGVGResponse

type GfSpListObjectsInGVGResponse struct {
	// object defines object related bucket and gvg info
	Objects []*ObjectDetails `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
}

GfSpListObjectsInGVGResponse is response type for the GfSpListObjectsInGVG RPC method

func (*GfSpListObjectsInGVGResponse) Descriptor

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

func (*GfSpListObjectsInGVGResponse) GetObjects

func (m *GfSpListObjectsInGVGResponse) GetObjects() []*ObjectDetails

func (*GfSpListObjectsInGVGResponse) Marshal

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

func (*GfSpListObjectsInGVGResponse) MarshalTo

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

func (*GfSpListObjectsInGVGResponse) MarshalToSizedBuffer

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

func (*GfSpListObjectsInGVGResponse) ProtoMessage

func (*GfSpListObjectsInGVGResponse) ProtoMessage()

func (*GfSpListObjectsInGVGResponse) Reset

func (m *GfSpListObjectsInGVGResponse) Reset()

func (*GfSpListObjectsInGVGResponse) Size

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

func (*GfSpListObjectsInGVGResponse) String

func (*GfSpListObjectsInGVGResponse) Unmarshal

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

func (*GfSpListObjectsInGVGResponse) XXX_DiscardUnknown

func (m *GfSpListObjectsInGVGResponse) XXX_DiscardUnknown()

func (*GfSpListObjectsInGVGResponse) XXX_Marshal

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

func (*GfSpListObjectsInGVGResponse) XXX_Merge

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

func (*GfSpListObjectsInGVGResponse) XXX_Size

func (m *GfSpListObjectsInGVGResponse) XXX_Size() int

func (*GfSpListObjectsInGVGResponse) XXX_Unmarshal

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

type GfSpListPaymentAccountStreamsRequest added in v0.2.5

type GfSpListPaymentAccountStreamsRequest struct {
	// payment_account defines the address of payment account
	PaymentAccount string `protobuf:"bytes,1,opt,name=payment_account,json=paymentAccount,proto3" json:"payment_account,omitempty"`
}

GfSpListPaymentAccountStreamsRequest is request type for the GfSpListPaymentAccountStreams RPC method

func (*GfSpListPaymentAccountStreamsRequest) Descriptor added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) GetPaymentAccount added in v0.2.5

func (m *GfSpListPaymentAccountStreamsRequest) GetPaymentAccount() string

func (*GfSpListPaymentAccountStreamsRequest) Marshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) MarshalTo added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) ProtoMessage added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) ProtoMessage()

func (*GfSpListPaymentAccountStreamsRequest) Reset added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) Size added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) String added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) Unmarshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListPaymentAccountStreamsRequest) XXX_DiscardUnknown()

func (*GfSpListPaymentAccountStreamsRequest) XXX_Marshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsRequest) XXX_Merge added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) XXX_Size added in v0.2.5

func (*GfSpListPaymentAccountStreamsRequest) XXX_Unmarshal added in v0.2.5

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

type GfSpListPaymentAccountStreamsResponse added in v0.2.5

type GfSpListPaymentAccountStreamsResponse struct {
	// buckets defines the list of bucket
	Buckets []*Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
}

GfSpListPaymentAccountStreamsResponse is response type for the GfSpListPaymentAccountStreams RPC method

func (*GfSpListPaymentAccountStreamsResponse) Descriptor added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) GetBuckets added in v0.2.5

func (m *GfSpListPaymentAccountStreamsResponse) GetBuckets() []*Bucket

func (*GfSpListPaymentAccountStreamsResponse) Marshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) MarshalTo added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) ProtoMessage added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) ProtoMessage()

func (*GfSpListPaymentAccountStreamsResponse) Reset added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) Size added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) String added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) Unmarshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListPaymentAccountStreamsResponse) XXX_DiscardUnknown()

func (*GfSpListPaymentAccountStreamsResponse) XXX_Marshal added in v0.2.5

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

func (*GfSpListPaymentAccountStreamsResponse) XXX_Merge added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) XXX_Size added in v0.2.5

func (*GfSpListPaymentAccountStreamsResponse) XXX_Unmarshal added in v0.2.5

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

type GfSpListSpExitEventsRequest

type GfSpListSpExitEventsRequest struct {
	// block_id is the unique identification for block
	BlockId uint64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// sp_id is the unique identification for sp
	SpId uint32 `protobuf:"varint,2,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpListSpExitEventsRequest is request type for the GfSpListSPExitEvents RPC method

func (*GfSpListSpExitEventsRequest) Descriptor

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

func (*GfSpListSpExitEventsRequest) GetBlockId

func (m *GfSpListSpExitEventsRequest) GetBlockId() uint64

func (*GfSpListSpExitEventsRequest) GetSpId

func (m *GfSpListSpExitEventsRequest) GetSpId() uint32

func (*GfSpListSpExitEventsRequest) Marshal

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

func (*GfSpListSpExitEventsRequest) MarshalTo

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

func (*GfSpListSpExitEventsRequest) MarshalToSizedBuffer

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

func (*GfSpListSpExitEventsRequest) ProtoMessage

func (*GfSpListSpExitEventsRequest) ProtoMessage()

func (*GfSpListSpExitEventsRequest) Reset

func (m *GfSpListSpExitEventsRequest) Reset()

func (*GfSpListSpExitEventsRequest) Size

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

func (*GfSpListSpExitEventsRequest) String

func (m *GfSpListSpExitEventsRequest) String() string

func (*GfSpListSpExitEventsRequest) Unmarshal

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

func (*GfSpListSpExitEventsRequest) XXX_DiscardUnknown

func (m *GfSpListSpExitEventsRequest) XXX_DiscardUnknown()

func (*GfSpListSpExitEventsRequest) XXX_Marshal

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

func (*GfSpListSpExitEventsRequest) XXX_Merge

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

func (*GfSpListSpExitEventsRequest) XXX_Size

func (m *GfSpListSpExitEventsRequest) XXX_Size() int

func (*GfSpListSpExitEventsRequest) XXX_Unmarshal

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

type GfSpListSpExitEventsResponse

type GfSpListSpExitEventsResponse struct {
	// ListSpExitEvents is the combination of sp exit events
	Events *ListSpExitEvents `protobuf:"bytes,1,opt,name=events,proto3" json:"events,omitempty"`
}

GfSpListSpExitEventsResponse is response type for the GfSpListSPExitEvents RPC method

func (*GfSpListSpExitEventsResponse) Descriptor

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

func (*GfSpListSpExitEventsResponse) GetEvents

func (*GfSpListSpExitEventsResponse) Marshal

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

func (*GfSpListSpExitEventsResponse) MarshalTo

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

func (*GfSpListSpExitEventsResponse) MarshalToSizedBuffer

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

func (*GfSpListSpExitEventsResponse) ProtoMessage

func (*GfSpListSpExitEventsResponse) ProtoMessage()

func (*GfSpListSpExitEventsResponse) Reset

func (m *GfSpListSpExitEventsResponse) Reset()

func (*GfSpListSpExitEventsResponse) Size

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

func (*GfSpListSpExitEventsResponse) String

func (*GfSpListSpExitEventsResponse) Unmarshal

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

func (*GfSpListSpExitEventsResponse) XXX_DiscardUnknown

func (m *GfSpListSpExitEventsResponse) XXX_DiscardUnknown()

func (*GfSpListSpExitEventsResponse) XXX_Marshal

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

func (*GfSpListSpExitEventsResponse) XXX_Merge

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

func (*GfSpListSpExitEventsResponse) XXX_Size

func (m *GfSpListSpExitEventsResponse) XXX_Size() int

func (*GfSpListSpExitEventsResponse) XXX_Unmarshal

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

type GfSpListSwapOutEventsRequest

type GfSpListSwapOutEventsRequest struct {
	// block_id is the unique identification for block
	BlockId uint64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	// sp_id is the unique identification for sp
	SpId uint32 `protobuf:"varint,2,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpListSwapOutEventsRequest is request type for the GfSpListSwapOutEvents RPC method

func (*GfSpListSwapOutEventsRequest) Descriptor

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

func (*GfSpListSwapOutEventsRequest) GetBlockId

func (m *GfSpListSwapOutEventsRequest) GetBlockId() uint64

func (*GfSpListSwapOutEventsRequest) GetSpId

func (m *GfSpListSwapOutEventsRequest) GetSpId() uint32

func (*GfSpListSwapOutEventsRequest) Marshal

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

func (*GfSpListSwapOutEventsRequest) MarshalTo

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

func (*GfSpListSwapOutEventsRequest) MarshalToSizedBuffer

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

func (*GfSpListSwapOutEventsRequest) ProtoMessage

func (*GfSpListSwapOutEventsRequest) ProtoMessage()

func (*GfSpListSwapOutEventsRequest) Reset

func (m *GfSpListSwapOutEventsRequest) Reset()

func (*GfSpListSwapOutEventsRequest) Size

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

func (*GfSpListSwapOutEventsRequest) String

func (*GfSpListSwapOutEventsRequest) Unmarshal

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

func (*GfSpListSwapOutEventsRequest) XXX_DiscardUnknown

func (m *GfSpListSwapOutEventsRequest) XXX_DiscardUnknown()

func (*GfSpListSwapOutEventsRequest) XXX_Marshal

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

func (*GfSpListSwapOutEventsRequest) XXX_Merge

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

func (*GfSpListSwapOutEventsRequest) XXX_Size

func (m *GfSpListSwapOutEventsRequest) XXX_Size() int

func (*GfSpListSwapOutEventsRequest) XXX_Unmarshal

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

type GfSpListSwapOutEventsResponse

type GfSpListSwapOutEventsResponse struct {
	// ListSwapOutEvents is the combination of swap out events
	Events []*ListSwapOutEvents `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
}

GfSpListSwapOutEventsResponse is response type for the GfSpListSwapOutEvents RPC method

func (*GfSpListSwapOutEventsResponse) Descriptor

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

func (*GfSpListSwapOutEventsResponse) GetEvents

func (*GfSpListSwapOutEventsResponse) Marshal

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

func (*GfSpListSwapOutEventsResponse) MarshalTo

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

func (*GfSpListSwapOutEventsResponse) MarshalToSizedBuffer

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

func (*GfSpListSwapOutEventsResponse) ProtoMessage

func (*GfSpListSwapOutEventsResponse) ProtoMessage()

func (*GfSpListSwapOutEventsResponse) Reset

func (m *GfSpListSwapOutEventsResponse) Reset()

func (*GfSpListSwapOutEventsResponse) Size

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

func (*GfSpListSwapOutEventsResponse) String

func (*GfSpListSwapOutEventsResponse) Unmarshal

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

func (*GfSpListSwapOutEventsResponse) XXX_DiscardUnknown

func (m *GfSpListSwapOutEventsResponse) XXX_DiscardUnknown()

func (*GfSpListSwapOutEventsResponse) XXX_Marshal

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

func (*GfSpListSwapOutEventsResponse) XXX_Merge

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

func (*GfSpListSwapOutEventsResponse) XXX_Size

func (m *GfSpListSwapOutEventsResponse) XXX_Size() int

func (*GfSpListSwapOutEventsResponse) XXX_Unmarshal

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

type GfSpListUserPaymentAccountsRequest added in v0.2.5

type GfSpListUserPaymentAccountsRequest 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"`
}

GfSpListUserPaymentAccountsRequest is request type for the GfSpListUserPaymentAccounts RPC method

func (*GfSpListUserPaymentAccountsRequest) Descriptor added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) GetAccountId added in v0.2.5

func (m *GfSpListUserPaymentAccountsRequest) GetAccountId() string

func (*GfSpListUserPaymentAccountsRequest) Marshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) MarshalTo added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) ProtoMessage added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) ProtoMessage()

func (*GfSpListUserPaymentAccountsRequest) Reset added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) Size added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) String added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) Unmarshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListUserPaymentAccountsRequest) XXX_DiscardUnknown()

func (*GfSpListUserPaymentAccountsRequest) XXX_Marshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsRequest) XXX_Merge added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) XXX_Size added in v0.2.5

func (*GfSpListUserPaymentAccountsRequest) XXX_Unmarshal added in v0.2.5

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

type GfSpListUserPaymentAccountsResponse added in v0.2.5

type GfSpListUserPaymentAccountsResponse struct {
	// stream_records defines stream payment records of a stream account
	StreamRecords []*StreamRecordMeta `protobuf:"bytes,1,rep,name=stream_records,json=streamRecords,proto3" json:"stream_records,omitempty"`
}

GfSpListUserPaymentAccountsResponse is response type for the GfSpListUserPaymentAccounts RPC method

func (*GfSpListUserPaymentAccountsResponse) Descriptor added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) GetStreamRecords added in v0.2.5

func (m *GfSpListUserPaymentAccountsResponse) GetStreamRecords() []*StreamRecordMeta

func (*GfSpListUserPaymentAccountsResponse) Marshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) MarshalTo added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) MarshalToSizedBuffer added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) ProtoMessage added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) ProtoMessage()

func (*GfSpListUserPaymentAccountsResponse) Reset added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) Size added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) String added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) Unmarshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) XXX_DiscardUnknown added in v0.2.5

func (m *GfSpListUserPaymentAccountsResponse) XXX_DiscardUnknown()

func (*GfSpListUserPaymentAccountsResponse) XXX_Marshal added in v0.2.5

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

func (*GfSpListUserPaymentAccountsResponse) XXX_Merge added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) XXX_Size added in v0.2.5

func (*GfSpListUserPaymentAccountsResponse) XXX_Unmarshal added in v0.2.5

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

type GfSpListVirtualGroupFamiliesBySpIDRequest

type GfSpListVirtualGroupFamiliesBySpIDRequest struct {
	// sp_id is the unique identification for sp
	SpId uint32 `protobuf:"varint,1,opt,name=sp_id,json=spId,proto3" json:"sp_id,omitempty"`
}

GfSpListVirtualGroupFamiliesBySpIDRequest is request type for the GfSpListVirtualGroupFamilies RPC method

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) Descriptor

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

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) GetSpId

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) Marshal

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

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) MarshalTo

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

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) MarshalToSizedBuffer

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

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) ProtoMessage

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) Reset

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) Size

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) String

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) Unmarshal

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_DiscardUnknown

func (m *GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_DiscardUnknown()

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_Marshal

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

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_Merge

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_Size

func (*GfSpListVirtualGroupFamiliesBySpIDRequest) XXX_Unmarshal

type GfSpListVirtualGroupFamiliesBySpIDResponse

type GfSpListVirtualGroupFamiliesBySpIDResponse struct {
	// global_virtual_group_families is a list of global virtual group families
	GlobalVirtualGroupFamilies []*types1.GlobalVirtualGroupFamily `` /* 143-byte string literal not displayed */
}

GfSpListVirtualGroupFamiliesBySpIDResponse is response type for the GfSpListVirtualGroupFamilies RPC method

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) Descriptor

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) GetGlobalVirtualGroupFamilies

func (m *GfSpListVirtualGroupFamiliesBySpIDResponse) GetGlobalVirtualGroupFamilies() []*types1.GlobalVirtualGroupFamily

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) Marshal

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

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) MarshalTo

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

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) MarshalToSizedBuffer

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

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) ProtoMessage

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) Reset

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) Size

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) String

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) Unmarshal

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_DiscardUnknown

func (m *GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_DiscardUnknown()

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_Marshal

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

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_Merge

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_Size

func (*GfSpListVirtualGroupFamiliesBySpIDResponse) XXX_Unmarshal

type GfSpMetadataServiceClient

type GfSpMetadataServiceClient interface {
	GfSpGetUserBuckets(ctx context.Context, in *GfSpGetUserBucketsRequest, opts ...grpc.CallOption) (*GfSpGetUserBucketsResponse, error)
	GfSpListObjectsByBucketName(ctx context.Context, in *GfSpListObjectsByBucketNameRequest, opts ...grpc.CallOption) (*GfSpListObjectsByBucketNameResponse, error)
	GfSpGetBucketByBucketName(ctx context.Context, in *GfSpGetBucketByBucketNameRequest, opts ...grpc.CallOption) (*GfSpGetBucketByBucketNameResponse, error)
	GfSpGetBucketByBucketID(ctx context.Context, in *GfSpGetBucketByBucketIDRequest, opts ...grpc.CallOption) (*GfSpGetBucketByBucketIDResponse, error)
	GfSpListDeletedObjectsByBlockNumberRange(ctx context.Context, in *GfSpListDeletedObjectsByBlockNumberRangeRequest, opts ...grpc.CallOption) (*GfSpListDeletedObjectsByBlockNumberRangeResponse, error)
	GfSpGetUserBucketsCount(ctx context.Context, in *GfSpGetUserBucketsCountRequest, opts ...grpc.CallOption) (*GfSpGetUserBucketsCountResponse, error)
	GfSpListExpiredBucketsBySp(ctx context.Context, in *GfSpListExpiredBucketsBySpRequest, opts ...grpc.CallOption) (*GfSpListExpiredBucketsBySpResponse, error)
	GfSpGetObjectMeta(ctx context.Context, in *GfSpGetObjectMetaRequest, opts ...grpc.CallOption) (*GfSpGetObjectMetaResponse, error)
	GfSpGetPaymentByBucketName(ctx context.Context, in *GfSpGetPaymentByBucketNameRequest, opts ...grpc.CallOption) (*GfSpGetPaymentByBucketNameResponse, error)
	GfSpGetPaymentByBucketID(ctx context.Context, in *GfSpGetPaymentByBucketIDRequest, opts ...grpc.CallOption) (*GfSpGetPaymentByBucketIDResponse, error)
	GfSpVerifyPermission(ctx context.Context, in *types.QueryVerifyPermissionRequest, opts ...grpc.CallOption) (*types.QueryVerifyPermissionResponse, error)
	GfSpGetBucketMeta(ctx context.Context, in *GfSpGetBucketMetaRequest, opts ...grpc.CallOption) (*GfSpGetBucketMetaResponse, error)
	GfSpGetEndpointBySpID(ctx context.Context, in *GfSpGetEndpointBySpIDRequest, opts ...grpc.CallOption) (*GfSpGetEndpointBySpIDResponse, error)
	GfSpGetBucketReadQuota(ctx context.Context, in *GfSpGetBucketReadQuotaRequest, opts ...grpc.CallOption) (*GfSpGetBucketReadQuotaResponse, error)
	GfSpListBucketReadRecord(ctx context.Context, in *GfSpListBucketReadRecordRequest, opts ...grpc.CallOption) (*GfSpListBucketReadRecordResponse, error)
	GfSpQueryUploadProgress(ctx context.Context, in *GfSpQueryUploadProgressRequest, opts ...grpc.CallOption) (*GfSpQueryUploadProgressResponse, error)
	GfSpQueryResumableUploadSegment(ctx context.Context, in *GfSpQueryResumableUploadSegmentRequest, opts ...grpc.CallOption) (*GfSpQueryResumableUploadSegmentResponse, error)
	GfSpGetGroupList(ctx context.Context, in *GfSpGetGroupListRequest, opts ...grpc.CallOption) (*GfSpGetGroupListResponse, error)
	GfSpListBucketsByIDs(ctx context.Context, in *GfSpListBucketsByIDsRequest, opts ...grpc.CallOption) (*GfSpListBucketsByIDsResponse, error)
	GfSpListObjectsByIDs(ctx context.Context, in *GfSpListObjectsByIDsRequest, opts ...grpc.CallOption) (*GfSpListObjectsByIDsResponse, error)
	GfSpVerifyPermissionByID(ctx context.Context, in *GfSpVerifyPermissionByIDRequest, opts ...grpc.CallOption) (*GfSpVerifyPermissionByIDResponse, error)
	GfSpListVirtualGroupFamiliesBySpID(ctx context.Context, in *GfSpListVirtualGroupFamiliesBySpIDRequest, opts ...grpc.CallOption) (*GfSpListVirtualGroupFamiliesBySpIDResponse, error)
	GfSpGetGlobalVirtualGroupByGvgID(ctx context.Context, in *GfSpGetGlobalVirtualGroupByGvgIDRequest, opts ...grpc.CallOption) (*GfSpGetGlobalVirtualGroupByGvgIDResponse, error)
	GfSpGetVirtualGroupFamily(ctx context.Context, in *GfSpGetVirtualGroupFamilyRequest, opts ...grpc.CallOption) (*GfSpGetVirtualGroupFamilyResponse, error)
	GfSpGetGlobalVirtualGroup(ctx context.Context, in *GfSpGetGlobalVirtualGroupRequest, opts ...grpc.CallOption) (*GfSpGetGlobalVirtualGroupResponse, error)
	GfSpListObjectsInGVG(ctx context.Context, in *GfSpListObjectsInGVGRequest, opts ...grpc.CallOption) (*GfSpListObjectsInGVGResponse, error)
	GfSpListObjectsInGVGAndBucket(ctx context.Context, in *GfSpListObjectsInGVGAndBucketRequest, opts ...grpc.CallOption) (*GfSpListObjectsInGVGAndBucketResponse, error)
	GfSpListObjectsByGVGAndBucketForGC(ctx context.Context, in *GfSpListObjectsByGVGAndBucketForGCRequest, opts ...grpc.CallOption) (*GfSpListObjectsByGVGAndBucketForGCResponse, error)
	GfSpListGlobalVirtualGroupsBySecondarySP(ctx context.Context, in *GfSpListGlobalVirtualGroupsBySecondarySPRequest, opts ...grpc.CallOption) (*GfSpListGlobalVirtualGroupsBySecondarySPResponse, error)
	GfSpListGlobalVirtualGroupsByBucket(ctx context.Context, in *GfSpListGlobalVirtualGroupsByBucketRequest, opts ...grpc.CallOption) (*GfSpListGlobalVirtualGroupsByBucketResponse, error)
	GfSpListMigrateBucketEvents(ctx context.Context, in *GfSpListMigrateBucketEventsRequest, opts ...grpc.CallOption) (*GfSpListMigrateBucketEventsResponse, error)
	GfSpListSwapOutEvents(ctx context.Context, in *GfSpListSwapOutEventsRequest, opts ...grpc.CallOption) (*GfSpListSwapOutEventsResponse, error)
	GfSpListSpExitEvents(ctx context.Context, in *GfSpListSpExitEventsRequest, opts ...grpc.CallOption) (*GfSpListSpExitEventsResponse, error)
	GfSpGetSPInfo(ctx context.Context, in *GfSpGetSPInfoRequest, opts ...grpc.CallOption) (*GfSpGetSPInfoResponse, error)
	GfSpGetStatus(ctx context.Context, in *GfSpGetStatusRequest, opts ...grpc.CallOption) (*GfSpGetStatusResponse, error)
	GfSpGetUserGroups(ctx context.Context, in *GfSpGetUserGroupsRequest, opts ...grpc.CallOption) (*GfSpGetUserGroupsResponse, error)
	GfSpGetGroupMembers(ctx context.Context, in *GfSpGetGroupMembersRequest, opts ...grpc.CallOption) (*GfSpGetGroupMembersResponse, error)
	GfSpGetUserOwnedGroups(ctx context.Context, in *GfSpGetUserOwnedGroupsRequest, opts ...grpc.CallOption) (*GfSpGetUserOwnedGroupsResponse, error)
	GfSpListObjectPolicies(ctx context.Context, in *GfSpListObjectPoliciesRequest, opts ...grpc.CallOption) (*GfSpListObjectPoliciesResponse, error)
	GfSpListPaymentAccountStreams(ctx context.Context, in *GfSpListPaymentAccountStreamsRequest, opts ...grpc.CallOption) (*GfSpListPaymentAccountStreamsResponse, error)
	GfSpListUserPaymentAccounts(ctx context.Context, in *GfSpListUserPaymentAccountsRequest, opts ...grpc.CallOption) (*GfSpListUserPaymentAccountsResponse, error)
	GfSpListGroupsByIDs(ctx context.Context, in *GfSpListGroupsByIDsRequest, opts ...grpc.CallOption) (*GfSpListGroupsByIDsResponse, error)
}

GfSpMetadataServiceClient is the client API for GfSpMetadataService service.

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

func NewGfSpMetadataServiceClient

func NewGfSpMetadataServiceClient(cc grpc1.ClientConn) GfSpMetadataServiceClient

type GfSpMetadataServiceServer

type GfSpMetadataServiceServer interface {
	GfSpGetUserBuckets(context.Context, *GfSpGetUserBucketsRequest) (*GfSpGetUserBucketsResponse, error)
	GfSpListObjectsByBucketName(context.Context, *GfSpListObjectsByBucketNameRequest) (*GfSpListObjectsByBucketNameResponse, error)
	GfSpGetBucketByBucketName(context.Context, *GfSpGetBucketByBucketNameRequest) (*GfSpGetBucketByBucketNameResponse, error)
	GfSpGetBucketByBucketID(context.Context, *GfSpGetBucketByBucketIDRequest) (*GfSpGetBucketByBucketIDResponse, error)
	GfSpListDeletedObjectsByBlockNumberRange(context.Context, *GfSpListDeletedObjectsByBlockNumberRangeRequest) (*GfSpListDeletedObjectsByBlockNumberRangeResponse, error)
	GfSpGetUserBucketsCount(context.Context, *GfSpGetUserBucketsCountRequest) (*GfSpGetUserBucketsCountResponse, error)
	GfSpListExpiredBucketsBySp(context.Context, *GfSpListExpiredBucketsBySpRequest) (*GfSpListExpiredBucketsBySpResponse, error)
	GfSpGetObjectMeta(context.Context, *GfSpGetObjectMetaRequest) (*GfSpGetObjectMetaResponse, error)
	GfSpGetPaymentByBucketName(context.Context, *GfSpGetPaymentByBucketNameRequest) (*GfSpGetPaymentByBucketNameResponse, error)
	GfSpGetPaymentByBucketID(context.Context, *GfSpGetPaymentByBucketIDRequest) (*GfSpGetPaymentByBucketIDResponse, error)
	GfSpVerifyPermission(context.Context, *types.QueryVerifyPermissionRequest) (*types.QueryVerifyPermissionResponse, error)
	GfSpGetBucketMeta(context.Context, *GfSpGetBucketMetaRequest) (*GfSpGetBucketMetaResponse, error)
	GfSpGetEndpointBySpID(context.Context, *GfSpGetEndpointBySpIDRequest) (*GfSpGetEndpointBySpIDResponse, error)
	GfSpGetBucketReadQuota(context.Context, *GfSpGetBucketReadQuotaRequest) (*GfSpGetBucketReadQuotaResponse, error)
	GfSpListBucketReadRecord(context.Context, *GfSpListBucketReadRecordRequest) (*GfSpListBucketReadRecordResponse, error)
	GfSpQueryUploadProgress(context.Context, *GfSpQueryUploadProgressRequest) (*GfSpQueryUploadProgressResponse, error)
	GfSpQueryResumableUploadSegment(context.Context, *GfSpQueryResumableUploadSegmentRequest) (*GfSpQueryResumableUploadSegmentResponse, error)
	GfSpGetGroupList(context.Context, *GfSpGetGroupListRequest) (*GfSpGetGroupListResponse, error)
	GfSpListBucketsByIDs(context.Context, *GfSpListBucketsByIDsRequest) (*GfSpListBucketsByIDsResponse, error)
	GfSpListObjectsByIDs(context.Context, *GfSpListObjectsByIDsRequest) (*GfSpListObjectsByIDsResponse, error)
	GfSpVerifyPermissionByID(context.Context, *GfSpVerifyPermissionByIDRequest) (*GfSpVerifyPermissionByIDResponse, error)
	GfSpListVirtualGroupFamiliesBySpID(context.Context, *GfSpListVirtualGroupFamiliesBySpIDRequest) (*GfSpListVirtualGroupFamiliesBySpIDResponse, error)
	GfSpGetGlobalVirtualGroupByGvgID(context.Context, *GfSpGetGlobalVirtualGroupByGvgIDRequest) (*GfSpGetGlobalVirtualGroupByGvgIDResponse, error)
	GfSpGetVirtualGroupFamily(context.Context, *GfSpGetVirtualGroupFamilyRequest) (*GfSpGetVirtualGroupFamilyResponse, error)
	GfSpGetGlobalVirtualGroup(context.Context, *GfSpGetGlobalVirtualGroupRequest) (*GfSpGetGlobalVirtualGroupResponse, error)
	GfSpListObjectsInGVG(context.Context, *GfSpListObjectsInGVGRequest) (*GfSpListObjectsInGVGResponse, error)
	GfSpListObjectsInGVGAndBucket(context.Context, *GfSpListObjectsInGVGAndBucketRequest) (*GfSpListObjectsInGVGAndBucketResponse, error)
	GfSpListObjectsByGVGAndBucketForGC(context.Context, *GfSpListObjectsByGVGAndBucketForGCRequest) (*GfSpListObjectsByGVGAndBucketForGCResponse, error)
	GfSpListGlobalVirtualGroupsBySecondarySP(context.Context, *GfSpListGlobalVirtualGroupsBySecondarySPRequest) (*GfSpListGlobalVirtualGroupsBySecondarySPResponse, error)
	GfSpListGlobalVirtualGroupsByBucket(context.Context, *GfSpListGlobalVirtualGroupsByBucketRequest) (*GfSpListGlobalVirtualGroupsByBucketResponse, error)
	GfSpListMigrateBucketEvents(context.Context, *GfSpListMigrateBucketEventsRequest) (*GfSpListMigrateBucketEventsResponse, error)
	GfSpListSwapOutEvents(context.Context, *GfSpListSwapOutEventsRequest) (*GfSpListSwapOutEventsResponse, error)
	GfSpListSpExitEvents(context.Context, *GfSpListSpExitEventsRequest) (*GfSpListSpExitEventsResponse, error)
	GfSpGetSPInfo(context.Context, *GfSpGetSPInfoRequest) (*GfSpGetSPInfoResponse, error)
	GfSpGetStatus(context.Context, *GfSpGetStatusRequest) (*GfSpGetStatusResponse, error)
	GfSpGetUserGroups(context.Context, *GfSpGetUserGroupsRequest) (*GfSpGetUserGroupsResponse, error)
	GfSpGetGroupMembers(context.Context, *GfSpGetGroupMembersRequest) (*GfSpGetGroupMembersResponse, error)
	GfSpGetUserOwnedGroups(context.Context, *GfSpGetUserOwnedGroupsRequest) (*GfSpGetUserOwnedGroupsResponse, error)
	GfSpListObjectPolicies(context.Context, *GfSpListObjectPoliciesRequest) (*GfSpListObjectPoliciesResponse, error)
	GfSpListPaymentAccountStreams(context.Context, *GfSpListPaymentAccountStreamsRequest) (*GfSpListPaymentAccountStreamsResponse, error)
	GfSpListUserPaymentAccounts(context.Context, *GfSpListUserPaymentAccountsRequest) (*GfSpListUserPaymentAccountsResponse, error)
	GfSpListGroupsByIDs(context.Context, *GfSpListGroupsByIDsRequest) (*GfSpListGroupsByIDsResponse, error)
}

GfSpMetadataServiceServer is the server API for GfSpMetadataService service.

type GfSpQueryResumableUploadSegmentRequest

type GfSpQueryResumableUploadSegmentRequest struct {
	// object_id defines the unique id of the object.
	ObjectId uint64 `protobuf:"varint,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
}

GfSpQueryResumableUploadSegmentRequest is request type for the QueryObjectPutState RPC method.

func (*GfSpQueryResumableUploadSegmentRequest) Descriptor

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

func (*GfSpQueryResumableUploadSegmentRequest) GetObjectId

func (*GfSpQueryResumableUploadSegmentRequest) Marshal

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

func (*GfSpQueryResumableUploadSegmentRequest) MarshalTo

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

func (*GfSpQueryResumableUploadSegmentRequest) MarshalToSizedBuffer

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

func (*GfSpQueryResumableUploadSegmentRequest) ProtoMessage

func (*GfSpQueryResumableUploadSegmentRequest) Reset

func (*GfSpQueryResumableUploadSegmentRequest) Size

func (*GfSpQueryResumableUploadSegmentRequest) String

func (*GfSpQueryResumableUploadSegmentRequest) Unmarshal

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

func (*GfSpQueryResumableUploadSegmentRequest) XXX_DiscardUnknown

func (m *GfSpQueryResumableUploadSegmentRequest) XXX_DiscardUnknown()

func (*GfSpQueryResumableUploadSegmentRequest) XXX_Marshal

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

func (*GfSpQueryResumableUploadSegmentRequest) XXX_Merge

func (*GfSpQueryResumableUploadSegmentRequest) XXX_Size

func (*GfSpQueryResumableUploadSegmentRequest) XXX_Unmarshal

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

type GfSpQueryResumableUploadSegmentResponse

type GfSpQueryResumableUploadSegmentResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// state defines the number of segment count.
	SegmentCount uint32 `protobuf:"varint,2,opt,name=segment_count,json=segmentCount,proto3" json:"segment_count,omitempty"`
}

GfSpQueryResumableUploadSegmentResponse is response type for the QueryObjectPutState RPC method.

func (*GfSpQueryResumableUploadSegmentResponse) Descriptor

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

func (*GfSpQueryResumableUploadSegmentResponse) GetErr

func (*GfSpQueryResumableUploadSegmentResponse) GetSegmentCount

func (m *GfSpQueryResumableUploadSegmentResponse) GetSegmentCount() uint32

func (*GfSpQueryResumableUploadSegmentResponse) Marshal

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

func (*GfSpQueryResumableUploadSegmentResponse) MarshalTo

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

func (*GfSpQueryResumableUploadSegmentResponse) MarshalToSizedBuffer

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

func (*GfSpQueryResumableUploadSegmentResponse) ProtoMessage

func (*GfSpQueryResumableUploadSegmentResponse) Reset

func (*GfSpQueryResumableUploadSegmentResponse) Size

func (*GfSpQueryResumableUploadSegmentResponse) String

func (*GfSpQueryResumableUploadSegmentResponse) Unmarshal

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

func (*GfSpQueryResumableUploadSegmentResponse) XXX_DiscardUnknown

func (m *GfSpQueryResumableUploadSegmentResponse) XXX_DiscardUnknown()

func (*GfSpQueryResumableUploadSegmentResponse) XXX_Marshal

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

func (*GfSpQueryResumableUploadSegmentResponse) XXX_Merge

func (*GfSpQueryResumableUploadSegmentResponse) XXX_Size

func (*GfSpQueryResumableUploadSegmentResponse) XXX_Unmarshal

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

type GfSpQueryUploadProgressRequest

type GfSpQueryUploadProgressRequest struct {
	// object_id defines the unique id of the object.
	ObjectId uint64 `protobuf:"varint,1,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
}

QueryUploadProgressRequest is request type for the QueryObjectPutState RPC method.

func (*GfSpQueryUploadProgressRequest) Descriptor

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

func (*GfSpQueryUploadProgressRequest) GetObjectId

func (m *GfSpQueryUploadProgressRequest) GetObjectId() uint64

func (*GfSpQueryUploadProgressRequest) Marshal

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

func (*GfSpQueryUploadProgressRequest) MarshalTo

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

func (*GfSpQueryUploadProgressRequest) MarshalToSizedBuffer

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

func (*GfSpQueryUploadProgressRequest) ProtoMessage

func (*GfSpQueryUploadProgressRequest) ProtoMessage()

func (*GfSpQueryUploadProgressRequest) Reset

func (m *GfSpQueryUploadProgressRequest) Reset()

func (*GfSpQueryUploadProgressRequest) Size

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

func (*GfSpQueryUploadProgressRequest) String

func (*GfSpQueryUploadProgressRequest) Unmarshal

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

func (*GfSpQueryUploadProgressRequest) XXX_DiscardUnknown

func (m *GfSpQueryUploadProgressRequest) XXX_DiscardUnknown()

func (*GfSpQueryUploadProgressRequest) XXX_Marshal

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

func (*GfSpQueryUploadProgressRequest) XXX_Merge

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

func (*GfSpQueryUploadProgressRequest) XXX_Size

func (m *GfSpQueryUploadProgressRequest) XXX_Size() int

func (*GfSpQueryUploadProgressRequest) XXX_Unmarshal

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

type GfSpQueryUploadProgressResponse

type GfSpQueryUploadProgressResponse struct {
	Err *gfsperrors.GfSpError `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// state defines the state of put object.
	State          types3.TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=store.types.TaskState" json:"state,omitempty"`
	ErrDescription string           `protobuf:"bytes,3,opt,name=err_description,json=errDescription,proto3" json:"err_description,omitempty"`
}

QueryUploadProgressResponse is response type for the QueryObjectPutState RPC method.

func (*GfSpQueryUploadProgressResponse) Descriptor

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

func (*GfSpQueryUploadProgressResponse) GetErr

func (*GfSpQueryUploadProgressResponse) GetErrDescription

func (m *GfSpQueryUploadProgressResponse) GetErrDescription() string

func (*GfSpQueryUploadProgressResponse) GetState

func (*GfSpQueryUploadProgressResponse) Marshal

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

func (*GfSpQueryUploadProgressResponse) MarshalTo

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

func (*GfSpQueryUploadProgressResponse) MarshalToSizedBuffer

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

func (*GfSpQueryUploadProgressResponse) ProtoMessage

func (*GfSpQueryUploadProgressResponse) ProtoMessage()

func (*GfSpQueryUploadProgressResponse) Reset

func (*GfSpQueryUploadProgressResponse) Size

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

func (*GfSpQueryUploadProgressResponse) String

func (*GfSpQueryUploadProgressResponse) Unmarshal

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

func (*GfSpQueryUploadProgressResponse) XXX_DiscardUnknown

func (m *GfSpQueryUploadProgressResponse) XXX_DiscardUnknown()

func (*GfSpQueryUploadProgressResponse) XXX_Marshal

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

func (*GfSpQueryUploadProgressResponse) XXX_Merge

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

func (*GfSpQueryUploadProgressResponse) XXX_Size

func (m *GfSpQueryUploadProgressResponse) XXX_Size() int

func (*GfSpQueryUploadProgressResponse) XXX_Unmarshal

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

type GfSpVerifyPermissionByIDRequest

type GfSpVerifyPermissionByIDRequest struct {
	// operator defines the account address of operator
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// source_type defines the source of resource creation
	ResourceType resource.ResourceType `` /* 136-byte string literal not displayed */
	// resource_id defines the id of source
	ResourceId uint64 `protobuf:"varint,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// action_type defines the requested action type of permission
	ActionType types4.ActionType `` /* 130-byte string literal not displayed */
}

GfSpVerifyPermissionByIDRequest is request type for the GfSpVerifyPermissionByID RPC method

func (*GfSpVerifyPermissionByIDRequest) Descriptor

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

func (*GfSpVerifyPermissionByIDRequest) GetActionType

func (*GfSpVerifyPermissionByIDRequest) GetOperator

func (m *GfSpVerifyPermissionByIDRequest) GetOperator() string

func (*GfSpVerifyPermissionByIDRequest) GetResourceId

func (m *GfSpVerifyPermissionByIDRequest) GetResourceId() uint64

func (*GfSpVerifyPermissionByIDRequest) GetResourceType

func (*GfSpVerifyPermissionByIDRequest) Marshal

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

func (*GfSpVerifyPermissionByIDRequest) MarshalTo

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

func (*GfSpVerifyPermissionByIDRequest) MarshalToSizedBuffer

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

func (*GfSpVerifyPermissionByIDRequest) ProtoMessage

func (*GfSpVerifyPermissionByIDRequest) ProtoMessage()

func (*GfSpVerifyPermissionByIDRequest) Reset

func (*GfSpVerifyPermissionByIDRequest) Size

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

func (*GfSpVerifyPermissionByIDRequest) String

func (*GfSpVerifyPermissionByIDRequest) Unmarshal

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

func (*GfSpVerifyPermissionByIDRequest) XXX_DiscardUnknown

func (m *GfSpVerifyPermissionByIDRequest) XXX_DiscardUnknown()

func (*GfSpVerifyPermissionByIDRequest) XXX_Marshal

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

func (*GfSpVerifyPermissionByIDRequest) XXX_Merge

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

func (*GfSpVerifyPermissionByIDRequest) XXX_Size

func (m *GfSpVerifyPermissionByIDRequest) XXX_Size() int

func (*GfSpVerifyPermissionByIDRequest) XXX_Unmarshal

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

type GfSpVerifyPermissionByIDResponse

type GfSpVerifyPermissionByIDResponse struct {
	// effect define the effect of the operation permission, include Allow or deny
	Effect types4.Effect `protobuf:"varint,1,opt,name=effect,proto3,enum=greenfield.permission.Effect" json:"effect,omitempty"`
}

GfSpVerifyPermissionByIDResponse is response type for the GfSpVerifyPermissionByID RPC method

func (*GfSpVerifyPermissionByIDResponse) Descriptor

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

func (*GfSpVerifyPermissionByIDResponse) GetEffect

func (*GfSpVerifyPermissionByIDResponse) Marshal

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

func (*GfSpVerifyPermissionByIDResponse) MarshalTo

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

func (*GfSpVerifyPermissionByIDResponse) MarshalToSizedBuffer

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

func (*GfSpVerifyPermissionByIDResponse) ProtoMessage

func (*GfSpVerifyPermissionByIDResponse) ProtoMessage()

func (*GfSpVerifyPermissionByIDResponse) Reset

func (*GfSpVerifyPermissionByIDResponse) Size

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

func (*GfSpVerifyPermissionByIDResponse) String

func (*GfSpVerifyPermissionByIDResponse) Unmarshal

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

func (*GfSpVerifyPermissionByIDResponse) XXX_DiscardUnknown

func (m *GfSpVerifyPermissionByIDResponse) XXX_DiscardUnknown()

func (*GfSpVerifyPermissionByIDResponse) XXX_Marshal

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

func (*GfSpVerifyPermissionByIDResponse) XXX_Merge

func (*GfSpVerifyPermissionByIDResponse) XXX_Size

func (m *GfSpVerifyPermissionByIDResponse) XXX_Size() int

func (*GfSpVerifyPermissionByIDResponse) XXX_Unmarshal

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

type Group

type Group struct {
	// group defines the basic group info
	Group *types.GroupInfo `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// operator defines operator address of group
	Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	// create_at defines the block number when the group created
	CreateAt int64 `protobuf:"varint,3,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// create_time defines the timestamp when the group created
	CreateTime int64 `protobuf:"varint,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// update_at defines the block number when the group updated
	UpdateAt int64 `protobuf:"varint,5,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	// update_time defines the timestamp when the group updated
	UpdateTime int64 `protobuf:"varint,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// number_of_members defines how many members in this group
	NumberOfMembers int64 `protobuf:"varint,7,opt,name=number_of_members,json=numberOfMembers,proto3" json:"number_of_members,omitempty"`
	// removed defines the group is deleted or not
	Removed bool `protobuf:"varint,8,opt,name=removed,proto3" json:"removed,omitempty"`
}

Group is the structure for group information

func (*Group) Descriptor

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

func (*Group) GetCreateAt

func (m *Group) GetCreateAt() int64

func (*Group) GetCreateTime

func (m *Group) GetCreateTime() int64

func (*Group) GetGroup

func (m *Group) GetGroup() *types.GroupInfo

func (*Group) GetNumberOfMembers added in v0.2.5

func (m *Group) GetNumberOfMembers() int64

func (*Group) GetOperator

func (m *Group) GetOperator() string

func (*Group) GetRemoved

func (m *Group) GetRemoved() bool

func (*Group) GetUpdateAt

func (m *Group) GetUpdateAt() int64

func (*Group) GetUpdateTime

func (m *Group) GetUpdateTime() int64

func (*Group) Marshal

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

func (*Group) MarshalTo

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

func (*Group) MarshalToSizedBuffer

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

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) Reset

func (m *Group) Reset()

func (*Group) Size

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

func (*Group) String

func (m *Group) String() string

func (*Group) Unmarshal

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

func (*Group) XXX_DiscardUnknown

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal

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

func (*Group) XXX_Merge

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

func (*Group) XXX_Size

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal

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

type GroupMember

type GroupMember struct {
	// group defines the basic group info
	Group     *types.GroupInfo `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	AccountId string           `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// operator defines operator address of group
	Operator string `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"`
	// create_at defines the block number when the group created
	CreateAt int64 `protobuf:"varint,4,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// create_time defines the timestamp when the group created
	CreateTime int64 `protobuf:"varint,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// update_at defines the block number when the group updated
	UpdateAt int64 `protobuf:"varint,6,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	// update_time defines the timestamp when the group updated
	UpdateTime int64 `protobuf:"varint,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// removed defines the group is deleted or not
	Removed bool `protobuf:"varint,8,opt,name=removed,proto3" json:"removed,omitempty"`
	// expiration_time is the user expiration time for this group
	ExpirationTime int64 `protobuf:"varint,9,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
}

GroupMember is the structure for group-account information

func (*GroupMember) Descriptor

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

func (*GroupMember) GetAccountId

func (m *GroupMember) GetAccountId() string

func (*GroupMember) GetCreateAt

func (m *GroupMember) GetCreateAt() int64

func (*GroupMember) GetCreateTime

func (m *GroupMember) GetCreateTime() int64

func (*GroupMember) GetExpirationTime

func (m *GroupMember) GetExpirationTime() int64

func (*GroupMember) GetGroup

func (m *GroupMember) GetGroup() *types.GroupInfo

func (*GroupMember) GetOperator

func (m *GroupMember) GetOperator() string

func (*GroupMember) GetRemoved

func (m *GroupMember) GetRemoved() bool

func (*GroupMember) GetUpdateAt

func (m *GroupMember) GetUpdateAt() int64

func (*GroupMember) GetUpdateTime

func (m *GroupMember) GetUpdateTime() int64

func (*GroupMember) Marshal

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

func (*GroupMember) MarshalTo

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

func (*GroupMember) MarshalToSizedBuffer

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

func (*GroupMember) ProtoMessage

func (*GroupMember) ProtoMessage()

func (*GroupMember) Reset

func (m *GroupMember) Reset()

func (*GroupMember) Size

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

func (*GroupMember) String

func (m *GroupMember) String() string

func (*GroupMember) Unmarshal

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

func (*GroupMember) XXX_DiscardUnknown

func (m *GroupMember) XXX_DiscardUnknown()

func (*GroupMember) XXX_Marshal

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

func (*GroupMember) XXX_Merge

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

func (*GroupMember) XXX_Size

func (m *GroupMember) XXX_Size() int

func (*GroupMember) XXX_Unmarshal

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

type ListMigrateBucketEvents

type ListMigrateBucketEvents struct {
	// events defines the migration bucket event
	Events *types.EventMigrationBucket `protobuf:"bytes,1,opt,name=events,proto3" json:"events,omitempty"`
	// cancel_events defines the migration bucket event
	CancelEvents *types.EventCancelMigrationBucket `protobuf:"bytes,2,opt,name=cancel_events,json=cancelEvents,proto3" json:"cancel_events,omitempty"`
	// complete_events defines the complete migration bucket event
	CompleteEvents *types.EventCompleteMigrationBucket `protobuf:"bytes,3,opt,name=complete_events,json=completeEvents,proto3" json:"complete_events,omitempty"`
}

ListMigrateBucketEvents is the combination of migrate bucket events

func (*ListMigrateBucketEvents) Descriptor

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

func (*ListMigrateBucketEvents) GetCancelEvents

func (*ListMigrateBucketEvents) GetCompleteEvents

func (*ListMigrateBucketEvents) GetEvents

func (*ListMigrateBucketEvents) Marshal

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

func (*ListMigrateBucketEvents) MarshalTo

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

func (*ListMigrateBucketEvents) MarshalToSizedBuffer

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

func (*ListMigrateBucketEvents) ProtoMessage

func (*ListMigrateBucketEvents) ProtoMessage()

func (*ListMigrateBucketEvents) Reset

func (m *ListMigrateBucketEvents) Reset()

func (*ListMigrateBucketEvents) Size

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

func (*ListMigrateBucketEvents) String

func (m *ListMigrateBucketEvents) String() string

func (*ListMigrateBucketEvents) Unmarshal

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

func (*ListMigrateBucketEvents) XXX_DiscardUnknown

func (m *ListMigrateBucketEvents) XXX_DiscardUnknown()

func (*ListMigrateBucketEvents) XXX_Marshal

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

func (*ListMigrateBucketEvents) XXX_Merge

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

func (*ListMigrateBucketEvents) XXX_Size

func (m *ListMigrateBucketEvents) XXX_Size() int

func (*ListMigrateBucketEvents) XXX_Unmarshal

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

type ListSpExitEvents

type ListSpExitEvents struct {
	// events defines the sp exit event
	Event *types1.EventStorageProviderExit `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// complete_events defines the complete sp exit event
	CompleteEvent *types1.EventCompleteStorageProviderExit `protobuf:"bytes,2,opt,name=complete_event,json=completeEvent,proto3" json:"complete_event,omitempty"`
}

ListSpExitEvents is the combination of sp exit events

func (*ListSpExitEvents) Descriptor

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

func (*ListSpExitEvents) GetCompleteEvent

func (*ListSpExitEvents) GetEvent

func (*ListSpExitEvents) Marshal

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

func (*ListSpExitEvents) MarshalTo

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

func (*ListSpExitEvents) MarshalToSizedBuffer

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

func (*ListSpExitEvents) ProtoMessage

func (*ListSpExitEvents) ProtoMessage()

func (*ListSpExitEvents) Reset

func (m *ListSpExitEvents) Reset()

func (*ListSpExitEvents) Size

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

func (*ListSpExitEvents) String

func (m *ListSpExitEvents) String() string

func (*ListSpExitEvents) Unmarshal

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

func (*ListSpExitEvents) XXX_DiscardUnknown

func (m *ListSpExitEvents) XXX_DiscardUnknown()

func (*ListSpExitEvents) XXX_Marshal

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

func (*ListSpExitEvents) XXX_Merge

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

func (*ListSpExitEvents) XXX_Size

func (m *ListSpExitEvents) XXX_Size() int

func (*ListSpExitEvents) XXX_Unmarshal

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

type ListSwapOutEvents

type ListSwapOutEvents struct {
	// events defines the swap out event
	Events *types1.EventSwapOut `protobuf:"bytes,1,opt,name=events,proto3" json:"events,omitempty"`
	// cancel_events defines the cancel swap out event
	CancelEvents *types1.EventCancelSwapOut `protobuf:"bytes,2,opt,name=cancel_events,json=cancelEvents,proto3" json:"cancel_events,omitempty"`
	// complete_events defines the complete swap out event
	CompleteEvents *types1.EventCompleteSwapOut `protobuf:"bytes,3,opt,name=complete_events,json=completeEvents,proto3" json:"complete_events,omitempty"`
}

ListSwapOutEvents is the combination of swap out events

func (*ListSwapOutEvents) Descriptor

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

func (*ListSwapOutEvents) GetCancelEvents

func (m *ListSwapOutEvents) GetCancelEvents() *types1.EventCancelSwapOut

func (*ListSwapOutEvents) GetCompleteEvents

func (m *ListSwapOutEvents) GetCompleteEvents() *types1.EventCompleteSwapOut

func (*ListSwapOutEvents) GetEvents

func (m *ListSwapOutEvents) GetEvents() *types1.EventSwapOut

func (*ListSwapOutEvents) Marshal

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

func (*ListSwapOutEvents) MarshalTo

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

func (*ListSwapOutEvents) MarshalToSizedBuffer

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

func (*ListSwapOutEvents) ProtoMessage

func (*ListSwapOutEvents) ProtoMessage()

func (*ListSwapOutEvents) Reset

func (m *ListSwapOutEvents) Reset()

func (*ListSwapOutEvents) Size

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

func (*ListSwapOutEvents) String

func (m *ListSwapOutEvents) String() string

func (*ListSwapOutEvents) Unmarshal

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

func (*ListSwapOutEvents) XXX_DiscardUnknown

func (m *ListSwapOutEvents) XXX_DiscardUnknown()

func (*ListSwapOutEvents) XXX_Marshal

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

func (*ListSwapOutEvents) XXX_Merge

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

func (*ListSwapOutEvents) XXX_Size

func (m *ListSwapOutEvents) XXX_Size() int

func (*ListSwapOutEvents) XXX_Unmarshal

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

type Object

type Object struct {
	// object_info defines the information of the object.
	ObjectInfo *types.ObjectInfo `protobuf:"bytes,1,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
	// locked_balance defines locked balance of object
	LockedBalance string `protobuf:"bytes,2,opt,name=locked_balance,json=lockedBalance,proto3" json:"locked_balance,omitempty"`
	// removed defines the object is deleted or not
	Removed bool `protobuf:"varint,3,opt,name=removed,proto3" json:"removed,omitempty"`
	// update_at defines the block number when the object updated
	UpdateAt int64 `protobuf:"varint,4,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	// delete_at defines the block number when the object deleted
	DeleteAt int64 `protobuf:"varint,5,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`
	// delete_reason defines the deleted reason of object
	DeleteReason string `protobuf:"bytes,6,opt,name=delete_reason,json=deleteReason,proto3" json:"delete_reason,omitempty"`
	// operator defines the operator address of object
	Operator string `protobuf:"bytes,7,opt,name=operator,proto3" json:"operator,omitempty"`
	// create_tx_hash defines the creation transaction hash of object
	CreateTxHash string `protobuf:"bytes,8,opt,name=create_tx_hash,json=createTxHash,proto3" json:"create_tx_hash,omitempty"`
	// update_tx_hash defines the update transaction hash of object
	UpdateTxHash string `protobuf:"bytes,9,opt,name=update_tx_hash,json=updateTxHash,proto3" json:"update_tx_hash,omitempty"`
	// seal_tx_hash defines the sealed transaction hash of object
	SealTxHash string `protobuf:"bytes,10,opt,name=seal_tx_hash,json=sealTxHash,proto3" json:"seal_tx_hash,omitempty"`
}

Object is the structure for user object

func (*Object) Descriptor

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

func (*Object) GetCreateTxHash

func (m *Object) GetCreateTxHash() string

func (*Object) GetDeleteAt

func (m *Object) GetDeleteAt() int64

func (*Object) GetDeleteReason

func (m *Object) GetDeleteReason() string

func (*Object) GetLockedBalance

func (m *Object) GetLockedBalance() string

func (*Object) GetObjectInfo

func (m *Object) GetObjectInfo() *types.ObjectInfo

func (*Object) GetOperator

func (m *Object) GetOperator() string

func (*Object) GetRemoved

func (m *Object) GetRemoved() bool

func (*Object) GetSealTxHash

func (m *Object) GetSealTxHash() string

func (*Object) GetUpdateAt

func (m *Object) GetUpdateAt() int64

func (*Object) GetUpdateTxHash

func (m *Object) GetUpdateTxHash() string

func (*Object) Marshal

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

func (*Object) MarshalTo

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

func (*Object) MarshalToSizedBuffer

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

func (*Object) ProtoMessage

func (*Object) ProtoMessage()

func (*Object) Reset

func (m *Object) Reset()

func (*Object) Size

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

func (*Object) String

func (m *Object) String() string

func (*Object) Unmarshal

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

func (*Object) XXX_DiscardUnknown

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal

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

func (*Object) XXX_Merge

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

func (*Object) XXX_Size

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal

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

type ObjectDetails

type ObjectDetails struct {
	// object is the structure for user object
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// bucket is the structure for user bucket
	Bucket *Bucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// gvg defines a global virtual group consists of one primary SP (SP) and multiple secondary SP
	Gvg *types1.GlobalVirtualGroup `protobuf:"bytes,3,opt,name=gvg,proto3" json:"gvg,omitempty"`
}

ObjectDetails defines object related bucket and gvg info

func (*ObjectDetails) Descriptor

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

func (*ObjectDetails) GetBucket

func (m *ObjectDetails) GetBucket() *Bucket

func (*ObjectDetails) GetGvg

func (*ObjectDetails) GetObject

func (m *ObjectDetails) GetObject() *Object

func (*ObjectDetails) Marshal

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

func (*ObjectDetails) MarshalTo

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

func (*ObjectDetails) MarshalToSizedBuffer

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

func (*ObjectDetails) ProtoMessage

func (*ObjectDetails) ProtoMessage()

func (*ObjectDetails) Reset

func (m *ObjectDetails) Reset()

func (*ObjectDetails) Size

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

func (*ObjectDetails) String

func (m *ObjectDetails) String() string

func (*ObjectDetails) Unmarshal

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

func (*ObjectDetails) XXX_DiscardUnknown

func (m *ObjectDetails) XXX_DiscardUnknown()

func (*ObjectDetails) XXX_Marshal

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

func (*ObjectDetails) XXX_Merge

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

func (*ObjectDetails) XXX_Size

func (m *ObjectDetails) XXX_Size() int

func (*ObjectDetails) XXX_Unmarshal

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

type Policy added in v0.2.5

type Policy struct {
	// principal_type defines the type of principal
	PrincipalType int32 `protobuf:"varint,1,opt,name=principal_type,json=principalType,proto3" json:"principal_type,omitempty"`
	// principal_value defines the value of principal
	PrincipalValue string `protobuf:"bytes,2,opt,name=principal_value,json=principalValue,proto3" json:"principal_value,omitempty"`
	// resource_type defines the type of resource that grants permission for
	ResourceType resource.ResourceType `` /* 136-byte string literal not displayed */
	// resource_id defines the bucket/object/group id of the resource that grants permission for
	ResourceId string `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// create_timestamp defines the create time of permission
	CreateTimestamp int64 `protobuf:"varint,5,opt,name=create_timestamp,json=createTimestamp,proto3" json:"create_timestamp,omitempty"`
	// update_timestamp defines the update time of permission
	UpdateTimestamp int64 `protobuf:"varint,6,opt,name=update_timestamp,json=updateTimestamp,proto3" json:"update_timestamp,omitempty"`
	// expiration_time defines the expiration time of permission
	ExpirationTime int64 `protobuf:"varint,7,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
}

func (*Policy) Descriptor added in v0.2.5

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

func (*Policy) GetCreateTimestamp added in v0.2.5

func (m *Policy) GetCreateTimestamp() int64

func (*Policy) GetExpirationTime added in v0.2.5

func (m *Policy) GetExpirationTime() int64

func (*Policy) GetPrincipalType added in v0.2.5

func (m *Policy) GetPrincipalType() int32

func (*Policy) GetPrincipalValue added in v0.2.5

func (m *Policy) GetPrincipalValue() string

func (*Policy) GetResourceId added in v0.2.5

func (m *Policy) GetResourceId() string

func (*Policy) GetResourceType added in v0.2.5

func (m *Policy) GetResourceType() resource.ResourceType

func (*Policy) GetUpdateTimestamp added in v0.2.5

func (m *Policy) GetUpdateTimestamp() int64

func (*Policy) Marshal added in v0.2.5

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

func (*Policy) MarshalTo added in v0.2.5

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

func (*Policy) MarshalToSizedBuffer added in v0.2.5

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

func (*Policy) ProtoMessage added in v0.2.5

func (*Policy) ProtoMessage()

func (*Policy) Reset added in v0.2.5

func (m *Policy) Reset()

func (*Policy) Size added in v0.2.5

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

func (*Policy) String added in v0.2.5

func (m *Policy) String() string

func (*Policy) Unmarshal added in v0.2.5

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

func (*Policy) XXX_DiscardUnknown added in v0.2.5

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal added in v0.2.5

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

func (*Policy) XXX_Merge added in v0.2.5

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

func (*Policy) XXX_Size added in v0.2.5

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal added in v0.2.5

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

type ReadRecord

type ReadRecord struct {
	// object_name is the read object name
	ObjectName string `protobuf:"bytes,1,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// object_id is the read object id
	ObjectId uint64 `protobuf:"varint,2,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	// account_address is the read account address
	AccountAddress string `protobuf:"bytes,3,opt,name=account_address,json=accountAddress,proto3" json:"account_address,omitempty"`
	// timestamp_us is the read time stamp
	TimestampUs int64 `protobuf:"varint,4,opt,name=timestamp_us,json=timestampUs,proto3" json:"timestamp_us,omitempty"`
	// read_size is the read object size
	ReadSize uint64 `protobuf:"varint,5,opt,name=read_size,json=readSize,proto3" json:"read_size,omitempty"`
}

ReadRecord is used to record the read request.

func (*ReadRecord) Descriptor

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

func (*ReadRecord) GetAccountAddress

func (m *ReadRecord) GetAccountAddress() string

func (*ReadRecord) GetObjectId

func (m *ReadRecord) GetObjectId() uint64

func (*ReadRecord) GetObjectName

func (m *ReadRecord) GetObjectName() string

func (*ReadRecord) GetReadSize

func (m *ReadRecord) GetReadSize() uint64

func (*ReadRecord) GetTimestampUs

func (m *ReadRecord) GetTimestampUs() int64

func (*ReadRecord) Marshal

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

func (*ReadRecord) MarshalTo

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

func (*ReadRecord) MarshalToSizedBuffer

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

func (*ReadRecord) ProtoMessage

func (*ReadRecord) ProtoMessage()

func (*ReadRecord) Reset

func (m *ReadRecord) Reset()

func (*ReadRecord) Size

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

func (*ReadRecord) String

func (m *ReadRecord) String() string

func (*ReadRecord) Unmarshal

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

func (*ReadRecord) XXX_DiscardUnknown

func (m *ReadRecord) XXX_DiscardUnknown()

func (*ReadRecord) XXX_Marshal

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

func (*ReadRecord) XXX_Merge

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

func (*ReadRecord) XXX_Size

func (m *ReadRecord) XXX_Size() int

func (*ReadRecord) XXX_Unmarshal

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

type Status

type Status struct {
	StorageProviderInfo *StorageProviderInfo `protobuf:"bytes,1,opt,name=storage_provider_info,json=storageProviderInfo,proto3" json:"storage_provider_info,omitempty"`
	BlockSyncerInfo     *BlockSyncerInfo     `protobuf:"bytes,2,opt,name=block_syncer_info,json=blockSyncerInfo,proto3" json:"block_syncer_info,omitempty"`
	ChainInfo           *ChainInfo           `protobuf:"bytes,3,opt,name=chain_info,json=chainInfo,proto3" json:"chain_info,omitempty"`
}

func (*Status) Descriptor

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

func (*Status) GetBlockSyncerInfo

func (m *Status) GetBlockSyncerInfo() *BlockSyncerInfo

func (*Status) GetChainInfo

func (m *Status) GetChainInfo() *ChainInfo

func (*Status) GetStorageProviderInfo

func (m *Status) GetStorageProviderInfo() *StorageProviderInfo

func (*Status) Marshal

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

func (*Status) MarshalTo

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

func (*Status) MarshalToSizedBuffer

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

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) Size

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

func (*Status) String

func (m *Status) String() string

func (*Status) Unmarshal

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

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

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

func (*Status) XXX_Merge

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

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

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

type StorageProviderInfo

type StorageProviderInfo struct {
	SpCodeVersion     string `protobuf:"bytes,1,opt,name=sp_code_version,json=spCodeVersion,proto3" json:"sp_code_version,omitempty"`
	SpCodeCommit      string `protobuf:"bytes,2,opt,name=sp_code_commit,json=spCodeCommit,proto3" json:"sp_code_commit,omitempty"`
	SpArchitecture    string `protobuf:"bytes,3,opt,name=sp_architecture,json=spArchitecture,proto3" json:"sp_architecture,omitempty"`
	SpGoVersion       string `protobuf:"bytes,4,opt,name=sp_go_version,json=spGoVersion,proto3" json:"sp_go_version,omitempty"`
	SpOperatingSystem string `protobuf:"bytes,5,opt,name=sp_operating_system,json=spOperatingSystem,proto3" json:"sp_operating_system,omitempty"`
	SpOperatorAddress string `protobuf:"bytes,6,opt,name=sp_operator_address,json=spOperatorAddress,proto3" json:"sp_operator_address,omitempty"`
	SpDomainName      string `protobuf:"bytes,7,opt,name=sp_domain_name,json=spDomainName,proto3" json:"sp_domain_name,omitempty"`
}

func (*StorageProviderInfo) Descriptor

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

func (*StorageProviderInfo) GetSpArchitecture

func (m *StorageProviderInfo) GetSpArchitecture() string

func (*StorageProviderInfo) GetSpCodeCommit

func (m *StorageProviderInfo) GetSpCodeCommit() string

func (*StorageProviderInfo) GetSpCodeVersion

func (m *StorageProviderInfo) GetSpCodeVersion() string

func (*StorageProviderInfo) GetSpDomainName

func (m *StorageProviderInfo) GetSpDomainName() string

func (*StorageProviderInfo) GetSpGoVersion

func (m *StorageProviderInfo) GetSpGoVersion() string

func (*StorageProviderInfo) GetSpOperatingSystem

func (m *StorageProviderInfo) GetSpOperatingSystem() string

func (*StorageProviderInfo) GetSpOperatorAddress

func (m *StorageProviderInfo) GetSpOperatorAddress() string

func (*StorageProviderInfo) Marshal

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

func (*StorageProviderInfo) MarshalTo

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

func (*StorageProviderInfo) MarshalToSizedBuffer

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

func (*StorageProviderInfo) ProtoMessage

func (*StorageProviderInfo) ProtoMessage()

func (*StorageProviderInfo) Reset

func (m *StorageProviderInfo) Reset()

func (*StorageProviderInfo) Size

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

func (*StorageProviderInfo) String

func (m *StorageProviderInfo) String() string

func (*StorageProviderInfo) Unmarshal

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

func (*StorageProviderInfo) XXX_DiscardUnknown

func (m *StorageProviderInfo) XXX_DiscardUnknown()

func (*StorageProviderInfo) XXX_Marshal

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

func (*StorageProviderInfo) XXX_Merge

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

func (*StorageProviderInfo) XXX_Size

func (m *StorageProviderInfo) XXX_Size() int

func (*StorageProviderInfo) XXX_Unmarshal

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

type StreamRecordMeta added in v0.2.5

type StreamRecordMeta struct {
	// stream_records defines stream payment records of a stream account
	StreamRecord *types2.StreamRecord `protobuf:"bytes,1,opt,name=stream_record,json=streamRecord,proto3" json:"stream_record,omitempty"`
	// refundable defines the payment account is refundable or not
	Refundable bool `protobuf:"varint,2,opt,name=refundable,proto3" json:"refundable,omitempty"`
}

StreamRecordMeta is the structure for user bucket with related vgf info

func (*StreamRecordMeta) Descriptor added in v0.2.5

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

func (*StreamRecordMeta) GetRefundable added in v0.2.5

func (m *StreamRecordMeta) GetRefundable() bool

func (*StreamRecordMeta) GetStreamRecord added in v0.2.5

func (m *StreamRecordMeta) GetStreamRecord() *types2.StreamRecord

func (*StreamRecordMeta) Marshal added in v0.2.5

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

func (*StreamRecordMeta) MarshalTo added in v0.2.5

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

func (*StreamRecordMeta) MarshalToSizedBuffer added in v0.2.5

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

func (*StreamRecordMeta) ProtoMessage added in v0.2.5

func (*StreamRecordMeta) ProtoMessage()

func (*StreamRecordMeta) Reset added in v0.2.5

func (m *StreamRecordMeta) Reset()

func (*StreamRecordMeta) Size added in v0.2.5

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

func (*StreamRecordMeta) String added in v0.2.5

func (m *StreamRecordMeta) String() string

func (*StreamRecordMeta) Unmarshal added in v0.2.5

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

func (*StreamRecordMeta) XXX_DiscardUnknown added in v0.2.5

func (m *StreamRecordMeta) XXX_DiscardUnknown()

func (*StreamRecordMeta) XXX_Marshal added in v0.2.5

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

func (*StreamRecordMeta) XXX_Merge added in v0.2.5

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

func (*StreamRecordMeta) XXX_Size added in v0.2.5

func (m *StreamRecordMeta) XXX_Size() int

func (*StreamRecordMeta) XXX_Unmarshal added in v0.2.5

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

type UnimplementedGfSpMetadataServiceServer

type UnimplementedGfSpMetadataServiceServer struct {
}

UnimplementedGfSpMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetBucketByBucketID

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetBucketByBucketName

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetBucketMeta

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetBucketReadQuota

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetEndpointBySpID

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetGlobalVirtualGroup

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetGroupList

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetGroupMembers

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetObjectMeta

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetPaymentByBucketID

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetPaymentByBucketName

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetSPInfo

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetStatus

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetUserBuckets

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetUserBucketsCount

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetUserGroups

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetUserOwnedGroups

func (*UnimplementedGfSpMetadataServiceServer) GfSpGetVirtualGroupFamily

func (*UnimplementedGfSpMetadataServiceServer) GfSpListBucketReadRecord

func (*UnimplementedGfSpMetadataServiceServer) GfSpListBucketsByIDs

func (*UnimplementedGfSpMetadataServiceServer) GfSpListExpiredBucketsBySp

func (*UnimplementedGfSpMetadataServiceServer) GfSpListGroupsByIDs added in v0.2.5

func (*UnimplementedGfSpMetadataServiceServer) GfSpListMigrateBucketEvents

func (*UnimplementedGfSpMetadataServiceServer) GfSpListObjectPolicies added in v0.2.5

func (*UnimplementedGfSpMetadataServiceServer) GfSpListObjectsByBucketName

func (*UnimplementedGfSpMetadataServiceServer) GfSpListObjectsByIDs

func (*UnimplementedGfSpMetadataServiceServer) GfSpListObjectsInGVG

func (*UnimplementedGfSpMetadataServiceServer) GfSpListObjectsInGVGAndBucket

func (*UnimplementedGfSpMetadataServiceServer) GfSpListPaymentAccountStreams added in v0.2.5

func (*UnimplementedGfSpMetadataServiceServer) GfSpListSpExitEvents

func (*UnimplementedGfSpMetadataServiceServer) GfSpListSwapOutEvents

func (*UnimplementedGfSpMetadataServiceServer) GfSpListUserPaymentAccounts added in v0.2.5

func (*UnimplementedGfSpMetadataServiceServer) GfSpQueryUploadProgress

func (*UnimplementedGfSpMetadataServiceServer) GfSpVerifyPermission

func (*UnimplementedGfSpMetadataServiceServer) GfSpVerifyPermissionByID

type VGFInfoBucket added in v0.2.5

type VGFInfoBucket struct {
	// bucket_info defines the information of the bucket.
	BucketInfo *types.BucketInfo `protobuf:"bytes,1,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
	// removed defines the bucket is deleted or not
	Removed bool `protobuf:"varint,2,opt,name=removed,proto3" json:"removed,omitempty"`
	// delete_at defines the block number when the bucket deleted.
	DeleteAt int64 `protobuf:"varint,3,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"`
	// delete_reason defines the deleted reason of bucket
	DeleteReason string `protobuf:"bytes,4,opt,name=delete_reason,json=deleteReason,proto3" json:"delete_reason,omitempty"`
	// operator defines the operator address of bucket
	Operator string `protobuf:"bytes,5,opt,name=operator,proto3" json:"operator,omitempty"`
	// create_tx_hash defines the creation transaction hash of object
	CreateTxHash string `protobuf:"bytes,6,opt,name=create_tx_hash,json=createTxHash,proto3" json:"create_tx_hash,omitempty"`
	// update_tx_hash defines the update transaction hash of object
	UpdateTxHash string `protobuf:"bytes,7,opt,name=update_tx_hash,json=updateTxHash,proto3" json:"update_tx_hash,omitempty"`
	// update_at defines the block number when the object updated
	UpdateAt int64 `protobuf:"varint,8,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	// update_time defines the block number when the object updated
	UpdateTime int64 `protobuf:"varint,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// vgf defines the vgf info
	Vgf *types1.GlobalVirtualGroupFamily `protobuf:"bytes,10,opt,name=vgf,proto3" json:"vgf,omitempty"`
}

VGFInfoBucket is the structure for user bucket with related vgf info

func (*VGFInfoBucket) Descriptor added in v0.2.5

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

func (*VGFInfoBucket) GetBucketInfo added in v0.2.5

func (m *VGFInfoBucket) GetBucketInfo() *types.BucketInfo

func (*VGFInfoBucket) GetCreateTxHash added in v0.2.5

func (m *VGFInfoBucket) GetCreateTxHash() string

func (*VGFInfoBucket) GetDeleteAt added in v0.2.5

func (m *VGFInfoBucket) GetDeleteAt() int64

func (*VGFInfoBucket) GetDeleteReason added in v0.2.5

func (m *VGFInfoBucket) GetDeleteReason() string

func (*VGFInfoBucket) GetOperator added in v0.2.5

func (m *VGFInfoBucket) GetOperator() string

func (*VGFInfoBucket) GetRemoved added in v0.2.5

func (m *VGFInfoBucket) GetRemoved() bool

func (*VGFInfoBucket) GetUpdateAt added in v0.2.5

func (m *VGFInfoBucket) GetUpdateAt() int64

func (*VGFInfoBucket) GetUpdateTime added in v0.2.5

func (m *VGFInfoBucket) GetUpdateTime() int64

func (*VGFInfoBucket) GetUpdateTxHash added in v0.2.5

func (m *VGFInfoBucket) GetUpdateTxHash() string

func (*VGFInfoBucket) GetVgf added in v0.2.5

func (*VGFInfoBucket) Marshal added in v0.2.5

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

func (*VGFInfoBucket) MarshalTo added in v0.2.5

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

func (*VGFInfoBucket) MarshalToSizedBuffer added in v0.2.5

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

func (*VGFInfoBucket) ProtoMessage added in v0.2.5

func (*VGFInfoBucket) ProtoMessage()

func (*VGFInfoBucket) Reset added in v0.2.5

func (m *VGFInfoBucket) Reset()

func (*VGFInfoBucket) Size added in v0.2.5

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

func (*VGFInfoBucket) String added in v0.2.5

func (m *VGFInfoBucket) String() string

func (*VGFInfoBucket) Unmarshal added in v0.2.5

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

func (*VGFInfoBucket) XXX_DiscardUnknown added in v0.2.5

func (m *VGFInfoBucket) XXX_DiscardUnknown()

func (*VGFInfoBucket) XXX_Marshal added in v0.2.5

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

func (*VGFInfoBucket) XXX_Merge added in v0.2.5

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

func (*VGFInfoBucket) XXX_Size added in v0.2.5

func (m *VGFInfoBucket) XXX_Size() int

func (*VGFInfoBucket) XXX_Unmarshal added in v0.2.5

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

Jump to

Keyboard shortcuts

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