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: 30 Imported by: 13

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

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewAminoCodec(Amino)
)
View Source 
var (
	ErrPoolNotFound = errors.Register(ModuleName, 1100, "pool with id %v does not exist")
	ErrInvalidJson  = errors.Register(ModuleName, 1101, "invalid json object: %v")
	ErrInvalidArgs  = errors.Register(ModuleName, 1102, "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 (
	// ParamsKey is the prefix for all module params defined in params.proto
	ParamsKey = []byte{0}

	// PoolKey is the prefix for all pools defined in pool.proto
	PoolKey = []byte{1}

	// PoolCountKey is the prefix for the pool counter defined in pool.proto
	PoolCountKey = []byte{2}
)
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 (
	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 (
	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 DefaultPoolInflationPayoutRate = sdk.MustNewDecFromStr("0.05")

DefaultPoolInflationPayoutRate ...

View Source 
var DefaultProtocolInflationShare = sdk.ZeroDec()

DefaultProtocolInflationShare ...

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",
	6: "POOL_STATUS_VOTING_POWER_TOO_HIGH",
}
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,
	"POOL_STATUS_VOTING_POWER_TOO_HIGH": 6,
}

Functions

func PoolKeyPrefix 

func PoolKeyPrefix(poolId uint64) []byte

func RegisterInterfaces 

func RegisterInterfaces(registry codecTypes.InterfaceRegistry)

func RegisterLegacyAminoCodec added in v1.2.0 

func RegisterLegacyAminoCodec(_ *codec.LegacyAmino)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v1.3.0 

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

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

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

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

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

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

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"`
	// inflation_share_weight is the fixed cost which gets paid out
	// to every successful uploader
	InflationShareWeight uint64 `protobuf:"varint,8,opt,name=inflation_share_weight,json=inflationShareWeight,proto3" json:"inflation_share_weight,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 (*EventCreatePool) GetInflationShareWeight added in v1.4.0 

func (m *EventCreatePool) GetInflationShareWeight() 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) 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 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 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"`
	// inflation_share_weight is the fixed cost which gets paid out
	// to every successful uploader
	InflationShareWeight uint64 `protobuf:"varint,8,opt,name=inflation_share_weight,json=inflationShareWeight,proto3" json:"inflation_share_weight,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 (*EventPoolUpdated) GetInflationShareWeight added in v1.4.0 

func (m *EventPoolUpdated) GetInflationShareWeight() 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) 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 EventUpdateParams added in v1.3.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.3.0 

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

func (*EventUpdateParams) GetNewParams added in v1.3.0 

func (m *EventUpdateParams) GetNewParams() Params

func (*EventUpdateParams) GetOldParams added in v1.3.0 

func (m *EventUpdateParams) GetOldParams() Params

func (*EventUpdateParams) GetPayload added in v1.3.0 

func (m *EventUpdateParams) GetPayload() string

func (*EventUpdateParams) Marshal added in v1.3.0 

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

func (*EventUpdateParams) MarshalTo added in v1.3.0 

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

func (*EventUpdateParams) MarshalToSizedBuffer added in v1.3.0 

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

func (*EventUpdateParams) ProtoMessage added in v1.3.0 

func (*EventUpdateParams) ProtoMessage()

func (*EventUpdateParams) Reset added in v1.3.0 

func (m *EventUpdateParams) Reset()

func (*EventUpdateParams) Size added in v1.3.0 

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

func (*EventUpdateParams) String added in v1.3.0 

func (m *EventUpdateParams) String() string

func (*EventUpdateParams) Unmarshal added in v1.3.0 

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

func (*EventUpdateParams) XXX_DiscardUnknown added in v1.3.0 

func (m *EventUpdateParams) XXX_DiscardUnknown()

func (*EventUpdateParams) XXX_Marshal added in v1.3.0 

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

func (*EventUpdateParams) XXX_Merge added in v1.3.0 

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

func (*EventUpdateParams) XXX_Size added in v1.3.0 

func (m *EventUpdateParams) XXX_Size() int

func (*EventUpdateParams) XXX_Unmarshal added in v1.3.0 

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

type FundersKeeper added in v1.4.0 

type FundersKeeper interface {
	CreateFundingState(ctx sdk.Context, poolId uint64)
}

type GenesisState 

type GenesisState struct {
	// params ...
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// 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) GetParams added in v1.3.0 

func (m *GenesisState) GetParams() Params

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 {
	// 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)
	// UpdateParams defines a governance operation for updating the x/pool 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 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"`
	// inflation_share_weight ...
	InflationShareWeight uint64 `protobuf:"varint,8,opt,name=inflation_share_weight,json=inflationShareWeight,proto3" json:"inflation_share_weight,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 (*MsgCreatePool) GetInflationShareWeight added in v1.4.0 

func (m *MsgCreatePool) GetInflationShareWeight() uint64
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) 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 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 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 {
	// 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)
	// UpdateParams defines a governance operation for updating the x/pool 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 MsgUpdateParams added in v1.3.0 

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

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

func (*MsgUpdateParams) GetAuthority added in v1.3.0 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetPayload added in v1.3.0 

func (m *MsgUpdateParams) GetPayload() string

func (*MsgUpdateParams) GetSigners added in v1.3.0 

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

GetSigners returns the expected signers for a MsgCancelRuntimeUpgrade message.

func (*MsgUpdateParams) Marshal added in v1.3.0 

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

func (*MsgUpdateParams) MarshalTo added in v1.3.0 

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

func (*MsgUpdateParams) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgUpdateParams) ProtoMessage added in v1.3.0 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset added in v1.3.0 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size added in v1.3.0 

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

func (*MsgUpdateParams) String added in v1.3.0 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal added in v1.3.0 

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

func (*MsgUpdateParams) ValidateBasic added in v1.3.0 

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal added in v1.3.0 

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

func (*MsgUpdateParams) XXX_Merge added in v1.3.0 

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

func (*MsgUpdateParams) XXX_Size added in v1.3.0 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal added in v1.3.0 

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

type MsgUpdateParamsResponse added in v1.3.0 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the Msg/UpdateParams response type.

func (*MsgUpdateParamsResponse) Descriptor added in v1.3.0 

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

func (*MsgUpdateParamsResponse) Marshal added in v1.3.0 

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

func (*MsgUpdateParamsResponse) MarshalTo added in v1.3.0 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*MsgUpdateParamsResponse) ProtoMessage added in v1.3.0 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset added in v1.3.0 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size added in v1.3.0 

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

func (*MsgUpdateParamsResponse) String added in v1.3.0 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal added in v1.3.0 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal added in v1.3.0 

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

func (*MsgUpdateParamsResponse) XXX_Merge added in v1.3.0 

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

func (*MsgUpdateParamsResponse) XXX_Size added in v1.3.0 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal added in v1.3.0 

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

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

type Params struct {
	// protocol_inflation_share ...
	ProtocolInflationShare github_com_cosmos_cosmos_sdk_types.Dec `` /* 169-byte string literal not displayed */
	// pool_inflation_payout_rate ...
	PoolInflationPayoutRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 174-byte string literal not displayed */
}

Params defines the pool module parameters.

func DefaultParams added in v1.3.0 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams added in v1.3.0 

func NewParams(
	protocolInflationShare sdk.Dec,
	poolInflationPayoutRate sdk.Dec,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor added in v1.3.0 

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

func (*Params) Marshal added in v1.3.0 

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

func (*Params) MarshalTo added in v1.3.0 

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

func (*Params) MarshalToSizedBuffer added in v1.3.0 

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

func (*Params) ProtoMessage added in v1.3.0 

func (*Params) ProtoMessage()

func (*Params) Reset added in v1.3.0 

func (m *Params) Reset()

func (*Params) Size added in v1.3.0 

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

func (*Params) String added in v1.3.0 

func (m *Params) String() string

func (*Params) Unmarshal added in v1.3.0 

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

func (Params) Validate added in v1.3.0 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown added in v1.3.0 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v1.3.0 

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

func (*Params) XXX_Merge added in v1.3.0 

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

func (*Params) XXX_Size added in v1.3.0 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v1.3.0 

func (m *Params) 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"`
	// inflation_share_weight ...
	InflationShareWeight uint64 `protobuf:"varint,12,opt,name=inflation_share_weight,json=inflationShareWeight,proto3" json:"inflation_share_weight,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"`
	// protocol ...
	Protocol *Protocol `protobuf:"bytes,16,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// upgrade_plan ...
	UpgradePlan *UpgradePlan `protobuf:"bytes,17,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,19,opt,name=current_compression_id,json=currentCompressionId,proto3" json:"current_compression_id,omitempty"`
}

Pool ...

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

func (m *Pool) GetId() uint64

func (*Pool) GetInflationShareWeight added in v1.4.0 

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

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

func (m *Pool) GetPoolAccount() sdk.AccAddress

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

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

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 indicates an unknown status, likely
	// due to an error
	POOL_STATUS_UNSPECIFIED PoolStatus = 0
	// POOL_STATUS_ACTIVE indicates, that the pool is running
	// normally
	POOL_STATUS_ACTIVE PoolStatus = 1
	// POOL_STATUS_DISABLED indicates, that the pool was disabled
	// by the governance and does not continue until it is enabled
	// by the governance again
	POOL_STATUS_DISABLED PoolStatus = 2
	// POOL_STATUS_NO_FUNDS indicates, that the pool currently has no
	// funds, but is continuing normally anyway, due to inflation splitting
	POOL_STATUS_NO_FUNDS PoolStatus = 3
	// POOL_STATUS_NOT_ENOUGH_DELEGATION indicates, that the min delegation
	// requirement has not been met and that the pool is halted
	POOL_STATUS_NOT_ENOUGH_DELEGATION PoolStatus = 4
	// POOL_STATUS_UPGRADING indicates, that the runtime is currently
	// being upgraded and that the pool is halted
	POOL_STATUS_UPGRADING PoolStatus = 5
	// POOL_STATUS_VOTING_POWER_TOO_HIGH indicates, that one validator
	// has more than 50% voting power and that the pool is halted
	POOL_STATUS_VOTING_POWER_TOO_HIGH PoolStatus = 6
)

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
	InflationShareWeight *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 QueryClient added in v1.3.0 

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

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryParamsRequest added in v1.3.0 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor added in v1.3.0 

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

func (*QueryParamsRequest) Marshal added in v1.3.0 

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

func (*QueryParamsRequest) MarshalTo added in v1.3.0 

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v1.3.0 

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

func (*QueryParamsRequest) ProtoMessage added in v1.3.0 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v1.3.0 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v1.3.0 

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

func (*QueryParamsRequest) String added in v1.3.0 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v1.3.0 

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v1.3.0 

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

func (*QueryParamsRequest) XXX_Merge added in v1.3.0 

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

func (*QueryParamsRequest) XXX_Size added in v1.3.0 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v1.3.0 

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

type QueryParamsResponse added in v1.3.0 

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

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

func (*QueryParamsResponse) GetParams added in v1.3.0 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal added in v1.3.0 

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

func (*QueryParamsResponse) MarshalTo added in v1.3.0 

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*QueryParamsResponse) ProtoMessage added in v1.3.0 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v1.3.0 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v1.3.0 

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

func (*QueryParamsResponse) String added in v1.3.0 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v1.3.0 

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v1.3.0 

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

func (*QueryParamsResponse) XXX_Merge added in v1.3.0 

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

func (*QueryParamsResponse) XXX_Size added in v1.3.0 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v1.3.0 

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

type QueryServer added in v1.3.0 

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

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

func (*UnimplementedMsgServer) UpdateParams added in v1.3.0 

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

func (*UnimplementedMsgServer) UpdatePool 

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

type UnimplementedQueryServer added in v1.3.0 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Params added in v1.3.0 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, 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.