rest

Documentation

Index

• Constants
• func IsStatusError(err error, code int) bool
• type Client
  • func NewClient(c *vim25.Client) *Client
  • func (c *Client) Do(ctx context.Context, req *http.Request, resBody interface{}) error
  • func (c *Client) Download(ctx context.Context, u *url.URL, param *soap.Download) (io.ReadCloser, int64, error)
  • func (c *Client) DownloadFile(ctx context.Context, file string, u *url.URL, param *soap.Download) error
  • func (c *Client) Login(ctx context.Context, user *url.Userinfo) error
  • func (c *Client) LoginByToken(ctx context.Context) error
  • func (c *Client) Logout(ctx context.Context) error
  • func (c *Client) MarshalJSON() ([]byte, error)
  • func (c *Client) Path() string
  • func (c *Client) Resource(path string) *Resource
  • func (c *Client) Session(ctx context.Context) (*Session, error)
  • func (c *Client) SessionID(id ...string) string
  • func (c *Client) UnmarshalJSON(b []byte) error
  • func (c *Client) Upload(ctx context.Context, f io.Reader, u *url.URL, param *soap.Upload) error
  • func (c *Client) Valid() bool
  • func (c *Client) WithHeader(ctx context.Context, headers http.Header) context.Context
  • func (c *Client) WithSigner(ctx context.Context, s Signer) context.Context
• type LocalizableMessage
  • func (m *LocalizableMessage) Error() string
• type RawResponse
• type Resource
  • func (r *Resource) Request(method string, body ...interface{}) *http.Request
  • func (r *Resource) String() string
  • func (r *Resource) WithAction(action string) *Resource
  • func (r *Resource) WithID(id string) *Resource
  • func (r *Resource) WithParam(name string, value string) *Resource
  • func (r *Resource) WithPathEncodedParam(name string, value string) *Resource
• type Session
• type Signer

Examples

• Client.LoginByToken

Constants

const (
	Path = "/rest"
)

Functions

func IsStatusError

func IsStatusError(err error, code int) bool

Types

type Client

type Client struct {
	*soap.Client
	// contains filtered or unexported fields
}

Client extends soap.Client to support JSON encoding, while inheriting security features, debug tracing and session persistence.

func NewClient

func NewClient(c *vim25.Client) *Client

NewClient creates a new Client instance.

func (*Client) Do

func (c *Client) Do(ctx context.Context, req *http.Request, resBody interface{}) error

Do sends the http.Request, decoding resBody if provided.

func (*Client) Download

func (c *Client) Download(ctx context.Context, u *url.URL, param *soap.Download) (io.ReadCloser, int64, error)

Download wraps soap.Client.Download, adding the REST authentication header

func (*Client) DownloadFile

func (c *Client) DownloadFile(ctx context.Context, file string, u *url.URL, param *soap.Download) error

DownloadFile wraps soap.Client.DownloadFile, adding the REST authentication header

func (*Client) Login

func (c *Client) Login(ctx context.Context, user *url.Userinfo) error

Login creates a new session via Basic Authentication with the given url.Userinfo.

func (*Client) LoginByToken

func (c *Client) LoginByToken(ctx context.Context) error

Example

package main

import (
	"context"
	"fmt"
	"net/url"

	_ "github.com/vmware/govmomi/lookup/simulator"
	"github.com/vmware/govmomi/simulator"
	"github.com/vmware/govmomi/sts"
	"github.com/vmware/govmomi/vapi/rest"
	"github.com/vmware/govmomi/vim25"

	_ "github.com/vmware/govmomi/sts/simulator"
)

func main() {
	simulator.Run(func(ctx context.Context, vc *vim25.Client) error {
		c, err := sts.NewClient(ctx, vc)
		if err != nil {
			return err
		}

		// Issue a bearer token
		req := sts.TokenRequest{
			Userinfo: url.UserPassword("Administrator@VSPHERE.LOCAL", "password"),
		}

		signer, err := c.Issue(ctx, req)
		if err != nil {
			return err
		}

		rc := rest.NewClient(vc)

		err = rc.LoginByToken(rc.WithSigner(ctx, signer))
		if err != nil {
			return err
		}

		session, err := rc.Session(ctx)
		if err != nil {
			return err
		}

		// Note: vcsim does not currently parse the token NameID for rest as it does for soap
		fmt.Println(session.User)

		return nil
	})
}

Output:

TODO

func (*Client) Logout

func (c *Client) Logout(ctx context.Context) error

Logout deletes the current session.

func (*Client) MarshalJSON

func (c *Client) MarshalJSON() ([]byte, error)

func (*Client) Path

func (c *Client) Path() string

Path returns rest.Path (see cache.Client)

func (*Client) Resource

func (c *Client) Resource(path string) *Resource

Resource helper for the given path.

func (*Client) Session

func (c *Client) Session(ctx context.Context) (*Session, error)

Session returns the user's current session. Nil is returned if the session is not authenticated.

func (*Client) SessionID

func (c *Client) SessionID(id ...string) string

SessionID is set by calling Login() or optionally with the given id param

func (*Client) UnmarshalJSON

func (c *Client) UnmarshalJSON(b []byte) error

func (*Client) Upload

func (c *Client) Upload(ctx context.Context, f io.Reader, u *url.URL, param *soap.Upload) error

Upload wraps soap.Client.Upload, adding the REST authentication header

func (*Client) Valid

func (c *Client) Valid() bool

Valid returns whether or not the client is valid and ready for use. This should be called after unmarshalling the client.

func (*Client) WithHeader

func (c *Client) WithHeader(
	ctx context.Context,
	headers http.Header) context.Context

WithHeader returns a new Context populated with the provided headers map. Calls to a VAPI REST client with this context will populate the HTTP headers map using the provided headers.

func (*Client) WithSigner

func (c *Client) WithSigner(ctx context.Context, s Signer) context.Context

type LocalizableMessage

type LocalizableMessage struct {
	Args           []string `json:"args,omitempty"`
	DefaultMessage string   `json:"default_message,omitempty"`
	ID             string   `json:"id,omitempty"`
}

LocalizableMessage represents a localizable error

func (*LocalizableMessage) Error

func (m *LocalizableMessage) Error() string

type RawResponse

type RawResponse struct {
	bytes.Buffer
}

RawResponse may be used with the Do method as the resBody argument in order to capture the raw response data.

type Resource

type Resource struct {
	// contains filtered or unexported fields
}

Resource wraps url.URL with helpers

func (*Resource) Request

func (r *Resource) Request(method string, body ...interface{}) *http.Request

Request returns a new http.Request for the given method. An optional body can be provided for POST and PATCH methods.

func (*Resource) String

func (r *Resource) String() string

func (*Resource) WithAction

func (r *Resource) WithAction(action string) *Resource

WithAction sets adds action to the URL.RawQuery

func (*Resource) WithID

func (r *Resource) WithID(id string) *Resource

WithID appends id to the URL.Path

func (*Resource) WithParam

func (r *Resource) WithParam(name string, value string) *Resource

WithParam adds one parameter on the URL.RawQuery

func (*Resource) WithPathEncodedParam

func (r *Resource) WithPathEncodedParam(name string, value string) *Resource

WithPathEncodedParam appends a parameter on the URL.RawQuery, For special cases where URL Path-style encoding is needed

type Session

type Session struct {
	User         string    `json:"user"`
	Created      time.Time `json:"created_time"`
	LastAccessed time.Time `json:"last_accessed_time"`
}

Session information

type Signer

type Signer interface {
	SignRequest(*http.Request) error
}