clients

Documentation

Index

• type ControllerClient
• type ControllerHTTPClient
  • func NewControllerHTTPClient(controllerHost string, controllerPort int, headers http.Header) *ControllerHTTPClient
  • func (c *ControllerHTTPClient) GetAllSchema(namespace string) (tables []common.Table, err error)
  • func (c *ControllerHTTPClient) GetSchemaHash(namespace string) (hash string, err error)

Types

type ControllerClient

type ControllerClient interface {
	GetSchemaHash(namespace string) (string, error)
	GetAllSchema(namespace string) ([]common.Table, error)
}

ControllerClient defines methods to communicate with ares-controller

type ControllerHTTPClient

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

ControllerHTTPClient implements ControllerClient over http

func NewControllerHTTPClient

func NewControllerHTTPClient(controllerHost string, controllerPort int, headers http.Header) *ControllerHTTPClient

NewControllerHTTPClient returns new ControllerHTTPClient

func (*ControllerHTTPClient) GetAllSchema

func (c *ControllerHTTPClient) GetAllSchema(namespace string) (tables []common.Table, err error)

func (*ControllerHTTPClient) GetSchemaHash

func (c *ControllerHTTPClient) GetSchemaHash(namespace string) (hash string, err error)