Go SDK: Migrate from V1 to V2

1
var bearerToken = ""
2
3
func GetSkyflowBearerToken() (string, error) {
4
    filePath := "<file_path>"
5
    if saUtil.IsExpired(bearerToken) {
6
        newToken, err := saUtil.GenerateBearerToken(filePath)
7
        if err != nil {
8
            return "", err
9
        }
10
        bearerToken = newToken.AccessToken
11
        return bearerToken, nil
12
    }
13
    return bearerToken, nil
14
}

1
// Option 1: API key (recommended)
2
skyflowCredentials := common.Credentials{ApiKey: "<YOUR_API_KEY>"}
3
4
// Option 2: Environment variable — set SKYFLOW_CREDENTIALS in your environment
5
6
// Option 3: Credentials file
7
skyflowCredentials := common.Credentials{Path: "<YOUR_CREDENTIALS_FILE_PATH>"}
8
9
// Option 4: Stringified JSON
10
skyflowCredentials := common.Credentials{CredentialsString: "<YOUR_CREDENTIALS_STRING>"}
11
12
// Option 5: Bearer token
13
skyflowCredentials := common.Credentials{Token: "<BEARER_TOKEN>"}

1
configuration := common.Configuration{
2
    VaultID:       "<vault_id>",
3
    VaultURL:      "<vault_url>",
4
    TokenProvider: GetToken,
5
}
6
skyflowClient := Skyflow.Init(configuration)

1
creds := common.Credentials{Path: "<YOUR_CREDENTIALS_FILE_PATH>"}
2
vaultConfig := common.VaultConfig{
3
    VaultId:     "<VAULT_ID>",
4
    ClusterId:   "<CLUSTER_ID>",
5
    Env:         common.DEV,
6
    Credentials: creds,
7
}
8
skyflowClient, err := client.NewSkyflow(
9
    client.WithVaults(vaultConfig),
10
    client.WithCredentials(common.Credentials{}),
11
    client.WithLogLevel(logger.DEBUG),
12
)

1
var records = make(map[string]interface{})
2
var record = make(map[string]interface{})
3
record["table"] = "<your_table_name>"
4
fields := map[string]interface{}{"<field_name>": "<field_value>"}
5
record["fields"] = fields
6
records["records"] = []interface{}{record}
7
8
options := common.InsertOptions{
9
    Tokens:          true,
10
    ContinueOnError: true,
11
}
12
res, err := skyflowClient.Insert(records, options)

1
service, err := skyflowClient.Vault("<VAULT_ID>")
2
if err != nil {
3
    fmt.Println(err)
4
    return
5
}
6
values := []map[string]interface{}{
7
    {"<COLUMN_NAME>": "<COLUMN_VALUE>"},
8
}
9
insert, err := service.Insert(ctx, common.InsertRequest{
10
    Table:  "<TABLE_NAME>",
11
    Values: values,
12
}, common.InsertOptions{
13
    ContinueOnError: false,
14
    ReturnTokens:    true,
15
})
16
fmt.Println(insert)

1
options := common.InsertOptions{
2
    Tokens:          true,
3
    Upsert:          upsertArray,
4
    ContinueOnError: true,
5
}

1
options := common.InsertOptions{
2
    ContinueOnError: false,
3
    ReturnTokens:    true,
4
    TokenMode:       common.DISABLE,
5
    Upsert:          "<UPSERT_COLUMN>",
6
}