Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector interface {
// Insert inserts rows to ares
// returns number of rows inserted and error.
// updateModes are optional, if ignored for all columns, no need to set
// if set, then all columns needs to be set
Insert(tableName string, columnNames []string, rows []Row, updateModes ...memCom.ColumnUpdateMode) (int, error)
}
Connector is the connector interface for ares.
type ConnectorConfig ¶
type ConnectorConfig struct {
// Address is in the format of host:port
Address string `yaml:"address"`
// DeviceChoosingTimeout value is the request timeout in seconds for http calls
// if <= 0, will use default
Timeout int `yaml:"timeout"`
// SchemaRefreshInterval is the interval in seconds for the connector to
// fetch and refresh schema from ares
// if <= 0, will use default
SchemaRefreshInterval int `yaml:"schemaRefreshInterval"`
}
ConnectorConfig holds the configurations for ares Connector.
func (ConnectorConfig) NewConnector ¶
func (cfg ConnectorConfig) NewConnector(logger bark.Logger, metricScope tally.Scope) (Connector, error)
NewConnector returns a new ares Connector
Click to show internal directories.
Click to hide internal directories.