models

package
v0.0.0-...-23d3fd2 Latest Latest
Warning

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

Go to latest
Published: Jun 26, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NetErrorUnknown                    string = "unknown"
	NetErrorIoTimeout                  string = "io_timeout"
	NetErrorNoRecentNetworkActivity    string = "no_recent_network_activity"
	NetErrorConnectionRefused          string = "connection_refused"
	NetErrorProtocolNotSupported       string = "protocol_not_supported"
	NetErrorPeerIDMismatch             string = "peer_id_mismatch"
	NetErrorNoRouteToHost              string = "no_route_to_host"
	NetErrorNetworkUnreachable         string = "network_unreachable"
	NetErrorNoGoodAddresses            string = "no_good_addresses"
	NetErrorContextDeadlineExceeded    string = "context_deadline_exceeded"
	NetErrorNoPublicIP                 string = "no_public_ip"
	NetErrorMaxDialAttemptsExceeded    string = "max_dial_attempts_exceeded"
	NetErrorMaddrReset                 string = "maddr_reset"
	NetErrorStreamReset                string = "stream_reset"
	NetErrorHostIsDown                 string = "host_is_down"
	NetErrorNegotiateSecurityProtocol  string = "negotiate_security_protocol"
	NetErrorNegotiateStreamMultiplexer string = "negotiate_stream_multiplexer"
	NetErrorResourceLimitExceeded      string = "resource_limit_exceeded"
	NetErrorWriteOnStream              string = "write_on_stream"
)

Enum values for NetError

View Source
const (
	CrawlStateStarted   string = "started"
	CrawlStateCancelled string = "cancelled"
	CrawlStateFailed    string = "failed"
	CrawlStateSucceeded string = "succeeded"
)

Enum values for CrawlState

View Source
const (
	SessionStateOpen    string = "open"
	SessionStatePending string = "pending"
	SessionStateClosed  string = "closed"
)

Enum values for SessionState

View Source
const (
	VisitTypeCrawl string = "crawl"
	VisitTypeDial  string = "dial"
)

Enum values for VisitType

Variables

View Source
var AgentVersionColumns = struct {
	ID           string
	CreatedAt    string
	AgentVersion string
}{
	ID:           "id",
	CreatedAt:    "created_at",
	AgentVersion: "agent_version",
}
View Source
var AgentVersionRels = struct {
	CrawlProperties string
	Peers           string
}{
	CrawlProperties: "CrawlProperties",
	Peers:           "Peers",
}

AgentVersionRels is where relationship names are stored.

View Source
var AgentVersionTableColumns = struct {
	ID           string
	CreatedAt    string
	AgentVersion string
}{
	ID:           "agent_versions.id",
	CreatedAt:    "agent_versions.created_at",
	AgentVersion: "agent_versions.agent_version",
}
View Source
var AgentVersionWhere = struct {
	ID           whereHelperint
	CreatedAt    whereHelpertime_Time
	AgentVersion whereHelperstring
}{
	ID:           whereHelperint{/* contains filtered or unexported fields */},
	CreatedAt:    whereHelpertime_Time{/* contains filtered or unexported fields */},
	AgentVersion: whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var CrawlColumns = struct {
	ID              string
	State           string
	StartedAt       string
	FinishedAt      string
	UpdatedAt       string
	CreatedAt       string
	CrawledPeers    string
	DialablePeers   string
	UndialablePeers string
}{
	ID:              "id",
	State:           "state",
	StartedAt:       "started_at",
	FinishedAt:      "finished_at",
	UpdatedAt:       "updated_at",
	CreatedAt:       "created_at",
	CrawledPeers:    "crawled_peers",
	DialablePeers:   "dialable_peers",
	UndialablePeers: "undialable_peers",
}
View Source
var CrawlPropertyColumns = struct {
	ID             string
	CrawlID        string
	ProtocolID     string
	AgentVersionID string
	Error          string
	Count          string
}{
	ID:             "id",
	CrawlID:        "crawl_id",
	ProtocolID:     "protocol_id",
	AgentVersionID: "agent_version_id",
	Error:          "error",
	Count:          "count",
}
View Source
var CrawlPropertyRels = struct {
	AgentVersion string
	Crawl        string
	Protocol     string
}{
	AgentVersion: "AgentVersion",
	Crawl:        "Crawl",
	Protocol:     "Protocol",
}

CrawlPropertyRels is where relationship names are stored.

View Source
var CrawlPropertyTableColumns = struct {
	ID             string
	CrawlID        string
	ProtocolID     string
	AgentVersionID string
	Error          string
	Count          string
}{
	ID:             "crawl_properties.id",
	CrawlID:        "crawl_properties.crawl_id",
	ProtocolID:     "crawl_properties.protocol_id",
	AgentVersionID: "crawl_properties.agent_version_id",
	Error:          "crawl_properties.error",
	Count:          "crawl_properties.count",
}
View Source
var CrawlPropertyWhere = struct {
	ID             whereHelperint
	CrawlID        whereHelperint
	ProtocolID     whereHelpernull_Int
	AgentVersionID whereHelpernull_Int
	Error          whereHelpernull_String
	Count          whereHelperint
}{
	ID:             whereHelperint{/* contains filtered or unexported fields */},
	CrawlID:        whereHelperint{/* contains filtered or unexported fields */},
	ProtocolID:     whereHelpernull_Int{/* contains filtered or unexported fields */},
	AgentVersionID: whereHelpernull_Int{/* contains filtered or unexported fields */},
	Error:          whereHelpernull_String{/* contains filtered or unexported fields */},
	Count:          whereHelperint{/* contains filtered or unexported fields */},
}
View Source
var CrawlRels = struct {
	CrawlProperties string
}{
	CrawlProperties: "CrawlProperties",
}

CrawlRels is where relationship names are stored.

View Source
var CrawlTableColumns = struct {
	ID              string
	State           string
	StartedAt       string
	FinishedAt      string
	UpdatedAt       string
	CreatedAt       string
	CrawledPeers    string
	DialablePeers   string
	UndialablePeers string
}{
	ID:              "crawls.id",
	State:           "crawls.state",
	StartedAt:       "crawls.started_at",
	FinishedAt:      "crawls.finished_at",
	UpdatedAt:       "crawls.updated_at",
	CreatedAt:       "crawls.created_at",
	CrawledPeers:    "crawls.crawled_peers",
	DialablePeers:   "crawls.dialable_peers",
	UndialablePeers: "crawls.undialable_peers",
}
View Source
var CrawlWhere = struct {
	ID              whereHelperint
	State           whereHelperstring
	StartedAt       whereHelpertime_Time
	FinishedAt      whereHelpernull_Time
	UpdatedAt       whereHelpertime_Time
	CreatedAt       whereHelpertime_Time
	CrawledPeers    whereHelpernull_Int
	DialablePeers   whereHelpernull_Int
	UndialablePeers whereHelpernull_Int
}{
	ID:              whereHelperint{/* contains filtered or unexported fields */},
	State:           whereHelperstring{/* contains filtered or unexported fields */},
	StartedAt:       whereHelpertime_Time{/* contains filtered or unexported fields */},
	FinishedAt:      whereHelpernull_Time{/* contains filtered or unexported fields */},
	UpdatedAt:       whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:       whereHelpertime_Time{/* contains filtered or unexported fields */},
	CrawledPeers:    whereHelpernull_Int{/* contains filtered or unexported fields */},
	DialablePeers:   whereHelpernull_Int{/* contains filtered or unexported fields */},
	UndialablePeers: whereHelpernull_Int{/* contains filtered or unexported fields */},
}
View Source
var ErrSyncFail = errors.New("models: failed to synchronize data after insert")

ErrSyncFail occurs during insert when the record could not be retrieved in order to populate default value information. This usually happens when LastInsertId fails or there was a primary key configuration that was not resolvable.

View Source
var IPAddressColumns = struct {
	ID             string
	MultiAddressID string
	Asn            string
	IsCloud        string
	UpdatedAt      string
	CreatedAt      string
	Country        string
	Continent      string
	Address        string
}{
	ID:             "id",
	MultiAddressID: "multi_address_id",
	Asn:            "asn",
	IsCloud:        "is_cloud",
	UpdatedAt:      "updated_at",
	CreatedAt:      "created_at",
	Country:        "country",
	Continent:      "continent",
	Address:        "address",
}
View Source
var IPAddressRels = struct {
	MultiAddress string
}{
	MultiAddress: "MultiAddress",
}

IPAddressRels is where relationship names are stored.

View Source
var IPAddressTableColumns = struct {
	ID             string
	MultiAddressID string
	Asn            string
	IsCloud        string
	UpdatedAt      string
	CreatedAt      string
	Country        string
	Continent      string
	Address        string
}{
	ID:             "ip_addresses.id",
	MultiAddressID: "ip_addresses.multi_address_id",
	Asn:            "ip_addresses.asn",
	IsCloud:        "ip_addresses.is_cloud",
	UpdatedAt:      "ip_addresses.updated_at",
	CreatedAt:      "ip_addresses.created_at",
	Country:        "ip_addresses.country",
	Continent:      "ip_addresses.continent",
	Address:        "ip_addresses.address",
}
View Source
var IPAddressWhere = struct {
	ID             whereHelperint
	MultiAddressID whereHelperint
	Asn            whereHelpernull_Int
	IsCloud        whereHelpernull_Int
	UpdatedAt      whereHelpertime_Time
	CreatedAt      whereHelpertime_Time
	Country        whereHelpernull_String
	Continent      whereHelpernull_String
	Address        whereHelperstring
}{
	ID:             whereHelperint{/* contains filtered or unexported fields */},
	MultiAddressID: whereHelperint{/* contains filtered or unexported fields */},
	Asn:            whereHelpernull_Int{/* contains filtered or unexported fields */},
	IsCloud:        whereHelpernull_Int{/* contains filtered or unexported fields */},
	UpdatedAt:      whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:      whereHelpertime_Time{/* contains filtered or unexported fields */},
	Country:        whereHelpernull_String{/* contains filtered or unexported fields */},
	Continent:      whereHelpernull_String{/* contains filtered or unexported fields */},
	Address:        whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var MultiAddressColumns = struct {
	ID           string
	Asn          string
	IsCloud      string
	IsRelay      string
	IsPublic     string
	Addr         string
	HasManyAddrs string
	Resolved     string
	Country      string
	Continent    string
	Maddr        string
	UpdatedAt    string
	CreatedAt    string
}{
	ID:           "id",
	Asn:          "asn",
	IsCloud:      "is_cloud",
	IsRelay:      "is_relay",
	IsPublic:     "is_public",
	Addr:         "addr",
	HasManyAddrs: "has_many_addrs",
	Resolved:     "resolved",
	Country:      "country",
	Continent:    "continent",
	Maddr:        "maddr",
	UpdatedAt:    "updated_at",
	CreatedAt:    "created_at",
}
View Source
var MultiAddressRels = struct {
	IPAddresses string
	Peers       string
}{
	IPAddresses: "IPAddresses",
	Peers:       "Peers",
}

MultiAddressRels is where relationship names are stored.

View Source
var MultiAddressTableColumns = struct {
	ID           string
	Asn          string
	IsCloud      string
	IsRelay      string
	IsPublic     string
	Addr         string
	HasManyAddrs string
	Resolved     string
	Country      string
	Continent    string
	Maddr        string
	UpdatedAt    string
	CreatedAt    string
}{
	ID:           "multi_addresses.id",
	Asn:          "multi_addresses.asn",
	IsCloud:      "multi_addresses.is_cloud",
	IsRelay:      "multi_addresses.is_relay",
	IsPublic:     "multi_addresses.is_public",
	Addr:         "multi_addresses.addr",
	HasManyAddrs: "multi_addresses.has_many_addrs",
	Resolved:     "multi_addresses.resolved",
	Country:      "multi_addresses.country",
	Continent:    "multi_addresses.continent",
	Maddr:        "multi_addresses.maddr",
	UpdatedAt:    "multi_addresses.updated_at",
	CreatedAt:    "multi_addresses.created_at",
}
View Source
var MultiAddressWhere = struct {
	ID           whereHelperint
	Asn          whereHelpernull_Int
	IsCloud      whereHelpernull_Int
	IsRelay      whereHelpernull_Bool
	IsPublic     whereHelpernull_Bool
	Addr         whereHelpernull_String
	HasManyAddrs whereHelpernull_Bool
	Resolved     whereHelperbool
	Country      whereHelpernull_String
	Continent    whereHelpernull_String
	Maddr        whereHelperstring
	UpdatedAt    whereHelpertime_Time
	CreatedAt    whereHelpertime_Time
}{
	ID:           whereHelperint{/* contains filtered or unexported fields */},
	Asn:          whereHelpernull_Int{/* contains filtered or unexported fields */},
	IsCloud:      whereHelpernull_Int{/* contains filtered or unexported fields */},
	IsRelay:      whereHelpernull_Bool{/* contains filtered or unexported fields */},
	IsPublic:     whereHelpernull_Bool{/* contains filtered or unexported fields */},
	Addr:         whereHelpernull_String{/* contains filtered or unexported fields */},
	HasManyAddrs: whereHelpernull_Bool{/* contains filtered or unexported fields */},
	Resolved:     whereHelperbool{/* contains filtered or unexported fields */},
	Country:      whereHelpernull_String{/* contains filtered or unexported fields */},
	Continent:    whereHelpernull_String{/* contains filtered or unexported fields */},
	Maddr:        whereHelperstring{/* contains filtered or unexported fields */},
	UpdatedAt:    whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:    whereHelpertime_Time{/* contains filtered or unexported fields */},
}
View Source
var NeighborColumns = struct {
	CrawlID     string
	PeerID      string
	NeighborIds string
	ErrorBits   string
}{
	CrawlID:     "crawl_id",
	PeerID:      "peer_id",
	NeighborIds: "neighbor_ids",
	ErrorBits:   "error_bits",
}
View Source
var NeighborRels = struct {
}{}

NeighborRels is where relationship names are stored.

View Source
var NeighborTableColumns = struct {
	CrawlID     string
	PeerID      string
	NeighborIds string
	ErrorBits   string
}{
	CrawlID:     "neighbors.crawl_id",
	PeerID:      "neighbors.peer_id",
	NeighborIds: "neighbors.neighbor_ids",
	ErrorBits:   "neighbors.error_bits",
}
View Source
var NeighborWhere = struct {
	CrawlID     whereHelperint
	PeerID      whereHelperint
	NeighborIds whereHelpertypes_Int64Array
	ErrorBits   whereHelperint16
}{
	CrawlID:     whereHelperint{/* contains filtered or unexported fields */},
	PeerID:      whereHelperint{/* contains filtered or unexported fields */},
	NeighborIds: whereHelpertypes_Int64Array{/* contains filtered or unexported fields */},
	ErrorBits:   whereHelperint16{/* contains filtered or unexported fields */},
}
View Source
var PeerColumns = struct {
	ID             string
	AgentVersionID string
	ProtocolsSetID string
	MultiHash      string
	UpdatedAt      string
	CreatedAt      string
	IsExposed      string
}{
	ID:             "id",
	AgentVersionID: "agent_version_id",
	ProtocolsSetID: "protocols_set_id",
	MultiHash:      "multi_hash",
	UpdatedAt:      "updated_at",
	CreatedAt:      "created_at",
	IsExposed:      "is_exposed",
}
View Source
var PeerLogColumns = struct {
	ID        string
	PeerID    string
	Field     string
	Old       string
	New       string
	CreatedAt string
}{
	ID:        "id",
	PeerID:    "peer_id",
	Field:     "field",
	Old:       "old",
	New:       "new",
	CreatedAt: "created_at",
}
View Source
var PeerLogRels = struct {
}{}

PeerLogRels is where relationship names are stored.

View Source
var PeerLogTableColumns = struct {
	ID        string
	PeerID    string
	Field     string
	Old       string
	New       string
	CreatedAt string
}{
	ID:        "peer_logs.id",
	PeerID:    "peer_logs.peer_id",
	Field:     "peer_logs.field",
	Old:       "peer_logs.old",
	New:       "peer_logs.new",
	CreatedAt: "peer_logs.created_at",
}
View Source
var PeerLogWhere = struct {
	ID        whereHelperint
	PeerID    whereHelperint
	Field     whereHelperstring
	Old       whereHelperstring
	New       whereHelperstring
	CreatedAt whereHelpertime_Time
}{
	ID:        whereHelperint{/* contains filtered or unexported fields */},
	PeerID:    whereHelperint{/* contains filtered or unexported fields */},
	Field:     whereHelperstring{/* contains filtered or unexported fields */},
	Old:       whereHelperstring{/* contains filtered or unexported fields */},
	New:       whereHelperstring{/* contains filtered or unexported fields */},
	CreatedAt: whereHelpertime_Time{/* contains filtered or unexported fields */},
}
View Source
var PeerRels = struct {
	AgentVersion   string
	ProtocolsSet   string
	SessionsOpen   string
	MultiAddresses string
}{
	AgentVersion:   "AgentVersion",
	ProtocolsSet:   "ProtocolsSet",
	SessionsOpen:   "SessionsOpen",
	MultiAddresses: "MultiAddresses",
}

PeerRels is where relationship names are stored.

View Source
var PeerTableColumns = struct {
	ID             string
	AgentVersionID string
	ProtocolsSetID string
	MultiHash      string
	UpdatedAt      string
	CreatedAt      string
	IsExposed      string
}{
	ID:             "peers.id",
	AgentVersionID: "peers.agent_version_id",
	ProtocolsSetID: "peers.protocols_set_id",
	MultiHash:      "peers.multi_hash",
	UpdatedAt:      "peers.updated_at",
	CreatedAt:      "peers.created_at",
	IsExposed:      "peers.is_exposed",
}
View Source
var PeerWhere = struct {
	ID             whereHelperint
	AgentVersionID whereHelpernull_Int
	ProtocolsSetID whereHelpernull_Int
	MultiHash      whereHelperstring
	UpdatedAt      whereHelpertime_Time
	CreatedAt      whereHelpertime_Time
	IsExposed      whereHelpernull_Bool
}{
	ID:             whereHelperint{/* contains filtered or unexported fields */},
	AgentVersionID: whereHelpernull_Int{/* contains filtered or unexported fields */},
	ProtocolsSetID: whereHelpernull_Int{/* contains filtered or unexported fields */},
	MultiHash:      whereHelperstring{/* contains filtered or unexported fields */},
	UpdatedAt:      whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:      whereHelpertime_Time{/* contains filtered or unexported fields */},
	IsExposed:      whereHelpernull_Bool{/* contains filtered or unexported fields */},
}
View Source
var ProtocolColumns = struct {
	ID        string
	CreatedAt string
	Protocol  string
}{
	ID:        "id",
	CreatedAt: "created_at",
	Protocol:  "protocol",
}
View Source
var ProtocolRels = struct {
	CrawlProperties string
}{
	CrawlProperties: "CrawlProperties",
}

ProtocolRels is where relationship names are stored.

View Source
var ProtocolTableColumns = struct {
	ID        string
	CreatedAt string
	Protocol  string
}{
	ID:        "protocols.id",
	CreatedAt: "protocols.created_at",
	Protocol:  "protocols.protocol",
}
View Source
var ProtocolWhere = struct {
	ID        whereHelperint
	CreatedAt whereHelpertime_Time
	Protocol  whereHelperstring
}{
	ID:        whereHelperint{/* contains filtered or unexported fields */},
	CreatedAt: whereHelpertime_Time{/* contains filtered or unexported fields */},
	Protocol:  whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var ProtocolsSetColumns = struct {
	ID          string
	ProtocolIds string
	Hash        string
}{
	ID:          "id",
	ProtocolIds: "protocol_ids",
	Hash:        "hash",
}
View Source
var ProtocolsSetRels = struct {
	Peers string
}{
	Peers: "Peers",
}

ProtocolsSetRels is where relationship names are stored.

View Source
var ProtocolsSetTableColumns = struct {
	ID          string
	ProtocolIds string
	Hash        string
}{
	ID:          "protocols_sets.id",
	ProtocolIds: "protocols_sets.protocol_ids",
	Hash:        "protocols_sets.hash",
}
View Source
var ProtocolsSetWhere = struct {
	ID          whereHelperint
	ProtocolIds whereHelpertypes_Int64Array
	Hash        whereHelper__byte
}{
	ID:          whereHelperint{/* contains filtered or unexported fields */},
	ProtocolIds: whereHelpertypes_Int64Array{/* contains filtered or unexported fields */},
	Hash:        whereHelper__byte{/* contains filtered or unexported fields */},
}
View Source
var SessionColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "id",
	PeerID:                "peer_id",
	FirstSuccessfulVisit:  "first_successful_visit",
	LastSuccessfulVisit:   "last_successful_visit",
	NextVisitDueAt:        "next_visit_due_at",
	FirstFailedVisit:      "first_failed_visit",
	LastFailedVisit:       "last_failed_visit",
	LastVisitedAt:         "last_visited_at",
	UpdatedAt:             "updated_at",
	CreatedAt:             "created_at",
	SuccessfulVisitsCount: "successful_visits_count",
	RecoveredCount:        "recovered_count",
	State:                 "state",
	FailedVisitsCount:     "failed_visits_count",
	FinishReason:          "finish_reason",
	Uptime:                "uptime",
}
View Source
var SessionRels = struct {
}{}

SessionRels is where relationship names are stored.

View Source
var SessionTableColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "sessions.id",
	PeerID:                "sessions.peer_id",
	FirstSuccessfulVisit:  "sessions.first_successful_visit",
	LastSuccessfulVisit:   "sessions.last_successful_visit",
	NextVisitDueAt:        "sessions.next_visit_due_at",
	FirstFailedVisit:      "sessions.first_failed_visit",
	LastFailedVisit:       "sessions.last_failed_visit",
	LastVisitedAt:         "sessions.last_visited_at",
	UpdatedAt:             "sessions.updated_at",
	CreatedAt:             "sessions.created_at",
	SuccessfulVisitsCount: "sessions.successful_visits_count",
	RecoveredCount:        "sessions.recovered_count",
	State:                 "sessions.state",
	FailedVisitsCount:     "sessions.failed_visits_count",
	FinishReason:          "sessions.finish_reason",
	Uptime:                "sessions.uptime",
}
View Source
var SessionWhere = struct {
	ID                    whereHelperint
	PeerID                whereHelperint
	FirstSuccessfulVisit  whereHelpertime_Time
	LastSuccessfulVisit   whereHelpertime_Time
	NextVisitDueAt        whereHelpernull_Time
	FirstFailedVisit      whereHelpernull_Time
	LastFailedVisit       whereHelpernull_Time
	LastVisitedAt         whereHelpertime_Time
	UpdatedAt             whereHelpertime_Time
	CreatedAt             whereHelpertime_Time
	SuccessfulVisitsCount whereHelperint
	RecoveredCount        whereHelperint
	State                 whereHelperstring
	FailedVisitsCount     whereHelperint16
	FinishReason          whereHelpernull_String
	Uptime                whereHelperstring
}{
	ID:                    whereHelperint{/* contains filtered or unexported fields */},
	PeerID:                whereHelperint{/* contains filtered or unexported fields */},
	FirstSuccessfulVisit:  whereHelpertime_Time{/* contains filtered or unexported fields */},
	LastSuccessfulVisit:   whereHelpertime_Time{/* contains filtered or unexported fields */},
	NextVisitDueAt:        whereHelpernull_Time{/* contains filtered or unexported fields */},
	FirstFailedVisit:      whereHelpernull_Time{/* contains filtered or unexported fields */},
	LastFailedVisit:       whereHelpernull_Time{/* contains filtered or unexported fields */},
	LastVisitedAt:         whereHelpertime_Time{/* contains filtered or unexported fields */},
	UpdatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	SuccessfulVisitsCount: whereHelperint{/* contains filtered or unexported fields */},
	RecoveredCount:        whereHelperint{/* contains filtered or unexported fields */},
	State:                 whereHelperstring{/* contains filtered or unexported fields */},
	FailedVisitsCount:     whereHelperint16{/* contains filtered or unexported fields */},
	FinishReason:          whereHelpernull_String{/* contains filtered or unexported fields */},
	Uptime:                whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var SessionsClosedColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "id",
	PeerID:                "peer_id",
	FirstSuccessfulVisit:  "first_successful_visit",
	LastSuccessfulVisit:   "last_successful_visit",
	NextVisitDueAt:        "next_visit_due_at",
	FirstFailedVisit:      "first_failed_visit",
	LastFailedVisit:       "last_failed_visit",
	LastVisitedAt:         "last_visited_at",
	UpdatedAt:             "updated_at",
	CreatedAt:             "created_at",
	SuccessfulVisitsCount: "successful_visits_count",
	RecoveredCount:        "recovered_count",
	State:                 "state",
	FailedVisitsCount:     "failed_visits_count",
	FinishReason:          "finish_reason",
	Uptime:                "uptime",
}
View Source
var SessionsClosedRels = struct {
}{}

SessionsClosedRels is where relationship names are stored.

View Source
var SessionsClosedTableColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "sessions_closed.id",
	PeerID:                "sessions_closed.peer_id",
	FirstSuccessfulVisit:  "sessions_closed.first_successful_visit",
	LastSuccessfulVisit:   "sessions_closed.last_successful_visit",
	NextVisitDueAt:        "sessions_closed.next_visit_due_at",
	FirstFailedVisit:      "sessions_closed.first_failed_visit",
	LastFailedVisit:       "sessions_closed.last_failed_visit",
	LastVisitedAt:         "sessions_closed.last_visited_at",
	UpdatedAt:             "sessions_closed.updated_at",
	CreatedAt:             "sessions_closed.created_at",
	SuccessfulVisitsCount: "sessions_closed.successful_visits_count",
	RecoveredCount:        "sessions_closed.recovered_count",
	State:                 "sessions_closed.state",
	FailedVisitsCount:     "sessions_closed.failed_visits_count",
	FinishReason:          "sessions_closed.finish_reason",
	Uptime:                "sessions_closed.uptime",
}
View Source
var SessionsClosedWhere = struct {
	ID                    whereHelperint
	PeerID                whereHelperint
	FirstSuccessfulVisit  whereHelpertime_Time
	LastSuccessfulVisit   whereHelpertime_Time
	NextVisitDueAt        whereHelpernull_Time
	FirstFailedVisit      whereHelpertime_Time
	LastFailedVisit       whereHelpertime_Time
	LastVisitedAt         whereHelpertime_Time
	UpdatedAt             whereHelpertime_Time
	CreatedAt             whereHelpertime_Time
	SuccessfulVisitsCount whereHelperint
	RecoveredCount        whereHelperint
	State                 whereHelperstring
	FailedVisitsCount     whereHelperint16
	FinishReason          whereHelperstring
	Uptime                whereHelperstring
}{
	ID:                    whereHelperint{/* contains filtered or unexported fields */},
	PeerID:                whereHelperint{/* contains filtered or unexported fields */},
	FirstSuccessfulVisit:  whereHelpertime_Time{/* contains filtered or unexported fields */},
	LastSuccessfulVisit:   whereHelpertime_Time{/* contains filtered or unexported fields */},
	NextVisitDueAt:        whereHelpernull_Time{/* contains filtered or unexported fields */},
	FirstFailedVisit:      whereHelpertime_Time{/* contains filtered or unexported fields */},
	LastFailedVisit:       whereHelpertime_Time{/* contains filtered or unexported fields */},
	LastVisitedAt:         whereHelpertime_Time{/* contains filtered or unexported fields */},
	UpdatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	SuccessfulVisitsCount: whereHelperint{/* contains filtered or unexported fields */},
	RecoveredCount:        whereHelperint{/* contains filtered or unexported fields */},
	State:                 whereHelperstring{/* contains filtered or unexported fields */},
	FailedVisitsCount:     whereHelperint16{/* contains filtered or unexported fields */},
	FinishReason:          whereHelperstring{/* contains filtered or unexported fields */},
	Uptime:                whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var SessionsOpenColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "id",
	PeerID:                "peer_id",
	FirstSuccessfulVisit:  "first_successful_visit",
	LastSuccessfulVisit:   "last_successful_visit",
	NextVisitDueAt:        "next_visit_due_at",
	FirstFailedVisit:      "first_failed_visit",
	LastFailedVisit:       "last_failed_visit",
	LastVisitedAt:         "last_visited_at",
	UpdatedAt:             "updated_at",
	CreatedAt:             "created_at",
	SuccessfulVisitsCount: "successful_visits_count",
	RecoveredCount:        "recovered_count",
	State:                 "state",
	FailedVisitsCount:     "failed_visits_count",
	FinishReason:          "finish_reason",
	Uptime:                "uptime",
}
View Source
var SessionsOpenRels = struct {
	Peer string
}{
	Peer: "Peer",
}

SessionsOpenRels is where relationship names are stored.

View Source
var SessionsOpenTableColumns = struct {
	ID                    string
	PeerID                string
	FirstSuccessfulVisit  string
	LastSuccessfulVisit   string
	NextVisitDueAt        string
	FirstFailedVisit      string
	LastFailedVisit       string
	LastVisitedAt         string
	UpdatedAt             string
	CreatedAt             string
	SuccessfulVisitsCount string
	RecoveredCount        string
	State                 string
	FailedVisitsCount     string
	FinishReason          string
	Uptime                string
}{
	ID:                    "sessions_open.id",
	PeerID:                "sessions_open.peer_id",
	FirstSuccessfulVisit:  "sessions_open.first_successful_visit",
	LastSuccessfulVisit:   "sessions_open.last_successful_visit",
	NextVisitDueAt:        "sessions_open.next_visit_due_at",
	FirstFailedVisit:      "sessions_open.first_failed_visit",
	LastFailedVisit:       "sessions_open.last_failed_visit",
	LastVisitedAt:         "sessions_open.last_visited_at",
	UpdatedAt:             "sessions_open.updated_at",
	CreatedAt:             "sessions_open.created_at",
	SuccessfulVisitsCount: "sessions_open.successful_visits_count",
	RecoveredCount:        "sessions_open.recovered_count",
	State:                 "sessions_open.state",
	FailedVisitsCount:     "sessions_open.failed_visits_count",
	FinishReason:          "sessions_open.finish_reason",
	Uptime:                "sessions_open.uptime",
}
View Source
var SessionsOpenWhere = struct {
	ID                    whereHelperint
	PeerID                whereHelperint
	FirstSuccessfulVisit  whereHelpertime_Time
	LastSuccessfulVisit   whereHelpertime_Time
	NextVisitDueAt        whereHelpertime_Time
	FirstFailedVisit      whereHelpernull_Time
	LastFailedVisit       whereHelpernull_Time
	LastVisitedAt         whereHelpertime_Time
	UpdatedAt             whereHelpertime_Time
	CreatedAt             whereHelpertime_Time
	SuccessfulVisitsCount whereHelperint
	RecoveredCount        whereHelperint
	State                 whereHelperstring
	FailedVisitsCount     whereHelperint16
	FinishReason          whereHelpernull_String
	Uptime                whereHelperstring
}{
	ID:                    whereHelperint{/* contains filtered or unexported fields */},
	PeerID:                whereHelperint{/* contains filtered or unexported fields */},
	FirstSuccessfulVisit:  whereHelpertime_Time{/* contains filtered or unexported fields */},
	LastSuccessfulVisit:   whereHelpertime_Time{/* contains filtered or unexported fields */},
	NextVisitDueAt:        whereHelpertime_Time{/* contains filtered or unexported fields */},
	FirstFailedVisit:      whereHelpernull_Time{/* contains filtered or unexported fields */},
	LastFailedVisit:       whereHelpernull_Time{/* contains filtered or unexported fields */},
	LastVisitedAt:         whereHelpertime_Time{/* contains filtered or unexported fields */},
	UpdatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:             whereHelpertime_Time{/* contains filtered or unexported fields */},
	SuccessfulVisitsCount: whereHelperint{/* contains filtered or unexported fields */},
	RecoveredCount:        whereHelperint{/* contains filtered or unexported fields */},
	State:                 whereHelperstring{/* contains filtered or unexported fields */},
	FailedVisitsCount:     whereHelperint16{/* contains filtered or unexported fields */},
	FinishReason:          whereHelpernull_String{/* contains filtered or unexported fields */},
	Uptime:                whereHelperstring{/* contains filtered or unexported fields */},
}
View Source
var TableNames = struct {
	AgentVersions        string
	CrawlProperties      string
	Crawls               string
	IPAddresses          string
	MultiAddresses       string
	Neighbors            string
	PeerLogs             string
	Peers                string
	PeersXMultiAddresses string
	Protocols            string
	ProtocolsSets        string
	Sessions             string
	SessionsClosed       string
	SessionsOpen         string
	Visits               string
}{
	AgentVersions:        "agent_versions",
	CrawlProperties:      "crawl_properties",
	Crawls:               "crawls",
	IPAddresses:          "ip_addresses",
	MultiAddresses:       "multi_addresses",
	Neighbors:            "neighbors",
	PeerLogs:             "peer_logs",
	Peers:                "peers",
	PeersXMultiAddresses: "peers_x_multi_addresses",
	Protocols:            "protocols",
	ProtocolsSets:        "protocols_sets",
	Sessions:             "sessions",
	SessionsClosed:       "sessions_closed",
	SessionsOpen:         "sessions_open",
	Visits:               "visits",
}
View Source
var ViewNames = struct {
}{}
View Source
var VisitColumns = struct {
	ID              string
	PeerID          string
	CrawlID         string
	SessionID       string
	AgentVersionID  string
	ProtocolsSetID  string
	Type            string
	ConnectError    string
	CrawlError      string
	VisitStartedAt  string
	VisitEndedAt    string
	CreatedAt       string
	DialDuration    string
	ConnectDuration string
	CrawlDuration   string
	MultiAddressIds string
	IsExposed       string
}{
	ID:              "id",
	PeerID:          "peer_id",
	CrawlID:         "crawl_id",
	SessionID:       "session_id",
	AgentVersionID:  "agent_version_id",
	ProtocolsSetID:  "protocols_set_id",
	Type:            "type",
	ConnectError:    "connect_error",
	CrawlError:      "crawl_error",
	VisitStartedAt:  "visit_started_at",
	VisitEndedAt:    "visit_ended_at",
	CreatedAt:       "created_at",
	DialDuration:    "dial_duration",
	ConnectDuration: "connect_duration",
	CrawlDuration:   "crawl_duration",
	MultiAddressIds: "multi_address_ids",
	IsExposed:       "is_exposed",
}
View Source
var VisitRels = struct {
}{}

VisitRels is where relationship names are stored.

View Source
var VisitTableColumns = struct {
	ID              string
	PeerID          string
	CrawlID         string
	SessionID       string
	AgentVersionID  string
	ProtocolsSetID  string
	Type            string
	ConnectError    string
	CrawlError      string
	VisitStartedAt  string
	VisitEndedAt    string
	CreatedAt       string
	DialDuration    string
	ConnectDuration string
	CrawlDuration   string
	MultiAddressIds string
	IsExposed       string
}{
	ID:              "visits.id",
	PeerID:          "visits.peer_id",
	CrawlID:         "visits.crawl_id",
	SessionID:       "visits.session_id",
	AgentVersionID:  "visits.agent_version_id",
	ProtocolsSetID:  "visits.protocols_set_id",
	Type:            "visits.type",
	ConnectError:    "visits.connect_error",
	CrawlError:      "visits.crawl_error",
	VisitStartedAt:  "visits.visit_started_at",
	VisitEndedAt:    "visits.visit_ended_at",
	CreatedAt:       "visits.created_at",
	DialDuration:    "visits.dial_duration",
	ConnectDuration: "visits.connect_duration",
	CrawlDuration:   "visits.crawl_duration",
	MultiAddressIds: "visits.multi_address_ids",
	IsExposed:       "visits.is_exposed",
}
View Source
var VisitWhere = struct {
	ID              whereHelperint
	PeerID          whereHelperint
	CrawlID         whereHelpernull_Int
	SessionID       whereHelpernull_Int
	AgentVersionID  whereHelpernull_Int
	ProtocolsSetID  whereHelpernull_Int
	Type            whereHelperstring
	ConnectError    whereHelpernull_String
	CrawlError      whereHelpernull_String
	VisitStartedAt  whereHelpertime_Time
	VisitEndedAt    whereHelpertime_Time
	CreatedAt       whereHelpertime_Time
	DialDuration    whereHelpernull_String
	ConnectDuration whereHelpernull_String
	CrawlDuration   whereHelpernull_String
	MultiAddressIds whereHelpertypes_Int64Array
	IsExposed       whereHelpernull_Bool
}{
	ID:              whereHelperint{/* contains filtered or unexported fields */},
	PeerID:          whereHelperint{/* contains filtered or unexported fields */},
	CrawlID:         whereHelpernull_Int{/* contains filtered or unexported fields */},
	SessionID:       whereHelpernull_Int{/* contains filtered or unexported fields */},
	AgentVersionID:  whereHelpernull_Int{/* contains filtered or unexported fields */},
	ProtocolsSetID:  whereHelpernull_Int{/* contains filtered or unexported fields */},
	Type:            whereHelperstring{/* contains filtered or unexported fields */},
	ConnectError:    whereHelpernull_String{/* contains filtered or unexported fields */},
	CrawlError:      whereHelpernull_String{/* contains filtered or unexported fields */},
	VisitStartedAt:  whereHelpertime_Time{/* contains filtered or unexported fields */},
	VisitEndedAt:    whereHelpertime_Time{/* contains filtered or unexported fields */},
	CreatedAt:       whereHelpertime_Time{/* contains filtered or unexported fields */},
	DialDuration:    whereHelpernull_String{/* contains filtered or unexported fields */},
	ConnectDuration: whereHelpernull_String{/* contains filtered or unexported fields */},
	CrawlDuration:   whereHelpernull_String{/* contains filtered or unexported fields */},
	MultiAddressIds: whereHelpertypes_Int64Array{/* contains filtered or unexported fields */},
	IsExposed:       whereHelpernull_Bool{/* contains filtered or unexported fields */},
}

Functions

func AddAgentVersionHook

func AddAgentVersionHook(hookPoint boil.HookPoint, agentVersionHook AgentVersionHook)

AddAgentVersionHook registers your hook function for all future operations.

func AddCrawlHook

func AddCrawlHook(hookPoint boil.HookPoint, crawlHook CrawlHook)

AddCrawlHook registers your hook function for all future operations.

func AddCrawlPropertyHook

func AddCrawlPropertyHook(hookPoint boil.HookPoint, crawlPropertyHook CrawlPropertyHook)

AddCrawlPropertyHook registers your hook function for all future operations.

func AddIPAddressHook

func AddIPAddressHook(hookPoint boil.HookPoint, ipAddressHook IPAddressHook)

AddIPAddressHook registers your hook function for all future operations.

func AddMultiAddressHook

func AddMultiAddressHook(hookPoint boil.HookPoint, multiAddressHook MultiAddressHook)

AddMultiAddressHook registers your hook function for all future operations.

func AddNeighborHook

func AddNeighborHook(hookPoint boil.HookPoint, neighborHook NeighborHook)

AddNeighborHook registers your hook function for all future operations.

func AddPeerHook

func AddPeerHook(hookPoint boil.HookPoint, peerHook PeerHook)

AddPeerHook registers your hook function for all future operations.

func AddPeerLogHook

func AddPeerLogHook(hookPoint boil.HookPoint, peerLogHook PeerLogHook)

AddPeerLogHook registers your hook function for all future operations.

func AddProtocolHook

func AddProtocolHook(hookPoint boil.HookPoint, protocolHook ProtocolHook)

AddProtocolHook registers your hook function for all future operations.

func AddProtocolsSetHook

func AddProtocolsSetHook(hookPoint boil.HookPoint, protocolsSetHook ProtocolsSetHook)

AddProtocolsSetHook registers your hook function for all future operations.

func AddSessionHook

func AddSessionHook(hookPoint boil.HookPoint, sessionHook SessionHook)

AddSessionHook registers your hook function for all future operations.

func AddSessionsClosedHook

func AddSessionsClosedHook(hookPoint boil.HookPoint, sessionsClosedHook SessionsClosedHook)

AddSessionsClosedHook registers your hook function for all future operations.

func AddSessionsOpenHook

func AddSessionsOpenHook(hookPoint boil.HookPoint, sessionsOpenHook SessionsOpenHook)

AddSessionsOpenHook registers your hook function for all future operations.

func AddVisitHook

func AddVisitHook(hookPoint boil.HookPoint, visitHook VisitHook)

AddVisitHook registers your hook function for all future operations.

func AgentVersionExists

func AgentVersionExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

AgentVersionExists checks if the AgentVersion row exists.

func AgentVersions

func AgentVersions(mods ...qm.QueryMod) agentVersionQuery

AgentVersions retrieves all the records using an executor.

func AllCrawlState

func AllCrawlState() []string

func AllNetError

func AllNetError() []string

func AllSessionState

func AllSessionState() []string

func AllVisitType

func AllVisitType() []string

func CrawlExists

func CrawlExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

CrawlExists checks if the Crawl row exists.

func CrawlProperties

func CrawlProperties(mods ...qm.QueryMod) crawlPropertyQuery

CrawlProperties retrieves all the records using an executor.

func CrawlPropertyExists

func CrawlPropertyExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

CrawlPropertyExists checks if the CrawlProperty row exists.

func Crawls

func Crawls(mods ...qm.QueryMod) crawlQuery

Crawls retrieves all the records using an executor.

func IPAddressExists

func IPAddressExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

IPAddressExists checks if the IPAddress row exists.

func IPAddresses

func IPAddresses(mods ...qm.QueryMod) ipAddressQuery

IPAddresses retrieves all the records using an executor.

func MultiAddressExists

func MultiAddressExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

MultiAddressExists checks if the MultiAddress row exists.

func MultiAddresses

func MultiAddresses(mods ...qm.QueryMod) multiAddressQuery

MultiAddresses retrieves all the records using an executor.

func NeighborExists

func NeighborExists(ctx context.Context, exec boil.ContextExecutor, crawlID int, peerID int) (bool, error)

NeighborExists checks if the Neighbor row exists.

func Neighbors

func Neighbors(mods ...qm.QueryMod) neighborQuery

Neighbors retrieves all the records using an executor.

func NewQuery

func NewQuery(mods ...qm.QueryMod) *queries.Query

NewQuery initializes a new Query using the passed in QueryMods

func PeerExists

func PeerExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

PeerExists checks if the Peer row exists.

func PeerLogExists

func PeerLogExists(ctx context.Context, exec boil.ContextExecutor, iD int, createdAt time.Time) (bool, error)

PeerLogExists checks if the PeerLog row exists.

func PeerLogs

func PeerLogs(mods ...qm.QueryMod) peerLogQuery

PeerLogs retrieves all the records using an executor.

func Peers

func Peers(mods ...qm.QueryMod) peerQuery

Peers retrieves all the records using an executor.

func ProtocolExists

func ProtocolExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

ProtocolExists checks if the Protocol row exists.

func Protocols

func Protocols(mods ...qm.QueryMod) protocolQuery

Protocols retrieves all the records using an executor.

func ProtocolsSetExists

func ProtocolsSetExists(ctx context.Context, exec boil.ContextExecutor, iD int) (bool, error)

ProtocolsSetExists checks if the ProtocolsSet row exists.

func ProtocolsSets

func ProtocolsSets(mods ...qm.QueryMod) protocolsSetQuery

ProtocolsSets retrieves all the records using an executor.

func SessionExists

func SessionExists(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time) (bool, error)

SessionExists checks if the Session row exists.

func Sessions

func Sessions(mods ...qm.QueryMod) sessionQuery

Sessions retrieves all the records using an executor.

func SessionsClosedExists

func SessionsClosedExists(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time) (bool, error)

SessionsClosedExists checks if the SessionsClosed row exists.

func SessionsCloseds

func SessionsCloseds(mods ...qm.QueryMod) sessionsClosedQuery

SessionsCloseds retrieves all the records using an executor.

func SessionsOpenExists

func SessionsOpenExists(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time) (bool, error)

SessionsOpenExists checks if the SessionsOpen row exists.

func SessionsOpens

func SessionsOpens(mods ...qm.QueryMod) sessionsOpenQuery

SessionsOpens retrieves all the records using an executor.

func VisitExists

func VisitExists(ctx context.Context, exec boil.ContextExecutor, iD int, visitStartedAt time.Time) (bool, error)

VisitExists checks if the Visit row exists.

func Visits

func Visits(mods ...qm.QueryMod) visitQuery

Visits retrieves all the records using an executor.

Types

type AgentVersion

type AgentVersion struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// Timestamp of when this agent version was seen the last time.
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	// Agent version string as reported from the remote peer.
	AgentVersion string `boil:"agent_version" json:"agent_version" toml:"agent_version" yaml:"agent_version"`

	R *agentVersionR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L agentVersionL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

AgentVersion is an object representing the database table.

func FindAgentVersion

func FindAgentVersion(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*AgentVersion, error)

FindAgentVersion retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*AgentVersion) AddCrawlProperties

func (o *AgentVersion) AddCrawlProperties(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*CrawlProperty) error

AddCrawlProperties adds the given related objects to the existing relationships of the agent_version, optionally inserting them as new records. Appends related to o.R.CrawlProperties. Sets related.R.AgentVersion appropriately.

func (*AgentVersion) AddPeers

func (o *AgentVersion) AddPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

AddPeers adds the given related objects to the existing relationships of the agent_version, optionally inserting them as new records. Appends related to o.R.Peers. Sets related.R.AgentVersion appropriately.

func (*AgentVersion) CrawlProperties

func (o *AgentVersion) CrawlProperties(mods ...qm.QueryMod) crawlPropertyQuery

CrawlProperties retrieves all the crawl_property's CrawlProperties with an executor.

func (*AgentVersion) Delete

func (o *AgentVersion) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single AgentVersion record with an executor. Delete will match against the primary key column to find the record to delete.

func (*AgentVersion) Insert

func (o *AgentVersion) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*AgentVersion) Peers

func (o *AgentVersion) Peers(mods ...qm.QueryMod) peerQuery

Peers retrieves all the peer's Peers with an executor.

func (*AgentVersion) Reload

func (o *AgentVersion) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*AgentVersion) RemoveCrawlProperties

func (o *AgentVersion) RemoveCrawlProperties(ctx context.Context, exec boil.ContextExecutor, related ...*CrawlProperty) error

RemoveCrawlProperties relationships from objects passed in. Removes related items from R.CrawlProperties (uses pointer comparison, removal does not keep order) Sets related.R.AgentVersion.

func (*AgentVersion) RemovePeers

func (o *AgentVersion) RemovePeers(ctx context.Context, exec boil.ContextExecutor, related ...*Peer) error

RemovePeers relationships from objects passed in. Removes related items from R.Peers (uses pointer comparison, removal does not keep order) Sets related.R.AgentVersion.

func (*AgentVersion) SetCrawlProperties

func (o *AgentVersion) SetCrawlProperties(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*CrawlProperty) error

SetCrawlProperties removes all previously related items of the agent_version replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.AgentVersion's CrawlProperties accordingly. Replaces o.R.CrawlProperties with related. Sets related.R.AgentVersion's CrawlProperties accordingly.

func (*AgentVersion) SetPeers

func (o *AgentVersion) SetPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

SetPeers removes all previously related items of the agent_version replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.AgentVersion's Peers accordingly. Replaces o.R.Peers with related. Sets related.R.AgentVersion's Peers accordingly.

func (*AgentVersion) Update

func (o *AgentVersion) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the AgentVersion. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*AgentVersion) Upsert

func (o *AgentVersion) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type AgentVersionHook

type AgentVersionHook func(context.Context, boil.ContextExecutor, *AgentVersion) error

AgentVersionHook is the signature for custom AgentVersion hook methods

type AgentVersionSlice

type AgentVersionSlice []*AgentVersion

AgentVersionSlice is an alias for a slice of pointers to AgentVersion. This should almost always be used instead of []AgentVersion.

func (AgentVersionSlice) DeleteAll

func (o AgentVersionSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*AgentVersionSlice) ReloadAll

func (o *AgentVersionSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (AgentVersionSlice) UpdateAll

func (o AgentVersionSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Crawl

type Crawl struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// The state of this crawl.
	State string `boil:"state" json:"state" toml:"state" yaml:"state"`
	// Timestamp of when this crawl process started.
	StartedAt time.Time `boil:"started_at" json:"started_at" toml:"started_at" yaml:"started_at"`
	// Timestamp of when this crawl process finished.
	FinishedAt null.Time `boil:"finished_at" json:"finished_at,omitempty" toml:"finished_at" yaml:"finished_at,omitempty"`
	// Timestamp of when this crawl row was updated the last time.
	UpdatedAt time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	// Timestamp of when this crawl instance was created which can slightly differ from the started_at timestamp.
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	// Number of _visited_ peers during this crawl.
	CrawledPeers null.Int `boil:"crawled_peers" json:"crawled_peers,omitempty" toml:"crawled_peers" yaml:"crawled_peers,omitempty"`
	// Number of successfully dialed peers during this crawl.
	DialablePeers null.Int `boil:"dialable_peers" json:"dialable_peers,omitempty" toml:"dialable_peers" yaml:"dialable_peers,omitempty"`
	// Number of peers that could not be reached during this crawl.
	UndialablePeers null.Int `boil:"undialable_peers" json:"undialable_peers,omitempty" toml:"undialable_peers" yaml:"undialable_peers,omitempty"`

	R *crawlR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L crawlL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Crawl is an object representing the database table.

func FindCrawl

func FindCrawl(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*Crawl, error)

FindCrawl retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Crawl) AddCrawlProperties

func (o *Crawl) AddCrawlProperties(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*CrawlProperty) error

AddCrawlProperties adds the given related objects to the existing relationships of the crawl, optionally inserting them as new records. Appends related to o.R.CrawlProperties. Sets related.R.Crawl appropriately.

func (*Crawl) CrawlProperties

func (o *Crawl) CrawlProperties(mods ...qm.QueryMod) crawlPropertyQuery

CrawlProperties retrieves all the crawl_property's CrawlProperties with an executor.

func (*Crawl) Delete

func (o *Crawl) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Crawl record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Crawl) Insert

func (o *Crawl) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Crawl) Reload

func (o *Crawl) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Crawl) Update

func (o *Crawl) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Crawl. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Crawl) Upsert

func (o *Crawl) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type CrawlHook

type CrawlHook func(context.Context, boil.ContextExecutor, *Crawl) error

CrawlHook is the signature for custom Crawl hook methods

type CrawlProperty

type CrawlProperty struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// A reference to the crawl that this aggregated crawl property belongs to.
	CrawlID int `boil:"crawl_id" json:"crawl_id" toml:"crawl_id" yaml:"crawl_id"`
	// If not NULL the count value corresponds to the number of peers we found with this protocol during the referenced crawl.
	ProtocolID null.Int `boil:"protocol_id" json:"protocol_id,omitempty" toml:"protocol_id" yaml:"protocol_id,omitempty"`
	// If not NULL the count value corresponds to the number of peers we found with this agent version during the referenced crawl.
	AgentVersionID null.Int `boil:"agent_version_id" json:"agent_version_id,omitempty" toml:"agent_version_id" yaml:"agent_version_id,omitempty"`
	// If not NULL the count value corresponds to the number of peers we failed to connect to with this error type during the referenced crawl.
	Error null.String `boil:"error" json:"error,omitempty" toml:"error" yaml:"error,omitempty"`
	// The aggregated count of one of the properties above (protocol, agent version, dial error).
	Count int `boil:"count" json:"count" toml:"count" yaml:"count"`

	R *crawlPropertyR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L crawlPropertyL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

CrawlProperty is an object representing the database table.

func FindCrawlProperty

func FindCrawlProperty(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*CrawlProperty, error)

FindCrawlProperty retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*CrawlProperty) AgentVersion

func (o *CrawlProperty) AgentVersion(mods ...qm.QueryMod) agentVersionQuery

AgentVersion pointed to by the foreign key.

func (*CrawlProperty) Crawl

func (o *CrawlProperty) Crawl(mods ...qm.QueryMod) crawlQuery

Crawl pointed to by the foreign key.

func (*CrawlProperty) Delete

func (o *CrawlProperty) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single CrawlProperty record with an executor. Delete will match against the primary key column to find the record to delete.

func (*CrawlProperty) Insert

func (o *CrawlProperty) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*CrawlProperty) Protocol

func (o *CrawlProperty) Protocol(mods ...qm.QueryMod) protocolQuery

Protocol pointed to by the foreign key.

func (*CrawlProperty) Reload

func (o *CrawlProperty) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*CrawlProperty) RemoveAgentVersion

func (o *CrawlProperty) RemoveAgentVersion(ctx context.Context, exec boil.ContextExecutor, related *AgentVersion) error

RemoveAgentVersion relationship. Sets o.R.AgentVersion to nil. Removes o from all passed in related items' relationships struct.

func (*CrawlProperty) RemoveProtocol

func (o *CrawlProperty) RemoveProtocol(ctx context.Context, exec boil.ContextExecutor, related *Protocol) error

RemoveProtocol relationship. Sets o.R.Protocol to nil. Removes o from all passed in related items' relationships struct.

func (*CrawlProperty) SetAgentVersion

func (o *CrawlProperty) SetAgentVersion(ctx context.Context, exec boil.ContextExecutor, insert bool, related *AgentVersion) error

SetAgentVersion of the crawlProperty to the related item. Sets o.R.AgentVersion to related. Adds o to related.R.CrawlProperties.

func (*CrawlProperty) SetCrawl

func (o *CrawlProperty) SetCrawl(ctx context.Context, exec boil.ContextExecutor, insert bool, related *Crawl) error

SetCrawl of the crawlProperty to the related item. Sets o.R.Crawl to related. Adds o to related.R.CrawlProperties.

func (*CrawlProperty) SetProtocol

func (o *CrawlProperty) SetProtocol(ctx context.Context, exec boil.ContextExecutor, insert bool, related *Protocol) error

SetProtocol of the crawlProperty to the related item. Sets o.R.Protocol to related. Adds o to related.R.CrawlProperties.

func (*CrawlProperty) Update

func (o *CrawlProperty) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the CrawlProperty. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*CrawlProperty) Upsert

func (o *CrawlProperty) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type CrawlPropertyHook

type CrawlPropertyHook func(context.Context, boil.ContextExecutor, *CrawlProperty) error

CrawlPropertyHook is the signature for custom CrawlProperty hook methods

type CrawlPropertySlice

type CrawlPropertySlice []*CrawlProperty

CrawlPropertySlice is an alias for a slice of pointers to CrawlProperty. This should almost always be used instead of []CrawlProperty.

func (CrawlPropertySlice) DeleteAll

func (o CrawlPropertySlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*CrawlPropertySlice) ReloadAll

func (o *CrawlPropertySlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (CrawlPropertySlice) UpdateAll

func (o CrawlPropertySlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type CrawlSlice

type CrawlSlice []*Crawl

CrawlSlice is an alias for a slice of pointers to Crawl. This should almost always be used instead of []Crawl.

func (CrawlSlice) DeleteAll

func (o CrawlSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*CrawlSlice) ReloadAll

func (o *CrawlSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (CrawlSlice) UpdateAll

func (o CrawlSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type IPAddress

type IPAddress struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// The multi address that this ip address belongs to.
	MultiAddressID int `boil:"multi_address_id" json:"multi_address_id" toml:"multi_address_id" yaml:"multi_address_id"`
	// The autonomous system number that this ip address belongs to.
	Asn null.Int `boil:"asn" json:"asn,omitempty" toml:"asn" yaml:"asn,omitempty"`
	// If NULL this address could not be associated with a cloud provider. If not NULL the integer corresponds to the UdgerDB datacenter ID.
	IsCloud null.Int `boil:"is_cloud" json:"is_cloud,omitempty" toml:"is_cloud" yaml:"is_cloud,omitempty"`
	// Timestamp of when this IP address was updated.
	UpdatedAt time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	// Timestamp of when this IP address was created.
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	// The country that this address belongs to in the form of a two to three letter country code
	Country null.String `boil:"country" json:"country,omitempty" toml:"country" yaml:"country,omitempty"`
	// The continent that this address belongs to in the form of a two letter code.
	Continent null.String `boil:"continent" json:"continent,omitempty" toml:"continent" yaml:"continent,omitempty"`
	// The IP address derived from the reference multi address.
	Address string `boil:"address" json:"address" toml:"address" yaml:"address"`

	R *ipAddressR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L ipAddressL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

IPAddress is an object representing the database table.

func FindIPAddress

func FindIPAddress(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*IPAddress, error)

FindIPAddress retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*IPAddress) Delete

func (o *IPAddress) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single IPAddress record with an executor. Delete will match against the primary key column to find the record to delete.

func (*IPAddress) Insert

func (o *IPAddress) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*IPAddress) MultiAddress

func (o *IPAddress) MultiAddress(mods ...qm.QueryMod) multiAddressQuery

MultiAddress pointed to by the foreign key.

func (*IPAddress) Reload

func (o *IPAddress) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*IPAddress) SetMultiAddress

func (o *IPAddress) SetMultiAddress(ctx context.Context, exec boil.ContextExecutor, insert bool, related *MultiAddress) error

SetMultiAddress of the ipAddress to the related item. Sets o.R.MultiAddress to related. Adds o to related.R.IPAddresses.

func (*IPAddress) Update

func (o *IPAddress) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the IPAddress. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*IPAddress) Upsert

func (o *IPAddress) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type IPAddressHook

type IPAddressHook func(context.Context, boil.ContextExecutor, *IPAddress) error

IPAddressHook is the signature for custom IPAddress hook methods

type IPAddressSlice

type IPAddressSlice []*IPAddress

IPAddressSlice is an alias for a slice of pointers to IPAddress. This should almost always be used instead of []IPAddress.

func (IPAddressSlice) DeleteAll

func (o IPAddressSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*IPAddressSlice) ReloadAll

func (o *IPAddressSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (IPAddressSlice) UpdateAll

func (o IPAddressSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type M

type M map[string]interface{}

M type is for providing columns and column values to UpdateAll.

type MultiAddress

type MultiAddress struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// The autonomous system number that this multi address belongs to.
	Asn null.Int `boil:"asn" json:"asn,omitempty" toml:"asn" yaml:"asn,omitempty"`
	// If NULL this multi address could not be associated with a cloud provider. If not NULL the integer corresponds to the UdgerDB datacenter ID.
	IsCloud null.Int `boil:"is_cloud" json:"is_cloud,omitempty" toml:"is_cloud" yaml:"is_cloud,omitempty"`
	// A boolean value that indicates whether this multi address is a relay address.
	IsRelay null.Bool `boil:"is_relay" json:"is_relay,omitempty" toml:"is_relay" yaml:"is_relay,omitempty"`
	// A boolean value that indicates whether this multi address is a publicly reachable one.
	IsPublic null.Bool `boil:"is_public" json:"is_public,omitempty" toml:"is_public" yaml:"is_public,omitempty"`
	// The derived IPv4 or IPv6 address of this multi address.
	Addr null.String `boil:"addr" json:"addr,omitempty" toml:"addr" yaml:"addr,omitempty"`
	// Indicates if the multi_address has multiple IP addresses. Could happen for dnsaddr multi addresses.
	HasManyAddrs null.Bool `boil:"has_many_addrs" json:"has_many_addrs,omitempty" toml:"has_many_addrs" yaml:"has_many_addrs,omitempty"`
	Resolved     bool      `boil:"resolved" json:"resolved" toml:"resolved" yaml:"resolved"`
	// The country that this multi address belongs to in the form of a two letter country code.
	Country null.String `boil:"country" json:"country,omitempty" toml:"country" yaml:"country,omitempty"`
	// The continent that this multi address belongs to in the form of a two letter code.
	Continent null.String `boil:"continent" json:"continent,omitempty" toml:"continent" yaml:"continent,omitempty"`
	// The multi address in the form of `/ip4/123.456.789.123/tcp/4001`.
	Maddr string `boil:"maddr" json:"maddr" toml:"maddr" yaml:"maddr"`
	// Timestamp of when this multi address was updated.
	UpdatedAt time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	// Timestamp of when this multi address was created.
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`

	R *multiAddressR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L multiAddressL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

MultiAddress is an object representing the database table.

func FindMultiAddress

func FindMultiAddress(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*MultiAddress, error)

FindMultiAddress retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*MultiAddress) AddIPAddresses

func (o *MultiAddress) AddIPAddresses(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*IPAddress) error

AddIPAddresses adds the given related objects to the existing relationships of the multi_address, optionally inserting them as new records. Appends related to o.R.IPAddresses. Sets related.R.MultiAddress appropriately.

func (*MultiAddress) AddPeers

func (o *MultiAddress) AddPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

AddPeers adds the given related objects to the existing relationships of the multi_address, optionally inserting them as new records. Appends related to o.R.Peers. Sets related.R.MultiAddresses appropriately.

func (*MultiAddress) Delete

func (o *MultiAddress) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single MultiAddress record with an executor. Delete will match against the primary key column to find the record to delete.

func (*MultiAddress) IPAddresses

func (o *MultiAddress) IPAddresses(mods ...qm.QueryMod) ipAddressQuery

IPAddresses retrieves all the ip_address's IPAddresses with an executor.

func (*MultiAddress) Insert

func (o *MultiAddress) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*MultiAddress) Peers

func (o *MultiAddress) Peers(mods ...qm.QueryMod) peerQuery

Peers retrieves all the peer's Peers with an executor.

func (*MultiAddress) Reload

func (o *MultiAddress) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*MultiAddress) RemovePeers

func (o *MultiAddress) RemovePeers(ctx context.Context, exec boil.ContextExecutor, related ...*Peer) error

RemovePeers relationships from objects passed in. Removes related items from R.Peers (uses pointer comparison, removal does not keep order) Sets related.R.MultiAddresses.

func (*MultiAddress) SetPeers

func (o *MultiAddress) SetPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

SetPeers removes all previously related items of the multi_address replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.MultiAddresses's Peers accordingly. Replaces o.R.Peers with related. Sets related.R.MultiAddresses's Peers accordingly.

func (*MultiAddress) Update

func (o *MultiAddress) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the MultiAddress. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*MultiAddress) Upsert

func (o *MultiAddress) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type MultiAddressHook

type MultiAddressHook func(context.Context, boil.ContextExecutor, *MultiAddress) error

MultiAddressHook is the signature for custom MultiAddress hook methods

type MultiAddressSlice

type MultiAddressSlice []*MultiAddress

MultiAddressSlice is an alias for a slice of pointers to MultiAddress. This should almost always be used instead of []MultiAddress.

func (MultiAddressSlice) DeleteAll

func (o MultiAddressSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*MultiAddressSlice) ReloadAll

func (o *MultiAddressSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (MultiAddressSlice) UpdateAll

func (o MultiAddressSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Neighbor

type Neighbor struct {
	CrawlID     int              `boil:"crawl_id" json:"crawl_id" toml:"crawl_id" yaml:"crawl_id"`
	PeerID      int              `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	NeighborIds types.Int64Array `boil:"neighbor_ids" json:"neighbor_ids,omitempty" toml:"neighbor_ids" yaml:"neighbor_ids,omitempty"`
	ErrorBits   int16            `boil:"error_bits" json:"error_bits" toml:"error_bits" yaml:"error_bits"`

	R *neighborR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L neighborL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Neighbor is an object representing the database table.

func FindNeighbor

func FindNeighbor(ctx context.Context, exec boil.ContextExecutor, crawlID int, peerID int, selectCols ...string) (*Neighbor, error)

FindNeighbor retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Neighbor) Delete

func (o *Neighbor) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Neighbor record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Neighbor) Insert

func (o *Neighbor) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Neighbor) Reload

func (o *Neighbor) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Neighbor) Update

func (o *Neighbor) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Neighbor. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Neighbor) Upsert

func (o *Neighbor) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type NeighborHook

type NeighborHook func(context.Context, boil.ContextExecutor, *Neighbor) error

NeighborHook is the signature for custom Neighbor hook methods

type NeighborSlice

type NeighborSlice []*Neighbor

NeighborSlice is an alias for a slice of pointers to Neighbor. This should almost always be used instead of []Neighbor.

func (NeighborSlice) DeleteAll

func (o NeighborSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*NeighborSlice) ReloadAll

func (o *NeighborSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (NeighborSlice) UpdateAll

func (o NeighborSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Peer

type Peer struct {
	ID             int       `boil:"id" json:"id" toml:"id" yaml:"id"`
	AgentVersionID null.Int  `boil:"agent_version_id" json:"agent_version_id,omitempty" toml:"agent_version_id" yaml:"agent_version_id,omitempty"`
	ProtocolsSetID null.Int  `boil:"protocols_set_id" json:"protocols_set_id,omitempty" toml:"protocols_set_id" yaml:"protocols_set_id,omitempty"`
	MultiHash      string    `boil:"multi_hash" json:"multi_hash" toml:"multi_hash" yaml:"multi_hash"`
	UpdatedAt      time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	CreatedAt      time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	IsExposed      null.Bool `boil:"is_exposed" json:"is_exposed,omitempty" toml:"is_exposed" yaml:"is_exposed,omitempty"`

	R *peerR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L peerL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Peer is an object representing the database table.

func FindPeer

func FindPeer(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*Peer, error)

FindPeer retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Peer) AddMultiAddresses

func (o *Peer) AddMultiAddresses(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*MultiAddress) error

AddMultiAddresses adds the given related objects to the existing relationships of the peer, optionally inserting them as new records. Appends related to o.R.MultiAddresses. Sets related.R.Peers appropriately.

func (*Peer) AgentVersion

func (o *Peer) AgentVersion(mods ...qm.QueryMod) agentVersionQuery

AgentVersion pointed to by the foreign key.

func (*Peer) Delete

func (o *Peer) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Peer record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Peer) Insert

func (o *Peer) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Peer) MultiAddresses

func (o *Peer) MultiAddresses(mods ...qm.QueryMod) multiAddressQuery

MultiAddresses retrieves all the multi_address's MultiAddresses with an executor.

func (*Peer) ProtocolsSet

func (o *Peer) ProtocolsSet(mods ...qm.QueryMod) protocolsSetQuery

ProtocolsSet pointed to by the foreign key.

func (*Peer) Reload

func (o *Peer) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Peer) RemoveAgentVersion

func (o *Peer) RemoveAgentVersion(ctx context.Context, exec boil.ContextExecutor, related *AgentVersion) error

RemoveAgentVersion relationship. Sets o.R.AgentVersion to nil. Removes o from all passed in related items' relationships struct.

func (*Peer) RemoveMultiAddresses

func (o *Peer) RemoveMultiAddresses(ctx context.Context, exec boil.ContextExecutor, related ...*MultiAddress) error

RemoveMultiAddresses relationships from objects passed in. Removes related items from R.MultiAddresses (uses pointer comparison, removal does not keep order) Sets related.R.Peers.

func (*Peer) RemoveProtocolsSet

func (o *Peer) RemoveProtocolsSet(ctx context.Context, exec boil.ContextExecutor, related *ProtocolsSet) error

RemoveProtocolsSet relationship. Sets o.R.ProtocolsSet to nil. Removes o from all passed in related items' relationships struct.

func (*Peer) SessionsOpen

func (o *Peer) SessionsOpen(mods ...qm.QueryMod) sessionsOpenQuery

SessionsOpen pointed to by the foreign key.

func (*Peer) SetAgentVersion

func (o *Peer) SetAgentVersion(ctx context.Context, exec boil.ContextExecutor, insert bool, related *AgentVersion) error

SetAgentVersion of the peer to the related item. Sets o.R.AgentVersion to related. Adds o to related.R.Peers.

func (*Peer) SetMultiAddresses

func (o *Peer) SetMultiAddresses(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*MultiAddress) error

SetMultiAddresses removes all previously related items of the peer replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.Peers's MultiAddresses accordingly. Replaces o.R.MultiAddresses with related. Sets related.R.Peers's MultiAddresses accordingly.

func (*Peer) SetProtocolsSet

func (o *Peer) SetProtocolsSet(ctx context.Context, exec boil.ContextExecutor, insert bool, related *ProtocolsSet) error

SetProtocolsSet of the peer to the related item. Sets o.R.ProtocolsSet to related. Adds o to related.R.Peers.

func (*Peer) SetSessionsOpen

func (o *Peer) SetSessionsOpen(ctx context.Context, exec boil.ContextExecutor, insert bool, related *SessionsOpen) error

SetSessionsOpen of the peer to the related item. Sets o.R.SessionsOpen to related. Adds o to related.R.Peer.

func (*Peer) Update

func (o *Peer) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Peer. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Peer) Upsert

func (o *Peer) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type PeerHook

type PeerHook func(context.Context, boil.ContextExecutor, *Peer) error

PeerHook is the signature for custom Peer hook methods

type PeerLog

type PeerLog struct {
	ID        int       `boil:"id" json:"id" toml:"id" yaml:"id"`
	PeerID    int       `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	Field     string    `boil:"field" json:"field" toml:"field" yaml:"field"`
	Old       string    `boil:"old" json:"old" toml:"old" yaml:"old"`
	New       string    `boil:"new" json:"new" toml:"new" yaml:"new"`
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`

	R *peerLogR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L peerLogL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

PeerLog is an object representing the database table.

func FindPeerLog

func FindPeerLog(ctx context.Context, exec boil.ContextExecutor, iD int, createdAt time.Time, selectCols ...string) (*PeerLog, error)

FindPeerLog retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*PeerLog) Delete

func (o *PeerLog) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single PeerLog record with an executor. Delete will match against the primary key column to find the record to delete.

func (*PeerLog) Insert

func (o *PeerLog) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*PeerLog) Reload

func (o *PeerLog) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*PeerLog) Update

func (o *PeerLog) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the PeerLog. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*PeerLog) Upsert

func (o *PeerLog) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type PeerLogHook

type PeerLogHook func(context.Context, boil.ContextExecutor, *PeerLog) error

PeerLogHook is the signature for custom PeerLog hook methods

type PeerLogSlice

type PeerLogSlice []*PeerLog

PeerLogSlice is an alias for a slice of pointers to PeerLog. This should almost always be used instead of []PeerLog.

func (PeerLogSlice) DeleteAll

func (o PeerLogSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*PeerLogSlice) ReloadAll

func (o *PeerLogSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (PeerLogSlice) UpdateAll

func (o PeerLogSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type PeerSlice

type PeerSlice []*Peer

PeerSlice is an alias for a slice of pointers to Peer. This should almost always be used instead of []Peer.

func (PeerSlice) DeleteAll

func (o PeerSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*PeerSlice) ReloadAll

func (o *PeerSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (PeerSlice) UpdateAll

func (o PeerSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Protocol

type Protocol struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// Timestamp of when this protocol was seen the last time.
	CreatedAt time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	// The full protocol string.
	Protocol string `boil:"protocol" json:"protocol" toml:"protocol" yaml:"protocol"`

	R *protocolR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L protocolL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Protocol is an object representing the database table.

func FindProtocol

func FindProtocol(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*Protocol, error)

FindProtocol retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Protocol) AddCrawlProperties

func (o *Protocol) AddCrawlProperties(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*CrawlProperty) error

AddCrawlProperties adds the given related objects to the existing relationships of the protocol, optionally inserting them as new records. Appends related to o.R.CrawlProperties. Sets related.R.Protocol appropriately.

func (*Protocol) CrawlProperties

func (o *Protocol) CrawlProperties(mods ...qm.QueryMod) crawlPropertyQuery

CrawlProperties retrieves all the crawl_property's CrawlProperties with an executor.

func (*Protocol) Delete

func (o *Protocol) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Protocol record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Protocol) Insert

func (o *Protocol) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Protocol) Reload

func (o *Protocol) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Protocol) RemoveCrawlProperties

func (o *Protocol) RemoveCrawlProperties(ctx context.Context, exec boil.ContextExecutor, related ...*CrawlProperty) error

RemoveCrawlProperties relationships from objects passed in. Removes related items from R.CrawlProperties (uses pointer comparison, removal does not keep order) Sets related.R.Protocol.

func (*Protocol) SetCrawlProperties

func (o *Protocol) SetCrawlProperties(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*CrawlProperty) error

SetCrawlProperties removes all previously related items of the protocol replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.Protocol's CrawlProperties accordingly. Replaces o.R.CrawlProperties with related. Sets related.R.Protocol's CrawlProperties accordingly.

func (*Protocol) Update

func (o *Protocol) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Protocol. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Protocol) Upsert

func (o *Protocol) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type ProtocolHook

type ProtocolHook func(context.Context, boil.ContextExecutor, *Protocol) error

ProtocolHook is the signature for custom Protocol hook methods

type ProtocolSlice

type ProtocolSlice []*Protocol

ProtocolSlice is an alias for a slice of pointers to Protocol. This should almost always be used instead of []Protocol.

func (ProtocolSlice) DeleteAll

func (o ProtocolSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*ProtocolSlice) ReloadAll

func (o *ProtocolSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (ProtocolSlice) UpdateAll

func (o ProtocolSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type ProtocolsSet

type ProtocolsSet struct {
	ID int `boil:"id" json:"id" toml:"id" yaml:"id"`
	// The protocol IDs of this protocol set. The IDs reference the protocols table (no foreign key checks).
	ProtocolIds types.Int64Array `boil:"protocol_ids" json:"protocol_ids" toml:"protocol_ids" yaml:"protocol_ids"`
	// The hash digest of the sorted protocol ids to allow a unique constraint.
	Hash []byte `boil:"hash" json:"hash" toml:"hash" yaml:"hash"`

	R *protocolsSetR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L protocolsSetL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

ProtocolsSet is an object representing the database table.

func FindProtocolsSet

func FindProtocolsSet(ctx context.Context, exec boil.ContextExecutor, iD int, selectCols ...string) (*ProtocolsSet, error)

FindProtocolsSet retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*ProtocolsSet) AddPeers

func (o *ProtocolsSet) AddPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

AddPeers adds the given related objects to the existing relationships of the protocols_set, optionally inserting them as new records. Appends related to o.R.Peers. Sets related.R.ProtocolsSet appropriately.

func (*ProtocolsSet) Delete

func (o *ProtocolsSet) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single ProtocolsSet record with an executor. Delete will match against the primary key column to find the record to delete.

func (*ProtocolsSet) Insert

func (o *ProtocolsSet) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*ProtocolsSet) Peers

func (o *ProtocolsSet) Peers(mods ...qm.QueryMod) peerQuery

Peers retrieves all the peer's Peers with an executor.

func (*ProtocolsSet) Reload

func (o *ProtocolsSet) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*ProtocolsSet) RemovePeers

func (o *ProtocolsSet) RemovePeers(ctx context.Context, exec boil.ContextExecutor, related ...*Peer) error

RemovePeers relationships from objects passed in. Removes related items from R.Peers (uses pointer comparison, removal does not keep order) Sets related.R.ProtocolsSet.

func (*ProtocolsSet) SetPeers

func (o *ProtocolsSet) SetPeers(ctx context.Context, exec boil.ContextExecutor, insert bool, related ...*Peer) error

SetPeers removes all previously related items of the protocols_set replacing them completely with the passed in related items, optionally inserting them as new records. Sets o.R.ProtocolsSet's Peers accordingly. Replaces o.R.Peers with related. Sets related.R.ProtocolsSet's Peers accordingly.

func (*ProtocolsSet) Update

func (o *ProtocolsSet) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the ProtocolsSet. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*ProtocolsSet) Upsert

func (o *ProtocolsSet) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type ProtocolsSetHook

type ProtocolsSetHook func(context.Context, boil.ContextExecutor, *ProtocolsSet) error

ProtocolsSetHook is the signature for custom ProtocolsSet hook methods

type ProtocolsSetSlice

type ProtocolsSetSlice []*ProtocolsSet

ProtocolsSetSlice is an alias for a slice of pointers to ProtocolsSet. This should almost always be used instead of []ProtocolsSet.

func (ProtocolsSetSlice) DeleteAll

func (o ProtocolsSetSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*ProtocolsSetSlice) ReloadAll

func (o *ProtocolsSetSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (ProtocolsSetSlice) UpdateAll

func (o ProtocolsSetSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Session

type Session struct {
	ID                    int         `boil:"id" json:"id" toml:"id" yaml:"id"`
	PeerID                int         `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	FirstSuccessfulVisit  time.Time   `boil:"first_successful_visit" json:"first_successful_visit" toml:"first_successful_visit" yaml:"first_successful_visit"`
	LastSuccessfulVisit   time.Time   `boil:"last_successful_visit" json:"last_successful_visit" toml:"last_successful_visit" yaml:"last_successful_visit"`
	NextVisitDueAt        null.Time   `boil:"next_visit_due_at" json:"next_visit_due_at,omitempty" toml:"next_visit_due_at" yaml:"next_visit_due_at,omitempty"`
	FirstFailedVisit      null.Time   `boil:"first_failed_visit" json:"first_failed_visit,omitempty" toml:"first_failed_visit" yaml:"first_failed_visit,omitempty"`
	LastFailedVisit       null.Time   `boil:"last_failed_visit" json:"last_failed_visit,omitempty" toml:"last_failed_visit" yaml:"last_failed_visit,omitempty"`
	LastVisitedAt         time.Time   `boil:"last_visited_at" json:"last_visited_at" toml:"last_visited_at" yaml:"last_visited_at"`
	UpdatedAt             time.Time   `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	CreatedAt             time.Time   `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	SuccessfulVisitsCount int         `boil:"successful_visits_count" json:"successful_visits_count" toml:"successful_visits_count" yaml:"successful_visits_count"`
	RecoveredCount        int         `boil:"recovered_count" json:"recovered_count" toml:"recovered_count" yaml:"recovered_count"`
	State                 string      `boil:"state" json:"state" toml:"state" yaml:"state"`
	FailedVisitsCount     int16       `boil:"failed_visits_count" json:"failed_visits_count" toml:"failed_visits_count" yaml:"failed_visits_count"`
	FinishReason          null.String `boil:"finish_reason" json:"finish_reason,omitempty" toml:"finish_reason" yaml:"finish_reason,omitempty"`
	Uptime                string      `boil:"uptime" json:"uptime" toml:"uptime" yaml:"uptime"`

	R *sessionR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L sessionL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Session is an object representing the database table.

func FindSession

func FindSession(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time, selectCols ...string) (*Session, error)

FindSession retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Session) Delete

func (o *Session) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Session record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Session) Insert

func (o *Session) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Session) Reload

func (o *Session) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Session) Update

func (o *Session) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Session. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Session) Upsert

func (o *Session) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type SessionHook

type SessionHook func(context.Context, boil.ContextExecutor, *Session) error

SessionHook is the signature for custom Session hook methods

type SessionSlice

type SessionSlice []*Session

SessionSlice is an alias for a slice of pointers to Session. This should almost always be used instead of []Session.

func (SessionSlice) DeleteAll

func (o SessionSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*SessionSlice) ReloadAll

func (o *SessionSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (SessionSlice) UpdateAll

func (o SessionSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type SessionsClosed

type SessionsClosed struct {
	ID                    int       `boil:"id" json:"id" toml:"id" yaml:"id"`
	PeerID                int       `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	FirstSuccessfulVisit  time.Time `boil:"first_successful_visit" json:"first_successful_visit" toml:"first_successful_visit" yaml:"first_successful_visit"`
	LastSuccessfulVisit   time.Time `boil:"last_successful_visit" json:"last_successful_visit" toml:"last_successful_visit" yaml:"last_successful_visit"`
	NextVisitDueAt        null.Time `boil:"next_visit_due_at" json:"next_visit_due_at,omitempty" toml:"next_visit_due_at" yaml:"next_visit_due_at,omitempty"`
	FirstFailedVisit      time.Time `boil:"first_failed_visit" json:"first_failed_visit" toml:"first_failed_visit" yaml:"first_failed_visit"`
	LastFailedVisit       time.Time `boil:"last_failed_visit" json:"last_failed_visit" toml:"last_failed_visit" yaml:"last_failed_visit"`
	LastVisitedAt         time.Time `boil:"last_visited_at" json:"last_visited_at" toml:"last_visited_at" yaml:"last_visited_at"`
	UpdatedAt             time.Time `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	CreatedAt             time.Time `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	SuccessfulVisitsCount int       `boil:"successful_visits_count" json:"successful_visits_count" toml:"successful_visits_count" yaml:"successful_visits_count"`
	RecoveredCount        int       `boil:"recovered_count" json:"recovered_count" toml:"recovered_count" yaml:"recovered_count"`
	State                 string    `boil:"state" json:"state" toml:"state" yaml:"state"`
	FailedVisitsCount     int16     `boil:"failed_visits_count" json:"failed_visits_count" toml:"failed_visits_count" yaml:"failed_visits_count"`
	FinishReason          string    `boil:"finish_reason" json:"finish_reason" toml:"finish_reason" yaml:"finish_reason"`
	Uptime                string    `boil:"uptime" json:"uptime" toml:"uptime" yaml:"uptime"`

	R *sessionsClosedR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L sessionsClosedL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

SessionsClosed is an object representing the database table.

func FindSessionsClosed

func FindSessionsClosed(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time, selectCols ...string) (*SessionsClosed, error)

FindSessionsClosed retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*SessionsClosed) Delete

func (o *SessionsClosed) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single SessionsClosed record with an executor. Delete will match against the primary key column to find the record to delete.

func (*SessionsClosed) Insert

func (o *SessionsClosed) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*SessionsClosed) Reload

func (o *SessionsClosed) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*SessionsClosed) Update

func (o *SessionsClosed) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the SessionsClosed. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*SessionsClosed) Upsert

func (o *SessionsClosed) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type SessionsClosedHook

type SessionsClosedHook func(context.Context, boil.ContextExecutor, *SessionsClosed) error

SessionsClosedHook is the signature for custom SessionsClosed hook methods

type SessionsClosedSlice

type SessionsClosedSlice []*SessionsClosed

SessionsClosedSlice is an alias for a slice of pointers to SessionsClosed. This should almost always be used instead of []SessionsClosed.

func (SessionsClosedSlice) DeleteAll

DeleteAll deletes all rows in the slice, using an executor.

func (*SessionsClosedSlice) ReloadAll

func (o *SessionsClosedSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (SessionsClosedSlice) UpdateAll

func (o SessionsClosedSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type SessionsOpen

type SessionsOpen struct {
	ID                    int         `boil:"id" json:"id" toml:"id" yaml:"id"`
	PeerID                int         `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	FirstSuccessfulVisit  time.Time   `boil:"first_successful_visit" json:"first_successful_visit" toml:"first_successful_visit" yaml:"first_successful_visit"`
	LastSuccessfulVisit   time.Time   `boil:"last_successful_visit" json:"last_successful_visit" toml:"last_successful_visit" yaml:"last_successful_visit"`
	NextVisitDueAt        time.Time   `boil:"next_visit_due_at" json:"next_visit_due_at" toml:"next_visit_due_at" yaml:"next_visit_due_at"`
	FirstFailedVisit      null.Time   `boil:"first_failed_visit" json:"first_failed_visit,omitempty" toml:"first_failed_visit" yaml:"first_failed_visit,omitempty"`
	LastFailedVisit       null.Time   `boil:"last_failed_visit" json:"last_failed_visit,omitempty" toml:"last_failed_visit" yaml:"last_failed_visit,omitempty"`
	LastVisitedAt         time.Time   `boil:"last_visited_at" json:"last_visited_at" toml:"last_visited_at" yaml:"last_visited_at"`
	UpdatedAt             time.Time   `boil:"updated_at" json:"updated_at" toml:"updated_at" yaml:"updated_at"`
	CreatedAt             time.Time   `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	SuccessfulVisitsCount int         `boil:"successful_visits_count" json:"successful_visits_count" toml:"successful_visits_count" yaml:"successful_visits_count"`
	RecoveredCount        int         `boil:"recovered_count" json:"recovered_count" toml:"recovered_count" yaml:"recovered_count"`
	State                 string      `boil:"state" json:"state" toml:"state" yaml:"state"`
	FailedVisitsCount     int16       `boil:"failed_visits_count" json:"failed_visits_count" toml:"failed_visits_count" yaml:"failed_visits_count"`
	FinishReason          null.String `boil:"finish_reason" json:"finish_reason,omitempty" toml:"finish_reason" yaml:"finish_reason,omitempty"`
	Uptime                string      `boil:"uptime" json:"uptime" toml:"uptime" yaml:"uptime"`

	R *sessionsOpenR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L sessionsOpenL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

SessionsOpen is an object representing the database table.

func FindSessionsOpen

func FindSessionsOpen(ctx context.Context, exec boil.ContextExecutor, iD int, state string, lastVisitedAt time.Time, selectCols ...string) (*SessionsOpen, error)

FindSessionsOpen retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*SessionsOpen) Delete

func (o *SessionsOpen) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single SessionsOpen record with an executor. Delete will match against the primary key column to find the record to delete.

func (*SessionsOpen) Insert

func (o *SessionsOpen) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*SessionsOpen) Peer

func (o *SessionsOpen) Peer(mods ...qm.QueryMod) peerQuery

Peer pointed to by the foreign key.

func (*SessionsOpen) Reload

func (o *SessionsOpen) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*SessionsOpen) SetPeer

func (o *SessionsOpen) SetPeer(ctx context.Context, exec boil.ContextExecutor, insert bool, related *Peer) error

SetPeer of the sessionsOpen to the related item. Sets o.R.Peer to related. Adds o to related.R.SessionsOpen.

func (*SessionsOpen) Update

func (o *SessionsOpen) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the SessionsOpen. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*SessionsOpen) Upsert

func (o *SessionsOpen) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type SessionsOpenHook

type SessionsOpenHook func(context.Context, boil.ContextExecutor, *SessionsOpen) error

SessionsOpenHook is the signature for custom SessionsOpen hook methods

type SessionsOpenSlice

type SessionsOpenSlice []*SessionsOpen

SessionsOpenSlice is an alias for a slice of pointers to SessionsOpen. This should almost always be used instead of []SessionsOpen.

func (SessionsOpenSlice) DeleteAll

func (o SessionsOpenSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*SessionsOpenSlice) ReloadAll

func (o *SessionsOpenSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (SessionsOpenSlice) UpdateAll

func (o SessionsOpenSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

type Visit

type Visit struct {
	ID              int              `boil:"id" json:"id" toml:"id" yaml:"id"`
	PeerID          int              `boil:"peer_id" json:"peer_id" toml:"peer_id" yaml:"peer_id"`
	CrawlID         null.Int         `boil:"crawl_id" json:"crawl_id,omitempty" toml:"crawl_id" yaml:"crawl_id,omitempty"`
	SessionID       null.Int         `boil:"session_id" json:"session_id,omitempty" toml:"session_id" yaml:"session_id,omitempty"`
	AgentVersionID  null.Int         `boil:"agent_version_id" json:"agent_version_id,omitempty" toml:"agent_version_id" yaml:"agent_version_id,omitempty"`
	ProtocolsSetID  null.Int         `boil:"protocols_set_id" json:"protocols_set_id,omitempty" toml:"protocols_set_id" yaml:"protocols_set_id,omitempty"`
	Type            string           `boil:"type" json:"type" toml:"type" yaml:"type"`
	ConnectError    null.String      `boil:"connect_error" json:"connect_error,omitempty" toml:"connect_error" yaml:"connect_error,omitempty"`
	CrawlError      null.String      `boil:"crawl_error" json:"crawl_error,omitempty" toml:"crawl_error" yaml:"crawl_error,omitempty"`
	VisitStartedAt  time.Time        `boil:"visit_started_at" json:"visit_started_at" toml:"visit_started_at" yaml:"visit_started_at"`
	VisitEndedAt    time.Time        `boil:"visit_ended_at" json:"visit_ended_at" toml:"visit_ended_at" yaml:"visit_ended_at"`
	CreatedAt       time.Time        `boil:"created_at" json:"created_at" toml:"created_at" yaml:"created_at"`
	DialDuration    null.String      `boil:"dial_duration" json:"dial_duration,omitempty" toml:"dial_duration" yaml:"dial_duration,omitempty"`
	ConnectDuration null.String      `boil:"connect_duration" json:"connect_duration,omitempty" toml:"connect_duration" yaml:"connect_duration,omitempty"`
	CrawlDuration   null.String      `boil:"crawl_duration" json:"crawl_duration,omitempty" toml:"crawl_duration" yaml:"crawl_duration,omitempty"`
	MultiAddressIds types.Int64Array `boil:"multi_address_ids" json:"multi_address_ids,omitempty" toml:"multi_address_ids" yaml:"multi_address_ids,omitempty"`
	IsExposed       null.Bool        `boil:"is_exposed" json:"is_exposed,omitempty" toml:"is_exposed" yaml:"is_exposed,omitempty"`

	R *visitR `boil:"-" json:"-" toml:"-" yaml:"-"`
	L visitL  `boil:"-" json:"-" toml:"-" yaml:"-"`
}

Visit is an object representing the database table.

func FindVisit

func FindVisit(ctx context.Context, exec boil.ContextExecutor, iD int, visitStartedAt time.Time, selectCols ...string) (*Visit, error)

FindVisit retrieves a single record by ID with an executor. If selectCols is empty Find will return all columns.

func (*Visit) Delete

func (o *Visit) Delete(ctx context.Context, exec boil.ContextExecutor) (int64, error)

Delete deletes a single Visit record with an executor. Delete will match against the primary key column to find the record to delete.

func (*Visit) Insert

func (o *Visit) Insert(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) error

Insert a single record using an executor. See boil.Columns.InsertColumnSet documentation to understand column list inference for inserts.

func (*Visit) Reload

func (o *Visit) Reload(ctx context.Context, exec boil.ContextExecutor) error

Reload refetches the object from the database using the primary keys with an executor.

func (*Visit) Update

func (o *Visit) Update(ctx context.Context, exec boil.ContextExecutor, columns boil.Columns) (int64, error)

Update uses an executor to update the Visit. See boil.Columns.UpdateColumnSet documentation to understand column list inference for updates. Update does not automatically update the record in case of default values. Use .Reload() to refresh the records.

func (*Visit) Upsert

func (o *Visit) Upsert(ctx context.Context, exec boil.ContextExecutor, updateOnConflict bool, conflictColumns []string, updateColumns, insertColumns boil.Columns) error

Upsert attempts an insert using an executor, and does an update or ignore on conflict. See boil.Columns documentation for how to properly use updateColumns and insertColumns.

type VisitHook

type VisitHook func(context.Context, boil.ContextExecutor, *Visit) error

VisitHook is the signature for custom Visit hook methods

type VisitSlice

type VisitSlice []*Visit

VisitSlice is an alias for a slice of pointers to Visit. This should almost always be used instead of []Visit.

func (VisitSlice) DeleteAll

func (o VisitSlice) DeleteAll(ctx context.Context, exec boil.ContextExecutor) (int64, error)

DeleteAll deletes all rows in the slice, using an executor.

func (*VisitSlice) ReloadAll

func (o *VisitSlice) ReloadAll(ctx context.Context, exec boil.ContextExecutor) error

ReloadAll refetches every row with matching primary key column values and overwrites the original object slice with the newly updated slice.

func (VisitSlice) UpdateAll

func (o VisitSlice) UpdateAll(ctx context.Context, exec boil.ContextExecutor, cols M) (int64, error)

UpdateAll updates all rows with the specified column values, using an executor.

Jump to

Keyboard shortcuts

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