http

Documentation

Index

• func GetAccessToken(retryClient *retryablehttp.Client, ...) (string, error)
• func NewWebbaiClient() api.Client
• func SendRequestWithToken(retryClient *retryablehttp.Client, url, token string, body []byte) (*http.Response, error)
• type WebbaiHttpClient
  • func (c *WebbaiHttpClient) SendChangeEvent(event *api.ChangeEvent) error
  • func (c *WebbaiHttpClient) SendK8sResources(list *api.ResourceList) error
  • func (c *WebbaiHttpClient) SendTrafficMetrics(request *prompb.WriteRequest) error

Functions

func GetAccessToken

func GetAccessToken(retryClient *retryablehttp.Client, tokenUrl, clientId, clientSecret, audience string) (string, error)

func NewWebbaiClient

func NewWebbaiClient() api.Client

func SendRequestWithToken

func SendRequestWithToken(retryClient *retryablehttp.Client, url, token string, body []byte) (*http.Response, error)

Types

type WebbaiHttpClient

type WebbaiHttpClient struct {
	ClientId     string
	ClientSecret string
	AuthUrl      string
	ChangeUrl    string
	ResourceUrl  string
	MetricsUrl   string
	// contains filtered or unexported fields
}

func (*WebbaiHttpClient) SendChangeEvent

func (c *WebbaiHttpClient) SendChangeEvent(event *api.ChangeEvent) error

func (*WebbaiHttpClient) SendK8sResources

func (c *WebbaiHttpClient) SendK8sResources(list *api.ResourceList) error

func (*WebbaiHttpClient) SendTrafficMetrics

func (c *WebbaiHttpClient) SendTrafficMetrics(request *prompb.WriteRequest) error