host

type AgentVersionProvider interface {
	AgentVersion(pid peer.ID) string
}

type BaseEvent struct {
	Timestamp  int64  `parquet:"timestamp"`
	Type       string `parquet:"type"`
	ProducerID string `parquet:"producer_id"`
}

type BaseRPCEvent struct {
	BaseEvent
	IsOg         bool   `parquet:"is_og"` // since we will divide original IHAVES into different rows off keep track of OG events for Control msg ids
	Direction    string `parquet:"direction"`
	RemotePeerID string `parquet:"remote_peer_id"`
}

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

type Config struct {
	DataStream            DataStream
	PeerscoreSnapshotFreq time.Duration
	PeerFilter            *FilterConfig // Optional peer filtering configuration
	DirectConnections     []peer.AddrInfo
	PubsubBlacklist       pubsub.Blacklist

	// Telemetry accessors
	Tracer trace.Tracer
	Meter  metric.Meter
}

type DataStream interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	PutRecord(ctx context.Context, event *TraceEvent) error
	Type() DataStreamType
	OutputType() DataStreamOutputType
}

type DataStreamOutputType int

type DataStreamRenderer interface {
	RenderPayload(evt *TraceEvent, msg *pubsub.Message, dst ssz.Unmarshaler) (*TraceEvent, error)
}

type DataStreamType int

type EventSubType int8

type EventSubmissionTask struct {
	EventType EventType
	Events    []any
	S3Key     string
}

type EventType int8

type FilterConfig struct {
	Mode     FilterMode `yaml:"mode" default:"disabled"`
	Patterns []string   `yaml:"patterns"`
}

type FilterMode string

type GenericParquetEvent struct {
	BaseEvent
	Topic   string `parquet:"topic"`
	Payload string `parquet:"payload"`
}

type GossipAddRemovePeerEvent struct {
	BaseEvent
	SubType      string `parquet:"sub_type"`
	RemotePeerID string `parquet:"remote_peer_id"`
}

type GossipGraftPruneEvent struct {
	BaseEvent
	SubType      string `parquet:"sub_type"`
	RemotePeerID string `parquet:"remote_peer_id"`
	Topic        string `parquet:"topic"`
}

type GossipIdontwantEvent struct {
	BaseRPCEvent
	MsgIDs []string `parquet:"msg_ids,list"`
	Msgs   int      `parquet:"msgs"`
}

type GossipIhaveEvent struct {
	BaseRPCEvent
	Topic  string   `parquet:"topic"`
	MsgIDs []string `parquet:"msg_ids,list"`
	Msgs   int      `parquet:"msgs"`
}

type GossipIwantEvent struct {
	BaseRPCEvent
	MsgIDs []string `parquet:"msg_ids,list"`
	Msgs   int      `parquet:"msgs"`
}

type GossipJoinLeaveTopicEvent struct {
	BaseEvent
	SubType string `parquet:"sub_type"`
	Topic   string `parquet:"topic"`
}

type GossipMsgArrivalEvent struct {
	BaseEvent
	SubType      string `parquet:"sub_type"`
	RemotePeerID string `parquet:"remote_peer_id"`
	Topic        string `parquet:"topic"`
	MsgID        string `parquet:"msg_id"`
	Local        bool   `parquet:"local"`
	MsgSize      int64  `parquet:"msg_size"`
	SeqNo        string `parquet:"seq_no"`
}

type GossipPeerExchangeEvent struct {
	BaseRPCEvent
	Topic   string   `parquet:"topic"`
	PxPeers []string `parquet:"px_peers,list"`
}

type GossipSentMsgEvent struct {
	BaseRPCEvent
	MsgID string `parquet:"msg_id"`
	Topic string `parquet:"topic"`
}

type Host struct {
	host.Host
	// contains filtered or unexported fields
}

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

type Libp2pConnectDisconnectEvent struct {
	BaseEvent
	SubType          string `parquet:"sub_type"`
	RemotePeerID     string `parquet:"remote_peer_id"`
	RemotePeerMaddrs string `parquet:"remote_peer_maddrs"`
	AgentVersion     string `parquet:"agent_version"`
	Direction        string `parquet:"direction"`
	Opened           int64  `parquet:"opened"`
	Limited          bool   `parquet:"limited"`
}

type LocalyProducedEvent interface {
	GetProducerID() string
}

type NoopDataStream struct{}

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

type RPCdirection int8

type RpcControlGraft struct {
	TopicID string
}

type RpcControlIHave struct {
	TopicID string
	MsgIDs  []string
}

type RpcControlIWant struct {
	MsgIDs []string
}

type RpcControlIdontWant struct {
	MsgIDs []string
}

type RpcControlPrune struct {
	TopicID string
	PeerIDs []peer.ID
}

type RpcMeta struct {
	PeerID        peer.ID
	Subscriptions []RpcMetaSub    `json:"Subs,omitempty"`
	Messages      []RpcMetaMsg    `json:"Msgs,omitempty"`
	Control       *RpcMetaControl `json:"Control,omitempty"`
}

type RpcMetaControl struct {
	IHave     []RpcControlIHave     `json:"IHave,omitempty"`
	IWant     []RpcControlIWant     `json:"IWant,omitempty"`
	Graft     []RpcControlGraft     `json:"Graft,omitempty"`
	Prune     []RpcControlPrune     `json:"Prune,omitempty"`
	Idontwant []RpcControlIdontWant `json:"Idontwant,omitempty"`
}

type RpcMetaMsg struct {
	MsgID string `json:"MsgID,omitempty"`
	Topic string `json:"Topic,omitempty"`
}

type RpcMetaSub struct {
	Subscribe bool
	TopicID   string
}

type S3DSConfig struct {
	Meter         metric.Meter
	Flushers      int
	ByteLimit     int64
	FlushInterval time.Duration
	AccessKeyID   string
	SecretKey     string
	Region        string
	Endpoint      string
	Bucket        string
	Tag           string
}

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

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

type SendRecvRPCEvent struct {
	BaseRPCEvent
	Ihaves     int32 `parquet:"ihaves"`
	Iwants     int32 `parquet:"iwants"`
	Idontwants int32 `parquet:"idontwants"`
	SentMsgs   int32 `parquet:"sent_msgs"`
}

type TopicHandler = func(context.Context, *pubsub.Message) error

type TopicScore struct {
	Topic                    string
	TimeInMesh               time.Duration
	FirstMessageDeliveries   float64
	MeshMessageDeliveries    float64
	InvalidMessageDeliveries float64
}

type TopicSubscription struct {
	Topic   string
	LocalID peer.ID
	Sub     *pubsub.Subscription
	Handler TopicHandler
}

type TraceEvent struct {
	Type      string
	Topic     string
	PeerID    peer.ID
	Timestamp time.Time
	Payload   any `json:"Data"` // cannot use field "Data" because of gk.Record method
}

type TraceEventPayloadMetaData struct {
	PeerID  string `json:"PeerID"`
	Topic   string `json:"Topic"`
	Seq     []byte `json:"Seq"`
	MsgID   string `json:"MsgID"`
	MsgSize int    `json:"MsgSize"`
}

type TraceEventPeerScore struct {
	PeerID             string
	Score              float64
	AppSpecificScore   float64
	IPColocationFactor float64
	BehaviourPenalty   float64
	Topics             []TopicScore
}

type TraceLogger struct{}