bqexport

Documentation

Overview

Package bqexport contains functionality related to exporting the authorization data from LUCI Auth Service to BigQuery (BQ).

Index

• func CronHandler(ctx context.Context) error
• func Run(ctx context.Context) error
• type Client
  • func NewClient(ctx context.Context) (*Client, error)
  • func (client *Client) Close() (reterr error)
  • func (client *Client) EnsureLatestViews(ctx context.Context) error
  • func (client *Client) InsertGroups(ctx context.Context, rows []*bqpb.GroupRow) error
  • func (client *Client) InsertRealms(ctx context.Context, rows []*bqpb.RealmRow) error

Functions

func CronHandler

func CronHandler(ctx context.Context) error

func Run

func Run(ctx context.Context) error

Run exports the authorization data from the latest AuthDB snapshot to BQ.

Types

type Client

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

Client provides methods to export authorization data to BQ.

func NewClient

func NewClient(ctx context.Context) (*Client, error)

func (*Client) Close

func (client *Client) Close() (reterr error)

Close releases resources held by the client.

func (*Client) EnsureLatestViews

func (client *Client) EnsureLatestViews(ctx context.Context) error

EnsureLatestViews ensures the views for the latest groups and latest realms have their metadata applied, including schema and query definition updates.

If a view's underlying table has its schema updated, be sure to update the metadata version to propagate it to the view as well.

func (*Client) InsertGroups

func (client *Client) InsertGroups(ctx context.Context, rows []*bqpb.GroupRow) error

InsertGroups inserts the given groups in BQ.

func (*Client) InsertRealms

func (client *Client) InsertRealms(ctx context.Context, rows []*bqpb.RealmRow) error

InsertRealms inserts the given realms in BQ.