Skip to content

Commit

Permalink
oss-go-sdk: rewrite CredentialsProvider
Browse files Browse the repository at this point in the history
  • Loading branch information
mozillazg committed Aug 28, 2023
1 parent e572e2d commit 267c17c
Show file tree
Hide file tree
Showing 2 changed files with 33 additions and 22 deletions.
2 changes: 1 addition & 1 deletion examples/rrsa/oss-go-sdk/README.md
@@ -1,4 +1,4 @@
# golang-sdk
# oss-go-sdk

## Usage

Expand Down
53 changes: 32 additions & 21 deletions examples/rrsa/oss-go-sdk/main.go
Expand Up @@ -26,7 +26,7 @@ func testOSSSDK() {
panic(err)
}

provider := &OSSCredentialsProvider{
provider := &CredentialsProvider{
cred: cred,
}
client, err := oss.New("https://oss-cn-hangzhou.aliyuncs.com", "", "",
Expand Down Expand Up @@ -64,39 +64,50 @@ func newOidcCredential() (credentials.Credential, error) {
return oidcCredential, err
}

type OSSCredentialsProvider struct {
type Credentials struct {
AccessKeyId string
AccessKeySecret string
SecurityToken string
}

type CredentialsProvider struct {
cred credentials.Credential
}

func (p *OSSCredentialsProvider) GetAccessKeyID() string {
value, err := p.cred.GetAccessKeyId()
func (c *Credentials) GetAccessKeyID() string {
return c.AccessKeyId
}

func (c *Credentials) GetAccessKeySecret() string {
return c.AccessKeySecret
}

func (c *Credentials) GetSecurityToken() string {
return c.SecurityToken
}

func (p CredentialsProvider) GetCredentials() oss.Credentials {
id, err := p.cred.GetAccessKeyId()
if err != nil {
log.Printf("get access key id failed: %+v", err)
return ""
return &Credentials{}
}
return tea.StringValue(value)
}

func (p *OSSCredentialsProvider) GetAccessKeySecret() string {
value, err := p.cred.GetAccessKeySecret()
secret, err := p.cred.GetAccessKeySecret()
if err != nil {
log.Printf("get access key secret failed: %+v", err)
return ""
return &Credentials{}
}
return tea.StringValue(value)
}

func (p *OSSCredentialsProvider) GetSecurityToken() string {
value, err := p.cred.GetSecurityToken()
token, err := p.cred.GetSecurityToken()
if err != nil {
log.Printf("get access security token failed: %+v", err)
return ""
return &Credentials{}
}
return tea.StringValue(value)
}

func (p *OSSCredentialsProvider) GetCredentials() oss.Credentials {
return p
return &Credentials{
AccessKeyId: tea.StringValue(id),
AccessKeySecret: tea.StringValue(secret),
SecurityToken: tea.StringValue(token),
}
}

func main() {
Expand Down

0 comments on commit 267c17c

Please sign in to comment.