types

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2023 License: MIT Imports: 22 Imported by: 13

Documentation

Index

Constants

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

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

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_pool"
)
View Source 
const (
	MaxFunders = 50 // maximum amount of funders which are allowed
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source 
var (
	ErrFundsTooLow   = errors.Register(ModuleName, 1101, "minimum funding amount of %vkyve not reached")
	ErrDefundTooHigh = errors.Register(ModuleName, 1102, "maximum defunding amount of %vkyve surpassed")
	ErrInvalidJson   = errors.Register(ModuleName, 1103, "invalid json object: %v")
	ErrInvalidArgs   = errors.Register(ModuleName, 1104, "invalid args")
)

funding 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 (
	PoolKey      = []byte{1}
	PoolCountKey = []byte{2}
)
View Source 
var (
	ErrInvalidLengthPool        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPool          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPool = 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 ErrPoolNotFound = errors.Register(ModuleName, 1100, "pool with id %v does not exist")
View Source 
var PoolStatus_name = map[int32]string{
	0: "POOL_STATUS_UNSPECIFIED",
	1: "POOL_STATUS_ACTIVE",
	2: "POOL_STATUS_DISABLED",
	3: "POOL_STATUS_NO_FUNDS",
	4: "POOL_STATUS_NOT_ENOUGH_DELEGATION",
	5: "POOL_STATUS_UPGRADING",
}
View Source 
var PoolStatus_value = map[string]int32{
	"POOL_STATUS_UNSPECIFIED":           0,
	"POOL_STATUS_ACTIVE":                1,
	"POOL_STATUS_DISABLED":              2,
	"POOL_STATUS_NO_FUNDS":              3,
	"POOL_STATUS_NOT_ENOUGH_DELEGATION": 4,
	"POOL_STATUS_UPGRADING":             5,
}

Functions

func PoolKeyPrefix 

func PoolKeyPrefix(poolId uint64) []byte

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)

Types

type AccountKeeper 

type AccountKeeper interface{}

type EventCreatePool 

type EventCreatePool struct {
	// id is the unique ID of the pool.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is the human readable name of the pool
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// runtime is the runtime name of the pool
	Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// config is either a json stringified config or an
	// external link pointing to the config
	Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// start_key is the first key the pool should start
	// indexing
	StartKey string `protobuf:"bytes,6,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	// upload_interval is the interval the pool should validate
	// bundles with
	UploadInterval uint64 `protobuf:"varint,7,opt,name=upload_interval,json=uploadInterval,proto3" json:"upload_interval,omitempty"`
	// operating_cost is the fixed cost which gets paid out
	// to every successful uploader
	OperatingCost uint64 `protobuf:"varint,8,opt,name=operating_cost,json=operatingCost,proto3" json:"operating_cost,omitempty"`
	// min_delegation is the minimum amount of $KYVE the pool has
	// to have in order to produce bundles
	MinDelegation uint64 `protobuf:"varint,9,opt,name=min_delegation,json=minDelegation,proto3" json:"min_delegation,omitempty"`
	// max_bundle_size is the max size a data bundle can have
	// (amount of data items)
	MaxBundleSize uint64 `protobuf:"varint,10,opt,name=max_bundle_size,json=maxBundleSize,proto3" json:"max_bundle_size,omitempty"`
	// version is the current version of the protocol nodes
	Version string `protobuf:"bytes,11,opt,name=version,proto3" json:"version,omitempty"`
	// binaries points to the current binaries of the protocol node
	Binaries string `protobuf:"bytes,12,opt,name=binaries,proto3" json:"binaries,omitempty"`
	// storage_provider_id is the unique id of the storage provider
	// the pool is archiving the data on
	StorageProviderId uint32 `protobuf:"varint,13,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id is the unique id of the compression type the bundles
	// get compressed with
	CompressionId uint32 `protobuf:"varint,14,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
}

EventCreatePool ... emitted_by: EndBlock(gov)

func (*EventCreatePool) Descriptor 

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

func (*EventCreatePool) GetBinaries 

func (m *EventCreatePool) GetBinaries() string

func (*EventCreatePool) GetCompressionId 

func (m *EventCreatePool) GetCompressionId() uint32

func (*EventCreatePool) GetConfig 

func (m *EventCreatePool) GetConfig() string

func (*EventCreatePool) GetId 

func (m *EventCreatePool) GetId() uint64
func (m *EventCreatePool) GetLogo() string

func (*EventCreatePool) GetMaxBundleSize 

func (m *EventCreatePool) GetMaxBundleSize() uint64

func (*EventCreatePool) GetMinDelegation 

func (m *EventCreatePool) GetMinDelegation() uint64

func (*EventCreatePool) GetName 

func (m *EventCreatePool) GetName() string

func (*EventCreatePool) GetOperatingCost 

func (m *EventCreatePool) GetOperatingCost() uint64

func (*EventCreatePool) GetRuntime 

func (m *EventCreatePool) GetRuntime() string

func (*EventCreatePool) GetStartKey 

func (m *EventCreatePool) GetStartKey() string

func (*EventCreatePool) GetStorageProviderId 

func (m *EventCreatePool) GetStorageProviderId() uint32

func (*EventCreatePool) GetUploadInterval 

func (m *EventCreatePool) GetUploadInterval() uint64

func (*EventCreatePool) GetVersion 

func (m *EventCreatePool) GetVersion() string

func (*EventCreatePool) Marshal 

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

func (*EventCreatePool) MarshalTo 

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

func (*EventCreatePool) MarshalToSizedBuffer 

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

func (*EventCreatePool) ProtoMessage 

func (*EventCreatePool) ProtoMessage()

func (*EventCreatePool) Reset 

func (m *EventCreatePool) Reset()

func (*EventCreatePool) Size 

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

func (*EventCreatePool) String 

func (m *EventCreatePool) String() string

func (*EventCreatePool) Unmarshal 

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

func (*EventCreatePool) XXX_DiscardUnknown 

func (m *EventCreatePool) XXX_DiscardUnknown()

func (*EventCreatePool) XXX_Marshal 

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

func (*EventCreatePool) XXX_Merge 

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

func (*EventCreatePool) XXX_Size 

func (m *EventCreatePool) XXX_Size() int

func (*EventCreatePool) XXX_Unmarshal 

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

type EventDefundPool 

type EventDefundPool 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"`
	// address is the account address of the pool funder.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// amount is the amount in ukyve the funder has defunded
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

EventDefundPool is an event emitted when a pool is defunded. emitted_by: MsgDefundPool

func (*EventDefundPool) Descriptor 

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

func (*EventDefundPool) GetAddress 

func (m *EventDefundPool) GetAddress() string

func (*EventDefundPool) GetAmount 

func (m *EventDefundPool) GetAmount() uint64

func (*EventDefundPool) GetPoolId 

func (m *EventDefundPool) GetPoolId() uint64

func (*EventDefundPool) Marshal 

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

func (*EventDefundPool) MarshalTo 

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

func (*EventDefundPool) MarshalToSizedBuffer 

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

func (*EventDefundPool) ProtoMessage 

func (*EventDefundPool) ProtoMessage()

func (*EventDefundPool) Reset 

func (m *EventDefundPool) Reset()

func (*EventDefundPool) Size 

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

func (*EventDefundPool) String 

func (m *EventDefundPool) String() string

func (*EventDefundPool) Unmarshal 

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

func (*EventDefundPool) XXX_DiscardUnknown 

func (m *EventDefundPool) XXX_DiscardUnknown()

func (*EventDefundPool) XXX_Marshal 

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

func (*EventDefundPool) XXX_Merge 

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

func (*EventDefundPool) XXX_Size 

func (m *EventDefundPool) XXX_Size() int

func (*EventDefundPool) XXX_Unmarshal 

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

type EventFundPool 

type EventFundPool 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"`
	// address is the account address of the pool funder.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// amount is the amount in ukyve the funder has funded
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

EventFundPool is an event emitted when a pool is funded. emitted_by: MsgFundPool

func (*EventFundPool) Descriptor 

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

func (*EventFundPool) GetAddress 

func (m *EventFundPool) GetAddress() string

func (*EventFundPool) GetAmount 

func (m *EventFundPool) GetAmount() uint64

func (*EventFundPool) GetPoolId 

func (m *EventFundPool) GetPoolId() uint64

func (*EventFundPool) Marshal 

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

func (*EventFundPool) MarshalTo 

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

func (*EventFundPool) MarshalToSizedBuffer 

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

func (*EventFundPool) ProtoMessage 

func (*EventFundPool) ProtoMessage()

func (*EventFundPool) Reset 

func (m *EventFundPool) Reset()

func (*EventFundPool) Size 

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

func (*EventFundPool) String 

func (m *EventFundPool) String() string

func (*EventFundPool) Unmarshal 

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

func (*EventFundPool) XXX_DiscardUnknown 

func (m *EventFundPool) XXX_DiscardUnknown()

func (*EventFundPool) XXX_Marshal 

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

func (*EventFundPool) XXX_Merge 

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

func (*EventFundPool) XXX_Size 

func (m *EventFundPool) XXX_Size() int

func (*EventFundPool) XXX_Unmarshal 

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

type EventPoolDisabled added in v1.1.0 

type EventPoolDisabled struct {
	// id is the unique ID of the affected pool.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

EventPoolDisabled ... emitted_by: EndBlock(gov)

func (*EventPoolDisabled) Descriptor added in v1.1.0 

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

func (*EventPoolDisabled) GetId added in v1.1.0 

func (m *EventPoolDisabled) GetId() uint64

func (*EventPoolDisabled) Marshal added in v1.1.0 

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

func (*EventPoolDisabled) MarshalTo added in v1.1.0 

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

func (*EventPoolDisabled) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventPoolDisabled) ProtoMessage added in v1.1.0 

func (*EventPoolDisabled) ProtoMessage()

func (*EventPoolDisabled) Reset added in v1.1.0 

func (m *EventPoolDisabled) Reset()

func (*EventPoolDisabled) Size added in v1.1.0 

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

func (*EventPoolDisabled) String added in v1.1.0 

func (m *EventPoolDisabled) String() string

func (*EventPoolDisabled) Unmarshal added in v1.1.0 

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

func (*EventPoolDisabled) XXX_DiscardUnknown added in v1.1.0 

func (m *EventPoolDisabled) XXX_DiscardUnknown()

func (*EventPoolDisabled) XXX_Marshal added in v1.1.0 

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

func (*EventPoolDisabled) XXX_Merge added in v1.1.0 

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

func (*EventPoolDisabled) XXX_Size added in v1.1.0 

func (m *EventPoolDisabled) XXX_Size() int

func (*EventPoolDisabled) XXX_Unmarshal added in v1.1.0 

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

type EventPoolEnabled added in v1.1.0 

type EventPoolEnabled struct {
	// id is the unique ID of the affected pool.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

EventPoolEnabled ... emitted_by: EndBlock(gov)

func (*EventPoolEnabled) Descriptor added in v1.1.0 

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

func (*EventPoolEnabled) GetId added in v1.1.0 

func (m *EventPoolEnabled) GetId() uint64

func (*EventPoolEnabled) Marshal added in v1.1.0 

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

func (*EventPoolEnabled) MarshalTo added in v1.1.0 

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

func (*EventPoolEnabled) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventPoolEnabled) ProtoMessage added in v1.1.0 

func (*EventPoolEnabled) ProtoMessage()

func (*EventPoolEnabled) Reset added in v1.1.0 

func (m *EventPoolEnabled) Reset()

func (*EventPoolEnabled) Size added in v1.1.0 

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

func (*EventPoolEnabled) String added in v1.1.0 

func (m *EventPoolEnabled) String() string

func (*EventPoolEnabled) Unmarshal added in v1.1.0 

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

func (*EventPoolEnabled) XXX_DiscardUnknown added in v1.1.0 

func (m *EventPoolEnabled) XXX_DiscardUnknown()

func (*EventPoolEnabled) XXX_Marshal added in v1.1.0 

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

func (*EventPoolEnabled) XXX_Merge added in v1.1.0 

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

func (*EventPoolEnabled) XXX_Size added in v1.1.0 

func (m *EventPoolEnabled) XXX_Size() int

func (*EventPoolEnabled) XXX_Unmarshal added in v1.1.0 

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

type EventPoolFundsSlashed 

type EventPoolFundsSlashed 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"`
	// address is the account address of the pool funder.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// amount is the amount in ukyve the validator has lost due to the slash
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

EventDefundPool is an event emitted when a pool is defunded. emitted_by: MsgSubmitBundleProposal

func (*EventPoolFundsSlashed) Descriptor 

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

func (*EventPoolFundsSlashed) GetAddress 

func (m *EventPoolFundsSlashed) GetAddress() string

func (*EventPoolFundsSlashed) GetAmount 

func (m *EventPoolFundsSlashed) GetAmount() uint64

func (*EventPoolFundsSlashed) GetPoolId 

func (m *EventPoolFundsSlashed) GetPoolId() uint64

func (*EventPoolFundsSlashed) Marshal 

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

func (*EventPoolFundsSlashed) MarshalTo 

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

func (*EventPoolFundsSlashed) MarshalToSizedBuffer 

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

func (*EventPoolFundsSlashed) ProtoMessage 

func (*EventPoolFundsSlashed) ProtoMessage()

func (*EventPoolFundsSlashed) Reset 

func (m *EventPoolFundsSlashed) Reset()

func (*EventPoolFundsSlashed) Size 

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

func (*EventPoolFundsSlashed) String 

func (m *EventPoolFundsSlashed) String() string

func (*EventPoolFundsSlashed) Unmarshal 

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

func (*EventPoolFundsSlashed) XXX_DiscardUnknown 

func (m *EventPoolFundsSlashed) XXX_DiscardUnknown()

func (*EventPoolFundsSlashed) XXX_Marshal 

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

func (*EventPoolFundsSlashed) XXX_Merge 

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

func (*EventPoolFundsSlashed) XXX_Size 

func (m *EventPoolFundsSlashed) XXX_Size() int

func (*EventPoolFundsSlashed) XXX_Unmarshal 

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

type EventPoolOutOfFunds 

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

EventPoolOutOfFunds is an event emitted when a pool has run out of funds emitted_by: MsgSubmitBundleProposal

func (*EventPoolOutOfFunds) Descriptor 

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

func (*EventPoolOutOfFunds) GetPoolId 

func (m *EventPoolOutOfFunds) GetPoolId() uint64

func (*EventPoolOutOfFunds) Marshal 

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

func (*EventPoolOutOfFunds) MarshalTo 

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

func (*EventPoolOutOfFunds) MarshalToSizedBuffer 

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

func (*EventPoolOutOfFunds) ProtoMessage 

func (*EventPoolOutOfFunds) ProtoMessage()

func (*EventPoolOutOfFunds) Reset 

func (m *EventPoolOutOfFunds) Reset()

func (*EventPoolOutOfFunds) Size 

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

func (*EventPoolOutOfFunds) String 

func (m *EventPoolOutOfFunds) String() string

func (*EventPoolOutOfFunds) Unmarshal 

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

func (*EventPoolOutOfFunds) XXX_DiscardUnknown 

func (m *EventPoolOutOfFunds) XXX_DiscardUnknown()

func (*EventPoolOutOfFunds) XXX_Marshal 

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

func (*EventPoolOutOfFunds) XXX_Merge 

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

func (*EventPoolOutOfFunds) XXX_Size 

func (m *EventPoolOutOfFunds) XXX_Size() int

func (*EventPoolOutOfFunds) XXX_Unmarshal 

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

type EventPoolUpdated added in v1.1.0 

type EventPoolUpdated struct {
	// id is the unique ID of the pool.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// raw update string
	RawUpdateString string `protobuf:"bytes,2,opt,name=raw_update_string,json=rawUpdateString,proto3" json:"raw_update_string,omitempty"`
	// name is the human readable name of the pool
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// runtime is the runtime name of the pool
	Runtime string `protobuf:"bytes,4,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Logo string `protobuf:"bytes,5,opt,name=logo,proto3" json:"logo,omitempty"`
	// config is either a json stringified config or an
	// external link pointing to the config
	Config string `protobuf:"bytes,6,opt,name=config,proto3" json:"config,omitempty"`
	// upload_interval is the interval the pool should validate
	// bundles with
	UploadInterval uint64 `protobuf:"varint,7,opt,name=upload_interval,json=uploadInterval,proto3" json:"upload_interval,omitempty"`
	// operating_cost is the fixed cost which gets paid out
	// to every successful uploader
	OperatingCost uint64 `protobuf:"varint,8,opt,name=operating_cost,json=operatingCost,proto3" json:"operating_cost,omitempty"`
	// min_delegation is the minimum amount of $KYVE the pool has
	// to have in order to produce bundles
	MinDelegation uint64 `protobuf:"varint,9,opt,name=min_delegation,json=minDelegation,proto3" json:"min_delegation,omitempty"`
	// max_bundle_size is the max size a data bundle can have
	// (amount of data items)
	MaxBundleSize uint64 `protobuf:"varint,10,opt,name=max_bundle_size,json=maxBundleSize,proto3" json:"max_bundle_size,omitempty"`
	// storage_provider_id is the unique id of the storage provider
	// the pool is archiving the data on
	StorageProviderId uint32 `protobuf:"varint,11,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id is the unique id of the compression type the bundles
	// get compressed with
	CompressionId uint32 `protobuf:"varint,12,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
}

EventPoolUpdated ... emitted_by: EndBlock(gov)

func (*EventPoolUpdated) Descriptor added in v1.1.0 

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

func (*EventPoolUpdated) GetCompressionId added in v1.1.0 

func (m *EventPoolUpdated) GetCompressionId() uint32

func (*EventPoolUpdated) GetConfig added in v1.1.0 

func (m *EventPoolUpdated) GetConfig() string

func (*EventPoolUpdated) GetId added in v1.1.0 

func (m *EventPoolUpdated) GetId() uint64
func (m *EventPoolUpdated) GetLogo() string

func (*EventPoolUpdated) GetMaxBundleSize added in v1.1.0 

func (m *EventPoolUpdated) GetMaxBundleSize() uint64

func (*EventPoolUpdated) GetMinDelegation added in v1.1.0 

func (m *EventPoolUpdated) GetMinDelegation() uint64

func (*EventPoolUpdated) GetName added in v1.1.0 

func (m *EventPoolUpdated) GetName() string

func (*EventPoolUpdated) GetOperatingCost added in v1.1.0 

func (m *EventPoolUpdated) GetOperatingCost() uint64

func (*EventPoolUpdated) GetRawUpdateString added in v1.1.0 

func (m *EventPoolUpdated) GetRawUpdateString() string

func (*EventPoolUpdated) GetRuntime added in v1.1.0 

func (m *EventPoolUpdated) GetRuntime() string

func (*EventPoolUpdated) GetStorageProviderId added in v1.1.0 

func (m *EventPoolUpdated) GetStorageProviderId() uint32

func (*EventPoolUpdated) GetUploadInterval added in v1.1.0 

func (m *EventPoolUpdated) GetUploadInterval() uint64

func (*EventPoolUpdated) Marshal added in v1.1.0 

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

func (*EventPoolUpdated) MarshalTo added in v1.1.0 

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

func (*EventPoolUpdated) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventPoolUpdated) ProtoMessage added in v1.1.0 

func (*EventPoolUpdated) ProtoMessage()

func (*EventPoolUpdated) Reset added in v1.1.0 

func (m *EventPoolUpdated) Reset()

func (*EventPoolUpdated) Size added in v1.1.0 

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

func (*EventPoolUpdated) String added in v1.1.0 

func (m *EventPoolUpdated) String() string

func (*EventPoolUpdated) Unmarshal added in v1.1.0 

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

func (*EventPoolUpdated) XXX_DiscardUnknown added in v1.1.0 

func (m *EventPoolUpdated) XXX_DiscardUnknown()

func (*EventPoolUpdated) XXX_Marshal added in v1.1.0 

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

func (*EventPoolUpdated) XXX_Merge added in v1.1.0 

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

func (*EventPoolUpdated) XXX_Size added in v1.1.0 

func (m *EventPoolUpdated) XXX_Size() int

func (*EventPoolUpdated) XXX_Unmarshal added in v1.1.0 

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

type EventRuntimeUpgradeCancelled added in v1.1.0 

type EventRuntimeUpgradeCancelled struct {
	// runtime is the name of the runtime that will be upgraded.
	Runtime string `protobuf:"bytes,1,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// affected_pools contains all IDs of pools that are affected by the
	// cancellation of this runtime upgrade.
	AffectedPools []uint64 `protobuf:"varint,2,rep,packed,name=affected_pools,json=affectedPools,proto3" json:"affected_pools,omitempty"`
}

EventRuntimeUpgradeCancelled ... emitted_by: EndBlock(gov)

func (*EventRuntimeUpgradeCancelled) Descriptor added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) GetAffectedPools added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) GetAffectedPools() []uint64

func (*EventRuntimeUpgradeCancelled) GetRuntime added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) GetRuntime() string

func (*EventRuntimeUpgradeCancelled) Marshal added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) MarshalTo added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) ProtoMessage added in v1.1.0 

func (*EventRuntimeUpgradeCancelled) ProtoMessage()

func (*EventRuntimeUpgradeCancelled) Reset added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) Reset()

func (*EventRuntimeUpgradeCancelled) Size added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) String added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) String() string

func (*EventRuntimeUpgradeCancelled) Unmarshal added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) XXX_DiscardUnknown added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) XXX_DiscardUnknown()

func (*EventRuntimeUpgradeCancelled) XXX_Marshal added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) XXX_Merge added in v1.1.0 

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

func (*EventRuntimeUpgradeCancelled) XXX_Size added in v1.1.0 

func (m *EventRuntimeUpgradeCancelled) XXX_Size() int

func (*EventRuntimeUpgradeCancelled) XXX_Unmarshal added in v1.1.0 

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

type EventRuntimeUpgradeScheduled added in v1.1.0 

type EventRuntimeUpgradeScheduled struct {
	// runtime is the name of the runtime that will be upgraded.
	Runtime string `protobuf:"bytes,1,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// version is the new version that the runtime will be upgraded to.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// scheduled_at is the time in UNIX seconds when the upgrade will occur.
	ScheduledAt uint64 `protobuf:"varint,3,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// duration is the amount of seconds the pool will be paused after the
	// scheduled time is reached. This will give node operators time to upgrade
	// their node.
	Duration uint64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"`
	// binaries contain download links for prebuilt binaries (in JSON format).
	Binaries string `protobuf:"bytes,5,opt,name=binaries,proto3" json:"binaries,omitempty"`
	// affected_pools contains all IDs of pools that will be affected by this runtime upgrade.
	AffectedPools []uint64 `protobuf:"varint,6,rep,packed,name=affected_pools,json=affectedPools,proto3" json:"affected_pools,omitempty"`
}

EventRuntimeUpgradeScheduled ... emitted_by: EndBlock(gov)

func (*EventRuntimeUpgradeScheduled) Descriptor added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) GetAffectedPools added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetAffectedPools() []uint64

func (*EventRuntimeUpgradeScheduled) GetBinaries added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetBinaries() string

func (*EventRuntimeUpgradeScheduled) GetDuration added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetDuration() uint64

func (*EventRuntimeUpgradeScheduled) GetRuntime added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetRuntime() string

func (*EventRuntimeUpgradeScheduled) GetScheduledAt added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetScheduledAt() uint64

func (*EventRuntimeUpgradeScheduled) GetVersion added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) GetVersion() string

func (*EventRuntimeUpgradeScheduled) Marshal added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) MarshalTo added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) MarshalToSizedBuffer added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) ProtoMessage added in v1.1.0 

func (*EventRuntimeUpgradeScheduled) ProtoMessage()

func (*EventRuntimeUpgradeScheduled) Reset added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) Reset()

func (*EventRuntimeUpgradeScheduled) Size added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) String added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) String() string

func (*EventRuntimeUpgradeScheduled) Unmarshal added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) XXX_DiscardUnknown added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) XXX_DiscardUnknown()

func (*EventRuntimeUpgradeScheduled) XXX_Marshal added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) XXX_Merge added in v1.1.0 

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

func (*EventRuntimeUpgradeScheduled) XXX_Size added in v1.1.0 

func (m *EventRuntimeUpgradeScheduled) XXX_Size() int

func (*EventRuntimeUpgradeScheduled) XXX_Unmarshal added in v1.1.0 

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

type Funder 

type Funder struct {
	// address is the address of the funder
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// amount is the current amount of funds in ukyve the funder has
	// still funded the pool with
	Amount uint64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
}

Funder is the object which holds info about a single pool funder

func (*Funder) Descriptor 

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

func (*Funder) GetAddress 

func (m *Funder) GetAddress() string

func (*Funder) GetAmount 

func (m *Funder) GetAmount() uint64

func (*Funder) Marshal 

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

func (*Funder) MarshalTo 

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

func (*Funder) MarshalToSizedBuffer 

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

func (*Funder) ProtoMessage 

func (*Funder) ProtoMessage()

func (*Funder) Reset 

func (m *Funder) Reset()

func (*Funder) Size 

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

func (*Funder) String 

func (m *Funder) String() string

func (*Funder) Unmarshal 

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

func (*Funder) XXX_DiscardUnknown 

func (m *Funder) XXX_DiscardUnknown()

func (*Funder) XXX_Marshal 

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

func (*Funder) XXX_Merge 

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

func (*Funder) XXX_Size 

func (m *Funder) XXX_Size() int

func (*Funder) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// pool_list ...
	PoolList []Pool `protobuf:"bytes,2,rep,name=pool_list,json=poolList,proto3" json:"pool_list"`
	// pool_count ...
	PoolCount uint64 `protobuf:"varint,3,opt,name=pool_count,json=poolCount,proto3" json:"pool_count,omitempty"`
}

GenesisState defines the pool 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) GetPoolCount 

func (m *GenesisState) GetPoolCount() uint64

func (*GenesisState) GetPoolList 

func (m *GenesisState) GetPoolList() []Pool

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 MsgCancelRuntimeUpgrade 

type MsgCancelRuntimeUpgrade struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// runtime ...
	Runtime string `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
}

MsgCancelRuntimeUpgrade defines a SDK message for cancelling a runtime upgrade.

func (*MsgCancelRuntimeUpgrade) Descriptor 

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

func (*MsgCancelRuntimeUpgrade) GetAuthority 

func (m *MsgCancelRuntimeUpgrade) GetAuthority() string

func (*MsgCancelRuntimeUpgrade) GetRuntime 

func (m *MsgCancelRuntimeUpgrade) GetRuntime() string

func (*MsgCancelRuntimeUpgrade) GetSigners 

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

GetSigners returns the expected signers for a MsgCancelRuntimeUpgrade message.

func (*MsgCancelRuntimeUpgrade) Marshal 

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

func (*MsgCancelRuntimeUpgrade) MarshalTo 

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

func (*MsgCancelRuntimeUpgrade) MarshalToSizedBuffer 

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

func (*MsgCancelRuntimeUpgrade) ProtoMessage 

func (*MsgCancelRuntimeUpgrade) ProtoMessage()

func (*MsgCancelRuntimeUpgrade) Reset 

func (m *MsgCancelRuntimeUpgrade) Reset()

func (*MsgCancelRuntimeUpgrade) Size 

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

func (*MsgCancelRuntimeUpgrade) String 

func (m *MsgCancelRuntimeUpgrade) String() string

func (*MsgCancelRuntimeUpgrade) Unmarshal 

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

func (*MsgCancelRuntimeUpgrade) ValidateBasic 

func (msg *MsgCancelRuntimeUpgrade) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgCancelRuntimeUpgrade) XXX_DiscardUnknown 

func (m *MsgCancelRuntimeUpgrade) XXX_DiscardUnknown()

func (*MsgCancelRuntimeUpgrade) XXX_Marshal 

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

func (*MsgCancelRuntimeUpgrade) XXX_Merge 

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

func (*MsgCancelRuntimeUpgrade) XXX_Size 

func (m *MsgCancelRuntimeUpgrade) XXX_Size() int

func (*MsgCancelRuntimeUpgrade) XXX_Unmarshal 

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

type MsgCancelRuntimeUpgradeResponse 

type MsgCancelRuntimeUpgradeResponse struct {
}

MsgCancelRuntimeUpgradeResponse defines the Msg/CancelRuntimeUpgrade response type.

func (*MsgCancelRuntimeUpgradeResponse) Descriptor 

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

func (*MsgCancelRuntimeUpgradeResponse) Marshal 

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

func (*MsgCancelRuntimeUpgradeResponse) MarshalTo 

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

func (*MsgCancelRuntimeUpgradeResponse) MarshalToSizedBuffer 

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

func (*MsgCancelRuntimeUpgradeResponse) ProtoMessage 

func (*MsgCancelRuntimeUpgradeResponse) ProtoMessage()

func (*MsgCancelRuntimeUpgradeResponse) Reset 

func (m *MsgCancelRuntimeUpgradeResponse) Reset()

func (*MsgCancelRuntimeUpgradeResponse) Size 

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

func (*MsgCancelRuntimeUpgradeResponse) String 

func (m *MsgCancelRuntimeUpgradeResponse) String() string

func (*MsgCancelRuntimeUpgradeResponse) Unmarshal 

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

func (*MsgCancelRuntimeUpgradeResponse) XXX_DiscardUnknown 

func (m *MsgCancelRuntimeUpgradeResponse) XXX_DiscardUnknown()

func (*MsgCancelRuntimeUpgradeResponse) XXX_Marshal 

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

func (*MsgCancelRuntimeUpgradeResponse) XXX_Merge 

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

func (*MsgCancelRuntimeUpgradeResponse) XXX_Size 

func (m *MsgCancelRuntimeUpgradeResponse) XXX_Size() int

func (*MsgCancelRuntimeUpgradeResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// FundPool ...
	FundPool(ctx context.Context, in *MsgFundPool, opts ...grpc.CallOption) (*MsgFundPoolResponse, error)
	// DefundPool ...
	DefundPool(ctx context.Context, in *MsgDefundPool, opts ...grpc.CallOption) (*MsgDefundPoolResponse, error)
	// CreatePool defines a governance operation for creating a new pool.
	// The authority is hard-coded to the x/gov module account.
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	// UpdatePool defines a governance operation for updating an existing pool.
	// The authority is hard-coded to the x/gov module account.
	UpdatePool(ctx context.Context, in *MsgUpdatePool, opts ...grpc.CallOption) (*MsgUpdatePoolResponse, error)
	// DisablePool defines a governance operation for disabling an existing pool.
	// The authority is hard-coded to the x/gov module account.
	DisablePool(ctx context.Context, in *MsgDisablePool, opts ...grpc.CallOption) (*MsgDisablePoolResponse, error)
	// EnablePool defines a governance operation for enabling an existing pool.
	// The authority is hard-coded to the x/gov module account.
	EnablePool(ctx context.Context, in *MsgEnablePool, opts ...grpc.CallOption) (*MsgEnablePoolResponse, error)
	// ScheduleRuntimeUpgrade defines a governance operation for scheduling a runtime upgrade.
	// The authority is hard-coded to the x/gov module account.
	ScheduleRuntimeUpgrade(ctx context.Context, in *MsgScheduleRuntimeUpgrade, opts ...grpc.CallOption) (*MsgScheduleRuntimeUpgradeResponse, error)
	// CancelRuntimeUpgrade defines a governance operation for cancelling a runtime upgrade.
	// The authority is hard-coded to the x/gov module account.
	CancelRuntimeUpgrade(ctx context.Context, in *MsgCancelRuntimeUpgrade, opts ...grpc.CallOption) (*MsgCancelRuntimeUpgradeResponse, 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 MsgCreatePool 

type MsgCreatePool struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// name ...
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// runtime ...
	Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// config ...
	Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// start_key ...
	StartKey string `protobuf:"bytes,6,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	// upload_interval ...
	UploadInterval uint64 `protobuf:"varint,7,opt,name=upload_interval,json=uploadInterval,proto3" json:"upload_interval,omitempty"`
	// operating_cost ...
	OperatingCost uint64 `protobuf:"varint,8,opt,name=operating_cost,json=operatingCost,proto3" json:"operating_cost,omitempty"`
	// min_delegation ...
	MinDelegation uint64 `protobuf:"varint,9,opt,name=min_delegation,json=minDelegation,proto3" json:"min_delegation,omitempty"`
	// max_bundle_size ...
	MaxBundleSize uint64 `protobuf:"varint,10,opt,name=max_bundle_size,json=maxBundleSize,proto3" json:"max_bundle_size,omitempty"`
	// version ...
	Version string `protobuf:"bytes,11,opt,name=version,proto3" json:"version,omitempty"`
	// binaries ...
	Binaries string `protobuf:"bytes,12,opt,name=binaries,proto3" json:"binaries,omitempty"`
	// storage_provider_id ...
	StorageProviderId uint32 `protobuf:"varint,13,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id ...
	CompressionId uint32 `protobuf:"varint,14,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
}

MsgCreatePool defines a SDK message for creating a new pool.

func (*MsgCreatePool) Descriptor 

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

func (*MsgCreatePool) GetAuthority 

func (m *MsgCreatePool) GetAuthority() string

func (*MsgCreatePool) GetBinaries 

func (m *MsgCreatePool) GetBinaries() string

func (*MsgCreatePool) GetCompressionId 

func (m *MsgCreatePool) GetCompressionId() uint32

func (*MsgCreatePool) GetConfig 

func (m *MsgCreatePool) GetConfig() string
func (m *MsgCreatePool) GetLogo() string

func (*MsgCreatePool) GetMaxBundleSize 

func (m *MsgCreatePool) GetMaxBundleSize() uint64

func (*MsgCreatePool) GetMinDelegation 

func (m *MsgCreatePool) GetMinDelegation() uint64

func (*MsgCreatePool) GetName 

func (m *MsgCreatePool) GetName() string

func (*MsgCreatePool) GetOperatingCost 

func (m *MsgCreatePool) GetOperatingCost() uint64

func (*MsgCreatePool) GetRuntime 

func (m *MsgCreatePool) GetRuntime() string

func (*MsgCreatePool) GetSigners 

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

GetSigners returns the expected signers for a MsgCreatePool message.

func (*MsgCreatePool) GetStartKey 

func (m *MsgCreatePool) GetStartKey() string

func (*MsgCreatePool) GetStorageProviderId 

func (m *MsgCreatePool) GetStorageProviderId() uint32

func (*MsgCreatePool) GetUploadInterval 

func (m *MsgCreatePool) GetUploadInterval() uint64

func (*MsgCreatePool) GetVersion 

func (m *MsgCreatePool) GetVersion() string

func (*MsgCreatePool) Marshal 

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

func (*MsgCreatePool) MarshalTo 

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

func (*MsgCreatePool) MarshalToSizedBuffer 

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

func (*MsgCreatePool) ProtoMessage 

func (*MsgCreatePool) ProtoMessage()

func (*MsgCreatePool) Reset 

func (m *MsgCreatePool) Reset()

func (*MsgCreatePool) Size 

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

func (*MsgCreatePool) String 

func (m *MsgCreatePool) String() string

func (*MsgCreatePool) Unmarshal 

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

func (*MsgCreatePool) ValidateBasic 

func (msg *MsgCreatePool) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgCreatePool) XXX_DiscardUnknown 

func (m *MsgCreatePool) XXX_DiscardUnknown()

func (*MsgCreatePool) XXX_Marshal 

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

func (*MsgCreatePool) XXX_Merge 

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

func (*MsgCreatePool) XXX_Size 

func (m *MsgCreatePool) XXX_Size() int

func (*MsgCreatePool) XXX_Unmarshal 

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

type MsgCreatePoolResponse 

type MsgCreatePoolResponse struct {
}

MsgCreatePoolResponse defines the Msg/CreatePool response type.

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type MsgDefundPool 

type MsgDefundPool struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// amount ...
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

MsgDefundPool defines a SDK message for defunding a pool.

func NewMsgDefundPool 

func NewMsgDefundPool(creator string, id uint64, amount uint64) *MsgDefundPool

func (*MsgDefundPool) Descriptor 

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

func (*MsgDefundPool) GetAmount 

func (m *MsgDefundPool) GetAmount() uint64

func (*MsgDefundPool) GetCreator 

func (m *MsgDefundPool) GetCreator() string

func (*MsgDefundPool) GetId 

func (m *MsgDefundPool) GetId() uint64

func (*MsgDefundPool) GetSignBytes 

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

func (*MsgDefundPool) GetSigners 

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

func (*MsgDefundPool) Marshal 

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

func (*MsgDefundPool) MarshalTo 

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

func (*MsgDefundPool) MarshalToSizedBuffer 

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

func (*MsgDefundPool) ProtoMessage 

func (*MsgDefundPool) ProtoMessage()

func (*MsgDefundPool) Reset 

func (m *MsgDefundPool) Reset()

func (*MsgDefundPool) Route 

func (msg *MsgDefundPool) Route() string

func (*MsgDefundPool) Size 

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

func (*MsgDefundPool) String 

func (m *MsgDefundPool) String() string

func (*MsgDefundPool) Type 

func (msg *MsgDefundPool) Type() string

func (*MsgDefundPool) Unmarshal 

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

func (*MsgDefundPool) ValidateBasic 

func (msg *MsgDefundPool) ValidateBasic() error

func (*MsgDefundPool) XXX_DiscardUnknown 

func (m *MsgDefundPool) XXX_DiscardUnknown()

func (*MsgDefundPool) XXX_Marshal 

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

func (*MsgDefundPool) XXX_Merge 

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

func (*MsgDefundPool) XXX_Size 

func (m *MsgDefundPool) XXX_Size() int

func (*MsgDefundPool) XXX_Unmarshal 

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

type MsgDefundPoolResponse 

type MsgDefundPoolResponse struct {
}

MsgDefundPoolResponse defines the Msg/DefundPool response type.

func (*MsgDefundPoolResponse) Descriptor 

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

func (*MsgDefundPoolResponse) Marshal 

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

func (*MsgDefundPoolResponse) MarshalTo 

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

func (*MsgDefundPoolResponse) MarshalToSizedBuffer 

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

func (*MsgDefundPoolResponse) ProtoMessage 

func (*MsgDefundPoolResponse) ProtoMessage()

func (*MsgDefundPoolResponse) Reset 

func (m *MsgDefundPoolResponse) Reset()

func (*MsgDefundPoolResponse) Size 

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

func (*MsgDefundPoolResponse) String 

func (m *MsgDefundPoolResponse) String() string

func (*MsgDefundPoolResponse) Unmarshal 

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

func (*MsgDefundPoolResponse) XXX_DiscardUnknown 

func (m *MsgDefundPoolResponse) XXX_DiscardUnknown()

func (*MsgDefundPoolResponse) XXX_Marshal 

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

func (*MsgDefundPoolResponse) XXX_Merge 

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

func (*MsgDefundPoolResponse) XXX_Size 

func (m *MsgDefundPoolResponse) XXX_Size() int

func (*MsgDefundPoolResponse) XXX_Unmarshal 

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

type MsgDisablePool 

type MsgDisablePool struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

MsgDisablePool defines a SDK message for disabling an existing pool.

func (*MsgDisablePool) Descriptor 

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

func (*MsgDisablePool) GetAuthority 

func (m *MsgDisablePool) GetAuthority() string

func (*MsgDisablePool) GetId 

func (m *MsgDisablePool) GetId() uint64

func (*MsgDisablePool) GetSigners 

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

GetSigners returns the expected signers for a MsgDisablePool message.

func (*MsgDisablePool) Marshal 

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

func (*MsgDisablePool) MarshalTo 

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

func (*MsgDisablePool) MarshalToSizedBuffer 

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

func (*MsgDisablePool) ProtoMessage 

func (*MsgDisablePool) ProtoMessage()

func (*MsgDisablePool) Reset 

func (m *MsgDisablePool) Reset()

func (*MsgDisablePool) Size 

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

func (*MsgDisablePool) String 

func (m *MsgDisablePool) String() string

func (*MsgDisablePool) Unmarshal 

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

func (*MsgDisablePool) ValidateBasic 

func (msg *MsgDisablePool) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgDisablePool) XXX_DiscardUnknown 

func (m *MsgDisablePool) XXX_DiscardUnknown()

func (*MsgDisablePool) XXX_Marshal 

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

func (*MsgDisablePool) XXX_Merge 

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

func (*MsgDisablePool) XXX_Size 

func (m *MsgDisablePool) XXX_Size() int

func (*MsgDisablePool) XXX_Unmarshal 

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

type MsgDisablePoolResponse 

type MsgDisablePoolResponse struct {
}

MsgDisablePoolResponse defines the Msg/DisablePool response type.

func (*MsgDisablePoolResponse) Descriptor 

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

func (*MsgDisablePoolResponse) Marshal 

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

func (*MsgDisablePoolResponse) MarshalTo 

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

func (*MsgDisablePoolResponse) MarshalToSizedBuffer 

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

func (*MsgDisablePoolResponse) ProtoMessage 

func (*MsgDisablePoolResponse) ProtoMessage()

func (*MsgDisablePoolResponse) Reset 

func (m *MsgDisablePoolResponse) Reset()

func (*MsgDisablePoolResponse) Size 

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

func (*MsgDisablePoolResponse) String 

func (m *MsgDisablePoolResponse) String() string

func (*MsgDisablePoolResponse) Unmarshal 

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

func (*MsgDisablePoolResponse) XXX_DiscardUnknown 

func (m *MsgDisablePoolResponse) XXX_DiscardUnknown()

func (*MsgDisablePoolResponse) XXX_Marshal 

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

func (*MsgDisablePoolResponse) XXX_Merge 

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

func (*MsgDisablePoolResponse) XXX_Size 

func (m *MsgDisablePoolResponse) XXX_Size() int

func (*MsgDisablePoolResponse) XXX_Unmarshal 

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

type MsgEnablePool 

type MsgEnablePool struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

MsgEnablePool defines a SDK message for enabling an existing pool.

func (*MsgEnablePool) Descriptor 

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

func (*MsgEnablePool) GetAuthority 

func (m *MsgEnablePool) GetAuthority() string

func (*MsgEnablePool) GetId 

func (m *MsgEnablePool) GetId() uint64

func (*MsgEnablePool) GetSigners 

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

GetSigners returns the expected signers for a MsgEnablePool message.

func (*MsgEnablePool) Marshal 

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

func (*MsgEnablePool) MarshalTo 

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

func (*MsgEnablePool) MarshalToSizedBuffer 

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

func (*MsgEnablePool) ProtoMessage 

func (*MsgEnablePool) ProtoMessage()

func (*MsgEnablePool) Reset 

func (m *MsgEnablePool) Reset()

func (*MsgEnablePool) Size 

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

func (*MsgEnablePool) String 

func (m *MsgEnablePool) String() string

func (*MsgEnablePool) Unmarshal 

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

func (*MsgEnablePool) ValidateBasic 

func (msg *MsgEnablePool) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgEnablePool) XXX_DiscardUnknown 

func (m *MsgEnablePool) XXX_DiscardUnknown()

func (*MsgEnablePool) XXX_Marshal 

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

func (*MsgEnablePool) XXX_Merge 

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

func (*MsgEnablePool) XXX_Size 

func (m *MsgEnablePool) XXX_Size() int

func (*MsgEnablePool) XXX_Unmarshal 

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

type MsgEnablePoolResponse 

type MsgEnablePoolResponse struct {
}

MsgEnablePoolResponse defines the Msg/EnablePool response type.

func (*MsgEnablePoolResponse) Descriptor 

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

func (*MsgEnablePoolResponse) Marshal 

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

func (*MsgEnablePoolResponse) MarshalTo 

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

func (*MsgEnablePoolResponse) MarshalToSizedBuffer 

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

func (*MsgEnablePoolResponse) ProtoMessage 

func (*MsgEnablePoolResponse) ProtoMessage()

func (*MsgEnablePoolResponse) Reset 

func (m *MsgEnablePoolResponse) Reset()

func (*MsgEnablePoolResponse) Size 

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

func (*MsgEnablePoolResponse) String 

func (m *MsgEnablePoolResponse) String() string

func (*MsgEnablePoolResponse) Unmarshal 

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

func (*MsgEnablePoolResponse) XXX_DiscardUnknown 

func (m *MsgEnablePoolResponse) XXX_DiscardUnknown()

func (*MsgEnablePoolResponse) XXX_Marshal 

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

func (*MsgEnablePoolResponse) XXX_Merge 

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

func (*MsgEnablePoolResponse) XXX_Size 

func (m *MsgEnablePoolResponse) XXX_Size() int

func (*MsgEnablePoolResponse) XXX_Unmarshal 

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

type MsgFundPool 

type MsgFundPool struct {
	// creator ...
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// amount ...
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
}

MsgFundPool defines a SDK message for funding a pool.

func NewMsgFundPool 

func NewMsgFundPool(creator string, id uint64, amount uint64) *MsgFundPool

func (*MsgFundPool) Descriptor 

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

func (*MsgFundPool) GetAmount 

func (m *MsgFundPool) GetAmount() uint64

func (*MsgFundPool) GetCreator 

func (m *MsgFundPool) GetCreator() string

func (*MsgFundPool) GetId 

func (m *MsgFundPool) GetId() uint64

func (*MsgFundPool) GetSignBytes 

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

func (*MsgFundPool) GetSigners 

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

func (*MsgFundPool) Marshal 

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

func (*MsgFundPool) MarshalTo 

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

func (*MsgFundPool) MarshalToSizedBuffer 

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

func (*MsgFundPool) ProtoMessage 

func (*MsgFundPool) ProtoMessage()

func (*MsgFundPool) Reset 

func (m *MsgFundPool) Reset()

func (*MsgFundPool) Route 

func (msg *MsgFundPool) Route() string

func (*MsgFundPool) Size 

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

func (*MsgFundPool) String 

func (m *MsgFundPool) String() string

func (*MsgFundPool) Type 

func (msg *MsgFundPool) Type() string

func (*MsgFundPool) Unmarshal 

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

func (*MsgFundPool) ValidateBasic 

func (msg *MsgFundPool) ValidateBasic() error

func (*MsgFundPool) XXX_DiscardUnknown 

func (m *MsgFundPool) XXX_DiscardUnknown()

func (*MsgFundPool) XXX_Marshal 

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

func (*MsgFundPool) XXX_Merge 

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

func (*MsgFundPool) XXX_Size 

func (m *MsgFundPool) XXX_Size() int

func (*MsgFundPool) XXX_Unmarshal 

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

type MsgFundPoolResponse 

type MsgFundPoolResponse struct {
}

MsgFundPoolResponse defines the Msg/DefundPool response type.

func (*MsgFundPoolResponse) Descriptor 

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

func (*MsgFundPoolResponse) Marshal 

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

func (*MsgFundPoolResponse) MarshalTo 

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

func (*MsgFundPoolResponse) MarshalToSizedBuffer 

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

func (*MsgFundPoolResponse) ProtoMessage 

func (*MsgFundPoolResponse) ProtoMessage()

func (*MsgFundPoolResponse) Reset 

func (m *MsgFundPoolResponse) Reset()

func (*MsgFundPoolResponse) Size 

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

func (*MsgFundPoolResponse) String 

func (m *MsgFundPoolResponse) String() string

func (*MsgFundPoolResponse) Unmarshal 

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

func (*MsgFundPoolResponse) XXX_DiscardUnknown 

func (m *MsgFundPoolResponse) XXX_DiscardUnknown()

func (*MsgFundPoolResponse) XXX_Marshal 

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

func (*MsgFundPoolResponse) XXX_Merge 

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

func (*MsgFundPoolResponse) XXX_Size 

func (m *MsgFundPoolResponse) XXX_Size() int

func (*MsgFundPoolResponse) XXX_Unmarshal 

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

type MsgScheduleRuntimeUpgrade 

type MsgScheduleRuntimeUpgrade struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// runtime ...
	Runtime string `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// version ...
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// scheduled_at ...
	ScheduledAt uint64 `protobuf:"varint,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// duration ...
	Duration uint64 `protobuf:"varint,5,opt,name=duration,proto3" json:"duration,omitempty"`
	// binaries ...
	Binaries string `protobuf:"bytes,6,opt,name=binaries,proto3" json:"binaries,omitempty"`
}

MsgScheduleRuntimeUpgrade defines a SDK message for scheduling a runtime upgrade.

func (*MsgScheduleRuntimeUpgrade) Descriptor 

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

func (*MsgScheduleRuntimeUpgrade) GetAuthority 

func (m *MsgScheduleRuntimeUpgrade) GetAuthority() string

func (*MsgScheduleRuntimeUpgrade) GetBinaries 

func (m *MsgScheduleRuntimeUpgrade) GetBinaries() string

func (*MsgScheduleRuntimeUpgrade) GetDuration 

func (m *MsgScheduleRuntimeUpgrade) GetDuration() uint64

func (*MsgScheduleRuntimeUpgrade) GetRuntime 

func (m *MsgScheduleRuntimeUpgrade) GetRuntime() string

func (*MsgScheduleRuntimeUpgrade) GetScheduledAt 

func (m *MsgScheduleRuntimeUpgrade) GetScheduledAt() uint64

func (*MsgScheduleRuntimeUpgrade) GetSigners 

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

GetSigners returns the expected signers for a MsgScheduleRuntimeUpgrade message.

func (*MsgScheduleRuntimeUpgrade) GetVersion 

func (m *MsgScheduleRuntimeUpgrade) GetVersion() string

func (*MsgScheduleRuntimeUpgrade) Marshal 

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

func (*MsgScheduleRuntimeUpgrade) MarshalTo 

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

func (*MsgScheduleRuntimeUpgrade) MarshalToSizedBuffer 

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

func (*MsgScheduleRuntimeUpgrade) ProtoMessage 

func (*MsgScheduleRuntimeUpgrade) ProtoMessage()

func (*MsgScheduleRuntimeUpgrade) Reset 

func (m *MsgScheduleRuntimeUpgrade) Reset()

func (*MsgScheduleRuntimeUpgrade) Size 

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

func (*MsgScheduleRuntimeUpgrade) String 

func (m *MsgScheduleRuntimeUpgrade) String() string

func (*MsgScheduleRuntimeUpgrade) Unmarshal 

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

func (*MsgScheduleRuntimeUpgrade) ValidateBasic 

func (msg *MsgScheduleRuntimeUpgrade) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgScheduleRuntimeUpgrade) XXX_DiscardUnknown 

func (m *MsgScheduleRuntimeUpgrade) XXX_DiscardUnknown()

func (*MsgScheduleRuntimeUpgrade) XXX_Marshal 

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

func (*MsgScheduleRuntimeUpgrade) XXX_Merge 

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

func (*MsgScheduleRuntimeUpgrade) XXX_Size 

func (m *MsgScheduleRuntimeUpgrade) XXX_Size() int

func (*MsgScheduleRuntimeUpgrade) XXX_Unmarshal 

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

type MsgScheduleRuntimeUpgradeResponse 

type MsgScheduleRuntimeUpgradeResponse struct {
}

MsgScheduleRuntimeUpgradeResponse defines the Msg/ScheduleRuntimeUpgrade response type.

func (*MsgScheduleRuntimeUpgradeResponse) Descriptor 

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

func (*MsgScheduleRuntimeUpgradeResponse) Marshal 

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

func (*MsgScheduleRuntimeUpgradeResponse) MarshalTo 

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

func (*MsgScheduleRuntimeUpgradeResponse) MarshalToSizedBuffer 

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

func (*MsgScheduleRuntimeUpgradeResponse) ProtoMessage 

func (*MsgScheduleRuntimeUpgradeResponse) ProtoMessage()

func (*MsgScheduleRuntimeUpgradeResponse) Reset 

func (m *MsgScheduleRuntimeUpgradeResponse) Reset()

func (*MsgScheduleRuntimeUpgradeResponse) Size 

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

func (*MsgScheduleRuntimeUpgradeResponse) String 

func (m *MsgScheduleRuntimeUpgradeResponse) String() string

func (*MsgScheduleRuntimeUpgradeResponse) Unmarshal 

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

func (*MsgScheduleRuntimeUpgradeResponse) XXX_DiscardUnknown 

func (m *MsgScheduleRuntimeUpgradeResponse) XXX_DiscardUnknown()

func (*MsgScheduleRuntimeUpgradeResponse) XXX_Marshal 

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

func (*MsgScheduleRuntimeUpgradeResponse) XXX_Merge 

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

func (*MsgScheduleRuntimeUpgradeResponse) XXX_Size 

func (m *MsgScheduleRuntimeUpgradeResponse) XXX_Size() int

func (*MsgScheduleRuntimeUpgradeResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// FundPool ...
	FundPool(context.Context, *MsgFundPool) (*MsgFundPoolResponse, error)
	// DefundPool ...
	DefundPool(context.Context, *MsgDefundPool) (*MsgDefundPoolResponse, error)
	// CreatePool defines a governance operation for creating a new pool.
	// The authority is hard-coded to the x/gov module account.
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	// UpdatePool defines a governance operation for updating an existing pool.
	// The authority is hard-coded to the x/gov module account.
	UpdatePool(context.Context, *MsgUpdatePool) (*MsgUpdatePoolResponse, error)
	// DisablePool defines a governance operation for disabling an existing pool.
	// The authority is hard-coded to the x/gov module account.
	DisablePool(context.Context, *MsgDisablePool) (*MsgDisablePoolResponse, error)
	// EnablePool defines a governance operation for enabling an existing pool.
	// The authority is hard-coded to the x/gov module account.
	EnablePool(context.Context, *MsgEnablePool) (*MsgEnablePoolResponse, error)
	// ScheduleRuntimeUpgrade defines a governance operation for scheduling a runtime upgrade.
	// The authority is hard-coded to the x/gov module account.
	ScheduleRuntimeUpgrade(context.Context, *MsgScheduleRuntimeUpgrade) (*MsgScheduleRuntimeUpgradeResponse, error)
	// CancelRuntimeUpgrade defines a governance operation for cancelling a runtime upgrade.
	// The authority is hard-coded to the x/gov module account.
	CancelRuntimeUpgrade(context.Context, *MsgCancelRuntimeUpgrade) (*MsgCancelRuntimeUpgradeResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdatePool 

type MsgUpdatePool struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// payload ...
	Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
}

MsgUpdatePool defines a SDK message for updating an existing pool.

func (*MsgUpdatePool) Descriptor 

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

func (*MsgUpdatePool) GetAuthority 

func (m *MsgUpdatePool) GetAuthority() string

func (*MsgUpdatePool) GetId 

func (m *MsgUpdatePool) GetId() uint64

func (*MsgUpdatePool) GetPayload 

func (m *MsgUpdatePool) GetPayload() string

func (*MsgUpdatePool) GetSigners 

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

GetSigners returns the expected signers for a MsgUpdatePool message.

func (*MsgUpdatePool) Marshal 

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

func (*MsgUpdatePool) MarshalTo 

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

func (*MsgUpdatePool) MarshalToSizedBuffer 

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

func (*MsgUpdatePool) ProtoMessage 

func (*MsgUpdatePool) ProtoMessage()

func (*MsgUpdatePool) Reset 

func (m *MsgUpdatePool) Reset()

func (*MsgUpdatePool) Size 

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

func (*MsgUpdatePool) String 

func (m *MsgUpdatePool) String() string

func (*MsgUpdatePool) Unmarshal 

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

func (*MsgUpdatePool) ValidateBasic 

func (msg *MsgUpdatePool) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdatePool) XXX_DiscardUnknown 

func (m *MsgUpdatePool) XXX_DiscardUnknown()

func (*MsgUpdatePool) XXX_Marshal 

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

func (*MsgUpdatePool) XXX_Merge 

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

func (*MsgUpdatePool) XXX_Size 

func (m *MsgUpdatePool) XXX_Size() int

func (*MsgUpdatePool) XXX_Unmarshal 

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

type MsgUpdatePoolResponse 

type MsgUpdatePoolResponse struct {
}

MsgUpdatePoolResponse defines the Msg/UpdatePool response type.

func (*MsgUpdatePoolResponse) Descriptor 

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

func (*MsgUpdatePoolResponse) Marshal 

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

func (*MsgUpdatePoolResponse) MarshalTo 

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

func (*MsgUpdatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgUpdatePoolResponse) ProtoMessage 

func (*MsgUpdatePoolResponse) ProtoMessage()

func (*MsgUpdatePoolResponse) Reset 

func (m *MsgUpdatePoolResponse) Reset()

func (*MsgUpdatePoolResponse) Size 

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

func (*MsgUpdatePoolResponse) String 

func (m *MsgUpdatePoolResponse) String() string

func (*MsgUpdatePoolResponse) Unmarshal 

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

func (*MsgUpdatePoolResponse) XXX_DiscardUnknown 

func (m *MsgUpdatePoolResponse) XXX_DiscardUnknown()

func (*MsgUpdatePoolResponse) XXX_Marshal 

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

func (*MsgUpdatePoolResponse) XXX_Merge 

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

func (*MsgUpdatePoolResponse) XXX_Size 

func (m *MsgUpdatePoolResponse) XXX_Size() int

func (*MsgUpdatePoolResponse) XXX_Unmarshal 

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

type Pool 

type Pool struct {
	// id - unique identifier of the pool, can not be changed
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is a human readable name for the pool
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// runtime specified which protocol and which version needs is required
	Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// config is either a JSON encoded string or a link to an external storage provider.
	// This is up to the implementation of the protocol node.
	Config string `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// start_key ...
	StartKey string `protobuf:"bytes,6,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	// current_key ...
	CurrentKey string `protobuf:"bytes,7,opt,name=current_key,json=currentKey,proto3" json:"current_key,omitempty"`
	// current_summary ...
	CurrentSummary string `protobuf:"bytes,8,opt,name=current_summary,json=currentSummary,proto3" json:"current_summary,omitempty"`
	// current_index ...
	CurrentIndex uint64 `protobuf:"varint,9,opt,name=current_index,json=currentIndex,proto3" json:"current_index,omitempty"`
	// total_bundles is the number of total finalized bundles
	TotalBundles uint64 `protobuf:"varint,10,opt,name=total_bundles,json=totalBundles,proto3" json:"total_bundles,omitempty"`
	// upload_interval ...
	UploadInterval uint64 `protobuf:"varint,11,opt,name=upload_interval,json=uploadInterval,proto3" json:"upload_interval,omitempty"`
	// operating_cost ...
	OperatingCost uint64 `protobuf:"varint,12,opt,name=operating_cost,json=operatingCost,proto3" json:"operating_cost,omitempty"`
	// min_delegation ...
	MinDelegation uint64 `protobuf:"varint,13,opt,name=min_delegation,json=minDelegation,proto3" json:"min_delegation,omitempty"`
	// max_bundle_size ...
	MaxBundleSize uint64 `protobuf:"varint,14,opt,name=max_bundle_size,json=maxBundleSize,proto3" json:"max_bundle_size,omitempty"`
	// disabled is true when the pool is disabled.
	// Can only be done via governance.
	Disabled bool `protobuf:"varint,15,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// funders ...
	Funders []*Funder `protobuf:"bytes,16,rep,name=funders,proto3" json:"funders,omitempty"`
	// total_funds ...
	TotalFunds uint64 `protobuf:"varint,17,opt,name=total_funds,json=totalFunds,proto3" json:"total_funds,omitempty"`
	// protocol ...
	Protocol *Protocol `protobuf:"bytes,18,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// upgrade_plan ...
	UpgradePlan *UpgradePlan `protobuf:"bytes,19,opt,name=upgrade_plan,json=upgradePlan,proto3" json:"upgrade_plan,omitempty"`
	// storage_provider_id ...
	CurrentStorageProviderId uint32 `` /* 139-byte string literal not displayed */
	// compression_id ...
	CurrentCompressionId uint32 `protobuf:"varint,21,opt,name=current_compression_id,json=currentCompressionId,proto3" json:"current_compression_id,omitempty"`
}

Pool ...

func (*Pool) AddAmountToFunder 

func (m *Pool) AddAmountToFunder(funderAddress string, amount uint64)

AddAmountToFunder adds the given amount to an existing funder. If the funder does not exist, a new funder is inserted.

func (*Pool) Descriptor 

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

func (*Pool) GetConfig 

func (m *Pool) GetConfig() string

func (*Pool) GetCurrentCompressionId 

func (m *Pool) GetCurrentCompressionId() uint32

func (*Pool) GetCurrentIndex 

func (m *Pool) GetCurrentIndex() uint64

func (*Pool) GetCurrentKey 

func (m *Pool) GetCurrentKey() string

func (*Pool) GetCurrentStorageProviderId 

func (m *Pool) GetCurrentStorageProviderId() uint32

func (*Pool) GetCurrentSummary 

func (m *Pool) GetCurrentSummary() string

func (*Pool) GetDisabled 

func (m *Pool) GetDisabled() bool

func (*Pool) GetFunderAmount 

func (m *Pool) GetFunderAmount(address string) uint64

func (*Pool) GetFunders 

func (m *Pool) GetFunders() []*Funder

func (*Pool) GetId 

func (m *Pool) GetId() uint64
func (m *Pool) GetLogo() string

func (*Pool) GetLowestFunder 

func (m *Pool) GetLowestFunder() Funder

func (*Pool) GetMaxBundleSize 

func (m *Pool) GetMaxBundleSize() uint64

func (*Pool) GetMinDelegation 

func (m *Pool) GetMinDelegation() uint64

func (*Pool) GetName 

func (m *Pool) GetName() string

func (*Pool) GetOperatingCost 

func (m *Pool) GetOperatingCost() uint64

func (*Pool) GetProtocol 

func (m *Pool) GetProtocol() *Protocol

func (*Pool) GetRuntime 

func (m *Pool) GetRuntime() string

func (*Pool) GetStartKey 

func (m *Pool) GetStartKey() string

func (*Pool) GetTotalBundles 

func (m *Pool) GetTotalBundles() uint64

func (*Pool) GetTotalFunds 

func (m *Pool) GetTotalFunds() uint64

func (*Pool) GetUpgradePlan 

func (m *Pool) GetUpgradePlan() *UpgradePlan

func (*Pool) GetUploadInterval 

func (m *Pool) GetUploadInterval() uint64

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) RemoveFunder 

func (m *Pool) RemoveFunder(funderAddress string)

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) SubtractAmountFromFunder 

func (m *Pool) SubtractAmountFromFunder(funderAddress string, amount uint64)

SubtractAmountFromFunder subtracts the given amount form an existing funder If the amount is grater or equal to the funders amount, the funder is removed.

func (*Pool) Unmarshal 

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

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolStatus 

type PoolStatus int32

PoolStatus ... 

const (
	// POOL_STATUS_UNSPECIFIED ...
	POOL_STATUS_UNSPECIFIED PoolStatus = 0
	// POOL_STATUS_ACTIVE ...
	POOL_STATUS_ACTIVE PoolStatus = 1
	// POOL_STATUS_DISABLED ...
	POOL_STATUS_DISABLED PoolStatus = 2
	// POOL_STATUS_NO_FUNDS ...
	POOL_STATUS_NO_FUNDS PoolStatus = 3
	// POOL_STATUS_NOT_ENOUGH_DELEGATION ...
	POOL_STATUS_NOT_ENOUGH_DELEGATION PoolStatus = 4
	// POOL_STATUS_UPGRADING ...
	POOL_STATUS_UPGRADING PoolStatus = 5
)

func (PoolStatus) EnumDescriptor 

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

func (PoolStatus) String 

func (x PoolStatus) String() string

type PoolUpdate added in v1.1.0 

type PoolUpdate struct {
	Name              *string
	Runtime           *string
	Config            *string
	UploadInterval    *uint64
	OperatingCost     *uint64
	MinDelegation     *uint64
	MaxBundleSize     *uint64
	StorageProviderId *uint32
	CompressionId     *uint32
}

PoolUpdate ...

type Protocol 

type Protocol struct {
	// version holds the current software version tag of the pool binaries
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// binaries is a stringified json object which holds binaries in the
	// current version for multiple platforms and architectures
	Binaries string `protobuf:"bytes,2,opt,name=binaries,proto3" json:"binaries,omitempty"`
	// last_upgrade is the unix time the pool was upgraded the last time
	LastUpgrade uint64 `protobuf:"varint,3,opt,name=last_upgrade,json=lastUpgrade,proto3" json:"last_upgrade,omitempty"`
}

Protocol holds all info about the current pool version and the available binaries for participating as a validator in a pool

func (*Protocol) Descriptor 

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

func (*Protocol) GetBinaries 

func (m *Protocol) GetBinaries() string

func (*Protocol) GetLastUpgrade 

func (m *Protocol) GetLastUpgrade() uint64

func (*Protocol) GetVersion 

func (m *Protocol) GetVersion() string

func (*Protocol) Marshal 

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

func (*Protocol) MarshalTo 

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

func (*Protocol) MarshalToSizedBuffer 

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

func (*Protocol) ProtoMessage 

func (*Protocol) ProtoMessage()

func (*Protocol) Reset 

func (m *Protocol) Reset()

func (*Protocol) Size 

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

func (*Protocol) String 

func (m *Protocol) String() string

func (*Protocol) Unmarshal 

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

func (*Protocol) XXX_DiscardUnknown 

func (m *Protocol) XXX_DiscardUnknown()

func (*Protocol) XXX_Marshal 

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

func (*Protocol) XXX_Merge 

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

func (*Protocol) XXX_Size 

func (m *Protocol) XXX_Size() int

func (*Protocol) XXX_Unmarshal 

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

type StakersKeeper 

type StakersKeeper interface {
	LeavePool(ctx sdk.Context, staker string, poolId uint64)
	GetAllStakerAddressesOfPool(ctx sdk.Context, poolId uint64) (stakers []string)
}

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CancelRuntimeUpgrade 

func (*UnimplementedMsgServer) CancelRuntimeUpgrade(ctx context.Context, req *MsgCancelRuntimeUpgrade) (*MsgCancelRuntimeUpgradeResponse, error)

func (*UnimplementedMsgServer) CreatePool 

func (*UnimplementedMsgServer) CreatePool(ctx context.Context, req *MsgCreatePool) (*MsgCreatePoolResponse, error)

func (*UnimplementedMsgServer) DefundPool 

func (*UnimplementedMsgServer) DefundPool(ctx context.Context, req *MsgDefundPool) (*MsgDefundPoolResponse, error)

func (*UnimplementedMsgServer) DisablePool 

func (*UnimplementedMsgServer) DisablePool(ctx context.Context, req *MsgDisablePool) (*MsgDisablePoolResponse, error)

func (*UnimplementedMsgServer) EnablePool 

func (*UnimplementedMsgServer) EnablePool(ctx context.Context, req *MsgEnablePool) (*MsgEnablePoolResponse, error)

func (*UnimplementedMsgServer) FundPool 

func (*UnimplementedMsgServer) FundPool(ctx context.Context, req *MsgFundPool) (*MsgFundPoolResponse, error)

func (*UnimplementedMsgServer) ScheduleRuntimeUpgrade 

func (*UnimplementedMsgServer) ScheduleRuntimeUpgrade(ctx context.Context, req *MsgScheduleRuntimeUpgrade) (*MsgScheduleRuntimeUpgradeResponse, error)

func (*UnimplementedMsgServer) UpdatePool 

func (*UnimplementedMsgServer) UpdatePool(ctx context.Context, req *MsgUpdatePool) (*MsgUpdatePoolResponse, error)

type UpgradeKeeper 

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

type UpgradePlan 

type UpgradePlan struct {
	// version is the new software version tag of the upgrade
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// binaries is the new stringified json object which holds binaries in the
	// upgrade version for multiple platforms and architectures
	Binaries string `protobuf:"bytes,2,opt,name=binaries,proto3" json:"binaries,omitempty"`
	// scheduled_at is the unix time the upgrade is supposed to be done
	ScheduledAt uint64 `protobuf:"varint,3,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// duration is the time in seconds how long the pool should halt
	// during the upgrade to give all validators a chance of switching
	// to the new binaries
	Duration uint64 `protobuf:"varint,4,opt,name=duration,proto3" json:"duration,omitempty"`
}

Upgrade holds all info when a pool has a scheduled upgrade

func (*UpgradePlan) Descriptor 

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

func (*UpgradePlan) GetBinaries 

func (m *UpgradePlan) GetBinaries() string

func (*UpgradePlan) GetDuration 

func (m *UpgradePlan) GetDuration() uint64

func (*UpgradePlan) GetScheduledAt 

func (m *UpgradePlan) GetScheduledAt() uint64

func (*UpgradePlan) GetVersion 

func (m *UpgradePlan) GetVersion() string

func (*UpgradePlan) Marshal 

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

func (*UpgradePlan) MarshalTo 

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

func (*UpgradePlan) MarshalToSizedBuffer 

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

func (*UpgradePlan) ProtoMessage 

func (*UpgradePlan) ProtoMessage()

func (*UpgradePlan) Reset 

func (m *UpgradePlan) Reset()

func (*UpgradePlan) Size 

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

func (*UpgradePlan) String 

func (m *UpgradePlan) String() string

func (*UpgradePlan) Unmarshal 

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

func (*UpgradePlan) XXX_DiscardUnknown 

func (m *UpgradePlan) XXX_DiscardUnknown()

func (*UpgradePlan) XXX_Marshal 

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

func (*UpgradePlan) XXX_Merge 

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

func (*UpgradePlan) XXX_Size 

func (m *UpgradePlan) XXX_Size() int

func (*UpgradePlan) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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