schemaless

package
v3.30.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	InfluxDBLineProtocol       = 1
	OpenTSDBTelnetLineProtocol = 2
	OpenTSDBJsonFormatProtocol = 3
)

Variables

View Source
var (
	ConnectTimeoutErr = errors.New("schemaless connect timeout")
)

Functions

func SetAutoReconnect

func SetAutoReconnect(reconnect bool) func(*Config)

func SetDb

func SetDb(db string) func(*Config)

func SetEnableCompression

func SetEnableCompression(enableCompression bool) func(*Config)

func SetErrorHandler

func SetErrorHandler(errorHandler func(error)) func(*Config)

func SetPassword

func SetPassword(password string) func(*Config)

func SetReadTimeout

func SetReadTimeout(readTimeout time.Duration) func(*Config)

func SetReconnectIntervalMs

func SetReconnectIntervalMs(reconnectIntervalMs int) func(*Config)

func SetReconnectRetryCount

func SetReconnectRetryCount(reconnectRetryCount int) func(*Config)

func SetUser

func SetUser(user string) func(*Config)

func SetWriteTimeout

func SetWriteTimeout(writeTimeout time.Duration) func(*Config)

Types

type Config

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

func NewConfig

func NewConfig(url string, chanLength uint, opts ...func(*Config)) *Config

type IndexedChan

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

type Schemaless

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

func NewSchemaless

func NewSchemaless(config *Config) (*Schemaless, error)

func (*Schemaless) Close

func (s *Schemaless) Close()

func (*Schemaless) Insert

func (s *Schemaless) Insert(lines string, protocol int, precision string, ttl int, reqID int64) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL