db

Documentation

Index

• type DBQuerier
  • func NewQuerier(conn genericConn) *DBQuerier
  • func (q *DBQuerier) GetSubscriptions(ctx context.Context, did string) ([]GetSubscriptionsRow, error)
  • func (q *DBQuerier) InvalidateToken(ctx context.Context, token string) (pgconn.CommandTag, error)
• type GetSubscriptionsRow
• type Querier

Types

type DBQuerier

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

func NewQuerier

func NewQuerier(conn genericConn) *DBQuerier

func (*DBQuerier) GetSubscriptions

func (q *DBQuerier) GetSubscriptions(ctx context.Context, did string) ([]GetSubscriptionsRow, error)

func (*DBQuerier) InvalidateToken

func (q *DBQuerier) InvalidateToken(ctx context.Context, token string) (pgconn.CommandTag, error)

type GetSubscriptionsRow

type GetSubscriptionsRow struct {
	Token   string `json:"token"`
	Posts   bool   `json:"posts"`
	Reposts bool   `json:"reposts"`
	Replies bool   `json:"replies"`
}

type Querier

type Querier interface {
	GetSubscriptions(ctx context.Context, did string) ([]GetSubscriptionsRow, error)

	InvalidateToken(ctx context.Context, token string) (pgconn.CommandTag, error)
}