types

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

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

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

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

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName
)
View Source 
const TypeMsgAttest = "attest"
View Source 
const TypeMsgJoinAttesterSet = "join_attester_set"
View Source 
const TypeMsgLeaveAttesterSet = "leave_attester_set"
View Source 
const TypeMsgUpdateParams = "update_params"

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
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 (
	// todo (Alex): use numbers instaed of verbose keyse?
	ValidatorIndexPrefix        = collections.NewPrefix("validator_index")
	ValidatorPowerPrefix        = collections.NewPrefix("validator_power")
	AttestationBitmapPrefix     = collections.NewPrefix("attestation_bitmap")
	EpochBitmapPrefix           = collections.NewPrefix("epoch_bitmap")
	AttesterSetPrefix           = collections.NewPrefix("attester_set")
	SignaturePrefix             = collections.NewPrefix("signature")
	StoredAttestationInfoPrefix = collections.NewPrefix("stored_attestation_info")
	ParamsKey                   = collections.NewPrefix("params")
)

KVStore key prefixes

View Source 
var (
	KeyEpochLength      = []byte("EpochLength")
	KeyQuorumFraction   = []byte("QuorumFraction")
	KeyMinParticipation = []byte("MinParticipation")
	KeyPruneAfter       = []byte("PruneAfter")
	KeyEmergencyMode    = []byte("EmergencyMode")
	KeySignMode         = []byte("SignMode")
)
View Source 
var (
	DefaultEpochLength      = uint64(10)                        // todo (Alex): what is a good default?
	DefaultQuorumFraction   = math.LegacyNewDecWithPrec(667, 3) // 2/3
	DefaultMinParticipation = math.LegacyNewDecWithPrec(5, 1)   // 1/2
	DefaultPruneAfter       = uint64(7)
	DefaultSignMode         = SignMode_SIGN_MODE_CHECKPOINT
)

Default parameter values

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc
View Source 
var SignMode_name = map[int32]string{
	0: "SIGN_MODE_UNSPECIFIED",
	1: "SIGN_MODE_CHECKPOINT",
}
View Source 
var SignMode_value = map[string]int32{
	"SIGN_MODE_UNSPECIFIED": 0,
	"SIGN_MODE_CHECKPOINT":  1,
}

Functions

func GetAttestationKey 

func GetAttestationKey(height int64) []byte

GetAttestationKey returns the key for attestation bitmap at height

func GetAttesterSetKey 

func GetAttesterSetKey(addr string) []byte

GetAttesterSetKey returns the key for attester set membership

func GetEpochBitmapKey 

func GetEpochBitmapKey(epoch uint64) []byte

GetEpochBitmapKey returns the key for epoch participation bitmap

func GetSignatureKey 

func GetSignatureKey(height int64, addr string) []byte

GetSignatureKey returns the key for validator signature at height

func GetValidatorIndexKey 

func GetValidatorIndexKey(addr string) []byte

GetValidatorIndexKey returns the key for validator index mapping

func GetValidatorPowerKey 

func GetValidatorPowerKey(index uint16) []byte

GetValidatorPowerKey returns the key for validator power by index

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the parameter key table

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

RegisterCodec registers the necessary types and interfaces with the codec

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the module interface types

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)

Types

type AccountKeeper 

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

AccountKeeper defines the expected account keeper interface

type AttestationBitmap 

type AttestationBitmap struct {
	// height is the checkpoint height
	Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// bitmap is the validator participation bitmap
	Bitmap []byte `protobuf:"bytes,2,opt,name=bitmap,proto3" json:"bitmap,omitempty"`
	// voted_power is the total voting power that attested
	VotedPower uint64 `protobuf:"varint,3,opt,name=voted_power,json=votedPower,proto3" json:"voted_power,omitempty"`
	// total_power is the total voting power at this height
	TotalPower uint64 `protobuf:"varint,4,opt,name=total_power,json=totalPower,proto3" json:"total_power,omitempty"`
	// soft_confirmed indicates if quorum was reached
	SoftConfirmed bool `protobuf:"varint,5,opt,name=soft_confirmed,json=softConfirmed,proto3" json:"soft_confirmed,omitempty"`
}

AttestationBitmap stores the bitmap and metadata for a checkpoint

func (*AttestationBitmap) Descriptor 

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

func (*AttestationBitmap) GetBitmap 

func (m *AttestationBitmap) GetBitmap() []byte

func (*AttestationBitmap) GetHeight 

func (m *AttestationBitmap) GetHeight() int64

func (*AttestationBitmap) GetSoftConfirmed 

func (m *AttestationBitmap) GetSoftConfirmed() bool

func (*AttestationBitmap) GetTotalPower 

func (m *AttestationBitmap) GetTotalPower() uint64

func (*AttestationBitmap) GetVotedPower 

func (m *AttestationBitmap) GetVotedPower() uint64

func (*AttestationBitmap) Marshal 

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

func (*AttestationBitmap) MarshalTo 

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

func (*AttestationBitmap) MarshalToSizedBuffer 

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

func (*AttestationBitmap) ProtoMessage 

func (*AttestationBitmap) ProtoMessage()

func (*AttestationBitmap) Reset 

func (m *AttestationBitmap) Reset()

func (*AttestationBitmap) Size 

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

func (*AttestationBitmap) String 

func (m *AttestationBitmap) String() string

func (*AttestationBitmap) Unmarshal 

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

func (*AttestationBitmap) XXX_DiscardUnknown 

func (m *AttestationBitmap) XXX_DiscardUnknown()

func (*AttestationBitmap) XXX_Marshal 

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

func (*AttestationBitmap) XXX_Merge 

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

func (*AttestationBitmap) XXX_Size 

func (m *AttestationBitmap) XXX_Size() int

func (*AttestationBitmap) XXX_Unmarshal 

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

type BankKeeper 

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

BankKeeper defines the expected bank keeper interface

type GenesisState 

type GenesisState struct {
	// params defines the module parameters at genesis
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// validator_indices contains the initial validator index mappings
	ValidatorIndices []ValidatorIndex `protobuf:"bytes,2,rep,name=validator_indices,json=validatorIndices,proto3" json:"validator_indices"`
	// attestation_bitmaps contains historical attestation data
	AttestationBitmaps []AttestationBitmap `protobuf:"bytes,3,rep,name=attestation_bitmaps,json=attestationBitmaps,proto3" json:"attestation_bitmaps"`
}

GenesisState defines the network module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAttestationBitmaps 

func (m *GenesisState) GetAttestationBitmaps() []AttestationBitmap

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetValidatorIndices 

func (m *GenesisState) GetValidatorIndices() []ValidatorIndex

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

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 MsgAttest 

type MsgAttest struct {
	// validator is the address of the validator submitting the attestation
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// height is the checkpoint height being attested
	Height int64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// vote is the base64-encoded canonical Comet vote
	Vote []byte `protobuf:"bytes,3,opt,name=vote,proto3" json:"vote,omitempty"`
}

MsgAttest submits a signed vote for a checkpoint

func NewMsgAttest 

func NewMsgAttest(validator string, height int64, vote []byte) *MsgAttest

NewMsgAttest creates a new MsgAttest instance

func (*MsgAttest) Descriptor 

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

func (*MsgAttest) Marshal 

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

func (*MsgAttest) MarshalTo 

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

func (*MsgAttest) MarshalToSizedBuffer 

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

func (*MsgAttest) ProtoMessage 

func (*MsgAttest) ProtoMessage()

func (*MsgAttest) Reset 

func (m *MsgAttest) Reset()

func (*MsgAttest) Size 

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

func (*MsgAttest) String 

func (m *MsgAttest) String() string

func (*MsgAttest) Unmarshal 

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

func (*MsgAttest) XXX_DiscardUnknown 

func (m *MsgAttest) XXX_DiscardUnknown()

func (*MsgAttest) XXX_Marshal 

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

func (*MsgAttest) XXX_Merge 

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

func (*MsgAttest) XXX_Size 

func (m *MsgAttest) XXX_Size() int

func (*MsgAttest) XXX_Unmarshal 

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

type MsgAttestResponse 

type MsgAttestResponse struct {
}

MsgAttestResponse is the response type for the Attest RPC

func (*MsgAttestResponse) Descriptor 

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

func (*MsgAttestResponse) Marshal 

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

func (*MsgAttestResponse) MarshalTo 

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

func (*MsgAttestResponse) MarshalToSizedBuffer 

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

func (*MsgAttestResponse) ProtoMessage 

func (*MsgAttestResponse) ProtoMessage()

func (*MsgAttestResponse) Reset 

func (m *MsgAttestResponse) Reset()

func (*MsgAttestResponse) Size 

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

func (*MsgAttestResponse) String 

func (m *MsgAttestResponse) String() string

func (*MsgAttestResponse) Unmarshal 

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

func (*MsgAttestResponse) XXX_DiscardUnknown 

func (m *MsgAttestResponse) XXX_DiscardUnknown()

func (*MsgAttestResponse) XXX_Marshal 

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

func (*MsgAttestResponse) XXX_Merge 

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

func (*MsgAttestResponse) XXX_Size 

func (m *MsgAttestResponse) XXX_Size() int

func (*MsgAttestResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// Attest submits a signed vote for a checkpoint
	Attest(ctx context.Context, in *MsgAttest, opts ...grpc.CallOption) (*MsgAttestResponse, error)
	// JoinAttesterSet opts a validator into the attester set
	JoinAttesterSet(ctx context.Context, in *MsgJoinAttesterSet, opts ...grpc.CallOption) (*MsgJoinAttesterSetResponse, error)
	// LeaveAttesterSet opts a validator out of the attester set
	LeaveAttesterSet(ctx context.Context, in *MsgLeaveAttesterSet, opts ...grpc.CallOption) (*MsgLeaveAttesterSetResponse, error)
	// UpdateParams updates the module parameters
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgJoinAttesterSet 

type MsgJoinAttesterSet struct {
	// validator is the address of the validator joining
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

MsgJoinAttesterSet opts a validator into the attester set

func NewMsgJoinAttesterSet 

func NewMsgJoinAttesterSet(validator string) *MsgJoinAttesterSet

NewMsgJoinAttesterSet creates a new MsgJoinAttesterSet instance

func (*MsgJoinAttesterSet) Descriptor 

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

func (*MsgJoinAttesterSet) Marshal 

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

func (*MsgJoinAttesterSet) MarshalTo 

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

func (*MsgJoinAttesterSet) MarshalToSizedBuffer 

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

func (*MsgJoinAttesterSet) ProtoMessage 

func (*MsgJoinAttesterSet) ProtoMessage()

func (*MsgJoinAttesterSet) Reset 

func (m *MsgJoinAttesterSet) Reset()

func (*MsgJoinAttesterSet) Size 

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

func (*MsgJoinAttesterSet) String 

func (m *MsgJoinAttesterSet) String() string

func (*MsgJoinAttesterSet) Unmarshal 

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

func (*MsgJoinAttesterSet) XXX_DiscardUnknown 

func (m *MsgJoinAttesterSet) XXX_DiscardUnknown()

func (*MsgJoinAttesterSet) XXX_Marshal 

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

func (*MsgJoinAttesterSet) XXX_Merge 

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

func (*MsgJoinAttesterSet) XXX_Size 

func (m *MsgJoinAttesterSet) XXX_Size() int

func (*MsgJoinAttesterSet) XXX_Unmarshal 

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

type MsgJoinAttesterSetResponse 

type MsgJoinAttesterSetResponse struct {
}

MsgJoinAttesterSetResponse is the response type for the JoinAttesterSet RPC

func (*MsgJoinAttesterSetResponse) Descriptor 

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

func (*MsgJoinAttesterSetResponse) Marshal 

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

func (*MsgJoinAttesterSetResponse) MarshalTo 

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

func (*MsgJoinAttesterSetResponse) MarshalToSizedBuffer 

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

func (*MsgJoinAttesterSetResponse) ProtoMessage 

func (*MsgJoinAttesterSetResponse) ProtoMessage()

func (*MsgJoinAttesterSetResponse) Reset 

func (m *MsgJoinAttesterSetResponse) Reset()

func (*MsgJoinAttesterSetResponse) Size 

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

func (*MsgJoinAttesterSetResponse) String 

func (m *MsgJoinAttesterSetResponse) String() string

func (*MsgJoinAttesterSetResponse) Unmarshal 

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

func (*MsgJoinAttesterSetResponse) XXX_DiscardUnknown 

func (m *MsgJoinAttesterSetResponse) XXX_DiscardUnknown()

func (*MsgJoinAttesterSetResponse) XXX_Marshal 

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

func (*MsgJoinAttesterSetResponse) XXX_Merge 

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

func (*MsgJoinAttesterSetResponse) XXX_Size 

func (m *MsgJoinAttesterSetResponse) XXX_Size() int

func (*MsgJoinAttesterSetResponse) XXX_Unmarshal 

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

type MsgLeaveAttesterSet 

type MsgLeaveAttesterSet struct {
	// validator is the address of the validator leaving
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

MsgLeaveAttesterSet opts a validator out of the attester set

func NewMsgLeaveAttesterSet 

func NewMsgLeaveAttesterSet(validator string) *MsgLeaveAttesterSet

NewMsgLeaveAttesterSet creates a new MsgLeaveAttesterSet instance

func (*MsgLeaveAttesterSet) Descriptor 

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

func (*MsgLeaveAttesterSet) Marshal 

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

func (*MsgLeaveAttesterSet) MarshalTo 

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

func (*MsgLeaveAttesterSet) MarshalToSizedBuffer 

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

func (*MsgLeaveAttesterSet) ProtoMessage 

func (*MsgLeaveAttesterSet) ProtoMessage()

func (*MsgLeaveAttesterSet) Reset 

func (m *MsgLeaveAttesterSet) Reset()

func (*MsgLeaveAttesterSet) Size 

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

func (*MsgLeaveAttesterSet) String 

func (m *MsgLeaveAttesterSet) String() string

func (*MsgLeaveAttesterSet) Unmarshal 

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

func (*MsgLeaveAttesterSet) XXX_DiscardUnknown 

func (m *MsgLeaveAttesterSet) XXX_DiscardUnknown()

func (*MsgLeaveAttesterSet) XXX_Marshal 

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

func (*MsgLeaveAttesterSet) XXX_Merge 

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

func (*MsgLeaveAttesterSet) XXX_Size 

func (m *MsgLeaveAttesterSet) XXX_Size() int

func (*MsgLeaveAttesterSet) XXX_Unmarshal 

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

type MsgLeaveAttesterSetResponse 

type MsgLeaveAttesterSetResponse struct {
}

MsgLeaveAttesterSetResponse is the response type for the LeaveAttesterSet RPC

func (*MsgLeaveAttesterSetResponse) Descriptor 

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

func (*MsgLeaveAttesterSetResponse) Marshal 

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

func (*MsgLeaveAttesterSetResponse) MarshalTo 

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

func (*MsgLeaveAttesterSetResponse) MarshalToSizedBuffer 

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

func (*MsgLeaveAttesterSetResponse) ProtoMessage 

func (*MsgLeaveAttesterSetResponse) ProtoMessage()

func (*MsgLeaveAttesterSetResponse) Reset 

func (m *MsgLeaveAttesterSetResponse) Reset()

func (*MsgLeaveAttesterSetResponse) Size 

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

func (*MsgLeaveAttesterSetResponse) String 

func (m *MsgLeaveAttesterSetResponse) String() string

func (*MsgLeaveAttesterSetResponse) Unmarshal 

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

func (*MsgLeaveAttesterSetResponse) XXX_DiscardUnknown 

func (m *MsgLeaveAttesterSetResponse) XXX_DiscardUnknown()

func (*MsgLeaveAttesterSetResponse) XXX_Marshal 

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

func (*MsgLeaveAttesterSetResponse) XXX_Merge 

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

func (*MsgLeaveAttesterSetResponse) XXX_Size 

func (m *MsgLeaveAttesterSetResponse) XXX_Size() int

func (*MsgLeaveAttesterSetResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Attest submits a signed vote for a checkpoint
	Attest(context.Context, *MsgAttest) (*MsgAttestResponse, error)
	// JoinAttesterSet opts a validator into the attester set
	JoinAttesterSet(context.Context, *MsgJoinAttesterSet) (*MsgJoinAttesterSetResponse, error)
	// LeaveAttesterSet opts a validator out of the attester set
	LeaveAttesterSet(context.Context, *MsgLeaveAttesterSet) (*MsgLeaveAttesterSetResponse, error)
	// UpdateParams updates the module parameters
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address that controls the module
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the module parameters to update
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams updates the network module parameters

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) 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) 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 is the response type for the UpdateParams RPC

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 Params 

type Params struct {
	// epoch_length is the number of blocks per attestation window
	EpochLength uint64 `protobuf:"varint,1,opt,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"`
	// quorum_fraction is the voting power needed for soft-finality (e.g., "2/3")
	QuorumFraction string `protobuf:"bytes,2,opt,name=quorum_fraction,json=quorumFraction,proto3" json:"quorum_fraction,omitempty"`
	// min_participation is the ejection threshold inside an epoch (e.g., "1/2")
	MinParticipation string `protobuf:"bytes,3,opt,name=min_participation,json=minParticipation,proto3" json:"min_participation,omitempty"`
	// prune_after is the number of epochs to retain attestation bitmaps
	PruneAfter uint64 `protobuf:"varint,4,opt,name=prune_after,json=pruneAfter,proto3" json:"prune_after,omitempty"`
	// sign_mode determines when validators must sign
	SignMode SignMode `protobuf:"varint,5,opt,name=sign_mode,json=signMode,proto3,enum=evabci.network.v1.SignMode" json:"sign_mode,omitempty"`
}

Params defines the parameters for the network module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default parameters

func NewParams 

func NewParams(
	epochLength uint64,
	quorumFraction math.LegacyDec,
	minParticipation math.LegacyDec,
	pruneAfter uint64,
	signMode SignMode,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetEpochLength 

func (m *Params) GetEpochLength() uint64

func (*Params) GetMinParticipation 

func (m *Params) GetMinParticipation() string

func (*Params) GetPruneAfter 

func (m *Params) GetPruneAfter() uint64

func (*Params) GetQuorumFraction 

func (m *Params) GetQuorumFraction() string

func (*Params) GetSignMode 

func (m *Params) GetSignMode() SignMode

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs implements params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the parameter set

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 QueryAttestationBitmapRequest 

type QueryAttestationBitmapRequest struct {
	Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

QueryAttestationBitmapRequest is the request type for the Query/AttestationBitmap RPC method.

func (*QueryAttestationBitmapRequest) Descriptor 

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

func (*QueryAttestationBitmapRequest) GetHeight 

func (m *QueryAttestationBitmapRequest) GetHeight() int64

func (*QueryAttestationBitmapRequest) Marshal 

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

func (*QueryAttestationBitmapRequest) MarshalTo 

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

func (*QueryAttestationBitmapRequest) MarshalToSizedBuffer 

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

func (*QueryAttestationBitmapRequest) ProtoMessage 

func (*QueryAttestationBitmapRequest) ProtoMessage()

func (*QueryAttestationBitmapRequest) Reset 

func (m *QueryAttestationBitmapRequest) Reset()

func (*QueryAttestationBitmapRequest) Size 

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

func (*QueryAttestationBitmapRequest) String 

func (m *QueryAttestationBitmapRequest) String() string

func (*QueryAttestationBitmapRequest) Unmarshal 

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

func (*QueryAttestationBitmapRequest) XXX_DiscardUnknown 

func (m *QueryAttestationBitmapRequest) XXX_DiscardUnknown()

func (*QueryAttestationBitmapRequest) XXX_Marshal 

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

func (*QueryAttestationBitmapRequest) XXX_Merge 

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

func (*QueryAttestationBitmapRequest) XXX_Size 

func (m *QueryAttestationBitmapRequest) XXX_Size() int

func (*QueryAttestationBitmapRequest) XXX_Unmarshal 

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

type QueryAttestationBitmapResponse 

type QueryAttestationBitmapResponse struct {
	Bitmap *AttestationBitmap `protobuf:"bytes,1,opt,name=bitmap,proto3" json:"bitmap,omitempty"`
}

QueryAttestationBitmapResponse is the response type for the Query/AttestationBitmap RPC method.

func (*QueryAttestationBitmapResponse) Descriptor 

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

func (*QueryAttestationBitmapResponse) GetBitmap 

func (m *QueryAttestationBitmapResponse) GetBitmap() *AttestationBitmap

func (*QueryAttestationBitmapResponse) Marshal 

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

func (*QueryAttestationBitmapResponse) MarshalTo 

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

func (*QueryAttestationBitmapResponse) MarshalToSizedBuffer 

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

func (*QueryAttestationBitmapResponse) ProtoMessage 

func (*QueryAttestationBitmapResponse) ProtoMessage()

func (*QueryAttestationBitmapResponse) Reset 

func (m *QueryAttestationBitmapResponse) Reset()

func (*QueryAttestationBitmapResponse) Size 

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

func (*QueryAttestationBitmapResponse) String 

func (m *QueryAttestationBitmapResponse) String() string

func (*QueryAttestationBitmapResponse) Unmarshal 

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

func (*QueryAttestationBitmapResponse) XXX_DiscardUnknown 

func (m *QueryAttestationBitmapResponse) XXX_DiscardUnknown()

func (*QueryAttestationBitmapResponse) XXX_Marshal 

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

func (*QueryAttestationBitmapResponse) XXX_Merge 

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

func (*QueryAttestationBitmapResponse) XXX_Size 

func (m *QueryAttestationBitmapResponse) XXX_Size() int

func (*QueryAttestationBitmapResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Params queries the module parameters
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// AttestationBitmap queries the attestation bitmap for a specific height
	AttestationBitmap(ctx context.Context, in *QueryAttestationBitmapRequest, opts ...grpc.CallOption) (*QueryAttestationBitmapResponse, error)
	// EpochInfo queries information about a specific epoch
	EpochInfo(ctx context.Context, in *QueryEpochInfoRequest, opts ...grpc.CallOption) (*QueryEpochInfoResponse, error)
	// ValidatorIndex queries the bitmap index for a validator
	ValidatorIndex(ctx context.Context, in *QueryValidatorIndexRequest, opts ...grpc.CallOption) (*QueryValidatorIndexResponse, error)
	// SoftConfirmationStatus queries if a height is soft-confirmed
	SoftConfirmationStatus(ctx context.Context, in *QuerySoftConfirmationStatusRequest, opts ...grpc.CallOption) (*QuerySoftConfirmationStatusResponse, 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 QueryEpochInfoRequest 

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

QueryEpochInfoRequest is the request type for the Query/EpochInfo RPC method.

func (*QueryEpochInfoRequest) Descriptor 

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

func (*QueryEpochInfoRequest) GetEpoch 

func (m *QueryEpochInfoRequest) GetEpoch() uint64

func (*QueryEpochInfoRequest) Marshal 

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

func (*QueryEpochInfoRequest) MarshalTo 

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

func (*QueryEpochInfoRequest) MarshalToSizedBuffer 

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

func (*QueryEpochInfoRequest) ProtoMessage 

func (*QueryEpochInfoRequest) ProtoMessage()

func (*QueryEpochInfoRequest) Reset 

func (m *QueryEpochInfoRequest) Reset()

func (*QueryEpochInfoRequest) Size 

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

func (*QueryEpochInfoRequest) String 

func (m *QueryEpochInfoRequest) String() string

func (*QueryEpochInfoRequest) Unmarshal 

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

func (*QueryEpochInfoRequest) XXX_DiscardUnknown 

func (m *QueryEpochInfoRequest) XXX_DiscardUnknown()

func (*QueryEpochInfoRequest) XXX_Marshal 

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

func (*QueryEpochInfoRequest) XXX_Merge 

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

func (*QueryEpochInfoRequest) XXX_Size 

func (m *QueryEpochInfoRequest) XXX_Size() int

func (*QueryEpochInfoRequest) XXX_Unmarshal 

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

type QueryEpochInfoResponse 

type QueryEpochInfoResponse struct {
	Epoch                   uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	StartHeight             int64  `protobuf:"varint,2,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
	EndHeight               int64  `protobuf:"varint,3,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"`
	ParticipationBitmap     []byte `protobuf:"bytes,4,opt,name=participation_bitmap,json=participationBitmap,proto3" json:"participation_bitmap,omitempty"`
	ActiveValidators        uint64 `protobuf:"varint,5,opt,name=active_validators,json=activeValidators,proto3" json:"active_validators,omitempty"`
	ParticipatingValidators uint64 `` /* 131-byte string literal not displayed */
}

QueryEpochInfoResponse is the response type for the Query/EpochInfo RPC method.

func (*QueryEpochInfoResponse) Descriptor 

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

func (*QueryEpochInfoResponse) GetActiveValidators 

func (m *QueryEpochInfoResponse) GetActiveValidators() uint64

func (*QueryEpochInfoResponse) GetEndHeight 

func (m *QueryEpochInfoResponse) GetEndHeight() int64

func (*QueryEpochInfoResponse) GetEpoch 

func (m *QueryEpochInfoResponse) GetEpoch() uint64

func (*QueryEpochInfoResponse) GetParticipatingValidators 

func (m *QueryEpochInfoResponse) GetParticipatingValidators() uint64

func (*QueryEpochInfoResponse) GetParticipationBitmap 

func (m *QueryEpochInfoResponse) GetParticipationBitmap() []byte

func (*QueryEpochInfoResponse) GetStartHeight 

func (m *QueryEpochInfoResponse) GetStartHeight() int64

func (*QueryEpochInfoResponse) Marshal 

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

func (*QueryEpochInfoResponse) MarshalTo 

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

func (*QueryEpochInfoResponse) MarshalToSizedBuffer 

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

func (*QueryEpochInfoResponse) ProtoMessage 

func (*QueryEpochInfoResponse) ProtoMessage()

func (*QueryEpochInfoResponse) Reset 

func (m *QueryEpochInfoResponse) Reset()

func (*QueryEpochInfoResponse) Size 

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

func (*QueryEpochInfoResponse) String 

func (m *QueryEpochInfoResponse) String() string

func (*QueryEpochInfoResponse) Unmarshal 

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

func (*QueryEpochInfoResponse) XXX_DiscardUnknown 

func (m *QueryEpochInfoResponse) XXX_DiscardUnknown()

func (*QueryEpochInfoResponse) XXX_Marshal 

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

func (*QueryEpochInfoResponse) XXX_Merge 

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

func (*QueryEpochInfoResponse) XXX_Size 

func (m *QueryEpochInfoResponse) XXX_Size() int

func (*QueryEpochInfoResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the module parameters
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// AttestationBitmap queries the attestation bitmap for a specific height
	AttestationBitmap(context.Context, *QueryAttestationBitmapRequest) (*QueryAttestationBitmapResponse, error)
	// EpochInfo queries information about a specific epoch
	EpochInfo(context.Context, *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)
	// ValidatorIndex queries the bitmap index for a validator
	ValidatorIndex(context.Context, *QueryValidatorIndexRequest) (*QueryValidatorIndexResponse, error)
	// SoftConfirmationStatus queries if a height is soft-confirmed
	SoftConfirmationStatus(context.Context, *QuerySoftConfirmationStatusRequest) (*QuerySoftConfirmationStatusResponse, error)
}

QueryServer is the server API for Query service.

type QuerySoftConfirmationStatusRequest 

type QuerySoftConfirmationStatusRequest struct {
	Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

QuerySoftConfirmationStatusRequest is the request type for the Query/SoftConfirmationStatus RPC method.

func (*QuerySoftConfirmationStatusRequest) Descriptor 

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

func (*QuerySoftConfirmationStatusRequest) GetHeight 

func (m *QuerySoftConfirmationStatusRequest) GetHeight() int64

func (*QuerySoftConfirmationStatusRequest) Marshal 

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

func (*QuerySoftConfirmationStatusRequest) MarshalTo 

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

func (*QuerySoftConfirmationStatusRequest) MarshalToSizedBuffer 

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

func (*QuerySoftConfirmationStatusRequest) ProtoMessage 

func (*QuerySoftConfirmationStatusRequest) ProtoMessage()

func (*QuerySoftConfirmationStatusRequest) Reset 

func (m *QuerySoftConfirmationStatusRequest) Reset()

func (*QuerySoftConfirmationStatusRequest) Size 

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

func (*QuerySoftConfirmationStatusRequest) String 

func (m *QuerySoftConfirmationStatusRequest) String() string

func (*QuerySoftConfirmationStatusRequest) Unmarshal 

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

func (*QuerySoftConfirmationStatusRequest) XXX_DiscardUnknown 

func (m *QuerySoftConfirmationStatusRequest) XXX_DiscardUnknown()

func (*QuerySoftConfirmationStatusRequest) XXX_Marshal 

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

func (*QuerySoftConfirmationStatusRequest) XXX_Merge 

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

func (*QuerySoftConfirmationStatusRequest) XXX_Size 

func (m *QuerySoftConfirmationStatusRequest) XXX_Size() int

func (*QuerySoftConfirmationStatusRequest) XXX_Unmarshal 

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

type QuerySoftConfirmationStatusResponse 

type QuerySoftConfirmationStatusResponse struct {
	IsSoftConfirmed bool   `protobuf:"varint,1,opt,name=is_soft_confirmed,json=isSoftConfirmed,proto3" json:"is_soft_confirmed,omitempty"`
	VotedPower      uint64 `protobuf:"varint,2,opt,name=voted_power,json=votedPower,proto3" json:"voted_power,omitempty"`
	TotalPower      uint64 `protobuf:"varint,3,opt,name=total_power,json=totalPower,proto3" json:"total_power,omitempty"`
	QuorumFraction  string `protobuf:"bytes,4,opt,name=quorum_fraction,json=quorumFraction,proto3" json:"quorum_fraction,omitempty"`
}

QuerySoftConfirmationStatusResponse is the response type for the Query/SoftConfirmationStatus RPC method.

func (*QuerySoftConfirmationStatusResponse) Descriptor 

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

func (*QuerySoftConfirmationStatusResponse) GetIsSoftConfirmed 

func (m *QuerySoftConfirmationStatusResponse) GetIsSoftConfirmed() bool

func (*QuerySoftConfirmationStatusResponse) GetQuorumFraction 

func (m *QuerySoftConfirmationStatusResponse) GetQuorumFraction() string

func (*QuerySoftConfirmationStatusResponse) GetTotalPower 

func (m *QuerySoftConfirmationStatusResponse) GetTotalPower() uint64

func (*QuerySoftConfirmationStatusResponse) GetVotedPower 

func (m *QuerySoftConfirmationStatusResponse) GetVotedPower() uint64

func (*QuerySoftConfirmationStatusResponse) Marshal 

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

func (*QuerySoftConfirmationStatusResponse) MarshalTo 

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

func (*QuerySoftConfirmationStatusResponse) MarshalToSizedBuffer 

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

func (*QuerySoftConfirmationStatusResponse) ProtoMessage 

func (*QuerySoftConfirmationStatusResponse) ProtoMessage()

func (*QuerySoftConfirmationStatusResponse) Reset 

func (m *QuerySoftConfirmationStatusResponse) Reset()

func (*QuerySoftConfirmationStatusResponse) Size 

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

func (*QuerySoftConfirmationStatusResponse) String 

func (m *QuerySoftConfirmationStatusResponse) String() string

func (*QuerySoftConfirmationStatusResponse) Unmarshal 

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

func (*QuerySoftConfirmationStatusResponse) XXX_DiscardUnknown 

func (m *QuerySoftConfirmationStatusResponse) XXX_DiscardUnknown()

func (*QuerySoftConfirmationStatusResponse) XXX_Marshal 

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

func (*QuerySoftConfirmationStatusResponse) XXX_Merge 

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

func (*QuerySoftConfirmationStatusResponse) XXX_Size 

func (m *QuerySoftConfirmationStatusResponse) XXX_Size() int

func (*QuerySoftConfirmationStatusResponse) XXX_Unmarshal 

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

type QueryValidatorIndexRequest 

type QueryValidatorIndexRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryValidatorIndexRequest is the request type for the Query/ValidatorIndex RPC method.

func (*QueryValidatorIndexRequest) Descriptor 

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

func (*QueryValidatorIndexRequest) GetAddress 

func (m *QueryValidatorIndexRequest) GetAddress() string

func (*QueryValidatorIndexRequest) Marshal 

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

func (*QueryValidatorIndexRequest) MarshalTo 

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

func (*QueryValidatorIndexRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorIndexRequest) ProtoMessage 

func (*QueryValidatorIndexRequest) ProtoMessage()

func (*QueryValidatorIndexRequest) Reset 

func (m *QueryValidatorIndexRequest) Reset()

func (*QueryValidatorIndexRequest) Size 

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

func (*QueryValidatorIndexRequest) String 

func (m *QueryValidatorIndexRequest) String() string

func (*QueryValidatorIndexRequest) Unmarshal 

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

func (*QueryValidatorIndexRequest) XXX_DiscardUnknown 

func (m *QueryValidatorIndexRequest) XXX_DiscardUnknown()

func (*QueryValidatorIndexRequest) XXX_Marshal 

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

func (*QueryValidatorIndexRequest) XXX_Merge 

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

func (*QueryValidatorIndexRequest) XXX_Size 

func (m *QueryValidatorIndexRequest) XXX_Size() int

func (*QueryValidatorIndexRequest) XXX_Unmarshal 

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

type QueryValidatorIndexResponse 

type QueryValidatorIndexResponse struct {
	Index *ValidatorIndex `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"`
}

QueryValidatorIndexResponse is the response type for the Query/ValidatorIndex RPC method.

func (*QueryValidatorIndexResponse) Descriptor 

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

func (*QueryValidatorIndexResponse) GetIndex 

func (m *QueryValidatorIndexResponse) GetIndex() *ValidatorIndex

func (*QueryValidatorIndexResponse) Marshal 

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

func (*QueryValidatorIndexResponse) MarshalTo 

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

func (*QueryValidatorIndexResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorIndexResponse) ProtoMessage 

func (*QueryValidatorIndexResponse) ProtoMessage()

func (*QueryValidatorIndexResponse) Reset 

func (m *QueryValidatorIndexResponse) Reset()

func (*QueryValidatorIndexResponse) Size 

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

func (*QueryValidatorIndexResponse) String 

func (m *QueryValidatorIndexResponse) String() string

func (*QueryValidatorIndexResponse) Unmarshal 

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

func (*QueryValidatorIndexResponse) XXX_DiscardUnknown 

func (m *QueryValidatorIndexResponse) XXX_DiscardUnknown()

func (*QueryValidatorIndexResponse) XXX_Marshal 

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

func (*QueryValidatorIndexResponse) XXX_Merge 

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

func (*QueryValidatorIndexResponse) XXX_Size 

func (m *QueryValidatorIndexResponse) XXX_Size() int

func (*QueryValidatorIndexResponse) XXX_Unmarshal 

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

type SignMode 

type SignMode int32

SignMode defines when validators must sign 

const (
	// SIGN_MODE_UNSPECIFIED is invalid
	SignMode_SIGN_MODE_UNSPECIFIED SignMode = 0
	// SIGN_MODE_CHECKPOINT means validators sign only at checkpoint heights
	SignMode_SIGN_MODE_CHECKPOINT SignMode = 1
)

func (SignMode) EnumDescriptor 

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

func (SignMode) String 

func (x SignMode) String() string

type StakingKeeper 

type StakingKeeper interface {
	GetAllValidators(ctx context.Context) (validators []stakingtypes.Validator, err error)
	GetValidator(ctx context.Context, addr sdk.ValAddress) (validator stakingtypes.Validator, err error)
	GetLastValidators(ctx context.Context) (validators []stakingtypes.Validator, err error)
	GetLastTotalPower(ctx context.Context) (math.Int, error)
}

StakingKeeper defines the expected staking keeper interface

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Attest 

func (*UnimplementedMsgServer) Attest(ctx context.Context, req *MsgAttest) (*MsgAttestResponse, error)

func (*UnimplementedMsgServer) JoinAttesterSet 

func (*UnimplementedMsgServer) JoinAttesterSet(ctx context.Context, req *MsgJoinAttesterSet) (*MsgJoinAttesterSetResponse, error)

func (*UnimplementedMsgServer) LeaveAttesterSet 

func (*UnimplementedMsgServer) LeaveAttesterSet(ctx context.Context, req *MsgLeaveAttesterSet) (*MsgLeaveAttesterSetResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AttestationBitmap 

func (*UnimplementedQueryServer) AttestationBitmap(ctx context.Context, req *QueryAttestationBitmapRequest) (*QueryAttestationBitmapResponse, error)

func (*UnimplementedQueryServer) EpochInfo 

func (*UnimplementedQueryServer) EpochInfo(ctx context.Context, req *QueryEpochInfoRequest) (*QueryEpochInfoResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) SoftConfirmationStatus 

func (*UnimplementedQueryServer) SoftConfirmationStatus(ctx context.Context, req *QuerySoftConfirmationStatusRequest) (*QuerySoftConfirmationStatusResponse, error)

func (*UnimplementedQueryServer) ValidatorIndex 

func (*UnimplementedQueryServer) ValidatorIndex(ctx context.Context, req *QueryValidatorIndexRequest) (*QueryValidatorIndexResponse, error)

type ValidatorIndex 

type ValidatorIndex struct {
	// address is the validator operator address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// index is the position in the bitmap
	Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// power is the cached voting power
	Power uint64 `protobuf:"varint,3,opt,name=power,proto3" json:"power,omitempty"`
}

ValidatorIndex maps a validator address to its bitmap index

func (*ValidatorIndex) Descriptor 

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

func (*ValidatorIndex) GetAddress 

func (m *ValidatorIndex) GetAddress() string

func (*ValidatorIndex) GetIndex 

func (m *ValidatorIndex) GetIndex() uint32

func (*ValidatorIndex) GetPower 

func (m *ValidatorIndex) GetPower() uint64

func (*ValidatorIndex) Marshal 

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

func (*ValidatorIndex) MarshalTo 

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

func (*ValidatorIndex) MarshalToSizedBuffer 

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

func (*ValidatorIndex) ProtoMessage 

func (*ValidatorIndex) ProtoMessage()

func (*ValidatorIndex) Reset 

func (m *ValidatorIndex) Reset()

func (*ValidatorIndex) Size 

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

func (*ValidatorIndex) String 

func (m *ValidatorIndex) String() string

func (*ValidatorIndex) Unmarshal 

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

func (*ValidatorIndex) XXX_DiscardUnknown 

func (m *ValidatorIndex) XXX_DiscardUnknown()

func (*ValidatorIndex) XXX_Marshal 

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

func (*ValidatorIndex) XXX_Merge 

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

func (*ValidatorIndex) XXX_Size 

func (m *ValidatorIndex) XXX_Size() int

func (*ValidatorIndex) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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