schemaregistry

Documentation

Index

• func GetConnectionURL(registry *kapi.SchemaRegistry) string
• type Check
• type Client
  • func (cc *Client) GetSchemaRegistryHealth() (*Response, error)
  • func (cc *Client) IsSchemaRegistryHealthy(response *Response) (bool, error)
• type Config
• type KubeDBClientBuilder
  • func NewKubeDBClientBuilder(kc client.Client, dbSchema *kapi.SchemaRegistry) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) GetSchemaRegistryClient() (*Client, error)
  • func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithPath(path string) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithPod(podName string) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder
• type Response
• type ResponseBody

Functions

func GetConnectionURL

func GetConnectionURL(registry *kapi.SchemaRegistry) string

Types

type Check

type Check struct {
	Name   string                 `json:"name"`
	Status string                 `json:"status"`
	Data   map[string]interface{} `json:"data,omitempty"`
}

type Client

type Client struct {
	*resty.Client
	Config *Config
}

func (*Client) GetSchemaRegistryHealth

func (cc *Client) GetSchemaRegistryHealth() (*Response, error)

func (*Client) IsSchemaRegistryHealthy

func (cc *Client) IsSchemaRegistryHealthy(response *Response) (bool, error)

IsSchemaRegistryHealthy parse health response in json from server and return overall status of the server

type Config

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

type KubeDBClientBuilder

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

func NewKubeDBClientBuilder

func NewKubeDBClientBuilder(kc client.Client, dbSchema *kapi.SchemaRegistry) *KubeDBClientBuilder

func (*KubeDBClientBuilder) GetSchemaRegistryClient

func (o *KubeDBClientBuilder) GetSchemaRegistryClient() (*Client, error)

func (*KubeDBClientBuilder) WithContext

func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithPath

func (o *KubeDBClientBuilder) WithPath(path string) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithPod

func (o *KubeDBClientBuilder) WithPod(podName string) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithURL

func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder

type Response

type Response struct {
	Code   int
	Header http.Header
	Body   io.ReadCloser
}

type ResponseBody

type ResponseBody struct {
	Status string  `json:"status"`
	Checks []Check `json:"checks"`
}