libp2p

package
v0.0.182 Latest Latest
Warning

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

Go to latest
Published: Jul 23, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	TraceAddPeerType = xatu.Event_LIBP2P_TRACE_ADD_PEER.String()
)
View Source
var (
	TraceConnectedType = xatu.Event_LIBP2P_TRACE_CONNECTED.String()
)
View Source
var (
	TraceDisconnectedType = xatu.Event_LIBP2P_TRACE_DISCONNECTED.String()
)
View Source
var (
	TraceGossipSubBeaconAttestationType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_BEACON_ATTESTATION.String()
)
View Source
var (
	TraceGossipSubBeaconBlockType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_BEACON_BLOCK.String()
)
View Source
var (
	TraceGossipSubBlobSidecarType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_BLOB_SIDECAR.String()
)
View Source
var (
	TraceHandleMetadataType = xatu.Event_LIBP2P_TRACE_HANDLE_METADATA.String()
)
View Source
var (
	TraceHandleStatusType = xatu.Event_LIBP2P_TRACE_HANDLE_STATUS.String()
)
View Source
var (
	TraceJoinType = xatu.Event_LIBP2P_TRACE_JOIN.String()
)
View Source
var (
	TraceRecvRPCType = xatu.Event_LIBP2P_TRACE_RECV_RPC.String()
)
View Source
var (
	TraceRemovePeerType = xatu.Event_LIBP2P_TRACE_REMOVE_PEER.String()
)
View Source
var (
	TraceSendRPCType = xatu.Event_LIBP2P_TRACE_SEND_RPC.String()
)

Functions

This section is empty.

Types

type TraceAddPeer

type TraceAddPeer struct {
	// contains filtered or unexported fields
}

func NewTraceAddPeer

func NewTraceAddPeer(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceAddPeer

func (*TraceAddPeer) AppendServerMeta

func (tap *TraceAddPeer) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceAddPeer) Filter

func (tap *TraceAddPeer) Filter(ctx context.Context) bool

func (*TraceAddPeer) Type

func (tap *TraceAddPeer) Type() string

func (*TraceAddPeer) Validate

func (tap *TraceAddPeer) Validate(ctx context.Context) error

type TraceConnected

type TraceConnected struct {
	// contains filtered or unexported fields
}

func NewTraceConnected

func NewTraceConnected(log logrus.FieldLogger, event *xatu.DecoratedEvent, geoipProvider geoip.Provider) *TraceConnected

func (*TraceConnected) AppendServerMeta

func (tc *TraceConnected) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceConnected) Filter

func (tc *TraceConnected) Filter(ctx context.Context) bool

func (*TraceConnected) Type

func (tc *TraceConnected) Type() string

func (*TraceConnected) Validate

func (tc *TraceConnected) Validate(ctx context.Context) error

type TraceDisconnected

type TraceDisconnected struct {
	// contains filtered or unexported fields
}

func NewTraceDisconnected

func NewTraceDisconnected(log logrus.FieldLogger, event *xatu.DecoratedEvent, geoipProvider geoip.Provider) *TraceDisconnected

func (*TraceDisconnected) AppendServerMeta

func (td *TraceDisconnected) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceDisconnected) Filter

func (td *TraceDisconnected) Filter(ctx context.Context) bool

func (*TraceDisconnected) Type

func (td *TraceDisconnected) Type() string

func (*TraceDisconnected) Validate

func (td *TraceDisconnected) Validate(ctx context.Context) error

type TraceGossipSubBeaconAttestation added in v0.0.169

type TraceGossipSubBeaconAttestation struct {
	// contains filtered or unexported fields
}

func NewTraceGossipSubBeaconAttestation added in v0.0.169

func NewTraceGossipSubBeaconAttestation(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGossipSubBeaconAttestation

func (*TraceGossipSubBeaconAttestation) AppendServerMeta added in v0.0.169

func (gsb *TraceGossipSubBeaconAttestation) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceGossipSubBeaconAttestation) Filter added in v0.0.169

func (*TraceGossipSubBeaconAttestation) Type added in v0.0.169

func (*TraceGossipSubBeaconAttestation) Validate added in v0.0.169

type TraceGossipSubBeaconBlock added in v0.0.168

type TraceGossipSubBeaconBlock struct {
	// contains filtered or unexported fields
}

func NewTraceGossipSubBeaconBlock added in v0.0.168

func NewTraceGossipSubBeaconBlock(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGossipSubBeaconBlock

func (*TraceGossipSubBeaconBlock) AppendServerMeta added in v0.0.168

func (gsb *TraceGossipSubBeaconBlock) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceGossipSubBeaconBlock) Filter added in v0.0.168

func (gsb *TraceGossipSubBeaconBlock) Filter(ctx context.Context) bool

func (*TraceGossipSubBeaconBlock) Type added in v0.0.168

func (gsb *TraceGossipSubBeaconBlock) Type() string

func (*TraceGossipSubBeaconBlock) Validate added in v0.0.168

func (gsb *TraceGossipSubBeaconBlock) Validate(ctx context.Context) error

type TraceGossipSubBlobSidecar added in v0.0.170

type TraceGossipSubBlobSidecar struct {
	// contains filtered or unexported fields
}

func NewTraceGossipSubBlobSidecar added in v0.0.170

func NewTraceGossipSubBlobSidecar(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGossipSubBlobSidecar

func (*TraceGossipSubBlobSidecar) AppendServerMeta added in v0.0.170

func (t *TraceGossipSubBlobSidecar) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

AppendServerMeta implements event.Event.

func (*TraceGossipSubBlobSidecar) Filter added in v0.0.170

Filter implements event.Event.

func (*TraceGossipSubBlobSidecar) Type added in v0.0.170

Type implements event.Event.

func (*TraceGossipSubBlobSidecar) Validate added in v0.0.170

Validate implements event.Event.

type TraceHandleMetadata added in v0.0.166

type TraceHandleMetadata struct {
	// contains filtered or unexported fields
}

func NewTraceHandleMetadata added in v0.0.166

func NewTraceHandleMetadata(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceHandleMetadata

func (*TraceHandleMetadata) AppendServerMeta added in v0.0.166

func (trr *TraceHandleMetadata) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceHandleMetadata) Filter added in v0.0.166

func (trr *TraceHandleMetadata) Filter(ctx context.Context) bool

func (*TraceHandleMetadata) Type added in v0.0.166

func (trr *TraceHandleMetadata) Type() string

func (*TraceHandleMetadata) Validate added in v0.0.166

func (trr *TraceHandleMetadata) Validate(ctx context.Context) error

type TraceHandleStatus added in v0.0.166

type TraceHandleStatus struct {
	// contains filtered or unexported fields
}

func NewTraceHandleStatus added in v0.0.166

func NewTraceHandleStatus(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceHandleStatus

func (*TraceHandleStatus) AppendServerMeta added in v0.0.166

func (trr *TraceHandleStatus) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceHandleStatus) Filter added in v0.0.166

func (trr *TraceHandleStatus) Filter(ctx context.Context) bool

func (*TraceHandleStatus) Type added in v0.0.166

func (trr *TraceHandleStatus) Type() string

func (*TraceHandleStatus) Validate added in v0.0.166

func (trr *TraceHandleStatus) Validate(ctx context.Context) error

type TraceJoin

type TraceJoin struct {
	// contains filtered or unexported fields
}

func NewTraceJoin

func NewTraceJoin(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceJoin

func (*TraceJoin) AppendServerMeta

func (tjm *TraceJoin) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceJoin) Filter

func (tjm *TraceJoin) Filter(ctx context.Context) bool

func (*TraceJoin) Type

func (tjm *TraceJoin) Type() string

func (*TraceJoin) Validate

func (tjm *TraceJoin) Validate(ctx context.Context) error

type TraceRecvRPC

type TraceRecvRPC struct {
	// contains filtered or unexported fields
}

func NewTraceRecvRPC

func NewTraceRecvRPC(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRecvRPC

func (*TraceRecvRPC) AppendServerMeta

func (trr *TraceRecvRPC) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceRecvRPC) Filter

func (trr *TraceRecvRPC) Filter(ctx context.Context) bool

func (*TraceRecvRPC) Type

func (trr *TraceRecvRPC) Type() string

func (*TraceRecvRPC) Validate

func (trr *TraceRecvRPC) Validate(ctx context.Context) error

type TraceRemovePeer

type TraceRemovePeer struct {
	// contains filtered or unexported fields
}

func NewTraceRemovePeer

func NewTraceRemovePeer(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRemovePeer

func (*TraceRemovePeer) AppendServerMeta

func (trp *TraceRemovePeer) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceRemovePeer) Filter

func (trp *TraceRemovePeer) Filter(ctx context.Context) bool

func (*TraceRemovePeer) Type

func (trp *TraceRemovePeer) Type() string

func (*TraceRemovePeer) Validate

func (trp *TraceRemovePeer) Validate(ctx context.Context) error

type TraceSendRPC

type TraceSendRPC struct {
	// contains filtered or unexported fields
}

func NewTraceSendRPC

func NewTraceSendRPC(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceSendRPC

func (*TraceSendRPC) AppendServerMeta

func (trr *TraceSendRPC) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceSendRPC) Filter

func (trr *TraceSendRPC) Filter(ctx context.Context) bool

func (*TraceSendRPC) Type

func (trr *TraceSendRPC) Type() string

func (*TraceSendRPC) Validate

func (trr *TraceSendRPC) Validate(ctx context.Context) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL