Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Cmp 

func Cmp(iv2Asset, ufsAsset *ufspb.Asset) bool

    Cmp does protobuf comparison between both inputs

    func Compare 

    func Compare(iv2Machine, ufsMachine *ufspb.Machine) bool

      Compare does protobuf comparison between both inputs

      func GetAllAssetInfo 

      func GetAllAssetInfo(ctx context.Context, client *datastore.Client) (map[string]*iv2pr2.AssetInfo, error)

        GetAllAssetInfo retrieves all the asset info data from inventory-V2

        func GetAllAssets 

        func GetAllAssets(ctx context.Context, client *datastore.Client) ([]*iv2pr.ChopsAsset, error)

          GetAllAssets retrieves all the asset data from inventory-V2

          func GetAssetToHostnameMap 

          func GetAssetToHostnameMap(ctx context.Context, client *bigquery.Client) (map[string]string, error)

            GetAssetToHostnameMap gets the asset tag to hostname mapping from assets_in_swarming BQ table

            func InitServer 

            func InitServer(srv *server.Server, opts Options)

              InitServer initializes a purger server.

              func SyncAssetInfoFromHaRT 

              func SyncAssetInfoFromHaRT(ctx context.Context) error

                SyncAssetInfoFromHaRT publishes the request for asset info to HaRT.

                The response for this request will be made to an endpoint on an RPC call. This function only checks for the assets that have Device info missing or the last update on the device was 48 hours ago.

                func SyncAssetsFromIV2 

                func SyncAssetsFromIV2(ctx context.Context) error

                  SyncAssetsFromIV2 updates assets table in UFS using data from IV2

                  func SyncMachinesFromAssets 

                  func SyncMachinesFromAssets(ctx context.Context) error

                    SyncMachinesFromAssets updates machines table from assets table

                    Checks all the DUT and Labstation assets and creates/updates machines if required.

                    func Use 

                    func Use(ctx context.Context, bqClient *bigquery.Client) context.Context

                      Use installs bigquery client to context.

                      func UseProject 

                      func UseProject(ctx context.Context, project string) context.Context

                        UseProject installs project name to context.

                        Types

                        type Options 

                        type Options struct {
	// CronInterval setups the user-specific cron interval for data dumping
	CronInterval time.Duration
}

                          Options is the dumper server configuration.

                          Source Files

                          View all