types

package
v1.0.0-alpha2 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2024 License: LGPL-3.0 Imports: 29 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateNode              = "create_node"
	EventTypeCommitReport            = "commit_report"
	EventTypeAddAuthorizedMembers    = "add_authorized_members"
	EventTypeRemoveAuthorizedMembers = "remove_authorized_members"
	EventTypeUpdateSaleLevel         = "update_sale_level"
	EventTypeCommitComputingPower    = "commit_computing_power"
	EventTypeClaimComputingPower     = "claim_computing_power"
	EventTypeEpochPhase              = "epoch_phase"
	EventTypeBeginBlock              = "begin_block"
	EventTypeEndBlock                = "end_block"

	AttributeKeyEpochID              = "epoch_id"
	AttributeKeyNodeID               = "node_id"
	AttributeKeyDivisionID           = "division_id"
	AttributeKeyReceiver             = "receiver"
	AttributeKeyOwner                = "owner"
	AttributeKeyReportType           = "report_type"
	AttributeKeyAuthorizedMember     = "authorized_member"
	AttributeKeyComputingPower       = "computing_power"
	AttributeKeyComputingPowerBefore = "computing_power_before"
	AttributeKeyComputingPowerAfter  = "computing_power_after"
	AttributeKeySaleLevelBefore      = "sale_level_before"
	AttributeKeySaleLevelAfter       = "sale_level_after"

	AttributeValueCategory = ModuleName
)
View Source 
const (
	LevelOne = iota + 1
	LevelTwo
	LevelThree
	LevelFour
	LevelFive
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "captains"

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

Variables

View Source 
var (
	ErrInvalidLengthCaptains        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCaptains          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCaptains = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrDivisionExists             = errorsmod.Register(ModuleName, 2, "division already exists")
	ErrDivisionNotExists          = errorsmod.Register(ModuleName, 3, "division does not exist")
	ErrDivisionSoldOut            = errorsmod.Register(ModuleName, 4, "division is sold out")
	ErrNodeExists                 = errorsmod.Register(ModuleName, 5, "node already exists")
	ErrUnauthorized               = errorsmod.Register(ModuleName, 6, "unauthorized address")
	ErrNodeNotExists              = errorsmod.Register(ModuleName, 7, "node does not exist")
	ErrInsufficientComputingPower = errorsmod.Register(ModuleName, 8, "insufficient experience")
	ErrInvalidSaleLevel           = errorsmod.Register(ModuleName, 9, "new sale level must be greater than the current sale level")
	ErrInvalidReport              = errorsmod.Register(ModuleName, 10, "invalid report")
)
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                        = []byte{prefixParams}
	CurrEpochKey                     = []byte{prefixCurrEpoch}
	NodeKey                          = []byte{prefixNode}
	NodeNextSequenceKey              = []byte{prefixNodeNextSeq}
	NodeByOwnerKey                   = []byte{prefixNodeByOwner}
	DivisionKey                      = []byte{prefixDivision}
	DivisionByNode                   = []byte{prefixDivisionByNode}
	EpochEmissionKey                 = []byte{prefixEpochEmission}
	GlobalClaimedEmissionKey         = []byte{prefixGlobalClaimedEmission}
	NodeClaimedEmissionKey           = []byte{prefixNodeClaimedEmission}
	NodeCumulativeEmissionByEpochKey = []byte{prefixNodeCumulativeEmissionByEpoch}
	ClaimableComputingPowerKey       = []byte{prefixClaimableComputingPower}
	GlobalComputingPowerOnEpochKey   = []byte{prefixGlobalComputingPowerOnEpoch}
	NodeComputingPowerOnEpochKey     = []byte{prefixNodeComputingPowerOnEpoch}
	GlobalPledgeOnEpochKey           = []byte{prefixGlobalPledgeOnEpoch}
	OwnerPledgeOnEpochKey            = []byte{prefixOwnerPledgeOnEpoch}
	ReportDigestOnEpochKey           = []byte{prefixReportDigestOnEpoch}
	ReportBatchOnEpochKey            = []byte{prefixReportBatchOnEpoch}
	EndOnEpochKey                    = []byte{prefixEndOnEpoch}
	StandByOverKey                   = []byte{prefixStandByOver}

	Delimiter   = []byte{0x00}
	PlaceHolder = []byte{0x01}
)
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 (
	ErrInvalidLengthReport        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReport          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReport = 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 ReportType_name = map[int32]string{
	0: "REPORT_TYPE_UNSPECIFIED",
	1: "REPORT_TYPE_DIGEST",
	2: "REPORT_TYPE_BATCH",
	3: "REPORT_TYPE_END",
}
View Source 
var ReportType_value = map[string]int32{
	"REPORT_TYPE_UNSPECIFIED": 0,
	"REPORT_TYPE_DIGEST":      1,
	"REPORT_TYPE_BATCH":       2,
	"REPORT_TYPE_END":         3,
}

Functions

func ClaimableComputingPowerStoreKey 

func ClaimableComputingPowerStoreKey(owner sdk.AccAddress) []byte

ClaimableComputingPowerStoreKey returns the byte representation of claimable computing power key Items are stored with the following key: values <prefix_key><owner> -> <computing_power>

func DivisionByNodeStoreKey 

func DivisionByNodeStoreKey(divisionID, nodeID string) []byte

DivisionByNodeStoreKey returns the byte representation of the division by node key Items are stored with the following key: values <prefix_key><division_id><delimiter><node_id> -> <place_holder>

func DivisionStoreKey 

func DivisionStoreKey(divisionID string) []byte

DivisionStoreKey returns the byte representation of the divisions key Items are stored with the following key: values <prefix_key><division_id> -> <divisions_info_bz>

func EndOnEpochStoreKey 

func EndOnEpochStoreKey(epochID uint64) []byte

EndOnEpochStoreKey returns the byte representation of the end on epoch key Items are stored with the following key: values <prefix_key><epoch_id> -> <end>

func EpochEmissionStoreKey 

func EpochEmissionStoreKey(epochID uint64) []byte

EpochEmissionStoreKey returns the byte representation of the emission sum on epoch key Items are stored with the following key: values <prefix_key><epoch_id> -> <emission>

func GenDivisionsId 

func GenDivisionsId(level int) string

func GlobalComputingPowerOnEpochStoreKey 

func GlobalComputingPowerOnEpochStoreKey(epochID uint64) []byte

GlobalComputingPowerOnEpochStoreKey returns the byte representation of the computing power sum on epoch key Items are stored with the following key: values <prefix_key><epoch_id> -> <computing_power>

func GlobalPledgeOnEpochStoreKey 

func GlobalPledgeOnEpochStoreKey(epochID uint64) []byte

GlobalPledgeOnEpochStoreKey returns the byte representation of the pledge amount sum on epoch key Items are stored with the following key: values <prefix_key><epoch_id> -> <pledge_amount>

func NodeByOwnerPrefixStoreKey 

func NodeByOwnerPrefixStoreKey(owner sdk.AccAddress) []byte

NodeByOwnerPrefixStoreKey returns the byte representation of the node by owner prefix key Items are stored with the following key <prefix_key><owner><delimiter>

func NodeByOwnerStoreKey 

func NodeByOwnerStoreKey(owner sdk.AccAddress, nodeID string) []byte

NodeByOwnerStoreKey returns the byte representation of the node owner Items are stored with the following key: values <prefix_key><owner><delimiter><node_id> -> <place_holder>

func NodeClaimedEmissionStoreKey 

func NodeClaimedEmissionStoreKey(nodeID string) []byte

NodeClaimedEmissionStoreKey returns the byte representation of the historical emission last claimed key Items are stored with the following key: values <prefix_key><node_id> -> <emission>

func NodeComputingPowerOnEpochStoreKey 

func NodeComputingPowerOnEpochStoreKey(epochID uint64, nodeID string) []byte

NodeComputingPowerOnEpochStoreKey returns the byte representation of the computing power by node on epoch key Items are stored with the following key: values <prefix_key><node_id><delimiter><epoch_id> -> <computing_power>

func NodeCumulativeEmissionByEpochStoreKey 

func NodeCumulativeEmissionByEpochStoreKey(epochID uint64, nodeID string) []byte

NodeCumulativeEmissionByEpochStoreKey returns the byte representation of cumulative emission by node on epoch key Items are stored with the following key: values <prefix_key><epoch_id><delimiter><node_id> -> <emission>

func NodeStoreKey 

func NodeStoreKey(nodeID string) []byte

NodeStoreKey returns the byte representation of the node key Items are stored with the following key: values <prefix_key><node_id> -> <node_info_bz>

func OwnerPledgeOnEpochStoreKey 

func OwnerPledgeOnEpochStoreKey(owner sdk.AccAddress, epochID uint64) []byte

OwnerPledgeOnEpochStoreKey returns the byte representation of the owner pledge on epoch key <prefix_key><epoch_id><delimiter><owner> -> <pledge>

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ReportBatchOnEpochPrefixStoreKey 

func ReportBatchOnEpochPrefixStoreKey(epochID uint64) []byte

ReportBatchOnEpochPrefixStoreKey returns the byte representation of the report batch on epoch prefix key <prefix_key><epoch_id>

func ReportBatchOnEpochStoreKey 

func ReportBatchOnEpochStoreKey(epochID, batchID uint64) []byte

ReportBatchOnEpochStoreKey returns the byte representation of the report batch on epoch key <prefix_key><epoch_id><delimiter><batch_id> -> <node_count_this_batch>

func ReportDigestOnEpochStoreKey 

func ReportDigestOnEpochStoreKey(epochID uint64) []byte

ReportDigestOnEpochStoreKey returns the byte representation of the digest on epoch key <prefix_key><epoch_id> -> <digest>

func SplitEpochAndStrFromStoreKey 

func SplitEpochAndStrFromStoreKey(prefix, key []byte) (uint64, string)

SplitEpochAndStrFromStoreKey splits the epoch and string from store key, for example: <prefix><epoch_id><delimiter><string> -> <epoch_id> + <string>

func SplitEpochFromStoreKey 

func SplitEpochFromStoreKey(prefix, key []byte) uint64

SplitEpochFromStoreKey splits the epoch from the store key, for example: <prefix><epoch_id> -> <epoch_id>

func SplitNodeAndEpochFromStoreKey 

func SplitNodeAndEpochFromStoreKey(prefix, key []byte) (string, uint64)

SplitNodeAndEpochFromStoreKey splits the node and epoch from store key, for example: <prefix><node_id><delimiter><epoch_id> -> <node_id> + <epoch_id>

func SplitStrFromStoreKey 

func SplitStrFromStoreKey(prefix, key []byte) string

SplitStrFromStoreKey splits the string from the store key, for example: <prefix><string> -> <string>

Types

type BaseState 

type BaseState struct {
	// id of the epoch
	EpochId uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// whether the epoch is ended
	IsEpochEnd bool `protobuf:"varint,2,opt,name=is_epoch_end,json=isEpochEnd,proto3" json:"is_epoch_end,omitempty"`
	// the next node sequence
	NextNodeSequence uint64 `protobuf:"varint,3,opt,name=next_node_sequence,json=nextNodeSequence,proto3" json:"next_node_sequence,omitempty"`
	// global claimed emission
	GlobalClaimedEmission github_com_cosmos_cosmos_sdk_types.Dec `` /* 166-byte string literal not displayed */
	// the digest of the report
	ReportDigest *ReportDigest `protobuf:"bytes,5,opt,name=report_digest,json=reportDigest,proto3" json:"report_digest,omitempty"`
	// is in epoch stand_by phase
	IsStandBy bool `protobuf:"varint,6,opt,name=is_stand_by,json=isStandBy,proto3" json:"is_stand_by,omitempty"`
}

EpochState defines the state of the epoch

func DefaultBaseState 

func DefaultBaseState() BaseState

DefaultBaseState returns a default BaseState

func (*BaseState) Descriptor 

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

func (*BaseState) GetEpochId 

func (m *BaseState) GetEpochId() uint64

func (*BaseState) GetIsEpochEnd 

func (m *BaseState) GetIsEpochEnd() bool

func (*BaseState) GetIsStandBy 

func (m *BaseState) GetIsStandBy() bool

func (*BaseState) GetNextNodeSequence 

func (m *BaseState) GetNextNodeSequence() uint64

func (*BaseState) GetReportDigest 

func (m *BaseState) GetReportDigest() *ReportDigest

func (*BaseState) Marshal 

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

func (*BaseState) MarshalTo 

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

func (*BaseState) MarshalToSizedBuffer 

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

func (*BaseState) ProtoMessage 

func (*BaseState) ProtoMessage()

func (*BaseState) Reset 

func (m *BaseState) Reset()

func (*BaseState) Size 

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

func (*BaseState) String 

func (m *BaseState) String() string

func (*BaseState) Unmarshal 

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

func (*BaseState) XXX_DiscardUnknown 

func (m *BaseState) XXX_DiscardUnknown()

func (*BaseState) XXX_Marshal 

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

func (*BaseState) XXX_Merge 

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

func (*BaseState) XXX_Size 

func (m *BaseState) XXX_Size() int

func (*BaseState) XXX_Unmarshal 

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

type BatchBase 

type BatchBase struct {
	// batch_id is the batch id of the report
	BatchId uint64 `protobuf:"varint,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// node_count is the number of nodes in the batch
	Count uint64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

BaseBatch is the base batch message.

func (*BatchBase) Descriptor 

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

func (*BatchBase) GetBatchId 

func (m *BatchBase) GetBatchId() uint64

func (*BatchBase) GetCount 

func (m *BatchBase) GetCount() uint64

func (*BatchBase) Marshal 

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

func (*BatchBase) MarshalTo 

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

func (*BatchBase) MarshalToSizedBuffer 

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

func (*BatchBase) ProtoMessage 

func (*BatchBase) ProtoMessage()

func (*BatchBase) Reset 

func (m *BatchBase) Reset()

func (*BatchBase) Size 

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

func (*BatchBase) String 

func (m *BatchBase) String() string

func (*BatchBase) Unmarshal 

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

func (*BatchBase) XXX_DiscardUnknown 

func (m *BatchBase) XXX_DiscardUnknown()

func (*BatchBase) XXX_Marshal 

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

func (*BatchBase) XXX_Merge 

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

func (*BatchBase) XXX_Size 

func (m *BatchBase) XXX_Size() int

func (*BatchBase) XXX_Unmarshal 

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

type ClaimableComputingPower 

type ClaimableComputingPower struct {
	Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	Owner  string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
}

func (*ClaimableComputingPower) Descriptor 

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

func (*ClaimableComputingPower) GetAmount 

func (m *ClaimableComputingPower) GetAmount() uint64

func (*ClaimableComputingPower) GetOwner 

func (m *ClaimableComputingPower) GetOwner() string

func (*ClaimableComputingPower) Marshal 

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

func (*ClaimableComputingPower) MarshalTo 

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

func (*ClaimableComputingPower) MarshalToSizedBuffer 

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

func (*ClaimableComputingPower) ProtoMessage 

func (*ClaimableComputingPower) ProtoMessage()

func (*ClaimableComputingPower) Reset 

func (m *ClaimableComputingPower) Reset()

func (*ClaimableComputingPower) Size 

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

func (*ClaimableComputingPower) String 

func (m *ClaimableComputingPower) String() string

func (*ClaimableComputingPower) Unmarshal 

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

func (*ClaimableComputingPower) XXX_DiscardUnknown 

func (m *ClaimableComputingPower) XXX_DiscardUnknown()

func (*ClaimableComputingPower) XXX_Marshal 

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

func (*ClaimableComputingPower) XXX_Merge 

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

func (*ClaimableComputingPower) XXX_Size 

func (m *ClaimableComputingPower) XXX_Size() int

func (*ClaimableComputingPower) XXX_Unmarshal 

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

type Division 

type Division struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// level defines the level of the node.
	Level uint64 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	// initial_supply defines the initial supply of the node in the division.
	InitialSupply uint64 `protobuf:"varint,3,opt,name=initial_supply,json=initialSupply,proto3" json:"initial_supply,omitempty"`
	// sold_count defines the total count of the node in the division.
	SoldCount uint64 `protobuf:"varint,4,opt,name=sold_count,json=soldCount,proto3" json:"sold_count,omitempty"`
	// total_count defines the supply count of nodes in the division.
	TotalCount uint64 `protobuf:"varint,5,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// computing_power_lower_bound defines the low bound of computing power in the division.
	ComputingPowerLowerBound uint64 `` /* 138-byte string literal not displayed */
	// computing_power_upper_bound defines the upper bound of computing power in the division.
	ComputingPowerUpperBound uint64 `` /* 138-byte string literal not displayed */
}

Division defines the division a node belongs to.

func DefaultDivision 

func DefaultDivision() []Division

DefaultDivision returns a default Division

func (*Division) Descriptor 

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

func (*Division) GetComputingPowerLowerBound 

func (m *Division) GetComputingPowerLowerBound() uint64

func (*Division) GetComputingPowerUpperBound 

func (m *Division) GetComputingPowerUpperBound() uint64

func (*Division) GetId 

func (m *Division) GetId() string

func (*Division) GetInitialSupply 

func (m *Division) GetInitialSupply() uint64

func (*Division) GetLevel 

func (m *Division) GetLevel() uint64

func (*Division) GetSoldCount 

func (m *Division) GetSoldCount() uint64

func (*Division) GetTotalCount 

func (m *Division) GetTotalCount() uint64

func (*Division) Marshal 

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

func (*Division) MarshalTo 

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

func (*Division) MarshalToSizedBuffer 

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

func (*Division) ProtoMessage 

func (*Division) ProtoMessage()

func (*Division) Reset 

func (m *Division) Reset()

func (*Division) Size 

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

func (*Division) String 

func (m *Division) String() string

func (*Division) Unmarshal 

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

func (*Division) XXX_DiscardUnknown 

func (m *Division) XXX_DiscardUnknown()

func (*Division) XXX_Marshal 

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

func (*Division) XXX_Merge 

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

func (*Division) XXX_Size 

func (m *Division) XXX_Size() int

func (*Division) XXX_Unmarshal 

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

type EpochEmission 

type EpochEmission struct {
	EpochId  uint64                                 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Emission github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=emission,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"emission"`
}

func (*EpochEmission) Descriptor 

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

func (*EpochEmission) GetEpochId 

func (m *EpochEmission) GetEpochId() uint64

func (*EpochEmission) Marshal 

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

func (*EpochEmission) MarshalTo 

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

func (*EpochEmission) MarshalToSizedBuffer 

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

func (*EpochEmission) ProtoMessage 

func (*EpochEmission) ProtoMessage()

func (*EpochEmission) Reset 

func (m *EpochEmission) Reset()

func (*EpochEmission) Size 

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

func (*EpochEmission) String 

func (m *EpochEmission) String() string

func (*EpochEmission) Unmarshal 

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

func (*EpochEmission) XXX_DiscardUnknown 

func (m *EpochEmission) XXX_DiscardUnknown()

func (*EpochEmission) XXX_Marshal 

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

func (*EpochEmission) XXX_Merge 

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

func (*EpochEmission) XXX_Size 

func (m *EpochEmission) XXX_Size() int

func (*EpochEmission) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params stores all the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// base_state stores the current epoch state.
	BaseState BaseState `protobuf:"bytes,2,opt,name=base_state,json=baseState,proto3" json:"base_state"`
	// divisions stores all divisions base info.
	Divisions []Division `protobuf:"bytes,3,rep,name=divisions,proto3" json:"divisions"`
	// nodes stores all nodes base info.
	Nodes []Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes"`
	// emission
	EpochesEmission         []EpochEmission          `protobuf:"bytes,5,rep,name=epoches_emission,json=epochesEmission,proto3" json:"epoches_emission"`
	NodesClaimedEmission    []NodeClaimedEmission    `protobuf:"bytes,6,rep,name=nodes_claimed_emission,json=nodesClaimedEmission,proto3" json:"nodes_claimed_emission"`
	NodesCumulativeEmission []NodeCumulativeEmission `protobuf:"bytes,7,rep,name=nodes_cumulative_emission,json=nodesCumulativeEmission,proto3" json:"nodes_cumulative_emission"`
	// pledge
	GlobalsPledge []GlobalPledge `protobuf:"bytes,8,rep,name=globals_pledge,json=globalsPledge,proto3" json:"globals_pledge"`
	OwnersPledge  []OwnerPledge  `protobuf:"bytes,9,rep,name=owners_pledge,json=ownersPledge,proto3" json:"owners_pledge"`
	// computing powers infos.
	OwnersClaimableComputingPower []ClaimableComputingPower `` /* 143-byte string literal not displayed */
	GlobalsComputingPower         []GlobalComputingPower    `protobuf:"bytes,11,rep,name=globals_computing_power,json=globalsComputingPower,proto3" json:"globals_computing_power"`
	NodesComputingPower           []NodesComputingPower     `protobuf:"bytes,12,rep,name=nodes_computing_power,json=nodesComputingPower,proto3" json:"nodes_computing_power"`
	// batches
	Batches []BatchBase `protobuf:"bytes,13,rep,name=batches,proto3" json:"batches"`
}

GenesisState defines the module's genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState gets raw genesis raw message for testing

func NewGenesisState 

func NewGenesisState(
	params Params,
	baseState BaseState,
	divisions []Division,
	nodes []Node,
	epochesEmission []EpochEmission,
	nodesClaimedEmission []NodeClaimedEmission,
	nodesCumulativeEmission []NodeCumulativeEmission,
	globalsPledge []GlobalPledge,
	ownersPledge []OwnerPledge,
	ownersClaimableComputingPower []ClaimableComputingPower,
	globalsComputingPower []GlobalComputingPower,
	nodesComputingPower []NodesComputingPower,
	batches []BatchBase,
) *GenesisState

NewGenesisState constructs a GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetBaseState 

func (m *GenesisState) GetBaseState() BaseState

func (*GenesisState) GetBatches 

func (m *GenesisState) GetBatches() []BatchBase

func (*GenesisState) GetDivisions 

func (m *GenesisState) GetDivisions() []Division

func (*GenesisState) GetEpochesEmission 

func (m *GenesisState) GetEpochesEmission() []EpochEmission

func (*GenesisState) GetGlobalsComputingPower 

func (m *GenesisState) GetGlobalsComputingPower() []GlobalComputingPower

func (*GenesisState) GetGlobalsPledge 

func (m *GenesisState) GetGlobalsPledge() []GlobalPledge

func (*GenesisState) GetNodes 

func (m *GenesisState) GetNodes() []Node

func (*GenesisState) GetNodesClaimedEmission 

func (m *GenesisState) GetNodesClaimedEmission() []NodeClaimedEmission

func (*GenesisState) GetNodesComputingPower 

func (m *GenesisState) GetNodesComputingPower() []NodesComputingPower

func (*GenesisState) GetNodesCumulativeEmission 

func (m *GenesisState) GetNodesCumulativeEmission() []NodeCumulativeEmission

func (*GenesisState) GetOwnersClaimableComputingPower 

func (m *GenesisState) GetOwnersClaimableComputingPower() []ClaimableComputingPower

func (*GenesisState) GetOwnersPledge 

func (m *GenesisState) GetOwnersPledge() []OwnerPledge

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) Validate 

func (gs *GenesisState) Validate() error

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

func (*GenesisState) ValidateBaseState 

func (gs *GenesisState) ValidateBaseState() error

ValidateBaseState performs basic base state validation returning an error upon any.

func (*GenesisState) ValidateBatches 

func (gs *GenesisState) ValidateBatches() error

ValidateBatches performs basic batches validation returning an error upon any.

func (*GenesisState) ValidateDivisions 

func (gs *GenesisState) ValidateDivisions() (map[string]uint64, error)

ValidateDivisions performs basic divisions validation returning an error upon any.

func (*GenesisState) ValidateEpochEmission 

func (gs *GenesisState) ValidateEpochEmission() error

ValidateEpochEmission performs basic epoch emission validation returning an error upon any.

func (*GenesisState) ValidateGlobalsComputingPower 

func (gs *GenesisState) ValidateGlobalsComputingPower() error

ValidateGlobalsComputingPower performs basic globals computing power validation returning an error upon any.

func (*GenesisState) ValidateGlobalsPledge 

func (gs *GenesisState) ValidateGlobalsPledge() error

ValidateGlobalsPledge performs basic globals pledge validation returning an error upon any. NOTE: no need to validate pledge amount as it can be zero.

func (*GenesisState) ValidateNodes 

func (gs *GenesisState) ValidateNodes(divIdMap map[string]uint64) (map[string]bool, error)

ValidateNodes performs basic nodes validation returning an error upon any.

func (*GenesisState) ValidateNodesClaimedEmission 

func (gs *GenesisState) ValidateNodesClaimedEmission(nodesMap map[string]bool) error

ValidateNodesClaimedEmission performs basic nodes claimed emission validation returning an error upon any.

func (*GenesisState) ValidateNodesComputingPower 

func (gs *GenesisState) ValidateNodesComputingPower() error

ValidateNodesComputingPower performs basic nodes computing power validation returning an error upon any. NOTE: no need to validate computing power amount as it can be zero.

func (*GenesisState) ValidateNodesCumulativeEmission 

func (gs *GenesisState) ValidateNodesCumulativeEmission(nodesMap map[string]bool) error

ValidateNodesCumulativeEmission performs basic nodes cumulative emission validation returning an error upon any.

func (*GenesisState) ValidateOwnersClaimableComputingPower 

func (gs *GenesisState) ValidateOwnersClaimableComputingPower() error

ValidateOwnersClaimableComputingPower performs basic owners claimable computing power validation returning an error upon any.

func (*GenesisState) ValidateOwnersPledge 

func (gs *GenesisState) ValidateOwnersPledge() error

ValidateOwnersPledge performs basic owners pledge validation returning an error upon any.

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 GlobalComputingPower 

type GlobalComputingPower struct {
	EpochId uint64                                 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Amount  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"amount"`
}

func (*GlobalComputingPower) Descriptor 

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

func (*GlobalComputingPower) GetEpochId 

func (m *GlobalComputingPower) GetEpochId() uint64

func (*GlobalComputingPower) Marshal 

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

func (*GlobalComputingPower) MarshalTo 

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

func (*GlobalComputingPower) MarshalToSizedBuffer 

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

func (*GlobalComputingPower) ProtoMessage 

func (*GlobalComputingPower) ProtoMessage()

func (*GlobalComputingPower) Reset 

func (m *GlobalComputingPower) Reset()

func (*GlobalComputingPower) Size 

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

func (*GlobalComputingPower) String 

func (m *GlobalComputingPower) String() string

func (*GlobalComputingPower) Unmarshal 

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

func (*GlobalComputingPower) XXX_DiscardUnknown 

func (m *GlobalComputingPower) XXX_DiscardUnknown()

func (*GlobalComputingPower) XXX_Marshal 

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

func (*GlobalComputingPower) XXX_Merge 

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

func (*GlobalComputingPower) XXX_Size 

func (m *GlobalComputingPower) XXX_Size() int

func (*GlobalComputingPower) XXX_Unmarshal 

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

type GlobalPledge 

type GlobalPledge struct {
	EpochId uint64                                 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Amount  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"amount"`
}

func (*GlobalPledge) Descriptor 

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

func (*GlobalPledge) GetEpochId 

func (m *GlobalPledge) GetEpochId() uint64

func (*GlobalPledge) Marshal 

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

func (*GlobalPledge) MarshalTo 

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

func (*GlobalPledge) MarshalToSizedBuffer 

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

func (*GlobalPledge) ProtoMessage 

func (*GlobalPledge) ProtoMessage()

func (*GlobalPledge) Reset 

func (m *GlobalPledge) Reset()

func (*GlobalPledge) Size 

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

func (*GlobalPledge) String 

func (m *GlobalPledge) String() string

func (*GlobalPledge) Unmarshal 

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

func (*GlobalPledge) XXX_DiscardUnknown 

func (m *GlobalPledge) XXX_DiscardUnknown()

func (*GlobalPledge) XXX_Marshal 

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

func (*GlobalPledge) XXX_Merge 

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

func (*GlobalPledge) XXX_Size 

func (m *GlobalPledge) XXX_Size() int

func (*GlobalPledge) XXX_Unmarshal 

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

type MsgAddAuthorizedMembers 

type MsgAddAuthorizedMembers struct {
	Authority string   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Members   []string `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
}

MsgAddAuthorizedMembers defines the Msg/AddAuthorizedMembers request type.

func NewAddAuthorizedMembers 

func NewAddAuthorizedMembers(authority string, members []string) *MsgAddAuthorizedMembers

NewAddAuthorizedMembers creates a new MsgAddAuthorizedMembers instance

func (*MsgAddAuthorizedMembers) Descriptor 

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

func (*MsgAddAuthorizedMembers) GetSigners 

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

GetSigners Implements Msg.

func (*MsgAddAuthorizedMembers) Marshal 

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

func (*MsgAddAuthorizedMembers) MarshalTo 

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

func (*MsgAddAuthorizedMembers) MarshalToSizedBuffer 

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

func (*MsgAddAuthorizedMembers) ProtoMessage 

func (*MsgAddAuthorizedMembers) ProtoMessage()

func (*MsgAddAuthorizedMembers) Reset 

func (m *MsgAddAuthorizedMembers) Reset()

func (*MsgAddAuthorizedMembers) Size 

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

func (*MsgAddAuthorizedMembers) String 

func (m *MsgAddAuthorizedMembers) String() string

func (*MsgAddAuthorizedMembers) Unmarshal 

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

func (*MsgAddAuthorizedMembers) ValidateBasic 

func (msg *MsgAddAuthorizedMembers) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgAddAuthorizedMembers) XXX_DiscardUnknown 

func (m *MsgAddAuthorizedMembers) XXX_DiscardUnknown()

func (*MsgAddAuthorizedMembers) XXX_Marshal 

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

func (*MsgAddAuthorizedMembers) XXX_Merge 

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

func (*MsgAddAuthorizedMembers) XXX_Size 

func (m *MsgAddAuthorizedMembers) XXX_Size() int

func (*MsgAddAuthorizedMembers) XXX_Unmarshal 

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

type MsgAddAuthorizedMembersResponse 

type MsgAddAuthorizedMembersResponse struct {
}

MsgAddAuthorizedMemberResponse defines the Msg/AddAuthorizedMemberResponse response type.

func (*MsgAddAuthorizedMembersResponse) Descriptor 

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

func (*MsgAddAuthorizedMembersResponse) Marshal 

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

func (*MsgAddAuthorizedMembersResponse) MarshalTo 

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

func (*MsgAddAuthorizedMembersResponse) MarshalToSizedBuffer 

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

func (*MsgAddAuthorizedMembersResponse) ProtoMessage 

func (*MsgAddAuthorizedMembersResponse) ProtoMessage()

func (*MsgAddAuthorizedMembersResponse) Reset 

func (m *MsgAddAuthorizedMembersResponse) Reset()

func (*MsgAddAuthorizedMembersResponse) Size 

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

func (*MsgAddAuthorizedMembersResponse) String 

func (m *MsgAddAuthorizedMembersResponse) String() string

func (*MsgAddAuthorizedMembersResponse) Unmarshal 

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

func (*MsgAddAuthorizedMembersResponse) XXX_DiscardUnknown 

func (m *MsgAddAuthorizedMembersResponse) XXX_DiscardUnknown()

func (*MsgAddAuthorizedMembersResponse) XXX_Marshal 

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

func (*MsgAddAuthorizedMembersResponse) XXX_Merge 

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

func (*MsgAddAuthorizedMembersResponse) XXX_Size 

func (m *MsgAddAuthorizedMembersResponse) XXX_Size() int

func (*MsgAddAuthorizedMembersResponse) XXX_Unmarshal 

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

type MsgClaimComputingPower 

type MsgClaimComputingPower struct {
	Sender               string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	ComputingPowerAmount uint64 `protobuf:"varint,2,opt,name=computing_power_amount,json=computingPowerAmount,proto3" json:"computing_power_amount,omitempty"`
	NodeId               string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

MsgClaimComputingPower defines the Msg/ClaimComputingPower request type.

func NewMsgWithdrawComputingPower 

func NewMsgWithdrawComputingPower(nodeId string, computingPowerAmount uint64, sender string) *MsgClaimComputingPower

func (*MsgClaimComputingPower) Descriptor 

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

func (*MsgClaimComputingPower) GetSigners 

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

GetSigners Implements Msg.

func (*MsgClaimComputingPower) Marshal 

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

func (*MsgClaimComputingPower) MarshalTo 

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

func (*MsgClaimComputingPower) MarshalToSizedBuffer 

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

func (*MsgClaimComputingPower) ProtoMessage 

func (*MsgClaimComputingPower) ProtoMessage()

func (*MsgClaimComputingPower) Reset 

func (m *MsgClaimComputingPower) Reset()

func (*MsgClaimComputingPower) Size 

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

func (*MsgClaimComputingPower) String 

func (m *MsgClaimComputingPower) String() string

func (*MsgClaimComputingPower) Unmarshal 

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

func (*MsgClaimComputingPower) ValidateBasic 

func (msg *MsgClaimComputingPower) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgClaimComputingPower) XXX_DiscardUnknown 

func (m *MsgClaimComputingPower) XXX_DiscardUnknown()

func (*MsgClaimComputingPower) XXX_Marshal 

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

func (*MsgClaimComputingPower) XXX_Merge 

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

func (*MsgClaimComputingPower) XXX_Size 

func (m *MsgClaimComputingPower) XXX_Size() int

func (*MsgClaimComputingPower) XXX_Unmarshal 

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

type MsgClaimComputingPowerResponse 

type MsgClaimComputingPowerResponse struct {
}

MsgClaimComputingPowerResponse defines the Msg/ClaimComputingPowerResponse response type.

func (*MsgClaimComputingPowerResponse) Descriptor 

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

func (*MsgClaimComputingPowerResponse) Marshal 

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

func (*MsgClaimComputingPowerResponse) MarshalTo 

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

func (*MsgClaimComputingPowerResponse) MarshalToSizedBuffer 

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

func (*MsgClaimComputingPowerResponse) ProtoMessage 

func (*MsgClaimComputingPowerResponse) ProtoMessage()

func (*MsgClaimComputingPowerResponse) Reset 

func (m *MsgClaimComputingPowerResponse) Reset()

func (*MsgClaimComputingPowerResponse) Size 

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

func (*MsgClaimComputingPowerResponse) String 

func (m *MsgClaimComputingPowerResponse) String() string

func (*MsgClaimComputingPowerResponse) Unmarshal 

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

func (*MsgClaimComputingPowerResponse) XXX_DiscardUnknown 

func (m *MsgClaimComputingPowerResponse) XXX_DiscardUnknown()

func (*MsgClaimComputingPowerResponse) XXX_Marshal 

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

func (*MsgClaimComputingPowerResponse) XXX_Merge 

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

func (*MsgClaimComputingPowerResponse) XXX_Size 

func (m *MsgClaimComputingPowerResponse) XXX_Size() int

func (*MsgClaimComputingPowerResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// UpdateParams updates the module params.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	// CreateCaptainNode creates a captain node and assign it to the owner.
	CreateCaptainNode(ctx context.Context, in *MsgCreateCaptainNode, opts ...grpc.CallOption) (*MsgCreateCaptainNodeResponse, error)
	// CommitReport commits the running state report of captain nodes
	CommitReport(ctx context.Context, in *MsgCommitReport, opts ...grpc.CallOption) (*MsgCommitReportResponse, error)
	// AddAuthorizedMembers adds authorized members allowed to access permission interface.
	AddAuthorizedMembers(ctx context.Context, in *MsgAddAuthorizedMembers, opts ...grpc.CallOption) (*MsgAddAuthorizedMembersResponse, error)
	// RemoveAuthorizedMembers removes authorized members.
	RemoveAuthorizedMembers(ctx context.Context, in *MsgRemoveAuthorizedMembers, opts ...grpc.CallOption) (*MsgRemoveAuthorizedMembersResponse, error)
	// UpdateSaleLevel updates CurrentLevelForSale in module params.
	UpdateSaleLevel(ctx context.Context, in *MsgUpdateSaleLevel, opts ...grpc.CallOption) (*MsgUpdateSaleLevelResponse, error)
	// CommitComputingPower assign pending computing power reward to users for later claiming.
	CommitComputingPower(ctx context.Context, in *MsgCommitComputingPower, opts ...grpc.CallOption) (*MsgCommitComputingPowerResponse, error)
	// ClaimComputingPower allows captain node owner to claim and increase node's computing power.
	ClaimComputingPower(ctx context.Context, in *MsgClaimComputingPower, opts ...grpc.CallOption) (*MsgClaimComputingPowerResponse, 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 MsgCommitComputingPower 

type MsgCommitComputingPower struct {
	// sender is the address of the owner of nft
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// computing_power_rewards is the extractable computing powers to reward.
	ComputingPowerRewards []ClaimableComputingPower `protobuf:"bytes,2,rep,name=computing_power_rewards,json=computingPowerRewards,proto3" json:"computing_power_rewards"`
}

MsgCommitComputingPower defines the Msg/CommitComputingPowerResponse request type.

func NewMsgCommitComputingPower 

func NewMsgCommitComputingPower(
	rewards []ClaimableComputingPower,
	authority string,
) *MsgCommitComputingPower

func (*MsgCommitComputingPower) Descriptor 

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

func (*MsgCommitComputingPower) GetSigners 

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

GetSigners Implements Msg.

func (*MsgCommitComputingPower) Marshal 

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

func (*MsgCommitComputingPower) MarshalTo 

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

func (*MsgCommitComputingPower) MarshalToSizedBuffer 

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

func (*MsgCommitComputingPower) ProtoMessage 

func (*MsgCommitComputingPower) ProtoMessage()

func (*MsgCommitComputingPower) Reset 

func (m *MsgCommitComputingPower) Reset()

func (*MsgCommitComputingPower) Size 

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

func (*MsgCommitComputingPower) String 

func (m *MsgCommitComputingPower) String() string

func (*MsgCommitComputingPower) Unmarshal 

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

func (*MsgCommitComputingPower) ValidateBasic 

func (msg *MsgCommitComputingPower) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgCommitComputingPower) XXX_DiscardUnknown 

func (m *MsgCommitComputingPower) XXX_DiscardUnknown()

func (*MsgCommitComputingPower) XXX_Marshal 

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

func (*MsgCommitComputingPower) XXX_Merge 

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

func (*MsgCommitComputingPower) XXX_Size 

func (m *MsgCommitComputingPower) XXX_Size() int

func (*MsgCommitComputingPower) XXX_Unmarshal 

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

type MsgCommitComputingPowerResponse 

type MsgCommitComputingPowerResponse struct {
}

MsgCommitComputingPowerResponse defines the Msg/CommitComputingPowerResponse response type.

func (*MsgCommitComputingPowerResponse) Descriptor 

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

func (*MsgCommitComputingPowerResponse) Marshal 

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

func (*MsgCommitComputingPowerResponse) MarshalTo 

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

func (*MsgCommitComputingPowerResponse) MarshalToSizedBuffer 

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

func (*MsgCommitComputingPowerResponse) ProtoMessage 

func (*MsgCommitComputingPowerResponse) ProtoMessage()

func (*MsgCommitComputingPowerResponse) Reset 

func (m *MsgCommitComputingPowerResponse) Reset()

func (*MsgCommitComputingPowerResponse) Size 

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

func (*MsgCommitComputingPowerResponse) String 

func (m *MsgCommitComputingPowerResponse) String() string

func (*MsgCommitComputingPowerResponse) Unmarshal 

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

func (*MsgCommitComputingPowerResponse) XXX_DiscardUnknown 

func (m *MsgCommitComputingPowerResponse) XXX_DiscardUnknown()

func (*MsgCommitComputingPowerResponse) XXX_Marshal 

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

func (*MsgCommitComputingPowerResponse) XXX_Merge 

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

func (*MsgCommitComputingPowerResponse) XXX_Size 

func (m *MsgCommitComputingPowerResponse) XXX_Size() int

func (*MsgCommitComputingPowerResponse) XXX_Unmarshal 

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

type MsgCommitReport 

type MsgCommitReport struct {
	Authority  string     `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	ReportType ReportType `protobuf:"varint,2,opt,name=report_type,json=reportType,proto3,enum=tabi.captains.v1.ReportType" json:"report_type,omitempty"`
	Report     *types.Any `protobuf:"bytes,3,opt,name=report,proto3" json:"report,omitempty"`
}

MsgCommitReport is the Msg/CommitReport request type.

func NewMsgCommitReport 

func NewMsgCommitReport(authority string, reportType ReportType, report any) (*MsgCommitReport, error)

NewMsgCommitReport creates a new MsgCommitReport instance report: interface of *ReportDigest, *ReportBatch, *ReportEnd

func (*MsgCommitReport) Descriptor 

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

func (*MsgCommitReport) GetSigners 

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

GetSigners Implements Msg.

func (*MsgCommitReport) Marshal 

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

func (*MsgCommitReport) MarshalTo 

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

func (*MsgCommitReport) MarshalToSizedBuffer 

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

func (*MsgCommitReport) ProtoMessage 

func (*MsgCommitReport) ProtoMessage()

func (*MsgCommitReport) Reset 

func (m *MsgCommitReport) Reset()

func (*MsgCommitReport) Size 

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

func (*MsgCommitReport) String 

func (m *MsgCommitReport) String() string

func (*MsgCommitReport) Unmarshal 

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

func (*MsgCommitReport) ValidateBasic 

func (msg *MsgCommitReport) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgCommitReport) XXX_DiscardUnknown 

func (m *MsgCommitReport) XXX_DiscardUnknown()

func (*MsgCommitReport) XXX_Marshal 

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

func (*MsgCommitReport) XXX_Merge 

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

func (*MsgCommitReport) XXX_Size 

func (m *MsgCommitReport) XXX_Size() int

func (*MsgCommitReport) XXX_Unmarshal 

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

type MsgCommitReportResponse 

type MsgCommitReportResponse struct {
}

MsgCommitReportResponse defines the Msg/CommitReportResponse response type.

func (*MsgCommitReportResponse) Descriptor 

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

func (*MsgCommitReportResponse) Marshal 

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

func (*MsgCommitReportResponse) MarshalTo 

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

func (*MsgCommitReportResponse) MarshalToSizedBuffer 

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

func (*MsgCommitReportResponse) ProtoMessage 

func (*MsgCommitReportResponse) ProtoMessage()

func (*MsgCommitReportResponse) Reset 

func (m *MsgCommitReportResponse) Reset()

func (*MsgCommitReportResponse) Size 

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

func (*MsgCommitReportResponse) String 

func (m *MsgCommitReportResponse) String() string

func (*MsgCommitReportResponse) Unmarshal 

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

func (*MsgCommitReportResponse) XXX_DiscardUnknown 

func (m *MsgCommitReportResponse) XXX_DiscardUnknown()

func (*MsgCommitReportResponse) XXX_Marshal 

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

func (*MsgCommitReportResponse) XXX_Merge 

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

func (*MsgCommitReportResponse) XXX_Size 

func (m *MsgCommitReportResponse) XXX_Size() int

func (*MsgCommitReportResponse) XXX_Unmarshal 

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

type MsgCreateCaptainNode 

type MsgCreateCaptainNode struct {
	Authority  string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Owner      string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	DivisionId string `protobuf:"bytes,3,opt,name=division_id,json=divisionId,proto3" json:"division_id,omitempty"`
}

MsgCreateCaptainNode defines the Msg/CreateCaptainNode request type.

func NewMsgCreateCaptainNode 

func NewMsgCreateCaptainNode(authority, owner, divisionId string) *MsgCreateCaptainNode

NewMsgCreateCaptainNode creates a new MsgCreateCaptainNode instance

func (*MsgCreateCaptainNode) Descriptor 

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

func (*MsgCreateCaptainNode) GetSigners 

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

GetSigners Implements Msg.

func (*MsgCreateCaptainNode) Marshal 

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

func (*MsgCreateCaptainNode) MarshalTo 

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

func (*MsgCreateCaptainNode) MarshalToSizedBuffer 

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

func (*MsgCreateCaptainNode) ProtoMessage 

func (*MsgCreateCaptainNode) ProtoMessage()

func (*MsgCreateCaptainNode) Reset 

func (m *MsgCreateCaptainNode) Reset()

func (*MsgCreateCaptainNode) Size 

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

func (*MsgCreateCaptainNode) String 

func (m *MsgCreateCaptainNode) String() string

func (*MsgCreateCaptainNode) Unmarshal 

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

func (*MsgCreateCaptainNode) ValidateBasic 

func (msg *MsgCreateCaptainNode) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgCreateCaptainNode) XXX_DiscardUnknown 

func (m *MsgCreateCaptainNode) XXX_DiscardUnknown()

func (*MsgCreateCaptainNode) XXX_Marshal 

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

func (*MsgCreateCaptainNode) XXX_Merge 

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

func (*MsgCreateCaptainNode) XXX_Size 

func (m *MsgCreateCaptainNode) XXX_Size() int

func (*MsgCreateCaptainNode) XXX_Unmarshal 

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

type MsgCreateCaptainNodeResponse 

type MsgCreateCaptainNodeResponse struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

MsgCreateCaptainNodeResponse defines the Msg/CreateCaptainNode response type.

func (*MsgCreateCaptainNodeResponse) Descriptor 

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

func (*MsgCreateCaptainNodeResponse) Marshal 

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

func (*MsgCreateCaptainNodeResponse) MarshalTo 

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

func (*MsgCreateCaptainNodeResponse) MarshalToSizedBuffer 

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

func (*MsgCreateCaptainNodeResponse) ProtoMessage 

func (*MsgCreateCaptainNodeResponse) ProtoMessage()

func (*MsgCreateCaptainNodeResponse) Reset 

func (m *MsgCreateCaptainNodeResponse) Reset()

func (*MsgCreateCaptainNodeResponse) Size 

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

func (*MsgCreateCaptainNodeResponse) String 

func (m *MsgCreateCaptainNodeResponse) String() string

func (*MsgCreateCaptainNodeResponse) Unmarshal 

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

func (*MsgCreateCaptainNodeResponse) XXX_DiscardUnknown 

func (m *MsgCreateCaptainNodeResponse) XXX_DiscardUnknown()

func (*MsgCreateCaptainNodeResponse) XXX_Marshal 

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

func (*MsgCreateCaptainNodeResponse) XXX_Merge 

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

func (*MsgCreateCaptainNodeResponse) XXX_Size 

func (m *MsgCreateCaptainNodeResponse) XXX_Size() int

func (*MsgCreateCaptainNodeResponse) XXX_Unmarshal 

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

type MsgRemoveAuthorizedMembers 

type MsgRemoveAuthorizedMembers struct {
	Authority string   `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Members   []string `protobuf:"bytes,2,rep,name=members,proto3" json:"members,omitempty"`
}

MsgRemoveAuthorizedMembers defines the Msg/RemoveAuthorizedMembers request type.

func NewMsgRemoveAuthorizedMembers 

func NewMsgRemoveAuthorizedMembers(authority string, members []string) *MsgRemoveAuthorizedMembers

NewMsgRemoveAuthorizedMembers creates a new MsgRemoveAuthorizedMembers instance

func (*MsgRemoveAuthorizedMembers) Descriptor 

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

func (*MsgRemoveAuthorizedMembers) GetSigners 

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

GetSigners Implements Msg.

func (*MsgRemoveAuthorizedMembers) Marshal 

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

func (*MsgRemoveAuthorizedMembers) MarshalTo 

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

func (*MsgRemoveAuthorizedMembers) MarshalToSizedBuffer 

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

func (*MsgRemoveAuthorizedMembers) ProtoMessage 

func (*MsgRemoveAuthorizedMembers) ProtoMessage()

func (*MsgRemoveAuthorizedMembers) Reset 

func (m *MsgRemoveAuthorizedMembers) Reset()

func (*MsgRemoveAuthorizedMembers) Size 

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

func (*MsgRemoveAuthorizedMembers) String 

func (m *MsgRemoveAuthorizedMembers) String() string

func (*MsgRemoveAuthorizedMembers) Unmarshal 

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

func (*MsgRemoveAuthorizedMembers) ValidateBasic 

func (msg *MsgRemoveAuthorizedMembers) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgRemoveAuthorizedMembers) XXX_DiscardUnknown 

func (m *MsgRemoveAuthorizedMembers) XXX_DiscardUnknown()

func (*MsgRemoveAuthorizedMembers) XXX_Marshal 

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

func (*MsgRemoveAuthorizedMembers) XXX_Merge 

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

func (*MsgRemoveAuthorizedMembers) XXX_Size 

func (m *MsgRemoveAuthorizedMembers) XXX_Size() int

func (*MsgRemoveAuthorizedMembers) XXX_Unmarshal 

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

type MsgRemoveAuthorizedMembersResponse 

type MsgRemoveAuthorizedMembersResponse struct {
}

MsgRemoveAuthorizedMembersResponse defines the Msg/RemoveAuthorizedMembersResponse response type.

func (*MsgRemoveAuthorizedMembersResponse) Descriptor 

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

func (*MsgRemoveAuthorizedMembersResponse) Marshal 

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

func (*MsgRemoveAuthorizedMembersResponse) MarshalTo 

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

func (*MsgRemoveAuthorizedMembersResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveAuthorizedMembersResponse) ProtoMessage 

func (*MsgRemoveAuthorizedMembersResponse) ProtoMessage()

func (*MsgRemoveAuthorizedMembersResponse) Reset 

func (m *MsgRemoveAuthorizedMembersResponse) Reset()

func (*MsgRemoveAuthorizedMembersResponse) Size 

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

func (*MsgRemoveAuthorizedMembersResponse) String 

func (m *MsgRemoveAuthorizedMembersResponse) String() string

func (*MsgRemoveAuthorizedMembersResponse) Unmarshal 

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

func (*MsgRemoveAuthorizedMembersResponse) XXX_DiscardUnknown 

func (m *MsgRemoveAuthorizedMembersResponse) XXX_DiscardUnknown()

func (*MsgRemoveAuthorizedMembersResponse) XXX_Marshal 

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

func (*MsgRemoveAuthorizedMembersResponse) XXX_Merge 

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

func (*MsgRemoveAuthorizedMembersResponse) XXX_Size 

func (m *MsgRemoveAuthorizedMembersResponse) XXX_Size() int

func (*MsgRemoveAuthorizedMembersResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// UpdateParams updates the module params.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	// CreateCaptainNode creates a captain node and assign it to the owner.
	CreateCaptainNode(context.Context, *MsgCreateCaptainNode) (*MsgCreateCaptainNodeResponse, error)
	// CommitReport commits the running state report of captain nodes
	CommitReport(context.Context, *MsgCommitReport) (*MsgCommitReportResponse, error)
	// AddAuthorizedMembers adds authorized members allowed to access permission interface.
	AddAuthorizedMembers(context.Context, *MsgAddAuthorizedMembers) (*MsgAddAuthorizedMembersResponse, error)
	// RemoveAuthorizedMembers removes authorized members.
	RemoveAuthorizedMembers(context.Context, *MsgRemoveAuthorizedMembers) (*MsgRemoveAuthorizedMembersResponse, error)
	// UpdateSaleLevel updates CurrentLevelForSale in module params.
	UpdateSaleLevel(context.Context, *MsgUpdateSaleLevel) (*MsgUpdateSaleLevelResponse, error)
	// CommitComputingPower assign pending computing power reward to users for later claiming.
	CommitComputingPower(context.Context, *MsgCommitComputingPower) (*MsgCommitComputingPowerResponse, error)
	// ClaimComputingPower allows captain node owner to claim and increase node's computing power.
	ClaimComputingPower(context.Context, *MsgClaimComputingPower) (*MsgClaimComputingPowerResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Params    Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams defines the Msg/UpdateParams request type.

func NewMsgUpdateParams 

func NewMsgUpdateParams(authority string, params Params) *MsgUpdateParams

NewMsgUpdateParams creates a new MsgUpdateParams instance

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetSigners 

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

GetSigners Implements Msg.

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the Msg/UpdateParamsResponse response type.

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type MsgUpdateSaleLevel 

type MsgUpdateSaleLevel struct {
	// sender is the address of the owner of nft
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// sale_level is the sale levels to update.
	SaleLevel uint64 `protobuf:"varint,2,opt,name=sale_level,json=saleLevel,proto3" json:"sale_level,omitempty"`
}

MsgUpdateSaleLevel defines the Msg/UpdateSaleLevel request type.

func NewMsgUpdateSaleLevel 

func NewMsgUpdateSaleLevel(authority string, level uint64) *MsgUpdateSaleLevel

NewMsgUpdateSaleLevel creates a new MsgUpdateSaleLevel instance

func (*MsgUpdateSaleLevel) Descriptor 

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

func (*MsgUpdateSaleLevel) GetSigners 

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

GetSigners Implements Msg.

func (*MsgUpdateSaleLevel) Marshal 

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

func (*MsgUpdateSaleLevel) MarshalTo 

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

func (*MsgUpdateSaleLevel) MarshalToSizedBuffer 

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

func (*MsgUpdateSaleLevel) ProtoMessage 

func (*MsgUpdateSaleLevel) ProtoMessage()

func (*MsgUpdateSaleLevel) Reset 

func (m *MsgUpdateSaleLevel) Reset()

func (*MsgUpdateSaleLevel) Size 

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

func (*MsgUpdateSaleLevel) String 

func (m *MsgUpdateSaleLevel) String() string

func (*MsgUpdateSaleLevel) Unmarshal 

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

func (*MsgUpdateSaleLevel) ValidateBasic 

func (msg *MsgUpdateSaleLevel) ValidateBasic() error

ValidateBasic Implements Msg.

func (*MsgUpdateSaleLevel) XXX_DiscardUnknown 

func (m *MsgUpdateSaleLevel) XXX_DiscardUnknown()

func (*MsgUpdateSaleLevel) XXX_Marshal 

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

func (*MsgUpdateSaleLevel) XXX_Merge 

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

func (*MsgUpdateSaleLevel) XXX_Size 

func (m *MsgUpdateSaleLevel) XXX_Size() int

func (*MsgUpdateSaleLevel) XXX_Unmarshal 

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

type MsgUpdateSaleLevelResponse 

type MsgUpdateSaleLevelResponse struct {
}

MsgUpdateSaleLevelResponse defines the Msg/UpdateSaleLevelResponse response type.

func (*MsgUpdateSaleLevelResponse) Descriptor 

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

func (*MsgUpdateSaleLevelResponse) Marshal 

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

func (*MsgUpdateSaleLevelResponse) MarshalTo 

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

func (*MsgUpdateSaleLevelResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateSaleLevelResponse) ProtoMessage 

func (*MsgUpdateSaleLevelResponse) ProtoMessage()

func (*MsgUpdateSaleLevelResponse) Reset 

func (m *MsgUpdateSaleLevelResponse) Reset()

func (*MsgUpdateSaleLevelResponse) Size 

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

func (*MsgUpdateSaleLevelResponse) String 

func (m *MsgUpdateSaleLevelResponse) String() string

func (*MsgUpdateSaleLevelResponse) Unmarshal 

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

func (*MsgUpdateSaleLevelResponse) XXX_DiscardUnknown 

func (m *MsgUpdateSaleLevelResponse) XXX_DiscardUnknown()

func (*MsgUpdateSaleLevelResponse) XXX_Marshal 

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

func (*MsgUpdateSaleLevelResponse) XXX_Merge 

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

func (*MsgUpdateSaleLevelResponse) XXX_Size 

func (m *MsgUpdateSaleLevelResponse) XXX_Size() int

func (*MsgUpdateSaleLevelResponse) XXX_Unmarshal 

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

type Node 

type Node struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DivisionId     string `protobuf:"bytes,2,opt,name=division_id,json=divisionId,proto3" json:"division_id,omitempty"`
	Owner          string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	ComputingPower uint64 `protobuf:"varint,4,opt,name=computing_power,json=computingPower,proto3" json:"computing_power,omitempty"`
}

Node defines the node

func (*Node) Descriptor 

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

func (*Node) GetComputingPower 

func (m *Node) GetComputingPower() uint64

func (*Node) GetDivisionId 

func (m *Node) GetDivisionId() string

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetOwner 

func (m *Node) GetOwner() string

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) MarshalToSizedBuffer 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeClaimedEmission 

type NodeClaimedEmission struct {
	NodeId   string                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Emission github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=emission,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"emission"`
}

func (*NodeClaimedEmission) Descriptor 

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

func (*NodeClaimedEmission) GetNodeId 

func (m *NodeClaimedEmission) GetNodeId() string

func (*NodeClaimedEmission) Marshal 

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

func (*NodeClaimedEmission) MarshalTo 

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

func (*NodeClaimedEmission) MarshalToSizedBuffer 

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

func (*NodeClaimedEmission) ProtoMessage 

func (*NodeClaimedEmission) ProtoMessage()

func (*NodeClaimedEmission) Reset 

func (m *NodeClaimedEmission) Reset()

func (*NodeClaimedEmission) Size 

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

func (*NodeClaimedEmission) String 

func (m *NodeClaimedEmission) String() string

func (*NodeClaimedEmission) Unmarshal 

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

func (*NodeClaimedEmission) XXX_DiscardUnknown 

func (m *NodeClaimedEmission) XXX_DiscardUnknown()

func (*NodeClaimedEmission) XXX_Marshal 

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

func (*NodeClaimedEmission) XXX_Merge 

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

func (*NodeClaimedEmission) XXX_Size 

func (m *NodeClaimedEmission) XXX_Size() int

func (*NodeClaimedEmission) XXX_Unmarshal 

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

type NodeCumulativeEmission 

type NodeCumulativeEmission struct {
	NodeId   string                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	EpochId  uint64                                 `protobuf:"varint,2,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Emission github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=emission,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"emission"`
}

func (*NodeCumulativeEmission) Descriptor 

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

func (*NodeCumulativeEmission) GetEpochId 

func (m *NodeCumulativeEmission) GetEpochId() uint64

func (*NodeCumulativeEmission) GetNodeId 

func (m *NodeCumulativeEmission) GetNodeId() string

func (*NodeCumulativeEmission) Marshal 

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

func (*NodeCumulativeEmission) MarshalTo 

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

func (*NodeCumulativeEmission) MarshalToSizedBuffer 

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

func (*NodeCumulativeEmission) ProtoMessage 

func (*NodeCumulativeEmission) ProtoMessage()

func (*NodeCumulativeEmission) Reset 

func (m *NodeCumulativeEmission) Reset()

func (*NodeCumulativeEmission) Size 

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

func (*NodeCumulativeEmission) String 

func (m *NodeCumulativeEmission) String() string

func (*NodeCumulativeEmission) Unmarshal 

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

func (*NodeCumulativeEmission) XXX_DiscardUnknown 

func (m *NodeCumulativeEmission) XXX_DiscardUnknown()

func (*NodeCumulativeEmission) XXX_Marshal 

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

func (*NodeCumulativeEmission) XXX_Merge 

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

func (*NodeCumulativeEmission) XXX_Size 

func (m *NodeCumulativeEmission) XXX_Size() int

func (*NodeCumulativeEmission) XXX_Unmarshal 

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

type NodePowerOnRatio 

type NodePowerOnRatio struct {
	// node_id is the id of the node
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// on_operation_ratio is the operation ratio of the node
	OnOperationRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 151-byte string literal not displayed */
}

NodePowerOnRatio is the power on ratio of a node.

func (*NodePowerOnRatio) Descriptor 

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

func (*NodePowerOnRatio) GetNodeId 

func (m *NodePowerOnRatio) GetNodeId() string

func (*NodePowerOnRatio) Marshal 

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

func (*NodePowerOnRatio) MarshalTo 

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

func (*NodePowerOnRatio) MarshalToSizedBuffer 

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

func (*NodePowerOnRatio) ProtoMessage 

func (*NodePowerOnRatio) ProtoMessage()

func (*NodePowerOnRatio) Reset 

func (m *NodePowerOnRatio) Reset()

func (*NodePowerOnRatio) Size 

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

func (*NodePowerOnRatio) String 

func (m *NodePowerOnRatio) String() string

func (*NodePowerOnRatio) Unmarshal 

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

func (*NodePowerOnRatio) XXX_DiscardUnknown 

func (m *NodePowerOnRatio) XXX_DiscardUnknown()

func (*NodePowerOnRatio) XXX_Marshal 

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

func (*NodePowerOnRatio) XXX_Merge 

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

func (*NodePowerOnRatio) XXX_Size 

func (m *NodePowerOnRatio) XXX_Size() int

func (*NodePowerOnRatio) XXX_Unmarshal 

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

type NodesComputingPower 

type NodesComputingPower struct {
	NodeId  string                                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	EpochId uint64                                 `protobuf:"varint,2,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Amount  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"amount"`
}

func (*NodesComputingPower) Descriptor 

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

func (*NodesComputingPower) GetEpochId 

func (m *NodesComputingPower) GetEpochId() uint64

func (*NodesComputingPower) GetNodeId 

func (m *NodesComputingPower) GetNodeId() string

func (*NodesComputingPower) Marshal 

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

func (*NodesComputingPower) MarshalTo 

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

func (*NodesComputingPower) MarshalToSizedBuffer 

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

func (*NodesComputingPower) ProtoMessage 

func (*NodesComputingPower) ProtoMessage()

func (*NodesComputingPower) Reset 

func (m *NodesComputingPower) Reset()

func (*NodesComputingPower) Size 

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

func (*NodesComputingPower) String 

func (m *NodesComputingPower) String() string

func (*NodesComputingPower) Unmarshal 

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

func (*NodesComputingPower) XXX_DiscardUnknown 

func (m *NodesComputingPower) XXX_DiscardUnknown()

func (*NodesComputingPower) XXX_Marshal 

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

func (*NodesComputingPower) XXX_Merge 

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

func (*NodesComputingPower) XXX_Size 

func (m *NodesComputingPower) XXX_Size() int

func (*NodesComputingPower) XXX_Unmarshal 

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

type OwnerPledge 

type OwnerPledge struct {
	Owner   string                                 `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	EpochId uint64                                 `protobuf:"varint,2,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Amount  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"amount"`
}

func (*OwnerPledge) Descriptor 

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

func (*OwnerPledge) GetEpochId 

func (m *OwnerPledge) GetEpochId() uint64

func (*OwnerPledge) GetOwner 

func (m *OwnerPledge) GetOwner() string

func (*OwnerPledge) Marshal 

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

func (*OwnerPledge) MarshalTo 

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

func (*OwnerPledge) MarshalToSizedBuffer 

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

func (*OwnerPledge) ProtoMessage 

func (*OwnerPledge) ProtoMessage()

func (*OwnerPledge) Reset 

func (m *OwnerPledge) Reset()

func (*OwnerPledge) Size 

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

func (*OwnerPledge) String 

func (m *OwnerPledge) String() string

func (*OwnerPledge) Unmarshal 

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

func (*OwnerPledge) XXX_DiscardUnknown 

func (m *OwnerPledge) XXX_DiscardUnknown()

func (*OwnerPledge) XXX_Marshal 

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

func (*OwnerPledge) XXX_Merge 

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

func (*OwnerPledge) XXX_Size 

func (m *OwnerPledge) XXX_Size() int

func (*OwnerPledge) XXX_Unmarshal 

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

type Params 

type Params struct {
	// captains_total_count defines the total count of the captains
	CaptainsTotalCount uint64 `protobuf:"varint,1,opt,name=captains_total_count,json=captainsTotalCount,proto3" json:"captains_total_count,omitempty"`
	// minimum_power_on_period defines the minimum period for a captain to be powered on
	MinimumPowerOnPeriod uint64 `` /* 126-byte string literal not displayed */
	// maximum_power_on_period defines the maximum period for a captain to be powered on
	MaximumPowerOnPeriod uint64 `` /* 126-byte string literal not displayed */
	// captains_constant is a fixed constant for reward calculation
	CaptainsConstant github_com_cosmos_cosmos_sdk_types.Dec `` /* 149-byte string literal not displayed */
	// halving_era defines the halving era coefficient
	HalvingEraCoefficient github_com_cosmos_cosmos_sdk_types.Dec `` /* 166-byte string literal not displayed */
	// tech_progress_coefficient defines the tech progress coefficient cardinality.
	TechProgressCoefficientCardinality github_com_cosmos_cosmos_sdk_types.Dec `` /* 207-byte string literal not displayed */
	// current_sale_level defines the current level for sale.
	CurrentSaleLevel uint64 `protobuf:"varint,7,opt,name=current_sale_level,json=currentSaleLevel,proto3" json:"current_sale_level,omitempty"`
	// authorized members list
	AuthorizedMembers []string `protobuf:"bytes,8,rep,name=authorized_members,json=authorizedMembers,proto3" json:"authorized_members,omitempty"`
}

Params defines captains module's parameters

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters.

func NewParams 

func NewParams(
	captainsTotalCount uint64,
	minimumPowerOnPeriod uint64,
	maximumPowerOnPeriod uint64,
	captainsConstant sdk.Dec,
	techProgressCoefficientCardinality sdk.Dec,
	halvingEraCoefficient sdk.Dec,
	currentSaleLevel uint64,
	authorizedMembers []string,
) Params

NewParams creates a Params.

func (*Params) Descriptor 

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

func (*Params) GetAuthorizedMembers 

func (m *Params) GetAuthorizedMembers() []string

func (*Params) GetCaptainsTotalCount 

func (m *Params) GetCaptainsTotalCount() uint64

func (*Params) GetCurrentSaleLevel 

func (m *Params) GetCurrentSaleLevel() uint64

func (*Params) GetMaximumPowerOnPeriod 

func (m *Params) GetMaximumPowerOnPeriod() uint64

func (*Params) GetMinimumPowerOnPeriod 

func (m *Params) GetMinimumPowerOnPeriod() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) Validate 

func (p *Params) Validate() error

Validate returns err if the Params is invalid

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryAuthorizedMembersRequest 

type QueryAuthorizedMembersRequest struct {
}

QueryAuthorizedMembersRequest is the request type for the Query/AuthorizedMembers RPC method

func (*QueryAuthorizedMembersRequest) Descriptor 

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

func (*QueryAuthorizedMembersRequest) Marshal 

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

func (*QueryAuthorizedMembersRequest) MarshalTo 

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

func (*QueryAuthorizedMembersRequest) MarshalToSizedBuffer 

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

func (*QueryAuthorizedMembersRequest) ProtoMessage 

func (*QueryAuthorizedMembersRequest) ProtoMessage()

func (*QueryAuthorizedMembersRequest) Reset 

func (m *QueryAuthorizedMembersRequest) Reset()

func (*QueryAuthorizedMembersRequest) Size 

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

func (*QueryAuthorizedMembersRequest) String 

func (m *QueryAuthorizedMembersRequest) String() string

func (*QueryAuthorizedMembersRequest) Unmarshal 

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

func (*QueryAuthorizedMembersRequest) XXX_DiscardUnknown 

func (m *QueryAuthorizedMembersRequest) XXX_DiscardUnknown()

func (*QueryAuthorizedMembersRequest) XXX_Marshal 

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

func (*QueryAuthorizedMembersRequest) XXX_Merge 

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

func (*QueryAuthorizedMembersRequest) XXX_Size 

func (m *QueryAuthorizedMembersRequest) XXX_Size() int

func (*QueryAuthorizedMembersRequest) XXX_Unmarshal 

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

type QueryAuthorizedMembersResponse 

type QueryAuthorizedMembersResponse struct {
	Members []string `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
}

QueryAuthorizedMembersResponse is the response type for the Query/AuthorizedMembers RPC method

func (*QueryAuthorizedMembersResponse) Descriptor 

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

func (*QueryAuthorizedMembersResponse) GetMembers 

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

func (*QueryAuthorizedMembersResponse) Marshal 

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

func (*QueryAuthorizedMembersResponse) MarshalTo 

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

func (*QueryAuthorizedMembersResponse) MarshalToSizedBuffer 

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

func (*QueryAuthorizedMembersResponse) ProtoMessage 

func (*QueryAuthorizedMembersResponse) ProtoMessage()

func (*QueryAuthorizedMembersResponse) Reset 

func (m *QueryAuthorizedMembersResponse) Reset()

func (*QueryAuthorizedMembersResponse) Size 

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

func (*QueryAuthorizedMembersResponse) String 

func (m *QueryAuthorizedMembersResponse) String() string

func (*QueryAuthorizedMembersResponse) Unmarshal 

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

func (*QueryAuthorizedMembersResponse) XXX_DiscardUnknown 

func (m *QueryAuthorizedMembersResponse) XXX_DiscardUnknown()

func (*QueryAuthorizedMembersResponse) XXX_Marshal 

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

func (*QueryAuthorizedMembersResponse) XXX_Merge 

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

func (*QueryAuthorizedMembersResponse) XXX_Size 

func (m *QueryAuthorizedMembersResponse) XXX_Size() int

func (*QueryAuthorizedMembersResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the captains module parameters
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Node queries an Node based on its id.
	Node(ctx context.Context, in *QueryNodeRequest, opts ...grpc.CallOption) (*QueryNodeResponse, error)
	// Nodes queries all node of a given owner
	Nodes(ctx context.Context, in *QueryNodesRequest, opts ...grpc.CallOption) (*QueryNodesResponse, error)
	// NodeLastEpochInfo queries the node last epoch emission, historical emission and pledge ratio.
	NodeLastEpochInfo(ctx context.Context, in *QueryNodeLastEpochInfoRequest, opts ...grpc.CallOption) (*QueryNodeLastEpochInfoResponse, error)
	// Divisions queries all Node divisions
	Divisions(ctx context.Context, in *QueryDivisionsRequest, opts ...grpc.CallOption) (*QueryDivisionsResponse, error)
	// Division queries a division by its id.
	Division(ctx context.Context, in *QueryDivisionRequest, opts ...grpc.CallOption) (*QueryDivisionResponse, error)
	// Supply queries the number of nodes under the division
	Supply(ctx context.Context, in *QuerySupplyRequest, opts ...grpc.CallOption) (*QuerySupplyResponse, error)
	// SaleLevel queries current sale level
	SaleLevel(ctx context.Context, in *QuerySaleLevelRequest, opts ...grpc.CallOption) (*QuerySaleLevelResponse, error)
	// AuthorizedMembers queries all the callers
	AuthorizedMembers(ctx context.Context, in *QueryAuthorizedMembersRequest, opts ...grpc.CallOption) (*QueryAuthorizedMembersResponse, error)
	// CurrentEpoch queries the current epoch as well as its height;
	CurrentEpoch(ctx context.Context, in *QueryCurrentEpochRequest, opts ...grpc.CallOption) (*QueryCurrentEpochResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryCurrentEpochRequest 

type QueryCurrentEpochRequest struct {
}

QueryCurrentEpochRequest is the request type for the Query/CurrentEpoch RPC method

func (*QueryCurrentEpochRequest) Descriptor 

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

func (*QueryCurrentEpochRequest) Marshal 

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

func (*QueryCurrentEpochRequest) MarshalTo 

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

func (*QueryCurrentEpochRequest) MarshalToSizedBuffer 

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

func (*QueryCurrentEpochRequest) ProtoMessage 

func (*QueryCurrentEpochRequest) ProtoMessage()

func (*QueryCurrentEpochRequest) Reset 

func (m *QueryCurrentEpochRequest) Reset()

func (*QueryCurrentEpochRequest) Size 

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

func (*QueryCurrentEpochRequest) String 

func (m *QueryCurrentEpochRequest) String() string

func (*QueryCurrentEpochRequest) Unmarshal 

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

func (*QueryCurrentEpochRequest) XXX_DiscardUnknown 

func (m *QueryCurrentEpochRequest) XXX_DiscardUnknown()

func (*QueryCurrentEpochRequest) XXX_Marshal 

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

func (*QueryCurrentEpochRequest) XXX_Merge 

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

func (*QueryCurrentEpochRequest) XXX_Size 

func (m *QueryCurrentEpochRequest) XXX_Size() int

func (*QueryCurrentEpochRequest) XXX_Unmarshal 

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

type QueryCurrentEpochResponse 

type QueryCurrentEpochResponse struct {
	Epoch  uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
}

QueryCurrentEpochResponse is the response type for the Query/CurrentEpoch RPC method

func (*QueryCurrentEpochResponse) Descriptor 

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

func (*QueryCurrentEpochResponse) GetEpoch 

func (m *QueryCurrentEpochResponse) GetEpoch() uint64

func (*QueryCurrentEpochResponse) GetHeight 

func (m *QueryCurrentEpochResponse) GetHeight() uint64

func (*QueryCurrentEpochResponse) Marshal 

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

func (*QueryCurrentEpochResponse) MarshalTo 

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

func (*QueryCurrentEpochResponse) MarshalToSizedBuffer 

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

func (*QueryCurrentEpochResponse) ProtoMessage 

func (*QueryCurrentEpochResponse) ProtoMessage()

func (*QueryCurrentEpochResponse) Reset 

func (m *QueryCurrentEpochResponse) Reset()

func (*QueryCurrentEpochResponse) Size 

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

func (*QueryCurrentEpochResponse) String 

func (m *QueryCurrentEpochResponse) String() string

func (*QueryCurrentEpochResponse) Unmarshal 

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

func (*QueryCurrentEpochResponse) XXX_DiscardUnknown 

func (m *QueryCurrentEpochResponse) XXX_DiscardUnknown()

func (*QueryCurrentEpochResponse) XXX_Marshal 

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

func (*QueryCurrentEpochResponse) XXX_Merge 

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

func (*QueryCurrentEpochResponse) XXX_Size 

func (m *QueryCurrentEpochResponse) XXX_Size() int

func (*QueryCurrentEpochResponse) XXX_Unmarshal 

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

type QueryDivisionRequest 

type QueryDivisionRequest struct {
	DivisionId string `protobuf:"bytes,1,opt,name=division_id,json=divisionId,proto3" json:"division_id,omitempty"`
}

QueryDivisionRequest is the request type for the Query/Division RPC method

func (*QueryDivisionRequest) Descriptor 

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

func (*QueryDivisionRequest) GetDivisionId 

func (m *QueryDivisionRequest) GetDivisionId() string

func (*QueryDivisionRequest) Marshal 

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

func (*QueryDivisionRequest) MarshalTo 

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

func (*QueryDivisionRequest) MarshalToSizedBuffer 

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

func (*QueryDivisionRequest) ProtoMessage 

func (*QueryDivisionRequest) ProtoMessage()

func (*QueryDivisionRequest) Reset 

func (m *QueryDivisionRequest) Reset()

func (*QueryDivisionRequest) Size 

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

func (*QueryDivisionRequest) String 

func (m *QueryDivisionRequest) String() string

func (*QueryDivisionRequest) Unmarshal 

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

func (*QueryDivisionRequest) XXX_DiscardUnknown 

func (m *QueryDivisionRequest) XXX_DiscardUnknown()

func (*QueryDivisionRequest) XXX_Marshal 

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

func (*QueryDivisionRequest) XXX_Merge 

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

func (*QueryDivisionRequest) XXX_Size 

func (m *QueryDivisionRequest) XXX_Size() int

func (*QueryDivisionRequest) XXX_Unmarshal 

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

type QueryDivisionResponse 

type QueryDivisionResponse struct {
	Division *Division `protobuf:"bytes,1,opt,name=division,proto3" json:"division,omitempty"`
}

QueryDivisionResponse is the response type for the Query/Division RPC method

func (*QueryDivisionResponse) Descriptor 

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

func (*QueryDivisionResponse) GetDivision 

func (m *QueryDivisionResponse) GetDivision() *Division

func (*QueryDivisionResponse) Marshal 

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

func (*QueryDivisionResponse) MarshalTo 

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

func (*QueryDivisionResponse) MarshalToSizedBuffer 

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

func (*QueryDivisionResponse) ProtoMessage 

func (*QueryDivisionResponse) ProtoMessage()

func (*QueryDivisionResponse) Reset 

func (m *QueryDivisionResponse) Reset()

func (*QueryDivisionResponse) Size 

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

func (*QueryDivisionResponse) String 

func (m *QueryDivisionResponse) String() string

func (*QueryDivisionResponse) Unmarshal 

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

func (*QueryDivisionResponse) XXX_DiscardUnknown 

func (m *QueryDivisionResponse) XXX_DiscardUnknown()

func (*QueryDivisionResponse) XXX_Marshal 

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

func (*QueryDivisionResponse) XXX_Merge 

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

func (*QueryDivisionResponse) XXX_Size 

func (m *QueryDivisionResponse) XXX_Size() int

func (*QueryDivisionResponse) XXX_Unmarshal 

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

type QueryDivisionsRequest 

type QueryDivisionsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDivisionsRequest is the request type for the Query/Divisions RPC method

func (*QueryDivisionsRequest) Descriptor 

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

func (*QueryDivisionsRequest) GetPagination 

func (m *QueryDivisionsRequest) GetPagination() *query.PageRequest

func (*QueryDivisionsRequest) Marshal 

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

func (*QueryDivisionsRequest) MarshalTo 

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

func (*QueryDivisionsRequest) MarshalToSizedBuffer 

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

func (*QueryDivisionsRequest) ProtoMessage 

func (*QueryDivisionsRequest) ProtoMessage()

func (*QueryDivisionsRequest) Reset 

func (m *QueryDivisionsRequest) Reset()

func (*QueryDivisionsRequest) Size 

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

func (*QueryDivisionsRequest) String 

func (m *QueryDivisionsRequest) String() string

func (*QueryDivisionsRequest) Unmarshal 

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

func (*QueryDivisionsRequest) XXX_DiscardUnknown 

func (m *QueryDivisionsRequest) XXX_DiscardUnknown()

func (*QueryDivisionsRequest) XXX_Marshal 

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

func (*QueryDivisionsRequest) XXX_Merge 

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

func (*QueryDivisionsRequest) XXX_Size 

func (m *QueryDivisionsRequest) XXX_Size() int

func (*QueryDivisionsRequest) XXX_Unmarshal 

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

type QueryDivisionsResponse 

type QueryDivisionsResponse struct {
	Divisions  []Division          `protobuf:"bytes,1,rep,name=divisions,proto3" json:"divisions"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDivisionsResponse is the response type for the Query/Divisions RPC method

func (*QueryDivisionsResponse) Descriptor 

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

func (*QueryDivisionsResponse) GetDivisions 

func (m *QueryDivisionsResponse) GetDivisions() []Division

func (*QueryDivisionsResponse) GetPagination 

func (m *QueryDivisionsResponse) GetPagination() *query.PageResponse

func (*QueryDivisionsResponse) Marshal 

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

func (*QueryDivisionsResponse) MarshalTo 

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

func (*QueryDivisionsResponse) MarshalToSizedBuffer 

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

func (*QueryDivisionsResponse) ProtoMessage 

func (*QueryDivisionsResponse) ProtoMessage()

func (*QueryDivisionsResponse) Reset 

func (m *QueryDivisionsResponse) Reset()

func (*QueryDivisionsResponse) Size 

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

func (*QueryDivisionsResponse) String 

func (m *QueryDivisionsResponse) String() string

func (*QueryDivisionsResponse) Unmarshal 

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

func (*QueryDivisionsResponse) XXX_DiscardUnknown 

func (m *QueryDivisionsResponse) XXX_DiscardUnknown()

func (*QueryDivisionsResponse) XXX_Marshal 

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

func (*QueryDivisionsResponse) XXX_Merge 

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

func (*QueryDivisionsResponse) XXX_Size 

func (m *QueryDivisionsResponse) XXX_Size() int

func (*QueryDivisionsResponse) XXX_Unmarshal 

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

type QueryNodeLastEpochInfoRequest 

type QueryNodeLastEpochInfoRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

QueryNodeLastEpochInfoRequest is the request type for the Query/NodeLastEpochInfo RPC method

func (*QueryNodeLastEpochInfoRequest) Descriptor 

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

func (*QueryNodeLastEpochInfoRequest) GetNodeId 

func (m *QueryNodeLastEpochInfoRequest) GetNodeId() string

func (*QueryNodeLastEpochInfoRequest) Marshal 

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

func (*QueryNodeLastEpochInfoRequest) MarshalTo 

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

func (*QueryNodeLastEpochInfoRequest) MarshalToSizedBuffer 

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

func (*QueryNodeLastEpochInfoRequest) ProtoMessage 

func (*QueryNodeLastEpochInfoRequest) ProtoMessage()

func (*QueryNodeLastEpochInfoRequest) Reset 

func (m *QueryNodeLastEpochInfoRequest) Reset()

func (*QueryNodeLastEpochInfoRequest) Size 

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

func (*QueryNodeLastEpochInfoRequest) String 

func (m *QueryNodeLastEpochInfoRequest) String() string

func (*QueryNodeLastEpochInfoRequest) Unmarshal 

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

func (*QueryNodeLastEpochInfoRequest) XXX_DiscardUnknown 

func (m *QueryNodeLastEpochInfoRequest) XXX_DiscardUnknown()

func (*QueryNodeLastEpochInfoRequest) XXX_Marshal 

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

func (*QueryNodeLastEpochInfoRequest) XXX_Merge 

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

func (*QueryNodeLastEpochInfoRequest) XXX_Size 

func (m *QueryNodeLastEpochInfoRequest) XXX_Size() int

func (*QueryNodeLastEpochInfoRequest) XXX_Unmarshal 

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

type QueryNodeLastEpochInfoResponse 

type QueryNodeLastEpochInfoResponse struct {
	Epoch              uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Height             uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	LastEpochEmission  string `protobuf:"bytes,3,opt,name=last_epoch_emission,json=lastEpochEmission,proto3" json:"last_epoch_emission,omitempty"`
	HistoricalEmission string `protobuf:"bytes,4,opt,name=historical_emission,json=historicalEmission,proto3" json:"historical_emission,omitempty"`
	PledgeRatio        string `protobuf:"bytes,5,opt,name=pledge_ratio,json=pledgeRatio,proto3" json:"pledge_ratio,omitempty"`
}

QueryNodeLastEpochInfoResponse is the response type for the Query/NodeLastEpochInfo RPC method

func (*QueryNodeLastEpochInfoResponse) Descriptor 

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

func (*QueryNodeLastEpochInfoResponse) GetEpoch 

func (m *QueryNodeLastEpochInfoResponse) GetEpoch() uint64

func (*QueryNodeLastEpochInfoResponse) GetHeight 

func (m *QueryNodeLastEpochInfoResponse) GetHeight() uint64

func (*QueryNodeLastEpochInfoResponse) GetHistoricalEmission 

func (m *QueryNodeLastEpochInfoResponse) GetHistoricalEmission() string

func (*QueryNodeLastEpochInfoResponse) GetLastEpochEmission 

func (m *QueryNodeLastEpochInfoResponse) GetLastEpochEmission() string

func (*QueryNodeLastEpochInfoResponse) GetPledgeRatio 

func (m *QueryNodeLastEpochInfoResponse) GetPledgeRatio() string

func (*QueryNodeLastEpochInfoResponse) Marshal 

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

func (*QueryNodeLastEpochInfoResponse) MarshalTo 

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

func (*QueryNodeLastEpochInfoResponse) MarshalToSizedBuffer 

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

func (*QueryNodeLastEpochInfoResponse) ProtoMessage 

func (*QueryNodeLastEpochInfoResponse) ProtoMessage()

func (*QueryNodeLastEpochInfoResponse) Reset 

func (m *QueryNodeLastEpochInfoResponse) Reset()

func (*QueryNodeLastEpochInfoResponse) Size 

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

func (*QueryNodeLastEpochInfoResponse) String 

func (m *QueryNodeLastEpochInfoResponse) String() string

func (*QueryNodeLastEpochInfoResponse) Unmarshal 

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

func (*QueryNodeLastEpochInfoResponse) XXX_DiscardUnknown 

func (m *QueryNodeLastEpochInfoResponse) XXX_DiscardUnknown()

func (*QueryNodeLastEpochInfoResponse) XXX_Marshal 

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

func (*QueryNodeLastEpochInfoResponse) XXX_Merge 

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

func (*QueryNodeLastEpochInfoResponse) XXX_Size 

func (m *QueryNodeLastEpochInfoResponse) XXX_Size() int

func (*QueryNodeLastEpochInfoResponse) XXX_Unmarshal 

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

type QueryNodeRequest 

type QueryNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

QueryNodeRequest is the request type for the Query/Node RPC method

func (*QueryNodeRequest) Descriptor 

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

func (*QueryNodeRequest) GetNodeId 

func (m *QueryNodeRequest) GetNodeId() string

func (*QueryNodeRequest) Marshal 

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

func (*QueryNodeRequest) MarshalTo 

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

func (*QueryNodeRequest) MarshalToSizedBuffer 

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

func (*QueryNodeRequest) ProtoMessage 

func (*QueryNodeRequest) ProtoMessage()

func (*QueryNodeRequest) Reset 

func (m *QueryNodeRequest) Reset()

func (*QueryNodeRequest) Size 

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

func (*QueryNodeRequest) String 

func (m *QueryNodeRequest) String() string

func (*QueryNodeRequest) Unmarshal 

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

func (*QueryNodeRequest) XXX_DiscardUnknown 

func (m *QueryNodeRequest) XXX_DiscardUnknown()

func (*QueryNodeRequest) XXX_Marshal 

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

func (*QueryNodeRequest) XXX_Merge 

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

func (*QueryNodeRequest) XXX_Size 

func (m *QueryNodeRequest) XXX_Size() int

func (*QueryNodeRequest) XXX_Unmarshal 

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

type QueryNodeResponse 

type QueryNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
}

QueryNodeResponse is the response type for the Query/Node RPC method

func (*QueryNodeResponse) Descriptor 

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

func (*QueryNodeResponse) GetNode 

func (m *QueryNodeResponse) GetNode() *Node

func (*QueryNodeResponse) Marshal 

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

func (*QueryNodeResponse) MarshalTo 

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

func (*QueryNodeResponse) MarshalToSizedBuffer 

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

func (*QueryNodeResponse) ProtoMessage 

func (*QueryNodeResponse) ProtoMessage()

func (*QueryNodeResponse) Reset 

func (m *QueryNodeResponse) Reset()

func (*QueryNodeResponse) Size 

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

func (*QueryNodeResponse) String 

func (m *QueryNodeResponse) String() string

func (*QueryNodeResponse) Unmarshal 

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

func (*QueryNodeResponse) XXX_DiscardUnknown 

func (m *QueryNodeResponse) XXX_DiscardUnknown()

func (*QueryNodeResponse) XXX_Marshal 

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

func (*QueryNodeResponse) XXX_Merge 

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

func (*QueryNodeResponse) XXX_Size 

func (m *QueryNodeResponse) XXX_Size() int

func (*QueryNodeResponse) XXX_Unmarshal 

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

type QueryNodesRequest 

type QueryNodesRequest struct {
	Owner      string             `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesRequest is the request type for the Query/Nodes RPC method

func (*QueryNodesRequest) Descriptor 

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

func (*QueryNodesRequest) GetOwner 

func (m *QueryNodesRequest) GetOwner() string

func (*QueryNodesRequest) GetPagination 

func (m *QueryNodesRequest) GetPagination() *query.PageRequest

func (*QueryNodesRequest) Marshal 

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

func (*QueryNodesRequest) MarshalTo 

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

func (*QueryNodesRequest) MarshalToSizedBuffer 

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

func (*QueryNodesRequest) ProtoMessage 

func (*QueryNodesRequest) ProtoMessage()

func (*QueryNodesRequest) Reset 

func (m *QueryNodesRequest) Reset()

func (*QueryNodesRequest) Size 

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

func (*QueryNodesRequest) String 

func (m *QueryNodesRequest) String() string

func (*QueryNodesRequest) Unmarshal 

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

func (*QueryNodesRequest) XXX_DiscardUnknown 

func (m *QueryNodesRequest) XXX_DiscardUnknown()

func (*QueryNodesRequest) XXX_Marshal 

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

func (*QueryNodesRequest) XXX_Merge 

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

func (*QueryNodesRequest) XXX_Size 

func (m *QueryNodesRequest) XXX_Size() int

func (*QueryNodesRequest) XXX_Unmarshal 

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

type QueryNodesResponse 

type QueryNodesResponse struct {
	Nodes      []Node              `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryNodesResponse is the response type for the Query/Nodes RPC methods

func (*QueryNodesResponse) Descriptor 

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

func (*QueryNodesResponse) GetNodes 

func (m *QueryNodesResponse) GetNodes() []Node

func (*QueryNodesResponse) GetPagination 

func (m *QueryNodesResponse) GetPagination() *query.PageResponse

func (*QueryNodesResponse) Marshal 

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

func (*QueryNodesResponse) MarshalTo 

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

func (*QueryNodesResponse) MarshalToSizedBuffer 

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

func (*QueryNodesResponse) ProtoMessage 

func (*QueryNodesResponse) ProtoMessage()

func (*QueryNodesResponse) Reset 

func (m *QueryNodesResponse) Reset()

func (*QueryNodesResponse) Size 

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

func (*QueryNodesResponse) String 

func (m *QueryNodesResponse) String() string

func (*QueryNodesResponse) Unmarshal 

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

func (*QueryNodesResponse) XXX_DiscardUnknown 

func (m *QueryNodesResponse) XXX_DiscardUnknown()

func (*QueryNodesResponse) XXX_Marshal 

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

func (*QueryNodesResponse) XXX_Merge 

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

func (*QueryNodesResponse) XXX_Size 

func (m *QueryNodesResponse) XXX_Size() int

func (*QueryNodesResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Parameters RPC method

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

QueryParamsResponse is response type for the Query/Parameters RPC method

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QuerySaleLevelRequest 

type QuerySaleLevelRequest struct {
}

QuerySaleLevelRequest is the request type for the Query/SaleLevel RPC method

func (*QuerySaleLevelRequest) Descriptor 

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

func (*QuerySaleLevelRequest) Marshal 

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

func (*QuerySaleLevelRequest) MarshalTo 

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

func (*QuerySaleLevelRequest) MarshalToSizedBuffer 

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

func (*QuerySaleLevelRequest) ProtoMessage 

func (*QuerySaleLevelRequest) ProtoMessage()

func (*QuerySaleLevelRequest) Reset 

func (m *QuerySaleLevelRequest) Reset()

func (*QuerySaleLevelRequest) Size 

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

func (*QuerySaleLevelRequest) String 

func (m *QuerySaleLevelRequest) String() string

func (*QuerySaleLevelRequest) Unmarshal 

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

func (*QuerySaleLevelRequest) XXX_DiscardUnknown 

func (m *QuerySaleLevelRequest) XXX_DiscardUnknown()

func (*QuerySaleLevelRequest) XXX_Marshal 

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

func (*QuerySaleLevelRequest) XXX_Merge 

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

func (*QuerySaleLevelRequest) XXX_Size 

func (m *QuerySaleLevelRequest) XXX_Size() int

func (*QuerySaleLevelRequest) XXX_Unmarshal 

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

type QuerySaleLevelResponse 

type QuerySaleLevelResponse struct {
	SaleLevel uint64 `protobuf:"varint,1,opt,name=sale_level,json=saleLevel,proto3" json:"sale_level,omitempty"`
}

QuerySaleLevelResponse is the response type for the Query/SaleLevel RPC method

func (*QuerySaleLevelResponse) Descriptor 

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

func (*QuerySaleLevelResponse) GetSaleLevel 

func (m *QuerySaleLevelResponse) GetSaleLevel() uint64

func (*QuerySaleLevelResponse) Marshal 

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

func (*QuerySaleLevelResponse) MarshalTo 

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

func (*QuerySaleLevelResponse) MarshalToSizedBuffer 

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

func (*QuerySaleLevelResponse) ProtoMessage 

func (*QuerySaleLevelResponse) ProtoMessage()

func (*QuerySaleLevelResponse) Reset 

func (m *QuerySaleLevelResponse) Reset()

func (*QuerySaleLevelResponse) Size 

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

func (*QuerySaleLevelResponse) String 

func (m *QuerySaleLevelResponse) String() string

func (*QuerySaleLevelResponse) Unmarshal 

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

func (*QuerySaleLevelResponse) XXX_DiscardUnknown 

func (m *QuerySaleLevelResponse) XXX_DiscardUnknown()

func (*QuerySaleLevelResponse) XXX_Marshal 

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

func (*QuerySaleLevelResponse) XXX_Merge 

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

func (*QuerySaleLevelResponse) XXX_Size 

func (m *QuerySaleLevelResponse) XXX_Size() int

func (*QuerySaleLevelResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the captains module parameters
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Node queries an Node based on its id.
	Node(context.Context, *QueryNodeRequest) (*QueryNodeResponse, error)
	// Nodes queries all node of a given owner
	Nodes(context.Context, *QueryNodesRequest) (*QueryNodesResponse, error)
	// NodeLastEpochInfo queries the node last epoch emission, historical emission and pledge ratio.
	NodeLastEpochInfo(context.Context, *QueryNodeLastEpochInfoRequest) (*QueryNodeLastEpochInfoResponse, error)
	// Divisions queries all Node divisions
	Divisions(context.Context, *QueryDivisionsRequest) (*QueryDivisionsResponse, error)
	// Division queries a division by its id.
	Division(context.Context, *QueryDivisionRequest) (*QueryDivisionResponse, error)
	// Supply queries the number of nodes under the division
	Supply(context.Context, *QuerySupplyRequest) (*QuerySupplyResponse, error)
	// SaleLevel queries current sale level
	SaleLevel(context.Context, *QuerySaleLevelRequest) (*QuerySaleLevelResponse, error)
	// AuthorizedMembers queries all the callers
	AuthorizedMembers(context.Context, *QueryAuthorizedMembersRequest) (*QueryAuthorizedMembersResponse, error)
	// CurrentEpoch queries the current epoch as well as its height;
	CurrentEpoch(context.Context, *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error)
}

QueryServer is the server API for Query service.

type QuerySupplyRequest 

type QuerySupplyRequest struct {
	DivisionId string `protobuf:"bytes,1,opt,name=division_id,json=divisionId,proto3" json:"division_id,omitempty"`
}

QuerySupplyRequest is the request type for the Query/Supply RPC method

func (*QuerySupplyRequest) Descriptor 

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

func (*QuerySupplyRequest) GetDivisionId 

func (m *QuerySupplyRequest) GetDivisionId() string

func (*QuerySupplyRequest) Marshal 

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

func (*QuerySupplyRequest) MarshalTo 

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

func (*QuerySupplyRequest) MarshalToSizedBuffer 

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

func (*QuerySupplyRequest) ProtoMessage 

func (*QuerySupplyRequest) ProtoMessage()

func (*QuerySupplyRequest) Reset 

func (m *QuerySupplyRequest) Reset()

func (*QuerySupplyRequest) Size 

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

func (*QuerySupplyRequest) String 

func (m *QuerySupplyRequest) String() string

func (*QuerySupplyRequest) Unmarshal 

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

func (*QuerySupplyRequest) XXX_DiscardUnknown 

func (m *QuerySupplyRequest) XXX_DiscardUnknown()

func (*QuerySupplyRequest) XXX_Marshal 

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

func (*QuerySupplyRequest) XXX_Merge 

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

func (*QuerySupplyRequest) XXX_Size 

func (m *QuerySupplyRequest) XXX_Size() int

func (*QuerySupplyRequest) XXX_Unmarshal 

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

type QuerySupplyResponse 

type QuerySupplyResponse struct {
	Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
}

QuerySupplyResponse is the response type for the Query/Supply RPC method

func (*QuerySupplyResponse) Descriptor 

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

func (*QuerySupplyResponse) GetAmount 

func (m *QuerySupplyResponse) GetAmount() uint64

func (*QuerySupplyResponse) Marshal 

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

func (*QuerySupplyResponse) MarshalTo 

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

func (*QuerySupplyResponse) MarshalToSizedBuffer 

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

func (*QuerySupplyResponse) ProtoMessage 

func (*QuerySupplyResponse) ProtoMessage()

func (*QuerySupplyResponse) Reset 

func (m *QuerySupplyResponse) Reset()

func (*QuerySupplyResponse) Size 

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

func (*QuerySupplyResponse) String 

func (m *QuerySupplyResponse) String() string

func (*QuerySupplyResponse) Unmarshal 

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

func (*QuerySupplyResponse) XXX_DiscardUnknown 

func (m *QuerySupplyResponse) XXX_DiscardUnknown()

func (*QuerySupplyResponse) XXX_Marshal 

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

func (*QuerySupplyResponse) XXX_Merge 

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

func (*QuerySupplyResponse) XXX_Size 

func (m *QuerySupplyResponse) XXX_Size() int

func (*QuerySupplyResponse) XXX_Unmarshal 

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

type ReportBatch 

type ReportBatch struct {
	// epoch_id is the epoch id of the report
	EpochId uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// batch_id is the batch id of the report
	BatchId uint64 `protobuf:"varint,2,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// node_count is the number of nodes in the batch
	NodeCount uint64 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// nodes is the list of node in the batch
	Nodes []NodePowerOnRatio `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes"`
}

ReportBatch marks the a batch of nodes.

func (*ReportBatch) Descriptor 

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

func (*ReportBatch) GetBatchId 

func (m *ReportBatch) GetBatchId() uint64

func (*ReportBatch) GetEpochId 

func (m *ReportBatch) GetEpochId() uint64

func (*ReportBatch) GetNodeCount 

func (m *ReportBatch) GetNodeCount() uint64

func (*ReportBatch) GetNodes 

func (m *ReportBatch) GetNodes() []NodePowerOnRatio

func (*ReportBatch) Marshal 

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

func (*ReportBatch) MarshalTo 

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

func (*ReportBatch) MarshalToSizedBuffer 

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

func (*ReportBatch) ProtoMessage 

func (*ReportBatch) ProtoMessage()

func (*ReportBatch) Reset 

func (m *ReportBatch) Reset()

func (*ReportBatch) Size 

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

func (*ReportBatch) String 

func (m *ReportBatch) String() string

func (*ReportBatch) Unmarshal 

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

func (*ReportBatch) ValidateBasic 

func (batch *ReportBatch) ValidateBasic() error

ValidateBasic validate a report batch

func (*ReportBatch) XXX_DiscardUnknown 

func (m *ReportBatch) XXX_DiscardUnknown()

func (*ReportBatch) XXX_Marshal 

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

func (*ReportBatch) XXX_Merge 

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

func (*ReportBatch) XXX_Size 

func (m *ReportBatch) XXX_Size() int

func (*ReportBatch) XXX_Unmarshal 

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

type ReportContent 

type ReportContent interface {
	ValidateBasic() error
}

type ReportDigest 

type ReportDigest struct {
	// epoch_id is the epoch id of the report
	EpochId uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// total_node_count is the total number of batches in the report
	TotalBatchCount uint64 `protobuf:"varint,2,opt,name=total_batch_count,json=totalBatchCount,proto3" json:"total_batch_count,omitempty"`
	// total_node_count is the total number of nodes in the report
	TotalNodeCount uint64 `protobuf:"varint,3,opt,name=total_node_count,json=totalNodeCount,proto3" json:"total_node_count,omitempty"`
	// maximum_node_count_per_batch is the maximum number of nodes per batch
	MaximumNodeCountPerBatch uint64 `` /* 140-byte string literal not displayed */
	// global_on_operation_ratio is the operation ratio of global nodes
	GlobalOnOperationRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 171-byte string literal not displayed */
}

func (*ReportDigest) Descriptor 

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

func (*ReportDigest) GetEpochId 

func (m *ReportDigest) GetEpochId() uint64

func (*ReportDigest) GetMaximumNodeCountPerBatch 

func (m *ReportDigest) GetMaximumNodeCountPerBatch() uint64

func (*ReportDigest) GetTotalBatchCount 

func (m *ReportDigest) GetTotalBatchCount() uint64

func (*ReportDigest) GetTotalNodeCount 

func (m *ReportDigest) GetTotalNodeCount() uint64

func (*ReportDigest) Marshal 

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

func (*ReportDigest) MarshalTo 

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

func (*ReportDigest) MarshalToSizedBuffer 

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

func (*ReportDigest) ProtoMessage 

func (*ReportDigest) ProtoMessage()

func (*ReportDigest) Reset 

func (m *ReportDigest) Reset()

func (*ReportDigest) Size 

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

func (*ReportDigest) String 

func (m *ReportDigest) String() string

func (*ReportDigest) Unmarshal 

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

func (*ReportDigest) ValidateBasic 

func (digest *ReportDigest) ValidateBasic() error

ValidateBasic validate a report digest

func (*ReportDigest) XXX_DiscardUnknown 

func (m *ReportDigest) XXX_DiscardUnknown()

func (*ReportDigest) XXX_Marshal 

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

func (*ReportDigest) XXX_Merge 

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

func (*ReportDigest) XXX_Size 

func (m *ReportDigest) XXX_Size() int

func (*ReportDigest) XXX_Unmarshal 

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

type ReportEnd 

type ReportEnd struct {
	EpochId uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
}

ReportEnd marks the end of commiting a report.

func (*ReportEnd) Descriptor 

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

func (*ReportEnd) GetEpochId 

func (m *ReportEnd) GetEpochId() uint64

func (*ReportEnd) Marshal 

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

func (*ReportEnd) MarshalTo 

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

func (*ReportEnd) MarshalToSizedBuffer 

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

func (*ReportEnd) ProtoMessage 

func (*ReportEnd) ProtoMessage()

func (*ReportEnd) Reset 

func (m *ReportEnd) Reset()

func (*ReportEnd) Size 

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

func (*ReportEnd) String 

func (m *ReportEnd) String() string

func (*ReportEnd) Unmarshal 

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

func (*ReportEnd) ValidateBasic 

func (end *ReportEnd) ValidateBasic() error

ValidateBasic validate a report end

func (*ReportEnd) XXX_DiscardUnknown 

func (m *ReportEnd) XXX_DiscardUnknown()

func (*ReportEnd) XXX_Marshal 

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

func (*ReportEnd) XXX_Merge 

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

func (*ReportEnd) XXX_Size 

func (m *ReportEnd) XXX_Size() int

func (*ReportEnd) XXX_Unmarshal 

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

type ReportType 

type ReportType int32
const (
	ReportType_REPORT_TYPE_UNSPECIFIED ReportType = 0
	ReportType_REPORT_TYPE_DIGEST      ReportType = 1
	ReportType_REPORT_TYPE_BATCH       ReportType = 2
	ReportType_REPORT_TYPE_END         ReportType = 3
)

func (ReportType) EnumDescriptor 

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

func (ReportType) String 

func (x ReportType) String() string

type StakingKeeper 

type StakingKeeper interface {
	GetDelegatorDelegations(ctx sdk.Context, delegator sdk.AccAddress, maxRetrieve uint16) (delegations []stakingtypes.Delegation)
	GetValidator(ctx sdk.Context, addr sdk.ValAddress) (validator stakingtypes.Validator, found bool)
	BondDenom(ctx sdk.Context) (res string)
	GetParams(ctx sdk.Context) stakingtypes.Params
}

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddAuthorizedMembers 

func (*UnimplementedMsgServer) AddAuthorizedMembers(ctx context.Context, req *MsgAddAuthorizedMembers) (*MsgAddAuthorizedMembersResponse, error)

func (*UnimplementedMsgServer) ClaimComputingPower 

func (*UnimplementedMsgServer) ClaimComputingPower(ctx context.Context, req *MsgClaimComputingPower) (*MsgClaimComputingPowerResponse, error)

func (*UnimplementedMsgServer) CommitComputingPower 

func (*UnimplementedMsgServer) CommitComputingPower(ctx context.Context, req *MsgCommitComputingPower) (*MsgCommitComputingPowerResponse, error)

func (*UnimplementedMsgServer) CommitReport 

func (*UnimplementedMsgServer) CommitReport(ctx context.Context, req *MsgCommitReport) (*MsgCommitReportResponse, error)

func (*UnimplementedMsgServer) CreateCaptainNode 

func (*UnimplementedMsgServer) CreateCaptainNode(ctx context.Context, req *MsgCreateCaptainNode) (*MsgCreateCaptainNodeResponse, error)

func (*UnimplementedMsgServer) RemoveAuthorizedMembers 

func (*UnimplementedMsgServer) RemoveAuthorizedMembers(ctx context.Context, req *MsgRemoveAuthorizedMembers) (*MsgRemoveAuthorizedMembersResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

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

func (*UnimplementedMsgServer) UpdateSaleLevel 

func (*UnimplementedMsgServer) UpdateSaleLevel(ctx context.Context, req *MsgUpdateSaleLevel) (*MsgUpdateSaleLevelResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AuthorizedMembers 

func (*UnimplementedQueryServer) AuthorizedMembers(ctx context.Context, req *QueryAuthorizedMembersRequest) (*QueryAuthorizedMembersResponse, error)

func (*UnimplementedQueryServer) CurrentEpoch 

func (*UnimplementedQueryServer) CurrentEpoch(ctx context.Context, req *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error)

func (*UnimplementedQueryServer) Division 

func (*UnimplementedQueryServer) Division(ctx context.Context, req *QueryDivisionRequest) (*QueryDivisionResponse, error)

func (*UnimplementedQueryServer) Divisions 

func (*UnimplementedQueryServer) Divisions(ctx context.Context, req *QueryDivisionsRequest) (*QueryDivisionsResponse, error)

func (*UnimplementedQueryServer) Node 

func (*UnimplementedQueryServer) Node(ctx context.Context, req *QueryNodeRequest) (*QueryNodeResponse, error)

func (*UnimplementedQueryServer) NodeLastEpochInfo 

func (*UnimplementedQueryServer) NodeLastEpochInfo(ctx context.Context, req *QueryNodeLastEpochInfoRequest) (*QueryNodeLastEpochInfoResponse, error)

func (*UnimplementedQueryServer) Nodes 

func (*UnimplementedQueryServer) Nodes(ctx context.Context, req *QueryNodesRequest) (*QueryNodesResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) SaleLevel 

func (*UnimplementedQueryServer) SaleLevel(ctx context.Context, req *QuerySaleLevelRequest) (*QuerySaleLevelResponse, error)

func (*UnimplementedQueryServer) Supply 

func (*UnimplementedQueryServer) Supply(ctx context.Context, req *QuerySupplyRequest) (*QuerySupplyResponse, 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.