libp2p

package
v0.0.168 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 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 (
	TraceGossipSubBeaconBlockType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_BEACON_BLOCK.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 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 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

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.