types

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: MIT Imports: 33 Imported by: 7

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 = "bundles"

	// 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_bundles"
)

Variables

View Source 
var (
	ErrInvalidLengthBundles        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBundles          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBundles = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source 
var (
	ErrUploaderAlreadyClaimed  = errors.Register(ModuleName, 1100, "uploader role already claimed")
	ErrInvalidArgs             = errors.Register(ModuleName, 1107, "invalid args")
	ErrFromIndex               = errors.Register(ModuleName, 1118, "invalid from index")
	ErrNotDesignatedUploader   = errors.Register(ModuleName, 1113, "not designated uploader")
	ErrUploadInterval          = errors.Register(ModuleName, 1108, "upload interval not surpassed")
	ErrMaxBundleSize           = errors.Register(ModuleName, 1109, "max bundle size was surpassed")
	ErrQuorumNotReached        = errors.Register(ModuleName, 1111, "no quorum reached")
	ErrInvalidVote             = errors.Register(ModuleName, 1119, "invalid vote %v")
	ErrInvalidStorageId        = errors.Register(ModuleName, 1120, "current storageId %v does not match provided storageId")
	ErrPoolDisabled            = errors.Register(ModuleName, 1121, "pool is disabled")
	ErrPoolCurrentlyUpgrading  = errors.Register(ModuleName, 1122, "pool currently upgrading")
	ErrMinDelegationNotReached = errors.Register(ModuleName, 1200, "min delegation not reached")
	ErrBundleDropped           = errors.Register(ModuleName, 1202, "bundle proposal is dropped")
	ErrAlreadyVotedValid       = errors.Register(ModuleName, 1204, "already voted valid on bundle proposal")
	ErrAlreadyVotedInvalid     = errors.Register(ModuleName, 1205, "already voted invalid on bundle proposal")
	ErrAlreadyVotedAbstain     = errors.Register(ModuleName, 1206, "already voted abstain on bundle proposal")
	ErrVotingPowerTooHigh      = errors.Register(ModuleName, 1207, "staker in pool has more than 50% voting power")
)

x/bundles module sentinel errors

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	// BundleKeyPrefix ...
	BundleKeyPrefix = []byte{1}
	// FinalizedBundlePrefix ...
	FinalizedBundlePrefix = []byte{2}
	// FinalizedBundleVersionMapKey ...
	FinalizedBundleVersionMapKey = []byte{3}
	// RoundRobinProgressPrefix ...
	RoundRobinProgressPrefix = []byte{4}

	FinalizedBundleByIndexPrefix = []byte{11}
)
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 BundleStatus_name = map[int32]string{
	0: "BUNDLE_STATUS_UNSPECIFIED",
	1: "BUNDLE_STATUS_VALID",
	2: "BUNDLE_STATUS_INVALID",
	3: "BUNDLE_STATUS_NO_FUNDS",
	4: "BUNDLE_STATUS_NO_QUORUM",
	5: "BUNDLE_STATUS_DISABLED",
}
View Source 
var BundleStatus_value = map[string]int32{
	"BUNDLE_STATUS_UNSPECIFIED": 0,
	"BUNDLE_STATUS_VALID":       1,
	"BUNDLE_STATUS_INVALID":     2,
	"BUNDLE_STATUS_NO_FUNDS":    3,
	"BUNDLE_STATUS_NO_QUORUM":   4,
	"BUNDLE_STATUS_DISABLED":    5,
}
View Source 
var DefaultMaxPoints = uint64(24)

DefaultMaxPoints ...

View Source 
var DefaultNetworkFee = sdk.MustNewDecFromStr("0.01")

DefaultNetworkFee ...

View Source 
var DefaultStorageCost = sdk.MustNewDecFromStr("0.025")

DefaultStorageCost ...

View Source 
var DefaultUploadTimeout = uint64(600)

DefaultUploadTimeout ...

View Source 
var ParamsKey = []byte{0x00}
View Source 
var VoteType_name = map[int32]string{
	0: "VOTE_TYPE_UNSPECIFIED",
	1: "VOTE_TYPE_VALID",
	2: "VOTE_TYPE_INVALID",
	3: "VOTE_TYPE_ABSTAIN",
}
View Source 
var VoteType_value = map[string]int32{
	"VOTE_TYPE_UNSPECIFIED": 0,
	"VOTE_TYPE_VALID":       1,
	"VOTE_TYPE_INVALID":     2,
	"VOTE_TYPE_ABSTAIN":     3,
}

Functions

func BundleProposalKey 

func BundleProposalKey(poolId uint64) []byte

BundleProposalKey ...

func FinalizedBundleByIndexKey added in v1.2.3 

func FinalizedBundleByIndexKey(poolId uint64, height uint64) []byte

FinalizedBundleByIndexKey ...

func FinalizedBundleKey 

func FinalizedBundleKey(poolId uint64, id uint64) []byte

FinalizedBundleKey ...

func RegisterInterfaces 

func RegisterInterfaces(registry codecTypes.InterfaceRegistry)

func RegisterLegacyAminoCodec added in v1.2.0 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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 RoundRobinProgressKey added in v1.3.0 

func RoundRobinProgressKey(poolId uint64) []byte

RoundRobinProgressKey ...

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(moduleName string) sdk.AccAddress
}

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

type BankKeeper 

type BankKeeper interface {
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type BundleProposal 

type BundleProposal struct {
	// pool_id is the id of the pool for which this proposal is for
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// storage_id is the id with which the data can be retrieved from
	StorageId string `protobuf:"bytes,2,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// uploader is the address of the staker who submitted the current proposal
	Uploader string `protobuf:"bytes,3,opt,name=uploader,proto3" json:"uploader,omitempty"`
	// next_uploader is the address of the staker who should upload the next proposal
	NextUploader string `protobuf:"bytes,4,opt,name=next_uploader,json=nextUploader,proto3" json:"next_uploader,omitempty"`
	// data_size the size of the data in bytes
	DataSize uint64 `protobuf:"varint,5,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	// bundle_size the size of the bundle (amount of data items)
	BundleSize uint64 `protobuf:"varint,6,opt,name=bundle_size,json=bundleSize,proto3" json:"bundle_size,omitempty"`
	// to_key the key of the last data item in the bundle proposal
	ToKey string `protobuf:"bytes,7,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	// bundle_summary a string summary of the current proposal
	BundleSummary string `protobuf:"bytes,8,opt,name=bundle_summary,json=bundleSummary,proto3" json:"bundle_summary,omitempty"`
	// data_hash a sha256 hash of the raw compressed data
	DataHash string `protobuf:"bytes,9,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	// updated_at the last time this proposal was edited
	UpdatedAt uint64 `protobuf:"varint,10,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// voters_valid list of all stakers who voted in favor for current proposal
	VotersValid []string `protobuf:"bytes,11,rep,name=voters_valid,json=votersValid,proto3" json:"voters_valid,omitempty"`
	// voters_invalid list of all stakers who voted against for current proposal
	VotersInvalid []string `protobuf:"bytes,12,rep,name=voters_invalid,json=votersInvalid,proto3" json:"voters_invalid,omitempty"`
	// voters_abstain list of all stakers who voted abstain for current proposal
	VotersAbstain []string `protobuf:"bytes,13,rep,name=voters_abstain,json=votersAbstain,proto3" json:"voters_abstain,omitempty"`
	// from_key the key of the first data item in the bundle proposal
	FromKey string `protobuf:"bytes,14,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	// storage_provider_id the id of the storage provider where the bundle is stored
	StorageProviderId uint32 `protobuf:"varint,15,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id the id of the compression type with which the data was compressed
	CompressionId uint32 `protobuf:"varint,16,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
}

BundleProposal represents the current bundle proposal of a storage pool

func (*BundleProposal) Descriptor 

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

func (*BundleProposal) GetBundleSize 

func (m *BundleProposal) GetBundleSize() uint64

func (*BundleProposal) GetBundleSummary 

func (m *BundleProposal) GetBundleSummary() string

func (*BundleProposal) GetCompressionId 

func (m *BundleProposal) GetCompressionId() uint32

func (*BundleProposal) GetDataHash 

func (m *BundleProposal) GetDataHash() string

func (*BundleProposal) GetDataSize 

func (m *BundleProposal) GetDataSize() uint64

func (*BundleProposal) GetFromKey 

func (m *BundleProposal) GetFromKey() string

func (*BundleProposal) GetNextUploader 

func (m *BundleProposal) GetNextUploader() string

func (*BundleProposal) GetPoolId 

func (m *BundleProposal) GetPoolId() uint64

func (*BundleProposal) GetStorageId 

func (m *BundleProposal) GetStorageId() string

func (*BundleProposal) GetStorageProviderId 

func (m *BundleProposal) GetStorageProviderId() uint32

func (*BundleProposal) GetToKey 

func (m *BundleProposal) GetToKey() string

func (*BundleProposal) GetUpdatedAt 

func (m *BundleProposal) GetUpdatedAt() uint64

func (*BundleProposal) GetUploader 

func (m *BundleProposal) GetUploader() string

func (*BundleProposal) GetVotersAbstain 

func (m *BundleProposal) GetVotersAbstain() []string

func (*BundleProposal) GetVotersInvalid 

func (m *BundleProposal) GetVotersInvalid() []string

func (*BundleProposal) GetVotersValid 

func (m *BundleProposal) GetVotersValid() []string

func (*BundleProposal) Marshal 

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

func (*BundleProposal) MarshalTo 

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

func (*BundleProposal) MarshalToSizedBuffer 

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

func (*BundleProposal) ProtoMessage 

func (*BundleProposal) ProtoMessage()

func (*BundleProposal) Reset 

func (m *BundleProposal) Reset()

func (*BundleProposal) Size 

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

func (*BundleProposal) String 

func (m *BundleProposal) String() string

func (*BundleProposal) Unmarshal 

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

func (*BundleProposal) XXX_DiscardUnknown 

func (m *BundleProposal) XXX_DiscardUnknown()

func (*BundleProposal) XXX_Marshal 

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

func (*BundleProposal) XXX_Merge 

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

func (*BundleProposal) XXX_Size 

func (m *BundleProposal) XXX_Size() int

func (*BundleProposal) XXX_Unmarshal 

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

type BundleReward 

type BundleReward struct {
	// treasury ...
	Treasury uint64
	// uploader ...
	Uploader uint64
	// delegation ...
	Delegation uint64
	// total ...
	Total uint64
}

type BundleStatus 

type BundleStatus int32

BundleStatus represents the status of an evaluated bundle proposal. 

const (
	// BUNDLE_STATUS_UNSPECIFIED ...
	BUNDLE_STATUS_UNSPECIFIED BundleStatus = 0
	// BUNDLE_STATUS_VALID ...
	BUNDLE_STATUS_VALID BundleStatus = 1
	// BUNDLE_STATUS_INVALID ...
	BUNDLE_STATUS_INVALID BundleStatus = 2
	// BUNDLE_STATUS_NO_FUNDS ...
	BUNDLE_STATUS_NO_FUNDS BundleStatus = 3
	// BUNDLE_STATUS_NO_QUORUM ...
	BUNDLE_STATUS_NO_QUORUM BundleStatus = 4
	// BUNDLE_STATUS_DISABLED  ...
	BUNDLE_STATUS_DISABLED BundleStatus = 5
)

func (BundleStatus) EnumDescriptor 

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

func (BundleStatus) String 

func (x BundleStatus) String() string

type BundleVersionEntry added in v1.2.3 

type BundleVersionEntry struct {
	// height ...
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// version ...
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

BundleVersionEntry ...

func (*BundleVersionEntry) Descriptor added in v1.2.3 

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

func (*BundleVersionEntry) GetHeight added in v1.2.3 

func (m *BundleVersionEntry) GetHeight() uint64

func (*BundleVersionEntry) GetVersion added in v1.2.3 

func (m *BundleVersionEntry) GetVersion() int32

func (*BundleVersionEntry) Marshal added in v1.2.3 

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

func (*BundleVersionEntry) MarshalTo added in v1.2.3 

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

func (*BundleVersionEntry) MarshalToSizedBuffer added in v1.2.3 

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

func (*BundleVersionEntry) ProtoMessage added in v1.2.3 

func (*BundleVersionEntry) ProtoMessage()

func (*BundleVersionEntry) Reset added in v1.2.3 

func (m *BundleVersionEntry) Reset()

func (*BundleVersionEntry) Size added in v1.2.3 

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

func (*BundleVersionEntry) String added in v1.2.3 

func (m *BundleVersionEntry) String() string

func (*BundleVersionEntry) Unmarshal added in v1.2.3 

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

func (*BundleVersionEntry) XXX_DiscardUnknown added in v1.2.3 

func (m *BundleVersionEntry) XXX_DiscardUnknown()

func (*BundleVersionEntry) XXX_Marshal added in v1.2.3 

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

func (*BundleVersionEntry) XXX_Merge added in v1.2.3 

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

func (*BundleVersionEntry) XXX_Size added in v1.2.3 

func (m *BundleVersionEntry) XXX_Size() int

func (*BundleVersionEntry) XXX_Unmarshal added in v1.2.3 

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

type BundleVersionMap added in v1.2.3 

type BundleVersionMap struct {
	// versions ...
	Versions []*BundleVersionEntry `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
}

BundleVersionMap ...

func (*BundleVersionMap) Descriptor added in v1.2.3 

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

func (BundleVersionMap) GetMap added in v1.2.3 

func (bundleVersionMap BundleVersionMap) GetMap() (versionMap map[int32]uint64)

GetMap converts to array to a go map which return the upgrade-height for each version. e.g. the schema changed from v1 to v2 at block 1,000. then: GetMap()[2] = 1000 Version 1 start at 0 and is not encoded in the map

func (*BundleVersionMap) GetVersions added in v1.2.3 

func (m *BundleVersionMap) GetVersions() []*BundleVersionEntry

func (*BundleVersionMap) Marshal added in v1.2.3 

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

func (*BundleVersionMap) MarshalTo added in v1.2.3 

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

func (*BundleVersionMap) MarshalToSizedBuffer added in v1.2.3 

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

func (*BundleVersionMap) ProtoMessage added in v1.2.3 

func (*BundleVersionMap) ProtoMessage()

func (*BundleVersionMap) Reset added in v1.2.3 

func (m *BundleVersionMap) Reset()

func (*BundleVersionMap) Size added in v1.2.3 

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

func (*BundleVersionMap) String added in v1.2.3 

func (m *BundleVersionMap) String() string

func (*BundleVersionMap) Unmarshal added in v1.2.3 

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

func (*BundleVersionMap) XXX_DiscardUnknown added in v1.2.3 

func (m *BundleVersionMap) XXX_DiscardUnknown()

func (*BundleVersionMap) XXX_Marshal added in v1.2.3 

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

func (*BundleVersionMap) XXX_Merge added in v1.2.3 

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

func (*BundleVersionMap) XXX_Size added in v1.2.3 

func (m *BundleVersionMap) XXX_Size() int

func (*BundleVersionMap) XXX_Unmarshal added in v1.2.3 

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

type DelegationKeeper 

type DelegationKeeper interface {
	GetDelegationAmount(ctx sdk.Context, staker string) uint64
	GetDelegationOfPool(ctx sdk.Context, poolId uint64) uint64
	GetTotalAndHighestDelegationOfPool(ctx sdk.Context, poolId uint64) (uint64, uint64)
	PayoutRewards(ctx sdk.Context, staker string, amount uint64, payerModuleName string) error
	SlashDelegators(ctx sdk.Context, poolId uint64, staker string, slashType delegationTypes.SlashType)
}

type DistrKeeper 

type DistrKeeper interface {
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

type EventBundleFinalized 

type EventBundleFinalized struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// internal id for the KYVE-bundle
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// total voting power which voted for valid
	Valid uint64 `protobuf:"varint,3,opt,name=valid,proto3" json:"valid,omitempty"`
	// total voting power which voted for invalid
	Invalid uint64 `protobuf:"varint,4,opt,name=invalid,proto3" json:"invalid,omitempty"`
	// total voting power which voted for abstain
	Abstain uint64 `protobuf:"varint,5,opt,name=abstain,proto3" json:"abstain,omitempty"`
	// total voting power of the pool
	Total uint64 `protobuf:"varint,6,opt,name=total,proto3" json:"total,omitempty"`
	// status of the finalized bundle
	Status BundleStatus `protobuf:"varint,7,opt,name=status,proto3,enum=kyve.bundles.v1beta1.BundleStatus" json:"status,omitempty"`
	// amount which funders provided to the total bundle reward (in ukyve)
	FundersPayout uint64 `protobuf:"varint,8,opt,name=funders_payout,json=fundersPayout,proto3" json:"funders_payout,omitempty"`
	// amount which the inflation pool provided to the total reward (in ukyve)
	InflationPayout uint64 `protobuf:"varint,9,opt,name=inflation_payout,json=inflationPayout,proto3" json:"inflation_payout,omitempty"`
	// rewards transferred to treasury (in ukyve)
	RewardTreasury uint64 `protobuf:"varint,10,opt,name=reward_treasury,json=rewardTreasury,proto3" json:"reward_treasury,omitempty"`
	// rewardUploader rewards directly transferred to uploader (in ukyve)
	RewardUploader uint64 `protobuf:"varint,11,opt,name=reward_uploader,json=rewardUploader,proto3" json:"reward_uploader,omitempty"`
	// rewardDelegation rewards distributed among all delegators (in ukyve)
	RewardDelegation uint64 `protobuf:"varint,12,opt,name=reward_delegation,json=rewardDelegation,proto3" json:"reward_delegation,omitempty"`
	// rewardTotal the total bundle reward
	RewardTotal uint64 `protobuf:"varint,13,opt,name=reward_total,json=rewardTotal,proto3" json:"reward_total,omitempty"`
	// finalized_at the block height where the bundle got finalized
	FinalizedAt uint64 `protobuf:"varint,14,opt,name=finalized_at,json=finalizedAt,proto3" json:"finalized_at,omitempty"`
	// uploader the address of the uploader of this bundle
	Uploader string `protobuf:"bytes,15,opt,name=uploader,proto3" json:"uploader,omitempty"`
	// next_uploader the address of the next uploader after this bundle
	NextUploader string `protobuf:"bytes,16,opt,name=next_uploader,json=nextUploader,proto3" json:"next_uploader,omitempty"`
}

EventBundleFinalized is an event emitted when a bundle is finalised. emitted_by: MsgSubmitBundleProposal, EndBlock

func (*EventBundleFinalized) Descriptor 

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

func (*EventBundleFinalized) GetAbstain 

func (m *EventBundleFinalized) GetAbstain() uint64

func (*EventBundleFinalized) GetFinalizedAt 

func (m *EventBundleFinalized) GetFinalizedAt() uint64

func (*EventBundleFinalized) GetFundersPayout added in v1.3.0 

func (m *EventBundleFinalized) GetFundersPayout() uint64

func (*EventBundleFinalized) GetId 

func (m *EventBundleFinalized) GetId() uint64

func (*EventBundleFinalized) GetInflationPayout added in v1.3.0 

func (m *EventBundleFinalized) GetInflationPayout() uint64

func (*EventBundleFinalized) GetInvalid 

func (m *EventBundleFinalized) GetInvalid() uint64

func (*EventBundleFinalized) GetNextUploader 

func (m *EventBundleFinalized) GetNextUploader() string

func (*EventBundleFinalized) GetPoolId 

func (m *EventBundleFinalized) GetPoolId() uint64

func (*EventBundleFinalized) GetRewardDelegation 

func (m *EventBundleFinalized) GetRewardDelegation() uint64

func (*EventBundleFinalized) GetRewardTotal 

func (m *EventBundleFinalized) GetRewardTotal() uint64

func (*EventBundleFinalized) GetRewardTreasury 

func (m *EventBundleFinalized) GetRewardTreasury() uint64

func (*EventBundleFinalized) GetRewardUploader 

func (m *EventBundleFinalized) GetRewardUploader() uint64

func (*EventBundleFinalized) GetStatus 

func (m *EventBundleFinalized) GetStatus() BundleStatus

func (*EventBundleFinalized) GetTotal 

func (m *EventBundleFinalized) GetTotal() uint64

func (*EventBundleFinalized) GetUploader 

func (m *EventBundleFinalized) GetUploader() string

func (*EventBundleFinalized) GetValid 

func (m *EventBundleFinalized) GetValid() uint64

func (*EventBundleFinalized) Marshal 

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

func (*EventBundleFinalized) MarshalTo 

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

func (*EventBundleFinalized) MarshalToSizedBuffer 

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

func (*EventBundleFinalized) ProtoMessage 

func (*EventBundleFinalized) ProtoMessage()

func (*EventBundleFinalized) Reset 

func (m *EventBundleFinalized) Reset()

func (*EventBundleFinalized) Size 

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

func (*EventBundleFinalized) String 

func (m *EventBundleFinalized) String() string

func (*EventBundleFinalized) Unmarshal 

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

func (*EventBundleFinalized) XXX_DiscardUnknown 

func (m *EventBundleFinalized) XXX_DiscardUnknown()

func (*EventBundleFinalized) XXX_Marshal 

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

func (*EventBundleFinalized) XXX_Merge 

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

func (*EventBundleFinalized) XXX_Size 

func (m *EventBundleFinalized) XXX_Size() int

func (*EventBundleFinalized) XXX_Unmarshal 

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

type EventBundleProposed 

type EventBundleProposed struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// internal id for the KYVE-bundle
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// storage_id is the ID to retrieve to data item from the configured storage provider
	// e.g. the ARWEAVE-id
	StorageId string `protobuf:"bytes,3,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// Address of the uploader/proposer of the bundle
	Uploader string `protobuf:"bytes,4,opt,name=uploader,proto3" json:"uploader,omitempty"`
	// data_size size in bytes of the data
	DataSize uint64 `protobuf:"varint,5,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	// from_index starting index of the bundle (inclusive)
	FromIndex uint64 `protobuf:"varint,6,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
	// bundle_size amount of data items in the bundle
	BundleSize uint64 `protobuf:"varint,7,opt,name=bundle_size,json=bundleSize,proto3" json:"bundle_size,omitempty"`
	// from_key the key of the first data item in the bundle
	FromKey string `protobuf:"bytes,8,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	// to_key the key of the last data item in the bundle
	ToKey string `protobuf:"bytes,9,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	// bundle_summary is a short string holding some useful information of
	// the bundle which will get stored on-chain
	BundleSummary string `protobuf:"bytes,10,opt,name=bundle_summary,json=bundleSummary,proto3" json:"bundle_summary,omitempty"`
	// data_hash is a sha256 hash of the raw compressed data
	DataHash string `protobuf:"bytes,11,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	// proposed_at the unix time when the bundle was proposed
	ProposedAt uint64 `protobuf:"varint,12,opt,name=proposed_at,json=proposedAt,proto3" json:"proposed_at,omitempty"`
	// storage_provider_id the unique id of the storage provider where
	// the data of the bundle is tored
	StorageProviderId uint32 `protobuf:"varint,13,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id  the unique id of the compression type the data
	// of the bundle was compressed with
	CompressionId uint32 `protobuf:"varint,14,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
}

EventBundleProposed is submitted by the MsgSubmitBundleProposal message emitted_by: MsgSubmitBundleProposal

func (*EventBundleProposed) Descriptor 

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

func (*EventBundleProposed) GetBundleSize 

func (m *EventBundleProposed) GetBundleSize() uint64

func (*EventBundleProposed) GetBundleSummary 

func (m *EventBundleProposed) GetBundleSummary() string

func (*EventBundleProposed) GetCompressionId 

func (m *EventBundleProposed) GetCompressionId() uint32

func (*EventBundleProposed) GetDataHash 

func (m *EventBundleProposed) GetDataHash() string

func (*EventBundleProposed) GetDataSize 

func (m *EventBundleProposed) GetDataSize() uint64

func (*EventBundleProposed) GetFromIndex 

func (m *EventBundleProposed) GetFromIndex() uint64

func (*EventBundleProposed) GetFromKey 

func (m *EventBundleProposed) GetFromKey() string

func (*EventBundleProposed) GetId 

func (m *EventBundleProposed) GetId() uint64

func (*EventBundleProposed) GetPoolId 

func (m *EventBundleProposed) GetPoolId() uint64

func (*EventBundleProposed) GetProposedAt 

func (m *EventBundleProposed) GetProposedAt() uint64

func (*EventBundleProposed) GetStorageId 

func (m *EventBundleProposed) GetStorageId() string

func (*EventBundleProposed) GetStorageProviderId 

func (m *EventBundleProposed) GetStorageProviderId() uint32

func (*EventBundleProposed) GetToKey 

func (m *EventBundleProposed) GetToKey() string

func (*EventBundleProposed) GetUploader 

func (m *EventBundleProposed) GetUploader() string

func (*EventBundleProposed) Marshal 

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

func (*EventBundleProposed) MarshalTo 

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

func (*EventBundleProposed) MarshalToSizedBuffer 

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

func (*EventBundleProposed) ProtoMessage 

func (*EventBundleProposed) ProtoMessage()

func (*EventBundleProposed) Reset 

func (m *EventBundleProposed) Reset()

func (*EventBundleProposed) Size 

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

func (*EventBundleProposed) String 

func (m *EventBundleProposed) String() string

func (*EventBundleProposed) Unmarshal 

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

func (*EventBundleProposed) XXX_DiscardUnknown 

func (m *EventBundleProposed) XXX_DiscardUnknown()

func (*EventBundleProposed) XXX_Marshal 

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

func (*EventBundleProposed) XXX_Merge 

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

func (*EventBundleProposed) XXX_Size 

func (m *EventBundleProposed) XXX_Size() int

func (*EventBundleProposed) XXX_Unmarshal 

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

type EventBundleVote 

type EventBundleVote struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// staker is the account staker of the protocol node.
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// storage_id is the unique ID of the bundle.
	StorageId string `protobuf:"bytes,3,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// vote is for what the validator voted with
	Vote VoteType `protobuf:"varint,4,opt,name=vote,proto3,enum=kyve.bundles.v1beta1.VoteType" json:"vote,omitempty"`
}

EventBundleVote is an event emitted when a protocol node votes on a bundle. emitted_by: MsgVoteBundleProposal

func (*EventBundleVote) Descriptor 

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

func (*EventBundleVote) GetPoolId 

func (m *EventBundleVote) GetPoolId() uint64

func (*EventBundleVote) GetStaker 

func (m *EventBundleVote) GetStaker() string

func (*EventBundleVote) GetStorageId 

func (m *EventBundleVote) GetStorageId() string

func (*EventBundleVote) GetVote 

func (m *EventBundleVote) GetVote() VoteType

func (*EventBundleVote) Marshal 

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

func (*EventBundleVote) MarshalTo 

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

func (*EventBundleVote) MarshalToSizedBuffer 

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

func (*EventBundleVote) ProtoMessage 

func (*EventBundleVote) ProtoMessage()

func (*EventBundleVote) Reset 

func (m *EventBundleVote) Reset()

func (*EventBundleVote) Size 

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

func (*EventBundleVote) String 

func (m *EventBundleVote) String() string

func (*EventBundleVote) Unmarshal 

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

func (*EventBundleVote) XXX_DiscardUnknown 

func (m *EventBundleVote) XXX_DiscardUnknown()

func (*EventBundleVote) XXX_Marshal 

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

func (*EventBundleVote) XXX_Merge 

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

func (*EventBundleVote) XXX_Size 

func (m *EventBundleVote) XXX_Size() int

func (*EventBundleVote) XXX_Unmarshal 

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

type EventClaimedUploaderRole 

type EventClaimedUploaderRole struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id internal id for the KYVE-bundle
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// new_uploader the address of the participant who claimed
	// the free uploader role
	NewUploader string `protobuf:"bytes,3,opt,name=new_uploader,json=newUploader,proto3" json:"new_uploader,omitempty"`
}

EventClaimedUploaderRole is an event emitted when an uploader claims the uploader role emitted_by: MsgClaimUploaderRole

func (*EventClaimedUploaderRole) Descriptor 

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

func (*EventClaimedUploaderRole) GetId 

func (m *EventClaimedUploaderRole) GetId() uint64

func (*EventClaimedUploaderRole) GetNewUploader 

func (m *EventClaimedUploaderRole) GetNewUploader() string

func (*EventClaimedUploaderRole) GetPoolId 

func (m *EventClaimedUploaderRole) GetPoolId() uint64

func (*EventClaimedUploaderRole) Marshal 

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

func (*EventClaimedUploaderRole) MarshalTo 

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

func (*EventClaimedUploaderRole) MarshalToSizedBuffer 

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

func (*EventClaimedUploaderRole) ProtoMessage 

func (*EventClaimedUploaderRole) ProtoMessage()

func (*EventClaimedUploaderRole) Reset 

func (m *EventClaimedUploaderRole) Reset()

func (*EventClaimedUploaderRole) Size 

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

func (*EventClaimedUploaderRole) String 

func (m *EventClaimedUploaderRole) String() string

func (*EventClaimedUploaderRole) Unmarshal 

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

func (*EventClaimedUploaderRole) XXX_DiscardUnknown 

func (m *EventClaimedUploaderRole) XXX_DiscardUnknown()

func (*EventClaimedUploaderRole) XXX_Marshal 

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

func (*EventClaimedUploaderRole) XXX_Merge 

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

func (*EventClaimedUploaderRole) XXX_Size 

func (m *EventClaimedUploaderRole) XXX_Size() int

func (*EventClaimedUploaderRole) XXX_Unmarshal 

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

type EventPointIncreased 

type EventPointIncreased struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// staker is the address of the staker who received the point
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// current_points is the amount of points the staker has now
	CurrentPoints uint64 `protobuf:"varint,3,opt,name=current_points,json=currentPoints,proto3" json:"current_points,omitempty"`
}

EventPointIncreased is an event emitted when a staker receives a point emitted_by: MsgSubmitBundleProposal, EndBlock

func (*EventPointIncreased) Descriptor 

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

func (*EventPointIncreased) GetCurrentPoints 

func (m *EventPointIncreased) GetCurrentPoints() uint64

func (*EventPointIncreased) GetPoolId 

func (m *EventPointIncreased) GetPoolId() uint64

func (*EventPointIncreased) GetStaker 

func (m *EventPointIncreased) GetStaker() string

func (*EventPointIncreased) Marshal 

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

func (*EventPointIncreased) MarshalTo 

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

func (*EventPointIncreased) MarshalToSizedBuffer 

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

func (*EventPointIncreased) ProtoMessage 

func (*EventPointIncreased) ProtoMessage()

func (*EventPointIncreased) Reset 

func (m *EventPointIncreased) Reset()

func (*EventPointIncreased) Size 

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

func (*EventPointIncreased) String 

func (m *EventPointIncreased) String() string

func (*EventPointIncreased) Unmarshal 

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

func (*EventPointIncreased) XXX_DiscardUnknown 

func (m *EventPointIncreased) XXX_DiscardUnknown()

func (*EventPointIncreased) XXX_Marshal 

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

func (*EventPointIncreased) XXX_Merge 

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

func (*EventPointIncreased) XXX_Size 

func (m *EventPointIncreased) XXX_Size() int

func (*EventPointIncreased) XXX_Unmarshal 

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

type EventPointsReset 

type EventPointsReset struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// staker is the address of the staker who has zero points now
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
}

EventPointIncreased is an event emitted when a staker receives a point emitted_by: MsgSubmitBundleProposal, EndBlock

func (*EventPointsReset) Descriptor 

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

func (*EventPointsReset) GetPoolId 

func (m *EventPointsReset) GetPoolId() uint64

func (*EventPointsReset) GetStaker 

func (m *EventPointsReset) GetStaker() string

func (*EventPointsReset) Marshal 

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

func (*EventPointsReset) MarshalTo 

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

func (*EventPointsReset) MarshalToSizedBuffer 

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

func (*EventPointsReset) ProtoMessage 

func (*EventPointsReset) ProtoMessage()

func (*EventPointsReset) Reset 

func (m *EventPointsReset) Reset()

func (*EventPointsReset) Size 

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

func (*EventPointsReset) String 

func (m *EventPointsReset) String() string

func (*EventPointsReset) Unmarshal 

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

func (*EventPointsReset) XXX_DiscardUnknown 

func (m *EventPointsReset) XXX_DiscardUnknown()

func (*EventPointsReset) XXX_Marshal 

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

func (*EventPointsReset) XXX_Merge 

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

func (*EventPointsReset) XXX_Size 

func (m *EventPointsReset) XXX_Size() int

func (*EventPointsReset) XXX_Unmarshal 

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

type EventSkippedUploaderRole 

type EventSkippedUploaderRole struct {
	// pool_id is the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id internal id for the KYVE-bundle
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// previous_uploader is the address of the staker who skipped his uploader role
	PreviousUploader string `protobuf:"bytes,3,opt,name=previous_uploader,json=previousUploader,proto3" json:"previous_uploader,omitempty"`
	// new_uploader is the address of the new uploader who got automatically selected
	NewUploader string `protobuf:"bytes,4,opt,name=new_uploader,json=newUploader,proto3" json:"new_uploader,omitempty"`
}

EventSkippedUploaderRole is an event emitted when an uploader skips the upload emitted_by: MsgSkipUploaderRole

func (*EventSkippedUploaderRole) Descriptor 

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

func (*EventSkippedUploaderRole) GetId 

func (m *EventSkippedUploaderRole) GetId() uint64

func (*EventSkippedUploaderRole) GetNewUploader 

func (m *EventSkippedUploaderRole) GetNewUploader() string

func (*EventSkippedUploaderRole) GetPoolId 

func (m *EventSkippedUploaderRole) GetPoolId() uint64

func (*EventSkippedUploaderRole) GetPreviousUploader 

func (m *EventSkippedUploaderRole) GetPreviousUploader() string

func (*EventSkippedUploaderRole) Marshal 

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

func (*EventSkippedUploaderRole) MarshalTo 

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

func (*EventSkippedUploaderRole) MarshalToSizedBuffer 

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

func (*EventSkippedUploaderRole) ProtoMessage 

func (*EventSkippedUploaderRole) ProtoMessage()

func (*EventSkippedUploaderRole) Reset 

func (m *EventSkippedUploaderRole) Reset()

func (*EventSkippedUploaderRole) Size 

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

func (*EventSkippedUploaderRole) String 

func (m *EventSkippedUploaderRole) String() string

func (*EventSkippedUploaderRole) Unmarshal 

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

func (*EventSkippedUploaderRole) XXX_DiscardUnknown 

func (m *EventSkippedUploaderRole) XXX_DiscardUnknown()

func (*EventSkippedUploaderRole) XXX_Marshal 

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

func (*EventSkippedUploaderRole) XXX_Merge 

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

func (*EventSkippedUploaderRole) XXX_Size 

func (m *EventSkippedUploaderRole) XXX_Size() int

func (*EventSkippedUploaderRole) XXX_Unmarshal 

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

type EventUpdateParams added in v1.1.0 

type EventUpdateParams struct {
	// old_params is the module's old parameters.
	OldParams Params `protobuf:"bytes,1,opt,name=old_params,json=oldParams,proto3" json:"old_params"`
	// new_params is the module's new parameters.
	NewParams Params `protobuf:"bytes,2,opt,name=new_params,json=newParams,proto3" json:"new_params"`
	// payload is the parameter updates that were performed.
	Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

EventUpdateParams is an event emitted when the module parameters are updated. emitted_by: MsgUpdateParams

func (*EventUpdateParams) Descriptor added in v1.1.0 

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

func (*EventUpdateParams) GetNewParams added in v1.1.0 

func (m *EventUpdateParams) GetNewParams() Params

func (*EventUpdateParams) GetOldParams added in v1.1.0 

func (m *EventUpdateParams) GetOldParams() Params

func (*EventUpdateParams) GetPayload added in v1.1.0 

func (m *EventUpdateParams) GetPayload() string

func (*EventUpdateParams) Marshal added in v1.1.0 

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

func (*EventUpdateParams) MarshalTo added in v1.1.0 

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

func (*EventUpdateParams) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventUpdateParams) ProtoMessage added in v1.1.0 

func (*EventUpdateParams) ProtoMessage()

func (*EventUpdateParams) Reset added in v1.1.0 

func (m *EventUpdateParams) Reset()

func (*EventUpdateParams) Size added in v1.1.0 

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

func (*EventUpdateParams) String added in v1.1.0 

func (m *EventUpdateParams) String() string

func (*EventUpdateParams) Unmarshal added in v1.1.0 

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

func (*EventUpdateParams) XXX_DiscardUnknown added in v1.1.0 

func (m *EventUpdateParams) XXX_DiscardUnknown()

func (*EventUpdateParams) XXX_Marshal added in v1.1.0 

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

func (*EventUpdateParams) XXX_Merge added in v1.1.0 

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

func (*EventUpdateParams) XXX_Size added in v1.1.0 

func (m *EventUpdateParams) XXX_Size() int

func (*EventUpdateParams) XXX_Unmarshal added in v1.1.0 

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

type FinalizedAt added in v1.1.0 

type FinalizedAt struct {
	// height ...
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// timestamp ...
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

FinalizedAt ...

func (*FinalizedAt) Descriptor added in v1.1.0 

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

func (*FinalizedAt) GetHeight added in v1.1.0 

func (m *FinalizedAt) GetHeight() uint64

func (*FinalizedAt) GetTimestamp added in v1.1.0 

func (m *FinalizedAt) GetTimestamp() uint64

func (*FinalizedAt) Marshal added in v1.1.0 

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

func (*FinalizedAt) MarshalTo added in v1.1.0 

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

func (*FinalizedAt) MarshalToSizedBuffer added in v1.1.0 

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

func (*FinalizedAt) ProtoMessage added in v1.1.0 

func (*FinalizedAt) ProtoMessage()

func (*FinalizedAt) Reset added in v1.1.0 

func (m *FinalizedAt) Reset()

func (*FinalizedAt) Size added in v1.1.0 

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

func (*FinalizedAt) String added in v1.1.0 

func (m *FinalizedAt) String() string

func (*FinalizedAt) Unmarshal added in v1.1.0 

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

func (*FinalizedAt) XXX_DiscardUnknown added in v1.1.0 

func (m *FinalizedAt) XXX_DiscardUnknown()

func (*FinalizedAt) XXX_Marshal added in v1.1.0 

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

func (*FinalizedAt) XXX_Merge added in v1.1.0 

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

func (*FinalizedAt) XXX_Size added in v1.1.0 

func (m *FinalizedAt) XXX_Size() int

func (*FinalizedAt) XXX_Unmarshal added in v1.1.0 

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

type FinalizedBundle 

type FinalizedBundle struct {
	// pool_id is the id of the pool for which this proposal is for
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id is a unique identifier for each finalized bundle in a pool
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// storage_id is the id with which the data can be retrieved from
	StorageId string `protobuf:"bytes,3,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// uploader is the address of the staker who submitted this bundle
	Uploader string `protobuf:"bytes,4,opt,name=uploader,proto3" json:"uploader,omitempty"`
	// from_index is the index from where the bundle starts (inclusive)
	FromIndex uint64 `protobuf:"varint,5,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
	// to_index is the index to which the bundle goes (exclusive)
	ToIndex uint64 `protobuf:"varint,6,opt,name=to_index,json=toIndex,proto3" json:"to_index,omitempty"`
	// to_key the key of the last data item in the bundle proposal
	ToKey string `protobuf:"bytes,7,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	// bundle_summary a string summary of the current proposal
	BundleSummary string `protobuf:"bytes,8,opt,name=bundle_summary,json=bundleSummary,proto3" json:"bundle_summary,omitempty"`
	// data_hash a sha256 hash of the raw compressed data
	DataHash string `protobuf:"bytes,9,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	// finalized_at contains details of the block that finalized this bundle.
	FinalizedAt *FinalizedAt `protobuf:"bytes,10,opt,name=finalized_at,json=finalizedAt,proto3" json:"finalized_at,omitempty"`
	// from_key the key of the first data item in the bundle proposal
	FromKey string `protobuf:"bytes,11,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	// storage_provider_id the id of the storage provider where the bundle is stored
	StorageProviderId uint32 `protobuf:"varint,12,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id the id of the compression type with which the data was compressed
	CompressionId uint32 `protobuf:"varint,13,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
	// stake_security
	StakeSecurity *StakeSecurity `protobuf:"bytes,14,opt,name=stake_security,json=stakeSecurity,proto3" json:"stake_security,omitempty"`
}

FinalizedBundle represents a bundle proposal where the majority agreed on its validity

func (*FinalizedBundle) Descriptor 

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

func (*FinalizedBundle) GetBundleSummary 

func (m *FinalizedBundle) GetBundleSummary() string

func (*FinalizedBundle) GetCompressionId 

func (m *FinalizedBundle) GetCompressionId() uint32

func (*FinalizedBundle) GetDataHash 

func (m *FinalizedBundle) GetDataHash() string

func (*FinalizedBundle) GetFinalizedAt 

func (m *FinalizedBundle) GetFinalizedAt() *FinalizedAt

func (*FinalizedBundle) GetFromIndex 

func (m *FinalizedBundle) GetFromIndex() uint64

func (*FinalizedBundle) GetFromKey 

func (m *FinalizedBundle) GetFromKey() string

func (*FinalizedBundle) GetId 

func (m *FinalizedBundle) GetId() uint64

func (*FinalizedBundle) GetPoolId 

func (m *FinalizedBundle) GetPoolId() uint64

func (*FinalizedBundle) GetStakeSecurity added in v1.3.0 

func (m *FinalizedBundle) GetStakeSecurity() *StakeSecurity

func (*FinalizedBundle) GetStorageId 

func (m *FinalizedBundle) GetStorageId() string

func (*FinalizedBundle) GetStorageProviderId 

func (m *FinalizedBundle) GetStorageProviderId() uint32

func (*FinalizedBundle) GetToIndex 

func (m *FinalizedBundle) GetToIndex() uint64

func (*FinalizedBundle) GetToKey 

func (m *FinalizedBundle) GetToKey() string

func (*FinalizedBundle) GetUploader 

func (m *FinalizedBundle) GetUploader() string

func (*FinalizedBundle) Marshal 

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

func (*FinalizedBundle) MarshalTo 

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

func (*FinalizedBundle) MarshalToSizedBuffer 

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

func (*FinalizedBundle) ProtoMessage 

func (*FinalizedBundle) ProtoMessage()

func (*FinalizedBundle) Reset 

func (m *FinalizedBundle) Reset()

func (*FinalizedBundle) Size 

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

func (*FinalizedBundle) String 

func (m *FinalizedBundle) String() string

func (*FinalizedBundle) Unmarshal 

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

func (*FinalizedBundle) XXX_DiscardUnknown 

func (m *FinalizedBundle) XXX_DiscardUnknown()

func (*FinalizedBundle) XXX_Marshal 

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

func (*FinalizedBundle) XXX_Merge 

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

func (*FinalizedBundle) XXX_Size 

func (m *FinalizedBundle) XXX_Size() int

func (*FinalizedBundle) XXX_Unmarshal 

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

type FundersKeeper added in v1.4.0 

type FundersKeeper interface {
	ChargeFundersOfPool(ctx sdk.Context, poolId uint64) (payout uint64, err error)
}

type GenesisState 

type GenesisState struct {
	// params defines all the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// bundle_proposal_list ...
	BundleProposalList []BundleProposal `protobuf:"bytes,2,rep,name=bundle_proposal_list,json=bundleProposalList,proto3" json:"bundle_proposal_list"`
	// finalized_bundle_list ...
	FinalizedBundleList []FinalizedBundle `protobuf:"bytes,3,rep,name=finalized_bundle_list,json=finalizedBundleList,proto3" json:"finalized_bundle_list"`
	// round_robin_progress_list ...
	RoundRobinProgressList []RoundRobinProgress `protobuf:"bytes,4,rep,name=round_robin_progress_list,json=roundRobinProgressList,proto3" json:"round_robin_progress_list"`
	// bundle_version_map ...
	BundleVersionMap BundleVersionMap `protobuf:"bytes,5,opt,name=bundle_version_map,json=bundleVersionMap,proto3" json:"bundle_version_map"`
}

GenesisState defines the bundles module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetBundleProposalList 

func (m *GenesisState) GetBundleProposalList() []BundleProposal

func (*GenesisState) GetBundleVersionMap added in v1.3.2 

func (m *GenesisState) GetBundleVersionMap() BundleVersionMap

func (*GenesisState) GetFinalizedBundleList 

func (m *GenesisState) GetFinalizedBundleList() []FinalizedBundle

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetRoundRobinProgressList added in v1.3.0 

func (m *GenesisState) GetRoundRobinProgressList() []RoundRobinProgress

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 MsgClaimUploaderRole 

type MsgClaimUploaderRole struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// id ...
	PoolId uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

MsgClaimUploaderRole defines a SDK message for claiming the uploader role.

func NewMsgClaimUploaderRole 

func NewMsgClaimUploaderRole(creator string, staker string, poolId uint64) *MsgClaimUploaderRole

func (*MsgClaimUploaderRole) Descriptor 

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

func (*MsgClaimUploaderRole) GetCreator 

func (m *MsgClaimUploaderRole) GetCreator() string

func (*MsgClaimUploaderRole) GetPoolId 

func (m *MsgClaimUploaderRole) GetPoolId() uint64

func (*MsgClaimUploaderRole) GetSignBytes 

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

func (*MsgClaimUploaderRole) GetSigners 

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

func (*MsgClaimUploaderRole) GetStaker 

func (m *MsgClaimUploaderRole) GetStaker() string

func (*MsgClaimUploaderRole) Marshal 

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

func (*MsgClaimUploaderRole) MarshalTo 

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

func (*MsgClaimUploaderRole) MarshalToSizedBuffer 

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

func (*MsgClaimUploaderRole) ProtoMessage 

func (*MsgClaimUploaderRole) ProtoMessage()

func (*MsgClaimUploaderRole) Reset 

func (m *MsgClaimUploaderRole) Reset()

func (*MsgClaimUploaderRole) Route 

func (msg *MsgClaimUploaderRole) Route() string

func (*MsgClaimUploaderRole) Size 

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

func (*MsgClaimUploaderRole) String 

func (m *MsgClaimUploaderRole) String() string

func (*MsgClaimUploaderRole) Type 

func (msg *MsgClaimUploaderRole) Type() string

func (*MsgClaimUploaderRole) Unmarshal 

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

func (*MsgClaimUploaderRole) ValidateBasic 

func (msg *MsgClaimUploaderRole) ValidateBasic() error

func (*MsgClaimUploaderRole) XXX_DiscardUnknown 

func (m *MsgClaimUploaderRole) XXX_DiscardUnknown()

func (*MsgClaimUploaderRole) XXX_Marshal 

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

func (*MsgClaimUploaderRole) XXX_Merge 

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

func (*MsgClaimUploaderRole) XXX_Size 

func (m *MsgClaimUploaderRole) XXX_Size() int

func (*MsgClaimUploaderRole) XXX_Unmarshal 

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

type MsgClaimUploaderRoleResponse 

type MsgClaimUploaderRoleResponse struct {
}

MsgClaimUploaderRoleResponse defines the Msg/ClaimUploaderRole response type.

func (*MsgClaimUploaderRoleResponse) Descriptor 

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

func (*MsgClaimUploaderRoleResponse) Marshal 

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

func (*MsgClaimUploaderRoleResponse) MarshalTo 

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

func (*MsgClaimUploaderRoleResponse) MarshalToSizedBuffer 

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

func (*MsgClaimUploaderRoleResponse) ProtoMessage 

func (*MsgClaimUploaderRoleResponse) ProtoMessage()

func (*MsgClaimUploaderRoleResponse) Reset 

func (m *MsgClaimUploaderRoleResponse) Reset()

func (*MsgClaimUploaderRoleResponse) Size 

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

func (*MsgClaimUploaderRoleResponse) String 

func (m *MsgClaimUploaderRoleResponse) String() string

func (*MsgClaimUploaderRoleResponse) Unmarshal 

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

func (*MsgClaimUploaderRoleResponse) XXX_DiscardUnknown 

func (m *MsgClaimUploaderRoleResponse) XXX_DiscardUnknown()

func (*MsgClaimUploaderRoleResponse) XXX_Marshal 

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

func (*MsgClaimUploaderRoleResponse) XXX_Merge 

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

func (*MsgClaimUploaderRoleResponse) XXX_Size 

func (m *MsgClaimUploaderRoleResponse) XXX_Size() int

func (*MsgClaimUploaderRoleResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// SubmitBundleProposal ...
	SubmitBundleProposal(ctx context.Context, in *MsgSubmitBundleProposal, opts ...grpc.CallOption) (*MsgSubmitBundleProposalResponse, error)
	// VoteBundleProposal ...
	VoteBundleProposal(ctx context.Context, in *MsgVoteBundleProposal, opts ...grpc.CallOption) (*MsgVoteBundleProposalResponse, error)
	// ClaimUploaderRole ...
	ClaimUploaderRole(ctx context.Context, in *MsgClaimUploaderRole, opts ...grpc.CallOption) (*MsgClaimUploaderRoleResponse, error)
	// SkipUploaderRole ...
	SkipUploaderRole(ctx context.Context, in *MsgSkipUploaderRole, opts ...grpc.CallOption) (*MsgSkipUploaderRoleResponse, error)
	// UpdateParams defines a governance operation for updating the x/bundles module
	// parameters. The authority is hard-coded to the x/gov module account.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 MsgServer 

type MsgServer interface {
	// SubmitBundleProposal ...
	SubmitBundleProposal(context.Context, *MsgSubmitBundleProposal) (*MsgSubmitBundleProposalResponse, error)
	// VoteBundleProposal ...
	VoteBundleProposal(context.Context, *MsgVoteBundleProposal) (*MsgVoteBundleProposalResponse, error)
	// ClaimUploaderRole ...
	ClaimUploaderRole(context.Context, *MsgClaimUploaderRole) (*MsgClaimUploaderRoleResponse, error)
	// SkipUploaderRole ...
	SkipUploaderRole(context.Context, *MsgSkipUploaderRole) (*MsgSkipUploaderRoleResponse, error)
	// UpdateParams defines a governance operation for updating the x/bundles module
	// parameters. The authority is hard-coded to the x/gov module account.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSkipUploaderRole 

type MsgSkipUploaderRole struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// pool_id ...
	PoolId uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// from_index ...
	FromIndex uint64 `protobuf:"varint,4,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
}

MsgSubmitBundleProposal defines a SDK message for submitting a bundle proposal.

func NewMsgSkipUploaderRole 

func NewMsgSkipUploaderRole(creator string, staker string, poolId uint64, fromIndex uint64) *MsgSkipUploaderRole

func (*MsgSkipUploaderRole) Descriptor 

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

func (*MsgSkipUploaderRole) GetCreator 

func (m *MsgSkipUploaderRole) GetCreator() string

func (*MsgSkipUploaderRole) GetFromIndex 

func (m *MsgSkipUploaderRole) GetFromIndex() uint64

func (*MsgSkipUploaderRole) GetPoolId 

func (m *MsgSkipUploaderRole) GetPoolId() uint64

func (*MsgSkipUploaderRole) GetSignBytes 

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

func (*MsgSkipUploaderRole) GetSigners 

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

func (*MsgSkipUploaderRole) GetStaker 

func (m *MsgSkipUploaderRole) GetStaker() string

func (*MsgSkipUploaderRole) Marshal 

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

func (*MsgSkipUploaderRole) MarshalTo 

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

func (*MsgSkipUploaderRole) MarshalToSizedBuffer 

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

func (*MsgSkipUploaderRole) ProtoMessage 

func (*MsgSkipUploaderRole) ProtoMessage()

func (*MsgSkipUploaderRole) Reset 

func (m *MsgSkipUploaderRole) Reset()

func (*MsgSkipUploaderRole) Route 

func (msg *MsgSkipUploaderRole) Route() string

func (*MsgSkipUploaderRole) Size 

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

func (*MsgSkipUploaderRole) String 

func (m *MsgSkipUploaderRole) String() string

func (*MsgSkipUploaderRole) Type 

func (msg *MsgSkipUploaderRole) Type() string

func (*MsgSkipUploaderRole) Unmarshal 

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

func (*MsgSkipUploaderRole) ValidateBasic 

func (msg *MsgSkipUploaderRole) ValidateBasic() error

func (*MsgSkipUploaderRole) XXX_DiscardUnknown 

func (m *MsgSkipUploaderRole) XXX_DiscardUnknown()

func (*MsgSkipUploaderRole) XXX_Marshal 

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

func (*MsgSkipUploaderRole) XXX_Merge 

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

func (*MsgSkipUploaderRole) XXX_Size 

func (m *MsgSkipUploaderRole) XXX_Size() int

func (*MsgSkipUploaderRole) XXX_Unmarshal 

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

type MsgSkipUploaderRoleResponse 

type MsgSkipUploaderRoleResponse struct {
}

MsgSubmitBundleProposalResponse defines the Msg/SubmitBundleProposal response type.

func (*MsgSkipUploaderRoleResponse) Descriptor 

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

func (*MsgSkipUploaderRoleResponse) Marshal 

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

func (*MsgSkipUploaderRoleResponse) MarshalTo 

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

func (*MsgSkipUploaderRoleResponse) MarshalToSizedBuffer 

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

func (*MsgSkipUploaderRoleResponse) ProtoMessage 

func (*MsgSkipUploaderRoleResponse) ProtoMessage()

func (*MsgSkipUploaderRoleResponse) Reset 

func (m *MsgSkipUploaderRoleResponse) Reset()

func (*MsgSkipUploaderRoleResponse) Size 

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

func (*MsgSkipUploaderRoleResponse) String 

func (m *MsgSkipUploaderRoleResponse) String() string

func (*MsgSkipUploaderRoleResponse) Unmarshal 

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

func (*MsgSkipUploaderRoleResponse) XXX_DiscardUnknown 

func (m *MsgSkipUploaderRoleResponse) XXX_DiscardUnknown()

func (*MsgSkipUploaderRoleResponse) XXX_Marshal 

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

func (*MsgSkipUploaderRoleResponse) XXX_Merge 

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

func (*MsgSkipUploaderRoleResponse) XXX_Size 

func (m *MsgSkipUploaderRoleResponse) XXX_Size() int

func (*MsgSkipUploaderRoleResponse) XXX_Unmarshal 

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

type MsgSubmitBundleProposal 

type MsgSubmitBundleProposal struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// pool_id ...
	PoolId uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// storage_id ...
	StorageId string `protobuf:"bytes,4,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// data_size ...
	DataSize uint64 `protobuf:"varint,5,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	// data_hash ...
	DataHash string `protobuf:"bytes,6,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	// from_index ...
	FromIndex uint64 `protobuf:"varint,7,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
	// bundle_size ...
	BundleSize uint64 `protobuf:"varint,8,opt,name=bundle_size,json=bundleSize,proto3" json:"bundle_size,omitempty"`
	// from_key
	FromKey string `protobuf:"bytes,9,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	// to_key ...
	ToKey string `protobuf:"bytes,10,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	// bundle_summary ...
	BundleSummary string `protobuf:"bytes,11,opt,name=bundle_summary,json=bundleSummary,proto3" json:"bundle_summary,omitempty"`
}

MsgSubmitBundleProposal defines a SDK message for submitting a bundle proposal.

func NewMsgSubmitBundleProposal 

func NewMsgSubmitBundleProposal(creator string, staker string, poolId uint64, storageId string, dataSize uint64, dataHash string, fromIndex uint64, bundleSize uint64, fromKey string, toKey string, bundleSummary string) *MsgSubmitBundleProposal

func (*MsgSubmitBundleProposal) Descriptor 

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

func (*MsgSubmitBundleProposal) GetBundleSize 

func (m *MsgSubmitBundleProposal) GetBundleSize() uint64

func (*MsgSubmitBundleProposal) GetBundleSummary 

func (m *MsgSubmitBundleProposal) GetBundleSummary() string

func (*MsgSubmitBundleProposal) GetCreator 

func (m *MsgSubmitBundleProposal) GetCreator() string

func (*MsgSubmitBundleProposal) GetDataHash 

func (m *MsgSubmitBundleProposal) GetDataHash() string

func (*MsgSubmitBundleProposal) GetDataSize 

func (m *MsgSubmitBundleProposal) GetDataSize() uint64

func (*MsgSubmitBundleProposal) GetFromIndex 

func (m *MsgSubmitBundleProposal) GetFromIndex() uint64

func (*MsgSubmitBundleProposal) GetFromKey 

func (m *MsgSubmitBundleProposal) GetFromKey() string

func (*MsgSubmitBundleProposal) GetPoolId 

func (m *MsgSubmitBundleProposal) GetPoolId() uint64

func (*MsgSubmitBundleProposal) GetSignBytes 

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

func (*MsgSubmitBundleProposal) GetSigners 

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

func (*MsgSubmitBundleProposal) GetStaker 

func (m *MsgSubmitBundleProposal) GetStaker() string

func (*MsgSubmitBundleProposal) GetStorageId 

func (m *MsgSubmitBundleProposal) GetStorageId() string

func (*MsgSubmitBundleProposal) GetToKey 

func (m *MsgSubmitBundleProposal) GetToKey() string

func (*MsgSubmitBundleProposal) Marshal 

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

func (*MsgSubmitBundleProposal) MarshalTo 

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

func (*MsgSubmitBundleProposal) MarshalToSizedBuffer 

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

func (*MsgSubmitBundleProposal) ProtoMessage 

func (*MsgSubmitBundleProposal) ProtoMessage()

func (*MsgSubmitBundleProposal) Reset 

func (m *MsgSubmitBundleProposal) Reset()

func (*MsgSubmitBundleProposal) Route 

func (msg *MsgSubmitBundleProposal) Route() string

func (*MsgSubmitBundleProposal) Size 

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

func (*MsgSubmitBundleProposal) String 

func (m *MsgSubmitBundleProposal) String() string

func (*MsgSubmitBundleProposal) Type 

func (msg *MsgSubmitBundleProposal) Type() string

func (*MsgSubmitBundleProposal) Unmarshal 

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

func (*MsgSubmitBundleProposal) ValidateBasic 

func (msg *MsgSubmitBundleProposal) ValidateBasic() error

func (*MsgSubmitBundleProposal) XXX_DiscardUnknown 

func (m *MsgSubmitBundleProposal) XXX_DiscardUnknown()

func (*MsgSubmitBundleProposal) XXX_Marshal 

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

func (*MsgSubmitBundleProposal) XXX_Merge 

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

func (*MsgSubmitBundleProposal) XXX_Size 

func (m *MsgSubmitBundleProposal) XXX_Size() int

func (*MsgSubmitBundleProposal) XXX_Unmarshal 

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

type MsgSubmitBundleProposalResponse 

type MsgSubmitBundleProposalResponse struct {
}

MsgSubmitBundleProposalResponse defines the Msg/SubmitBundleProposal response type.

func (*MsgSubmitBundleProposalResponse) Descriptor 

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

func (*MsgSubmitBundleProposalResponse) Marshal 

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

func (*MsgSubmitBundleProposalResponse) MarshalTo 

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

func (*MsgSubmitBundleProposalResponse) MarshalToSizedBuffer 

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

func (*MsgSubmitBundleProposalResponse) ProtoMessage 

func (*MsgSubmitBundleProposalResponse) ProtoMessage()

func (*MsgSubmitBundleProposalResponse) Reset 

func (m *MsgSubmitBundleProposalResponse) Reset()

func (*MsgSubmitBundleProposalResponse) Size 

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

func (*MsgSubmitBundleProposalResponse) String 

func (m *MsgSubmitBundleProposalResponse) String() string

func (*MsgSubmitBundleProposalResponse) Unmarshal 

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

func (*MsgSubmitBundleProposalResponse) XXX_DiscardUnknown 

func (m *MsgSubmitBundleProposalResponse) XXX_DiscardUnknown()

func (*MsgSubmitBundleProposalResponse) XXX_Marshal 

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

func (*MsgSubmitBundleProposalResponse) XXX_Merge 

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

func (*MsgSubmitBundleProposalResponse) XXX_Size 

func (m *MsgSubmitBundleProposalResponse) XXX_Size() int

func (*MsgSubmitBundleProposalResponse) XXX_Unmarshal 

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

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// payload defines the x/bundles parameters to update.
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

MsgUpdateParams defines a SDK message for updating the module parameters.

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetPayload 

func (m *MsgUpdateParams) GetPayload() string

func (*MsgUpdateParams) GetSigners 

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

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the Msg/UpdateParams response type.

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MsgVoteBundleProposal 

type MsgVoteBundleProposal struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// id ...
	PoolId uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// storage_id ...
	StorageId string `protobuf:"bytes,4,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// vote ...
	Vote VoteType `protobuf:"varint,5,opt,name=vote,proto3,enum=kyve.bundles.v1beta1.VoteType" json:"vote,omitempty"`
}

MsgVoteBundleProposal defines a SDK message for voting on a bundle proposal.

func NewMsgVoteBundleProposal 

func NewMsgVoteBundleProposal(creator string, staker string, poolId uint64, storageId string, vote VoteType) *MsgVoteBundleProposal

func (*MsgVoteBundleProposal) Descriptor 

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

func (*MsgVoteBundleProposal) GetCreator 

func (m *MsgVoteBundleProposal) GetCreator() string

func (*MsgVoteBundleProposal) GetPoolId 

func (m *MsgVoteBundleProposal) GetPoolId() uint64

func (*MsgVoteBundleProposal) GetSignBytes 

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

func (*MsgVoteBundleProposal) GetSigners 

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

func (*MsgVoteBundleProposal) GetStaker 

func (m *MsgVoteBundleProposal) GetStaker() string

func (*MsgVoteBundleProposal) GetStorageId 

func (m *MsgVoteBundleProposal) GetStorageId() string

func (*MsgVoteBundleProposal) GetVote 

func (m *MsgVoteBundleProposal) GetVote() VoteType

func (*MsgVoteBundleProposal) Marshal 

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

func (*MsgVoteBundleProposal) MarshalTo 

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

func (*MsgVoteBundleProposal) MarshalToSizedBuffer 

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

func (*MsgVoteBundleProposal) ProtoMessage 

func (*MsgVoteBundleProposal) ProtoMessage()

func (*MsgVoteBundleProposal) Reset 

func (m *MsgVoteBundleProposal) Reset()

func (*MsgVoteBundleProposal) Route 

func (msg *MsgVoteBundleProposal) Route() string

func (*MsgVoteBundleProposal) Size 

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

func (*MsgVoteBundleProposal) String 

func (m *MsgVoteBundleProposal) String() string

func (*MsgVoteBundleProposal) Type 

func (msg *MsgVoteBundleProposal) Type() string

func (*MsgVoteBundleProposal) Unmarshal 

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

func (*MsgVoteBundleProposal) ValidateBasic 

func (msg *MsgVoteBundleProposal) ValidateBasic() error

func (*MsgVoteBundleProposal) XXX_DiscardUnknown 

func (m *MsgVoteBundleProposal) XXX_DiscardUnknown()

func (*MsgVoteBundleProposal) XXX_Marshal 

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

func (*MsgVoteBundleProposal) XXX_Merge 

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

func (*MsgVoteBundleProposal) XXX_Size 

func (m *MsgVoteBundleProposal) XXX_Size() int

func (*MsgVoteBundleProposal) XXX_Unmarshal 

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

type MsgVoteBundleProposalResponse 

type MsgVoteBundleProposalResponse struct {
}

MsgVoteBundleProposalResponse defines the Msg/VoteBundleProposal response type.

func (*MsgVoteBundleProposalResponse) Descriptor 

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

func (*MsgVoteBundleProposalResponse) Marshal 

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

func (*MsgVoteBundleProposalResponse) MarshalTo 

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

func (*MsgVoteBundleProposalResponse) MarshalToSizedBuffer 

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

func (*MsgVoteBundleProposalResponse) ProtoMessage 

func (*MsgVoteBundleProposalResponse) ProtoMessage()

func (*MsgVoteBundleProposalResponse) Reset 

func (m *MsgVoteBundleProposalResponse) Reset()

func (*MsgVoteBundleProposalResponse) Size 

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

func (*MsgVoteBundleProposalResponse) String 

func (m *MsgVoteBundleProposalResponse) String() string

func (*MsgVoteBundleProposalResponse) Unmarshal 

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

func (*MsgVoteBundleProposalResponse) XXX_DiscardUnknown 

func (m *MsgVoteBundleProposalResponse) XXX_DiscardUnknown()

func (*MsgVoteBundleProposalResponse) XXX_Marshal 

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

func (*MsgVoteBundleProposalResponse) XXX_Merge 

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

func (*MsgVoteBundleProposalResponse) XXX_Size 

func (m *MsgVoteBundleProposalResponse) XXX_Size() int

func (*MsgVoteBundleProposalResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// upload_timeout ...
	UploadTimeout uint64 `protobuf:"varint,1,opt,name=upload_timeout,json=uploadTimeout,proto3" json:"upload_timeout,omitempty"`
	// storage_cost ...
	StorageCost github_com_cosmos_cosmos_sdk_types.Dec `` /* 134-byte string literal not displayed */
	// network_fee ...
	NetworkFee github_com_cosmos_cosmos_sdk_types.Dec `` /* 131-byte string literal not displayed */
	// max_points ...
	MaxPoints uint64 `protobuf:"varint,4,opt,name=max_points,json=maxPoints,proto3" json:"max_points,omitempty"`
}

Params defines the bundles module parameters.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	uploadTimeout uint64,
	storageCost sdk.Dec,
	networkFee sdk.Dec,
	maxPoints uint64,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetMaxPoints 

func (m *Params) GetMaxPoints() uint64

func (*Params) GetUploadTimeout 

func (m *Params) GetUploadTimeout() uint64

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) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

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 PoolKeeper 

type PoolKeeper interface {
	AssertPoolExists(ctx sdk.Context, poolId uint64) error
	GetPoolWithError(ctx sdk.Context, poolId uint64) (pooltypes.Pool, error)
	GetPool(ctx sdk.Context, id uint64) (val pooltypes.Pool, found bool)

	IncrementBundleInformation(ctx sdk.Context, poolId uint64, currentHeight uint64, currentKey string, currentValue string)

	GetAllPools(ctx sdk.Context) (list []pooltypes.Pool)
	ChargeInflationPool(ctx sdk.Context, poolId uint64) (payout uint64, err error)
}

type QueryClient 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 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)
}

QueryServer is the server API for Query service.

type RoundRobinProgress added in v1.3.0 

type RoundRobinProgress struct {
	// pool_id ...
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// progress_list ...
	ProgressList []*RoundRobinSingleValidatorProgress `protobuf:"bytes,2,rep,name=progress_list,json=progressList,proto3" json:"progress_list,omitempty"`
}

RoundRobinProgress ...

func (*RoundRobinProgress) Descriptor added in v1.3.0 

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

func (*RoundRobinProgress) GetPoolId added in v1.3.0 

func (m *RoundRobinProgress) GetPoolId() uint64

func (*RoundRobinProgress) GetProgressList added in v1.3.0 

func (m *RoundRobinProgress) GetProgressList() []*RoundRobinSingleValidatorProgress

func (*RoundRobinProgress) Marshal added in v1.3.0 

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

func (*RoundRobinProgress) MarshalTo added in v1.3.0 

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

func (*RoundRobinProgress) MarshalToSizedBuffer added in v1.3.0 

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

func (*RoundRobinProgress) ProtoMessage added in v1.3.0 

func (*RoundRobinProgress) ProtoMessage()

func (*RoundRobinProgress) Reset added in v1.3.0 

func (m *RoundRobinProgress) Reset()

func (*RoundRobinProgress) Size added in v1.3.0 

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

func (*RoundRobinProgress) String added in v1.3.0 

func (m *RoundRobinProgress) String() string

func (*RoundRobinProgress) Unmarshal added in v1.3.0 

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

func (*RoundRobinProgress) XXX_DiscardUnknown added in v1.3.0 

func (m *RoundRobinProgress) XXX_DiscardUnknown()

func (*RoundRobinProgress) XXX_Marshal added in v1.3.0 

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

func (*RoundRobinProgress) XXX_Merge added in v1.3.0 

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

func (*RoundRobinProgress) XXX_Size added in v1.3.0 

func (m *RoundRobinProgress) XXX_Size() int

func (*RoundRobinProgress) XXX_Unmarshal added in v1.3.0 

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

type RoundRobinSingleValidatorProgress added in v1.3.0 

type RoundRobinSingleValidatorProgress struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// progress ...
	Progress int64 `protobuf:"varint,2,opt,name=progress,proto3" json:"progress,omitempty"`
}

RoundRobinSingleValidatorProgress ...

func (*RoundRobinSingleValidatorProgress) Descriptor added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) GetAddress added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) GetAddress() string

func (*RoundRobinSingleValidatorProgress) GetProgress added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) GetProgress() int64

func (*RoundRobinSingleValidatorProgress) Marshal added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) MarshalTo added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) MarshalToSizedBuffer added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) ProtoMessage added in v1.3.0 

func (*RoundRobinSingleValidatorProgress) ProtoMessage()

func (*RoundRobinSingleValidatorProgress) Reset added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) Reset()

func (*RoundRobinSingleValidatorProgress) Size added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) String added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) String() string

func (*RoundRobinSingleValidatorProgress) Unmarshal added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) XXX_DiscardUnknown added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) XXX_DiscardUnknown()

func (*RoundRobinSingleValidatorProgress) XXX_Marshal added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) XXX_Merge added in v1.3.0 

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

func (*RoundRobinSingleValidatorProgress) XXX_Size added in v1.3.0 

func (m *RoundRobinSingleValidatorProgress) XXX_Size() int

func (*RoundRobinSingleValidatorProgress) XXX_Unmarshal added in v1.3.0 

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

type StakeSecurity added in v1.2.3 

type StakeSecurity struct {
	// valid_vote_power is the total amount of stake of all pool stakers which voted valid for the given bundle.
	ValidVotePower uint64 `protobuf:"varint,1,opt,name=valid_vote_power,json=validVotePower,proto3" json:"valid_vote_power,omitempty"`
	// total_vote_power is the total amount of stake that was present during the finalization of the bundle
	TotalVotePower uint64 `protobuf:"varint,2,opt,name=total_vote_power,json=totalVotePower,proto3" json:"total_vote_power,omitempty"`
}

StakeSecurity stores information about total stake and valid votes with which the bundle got finalized.

func (*StakeSecurity) Descriptor added in v1.2.3 

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

func (*StakeSecurity) GetTotalVotePower added in v1.2.3 

func (m *StakeSecurity) GetTotalVotePower() uint64

func (*StakeSecurity) GetValidVotePower added in v1.2.3 

func (m *StakeSecurity) GetValidVotePower() uint64

func (*StakeSecurity) Marshal added in v1.2.3 

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

func (*StakeSecurity) MarshalTo added in v1.2.3 

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

func (*StakeSecurity) MarshalToSizedBuffer added in v1.2.3 

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

func (*StakeSecurity) ProtoMessage added in v1.2.3 

func (*StakeSecurity) ProtoMessage()

func (*StakeSecurity) Reset added in v1.2.3 

func (m *StakeSecurity) Reset()

func (*StakeSecurity) Size added in v1.2.3 

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

func (*StakeSecurity) String added in v1.2.3 

func (m *StakeSecurity) String() string

func (*StakeSecurity) Unmarshal added in v1.2.3 

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

func (*StakeSecurity) XXX_DiscardUnknown added in v1.2.3 

func (m *StakeSecurity) XXX_DiscardUnknown()

func (*StakeSecurity) XXX_Marshal added in v1.2.3 

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

func (*StakeSecurity) XXX_Merge added in v1.2.3 

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

func (*StakeSecurity) XXX_Size added in v1.2.3 

func (m *StakeSecurity) XXX_Size() int

func (*StakeSecurity) XXX_Unmarshal added in v1.2.3 

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

type StakerKeeper 

type StakerKeeper interface {
	GetAllStakerAddressesOfPool(ctx sdk.Context, poolId uint64) (stakers []string)
	GetCommission(ctx sdk.Context, stakerAddress string) sdk.Dec
	IncreaseStakerCommissionRewards(ctx sdk.Context, address string, amount uint64) error
	AssertValaccountAuthorized(ctx sdk.Context, poolId uint64, stakerAddress string, valaddress string) error

	DoesStakerExist(ctx sdk.Context, staker string) bool
	DoesValaccountExist(ctx sdk.Context, poolId uint64, stakerAddress string) bool

	LeavePool(ctx sdk.Context, staker string, poolId uint64)

	IncrementPoints(ctx sdk.Context, poolId uint64, stakerAddress string) (newPoints uint64)
	ResetPoints(ctx sdk.Context, poolId uint64, stakerAddress string) (previousPoints uint64)
}

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ClaimUploaderRole 

func (*UnimplementedMsgServer) ClaimUploaderRole(ctx context.Context, req *MsgClaimUploaderRole) (*MsgClaimUploaderRoleResponse, error)

func (*UnimplementedMsgServer) SkipUploaderRole 

func (*UnimplementedMsgServer) SkipUploaderRole(ctx context.Context, req *MsgSkipUploaderRole) (*MsgSkipUploaderRoleResponse, error)

func (*UnimplementedMsgServer) SubmitBundleProposal 

func (*UnimplementedMsgServer) SubmitBundleProposal(ctx context.Context, req *MsgSubmitBundleProposal) (*MsgSubmitBundleProposalResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

func (*UnimplementedMsgServer) VoteBundleProposal 

func (*UnimplementedMsgServer) VoteBundleProposal(ctx context.Context, req *MsgVoteBundleProposal) (*MsgVoteBundleProposalResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Params 

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

type UpgradeKeeper 

type UpgradeKeeper interface {
	ScheduleUpgrade(ctx sdk.Context, plan types.Plan) error
}

type VoteDistribution 

type VoteDistribution struct {
	// valid ...
	Valid uint64
	// invalid ...
	Invalid uint64
	// abstain ...
	Abstain uint64
	// total ...
	Total uint64
	// status ...
	Status BundleStatus
}

type VoteType 

type VoteType int32

VoteType ... 

const (
	// VOTE_TYPE_UNSPECIFIED ...
	VOTE_TYPE_UNSPECIFIED VoteType = 0
	// VOTE_TYPE_VALID ...
	VOTE_TYPE_VALID VoteType = 1
	// VOTE_TYPE_INVALID ...
	VOTE_TYPE_INVALID VoteType = 2
	// VOTE_TYPE_ABSTAIN ...
	VOTE_TYPE_ABSTAIN VoteType = 3
)

func (VoteType) EnumDescriptor 

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

func (VoteType) String 

func (x VoteType) String() string

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.