db

Documentation

Index

• func DeferRollback(txn *sql.Tx)
• func MapNetDirection(conn network.Conn) string
• type Client
  • func NewClient(c *cli.Context) (*Client, error)
  • func (c *Client) GetAuthorization(ctx context.Context, exec boil.ContextExecutor, apiKey string) (*models.Authorization, error)
  • func (c *Client) UpsertIPAddresses(ctx context.Context, exec boil.ContextExecutor, maddr ma.Multiaddr) (models.IPAddressSlice, *string, *string, *int, error)
  • func (c *Client) UpsertMultiAddresses(ctx context.Context, exec boil.ContextExecutor, maddrs []ma.Multiaddr) (models.MultiAddressSlice, error)
  • func (c *Client) UpsertMultiAddressesSet(ctx context.Context, exec boil.ContextExecutor, ...) (int, error)
  • func (c *Client) UpsertPeer(ctx context.Context, exec boil.ContextExecutor, pid peer.ID, ...) (*models.Peer, error)

Functions

func DeferRollback

func DeferRollback(txn *sql.Tx)

DeferRollback calls rollback on the given transaction and logs the potential error.

func MapNetDirection

func MapNetDirection(conn network.Conn) string

MapNetDirection maps the connection direction the corresponding database types.

Types

type Client

type Client struct {
	*sql.DB

	MMClient *maxmind.Client
}

func NewClient

func NewClient(c *cli.Context) (*Client, error)

func (*Client) GetAuthorization

func (c *Client) GetAuthorization(ctx context.Context, exec boil.ContextExecutor, apiKey string) (*models.Authorization, error)

func (*Client) UpsertIPAddresses

func (c *Client) UpsertIPAddresses(ctx context.Context, exec boil.ContextExecutor, maddr ma.Multiaddr) (models.IPAddressSlice, *string, *string, *int, error)

func (*Client) UpsertMultiAddresses

func (c *Client) UpsertMultiAddresses(ctx context.Context, exec boil.ContextExecutor, maddrs []ma.Multiaddr) (models.MultiAddressSlice, error)

func (*Client) UpsertMultiAddressesSet

func (c *Client) UpsertMultiAddressesSet(ctx context.Context, exec boil.ContextExecutor, dbMaddrs models.MultiAddressSlice) (int, error)

func (*Client) UpsertPeer

func (c *Client) UpsertPeer(ctx context.Context, exec boil.ContextExecutor, pid peer.ID, agentVersion *string, protocols []string) (*models.Peer, error)