chore: Address linter issues (#20486)
This commit is contained in:
Alexander Peters
GitHub
parent
0256369851
commit
a6857962c5
2
Makefile
2
Makefile
@ -395,7 +395,7 @@ benchmark:
|
||||
### Linting ###
|
||||
###############################################################################
|
||||
|
||||
golangci_version=v1.56.2
|
||||
golangci_version=v1.59.0
|
||||
|
||||
#? setup-pre-commit: Set pre-commit git hook
|
||||
setup-pre-commit:
|
||||
|
||||
@ -1,6 +1,8 @@
|
||||
package context
|
||||
|
||||
type contextKey uint8
|
||||
|
||||
const (
|
||||
ExecModeKey = iota
|
||||
CometInfoKey
|
||||
ExecModeKey contextKey = iota
|
||||
CometInfoKey contextKey = iota
|
||||
)
|
||||
|
||||
@ -6,6 +6,10 @@ package cmtservice
|
||||
import (
|
||||
context "context"
|
||||
fmt "fmt"
|
||||
io "io"
|
||||
math "math"
|
||||
math_bits "math/bits"
|
||||
|
||||
v11 "github.com/cometbft/cometbft/api/cometbft/p2p/v1"
|
||||
v1 "github.com/cometbft/cometbft/api/cometbft/types/v1"
|
||||
_ "github.com/cosmos/cosmos-proto"
|
||||
@ -19,15 +23,15 @@ import (
|
||||
grpc "google.golang.org/grpc"
|
||||
codes "google.golang.org/grpc/codes"
|
||||
status "google.golang.org/grpc/status"
|
||||
io "io"
|
||||
math "math"
|
||||
math_bits "math/bits"
|
||||
)
|
||||
|
||||
// Reference imports to suppress errors if they are not otherwise used.
|
||||
var _ = proto.Marshal
|
||||
var _ = fmt.Errorf
|
||||
var _ = math.Inf
|
||||
|
||||
var (
|
||||
_ = fmt.Errorf
|
||||
_ = math.Inf
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the proto package it is being compiled against.
|
||||
@ -48,9 +52,11 @@ func (*GetValidatorSetByHeightRequest) ProtoMessage() {}
|
||||
func (*GetValidatorSetByHeightRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{0}
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetValidatorSetByHeightRequest.Marshal(b, m, deterministic)
|
||||
@ -63,12 +69,15 @@ func (m *GetValidatorSetByHeightRequest) XXX_Marshal(b []byte, deterministic boo
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetValidatorSetByHeightRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetValidatorSetByHeightRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -103,9 +112,11 @@ func (*GetValidatorSetByHeightResponse) ProtoMessage() {}
|
||||
func (*GetValidatorSetByHeightResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{1}
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetValidatorSetByHeightResponse.Marshal(b, m, deterministic)
|
||||
@ -118,12 +129,15 @@ func (m *GetValidatorSetByHeightResponse) XXX_Marshal(b []byte, deterministic bo
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetValidatorSetByHeightResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetValidatorSetByHeightResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -163,9 +177,11 @@ func (*GetLatestValidatorSetRequest) ProtoMessage() {}
|
||||
func (*GetLatestValidatorSetRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{2}
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetLatestValidatorSetRequest.Marshal(b, m, deterministic)
|
||||
@ -178,12 +194,15 @@ func (m *GetLatestValidatorSetRequest) XXX_Marshal(b []byte, deterministic bool)
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetLatestValidatorSetRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetLatestValidatorSetRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -211,9 +230,11 @@ func (*GetLatestValidatorSetResponse) ProtoMessage() {}
|
||||
func (*GetLatestValidatorSetResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{3}
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetLatestValidatorSetResponse.Marshal(b, m, deterministic)
|
||||
@ -226,12 +247,15 @@ func (m *GetLatestValidatorSetResponse) XXX_Marshal(b []byte, deterministic bool
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetLatestValidatorSetResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetLatestValidatorSetResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -273,9 +297,11 @@ func (*Validator) ProtoMessage() {}
|
||||
func (*Validator) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{4}
|
||||
}
|
||||
|
||||
func (m *Validator) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *Validator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_Validator.Marshal(b, m, deterministic)
|
||||
@ -288,12 +314,15 @@ func (m *Validator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *Validator) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Validator.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *Validator) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *Validator) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Validator.DiscardUnknown(m)
|
||||
}
|
||||
@ -339,9 +368,11 @@ func (*GetBlockByHeightRequest) ProtoMessage() {}
|
||||
func (*GetBlockByHeightRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{5}
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetBlockByHeightRequest.Marshal(b, m, deterministic)
|
||||
@ -354,12 +385,15 @@ func (m *GetBlockByHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]b
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetBlockByHeightRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetBlockByHeightRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -387,9 +421,11 @@ func (*GetBlockByHeightResponse) ProtoMessage() {}
|
||||
func (*GetBlockByHeightResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{6}
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetBlockByHeightResponse.Marshal(b, m, deterministic)
|
||||
@ -402,12 +438,15 @@ func (m *GetBlockByHeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetBlockByHeightResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetBlockByHeightResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -436,8 +475,7 @@ func (m *GetBlockByHeightResponse) GetSdkBlock() *Block {
|
||||
}
|
||||
|
||||
// GetLatestBlockRequest is the request type for the Query/GetLatestBlock RPC method.
|
||||
type GetLatestBlockRequest struct {
|
||||
}
|
||||
type GetLatestBlockRequest struct{}
|
||||
|
||||
func (m *GetLatestBlockRequest) Reset() { *m = GetLatestBlockRequest{} }
|
||||
func (m *GetLatestBlockRequest) String() string { return proto.CompactTextString(m) }
|
||||
@ -445,9 +483,11 @@ func (*GetLatestBlockRequest) ProtoMessage() {}
|
||||
func (*GetLatestBlockRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{7}
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetLatestBlockRequest.Marshal(b, m, deterministic)
|
||||
@ -460,12 +500,15 @@ func (m *GetLatestBlockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byt
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetLatestBlockRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetLatestBlockRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -486,9 +529,11 @@ func (*GetLatestBlockResponse) ProtoMessage() {}
|
||||
func (*GetLatestBlockResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{8}
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetLatestBlockResponse.Marshal(b, m, deterministic)
|
||||
@ -501,12 +546,15 @@ func (m *GetLatestBlockResponse) XXX_Marshal(b []byte, deterministic bool) ([]by
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetLatestBlockResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetLatestBlockResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -535,8 +583,7 @@ func (m *GetLatestBlockResponse) GetSdkBlock() *Block {
|
||||
}
|
||||
|
||||
// GetSyncingRequest is the request type for the Query/GetSyncing RPC method.
|
||||
type GetSyncingRequest struct {
|
||||
}
|
||||
type GetSyncingRequest struct{}
|
||||
|
||||
func (m *GetSyncingRequest) Reset() { *m = GetSyncingRequest{} }
|
||||
func (m *GetSyncingRequest) String() string { return proto.CompactTextString(m) }
|
||||
@ -544,9 +591,11 @@ func (*GetSyncingRequest) ProtoMessage() {}
|
||||
func (*GetSyncingRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{9}
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetSyncingRequest.Marshal(b, m, deterministic)
|
||||
@ -559,12 +608,15 @@ func (m *GetSyncingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, e
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetSyncingRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetSyncingRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -582,9 +634,11 @@ func (*GetSyncingResponse) ProtoMessage() {}
|
||||
func (*GetSyncingResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{10}
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetSyncingResponse.Marshal(b, m, deterministic)
|
||||
@ -597,12 +651,15 @@ func (m *GetSyncingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte,
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetSyncingResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetSyncingResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -617,8 +674,7 @@ func (m *GetSyncingResponse) GetSyncing() bool {
|
||||
}
|
||||
|
||||
// GetNodeInfoRequest is the request type for the Query/GetNodeInfo RPC method.
|
||||
type GetNodeInfoRequest struct {
|
||||
}
|
||||
type GetNodeInfoRequest struct{}
|
||||
|
||||
func (m *GetNodeInfoRequest) Reset() { *m = GetNodeInfoRequest{} }
|
||||
func (m *GetNodeInfoRequest) String() string { return proto.CompactTextString(m) }
|
||||
@ -626,9 +682,11 @@ func (*GetNodeInfoRequest) ProtoMessage() {}
|
||||
func (*GetNodeInfoRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{11}
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetNodeInfoRequest.Marshal(b, m, deterministic)
|
||||
@ -641,12 +699,15 @@ func (m *GetNodeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte,
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetNodeInfoRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetNodeInfoRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -665,9 +726,11 @@ func (*GetNodeInfoResponse) ProtoMessage() {}
|
||||
func (*GetNodeInfoResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{12}
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_GetNodeInfoResponse.Marshal(b, m, deterministic)
|
||||
@ -680,12 +743,15 @@ func (m *GetNodeInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte,
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_GetNodeInfoResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_GetNodeInfoResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -724,9 +790,11 @@ func (*VersionInfo) ProtoMessage() {}
|
||||
func (*VersionInfo) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{13}
|
||||
}
|
||||
|
||||
func (m *VersionInfo) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *VersionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_VersionInfo.Marshal(b, m, deterministic)
|
||||
@ -739,12 +807,15 @@ func (m *VersionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *VersionInfo) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_VersionInfo.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *VersionInfo) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *VersionInfo) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_VersionInfo.DiscardUnknown(m)
|
||||
}
|
||||
@ -823,9 +894,11 @@ func (*Module) ProtoMessage() {}
|
||||
func (*Module) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{14}
|
||||
}
|
||||
|
||||
func (m *Module) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *Module) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_Module.Marshal(b, m, deterministic)
|
||||
@ -838,12 +911,15 @@ func (m *Module) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *Module) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Module.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *Module) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *Module) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Module.DiscardUnknown(m)
|
||||
}
|
||||
@ -885,9 +961,11 @@ func (*ABCIQueryRequest) ProtoMessage() {}
|
||||
func (*ABCIQueryRequest) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{15}
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_ABCIQueryRequest.Marshal(b, m, deterministic)
|
||||
@ -900,12 +978,15 @@ func (m *ABCIQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, er
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_ABCIQueryRequest.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_ABCIQueryRequest.DiscardUnknown(m)
|
||||
}
|
||||
@ -962,9 +1043,11 @@ func (*ABCIQueryResponse) ProtoMessage() {}
|
||||
func (*ABCIQueryResponse) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{16}
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_ABCIQueryResponse.Marshal(b, m, deterministic)
|
||||
@ -977,12 +1060,15 @@ func (m *ABCIQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, e
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_ABCIQueryResponse.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_ABCIQueryResponse.DiscardUnknown(m)
|
||||
}
|
||||
@ -1069,9 +1155,11 @@ func (*ProofOp) ProtoMessage() {}
|
||||
func (*ProofOp) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{17}
|
||||
}
|
||||
|
||||
func (m *ProofOp) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *ProofOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_ProofOp.Marshal(b, m, deterministic)
|
||||
@ -1084,12 +1172,15 @@ func (m *ProofOp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *ProofOp) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_ProofOp.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *ProofOp) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *ProofOp) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_ProofOp.DiscardUnknown(m)
|
||||
}
|
||||
@ -1130,9 +1221,11 @@ func (*ProofOps) ProtoMessage() {}
|
||||
func (*ProofOps) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_40c93fb3ef485c5d, []int{18}
|
||||
}
|
||||
|
||||
func (m *ProofOps) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *ProofOps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_ProofOps.Marshal(b, m, deterministic)
|
||||
@ -1145,12 +1238,15 @@ func (m *ProofOps) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *ProofOps) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_ProofOps.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *ProofOps) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *ProofOps) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_ProofOps.DiscardUnknown(m)
|
||||
}
|
||||
@ -1406,27 +1502,32 @@ type ServiceServer interface {
|
||||
}
|
||||
|
||||
// UnimplementedServiceServer can be embedded to have forward compatible implementations.
|
||||
type UnimplementedServiceServer struct {
|
||||
}
|
||||
type UnimplementedServiceServer struct{}
|
||||
|
||||
func (*UnimplementedServiceServer) GetNodeInfo(ctx context.Context, req *GetNodeInfoRequest) (*GetNodeInfoResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetNodeInfo not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) GetSyncing(ctx context.Context, req *GetSyncingRequest) (*GetSyncingResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetSyncing not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) GetLatestBlock(ctx context.Context, req *GetLatestBlockRequest) (*GetLatestBlockResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetLatestBlock not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) GetBlockByHeight(ctx context.Context, req *GetBlockByHeightRequest) (*GetBlockByHeightResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetBlockByHeight not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) GetLatestValidatorSet(ctx context.Context, req *GetLatestValidatorSetRequest) (*GetLatestValidatorSetResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetLatestValidatorSet not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) GetValidatorSetByHeight(ctx context.Context, req *GetValidatorSetByHeightRequest) (*GetValidatorSetByHeightResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method GetValidatorSetByHeight not implemented")
|
||||
}
|
||||
|
||||
func (*UnimplementedServiceServer) ABCIQuery(ctx context.Context, req *ABCIQueryRequest) (*ABCIQueryResponse, error) {
|
||||
return nil, status.Errorf(codes.Unimplemented, "method ABCIQuery not implemented")
|
||||
}
|
||||
@ -2487,6 +2588,7 @@ func encodeVarintQuery(dAtA []byte, offset int, v uint64) int {
|
||||
dAtA[offset] = uint8(v)
|
||||
return base
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) Size() (n int) {
|
||||
if m == nil {
|
||||
return 0
|
||||
@ -2861,9 +2963,11 @@ func (m *ProofOps) Size() (n int) {
|
||||
func sovQuery(x uint64) (n int) {
|
||||
return (math_bits.Len64(x|1) + 6) / 7
|
||||
}
|
||||
|
||||
func sozQuery(x uint64) (n int) {
|
||||
return sovQuery(uint64((x << 1) ^ uint64((int64(x) >> 63))))
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -2969,6 +3073,7 @@ func (m *GetValidatorSetByHeightRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetValidatorSetByHeightResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3108,6 +3213,7 @@ func (m *GetValidatorSetByHeightResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3194,6 +3300,7 @@ func (m *GetLatestValidatorSetRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetLatestValidatorSetResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3333,6 +3440,7 @@ func (m *GetLatestValidatorSetResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *Validator) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3489,6 +3597,7 @@ func (m *Validator) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3558,6 +3667,7 @@ func (m *GetBlockByHeightRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetBlockByHeightResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3716,6 +3826,7 @@ func (m *GetBlockByHeightResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3766,6 +3877,7 @@ func (m *GetLatestBlockRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetLatestBlockResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3924,6 +4036,7 @@ func (m *GetLatestBlockResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetSyncingRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -3974,6 +4087,7 @@ func (m *GetSyncingRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetSyncingResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4044,6 +4158,7 @@ func (m *GetSyncingResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4094,6 +4209,7 @@ func (m *GetNodeInfoRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *GetNodeInfoResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4216,6 +4332,7 @@ func (m *GetNodeInfoResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *VersionInfo) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4524,6 +4641,7 @@ func (m *VersionInfo) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *Module) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4670,6 +4788,7 @@ func (m *Module) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ABCIQueryRequest) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -4825,6 +4944,7 @@ func (m *ABCIQueryRequest) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ABCIQueryResponse) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -5132,6 +5252,7 @@ func (m *ABCIQueryResponse) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProofOp) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -5282,6 +5403,7 @@ func (m *ProofOp) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *ProofOps) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -5366,6 +5488,7 @@ func (m *ProofOps) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func skipQuery(dAtA []byte) (n int, err error) {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
|
||||
@ -26,12 +26,15 @@ import (
|
||||
|
||||
// Suppress "imported and not used" errors
|
||||
var _ codes.Code
|
||||
var _ io.Reader
|
||||
var _ status.Status
|
||||
var _ = runtime.String
|
||||
var _ = utilities.NewDoubleArray
|
||||
var _ = descriptor.ForMessage
|
||||
var _ = metadata.Join
|
||||
|
||||
var (
|
||||
_ io.Reader
|
||||
_ status.Status
|
||||
_ = runtime.String
|
||||
_ = utilities.NewDoubleArray
|
||||
_ = descriptor.ForMessage
|
||||
_ = metadata.Join
|
||||
)
|
||||
|
||||
func request_Service_GetNodeInfo_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
var protoReq GetNodeInfoRequest
|
||||
@ -39,7 +42,6 @@ func request_Service_GetNodeInfo_0(ctx context.Context, marshaler runtime.Marsha
|
||||
|
||||
msg, err := client.GetNodeInfo(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetNodeInfo_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -48,7 +50,6 @@ func local_request_Service_GetNodeInfo_0(ctx context.Context, marshaler runtime.
|
||||
|
||||
msg, err := server.GetNodeInfo(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func request_Service_GetSyncing_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -57,7 +58,6 @@ func request_Service_GetSyncing_0(ctx context.Context, marshaler runtime.Marshal
|
||||
|
||||
msg, err := client.GetSyncing(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetSyncing_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -66,7 +66,6 @@ func local_request_Service_GetSyncing_0(ctx context.Context, marshaler runtime.M
|
||||
|
||||
msg, err := server.GetSyncing(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func request_Service_GetLatestBlock_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -75,7 +74,6 @@ func request_Service_GetLatestBlock_0(ctx context.Context, marshaler runtime.Mar
|
||||
|
||||
msg, err := client.GetLatestBlock(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetLatestBlock_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -84,7 +82,6 @@ func local_request_Service_GetLatestBlock_0(ctx context.Context, marshaler runti
|
||||
|
||||
msg, err := server.GetLatestBlock(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func request_Service_GetBlockByHeight_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -111,7 +108,6 @@ func request_Service_GetBlockByHeight_0(ctx context.Context, marshaler runtime.M
|
||||
|
||||
msg, err := client.GetBlockByHeight(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetBlockByHeight_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -138,12 +134,9 @@ func local_request_Service_GetBlockByHeight_0(ctx context.Context, marshaler run
|
||||
|
||||
msg, err := server.GetBlockByHeight(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
var (
|
||||
filter_Service_GetLatestValidatorSet_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
|
||||
)
|
||||
var filter_Service_GetLatestValidatorSet_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
|
||||
|
||||
func request_Service_GetLatestValidatorSet_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
var protoReq GetLatestValidatorSetRequest
|
||||
@ -158,7 +151,6 @@ func request_Service_GetLatestValidatorSet_0(ctx context.Context, marshaler runt
|
||||
|
||||
msg, err := client.GetLatestValidatorSet(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetLatestValidatorSet_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -174,12 +166,9 @@ func local_request_Service_GetLatestValidatorSet_0(ctx context.Context, marshale
|
||||
|
||||
msg, err := server.GetLatestValidatorSet(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
var (
|
||||
filter_Service_GetValidatorSetByHeight_0 = &utilities.DoubleArray{Encoding: map[string]int{"height": 0}, Base: []int{1, 1, 0}, Check: []int{0, 1, 2}}
|
||||
)
|
||||
var filter_Service_GetValidatorSetByHeight_0 = &utilities.DoubleArray{Encoding: map[string]int{"height": 0}, Base: []int{1, 1, 0}, Check: []int{0, 1, 2}}
|
||||
|
||||
func request_Service_GetValidatorSetByHeight_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
var protoReq GetValidatorSetByHeightRequest
|
||||
@ -212,7 +201,6 @@ func request_Service_GetValidatorSetByHeight_0(ctx context.Context, marshaler ru
|
||||
|
||||
msg, err := client.GetValidatorSetByHeight(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_GetValidatorSetByHeight_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -246,12 +234,9 @@ func local_request_Service_GetValidatorSetByHeight_0(ctx context.Context, marsha
|
||||
|
||||
msg, err := server.GetValidatorSetByHeight(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
var (
|
||||
filter_Service_ABCIQuery_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
|
||||
)
|
||||
var filter_Service_ABCIQuery_0 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
|
||||
|
||||
func request_Service_ABCIQuery_0(ctx context.Context, marshaler runtime.Marshaler, client ServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
var protoReq ABCIQueryRequest
|
||||
@ -266,7 +251,6 @@ func request_Service_ABCIQuery_0(ctx context.Context, marshaler runtime.Marshale
|
||||
|
||||
msg, err := client.ABCIQuery(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
func local_request_Service_ABCIQuery_0(ctx context.Context, marshaler runtime.Marshaler, server ServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
|
||||
@ -282,7 +266,6 @@ func local_request_Service_ABCIQuery_0(ctx context.Context, marshaler runtime.Ma
|
||||
|
||||
msg, err := server.ABCIQuery(ctx, &protoReq)
|
||||
return msg, metadata, err
|
||||
|
||||
}
|
||||
|
||||
// RegisterServiceHandlerServer registers the http handlers for service Service to "mux".
|
||||
@ -290,7 +273,6 @@ func local_request_Service_ABCIQuery_0(ctx context.Context, marshaler runtime.Ma
|
||||
// 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 RegisterServiceHandlerFromEndpoint instead.
|
||||
func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServiceServer) error {
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetNodeInfo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
ctx, cancel := context.WithCancel(req.Context())
|
||||
defer cancel()
|
||||
@ -311,7 +293,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetNodeInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetSyncing_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -334,7 +315,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetSyncing_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetLatestBlock_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -357,7 +337,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetLatestBlock_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetBlockByHeight_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -380,7 +359,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetBlockByHeight_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetLatestValidatorSet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -403,7 +381,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetLatestValidatorSet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetValidatorSetByHeight_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -426,7 +403,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_GetValidatorSetByHeight_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_ABCIQuery_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -449,7 +425,6 @@ func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, se
|
||||
}
|
||||
|
||||
forward_Service_ABCIQuery_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
return nil
|
||||
@ -492,7 +467,6 @@ func RegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *gr
|
||||
// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
|
||||
// "ServiceClient" to call the correct interceptors.
|
||||
func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServiceClient) error {
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetNodeInfo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
ctx, cancel := context.WithCancel(req.Context())
|
||||
defer cancel()
|
||||
@ -510,7 +484,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetNodeInfo_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetSyncing_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -530,7 +503,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetSyncing_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetLatestBlock_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -550,7 +522,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetLatestBlock_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetBlockByHeight_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -570,7 +541,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetBlockByHeight_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetLatestValidatorSet_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -590,7 +560,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetLatestValidatorSet_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_GetValidatorSetByHeight_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -610,7 +579,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_GetValidatorSetByHeight_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
mux.Handle("GET", pattern_Service_ABCIQuery_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
|
||||
@ -630,7 +598,6 @@ func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, cl
|
||||
}
|
||||
|
||||
forward_Service_ABCIQuery_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
|
||||
|
||||
})
|
||||
|
||||
return nil
|
||||
|
||||
@ -5,6 +5,11 @@ package cmtservice
|
||||
|
||||
import (
|
||||
fmt "fmt"
|
||||
io "io"
|
||||
math "math"
|
||||
math_bits "math/bits"
|
||||
time "time"
|
||||
|
||||
v1 "github.com/cometbft/cometbft/api/cometbft/types/v1"
|
||||
v11 "github.com/cometbft/cometbft/api/cometbft/version/v1"
|
||||
_ "github.com/cosmos/cosmos-sdk/types/tx/amino"
|
||||
@ -12,17 +17,16 @@ import (
|
||||
proto "github.com/cosmos/gogoproto/proto"
|
||||
github_com_cosmos_gogoproto_types "github.com/cosmos/gogoproto/types"
|
||||
_ "google.golang.org/protobuf/types/known/timestamppb"
|
||||
io "io"
|
||||
math "math"
|
||||
math_bits "math/bits"
|
||||
time "time"
|
||||
)
|
||||
|
||||
// Reference imports to suppress errors if they are not otherwise used.
|
||||
var _ = proto.Marshal
|
||||
var _ = fmt.Errorf
|
||||
var _ = math.Inf
|
||||
var _ = time.Kitchen
|
||||
|
||||
var (
|
||||
_ = fmt.Errorf
|
||||
_ = math.Inf
|
||||
_ = time.Kitchen
|
||||
)
|
||||
|
||||
// This is a compile-time assertion to ensure that this generated file
|
||||
// is compatible with the proto package it is being compiled against.
|
||||
@ -45,9 +49,11 @@ func (*Block) ProtoMessage() {}
|
||||
func (*Block) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_bb9931519c08e0d6, []int{0}
|
||||
}
|
||||
|
||||
func (m *Block) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_Block.Marshal(b, m, deterministic)
|
||||
@ -60,12 +66,15 @@ func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *Block) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Block.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *Block) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *Block) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Block.DiscardUnknown(m)
|
||||
}
|
||||
@ -132,9 +141,11 @@ func (*Header) ProtoMessage() {}
|
||||
func (*Header) Descriptor() ([]byte, []int) {
|
||||
return fileDescriptor_bb9931519c08e0d6, []int{1}
|
||||
}
|
||||
|
||||
func (m *Header) XXX_Unmarshal(b []byte) error {
|
||||
return m.Unmarshal(b)
|
||||
}
|
||||
|
||||
func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
if deterministic {
|
||||
return xxx_messageInfo_Header.Marshal(b, m, deterministic)
|
||||
@ -147,12 +158,15 @@ func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
||||
return b[:n], nil
|
||||
}
|
||||
}
|
||||
|
||||
func (m *Header) XXX_Merge(src proto.Message) {
|
||||
xxx_messageInfo_Header.Merge(m, src)
|
||||
}
|
||||
|
||||
func (m *Header) XXX_Size() int {
|
||||
return m.Size()
|
||||
}
|
||||
|
||||
func (m *Header) XXX_DiscardUnknown() {
|
||||
xxx_messageInfo_Header.DiscardUnknown(m)
|
||||
}
|
||||
@ -513,6 +527,7 @@ func encodeVarintTypes(dAtA []byte, offset int, v uint64) int {
|
||||
dAtA[offset] = uint8(v)
|
||||
return base
|
||||
}
|
||||
|
||||
func (m *Block) Size() (n int) {
|
||||
if m == nil {
|
||||
return 0
|
||||
@ -593,9 +608,11 @@ func (m *Header) Size() (n int) {
|
||||
func sovTypes(x uint64) (n int) {
|
||||
return (math_bits.Len64(x|1) + 6) / 7
|
||||
}
|
||||
|
||||
func sozTypes(x uint64) (n int) {
|
||||
return sovTypes(uint64((x << 1) ^ uint64((int64(x) >> 63))))
|
||||
}
|
||||
|
||||
func (m *Block) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -781,6 +798,7 @@ func (m *Block) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (m *Header) Unmarshal(dAtA []byte) error {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
@ -1285,6 +1303,7 @@ func (m *Header) Unmarshal(dAtA []byte) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func skipTypes(dAtA []byte) (n int, err error) {
|
||||
l := len(dAtA)
|
||||
iNdEx := 0
|
||||
|
||||
@ -305,11 +305,11 @@ func (aa AccAddress) String() string {
|
||||
func (aa AccAddress) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(aa.String()))
|
||||
_, _ = s.Write([]byte(aa.String()))
|
||||
case 'p':
|
||||
s.Write([]byte(fmt.Sprintf("%p", aa)))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%p", aa)))
|
||||
default:
|
||||
s.Write([]byte(fmt.Sprintf("%X", []byte(aa))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%X", []byte(aa))))
|
||||
}
|
||||
}
|
||||
|
||||
@ -456,11 +456,11 @@ func (va ValAddress) String() string {
|
||||
func (va ValAddress) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(va.String()))
|
||||
_, _ = s.Write([]byte(va.String()))
|
||||
case 'p':
|
||||
s.Write([]byte(fmt.Sprintf("%p", va)))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%p", va)))
|
||||
default:
|
||||
s.Write([]byte(fmt.Sprintf("%X", []byte(va))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%X", []byte(va))))
|
||||
}
|
||||
}
|
||||
|
||||
@ -627,11 +627,11 @@ func MustBech32ifyAddressBytes(prefix string, bs []byte) string {
|
||||
func (ca ConsAddress) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(ca.String()))
|
||||
_, _ = s.Write([]byte(ca.String()))
|
||||
case 'p':
|
||||
s.Write([]byte(fmt.Sprintf("%p", ca)))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%p", ca)))
|
||||
default:
|
||||
s.Write([]byte(fmt.Sprintf("%X", []byte(ca))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%X", []byte(ca))))
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -122,10 +122,10 @@ func ProposalStatusFromString(str string) (ProposalStatus, error) {
|
||||
func (status ProposalStatus) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(status.String()))
|
||||
_, _ = s.Write([]byte(status.String()))
|
||||
default:
|
||||
// TODO: Do this conversion more directly
|
||||
s.Write([]byte(fmt.Sprintf("%v", byte(status))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%v", byte(status))))
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -150,8 +150,8 @@ func ValidVoteOption(option VoteOption) bool {
|
||||
func (vo VoteOption) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(vo.String()))
|
||||
_, _ = s.Write([]byte(vo.String()))
|
||||
default:
|
||||
s.Write([]byte(fmt.Sprintf("%v", byte(vo))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%v", byte(vo))))
|
||||
}
|
||||
}
|
||||
|
||||
@ -141,10 +141,10 @@ func ProposalStatusFromString(str string) (ProposalStatus, error) {
|
||||
func (status ProposalStatus) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(status.String()))
|
||||
_, _ = s.Write([]byte(status.String()))
|
||||
default:
|
||||
// TODO: Do this conversion more directly
|
||||
s.Write([]byte(fmt.Sprintf("%v", byte(status))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%v", byte(status))))
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -113,8 +113,8 @@ func ValidVoteOption(option VoteOption) bool {
|
||||
func (vo VoteOption) Format(s fmt.State, verb rune) {
|
||||
switch verb {
|
||||
case 's':
|
||||
s.Write([]byte(vo.String()))
|
||||
_, _ = s.Write([]byte(vo.String()))
|
||||
default:
|
||||
s.Write([]byte(fmt.Sprintf("%v", byte(vo))))
|
||||
_, _ = s.Write([]byte(fmt.Sprintf("%v", byte(vo))))
|
||||
}
|
||||
}
|
||||
|
||||
@ -292,7 +292,6 @@ func (k Keeper) abortProposals(ctx context.Context, groupPolicyAddr sdk.AccAddre
|
||||
return err
|
||||
}
|
||||
|
||||
//nolint:gosec // "implicit memory aliasing in the for loop (because of the pointer on &proposalInfo)"
|
||||
for _, proposalInfo := range proposals {
|
||||
// Mark all proposals still in the voting phase as aborted.
|
||||
if proposalInfo.Status == group.PROPOSAL_STATUS_SUBMITTED {
|
||||
@ -337,7 +336,6 @@ func (k Keeper) pruneVotes(ctx context.Context, proposalID uint64) error {
|
||||
return err
|
||||
}
|
||||
|
||||
//nolint:gosec // "implicit memory aliasing in the for loop (because of the pointer on &v)"
|
||||
for _, v := range votes {
|
||||
err = k.voteTable.Delete(k.KVStoreService.OpenKVStore(ctx), &v)
|
||||
if err != nil {
|
||||
@ -410,7 +408,6 @@ func (k Keeper) TallyProposalsAtVPEnd(ctx context.Context) error {
|
||||
if err != nil {
|
||||
return nil
|
||||
}
|
||||
//nolint:gosec // "implicit memory aliasing in the for loop (because of the pointers in the loop)"
|
||||
for _, proposal := range proposals {
|
||||
policyInfo, err := k.getGroupPolicyInfo(ctx, proposal.GroupPolicyAddress)
|
||||
if err != nil {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user