mempool

package
v0.0.0-...-22ab5e0 Latest Latest
Warning

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

 Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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")
)

Functions

This section is empty.

Types

type Message 

type Message struct {
	// Types that are valid to be assigned to Sum:
	//
	//	*Message_Txs
	//	*Message_SeenTx
	//	*Message_WantTx
	Sum isMessage_Sum `protobuf_oneof:"sum"`
}

func (*Message) Descriptor 

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

func (*Message) GetSeenTx 

func (m *Message) GetSeenTx() *SeenTx

func (*Message) GetSum 

func (m *Message) GetSum() isMessage_Sum

func (*Message) GetTxs 

func (m *Message) GetTxs() *Txs

func (*Message) GetWantTx 

func (m *Message) GetWantTx() *WantTx

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) Unwrap 

func (m *Message) Unwrap() (proto.Message, error)

Unwrap implements the p2p Wrapper interface and unwraps a wrapped mempool message.

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_OneofWrappers 

func (*Message) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_SeenTx 

type Message_SeenTx struct {
	SeenTx *SeenTx `protobuf:"bytes,2,opt,name=seen_tx,json=seenTx,proto3,oneof" json:"seen_tx,omitempty"`
}

func (*Message_SeenTx) MarshalTo 

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

func (*Message_SeenTx) MarshalToSizedBuffer 

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

func (*Message_SeenTx) Size 

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

type Message_Txs 

type Message_Txs struct {
	Txs *Txs `protobuf:"bytes,1,opt,name=txs,proto3,oneof" json:"txs,omitempty"`
}

func (*Message_Txs) MarshalTo 

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

func (*Message_Txs) MarshalToSizedBuffer 

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

func (*Message_Txs) Size 

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

type Message_WantTx 

type Message_WantTx struct {
	WantTx *WantTx `protobuf:"bytes,3,opt,name=want_tx,json=wantTx,proto3,oneof" json:"want_tx,omitempty"`
}

func (*Message_WantTx) MarshalTo 

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

func (*Message_WantTx) MarshalToSizedBuffer 

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

func (*Message_WantTx) Size 

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

type SeenTx 

type SeenTx struct {
	TxKey []byte `protobuf:"bytes,1,opt,name=tx_key,json=txKey,proto3" json:"tx_key,omitempty"`
}

func (*SeenTx) Descriptor 

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

func (*SeenTx) GetTxKey 

func (m *SeenTx) GetTxKey() []byte

func (*SeenTx) Marshal 

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

func (*SeenTx) MarshalTo 

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

func (*SeenTx) MarshalToSizedBuffer 

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

func (*SeenTx) ProtoMessage 

func (*SeenTx) ProtoMessage()

func (*SeenTx) Reset 

func (m *SeenTx) Reset()

func (*SeenTx) Size 

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

func (*SeenTx) String 

func (m *SeenTx) String() string

func (*SeenTx) Unmarshal 

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

func (*SeenTx) Wrap 

func (m *SeenTx) Wrap() proto.Message

Wrap implements the p2p Wrapper interface and wraps a mempool seen tx message.

func (*SeenTx) XXX_DiscardUnknown 

func (m *SeenTx) XXX_DiscardUnknown()

func (*SeenTx) XXX_Marshal 

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

func (*SeenTx) XXX_Merge 

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

func (*SeenTx) XXX_Size 

func (m *SeenTx) XXX_Size() int

func (*SeenTx) XXX_Unmarshal 

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

type Txs 

type Txs struct {
	Txs [][]byte `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
}

func (*Txs) Descriptor 

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

func (*Txs) GetTxs 

func (m *Txs) GetTxs() [][]byte

func (*Txs) Marshal 

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

func (*Txs) MarshalTo 

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

func (*Txs) MarshalToSizedBuffer 

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

func (*Txs) ProtoMessage 

func (*Txs) ProtoMessage()

func (*Txs) Reset 

func (m *Txs) Reset()

func (*Txs) Size 

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

func (*Txs) String 

func (m *Txs) String() string

func (*Txs) Unmarshal 

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

func (*Txs) Wrap 

func (m *Txs) Wrap() proto.Message

Wrap implements the p2p Wrapper interface and wraps a mempool message.

func (*Txs) XXX_DiscardUnknown 

func (m *Txs) XXX_DiscardUnknown()

func (*Txs) XXX_Marshal 

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

func (*Txs) XXX_Merge 

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

func (*Txs) XXX_Size 

func (m *Txs) XXX_Size() int

func (*Txs) XXX_Unmarshal 

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

type WantTx 

type WantTx struct {
	TxKey []byte `protobuf:"bytes,1,opt,name=tx_key,json=txKey,proto3" json:"tx_key,omitempty"`
}

func (*WantTx) Descriptor 

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

func (*WantTx) GetTxKey 

func (m *WantTx) GetTxKey() []byte

func (*WantTx) Marshal 

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

func (*WantTx) MarshalTo 

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

func (*WantTx) MarshalToSizedBuffer 

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

func (*WantTx) ProtoMessage 

func (*WantTx) ProtoMessage()

func (*WantTx) Reset 

func (m *WantTx) Reset()

func (*WantTx) Size 

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

func (*WantTx) String 

func (m *WantTx) String() string

func (*WantTx) Unmarshal 

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

func (*WantTx) Wrap 

func (m *WantTx) Wrap() proto.Message

Wrap implements the p2p Wrapper interface and wraps a mempool want tx message.

func (*WantTx) XXX_DiscardUnknown 

func (m *WantTx) XXX_DiscardUnknown()

func (*WantTx) XXX_Marshal 

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

func (*WantTx) XXX_Merge 

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

func (*WantTx) XXX_Size 

func (m *WantTx) XXX_Size() int

func (*WantTx) XXX_Unmarshal 

func (m *WantTx) 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.