libp2p

package
v1.6.2 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2025 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const TypeLibp2pRPCDataColumnCustodyProbe = "LIBP2P_TRACE_RPC_DATA_COLUMN_CUSTODY_PROBE"

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 (
	TraceDeliverMessageType = xatu.Event_LIBP2P_TRACE_DELIVER_MESSAGE.String()
)
View Source 
var (
	TraceDisconnectedType = xatu.Event_LIBP2P_TRACE_DISCONNECTED.String()
)
View Source 
var (
	TraceDropRPCType = xatu.Event_LIBP2P_TRACE_DROP_RPC.String()
)
View Source 
var (
	TraceDuplicateMessageType = xatu.Event_LIBP2P_TRACE_DUPLICATE_MESSAGE.String()
)
View Source 
var (
	TraceGossipSubAggregateAndProofType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_AGGREGATE_AND_PROOF.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 (
	TraceGossipSubDataColumnSidecarType = xatu.Event_LIBP2P_TRACE_GOSSIPSUB_DATA_COLUMN_SIDECAR.String()
)
View Source 
var (
	TraceGraftType = xatu.Event_LIBP2P_TRACE_GRAFT.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 (
	TraceLeaveType = xatu.Event_LIBP2P_TRACE_LEAVE.String()
)
View Source 
var (
	TracePruneType = xatu.Event_LIBP2P_TRACE_PRUNE.String()
)
View Source 
var (
	TracePublishMessageType = xatu.Event_LIBP2P_TRACE_PUBLISH_MESSAGE.String()
)
View Source 
var (
	TraceRPCMetaControlGraftType = xatu.Event_LIBP2P_TRACE_RPC_META_CONTROL_GRAFT.String()
)
View Source 
var (
	TraceRPCMetaControlIDontWantType = xatu.Event_LIBP2P_TRACE_RPC_META_CONTROL_IDONTWANT.String()
)
View Source 
var (
	TraceRPCMetaControlIHaveType = xatu.Event_LIBP2P_TRACE_RPC_META_CONTROL_IHAVE.String()
)
View Source 
var (
	TraceRPCMetaControlIWantType = xatu.Event_LIBP2P_TRACE_RPC_META_CONTROL_IWANT.String()
)
View Source 
var (
	TraceRPCMetaControlPruneType = xatu.Event_LIBP2P_TRACE_RPC_META_CONTROL_PRUNE.String()
)
View Source 
var (
	TraceRPCMetaMessageType = xatu.Event_LIBP2P_TRACE_RPC_META_MESSAGE.String()
)
View Source 
var (
	TraceRPCMetaSubscriptionType = xatu.Event_LIBP2P_TRACE_RPC_META_SUBSCRIPTION.String()
)
View Source 
var (
	TraceRecvRPCType = xatu.Event_LIBP2P_TRACE_RECV_RPC.String()
)
View Source 
var (
	TraceRejectMessageType = xatu.Event_LIBP2P_TRACE_REJECT_MESSAGE.String()
)
View Source 
var (
	TraceRemovePeerType = xatu.Event_LIBP2P_TRACE_REMOVE_PEER.String()
)
View Source 
var (
	TraceSendRPCType = xatu.Event_LIBP2P_TRACE_SEND_RPC.String()
)
View Source 
var TraceSyntheticHeartbeatType = xatu.Event_LIBP2P_TRACE_SYNTHETIC_HEARTBEAT.String()

Functions

This section is empty.

Types

type DataColumnCustodyProbe added in v1.5.0 

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

func NewDataColumnCustodyProbe added in v1.5.0 

func NewDataColumnCustodyProbe(log logrus.FieldLogger, event *xatu.DecoratedEvent) *DataColumnCustodyProbe

func (*DataColumnCustodyProbe) AppendServerMeta added in v1.5.0 

func (e *DataColumnCustodyProbe) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*DataColumnCustodyProbe) Filter added in v1.5.0 

func (e *DataColumnCustodyProbe) Filter(ctx context.Context) bool

func (*DataColumnCustodyProbe) Type added in v1.5.0 

func (e *DataColumnCustodyProbe) Type() string

func (*DataColumnCustodyProbe) Validate added in v1.5.0 

func (e *DataColumnCustodyProbe) Validate(ctx context.Context) error

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 TraceDeliverMessage added in v1.1.7 

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

func NewTraceDeliverMessage added in v1.1.7 

func NewTraceDeliverMessage(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceDeliverMessage

func (*TraceDeliverMessage) AppendServerMeta added in v1.1.7 

func (tlm *TraceDeliverMessage) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceDeliverMessage) Filter added in v1.1.7 

func (tlm *TraceDeliverMessage) Filter(ctx context.Context) bool

func (*TraceDeliverMessage) Type added in v1.1.7 

func (tlm *TraceDeliverMessage) Type() string

func (*TraceDeliverMessage) Validate added in v1.1.7 

func (tlm *TraceDeliverMessage) 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 TraceDropRPC added in v1.1.5 

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

func NewTraceDropRPC added in v1.1.5 

func NewTraceDropRPC(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceDropRPC

func (*TraceDropRPC) AppendServerMeta added in v1.1.5 

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

func (*TraceDropRPC) Filter added in v1.1.5 

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

func (*TraceDropRPC) Type added in v1.1.5 

func (trr *TraceDropRPC) Type() string

func (*TraceDropRPC) Validate added in v1.1.5 

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

type TraceDuplicateMessage added in v1.1.7 

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

func NewTraceDuplicateMessage added in v1.1.7 

func NewTraceDuplicateMessage(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceDuplicateMessage

func (*TraceDuplicateMessage) AppendServerMeta added in v1.1.7 

func (tlm *TraceDuplicateMessage) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceDuplicateMessage) Filter added in v1.1.7 

func (tlm *TraceDuplicateMessage) Filter(ctx context.Context) bool

func (*TraceDuplicateMessage) Type added in v1.1.7 

func (tlm *TraceDuplicateMessage) Type() string

func (*TraceDuplicateMessage) Validate added in v1.1.7 

func (tlm *TraceDuplicateMessage) Validate(ctx context.Context) error

type TraceGossipSubAggregateAndProof added in v1.1.27 

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

func NewTraceGossipSubAggregateAndProof added in v1.1.27 

func NewTraceGossipSubAggregateAndProof(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGossipSubAggregateAndProof

func (*TraceGossipSubAggregateAndProof) AppendServerMeta added in v1.1.27 

func (gsaap *TraceGossipSubAggregateAndProof) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceGossipSubAggregateAndProof) Filter added in v1.1.27 

func (gsaap *TraceGossipSubAggregateAndProof) Filter(ctx context.Context) bool

func (*TraceGossipSubAggregateAndProof) Type added in v1.1.27 

func (gsaap *TraceGossipSubAggregateAndProof) Type() string

func (*TraceGossipSubAggregateAndProof) Validate added in v1.1.27 

func (gsaap *TraceGossipSubAggregateAndProof) 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 (gsb *TraceGossipSubBeaconAttestation) Filter(ctx context.Context) bool

func (*TraceGossipSubBeaconAttestation) Type added in v0.0.169 

func (gsb *TraceGossipSubBeaconAttestation) Type() string

func (*TraceGossipSubBeaconAttestation) Validate added in v0.0.169 

func (gsb *TraceGossipSubBeaconAttestation) 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 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 

func (t *TraceGossipSubBlobSidecar) Filter(ctx context.Context) bool

Filter implements event.Event.

func (*TraceGossipSubBlobSidecar) Type added in v0.0.170 

func (t *TraceGossipSubBlobSidecar) Type() string

Type implements event.Event.

func (*TraceGossipSubBlobSidecar) Validate added in v0.0.170 

func (t *TraceGossipSubBlobSidecar) Validate(ctx context.Context) error

Validate implements event.Event.

type TraceGossipSubDataColumnSidecar added in v1.3.4 

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

func NewTraceGossipSubDataColumnSidecar added in v1.3.4 

func NewTraceGossipSubDataColumnSidecar(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGossipSubDataColumnSidecar

func (*TraceGossipSubDataColumnSidecar) AppendServerMeta added in v1.3.4 

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

AppendServerMeta implements event.Event.

func (*TraceGossipSubDataColumnSidecar) Filter added in v1.3.4 

func (t *TraceGossipSubDataColumnSidecar) Filter(ctx context.Context) bool

Filter implements event.Event.

func (*TraceGossipSubDataColumnSidecar) Type added in v1.3.4 

func (t *TraceGossipSubDataColumnSidecar) Type() string

Type implements event.Event.

func (*TraceGossipSubDataColumnSidecar) Validate added in v1.3.4 

func (t *TraceGossipSubDataColumnSidecar) Validate(ctx context.Context) error

Validate implements event.Event.

type TraceGraft added in v1.1.5 

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

func NewTraceGraft added in v1.1.5 

func NewTraceGraft(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceGraft

func (*TraceGraft) AppendServerMeta added in v1.1.5 

func (tlm *TraceGraft) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceGraft) Filter added in v1.1.5 

func (tlm *TraceGraft) Filter(ctx context.Context) bool

func (*TraceGraft) Type added in v1.1.5 

func (tlm *TraceGraft) Type() string

func (*TraceGraft) Validate added in v1.1.5 

func (tlm *TraceGraft) 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 TraceLeave added in v1.1.5 

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

func NewTraceLeave added in v1.1.5 

func NewTraceLeave(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceLeave

func (*TraceLeave) AppendServerMeta added in v1.1.5 

func (tlm *TraceLeave) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceLeave) Filter added in v1.1.5 

func (tlm *TraceLeave) Filter(ctx context.Context) bool

func (*TraceLeave) Type added in v1.1.5 

func (tlm *TraceLeave) Type() string

func (*TraceLeave) Validate added in v1.1.5 

func (tlm *TraceLeave) Validate(ctx context.Context) error

type TracePrune added in v1.1.5 

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

func NewTracePrune added in v1.1.5 

func NewTracePrune(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TracePrune

func (*TracePrune) AppendServerMeta added in v1.1.5 

func (tlm *TracePrune) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TracePrune) Filter added in v1.1.5 

func (tlm *TracePrune) Filter(ctx context.Context) bool

func (*TracePrune) Type added in v1.1.5 

func (tlm *TracePrune) Type() string

func (*TracePrune) Validate added in v1.1.5 

func (tlm *TracePrune) Validate(ctx context.Context) error

type TracePublishMessage added in v1.1.7 

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

func NewTracePublishMessage added in v1.1.7 

func NewTracePublishMessage(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TracePublishMessage

func (*TracePublishMessage) AppendServerMeta added in v1.1.7 

func (tlm *TracePublishMessage) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TracePublishMessage) Filter added in v1.1.7 

func (tlm *TracePublishMessage) Filter(ctx context.Context) bool

func (*TracePublishMessage) Type added in v1.1.7 

func (tlm *TracePublishMessage) Type() string

func (*TracePublishMessage) Validate added in v1.1.7 

func (tlm *TracePublishMessage) Validate(ctx context.Context) error

type TraceRPCMetaControlGraft added in v1.1.9 

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

func NewTraceRPCMetaControlGraft added in v1.1.9 

func NewTraceRPCMetaControlGraft(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaControlGraft

func (*TraceRPCMetaControlGraft) AppendServerMeta added in v1.1.9 

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

func (*TraceRPCMetaControlGraft) Filter added in v1.1.9 

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

func (*TraceRPCMetaControlGraft) Type added in v1.1.9 

func (trr *TraceRPCMetaControlGraft) Type() string

func (*TraceRPCMetaControlGraft) Validate added in v1.1.9 

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

type TraceRPCMetaControlIDontWant added in v1.1.9 

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

func NewTraceRPCMetaControlIDontWant added in v1.1.9 

func NewTraceRPCMetaControlIDontWant(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaControlIDontWant

func (*TraceRPCMetaControlIDontWant) AppendServerMeta added in v1.1.9 

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

func (*TraceRPCMetaControlIDontWant) Filter added in v1.1.9 

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

func (*TraceRPCMetaControlIDontWant) Type added in v1.1.9 

func (trr *TraceRPCMetaControlIDontWant) Type() string

func (*TraceRPCMetaControlIDontWant) Validate added in v1.1.9 

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

type TraceRPCMetaControlIHave added in v1.1.9 

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

func NewTraceRPCMetaControlIHave added in v1.1.9 

func NewTraceRPCMetaControlIHave(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaControlIHave

func (*TraceRPCMetaControlIHave) AppendServerMeta added in v1.1.9 

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

func (*TraceRPCMetaControlIHave) Filter added in v1.1.9 

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

func (*TraceRPCMetaControlIHave) Type added in v1.1.9 

func (trr *TraceRPCMetaControlIHave) Type() string

func (*TraceRPCMetaControlIHave) Validate added in v1.1.9 

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

type TraceRPCMetaControlIWant added in v1.1.9 

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

func NewTraceRPCMetaControlIWant added in v1.1.9 

func NewTraceRPCMetaControlIWant(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaControlIWant

func (*TraceRPCMetaControlIWant) AppendServerMeta added in v1.1.9 

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

func (*TraceRPCMetaControlIWant) Filter added in v1.1.9 

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

func (*TraceRPCMetaControlIWant) Type added in v1.1.9 

func (trr *TraceRPCMetaControlIWant) Type() string

func (*TraceRPCMetaControlIWant) Validate added in v1.1.9 

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

type TraceRPCMetaControlPrune added in v1.1.9 

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

func NewTraceRPCMetaControlPrune added in v1.1.9 

func NewTraceRPCMetaControlPrune(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaControlPrune

func (*TraceRPCMetaControlPrune) AppendServerMeta added in v1.1.9 

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

func (*TraceRPCMetaControlPrune) Filter added in v1.1.9 

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

func (*TraceRPCMetaControlPrune) Type added in v1.1.9 

func (trr *TraceRPCMetaControlPrune) Type() string

func (*TraceRPCMetaControlPrune) Validate added in v1.1.9 

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

type TraceRPCMetaMessage added in v1.1.12 

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

func NewTraceRPCMetaMessage added in v1.1.12 

func NewTraceRPCMetaMessage(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaMessage

func (*TraceRPCMetaMessage) AppendServerMeta added in v1.1.12 

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

func (*TraceRPCMetaMessage) Filter added in v1.1.12 

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

func (*TraceRPCMetaMessage) Type added in v1.1.12 

func (trr *TraceRPCMetaMessage) Type() string

func (*TraceRPCMetaMessage) Validate added in v1.1.12 

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

type TraceRPCMetaSubscription added in v1.1.12 

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

func NewTraceRPCMetaSubscription added in v1.1.12 

func NewTraceRPCMetaSubscription(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRPCMetaSubscription

func (*TraceRPCMetaSubscription) AppendServerMeta added in v1.1.12 

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

func (*TraceRPCMetaSubscription) Filter added in v1.1.12 

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

func (*TraceRPCMetaSubscription) Type added in v1.1.12 

func (trr *TraceRPCMetaSubscription) Type() string

func (*TraceRPCMetaSubscription) Validate added in v1.1.12 

func (trr *TraceRPCMetaSubscription) 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 TraceRejectMessage added in v1.1.7 

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

func NewTraceRejectMessage added in v1.1.7 

func NewTraceRejectMessage(log logrus.FieldLogger, event *xatu.DecoratedEvent) *TraceRejectMessage

func (*TraceRejectMessage) AppendServerMeta added in v1.1.7 

func (tlm *TraceRejectMessage) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceRejectMessage) Filter added in v1.1.7 

func (tlm *TraceRejectMessage) Filter(ctx context.Context) bool

func (*TraceRejectMessage) Type added in v1.1.7 

func (tlm *TraceRejectMessage) Type() string

func (*TraceRejectMessage) Validate added in v1.1.7 

func (tlm *TraceRejectMessage) 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

type TraceSyntheticHeartbeat added in v1.4.0 

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

func NewTraceSyntheticHeartbeat added in v1.4.0 

func NewTraceSyntheticHeartbeat(log logrus.FieldLogger, event *xatu.DecoratedEvent, geoipProvider geoip.Provider) *TraceSyntheticHeartbeat

func (*TraceSyntheticHeartbeat) AppendServerMeta added in v1.4.0 

func (th *TraceSyntheticHeartbeat) AppendServerMeta(ctx context.Context, meta *xatu.ServerMeta) *xatu.ServerMeta

func (*TraceSyntheticHeartbeat) Filter added in v1.4.0 

func (th *TraceSyntheticHeartbeat) Filter(ctx context.Context) bool

func (*TraceSyntheticHeartbeat) Type added in v1.4.0 

func (th *TraceSyntheticHeartbeat) Type() string

func (*TraceSyntheticHeartbeat) Validate added in v1.4.0 

func (th *TraceSyntheticHeartbeat) 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.