mirror of https://github.com/hashicorp/consul
Add license management functions to API client (#6268)
* Add license management functions to API client * Get rid of jsonapi struct tagspull/6274/head
parent
96be92f3b5
commit
5ce6bfa292
@ -0,0 +1,92 @@
|
|||||||
|
package api
|
||||||
|
|
||||||
|
import (
|
||||||
|
"io/ioutil"
|
||||||
|
"strings"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
type License struct {
|
||||||
|
// The unique identifier of the license
|
||||||
|
LicenseID string `json:"license_id"`
|
||||||
|
|
||||||
|
// The customer ID associated with the license
|
||||||
|
CustomerID string `json:"customer_id"`
|
||||||
|
|
||||||
|
// If set, an identifier that should be used to lock the license to a
|
||||||
|
// particular site, cluster, etc.
|
||||||
|
InstallationID string `json:"installation_id"`
|
||||||
|
|
||||||
|
// The time at which the license was issued
|
||||||
|
IssueTime time.Time `json:"issue_time"`
|
||||||
|
|
||||||
|
// The time at which the license starts being valid
|
||||||
|
StartTime time.Time `json:"start_time"`
|
||||||
|
|
||||||
|
// The time after which the license expires
|
||||||
|
ExpirationTime time.Time `json:"expiration_time"`
|
||||||
|
|
||||||
|
// The time at which the license ceases to function and can
|
||||||
|
// no longer be used in any capacity
|
||||||
|
TerminationTime time.Time `json:"termination_time"`
|
||||||
|
|
||||||
|
// The product the license is valid for
|
||||||
|
Product string `json:"product"`
|
||||||
|
|
||||||
|
// License Specific Flags
|
||||||
|
Flags map[string]interface{} `json:"flags"`
|
||||||
|
|
||||||
|
// List of features enabled by the license
|
||||||
|
Features []string `json:"features"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LicenseReply struct {
|
||||||
|
Valid bool
|
||||||
|
License *License
|
||||||
|
Warnings []string
|
||||||
|
}
|
||||||
|
|
||||||
|
func (op *Operator) LicenseGet(q *QueryOptions) (*LicenseReply, error) {
|
||||||
|
var reply LicenseReply
|
||||||
|
if _, err := op.c.query("/v1/operator/license", &reply, q); err != nil {
|
||||||
|
return nil, err
|
||||||
|
} else {
|
||||||
|
return &reply, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (op *Operator) LicenseGetSigned(q *QueryOptions) (string, error) {
|
||||||
|
r := op.c.newRequest("GET", "/v1/operator/license")
|
||||||
|
r.params.Set("signed", "1")
|
||||||
|
r.setQueryOptions(q)
|
||||||
|
_, resp, err := requireOK(op.c.doRequest(r))
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
defer resp.Body.Close()
|
||||||
|
|
||||||
|
data, err := ioutil.ReadAll(resp.Body)
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
return string(data), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (op *Operator) LicensePut(license string, opts *WriteOptions) (*LicenseReply, error) {
|
||||||
|
var reply LicenseReply
|
||||||
|
r := op.c.newRequest("PUT", "/v1/operator/license")
|
||||||
|
r.setWriteOptions(opts)
|
||||||
|
r.body = strings.NewReader(license)
|
||||||
|
_, resp, err := requireOK(op.c.doRequest(r))
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
defer resp.Body.Close()
|
||||||
|
|
||||||
|
if err := decodeBody(resp, &reply); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return &reply, nil
|
||||||
|
}
|
Loading…
Reference in new issue