Versions in this module Expand all Collapse all v0 v0.1.0 Apr 21, 2023 Changes in this version + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + var File_txpool_proto_operator_proto protoreflect.FileDescriptor + var File_txpool_proto_v1_proto protoreflect.FileDescriptor + var TxnPoolOperator_ServiceDesc = grpc.ServiceDesc + func RegisterTxnPoolOperatorServer(s grpc.ServiceRegistrar, srv TxnPoolOperatorServer) + type AddTxnReq struct + From string + Raw *anypb.Any + func (*AddTxnReq) Descriptor() ([]byte, []int) + func (*AddTxnReq) ProtoMessage() + func (m *AddTxnReq) Validate() error + func (m *AddTxnReq) ValidateAll() error + func (x *AddTxnReq) GetFrom() string + func (x *AddTxnReq) GetRaw() *anypb.Any + func (x *AddTxnReq) ProtoReflect() protoreflect.Message + func (x *AddTxnReq) Reset() + func (x *AddTxnReq) String() string + type AddTxnReqMultiError []error + func (m AddTxnReqMultiError) AllErrors() []error + func (m AddTxnReqMultiError) Error() string + type AddTxnReqValidationError struct + func (e AddTxnReqValidationError) Cause() error + func (e AddTxnReqValidationError) Error() string + func (e AddTxnReqValidationError) ErrorName() string + func (e AddTxnReqValidationError) Field() string + func (e AddTxnReqValidationError) Key() bool + func (e AddTxnReqValidationError) Reason() string + type AddTxnResp struct + TxHash string + func (*AddTxnResp) Descriptor() ([]byte, []int) + func (*AddTxnResp) ProtoMessage() + func (m *AddTxnResp) Validate() error + func (m *AddTxnResp) ValidateAll() error + func (x *AddTxnResp) GetTxHash() string + func (x *AddTxnResp) ProtoReflect() protoreflect.Message + func (x *AddTxnResp) Reset() + func (x *AddTxnResp) String() string + type AddTxnRespMultiError []error + func (m AddTxnRespMultiError) AllErrors() []error + func (m AddTxnRespMultiError) Error() string + type AddTxnRespValidationError struct + func (e AddTxnRespValidationError) Cause() error + func (e AddTxnRespValidationError) Error() string + func (e AddTxnRespValidationError) ErrorName() string + func (e AddTxnRespValidationError) Field() string + func (e AddTxnRespValidationError) Key() bool + func (e AddTxnRespValidationError) Reason() string + type EventType int32 + const EventType_ADDED + const EventType_DEMOTED + const EventType_DROPPED + const EventType_ENQUEUED + const EventType_PROMOTED + const EventType_PRUNED_ENQUEUED + const EventType_PRUNED_PROMOTED + func (EventType) Descriptor() protoreflect.EnumDescriptor + func (EventType) EnumDescriptor() ([]byte, []int) + func (EventType) Type() protoreflect.EnumType + func (x EventType) Enum() *EventType + func (x EventType) Number() protoreflect.EnumNumber + func (x EventType) String() string + type SubscribeRequest struct + Types []EventType + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (m *SubscribeRequest) Validate() error + func (m *SubscribeRequest) ValidateAll() error + func (x *SubscribeRequest) GetTypes() []EventType + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type SubscribeRequestMultiError []error + func (m SubscribeRequestMultiError) AllErrors() []error + func (m SubscribeRequestMultiError) Error() string + type SubscribeRequestValidationError struct + func (e SubscribeRequestValidationError) Cause() error + func (e SubscribeRequestValidationError) Error() string + func (e SubscribeRequestValidationError) ErrorName() string + func (e SubscribeRequestValidationError) Field() string + func (e SubscribeRequestValidationError) Key() bool + func (e SubscribeRequestValidationError) Reason() string + type TxPoolEvent struct + TxHash string + Type EventType + func (*TxPoolEvent) Descriptor() ([]byte, []int) + func (*TxPoolEvent) ProtoMessage() + func (m *TxPoolEvent) Validate() error + func (m *TxPoolEvent) ValidateAll() error + func (x *TxPoolEvent) GetTxHash() string + func (x *TxPoolEvent) GetType() EventType + func (x *TxPoolEvent) ProtoReflect() protoreflect.Message + func (x *TxPoolEvent) Reset() + func (x *TxPoolEvent) String() string + type TxPoolEventMultiError []error + func (m TxPoolEventMultiError) AllErrors() []error + func (m TxPoolEventMultiError) Error() string + type TxPoolEventValidationError struct + func (e TxPoolEventValidationError) Cause() error + func (e TxPoolEventValidationError) Error() string + func (e TxPoolEventValidationError) ErrorName() string + func (e TxPoolEventValidationError) Field() string + func (e TxPoolEventValidationError) Key() bool + func (e TxPoolEventValidationError) Reason() string + type Txn struct + Raw *anypb.Any + func (*Txn) Descriptor() ([]byte, []int) + func (*Txn) ProtoMessage() + func (m *Txn) Validate() error + func (m *Txn) ValidateAll() error + func (x *Txn) GetRaw() *anypb.Any + func (x *Txn) ProtoReflect() protoreflect.Message + func (x *Txn) Reset() + func (x *Txn) String() string + type TxnMultiError []error + func (m TxnMultiError) AllErrors() []error + func (m TxnMultiError) Error() string + type TxnPoolOperatorClient interface + AddTxn func(ctx context.Context, in *AddTxnReq, opts ...grpc.CallOption) (*AddTxnResp, error) + Status func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TxnPoolStatusResp, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (TxnPoolOperator_SubscribeClient, error) + func NewTxnPoolOperatorClient(cc grpc.ClientConnInterface) TxnPoolOperatorClient + type TxnPoolOperatorServer interface + AddTxn func(context.Context, *AddTxnReq) (*AddTxnResp, error) + Status func(context.Context, *emptypb.Empty) (*TxnPoolStatusResp, error) + Subscribe func(*SubscribeRequest, TxnPoolOperator_SubscribeServer) error + type TxnPoolOperator_SubscribeClient interface + Recv func() (*TxPoolEvent, error) + type TxnPoolOperator_SubscribeServer interface + Send func(*TxPoolEvent) error + type TxnPoolStatusResp struct + Length uint64 + func (*TxnPoolStatusResp) Descriptor() ([]byte, []int) + func (*TxnPoolStatusResp) ProtoMessage() + func (m *TxnPoolStatusResp) Validate() error + func (m *TxnPoolStatusResp) ValidateAll() error + func (x *TxnPoolStatusResp) GetLength() uint64 + func (x *TxnPoolStatusResp) ProtoReflect() protoreflect.Message + func (x *TxnPoolStatusResp) Reset() + func (x *TxnPoolStatusResp) String() string + type TxnPoolStatusRespMultiError []error + func (m TxnPoolStatusRespMultiError) AllErrors() []error + func (m TxnPoolStatusRespMultiError) Error() string + type TxnPoolStatusRespValidationError struct + func (e TxnPoolStatusRespValidationError) Cause() error + func (e TxnPoolStatusRespValidationError) Error() string + func (e TxnPoolStatusRespValidationError) ErrorName() string + func (e TxnPoolStatusRespValidationError) Field() string + func (e TxnPoolStatusRespValidationError) Key() bool + func (e TxnPoolStatusRespValidationError) Reason() string + type TxnValidationError struct + func (e TxnValidationError) Cause() error + func (e TxnValidationError) Error() string + func (e TxnValidationError) ErrorName() string + func (e TxnValidationError) Field() string + func (e TxnValidationError) Key() bool + func (e TxnValidationError) Reason() string + type UnimplementedTxnPoolOperatorServer struct + func (UnimplementedTxnPoolOperatorServer) AddTxn(context.Context, *AddTxnReq) (*AddTxnResp, error) + func (UnimplementedTxnPoolOperatorServer) Status(context.Context, *emptypb.Empty) (*TxnPoolStatusResp, error) + func (UnimplementedTxnPoolOperatorServer) Subscribe(*SubscribeRequest, TxnPoolOperator_SubscribeServer) error + type UnsafeTxnPoolOperatorServer interface
Go to main page