db

Documentation

Index

• func DeferRollback(txn *sql.Tx)
• 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, ...) (models.IPAddressSlice, *string, *string, *int, error)
  • func (c *Client) UpsertMultiAddress(ctx context.Context, exec boil.ContextExecutor, maddr ma.Multiaddr) (*models.MultiAddress, 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.

Types

type Client

type Client struct {
	*sql.DB

	MMClient *maxmind.Client

	UdgerClient *udger.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, addrInfos map[string]*maxmind.AddrInfo) (models.IPAddressSlice, *string, *string, *int, error)

func (*Client) UpsertMultiAddress

func (c *Client) UpsertMultiAddress(ctx context.Context, exec boil.ContextExecutor, maddr ma.Multiaddr) (*models.MultiAddress, 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)