observed

Documentation

Index

• type PeerAgent
  • func (p *PeerAgent) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error
• type PeerAgentList
  • func (l PeerAgentList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

Types

type PeerAgent

type PeerAgent struct {

	// SurveyerPeerID is the peer ID of the node performing the survey
	SurveyerPeerID string `pg:",pk,notnull"`

	// ObservedAt is the time the observation was made
	ObservedAt time.Time `pg:",pk,notnull"`

	// RawAgent is the raw peer agent string
	RawAgent string `pg:",pk,notnull"`

	// NormalizedAgent is a parsed version of peer agent string, stripping out patch versions
	NormalizedAgent string `pg:",notnull"`

	// Count is the number of peers with the associated agent
	Count int64 `pg:",use_zero,notnull"`
	// contains filtered or unexported fields
}

func (*PeerAgent) Persist

func (p *PeerAgent) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error

type PeerAgentList

type PeerAgentList []*PeerAgent

func (PeerAgentList) Persist

func (l PeerAgentList) Persist(ctx context.Context, s model.StorageBatch, version model.Version) error