client

Documentation

Index

• type Request
  • func NewRequest(ctx context.Context, log logr.Logger, session *http.Client, baseURI *url.URL, ...) *Request
  • func (r *Request) DecodeResponseInto(message interface{}) *Request
  • func (r *Request) Do() (*YugawareResponse, error)
  • func (r *Request) Get() *Request
  • func (r *Request) Path(path string) *Request
  • func (r *Request) Post() *Request
  • func (r *Request) RequestBody(message interface{}) *Request
• type TLSOptions
• type YugawareClient
  • func New(ctx context.Context, log logr.Logger, hostname string) *YugawareClient
  • func (c *YugawareClient) ConfigureKubernetesProvider(request *yugaware.ConfigureKubernetesProviderRequest) (*yugaware.ConfigureKubernetesProviderResponse, error)
  • func (c *YugawareClient) Connect() (*YugawareClient, error)
  • func (c *YugawareClient) CustomerCount() (*yugaware.CustomerCountResponse, error)
  • func (c *YugawareClient) CustomerUUID() strfmt.UUID
  • func (c *YugawareClient) Login(request *yugaware.LoginRequest) (*yugaware.LoginResponse, error)
  • func (c *YugawareClient) Logout() error
  • func (c *YugawareClient) RegisterYugaware(request *yugaware.RegisterYugawareRequest) (*yugaware.RegisterYugawareResponse, error)
  • func (c *YugawareClient) Session() *http.Client
  • func (c *YugawareClient) TLSOptions(opts *TLSOptions) *YugawareClient
  • func (c *YugawareClient) TimeoutSeconds(timeout int) *YugawareClient
• type YugawareResponse

Types

type Request

type Request struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewRequest

func NewRequest(ctx context.Context, log logr.Logger, session *http.Client, baseURI *url.URL, authToken string, csrfToken string) *Request

func (*Request) DecodeResponseInto

func (r *Request) DecodeResponseInto(message interface{}) *Request

func (*Request) Do

func (r *Request) Do() (*YugawareResponse, error)

func (*Request) Get

func (r *Request) Get() *Request

func (*Request) Path

func (r *Request) Path(path string) *Request

func (*Request) Post

func (r *Request) Post() *Request

func (*Request) RequestBody

func (r *Request) RequestBody(message interface{}) *Request

type TLSOptions

type TLSOptions struct {
	SkipHostVerification bool
	CaCertPath           string
	CertPath             string
	KeyPath              string
}

type YugawareClient

type YugawareClient struct {
	Ctx context.Context

	Log logr.Logger

	PlatformAPIs *swaggerclient.YugabytePlatformAPIs
	SwaggerAuth  runtime.ClientAuthInfoWriter
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, log logr.Logger, hostname string) *YugawareClient

func (*YugawareClient) ConfigureKubernetesProvider

func (c *YugawareClient) ConfigureKubernetesProvider(request *yugaware.ConfigureKubernetesProviderRequest) (*yugaware.ConfigureKubernetesProviderResponse, error)

func (*YugawareClient) Connect

func (c *YugawareClient) Connect() (*YugawareClient, error)

func (*YugawareClient) CustomerCount

func (c *YugawareClient) CustomerCount() (*yugaware.CustomerCountResponse, error)

func (*YugawareClient) CustomerUUID

func (c *YugawareClient) CustomerUUID() strfmt.UUID

func (*YugawareClient) Login

func (c *YugawareClient) Login(request *yugaware.LoginRequest) (*yugaware.LoginResponse, error)

func (*YugawareClient) Logout

func (c *YugawareClient) Logout() error

func (*YugawareClient) RegisterYugaware

func (c *YugawareClient) RegisterYugaware(request *yugaware.RegisterYugawareRequest) (*yugaware.RegisterYugawareResponse, error)

func (*YugawareClient) Session

func (c *YugawareClient) Session() *http.Client

func (*YugawareClient) TLSOptions

func (c *YugawareClient) TLSOptions(opts *TLSOptions) *YugawareClient

func (*YugawareClient) TimeoutSeconds

func (c *YugawareClient) TimeoutSeconds(timeout int) *YugawareClient

type YugawareResponse

type YugawareResponse struct {
	Response *http.Response
	Body     []byte
}