Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + const InstanceNameHeaderKey + type ControllerClient interface + GetAllSchema func(namespace string) ([]metaCom.Table, error) + GetAssignment func(jobNamespace, instance string) (*models.IngestionAssignment, error) + GetAssignmentHash func(jobNamespace, instance string) (string, error) + GetNamespaces func() ([]string, error) + GetSchemaHash func(namespace string) (string, error) + type ControllerHTTPClient struct + func NewControllerHTTPClient(address string, timeoutSec time.Duration, headers http.Header) *ControllerHTTPClient + func (c *ControllerHTTPClient) ExtendEnumCases(tableName, columnName string, enumCases []string) (enumIDs []int, err error) + func (c *ControllerHTTPClient) FetchAllEnums(tableName string, columnName string) (enumDictReponse []string, err error) + func (c *ControllerHTTPClient) FetchAllSchemas() (tables []*metaCom.Table, err error) + func (c *ControllerHTTPClient) FetchSchema(tableName string) (table *metaCom.Table, err error) + func (c *ControllerHTTPClient) GetAllSchema(namespace string) (tables []metaCom.Table, err error) + func (c *ControllerHTTPClient) GetAssignment(jobNamespace, instance string) (assignment *models.IngestionAssignment, err error) + func (c *ControllerHTTPClient) GetAssignmentHash(jobNamespace, instance string) (hash string, err error) + func (c *ControllerHTTPClient) GetNamespaces() (namespaces []string, err error) + func (c *ControllerHTTPClient) GetSchemaHash(namespace string) (hash string, err error) + func (c *ControllerHTTPClient) SetNamespace(namespace string)
Go to main page