types

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2023 License: Apache-2.0 Imports: 40 Imported by: 43

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "storage"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey defines the module's message routing key
	RouterKey = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_storage"
)
View Source 
const (
	// For bucket
	TypeMsgCreateBucket = "create_bucket"
	TypeMsgDeleteBucket = "delete_bucket"

	// For object
	TypeMsgCopyObject       = "copy_object"
	TypeMsgCreateObject     = "create_object"
	TypeMsgDeleteObject     = "delete_object"
	TypeMsgSealObject       = "seal_object"
	TypeMsgRejectSealObject = "reject_seal_object"

	// For group
	TypeMsgCreateGroup       = "create_group"
	TypeMsgDeleteGroup       = "delete_group"
	TypeMsgLeaveGroup        = "leave_group"
	TypeMsgUpdateGroupMember = "update_group_member"
)
View Source 
const (
	DefaultMaxSegmentSize          uint64 = 16 * 1024 * 1024 // 16M
	DefaultRedundantDataChunkNum   uint32 = 4
	DefaultRedundantParityChunkNum uint32 = 2
	DefaultMaxPayloadSize          uint64 = 2 * 1024 * 1024 * 1024
)

storage params default values

View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default global index

View Source 
const (

	// SlashSeparator - slash separator.
	SlashSeparator = "/"
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source 
var (
	ErrNoSuchBucket                = sdkerrors.Register(ModuleName, 1100, "no such bucket")
	ErrNoSuchObject                = sdkerrors.Register(ModuleName, 1101, "no such object")
	ErrNoSuchGroup                 = sdkerrors.Register(ModuleName, 1102, "no such group")
	ErrBucketAlreadyExists         = sdkerrors.Register(ModuleName, 1103, "bucket already exists")
	ErrObjectAlreadyExists         = sdkerrors.Register(ModuleName, 1104, "object already exists")
	ErrGroupAlreadyExists          = sdkerrors.Register(ModuleName, 1105, "group already exists")
	ErrAccessDenied                = sdkerrors.Register(ModuleName, 1106, "access denied")
	ErrSPAddressMismatch           = sdkerrors.Register(ModuleName, 1107, "sp address mismatch")
	ErrObjectAlreadySealed         = sdkerrors.Register(ModuleName, 1108, "object already sealed")
	ErrBucketNotEmpty              = sdkerrors.Register(ModuleName, 1109, "bucket is not empty")
	ErrNoSuchGroupMember           = sdkerrors.Register(ModuleName, 1110, "no such group member")
	ErrGroupMemberAlreadyExists    = sdkerrors.Register(ModuleName, 1111, "group member already exists")
	ErrGroupMemberNotExists        = sdkerrors.Register(ModuleName, 1112, "group member already exists")
	ErrNoSuchStorageProvider       = sdkerrors.Register(ModuleName, 1113, "no such storage provider")
	ErrSequenceUniqueConstraint    = sdkerrors.Register(ModuleName, 1114, "sequence already initialized")
	ErrStorageProviderNotInService = sdkerrors.Register(ModuleName, 1115, "storage provider not in service")
	ErrObjectStatusNotInit         = sdkerrors.Register(ModuleName, 1116, "not a INIT object")

	ErrInvalidBucketName  = sdkerrors.Register(ModuleName, 2000, "invalid bucket name")
	ErrInvalidObjectName  = sdkerrors.Register(ModuleName, 2001, "invalid object name")
	ErrInvalidGroupName   = sdkerrors.Register(ModuleName, 2002, "invalid group name")
	ErrInvalidChcecksum   = sdkerrors.Register(ModuleName, 2003, "invalid checksum")
	ErrInvalidContentType = sdkerrors.Register(ModuleName, 2004, "invalid content type")
	ErrInvalidSPSignature = sdkerrors.Register(ModuleName, 2005, "invalid sp signature")
	ErrInvalidSPAddress   = sdkerrors.Register(ModuleName, 2006, "invalid sp address")
)

x/storage module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	BucketPrefix      = []byte{0x10}
	ObjectPrefix      = []byte{0x11}
	GroupPrefix       = []byte{0x12}
	GroupMemberPrefix = []byte{0x13} // TODO(fynn): will be deprecated after permission module ready

)
View Source 
var (
	KeyMaxSegmentSize          = []byte("MaxSegmentSize")
	KeyRedundantDataChunkNum   = []byte("RedundantDataChunkNum")
	KeyRedundantParityChunkNum = []byte("RedundantParityChunkNum")
	KeyMaxPayloadSize          = []byte("MaxPayloadSize")
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ObjectStatus_name = map[int32]string{
	0: "OBJECT_STATUS_INIT",
	1: "OBJECT_STATUS_IN_SERVICE",
}
View Source 
var ObjectStatus_value = map[string]int32{
	"OBJECT_STATUS_INIT":       0,
	"OBJECT_STATUS_IN_SERVICE": 1,
}
View Source 
var ReadQuota_name = map[int32]string{
	0: "READ_QUOTA_FREE",
}
View Source 
var ReadQuota_value = map[string]int32{
	"READ_QUOTA_FREE": 0,
}
View Source 
var RedundancyType_name = map[int32]string{
	0: "REDUNDANCY_REPLICA_TYPE",
	1: "REDUNDANCY_EC_TYPE",
	2: "REDUNDANCY_INLINE_TYPE",
}
View Source 
var RedundancyType_value = map[string]int32{
	"REDUNDANCY_REPLICA_TYPE": 0,
	"REDUNDANCY_EC_TYPE":      1,
	"REDUNDANCY_INLINE_TYPE":  2,
}
View Source 
var SourceType_name = map[int32]string{
	0: "SOURCE_TYPE_ORIGIN",
	1: "SOURCE_TYPE_BSC_CROSS_CHAIN",
}
View Source 
var SourceType_value = map[string]int32{
	"SOURCE_TYPE_ORIGIN":          0,
	"SOURCE_TYPE_BSC_CROSS_CHAIN": 1,
}

Functions

func CheckValidBucketName 

func CheckValidBucketName(bucketName string) (err error)

CheckValidBucketName - checks if we have a valid input bucket name. This is a stricter version. - http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingBucket.html

func CheckValidContentType 

func CheckValidContentType(contentType string) error

func CheckValidExpectChecksums 

func CheckValidExpectChecksums(expectChecksums [][]byte) error

CheckValidExpectChecksums checks if the MSG have a valid SHA256 checksum.

func CheckValidGroupName 

func CheckValidGroupName(groupName string) error

func CheckValidObjectName 

func CheckValidObjectName(objectName string) error

/ CheckValidObjectName - checks if we have a valid input object name.

func GetBucketKey 

func GetBucketKey(bucketName string) []byte

func GetGroupKey 

func GetGroupKey(owner string, groupName string) []byte

func GetGroupMemberKey 

func GetGroupMemberKey(groupId math.Uint, memberAcc string) []byte

func GetObjectKey 

func GetObjectKey(bucketName string, objectName string) []byte

func MustMarshalUint 

func MustMarshalUint(n sdkmath.Uint) []byte

func MustUnmarshalUint 

func MustUnmarshalUint(data []byte) sdkmath.Uint

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func VerifySignature 

func VerifySignature(sigAcc sdk.AccAddress, sigData []byte, sig []byte) error

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected interface needed to retrieve account balances.

type BucketInfo 

type BucketInfo struct {
	// owner is the account address of bucket creator, it is also the bucket owner.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// bucket_name is a globally unique name of bucket
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// is_public define the highest permissions for bucket. When the bucket is public, everyone can get the object in it.
	IsPublic bool `protobuf:"varint,3,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// id is the unique identification for bucket.
	Id Uint `protobuf:"bytes,4,opt,name=id,proto3,customtype=Uint" json:"id"`
	// create_at define the block number when the bucket created.
	CreateAt int64 `protobuf:"varint,5,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// payment_address is the address of the payment account
	PaymentAddress string `protobuf:"bytes,6,opt,name=payment_address,json=paymentAddress,proto3" json:"payment_address,omitempty"`
	// primary_sp_address is the address of the primary sp. Objects belongs to this bucket will never
	// leave this SP, unless you explicitly shift them to another SP.
	PrimarySpAddress string `protobuf:"bytes,7,opt,name=primary_sp_address,json=primarySpAddress,proto3" json:"primary_sp_address,omitempty"`
	// read_quota defines the traffic quota for read
	ReadQuota ReadQuota `` /* 132-byte string literal not displayed */
}

func (*BucketInfo) Descriptor 

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

func (*BucketInfo) GetBucketName 

func (m *BucketInfo) GetBucketName() string

func (*BucketInfo) GetCreateAt 

func (m *BucketInfo) GetCreateAt() int64

func (*BucketInfo) GetIsPublic 

func (m *BucketInfo) GetIsPublic() bool

func (*BucketInfo) GetOwner 

func (m *BucketInfo) GetOwner() string

func (*BucketInfo) GetPaymentAddress 

func (m *BucketInfo) GetPaymentAddress() string

func (*BucketInfo) GetPrimarySpAddress 

func (m *BucketInfo) GetPrimarySpAddress() string

func (*BucketInfo) GetReadQuota 

func (m *BucketInfo) GetReadQuota() ReadQuota

func (*BucketInfo) Marshal 

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

func (*BucketInfo) MarshalTo 

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

func (*BucketInfo) MarshalToSizedBuffer 

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

func (*BucketInfo) ProtoMessage 

func (*BucketInfo) ProtoMessage()

func (*BucketInfo) Reset 

func (m *BucketInfo) Reset()

func (*BucketInfo) Size 

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

func (*BucketInfo) String 

func (m *BucketInfo) String() string

func (*BucketInfo) Unmarshal 

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

func (*BucketInfo) XXX_DiscardUnknown 

func (m *BucketInfo) XXX_DiscardUnknown()

func (*BucketInfo) XXX_Marshal 

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

func (*BucketInfo) XXX_Merge 

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

func (*BucketInfo) XXX_Size 

func (m *BucketInfo) XXX_Size() int

func (*BucketInfo) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

GenesisState defines the bridge module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type GroupInfo 

type GroupInfo struct {
	// owner is the owner of the group. It can not changed once it created.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// group_name is the name of group which is unique under an account.
	GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// id is the unique identifier of group
	Id Uint `protobuf:"bytes,3,opt,name=id,proto3,customtype=Uint" json:"id"`
}

func (*GroupInfo) Descriptor 

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

func (*GroupInfo) GetGroupName 

func (m *GroupInfo) GetGroupName() string

func (*GroupInfo) GetOwner 

func (m *GroupInfo) GetOwner() string

func (*GroupInfo) Marshal 

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

func (*GroupInfo) MarshalTo 

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

func (*GroupInfo) MarshalToSizedBuffer 

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

func (*GroupInfo) ProtoMessage 

func (*GroupInfo) ProtoMessage()

func (*GroupInfo) Reset 

func (m *GroupInfo) Reset()

func (*GroupInfo) Size 

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

func (*GroupInfo) String 

func (m *GroupInfo) String() string

func (*GroupInfo) Unmarshal 

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

func (*GroupInfo) XXX_DiscardUnknown 

func (m *GroupInfo) XXX_DiscardUnknown()

func (*GroupInfo) XXX_Marshal 

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

func (*GroupInfo) XXX_Merge 

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

func (*GroupInfo) XXX_Size 

func (m *GroupInfo) XXX_Size() int

func (*GroupInfo) XXX_Unmarshal 

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

type GroupMemberInfo 

type GroupMemberInfo struct {
	Member     string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	Id         Uint   `protobuf:"bytes,2,opt,name=id,proto3,customtype=Uint" json:"id"`
	ExpireTime uint64 `protobuf:"varint,3,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
}

func (*GroupMemberInfo) Descriptor 

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

func (*GroupMemberInfo) GetExpireTime 

func (m *GroupMemberInfo) GetExpireTime() uint64

func (*GroupMemberInfo) GetMember 

func (m *GroupMemberInfo) GetMember() string

func (*GroupMemberInfo) Marshal 

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

func (*GroupMemberInfo) MarshalTo 

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

func (*GroupMemberInfo) MarshalToSizedBuffer 

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

func (*GroupMemberInfo) ProtoMessage 

func (*GroupMemberInfo) ProtoMessage()

func (*GroupMemberInfo) Reset 

func (m *GroupMemberInfo) Reset()

func (*GroupMemberInfo) Size 

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

func (*GroupMemberInfo) String 

func (m *GroupMemberInfo) String() string

func (*GroupMemberInfo) Unmarshal 

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

func (*GroupMemberInfo) XXX_DiscardUnknown 

func (m *GroupMemberInfo) XXX_DiscardUnknown()

func (*GroupMemberInfo) XXX_Marshal 

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

func (*GroupMemberInfo) XXX_Merge 

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

func (*GroupMemberInfo) XXX_Size 

func (m *GroupMemberInfo) XXX_Size() int

func (*GroupMemberInfo) XXX_Unmarshal 

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

type Int deprecated 

type Int = sdkmath.Int

Type aliases to the SDK's math sub-module

Deprecated: Functionality of this package has been moved to it's own module: cosmossdk.io/math

Please use the above module instead of this package.

type MsgClient 

type MsgClient interface {
	CreateBucket(ctx context.Context, in *MsgCreateBucket, opts ...grpc.CallOption) (*MsgCreateBucketResponse, error)
	DeleteBucket(ctx context.Context, in *MsgDeleteBucket, opts ...grpc.CallOption) (*MsgDeleteBucketResponse, error)
	CreateObject(ctx context.Context, in *MsgCreateObject, opts ...grpc.CallOption) (*MsgCreateObjectResponse, error)
	SealObject(ctx context.Context, in *MsgSealObject, opts ...grpc.CallOption) (*MsgSealObjectResponse, error)
	RejectSealObject(ctx context.Context, in *MsgRejectSealObject, opts ...grpc.CallOption) (*MsgRejectSealObjectResponse, error)
	DeleteObject(ctx context.Context, in *MsgDeleteObject, opts ...grpc.CallOption) (*MsgDeleteObjectResponse, error)
	CreateGroup(ctx context.Context, in *MsgCreateGroup, opts ...grpc.CallOption) (*MsgCreateGroupResponse, error)
	DeleteGroup(ctx context.Context, in *MsgDeleteGroup, opts ...grpc.CallOption) (*MsgDeleteGroupResponse, error)
	UpdateGroupMember(ctx context.Context, in *MsgUpdateGroupMember, opts ...grpc.CallOption) (*MsgUpdateGroupMemberResponse, error)
	LeaveGroup(ctx context.Context, in *MsgLeaveGroup, opts ...grpc.CallOption) (*MsgLeaveGroupResponse, error)
	CopyObject(ctx context.Context, in *MsgCopyObject, opts ...grpc.CallOption) (*MsgCopyObjectResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCopyObject 

type MsgCopyObject struct {
	// operator is the account address of the operator who has the CopyObject permission of the object to be deleted.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// src_bucket_name is the name of the bucket where the object to be copied is located
	SrcBucketName string `protobuf:"bytes,2,opt,name=src_bucket_name,json=srcBucketName,proto3" json:"src_bucket_name,omitempty"`
	// dst_bucket_name is the name of the bucket where the object is copied to.
	DstBucketName string `protobuf:"bytes,3,opt,name=dst_bucket_name,json=dstBucketName,proto3" json:"dst_bucket_name,omitempty"`
	// src_object_name is the name of the object which to be copied
	SrcObjectName string `protobuf:"bytes,4,opt,name=src_object_name,json=srcObjectName,proto3" json:"src_object_name,omitempty"`
	// dst_object_name is the name of the object which is copied to
	DstObjectName string `protobuf:"bytes,5,opt,name=dst_object_name,json=dstObjectName,proto3" json:"dst_object_name,omitempty"`
	// dst_primary_sp_approval_signature is a approval signature of primary sp
	DstPrimarySpApprovalSignature []byte `` /* 154-byte string literal not displayed */
}

func NewMsgCopyObject 

func NewMsgCopyObject(
	operator sdk.AccAddress, srcBucketName string, dstBucketName string,
	srcObjectName string, dstObjectName string, dstPrimarySPApproval []byte) *MsgCopyObject

func (*MsgCopyObject) Descriptor 

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

func (*MsgCopyObject) GetDstBucketName 

func (m *MsgCopyObject) GetDstBucketName() string

func (*MsgCopyObject) GetDstObjectName 

func (m *MsgCopyObject) GetDstObjectName() string

func (*MsgCopyObject) GetDstPrimarySpApprovalSignature 

func (m *MsgCopyObject) GetDstPrimarySpApprovalSignature() []byte

func (*MsgCopyObject) GetOperator 

func (m *MsgCopyObject) GetOperator() string

func (*MsgCopyObject) GetSignBytes 

func (msg *MsgCopyObject) GetSignBytes() []byte

func (*MsgCopyObject) GetSigners 

func (msg *MsgCopyObject) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgCopyObject) GetSrcBucketName 

func (m *MsgCopyObject) GetSrcBucketName() string

func (*MsgCopyObject) GetSrcObjectName 

func (m *MsgCopyObject) GetSrcObjectName() string

func (*MsgCopyObject) Marshal 

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

func (*MsgCopyObject) MarshalTo 

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

func (*MsgCopyObject) MarshalToSizedBuffer 

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

func (*MsgCopyObject) ProtoMessage 

func (*MsgCopyObject) ProtoMessage()

func (*MsgCopyObject) Reset 

func (m *MsgCopyObject) Reset()

func (*MsgCopyObject) Route 

func (msg *MsgCopyObject) Route() string

Route implements the sdk.Msg interface.

func (*MsgCopyObject) Size 

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

func (*MsgCopyObject) String 

func (m *MsgCopyObject) String() string

func (*MsgCopyObject) Type 

func (msg *MsgCopyObject) Type() string

Type implements the sdk.Msg interface.

func (*MsgCopyObject) Unmarshal 

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

func (*MsgCopyObject) ValidateBasic 

func (msg *MsgCopyObject) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgCopyObject) XXX_DiscardUnknown 

func (m *MsgCopyObject) XXX_DiscardUnknown()

func (*MsgCopyObject) XXX_Marshal 

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

func (*MsgCopyObject) XXX_Merge 

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

func (*MsgCopyObject) XXX_Size 

func (m *MsgCopyObject) XXX_Size() int

func (*MsgCopyObject) XXX_Unmarshal 

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

type MsgCopyObjectResponse 

type MsgCopyObjectResponse struct {
}

func (*MsgCopyObjectResponse) Descriptor 

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

func (*MsgCopyObjectResponse) Marshal 

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

func (*MsgCopyObjectResponse) MarshalTo 

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

func (*MsgCopyObjectResponse) MarshalToSizedBuffer 

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

func (*MsgCopyObjectResponse) ProtoMessage 

func (*MsgCopyObjectResponse) ProtoMessage()

func (*MsgCopyObjectResponse) Reset 

func (m *MsgCopyObjectResponse) Reset()

func (*MsgCopyObjectResponse) Size 

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

func (*MsgCopyObjectResponse) String 

func (m *MsgCopyObjectResponse) String() string

func (*MsgCopyObjectResponse) Unmarshal 

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

func (*MsgCopyObjectResponse) XXX_DiscardUnknown 

func (m *MsgCopyObjectResponse) XXX_DiscardUnknown()

func (*MsgCopyObjectResponse) XXX_Marshal 

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

func (*MsgCopyObjectResponse) XXX_Merge 

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

func (*MsgCopyObjectResponse) XXX_Size 

func (m *MsgCopyObjectResponse) XXX_Size() int

func (*MsgCopyObjectResponse) XXX_Unmarshal 

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

type MsgCreateBucket 

type MsgCreateBucket struct {
	// creator is the account address of bucket creator, it is also the bucket owner.
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// bucket_name is a globally unique name of bucket
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// is_public means the bucket is private or public. if private, only bucket owner or grantee can read it,
	// otherwise every greenfield user can read it.
	IsPublic bool `protobuf:"varint,3,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// payment_address is an account address specified by bucket owner to pay the read fee. Default: creator
	PaymentAddress string `protobuf:"bytes,4,opt,name=payment_address,json=paymentAddress,proto3" json:"payment_address,omitempty"`
	// primary_sp_address is the address of primary sp.
	PrimarySpAddress string `protobuf:"bytes,6,opt,name=primary_sp_address,json=primarySpAddress,proto3" json:"primary_sp_address,omitempty"`
	// primary_sp_approval_signature is the signature of the primary SP which indicates that primary sp confirm the user's request.
	PrimarySpApprovalSignature []byte `` /* 143-byte string literal not displayed */
}

func NewMsgCreateBucket 

func NewMsgCreateBucket(
	creator sdk.AccAddress, bucketName string, isPublic bool,
	primarySPAddress sdk.AccAddress, paymentAddress sdk.AccAddress, primarySPApproval []byte) *MsgCreateBucket

NewMsgCreateBucket creates a new MsgCreateBucket instance.

func (*MsgCreateBucket) Descriptor 

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

func (*MsgCreateBucket) GetBucketName 

func (m *MsgCreateBucket) GetBucketName() string

func (*MsgCreateBucket) GetCreator 

func (m *MsgCreateBucket) GetCreator() string

func (*MsgCreateBucket) GetIsPublic 

func (m *MsgCreateBucket) GetIsPublic() bool

func (*MsgCreateBucket) GetPaymentAddress 

func (m *MsgCreateBucket) GetPaymentAddress() string

func (*MsgCreateBucket) GetPrimarySpAddress 

func (m *MsgCreateBucket) GetPrimarySpAddress() string

func (*MsgCreateBucket) GetPrimarySpApprovalSignature 

func (m *MsgCreateBucket) GetPrimarySpApprovalSignature() []byte

func (*MsgCreateBucket) GetSignBytes 

func (msg *MsgCreateBucket) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgCreateBucket) GetSigners 

func (msg *MsgCreateBucket) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface. It returns the address(es) that must sign over msg.GetSignBytes().

func (*MsgCreateBucket) Marshal 

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

func (*MsgCreateBucket) MarshalTo 

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

func (*MsgCreateBucket) MarshalToSizedBuffer 

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

func (*MsgCreateBucket) ProtoMessage 

func (*MsgCreateBucket) ProtoMessage()

func (*MsgCreateBucket) Reset 

func (m *MsgCreateBucket) Reset()

func (*MsgCreateBucket) Route 

func (msg *MsgCreateBucket) Route() string

Route implements the sdk.Msg interface.

func (*MsgCreateBucket) Size 

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

func (*MsgCreateBucket) String 

func (m *MsgCreateBucket) String() string

func (*MsgCreateBucket) Type 

func (msg *MsgCreateBucket) Type() string

Type implements the sdk.Msg interface.

func (*MsgCreateBucket) Unmarshal 

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

func (*MsgCreateBucket) ValidateBasic 

func (msg *MsgCreateBucket) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgCreateBucket) XXX_DiscardUnknown 

func (m *MsgCreateBucket) XXX_DiscardUnknown()

func (*MsgCreateBucket) XXX_Marshal 

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

func (*MsgCreateBucket) XXX_Merge 

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

func (*MsgCreateBucket) XXX_Size 

func (m *MsgCreateBucket) XXX_Size() int

func (*MsgCreateBucket) XXX_Unmarshal 

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

type MsgCreateBucketResponse 

type MsgCreateBucketResponse struct {
}

func (*MsgCreateBucketResponse) Descriptor 

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

func (*MsgCreateBucketResponse) Marshal 

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

func (*MsgCreateBucketResponse) MarshalTo 

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

func (*MsgCreateBucketResponse) MarshalToSizedBuffer 

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

func (*MsgCreateBucketResponse) ProtoMessage 

func (*MsgCreateBucketResponse) ProtoMessage()

func (*MsgCreateBucketResponse) Reset 

func (m *MsgCreateBucketResponse) Reset()

func (*MsgCreateBucketResponse) Size 

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

func (*MsgCreateBucketResponse) String 

func (m *MsgCreateBucketResponse) String() string

func (*MsgCreateBucketResponse) Unmarshal 

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

func (*MsgCreateBucketResponse) XXX_DiscardUnknown 

func (m *MsgCreateBucketResponse) XXX_DiscardUnknown()

func (*MsgCreateBucketResponse) XXX_Marshal 

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

func (*MsgCreateBucketResponse) XXX_Merge 

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

func (*MsgCreateBucketResponse) XXX_Size 

func (m *MsgCreateBucketResponse) XXX_Size() int

func (*MsgCreateBucketResponse) XXX_Unmarshal 

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

type MsgCreateGroup 

type MsgCreateGroup struct {
	// owner is the account address of group owner who create the group
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// group_name is the name of the group. it's not globally unique.
	GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// member_request is a list of member which to be add or remove
	Members []string `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
}

func NewMsgCreateGroup 

func NewMsgCreateGroup(creator sdk.AccAddress, groupName string, membersAcc []sdk.AccAddress) *MsgCreateGroup

func (*MsgCreateGroup) Descriptor 

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

func (*MsgCreateGroup) GetCreator 

func (m *MsgCreateGroup) GetCreator() string

func (*MsgCreateGroup) GetGroupName 

func (m *MsgCreateGroup) GetGroupName() string

func (*MsgCreateGroup) GetMembers 

func (m *MsgCreateGroup) GetMembers() []string

func (*MsgCreateGroup) GetSignBytes 

func (msg *MsgCreateGroup) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgCreateGroup) GetSigners 

func (msg *MsgCreateGroup) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgCreateGroup) Marshal 

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

func (*MsgCreateGroup) MarshalTo 

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

func (*MsgCreateGroup) MarshalToSizedBuffer 

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

func (*MsgCreateGroup) ProtoMessage 

func (*MsgCreateGroup) ProtoMessage()

func (*MsgCreateGroup) Reset 

func (m *MsgCreateGroup) Reset()

func (*MsgCreateGroup) Route 

func (msg *MsgCreateGroup) Route() string

Route implements the sdk.Msg interface.

func (*MsgCreateGroup) Size 

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

func (*MsgCreateGroup) String 

func (m *MsgCreateGroup) String() string

func (*MsgCreateGroup) Type 

func (msg *MsgCreateGroup) Type() string

Type implements the sdk.Msg interface.

func (*MsgCreateGroup) Unmarshal 

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

func (*MsgCreateGroup) ValidateBasic 

func (msg *MsgCreateGroup) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgCreateGroup) XXX_DiscardUnknown 

func (m *MsgCreateGroup) XXX_DiscardUnknown()

func (*MsgCreateGroup) XXX_Marshal 

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

func (*MsgCreateGroup) XXX_Merge 

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

func (*MsgCreateGroup) XXX_Size 

func (m *MsgCreateGroup) XXX_Size() int

func (*MsgCreateGroup) XXX_Unmarshal 

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

type MsgCreateGroupResponse 

type MsgCreateGroupResponse struct {
}

func (*MsgCreateGroupResponse) Descriptor 

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

func (*MsgCreateGroupResponse) Marshal 

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

func (*MsgCreateGroupResponse) MarshalTo 

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

func (*MsgCreateGroupResponse) MarshalToSizedBuffer 

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

func (*MsgCreateGroupResponse) ProtoMessage 

func (*MsgCreateGroupResponse) ProtoMessage()

func (*MsgCreateGroupResponse) Reset 

func (m *MsgCreateGroupResponse) Reset()

func (*MsgCreateGroupResponse) Size 

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

func (*MsgCreateGroupResponse) String 

func (m *MsgCreateGroupResponse) String() string

func (*MsgCreateGroupResponse) Unmarshal 

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

func (*MsgCreateGroupResponse) XXX_DiscardUnknown 

func (m *MsgCreateGroupResponse) XXX_DiscardUnknown()

func (*MsgCreateGroupResponse) XXX_Marshal 

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

func (*MsgCreateGroupResponse) XXX_Merge 

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

func (*MsgCreateGroupResponse) XXX_Size 

func (m *MsgCreateGroupResponse) XXX_Size() int

func (*MsgCreateGroupResponse) XXX_Unmarshal 

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

type MsgCreateObject 

type MsgCreateObject struct {
	// creator is the account address of object uploader
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// bucket_name is the name of the bucket where the object is stored.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// object_name is the name of object
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// payload_size is size of the object's payload
	PayloadSize uint64 `protobuf:"varint,4,opt,name=payload_size,json=payloadSize,proto3" json:"payload_size,omitempty"`
	// is_public means the bucket is private or public. if private, only bucket owner or grantee can access it,
	// otherwise every greenfield user can access it.
	IsPublic bool `protobuf:"varint,5,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// content_type is a standard MIME type describing the format of the object.
	ContentType string `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// primary_sp_approval_signature is the signature of the primary SP with its signature
	// which indicates that primary sp confirm the user's creation request.
	PrimarySpApprovalSignature []byte `` /* 143-byte string literal not displayed */
	// expect_checksums is a list of hashes which was generate by redundancy algorithm.
	ExpectChecksums [][]byte `protobuf:"bytes,8,rep,name=expect_checksums,json=expectChecksums,proto3" json:"expect_checksums,omitempty"`
	// expect_secondarySPs is a list of StorageProvider address, which is optional
	ExpectSecondarySpAddresses []string `` /* 143-byte string literal not displayed */
}

func NewMsgCreateObject 

func NewMsgCreateObject(
	creator sdk.AccAddress, bucketName string, objectName string, payloadSize uint64,
	isPublic bool, expectChecksums [][]byte, contentType string, primarySPApproval []byte,
	secondarySPAccs []sdk.AccAddress) *MsgCreateObject

NewMsgCreateObject creates a new MsgCreateObject instance.

func (*MsgCreateObject) Descriptor 

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

func (*MsgCreateObject) GetBucketName 

func (m *MsgCreateObject) GetBucketName() string

func (*MsgCreateObject) GetContentType 

func (m *MsgCreateObject) GetContentType() string

func (*MsgCreateObject) GetCreator 

func (m *MsgCreateObject) GetCreator() string

func (*MsgCreateObject) GetExpectChecksums 

func (m *MsgCreateObject) GetExpectChecksums() [][]byte

func (*MsgCreateObject) GetExpectSecondarySpAddresses 

func (m *MsgCreateObject) GetExpectSecondarySpAddresses() []string

func (*MsgCreateObject) GetIsPublic 

func (m *MsgCreateObject) GetIsPublic() bool

func (*MsgCreateObject) GetObjectName 

func (m *MsgCreateObject) GetObjectName() string

func (*MsgCreateObject) GetPayloadSize 

func (m *MsgCreateObject) GetPayloadSize() uint64

func (*MsgCreateObject) GetPrimarySpApprovalSignature 

func (m *MsgCreateObject) GetPrimarySpApprovalSignature() []byte

func (*MsgCreateObject) GetSignBytes 

func (msg *MsgCreateObject) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgCreateObject) GetSigners 

func (msg *MsgCreateObject) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgCreateObject) Marshal 

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

func (*MsgCreateObject) MarshalTo 

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

func (*MsgCreateObject) MarshalToSizedBuffer 

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

func (*MsgCreateObject) ProtoMessage 

func (*MsgCreateObject) ProtoMessage()

func (*MsgCreateObject) Reset 

func (m *MsgCreateObject) Reset()

func (*MsgCreateObject) Route 

func (msg *MsgCreateObject) Route() string

Route implements the sdk.Msg interface.

func (*MsgCreateObject) Size 

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

func (*MsgCreateObject) String 

func (m *MsgCreateObject) String() string

func (*MsgCreateObject) Type 

func (msg *MsgCreateObject) Type() string

Type implements the sdk.Msg interface.

func (*MsgCreateObject) Unmarshal 

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

func (*MsgCreateObject) ValidateBasic 

func (msg *MsgCreateObject) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgCreateObject) XXX_DiscardUnknown 

func (m *MsgCreateObject) XXX_DiscardUnknown()

func (*MsgCreateObject) XXX_Marshal 

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

func (*MsgCreateObject) XXX_Merge 

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

func (*MsgCreateObject) XXX_Size 

func (m *MsgCreateObject) XXX_Size() int

func (*MsgCreateObject) XXX_Unmarshal 

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

type MsgCreateObjectResponse 

type MsgCreateObjectResponse struct {
}

func (*MsgCreateObjectResponse) Descriptor 

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

func (*MsgCreateObjectResponse) Marshal 

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

func (*MsgCreateObjectResponse) MarshalTo 

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

func (*MsgCreateObjectResponse) MarshalToSizedBuffer 

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

func (*MsgCreateObjectResponse) ProtoMessage 

func (*MsgCreateObjectResponse) ProtoMessage()

func (*MsgCreateObjectResponse) Reset 

func (m *MsgCreateObjectResponse) Reset()

func (*MsgCreateObjectResponse) Size 

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

func (*MsgCreateObjectResponse) String 

func (m *MsgCreateObjectResponse) String() string

func (*MsgCreateObjectResponse) Unmarshal 

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

func (*MsgCreateObjectResponse) XXX_DiscardUnknown 

func (m *MsgCreateObjectResponse) XXX_DiscardUnknown()

func (*MsgCreateObjectResponse) XXX_Marshal 

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

func (*MsgCreateObjectResponse) XXX_Merge 

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

func (*MsgCreateObjectResponse) XXX_Size 

func (m *MsgCreateObjectResponse) XXX_Size() int

func (*MsgCreateObjectResponse) XXX_Unmarshal 

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

type MsgDeleteBucket 

type MsgDeleteBucket struct {
	// creator is the account address of the grantee who has the DeleteBucket permission of the bucket to be deleted.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// bucket_name is the name of the bucket to be deleted.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
}

func NewMsgDeleteBucket 

func NewMsgDeleteBucket(operator sdk.AccAddress, bucketName string) *MsgDeleteBucket

NewMsgDeleteBucket creates a new MsgDeleteBucket instance

func (*MsgDeleteBucket) Descriptor 

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

func (*MsgDeleteBucket) GetBucketName 

func (m *MsgDeleteBucket) GetBucketName() string

func (*MsgDeleteBucket) GetOperator 

func (m *MsgDeleteBucket) GetOperator() string

func (*MsgDeleteBucket) GetSignBytes 

func (msg *MsgDeleteBucket) GetSignBytes() []byte

GetSignBytes implements the sdk.Msg interface.

func (*MsgDeleteBucket) GetSigners 

func (msg *MsgDeleteBucket) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgDeleteBucket) Marshal 

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

func (*MsgDeleteBucket) MarshalTo 

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

func (*MsgDeleteBucket) MarshalToSizedBuffer 

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

func (*MsgDeleteBucket) ProtoMessage 

func (*MsgDeleteBucket) ProtoMessage()

func (*MsgDeleteBucket) Reset 

func (m *MsgDeleteBucket) Reset()

func (*MsgDeleteBucket) Route 

func (msg *MsgDeleteBucket) Route() string

Route implements the sdk.Msg interface.

func (*MsgDeleteBucket) Size 

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

func (*MsgDeleteBucket) String 

func (m *MsgDeleteBucket) String() string

func (*MsgDeleteBucket) Type 

func (msg *MsgDeleteBucket) Type() string

Type implements the sdk.Msg interface.

func (*MsgDeleteBucket) Unmarshal 

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

func (*MsgDeleteBucket) ValidateBasic 

func (msg *MsgDeleteBucket) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgDeleteBucket) XXX_DiscardUnknown 

func (m *MsgDeleteBucket) XXX_DiscardUnknown()

func (*MsgDeleteBucket) XXX_Marshal 

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

func (*MsgDeleteBucket) XXX_Merge 

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

func (*MsgDeleteBucket) XXX_Size 

func (m *MsgDeleteBucket) XXX_Size() int

func (*MsgDeleteBucket) XXX_Unmarshal 

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

type MsgDeleteBucketResponse 

type MsgDeleteBucketResponse struct {
}

func (*MsgDeleteBucketResponse) Descriptor 

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

func (*MsgDeleteBucketResponse) Marshal 

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

func (*MsgDeleteBucketResponse) MarshalTo 

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

func (*MsgDeleteBucketResponse) MarshalToSizedBuffer 

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

func (*MsgDeleteBucketResponse) ProtoMessage 

func (*MsgDeleteBucketResponse) ProtoMessage()

func (*MsgDeleteBucketResponse) Reset 

func (m *MsgDeleteBucketResponse) Reset()

func (*MsgDeleteBucketResponse) Size 

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

func (*MsgDeleteBucketResponse) String 

func (m *MsgDeleteBucketResponse) String() string

func (*MsgDeleteBucketResponse) Unmarshal 

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

func (*MsgDeleteBucketResponse) XXX_DiscardUnknown 

func (m *MsgDeleteBucketResponse) XXX_DiscardUnknown()

func (*MsgDeleteBucketResponse) XXX_Marshal 

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

func (*MsgDeleteBucketResponse) XXX_Merge 

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

func (*MsgDeleteBucketResponse) XXX_Size 

func (m *MsgDeleteBucketResponse) XXX_Size() int

func (*MsgDeleteBucketResponse) XXX_Unmarshal 

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

type MsgDeleteGroup 

type MsgDeleteGroup struct {
	// operator is the account address of the operator who has the DeleteGroup permission of the group to be deleted.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// group_name is the name of the group which to be deleted
	GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
}

func NewMsgDeleteGroup 

func NewMsgDeleteGroup(operator sdk.AccAddress, groupName string) *MsgDeleteGroup

func (*MsgDeleteGroup) Descriptor 

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

func (*MsgDeleteGroup) GetGroupName 

func (m *MsgDeleteGroup) GetGroupName() string

func (*MsgDeleteGroup) GetOperator 

func (m *MsgDeleteGroup) GetOperator() string

func (*MsgDeleteGroup) GetSignBytes 

func (msg *MsgDeleteGroup) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgDeleteGroup) GetSigners 

func (msg *MsgDeleteGroup) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgDeleteGroup) Marshal 

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

func (*MsgDeleteGroup) MarshalTo 

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

func (*MsgDeleteGroup) MarshalToSizedBuffer 

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

func (*MsgDeleteGroup) ProtoMessage 

func (*MsgDeleteGroup) ProtoMessage()

func (*MsgDeleteGroup) Reset 

func (m *MsgDeleteGroup) Reset()

func (*MsgDeleteGroup) Route 

func (msg *MsgDeleteGroup) Route() string

Route implements the sdk.Msg interface.

func (*MsgDeleteGroup) Size 

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

func (*MsgDeleteGroup) String 

func (m *MsgDeleteGroup) String() string

func (*MsgDeleteGroup) Type 

func (msg *MsgDeleteGroup) Type() string

Type implements the sdk.Msg interface.

func (*MsgDeleteGroup) Unmarshal 

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

func (*MsgDeleteGroup) ValidateBasic 

func (msg *MsgDeleteGroup) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgDeleteGroup) XXX_DiscardUnknown 

func (m *MsgDeleteGroup) XXX_DiscardUnknown()

func (*MsgDeleteGroup) XXX_Marshal 

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

func (*MsgDeleteGroup) XXX_Merge 

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

func (*MsgDeleteGroup) XXX_Size 

func (m *MsgDeleteGroup) XXX_Size() int

func (*MsgDeleteGroup) XXX_Unmarshal 

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

type MsgDeleteGroupResponse 

type MsgDeleteGroupResponse struct {
}

func (*MsgDeleteGroupResponse) Descriptor 

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

func (*MsgDeleteGroupResponse) Marshal 

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

func (*MsgDeleteGroupResponse) MarshalTo 

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

func (*MsgDeleteGroupResponse) MarshalToSizedBuffer 

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

func (*MsgDeleteGroupResponse) ProtoMessage 

func (*MsgDeleteGroupResponse) ProtoMessage()

func (*MsgDeleteGroupResponse) Reset 

func (m *MsgDeleteGroupResponse) Reset()

func (*MsgDeleteGroupResponse) Size 

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

func (*MsgDeleteGroupResponse) String 

func (m *MsgDeleteGroupResponse) String() string

func (*MsgDeleteGroupResponse) Unmarshal 

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

func (*MsgDeleteGroupResponse) XXX_DiscardUnknown 

func (m *MsgDeleteGroupResponse) XXX_DiscardUnknown()

func (*MsgDeleteGroupResponse) XXX_Marshal 

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

func (*MsgDeleteGroupResponse) XXX_Merge 

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

func (*MsgDeleteGroupResponse) XXX_Size 

func (m *MsgDeleteGroupResponse) XXX_Size() int

func (*MsgDeleteGroupResponse) XXX_Unmarshal 

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

type MsgDeleteObject 

type MsgDeleteObject struct {
	// operator is the account address of the operator who has the DeleteObject permission of the object to be deleted.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// bucket_name is the name of the bucket where the object which to be deleted is stored.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// object_name is the name of the object which to be deleted.
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
}

func NewMsgDeleteObject 

func NewMsgDeleteObject(operator sdk.AccAddress, bucketName string, objectName string) *MsgDeleteObject

func (*MsgDeleteObject) Descriptor 

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

func (*MsgDeleteObject) GetBucketName 

func (m *MsgDeleteObject) GetBucketName() string

func (*MsgDeleteObject) GetObjectName 

func (m *MsgDeleteObject) GetObjectName() string

func (*MsgDeleteObject) GetOperator 

func (m *MsgDeleteObject) GetOperator() string

func (*MsgDeleteObject) GetSignBytes 

func (msg *MsgDeleteObject) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgDeleteObject) GetSigners 

func (msg *MsgDeleteObject) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgDeleteObject) Marshal 

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

func (*MsgDeleteObject) MarshalTo 

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

func (*MsgDeleteObject) MarshalToSizedBuffer 

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

func (*MsgDeleteObject) ProtoMessage 

func (*MsgDeleteObject) ProtoMessage()

func (*MsgDeleteObject) Reset 

func (m *MsgDeleteObject) Reset()

func (*MsgDeleteObject) Route 

func (msg *MsgDeleteObject) Route() string

Route implements the sdk.Msg interface.

func (*MsgDeleteObject) Size 

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

func (*MsgDeleteObject) String 

func (m *MsgDeleteObject) String() string

func (*MsgDeleteObject) Type 

func (msg *MsgDeleteObject) Type() string

Type implements the sdk.Msg interface.

func (*MsgDeleteObject) Unmarshal 

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

func (*MsgDeleteObject) ValidateBasic 

func (msg *MsgDeleteObject) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgDeleteObject) XXX_DiscardUnknown 

func (m *MsgDeleteObject) XXX_DiscardUnknown()

func (*MsgDeleteObject) XXX_Marshal 

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

func (*MsgDeleteObject) XXX_Merge 

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

func (*MsgDeleteObject) XXX_Size 

func (m *MsgDeleteObject) XXX_Size() int

func (*MsgDeleteObject) XXX_Unmarshal 

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

type MsgDeleteObjectResponse 

type MsgDeleteObjectResponse struct {
}

func (*MsgDeleteObjectResponse) Descriptor 

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

func (*MsgDeleteObjectResponse) Marshal 

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

func (*MsgDeleteObjectResponse) MarshalTo 

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

func (*MsgDeleteObjectResponse) MarshalToSizedBuffer 

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

func (*MsgDeleteObjectResponse) ProtoMessage 

func (*MsgDeleteObjectResponse) ProtoMessage()

func (*MsgDeleteObjectResponse) Reset 

func (m *MsgDeleteObjectResponse) Reset()

func (*MsgDeleteObjectResponse) Size 

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

func (*MsgDeleteObjectResponse) String 

func (m *MsgDeleteObjectResponse) String() string

func (*MsgDeleteObjectResponse) Unmarshal 

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

func (*MsgDeleteObjectResponse) XXX_DiscardUnknown 

func (m *MsgDeleteObjectResponse) XXX_DiscardUnknown()

func (*MsgDeleteObjectResponse) XXX_Marshal 

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

func (*MsgDeleteObjectResponse) XXX_Merge 

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

func (*MsgDeleteObjectResponse) XXX_Size 

func (m *MsgDeleteObjectResponse) XXX_Size() int

func (*MsgDeleteObjectResponse) XXX_Unmarshal 

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

type MsgLeaveGroup 

type MsgLeaveGroup struct {
	// member is the account address of the member who want to leave the group
	Member string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// group_owner is the owner of the group you want to leave
	GroupOwner string `protobuf:"bytes,2,opt,name=group_owner,json=groupOwner,proto3" json:"group_owner,omitempty"`
	// group_name is the name of the group you want to leave
	GroupName string `protobuf:"bytes,3,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
}

func NewMsgLeaveGroup 

func NewMsgLeaveGroup(member sdk.AccAddress, groupOwner sdk.AccAddress, groupName string) *MsgLeaveGroup

func (*MsgLeaveGroup) Descriptor 

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

func (*MsgLeaveGroup) GetGroupName 

func (m *MsgLeaveGroup) GetGroupName() string

func (*MsgLeaveGroup) GetGroupOwner 

func (m *MsgLeaveGroup) GetGroupOwner() string

func (*MsgLeaveGroup) GetMember 

func (m *MsgLeaveGroup) GetMember() string

func (*MsgLeaveGroup) GetSignBytes 

func (msg *MsgLeaveGroup) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgLeaveGroup) GetSigners 

func (msg *MsgLeaveGroup) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgLeaveGroup) Marshal 

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

func (*MsgLeaveGroup) MarshalTo 

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

func (*MsgLeaveGroup) MarshalToSizedBuffer 

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

func (*MsgLeaveGroup) ProtoMessage 

func (*MsgLeaveGroup) ProtoMessage()

func (*MsgLeaveGroup) Reset 

func (m *MsgLeaveGroup) Reset()

func (*MsgLeaveGroup) Route 

func (msg *MsgLeaveGroup) Route() string

Route implements the sdk.Msg interface.

func (*MsgLeaveGroup) Size 

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

func (*MsgLeaveGroup) String 

func (m *MsgLeaveGroup) String() string

func (*MsgLeaveGroup) Type 

func (msg *MsgLeaveGroup) Type() string

Type implements the sdk.Msg interface.

func (*MsgLeaveGroup) Unmarshal 

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

func (*MsgLeaveGroup) ValidateBasic 

func (msg *MsgLeaveGroup) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgLeaveGroup) XXX_DiscardUnknown 

func (m *MsgLeaveGroup) XXX_DiscardUnknown()

func (*MsgLeaveGroup) XXX_Marshal 

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

func (*MsgLeaveGroup) XXX_Merge 

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

func (*MsgLeaveGroup) XXX_Size 

func (m *MsgLeaveGroup) XXX_Size() int

func (*MsgLeaveGroup) XXX_Unmarshal 

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

type MsgLeaveGroupResponse 

type MsgLeaveGroupResponse struct {
}

func (*MsgLeaveGroupResponse) Descriptor 

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

func (*MsgLeaveGroupResponse) Marshal 

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

func (*MsgLeaveGroupResponse) MarshalTo 

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

func (*MsgLeaveGroupResponse) MarshalToSizedBuffer 

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

func (*MsgLeaveGroupResponse) ProtoMessage 

func (*MsgLeaveGroupResponse) ProtoMessage()

func (*MsgLeaveGroupResponse) Reset 

func (m *MsgLeaveGroupResponse) Reset()

func (*MsgLeaveGroupResponse) Size 

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

func (*MsgLeaveGroupResponse) String 

func (m *MsgLeaveGroupResponse) String() string

func (*MsgLeaveGroupResponse) Unmarshal 

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

func (*MsgLeaveGroupResponse) XXX_DiscardUnknown 

func (m *MsgLeaveGroupResponse) XXX_DiscardUnknown()

func (*MsgLeaveGroupResponse) XXX_Marshal 

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

func (*MsgLeaveGroupResponse) XXX_Merge 

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

func (*MsgLeaveGroupResponse) XXX_Size 

func (m *MsgLeaveGroupResponse) XXX_Size() int

func (*MsgLeaveGroupResponse) XXX_Unmarshal 

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

type MsgRejectSealObject 

type MsgRejectSealObject struct {
	// operator is the account address of the object owner
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// bucket_name is the name of the bucket where the object is stored.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// object_name is the name of unsealed object to be reject.
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
}

func NewMsgRejectUnsealedObject 

func NewMsgRejectUnsealedObject(operator sdk.AccAddress, bucketName string, objectName string) *MsgRejectSealObject

func (*MsgRejectSealObject) Descriptor 

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

func (*MsgRejectSealObject) GetBucketName 

func (m *MsgRejectSealObject) GetBucketName() string

func (*MsgRejectSealObject) GetObjectName 

func (m *MsgRejectSealObject) GetObjectName() string

func (*MsgRejectSealObject) GetOperator 

func (m *MsgRejectSealObject) GetOperator() string

func (*MsgRejectSealObject) GetSignBytes 

func (msg *MsgRejectSealObject) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgRejectSealObject) GetSigners 

func (msg *MsgRejectSealObject) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgRejectSealObject) Marshal 

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

func (*MsgRejectSealObject) MarshalTo 

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

func (*MsgRejectSealObject) MarshalToSizedBuffer 

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

func (*MsgRejectSealObject) ProtoMessage 

func (*MsgRejectSealObject) ProtoMessage()

func (*MsgRejectSealObject) Reset 

func (m *MsgRejectSealObject) Reset()

func (*MsgRejectSealObject) Route 

func (msg *MsgRejectSealObject) Route() string

Route implements the sdk.Msg interface.

func (*MsgRejectSealObject) Size 

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

func (*MsgRejectSealObject) String 

func (m *MsgRejectSealObject) String() string

func (*MsgRejectSealObject) Type 

func (msg *MsgRejectSealObject) Type() string

Type implements the sdk.Msg interface.

func (*MsgRejectSealObject) Unmarshal 

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

func (*MsgRejectSealObject) ValidateBasic 

func (msg *MsgRejectSealObject) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgRejectSealObject) XXX_DiscardUnknown 

func (m *MsgRejectSealObject) XXX_DiscardUnknown()

func (*MsgRejectSealObject) XXX_Marshal 

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

func (*MsgRejectSealObject) XXX_Merge 

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

func (*MsgRejectSealObject) XXX_Size 

func (m *MsgRejectSealObject) XXX_Size() int

func (*MsgRejectSealObject) XXX_Unmarshal 

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

type MsgRejectSealObjectResponse 

type MsgRejectSealObjectResponse struct {
}

func (*MsgRejectSealObjectResponse) Descriptor 

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

func (*MsgRejectSealObjectResponse) Marshal 

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

func (*MsgRejectSealObjectResponse) MarshalTo 

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

func (*MsgRejectSealObjectResponse) MarshalToSizedBuffer 

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

func (*MsgRejectSealObjectResponse) ProtoMessage 

func (*MsgRejectSealObjectResponse) ProtoMessage()

func (*MsgRejectSealObjectResponse) Reset 

func (m *MsgRejectSealObjectResponse) Reset()

func (*MsgRejectSealObjectResponse) Size 

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

func (*MsgRejectSealObjectResponse) String 

func (m *MsgRejectSealObjectResponse) String() string

func (*MsgRejectSealObjectResponse) Unmarshal 

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

func (*MsgRejectSealObjectResponse) XXX_DiscardUnknown 

func (m *MsgRejectSealObjectResponse) XXX_DiscardUnknown()

func (*MsgRejectSealObjectResponse) XXX_Marshal 

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

func (*MsgRejectSealObjectResponse) XXX_Merge 

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

func (*MsgRejectSealObjectResponse) XXX_Size 

func (m *MsgRejectSealObjectResponse) XXX_Size() int

func (*MsgRejectSealObjectResponse) XXX_Unmarshal 

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

type MsgSealObject 

type MsgSealObject struct {
	// operator is the account address of primary SP
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// bucket_name is the name of the bucket where the object is stored.
	BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// object_name is the name of object to be sealed.
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// secondary_sp_addresses is a list of storage provider which store the redundant data.
	SecondarySpAddresses []string `protobuf:"bytes,4,rep,name=secondary_sp_addresses,json=secondarySpAddresses,proto3" json:"secondary_sp_addresses,omitempty"`
	// secondary_sp_signatures is the signature of the secondary sp that can
	// acknowledge that the payload data has received and stored.
	SecondarySpSignatures [][]byte `` /* 126-byte string literal not displayed */
}

func NewMsgSealObject 

func NewMsgSealObject(
	operator sdk.AccAddress, bucketName string, objectName string,
	secondarySPAccs []sdk.AccAddress, secondarySpSignatures [][]byte) *MsgSealObject

func (*MsgSealObject) Descriptor 

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

func (*MsgSealObject) GetBucketName 

func (m *MsgSealObject) GetBucketName() string

func (*MsgSealObject) GetObjectName 

func (m *MsgSealObject) GetObjectName() string

func (*MsgSealObject) GetOperator 

func (m *MsgSealObject) GetOperator() string

func (*MsgSealObject) GetSecondarySpAddresses 

func (m *MsgSealObject) GetSecondarySpAddresses() []string

func (*MsgSealObject) GetSecondarySpSignatures 

func (m *MsgSealObject) GetSecondarySpSignatures() [][]byte

func (*MsgSealObject) GetSignBytes 

func (msg *MsgSealObject) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgSealObject) GetSigners 

func (msg *MsgSealObject) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgSealObject) Marshal 

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

func (*MsgSealObject) MarshalTo 

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

func (*MsgSealObject) MarshalToSizedBuffer 

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

func (*MsgSealObject) ProtoMessage 

func (*MsgSealObject) ProtoMessage()

func (*MsgSealObject) Reset 

func (m *MsgSealObject) Reset()

func (*MsgSealObject) Route 

func (msg *MsgSealObject) Route() string

Route implements the sdk.Msg interface.

func (*MsgSealObject) Size 

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

func (*MsgSealObject) String 

func (m *MsgSealObject) String() string

func (*MsgSealObject) Type 

func (msg *MsgSealObject) Type() string

Type implements the sdk.Msg interface.

func (*MsgSealObject) Unmarshal 

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

func (*MsgSealObject) ValidateBasic 

func (msg *MsgSealObject) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgSealObject) XXX_DiscardUnknown 

func (m *MsgSealObject) XXX_DiscardUnknown()

func (*MsgSealObject) XXX_Marshal 

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

func (*MsgSealObject) XXX_Merge 

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

func (*MsgSealObject) XXX_Size 

func (m *MsgSealObject) XXX_Size() int

func (*MsgSealObject) XXX_Unmarshal 

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

type MsgSealObjectResponse 

type MsgSealObjectResponse struct {
}

func (*MsgSealObjectResponse) Descriptor 

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

func (*MsgSealObjectResponse) Marshal 

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

func (*MsgSealObjectResponse) MarshalTo 

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

func (*MsgSealObjectResponse) MarshalToSizedBuffer 

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

func (*MsgSealObjectResponse) ProtoMessage 

func (*MsgSealObjectResponse) ProtoMessage()

func (*MsgSealObjectResponse) Reset 

func (m *MsgSealObjectResponse) Reset()

func (*MsgSealObjectResponse) Size 

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

func (*MsgSealObjectResponse) String 

func (m *MsgSealObjectResponse) String() string

func (*MsgSealObjectResponse) Unmarshal 

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

func (*MsgSealObjectResponse) XXX_DiscardUnknown 

func (m *MsgSealObjectResponse) XXX_DiscardUnknown()

func (*MsgSealObjectResponse) XXX_Marshal 

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

func (*MsgSealObjectResponse) XXX_Merge 

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

func (*MsgSealObjectResponse) XXX_Size 

func (m *MsgSealObjectResponse) XXX_Size() int

func (*MsgSealObjectResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	CreateBucket(context.Context, *MsgCreateBucket) (*MsgCreateBucketResponse, error)
	DeleteBucket(context.Context, *MsgDeleteBucket) (*MsgDeleteBucketResponse, error)
	CreateObject(context.Context, *MsgCreateObject) (*MsgCreateObjectResponse, error)
	SealObject(context.Context, *MsgSealObject) (*MsgSealObjectResponse, error)
	RejectSealObject(context.Context, *MsgRejectSealObject) (*MsgRejectSealObjectResponse, error)
	DeleteObject(context.Context, *MsgDeleteObject) (*MsgDeleteObjectResponse, error)
	CreateGroup(context.Context, *MsgCreateGroup) (*MsgCreateGroupResponse, error)
	DeleteGroup(context.Context, *MsgDeleteGroup) (*MsgDeleteGroupResponse, error)
	UpdateGroupMember(context.Context, *MsgUpdateGroupMember) (*MsgUpdateGroupMemberResponse, error)
	LeaveGroup(context.Context, *MsgLeaveGroup) (*MsgLeaveGroupResponse, error)
	CopyObject(context.Context, *MsgCopyObject) (*MsgCopyObjectResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateGroupMember 

type MsgUpdateGroupMember struct {
	// operator is the account address of the operator who has the UpdateGroupMember permission of the group.
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// group_name is the name of the group which to be updated
	GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// members_to_add is a list of members account address which will be add to the group
	MembersToAdd []string `protobuf:"bytes,3,rep,name=members_to_add,json=membersToAdd,proto3" json:"members_to_add,omitempty"`
	// members_to_delete is a list of members account address which will be remove from the group
	MembersToDelete []string `protobuf:"bytes,4,rep,name=members_to_delete,json=membersToDelete,proto3" json:"members_to_delete,omitempty"`
}

func NewMsgUpdateGroupMember 

func NewMsgUpdateGroupMember(
	operator sdk.AccAddress, groupName string, membersToAdd []sdk.AccAddress,
	membersToDelete []sdk.AccAddress) *MsgUpdateGroupMember

func (*MsgUpdateGroupMember) Descriptor 

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

func (*MsgUpdateGroupMember) GetGroupName 

func (m *MsgUpdateGroupMember) GetGroupName() string

func (*MsgUpdateGroupMember) GetMembersToAdd 

func (m *MsgUpdateGroupMember) GetMembersToAdd() []string

func (*MsgUpdateGroupMember) GetMembersToDelete 

func (m *MsgUpdateGroupMember) GetMembersToDelete() []string

func (*MsgUpdateGroupMember) GetOperator 

func (m *MsgUpdateGroupMember) GetOperator() string

func (*MsgUpdateGroupMember) GetSignBytes 

func (msg *MsgUpdateGroupMember) GetSignBytes() []byte

GetSignBytes returns the message bytes to sign over.

func (*MsgUpdateGroupMember) GetSigners 

func (msg *MsgUpdateGroupMember) GetSigners() []sdk.AccAddress

GetSigners implements the sdk.Msg interface.

func (*MsgUpdateGroupMember) Marshal 

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

func (*MsgUpdateGroupMember) MarshalTo 

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

func (*MsgUpdateGroupMember) MarshalToSizedBuffer 

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

func (*MsgUpdateGroupMember) ProtoMessage 

func (*MsgUpdateGroupMember) ProtoMessage()

func (*MsgUpdateGroupMember) Reset 

func (m *MsgUpdateGroupMember) Reset()

func (*MsgUpdateGroupMember) Route 

func (msg *MsgUpdateGroupMember) Route() string

Route implements the sdk.Msg interface.

func (*MsgUpdateGroupMember) Size 

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

func (*MsgUpdateGroupMember) String 

func (m *MsgUpdateGroupMember) String() string

func (*MsgUpdateGroupMember) Type 

func (msg *MsgUpdateGroupMember) Type() string

Type implements the sdk.Msg interface.

func (*MsgUpdateGroupMember) Unmarshal 

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

func (*MsgUpdateGroupMember) ValidateBasic 

func (msg *MsgUpdateGroupMember) ValidateBasic() error

ValidateBasic implements the sdk.Msg interface.

func (*MsgUpdateGroupMember) XXX_DiscardUnknown 

func (m *MsgUpdateGroupMember) XXX_DiscardUnknown()

func (*MsgUpdateGroupMember) XXX_Marshal 

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

func (*MsgUpdateGroupMember) XXX_Merge 

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

func (*MsgUpdateGroupMember) XXX_Size 

func (m *MsgUpdateGroupMember) XXX_Size() int

func (*MsgUpdateGroupMember) XXX_Unmarshal 

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

type MsgUpdateGroupMemberResponse 

type MsgUpdateGroupMemberResponse struct {
}

func (*MsgUpdateGroupMemberResponse) Descriptor 

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

func (*MsgUpdateGroupMemberResponse) Marshal 

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

func (*MsgUpdateGroupMemberResponse) MarshalTo 

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

func (*MsgUpdateGroupMemberResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateGroupMemberResponse) ProtoMessage 

func (*MsgUpdateGroupMemberResponse) ProtoMessage()

func (*MsgUpdateGroupMemberResponse) Reset 

func (m *MsgUpdateGroupMemberResponse) Reset()

func (*MsgUpdateGroupMemberResponse) Size 

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

func (*MsgUpdateGroupMemberResponse) String 

func (m *MsgUpdateGroupMemberResponse) String() string

func (*MsgUpdateGroupMemberResponse) Unmarshal 

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

func (*MsgUpdateGroupMemberResponse) XXX_DiscardUnknown 

func (m *MsgUpdateGroupMemberResponse) XXX_DiscardUnknown()

func (*MsgUpdateGroupMemberResponse) XXX_Marshal 

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

func (*MsgUpdateGroupMemberResponse) XXX_Merge 

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

func (*MsgUpdateGroupMemberResponse) XXX_Size 

func (m *MsgUpdateGroupMemberResponse) XXX_Size() int

func (*MsgUpdateGroupMemberResponse) XXX_Unmarshal 

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

type ObjectInfo 

type ObjectInfo struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,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"`
	// object_name is the name of object
	ObjectName string `protobuf:"bytes,3,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	// id is the unique identifier of object
	Id Uint `protobuf:"bytes,4,opt,name=id,proto3,customtype=Uint" json:"id"`
	// payloadSize is the total size of the object payload
	PayloadSize uint64 `protobuf:"varint,5,opt,name=payload_size,json=payloadSize,proto3" json:"payload_size,omitempty"`
	// is_public define the highest permissions for object. When the object is public, everyone can access it.
	IsPublic bool `protobuf:"varint,6,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// content_type define the format of the object which should be a standard MIME type.
	ContentType string `protobuf:"bytes,7,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// create_at define the block number when the object created
	CreateAt int64 `protobuf:"varint,8,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// object_status define the upload status of the object.
	ObjectStatus ObjectStatus `` /* 144-byte string literal not displayed */
	// redundancy_type define the type of the redundancy which can be multi-replication or EC.
	RedundancyType RedundancyType `` /* 153-byte string literal not displayed */
	// source_type define the source of the object.
	SourceType SourceType `` /* 137-byte string literal not displayed */
	// checksums define the root hash of the pieces which stored in a SP.
	Checksums [][]byte `protobuf:"bytes,12,rep,name=checksums,proto3" json:"checksums,omitempty"`
	// secondary_sp_addresses define the addresses of secondary_sps
	SecondarySpAddresses []string `protobuf:"bytes,13,rep,name=secondary_sp_addresses,json=secondarySpAddresses,proto3" json:"secondary_sp_addresses,omitempty"`
}

func (*ObjectInfo) Descriptor 

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

func (*ObjectInfo) GetBucketName 

func (m *ObjectInfo) GetBucketName() string

func (*ObjectInfo) GetChecksums 

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

func (*ObjectInfo) GetContentType 

func (m *ObjectInfo) GetContentType() string

func (*ObjectInfo) GetCreateAt 

func (m *ObjectInfo) GetCreateAt() int64

func (*ObjectInfo) GetIsPublic 

func (m *ObjectInfo) GetIsPublic() bool

func (*ObjectInfo) GetObjectName 

func (m *ObjectInfo) GetObjectName() string

func (*ObjectInfo) GetObjectStatus 

func (m *ObjectInfo) GetObjectStatus() ObjectStatus

func (*ObjectInfo) GetOwner 

func (m *ObjectInfo) GetOwner() string

func (*ObjectInfo) GetPayloadSize 

func (m *ObjectInfo) GetPayloadSize() uint64

func (*ObjectInfo) GetRedundancyType 

func (m *ObjectInfo) GetRedundancyType() RedundancyType

func (*ObjectInfo) GetSecondarySpAddresses 

func (m *ObjectInfo) GetSecondarySpAddresses() []string

func (*ObjectInfo) GetSourceType 

func (m *ObjectInfo) GetSourceType() SourceType

func (*ObjectInfo) Marshal 

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

func (*ObjectInfo) MarshalTo 

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

func (*ObjectInfo) MarshalToSizedBuffer 

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

func (*ObjectInfo) ProtoMessage 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size 

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

func (*ObjectInfo) String 

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal 

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

func (*ObjectInfo) XXX_DiscardUnknown 

func (m *ObjectInfo) XXX_DiscardUnknown()

func (*ObjectInfo) XXX_Marshal 

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

func (*ObjectInfo) XXX_Merge 

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

func (*ObjectInfo) XXX_Size 

func (m *ObjectInfo) XXX_Size() int

func (*ObjectInfo) XXX_Unmarshal 

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

type ObjectStatus 

type ObjectStatus int32
const (
	OBJECT_STATUS_INIT       ObjectStatus = 0
	OBJECT_STATUS_IN_SERVICE ObjectStatus = 1
)

func (ObjectStatus) EnumDescriptor 

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

func (ObjectStatus) String 

func (x ObjectStatus) String() string

type Params 

type Params struct {
	// max_segment_size is the maximum size of a segment. default: 16M
	MaxSegmentSize uint64 `protobuf:"varint,1,opt,name=max_segment_size,json=maxSegmentSize,proto3" json:"max_segment_size,omitempty"`
	// redundant_data_check_num is the num of data chunks of EC redundancy algorithm
	RedundantDataChunkNum uint32 `` /* 129-byte string literal not displayed */
	// redundant_data_check_num is the num of parity chunks of EC redundancy algorithm
	RedundantParityChunkNum uint32 `` /* 135-byte string literal not displayed */
	// max_payload_size is the maximum size of the payload, default: 2G
	MaxPayloadSize uint64 `protobuf:"varint,4,opt,name=max_payload_size,json=maxPayloadSize,proto3" json:"max_payload_size,omitempty"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	maxSegmentSize uint64, redundantDataChunkNum uint32,
	redundantParityChunkNum uint32, maxPayloadSize uint64) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetMaxPayloadSize 

func (m *Params) GetMaxPayloadSize() uint64

func (*Params) GetMaxSegmentSize 

func (m *Params) GetMaxSegmentSize() uint64

func (*Params) GetRedundantDataChunkNum 

func (m *Params) GetRedundantDataChunkNum() uint32

func (*Params) GetRedundantParityChunkNum 

func (m *Params) GetRedundantParityChunkNum() uint32

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryBucketRequest 

type QueryBucketRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
}

this line is used by starport scaffolding # 3

func (*QueryBucketRequest) Descriptor 

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

func (*QueryBucketRequest) GetBucketName 

func (m *QueryBucketRequest) GetBucketName() string

func (*QueryBucketRequest) Marshal 

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

func (*QueryBucketRequest) MarshalTo 

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

func (*QueryBucketRequest) MarshalToSizedBuffer 

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

func (*QueryBucketRequest) ProtoMessage 

func (*QueryBucketRequest) ProtoMessage()

func (*QueryBucketRequest) Reset 

func (m *QueryBucketRequest) Reset()

func (*QueryBucketRequest) Size 

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

func (*QueryBucketRequest) String 

func (m *QueryBucketRequest) String() string

func (*QueryBucketRequest) Unmarshal 

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

func (*QueryBucketRequest) XXX_DiscardUnknown 

func (m *QueryBucketRequest) XXX_DiscardUnknown()

func (*QueryBucketRequest) XXX_Marshal 

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

func (*QueryBucketRequest) XXX_Merge 

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

func (*QueryBucketRequest) XXX_Size 

func (m *QueryBucketRequest) XXX_Size() int

func (*QueryBucketRequest) XXX_Unmarshal 

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

type QueryBucketResponse 

type QueryBucketResponse struct {
	BucketInfo *BucketInfo `protobuf:"bytes,1,opt,name=bucket_info,json=bucketInfo,proto3" json:"bucket_info,omitempty"`
}

func (*QueryBucketResponse) Descriptor 

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

func (*QueryBucketResponse) GetBucketInfo 

func (m *QueryBucketResponse) GetBucketInfo() *BucketInfo

func (*QueryBucketResponse) Marshal 

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

func (*QueryBucketResponse) MarshalTo 

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

func (*QueryBucketResponse) MarshalToSizedBuffer 

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

func (*QueryBucketResponse) ProtoMessage 

func (*QueryBucketResponse) ProtoMessage()

func (*QueryBucketResponse) Reset 

func (m *QueryBucketResponse) Reset()

func (*QueryBucketResponse) Size 

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

func (*QueryBucketResponse) String 

func (m *QueryBucketResponse) String() string

func (*QueryBucketResponse) Unmarshal 

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

func (*QueryBucketResponse) XXX_DiscardUnknown 

func (m *QueryBucketResponse) XXX_DiscardUnknown()

func (*QueryBucketResponse) XXX_Marshal 

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

func (*QueryBucketResponse) XXX_Merge 

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

func (*QueryBucketResponse) XXX_Size 

func (m *QueryBucketResponse) XXX_Size() int

func (*QueryBucketResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Queries a list of Bucket items.
	Bucket(ctx context.Context, in *QueryBucketRequest, opts ...grpc.CallOption) (*QueryBucketResponse, error)
	// Queries a list of Object items.
	Object(ctx context.Context, in *QueryObjectRequest, opts ...grpc.CallOption) (*QueryObjectResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryObjectRequest 

type QueryObjectRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	ObjectName string `protobuf:"bytes,2,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
}

func (*QueryObjectRequest) Descriptor 

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

func (*QueryObjectRequest) GetBucketName 

func (m *QueryObjectRequest) GetBucketName() string

func (*QueryObjectRequest) GetObjectName 

func (m *QueryObjectRequest) GetObjectName() string

func (*QueryObjectRequest) Marshal 

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

func (*QueryObjectRequest) MarshalTo 

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

func (*QueryObjectRequest) MarshalToSizedBuffer 

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

func (*QueryObjectRequest) ProtoMessage 

func (*QueryObjectRequest) ProtoMessage()

func (*QueryObjectRequest) Reset 

func (m *QueryObjectRequest) Reset()

func (*QueryObjectRequest) Size 

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

func (*QueryObjectRequest) String 

func (m *QueryObjectRequest) String() string

func (*QueryObjectRequest) Unmarshal 

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

func (*QueryObjectRequest) XXX_DiscardUnknown 

func (m *QueryObjectRequest) XXX_DiscardUnknown()

func (*QueryObjectRequest) XXX_Marshal 

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

func (*QueryObjectRequest) XXX_Merge 

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

func (*QueryObjectRequest) XXX_Size 

func (m *QueryObjectRequest) XXX_Size() int

func (*QueryObjectRequest) XXX_Unmarshal 

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

type QueryObjectResponse 

type QueryObjectResponse struct {
	ObjectInfo *ObjectInfo `protobuf:"bytes,1,opt,name=object_info,json=objectInfo,proto3" json:"object_info,omitempty"`
}

func (*QueryObjectResponse) Descriptor 

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

func (*QueryObjectResponse) GetObjectInfo 

func (m *QueryObjectResponse) GetObjectInfo() *ObjectInfo

func (*QueryObjectResponse) Marshal 

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

func (*QueryObjectResponse) MarshalTo 

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

func (*QueryObjectResponse) MarshalToSizedBuffer 

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

func (*QueryObjectResponse) ProtoMessage 

func (*QueryObjectResponse) ProtoMessage()

func (*QueryObjectResponse) Reset 

func (m *QueryObjectResponse) Reset()

func (*QueryObjectResponse) Size 

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

func (*QueryObjectResponse) String 

func (m *QueryObjectResponse) String() string

func (*QueryObjectResponse) Unmarshal 

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

func (*QueryObjectResponse) XXX_DiscardUnknown 

func (m *QueryObjectResponse) XXX_DiscardUnknown()

func (*QueryObjectResponse) XXX_Marshal 

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

func (*QueryObjectResponse) XXX_Merge 

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

func (*QueryObjectResponse) XXX_Size 

func (m *QueryObjectResponse) XXX_Size() int

func (*QueryObjectResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Queries a list of Bucket items.
	Bucket(context.Context, *QueryBucketRequest) (*QueryBucketResponse, error)
	// Queries a list of Object items.
	Object(context.Context, *QueryObjectRequest) (*QueryObjectResponse, error)
}

QueryServer is the server API for Query service.

type ReadQuota 

type ReadQuota int32
const (
	READ_QUOTA_FREE ReadQuota = 0
)

func (ReadQuota) EnumDescriptor 

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

func (ReadQuota) String 

func (x ReadQuota) String() string

type RedundancyType 

type RedundancyType int32
const (
	REDUNDANCY_REPLICA_TYPE RedundancyType = 0
	REDUNDANCY_EC_TYPE      RedundancyType = 1
	REDUNDANCY_INLINE_TYPE  RedundancyType = 2
)

func (RedundancyType) EnumDescriptor 

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

func (RedundancyType) String 

func (x RedundancyType) String() string

type SourceType 

type SourceType int32
const (
	SOURCE_TYPE_ORIGIN          SourceType = 0
	SOURCE_TYPE_BSC_CROSS_CHAIN SourceType = 1
)

func (SourceType) EnumDescriptor 

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

func (SourceType) String 

func (x SourceType) String() string

type SpKeeper 

type SpKeeper interface {
	GetStorageProvider(ctx sdk.Context, addr sdk.AccAddress) (sp sptypes.StorageProvider, found bool)
}

type Uint deprecated 

type Uint = sdkmath.Uint

Type aliases to the SDK's math sub-module

Deprecated: Functionality of this package has been moved to it's own module: cosmossdk.io/math

Please use the above module instead of this package.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CopyObject 

func (*UnimplementedMsgServer) CopyObject(ctx context.Context, req *MsgCopyObject) (*MsgCopyObjectResponse, error)

func (*UnimplementedMsgServer) CreateBucket 

func (*UnimplementedMsgServer) CreateBucket(ctx context.Context, req *MsgCreateBucket) (*MsgCreateBucketResponse, error)

func (*UnimplementedMsgServer) CreateGroup 

func (*UnimplementedMsgServer) CreateGroup(ctx context.Context, req *MsgCreateGroup) (*MsgCreateGroupResponse, error)

func (*UnimplementedMsgServer) CreateObject 

func (*UnimplementedMsgServer) CreateObject(ctx context.Context, req *MsgCreateObject) (*MsgCreateObjectResponse, error)

func (*UnimplementedMsgServer) DeleteBucket 

func (*UnimplementedMsgServer) DeleteBucket(ctx context.Context, req *MsgDeleteBucket) (*MsgDeleteBucketResponse, error)

func (*UnimplementedMsgServer) DeleteGroup 

func (*UnimplementedMsgServer) DeleteGroup(ctx context.Context, req *MsgDeleteGroup) (*MsgDeleteGroupResponse, error)

func (*UnimplementedMsgServer) DeleteObject 

func (*UnimplementedMsgServer) DeleteObject(ctx context.Context, req *MsgDeleteObject) (*MsgDeleteObjectResponse, error)

func (*UnimplementedMsgServer) LeaveGroup 

func (*UnimplementedMsgServer) LeaveGroup(ctx context.Context, req *MsgLeaveGroup) (*MsgLeaveGroupResponse, error)

func (*UnimplementedMsgServer) RejectSealObject 

func (*UnimplementedMsgServer) RejectSealObject(ctx context.Context, req *MsgRejectSealObject) (*MsgRejectSealObjectResponse, error)

func (*UnimplementedMsgServer) SealObject 

func (*UnimplementedMsgServer) SealObject(ctx context.Context, req *MsgSealObject) (*MsgSealObjectResponse, error)

func (*UnimplementedMsgServer) UpdateGroupMember 

func (*UnimplementedMsgServer) UpdateGroupMember(ctx context.Context, req *MsgUpdateGroupMember) (*MsgUpdateGroupMemberResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Bucket 

func (*UnimplementedQueryServer) Bucket(ctx context.Context, req *QueryBucketRequest) (*QueryBucketResponse, error)

func (*UnimplementedQueryServer) Object 

func (*UnimplementedQueryServer) Object(ctx context.Context, req *QueryObjectRequest) (*QueryObjectResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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