rpcInterfaceMessages

Nov 26, 2024

Changes in this version

type GrpcMessage

+ func (gm GrpcMessage) GetError() *rpcclient.JsonError

type JsonrpcMessage

+ func (jm JsonrpcMessage) GetError() *rpcclient.JsonError

type ParsableRPCInput

+ Error *rpcclient.JsonError

+ func (pri ParsableRPCInput) GetError() *rpcclient.JsonError

type RestMessage

+ func (rm RestMessage) GetError() *rpcclient.JsonError

Nov 5, 2024

Changes in this version

+ type TendermintMessageResponse struct

+ Response TendermintMessageResponseBody

+ type TendermintMessageResponseBody struct

+ Code int

+ Log string

type TendermintrpcMessage

+ func (jm TendermintrpcMessage) CheckResponseError(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

Oct 20, 2024

Changes in this version

+ var ErrFailedToConvertMessage = sdkerrors.New("RPC error", 1000, "failed to convert a message")

+ var WontCalculateBatchHash = sdkerrors.New("Wont calculate batch hash", 892, "wont calculate batch message hash")

+ func CheckResponseErrorForJsonRpcBatch(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ func ConvertErrorToRPCError(errString string, code int) *tenderminttypes.RPCError

+ func ConvertToTendermintError(errString string, inputInfo []byte) string

+ func DescriptorSourceFromServer(refClient *grpcreflect.Client) grpcurl.DescriptorSource

+ func GetTendermintRPCError(jsonError *rpcclient.JsonError) (*tenderminttypes.RPCError, error)

+ func IdFromRawMessage(rawID json.RawMessage) (jsonrpcId, error)

+ func ParseSymbol(svcAndMethod string) (string, string)

+ func ReflectionSupport(err error) error

+ type GenericMessage interface

+ DisableErrorHandling func()

+ GetHeaders func() []pairingtypes.Metadata

+ GetParams func() interface{}

+ type GrpcMessage struct

+ Codec *dyncodec.Codec

+ Msg []byte

+ Path string

+ Registry *dyncodec.Registry

+ func (gm *GrpcMessage) GetRawRequestHash() ([]byte, error)

+ func (gm *GrpcMessage) SetParsingData(methodDesc *desc.MethodDescriptor, formatter grpcurl.Formatter)

+ func (gm *GrpcMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string

+ func (gm *GrpcMessage) UpdateLatestBlockInMessage(latestBlock uint64, modifyContent bool) (success bool)

+ func (gm GrpcMessage) GetID() json.RawMessage

+ func (gm GrpcMessage) GetMethod() string

+ func (gm GrpcMessage) GetParams() interface{}

+ func (gm GrpcMessage) GetResult() json.RawMessage

+ func (gm GrpcMessage) NewParsableRPCInput(input json.RawMessage) (parser.RPCInput, error)

+ func (gm GrpcMessage) ParseBlock(inp string) (int64, error)

+ func (jm GrpcMessage) CheckResponseError(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ type JSONRPCIntID int

+ func (id JSONRPCIntID) String() string

+ type JSONRPCStringID string

+ func (id JSONRPCStringID) String() string

+ type JsonrpcBatchMessage struct

+ func NewBatchMessage(msgs []JsonrpcMessage) (JsonrpcBatchMessage, error)

+ func (jbm *JsonrpcBatchMessage) GetBatch() []rpcclient.BatchElemWithId

+ func (jbm *JsonrpcBatchMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string

+ func (jbm *JsonrpcBatchMessage) UpdateLatestBlockInMessage(latestBlock uint64, modifyContent bool) (success bool)

+ func (jbm JsonrpcBatchMessage) GetParams() interface{}

+ func (jbm JsonrpcBatchMessage) GetRawRequestHash() ([]byte, error)

+ type JsonrpcMessage struct

+ Error *rpcclient.JsonError

+ ID json.RawMessage

+ Method string

+ Params interface{}

+ Result json.RawMessage

+ Version string

+ func ConvertBatchElement(batchElement rpcclient.BatchElemWithId) (JsonrpcMessage, error)

+ func ConvertJsonRPCMsg(rpcMsg *rpcclient.JsonrpcMessage) (*JsonrpcMessage, error)

+ func ParseJsonRPCMsg(data []byte) (msgRet []JsonrpcMessage, err error)

+ func (jm *JsonrpcMessage) GetRawRequestHash() ([]byte, error)

+ func (jm *JsonrpcMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string

+ func (jm *JsonrpcMessage) UpdateLatestBlockInMessage(latestBlock uint64, modifyContent bool) (success bool)

+ func (jm JsonrpcMessage) CheckResponseError(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ func (jm JsonrpcMessage) GetID() json.RawMessage

+ func (jm JsonrpcMessage) GetMethod() string

+ func (jm JsonrpcMessage) GetParams() interface{}

+ func (jm JsonrpcMessage) GetResult() json.RawMessage

+ func (jm JsonrpcMessage) NewParsableRPCInput(input json.RawMessage) (parser.RPCInput, error)

+ func (jm JsonrpcMessage) ParseBlock(inp string) (int64, error)

+ type ParsableRPCInput struct

+ Result json.RawMessage

+ func (pri ParsableRPCInput) GetID() json.RawMessage

+ func (pri ParsableRPCInput) GetMethod() string

+ func (pri ParsableRPCInput) GetParams() interface{}

+ func (pri ParsableRPCInput) GetResult() json.RawMessage

+ func (pri ParsableRPCInput) ParseBlock(inp string) (int64, error)

+ type RPCResponse struct

+ Error *tenderminttypes.RPCError

+ ID jsonrpcId

+ JSONRPC string

+ Result json.RawMessage

+ func ConvertTendermintMsg(rpcMsg *rpcclient.JsonrpcMessage) (*RPCResponse, error)

+ type RestMessage struct

+ Msg []byte

+ Path string

+ SpecPath string

+ func (jm RestMessage) CheckResponseError(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ func (rm *RestMessage) GetRawRequestHash() ([]byte, error)

+ func (rm *RestMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string

+ func (rm *RestMessage) UpdateLatestBlockInMessage(latestBlock uint64, modifyContent bool) (success bool)

+ func (rm RestMessage) GetID() json.RawMessage

+ func (rm RestMessage) GetMethod() string

+ func (rm RestMessage) GetParams() interface{}

+ func (rm RestMessage) GetResult() json.RawMessage

+ func (rm RestMessage) ParseBlock(inp string) (int64, error)

+ type ServerSource struct

+ Client *grpcreflect.Client

+ func (ss ServerSource) AllExtensionsForType(typeName string) ([]*desc.FieldDescriptor, error)

+ func (ss ServerSource) FindSymbol(fullyQualifiedName string) (desc.Descriptor, error)

+ func (ss ServerSource) ListServices() ([]string, error)

+ type TendermintrpcMessage struct

+ Path string

+ func (cp TendermintrpcMessage) GetParams() interface{}

+ func (tm *TendermintrpcMessage) GetRawRequestHash() ([]byte, error)

+ func (tm TendermintrpcMessage) GetResult() json.RawMessage

+ func (tm TendermintrpcMessage) ParseBlock(inp string) (int64, error)

+ func (tm TendermintrpcMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string