Skip to content

Commit

Permalink
Added workflow client tinkerbell#35
Browse files Browse the repository at this point in the history
  • Loading branch information
Cbkhare committed Jul 9, 2020
1 parent 32f7149 commit 51b3350
Showing 1 changed file with 13 additions and 0 deletions.
13 changes: 13 additions & 0 deletions packet/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,12 +19,16 @@ import (
type hardwareGetter interface {
}

type workflowGetter interface {
}

type Client struct {
http *http.Client
baseURL *url.URL
consumerToken string
authToken string
hardwareClient hardwareGetter
workflowClient workflowGetter
}

func NewClient(consumerToken, authToken string, baseURL *url.URL) (*Client, error) {
Expand All @@ -44,6 +48,7 @@ func NewClient(consumerToken, authToken string, baseURL *url.URL) (*Client, erro
}

var hg hardwareGetter
var wg workflowGetter
var err error
dataModelVersion := os.Getenv("DATA_MODEL_VERSION")
switch dataModelVersion {
Expand All @@ -52,6 +57,12 @@ func NewClient(consumerToken, authToken string, baseURL *url.URL) (*Client, erro
if err != nil {
return nil, errors.Wrap(err, "connect to tink")
}

wg, err = tinkClient.TinkerbellWorkflowClient()
if err != nil {
return nil, errors.Wrap(err, "connect to tink")
}

default:
facility := os.Getenv("FACILITY_CODE")
if facility == "" {
Expand All @@ -62,6 +73,7 @@ func NewClient(consumerToken, authToken string, baseURL *url.URL) (*Client, erro
if err != nil {
return nil, errors.Wrap(err, "connect to cacher")
}
wg = hg
}

return &Client{
Expand All @@ -70,6 +82,7 @@ func NewClient(consumerToken, authToken string, baseURL *url.URL) (*Client, erro
consumerToken: consumerToken,
authToken: authToken,
hardwareClient: hg,
workflowClient: wg,
}, nil
}

Expand Down

0 comments on commit 51b3350

Please sign in to comment.