coordinator

package
Version: v0.0.0-...-0ae59ff Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2020 License: MIT Imports: 35 Imported by: 0

Documentation

Overview

Package coordinator contains abstractions for writing points, executing statements, and accessing meta data.

Index

Constants

View Source
const (
	// DefaultWriteTimeout is the default timeout for a complete write to succeed.
	DefaultWriteTimeout = 10 * time.Second

	DefaultDialTimeout = 1 * time.Second

	DefaultPoolMaxIdleTimeout = 60 * time.Second
	DefaultShardReaderTimeout = 600 * time.Second

	// DefaultMaxConcurrentQueries is the maximum number of running queries.
	// A value of zero will make the maximum query limit unlimited.
	DefaultMaxConcurrentQueries = 0

	DefaultPoolMaxIdleStreams = 100
	DefaultPoolMaxConnections = 200

	// DefaultMaxSelectPointN is the maximum number of points a SELECT can process.
	// A value of zero will make the maximum point count unlimited.
	DefaultMaxSelectPointN = 0

	// DefaultMaxSelectSeriesN is the maximum number of series a SELECT can run.
	// A value of zero will make the maximum series count unlimited.
	DefaultMaxSelectSeriesN = 0

	DefaultMetaService = "127.0.0.1:2347"
)
View Source
const MaxMessageSize = 1024 * 1024 * 1024 // 1GB

MaxMessageSize defines how large a message can be before we reject it

View Source
const MuxHeader = 2

MuxHeader is the header byte used in the TCP mux.

Variables

View Source
var (
	// ErrTimeout is returned when a write times out.
	ErrTimeout = errors.New("timeout")

	// ErrPartialWrite is returned when a write partially succeeds but does
	// not meet the requested consistency level.
	ErrPartialWrite = errors.New("partial write")

	// ErrWriteFailed is returned when no writes succeeded.
	ErrWriteFailed = errors.New("write failed")
)

Functions

func DatabaseShards

func DatabaseShards(c interface {
	Database(name string) *meta.DatabaseInfo
}, db string) ([]meta.ShardInfo, error)

func DecodeLV

func DecodeLV(r io.Reader, v encoding.BinaryUnmarshaler) error

DecodeLV reads the length-value record from r and unmarshals it into v.

func DecodeTLV

func DecodeTLV(r io.Reader, v encoding.BinaryUnmarshaler) (typ byte, err error)

DecodeTLV reads the type-length-value record from r and unmarshals it into v.

func EncodeLV

func EncodeLV(w io.Writer, v encoding.BinaryMarshaler) error

EncodeLV encodes v to a binary format and writes the length-value record to w.

func EncodeTLV

func EncodeTLV(w io.Writer, typ byte, v encoding.BinaryMarshaler) error

EncodeTLV encodes v to a binary format and writes the record-length-value record to w.

func GetShardInfoByIds

func GetShardInfoByIds(MetaClient interface {
	ShardOwner(id uint64) (string, string, *meta.ShardGroupInfo)
}, ids []uint64) ([]meta.ShardInfo, error)

func IsRetryable

func IsRetryable(err error) bool

func NewBoundedPool

func NewBoundedPool(initialCap, maxCap int, timeout time.Duration, factory Factory) (pool.Pool, error)

NewBoundedPool returns a new pool based on buffered channels with an initial capacity, maximum capacity and timeout to wait for a connection from the pool. Factory is used when initial capacity is greater than zero to fill the pool. A zero initialCap doesn't fill the Pool until a new Get() is called. During a Get(), If there is no new connection available in the pool and total connections is less than the max, a new connection will be created via the Factory() method. Othewise, the call will block until a connection is available or the timeout is reached.

func ReadLV

func ReadLV(r io.Reader) ([]byte, error)

ReadLV reads the length-value from a TLV record.

func ReadTLV

func ReadTLV(r io.Reader) (byte, []byte, error)

ReadTLV reads a type-length-value record from r.

func ReadType

func ReadType(r io.Reader) (byte, error)

ReadType reads the type from a TLV record.

func RequestAndParseResponse

func RequestAndParseResponse(url string, data interface{}, resp interface{}) error

func WriteLV

func WriteLV(w io.Writer, buf []byte) error

WriteLV writes the length-value in a TLV record to w.

func WriteTLV

func WriteTLV(w io.Writer, typ byte, buf []byte) error

WriteTLV writes a type-length-value record to w.

func WriteType

func WriteType(w io.Writer, typ byte) error

WriteType writes the type in a TLV record to w.

Types

type ClusterExecutor

type ClusterExecutor struct {
	TSDBStore
	Node       *influxdb.Node
	MetaClient interface {
		DataNodes() ([]meta.NodeInfo, error)
		DataNode(nodeId uint64) (*meta.NodeInfo, error)
		ShardOwner(id uint64) (string, string, *meta.ShardGroupInfo)
		Database(name string) *meta.DatabaseInfo
	}

	// TaskManager holds the StatementExecutor that handles task-related commands.
	TaskManager query.StatementExecutor

	RemoteNodeExecutor RemoteNodeExecutor
	Logger             *zap.Logger
}

func NewClusterExecutor

func NewClusterExecutor(n *influxdb.Node, s TSDBStore, m MetaClient, Config Config) *ClusterExecutor

func (*ClusterExecutor) CreateIterator

func (me *ClusterExecutor) CreateIterator(ctx context.Context, m *influxql.Measurement, opt query.IteratorOptions, shards []meta.ShardInfo) (query.Iterator, error)

func (*ClusterExecutor) DeleteDatabase

func (me *ClusterExecutor) DeleteDatabase(database string) error

func (*ClusterExecutor) DeleteMeasurement

func (me *ClusterExecutor) DeleteMeasurement(database, name string) error

func (*ClusterExecutor) DeleteSeries

func (me *ClusterExecutor) DeleteSeries(database string, sources []influxql.Source, cond influxql.Expr) error

func (*ClusterExecutor) ExecuteStatement

func (me *ClusterExecutor) ExecuteStatement(stmt influxql.Statement, ctx *query.ExecutionContext) error

func (*ClusterExecutor) FieldDimensions

func (me *ClusterExecutor) FieldDimensions(m *influxql.Measurement, shards []meta.ShardInfo) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)

func (*ClusterExecutor) IteratorCost

func (*ClusterExecutor) MapType

func (me *ClusterExecutor) MapType(m *influxql.Measurement, field string, shards []meta.ShardInfo) influxql.DataType

func (*ClusterExecutor) MeasurementNames

func (me *ClusterExecutor) MeasurementNames(auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error)

func (*ClusterExecutor) SeriesCardinality

func (me *ClusterExecutor) SeriesCardinality(database string) (int64, error)

func (*ClusterExecutor) TagKeys

func (me *ClusterExecutor) TagKeys(auth query.Authorizer, ids []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)

func (*ClusterExecutor) TagValues

func (me *ClusterExecutor) TagValues(auth query.Authorizer, ids []uint64, cond influxql.Expr) ([]tsdb.TagValues, error)

func (*ClusterExecutor) WithLogger

func (me *ClusterExecutor) WithLogger(log *zap.Logger)

type ClusterMetaClient

type ClusterMetaClient struct {
	NodeID uint64

	Logger *zap.Logger
	// contains filtered or unexported fields
}

func NewMetaClient

func NewMetaClient(mc *meta.Config, cc Config, nodeID uint64) *ClusterMetaClient

func (*ClusterMetaClient) AcquireLease

func (me *ClusterMetaClient) AcquireLease(name string) (*meta.Lease, error)

func (*ClusterMetaClient) AddShardOwner

func (me *ClusterMetaClient) AddShardOwner(shardID, nodeID uint64) error

func (*ClusterMetaClient) AdminUserExists

func (me *ClusterMetaClient) AdminUserExists() bool

func (*ClusterMetaClient) Authenticate

func (me *ClusterMetaClient) Authenticate(username, password string) (meta.User, error)

func (*ClusterMetaClient) ClusterID

func (me *ClusterMetaClient) ClusterID() uint64

func (*ClusterMetaClient) CreateContinuousQuery

func (me *ClusterMetaClient) CreateContinuousQuery(database, name, query string) error

func (*ClusterMetaClient) CreateDataNode

func (me *ClusterMetaClient) CreateDataNode(httpAddr, tcpAddr string) (*meta.NodeInfo, error)

func (*ClusterMetaClient) CreateDatabase

func (me *ClusterMetaClient) CreateDatabase(name string) (*meta.DatabaseInfo, error)

func (*ClusterMetaClient) CreateDatabaseWithRetentionPolicy

func (me *ClusterMetaClient) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)

func (*ClusterMetaClient) CreateRetentionPolicy

func (me *ClusterMetaClient) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error)

func (*ClusterMetaClient) CreateShardGroup

func (me *ClusterMetaClient) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)

func (*ClusterMetaClient) CreateSubscription

func (me *ClusterMetaClient) CreateSubscription(database, rp, name, mode string, destinations []string) error

func (*ClusterMetaClient) CreateUser

func (me *ClusterMetaClient) CreateUser(name, password string, admin bool) (meta.User, error)

func (*ClusterMetaClient) DataNode

func (me *ClusterMetaClient) DataNode(id uint64) (*meta.NodeInfo, error)

func (*ClusterMetaClient) DataNodeByTCPHost

func (me *ClusterMetaClient) DataNodeByTCPHost(addr string) (*meta.NodeInfo, error)

func (*ClusterMetaClient) DataNodes

func (me *ClusterMetaClient) DataNodes() ([]meta.NodeInfo, error)

func (*ClusterMetaClient) Database

func (me *ClusterMetaClient) Database(name string) *meta.DatabaseInfo

func (*ClusterMetaClient) Databases

func (me *ClusterMetaClient) Databases() []meta.DatabaseInfo

func (*ClusterMetaClient) DeleteDataNode

func (me *ClusterMetaClient) DeleteDataNode(id uint64) error

func (*ClusterMetaClient) DeleteShardGroup

func (me *ClusterMetaClient) DeleteShardGroup(database, policy string, id uint64) error

func (*ClusterMetaClient) DropContinuousQuery

func (me *ClusterMetaClient) DropContinuousQuery(database, name string) error

func (*ClusterMetaClient) DropDatabase

func (me *ClusterMetaClient) DropDatabase(name string) error

func (*ClusterMetaClient) DropRetentionPolicy

func (me *ClusterMetaClient) DropRetentionPolicy(database, name string) error

func (*ClusterMetaClient) DropShard

func (me *ClusterMetaClient) DropShard(id uint64) error

func (*ClusterMetaClient) DropSubscription

func (me *ClusterMetaClient) DropSubscription(database, rp, name string) error

func (*ClusterMetaClient) DropUser

func (me *ClusterMetaClient) DropUser(name string) error

func (*ClusterMetaClient) MarshalBinary

func (me *ClusterMetaClient) MarshalBinary() ([]byte, error)

func (*ClusterMetaClient) Open

func (me *ClusterMetaClient) Open() error

func (*ClusterMetaClient) PrecreateShardGroups

func (me *ClusterMetaClient) PrecreateShardGroups(from, to time.Time) error

func (*ClusterMetaClient) PruneShardGroups

func (me *ClusterMetaClient) PruneShardGroups() error

func (*ClusterMetaClient) RemoveShardOwner

func (me *ClusterMetaClient) RemoveShardOwner(shardID, nodeID uint64) error

func (*ClusterMetaClient) RetentionPolicy

func (me *ClusterMetaClient) RetentionPolicy(database, name string) (*meta.RetentionPolicyInfo, error)

func (*ClusterMetaClient) RunSyncLoop

func (me *ClusterMetaClient) RunSyncLoop()

func (*ClusterMetaClient) SetAdminPrivilege

func (me *ClusterMetaClient) SetAdminPrivilege(username string, admin bool) error

func (*ClusterMetaClient) SetPrivilege

func (me *ClusterMetaClient) SetPrivilege(username, database string, p influxql.Privilege) error

func (*ClusterMetaClient) ShardGroupsByTimeRange

func (me *ClusterMetaClient) ShardGroupsByTimeRange(database, policy string, min, max time.Time) ([]meta.ShardGroupInfo, error)

func (*ClusterMetaClient) ShardIDs

func (me *ClusterMetaClient) ShardIDs() []uint64

func (*ClusterMetaClient) ShardOwner

func (me *ClusterMetaClient) ShardOwner(id uint64) (string, string, *meta.ShardGroupInfo)

func (*ClusterMetaClient) TruncateShardGroups

func (me *ClusterMetaClient) TruncateShardGroups(t time.Time) error

func (*ClusterMetaClient) UpdateRetentionPolicy

func (me *ClusterMetaClient) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error

func (*ClusterMetaClient) UpdateUser

func (me *ClusterMetaClient) UpdateUser(name, password string) error

func (*ClusterMetaClient) User

func (me *ClusterMetaClient) User(name string) (meta.User, error)

func (*ClusterMetaClient) UserCount

func (me *ClusterMetaClient) UserCount() int

func (*ClusterMetaClient) UserPrivilege

func (me *ClusterMetaClient) UserPrivilege(username, database string) (*influxql.Privilege, error)

func (*ClusterMetaClient) UserPrivileges

func (me *ClusterMetaClient) UserPrivileges(username string) (map[string]influxql.Privilege, error)

func (*ClusterMetaClient) Users

func (me *ClusterMetaClient) Users() []meta.UserInfo

func (*ClusterMetaClient) WaitForDataChanged

func (me *ClusterMetaClient) WaitForDataChanged() chan struct{}

func (*ClusterMetaClient) WithLogger

func (me *ClusterMetaClient) WithLogger(log *zap.Logger)

type ClusterShardMapper

type ClusterShardMapper struct {
	MetaClient interface {
		ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
	}
	Node            *influxdb.Node
	ClusterExecutor interface {
		IteratorCost(m *influxql.Measurement, opt query.IteratorOptions, shards []meta.ShardInfo) (query.IteratorCost, error)
		MapType(m *influxql.Measurement, field string, shards []meta.ShardInfo) influxql.DataType
		CreateIterator(ctx context.Context, m *influxql.Measurement, opt query.IteratorOptions, shards []meta.ShardInfo) (query.Iterator, error)
		FieldDimensions(m *influxql.Measurement, shards []meta.ShardInfo) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)
	}
}

ClusterShardMapper implements a ShardMapper for local shards.

func (*ClusterShardMapper) MapShards

MapShards maps the sources to the appropriate shards into an IteratorCreator.

type ClusterShardMapping

type ClusterShardMapping struct {
	ClusterExecutor interface {
		IteratorCost(m *influxql.Measurement, opt query.IteratorOptions, shards []meta.ShardInfo) (query.IteratorCost, error)
		MapType(m *influxql.Measurement, field string, shards []meta.ShardInfo) influxql.DataType
		CreateIterator(ctx context.Context, m *influxql.Measurement, opt query.IteratorOptions, shards []meta.ShardInfo) (query.Iterator, error)
		FieldDimensions(m *influxql.Measurement, shards []meta.ShardInfo) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)
	}
	MetaClient interface {
		ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
	}
	Node *influxdb.Node

	// MinTime is the minimum time that this shard mapper will allow.
	// Any attempt to use a time before this one will automatically result in using
	// this time instead.
	MinTime time.Time

	// MaxTime is the maximum time that this shard mapper will allow.
	// Any attempt to use a time after this one will automatically result in using
	// this time instead.
	MaxTime time.Time
	// contains filtered or unexported fields
}

ShardMapper maps data sources to a list of shard information.

func (*ClusterShardMapping) Close

func (a *ClusterShardMapping) Close() error

Close clears out the list of mapped shards.

func (*ClusterShardMapping) CreateIterator

func (*ClusterShardMapping) FieldDimensions

func (a *ClusterShardMapping) FieldDimensions(m *influxql.Measurement) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)

func (*ClusterShardMapping) IteratorCost

func (*ClusterShardMapping) MapType

type Config

type Config struct {
	DailTimeout               toml.Duration `toml:"dial-timeout"`
	PoolMaxIdleTimeout        toml.Duration `toml:"pool-max-idle-time"`
	PoolMaxIdleStreams        int           `toml:"pool-max-idle-streams"`
	PoolMaxConnections        int           `toml:"pool-max-connections"`
	ShardReaderTimeout        toml.Duration `toml:"shard-reader-timeout"`
	ClusterTracing            bool          `toml:"cluster-tracing"`
	WriteTimeout              toml.Duration `toml:"write-timeout"`
	MaxConcurrentQueries      int           `toml:"max-concurrent-queries"`
	QueryTimeout              toml.Duration `toml:"query-timeout"`
	LogQueriesAfter           toml.Duration `toml:"log-queries-after"`
	MaxSelectPointN           int           `toml:"max-select-point"`
	MaxSelectSeriesN          int           `toml:"max-select-series"`
	MaxSelectBucketsN         int           `toml:"max-select-buckets"`
	MetaServices              []string      `toml:"meta-services"`
	PingMetaServiceIntervalMs int64         `toml:"ping-meta-service-interval"`
}

Config represents the configuration for the coordinator service.

func NewConfig

func NewConfig() Config

NewConfig returns an instance of Config with defaults.

func (Config) Diagnostics

func (c Config) Diagnostics() (*diagnostics.Diagnostics, error)

Diagnostics returns a diagnostics representation of a subset of the Config.

type CreateIteratorRequest

type CreateIteratorRequest struct {
	SpanContex  *tracing.SpanContext
	ShardIDs    []uint64
	Opt         query.IteratorOptions
	Measurement influxql.Measurement
}

CreateIteratorRequest represents a request to create a remote iterator.

func (*CreateIteratorRequest) MarshalBinary

func (r *CreateIteratorRequest) MarshalBinary() ([]byte, error)

MarshalBinary encodes r to a binary format.

func (*CreateIteratorRequest) UnmarshalBinary

func (r *CreateIteratorRequest) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes data into r.

type CreateIteratorResponse

type CreateIteratorResponse struct {
	DataType influxql.DataType
	SeriesN  int
	Err      error
}

CreateIteratorResponse represents a response from remote iterator creation.

func (*CreateIteratorResponse) MarshalBinary

func (r *CreateIteratorResponse) MarshalBinary() ([]byte, error)

MarshalBinary encodes r to a binary format.

func (*CreateIteratorResponse) UnmarshalBinary

func (r *CreateIteratorResponse) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes data into r.

type DeleteDatabaseRequest

type DeleteDatabaseRequest struct {
	Database string
}

func (*DeleteDatabaseRequest) MarshalBinary

func (r *DeleteDatabaseRequest) MarshalBinary() ([]byte, error)

func (*DeleteDatabaseRequest) UnmarshalBinary

func (r *DeleteDatabaseRequest) UnmarshalBinary(b []byte) error

type DeleteDatabaseResponse

type DeleteDatabaseResponse struct {
	Err string
}

func (*DeleteDatabaseResponse) MarshalBinary

func (r *DeleteDatabaseResponse) MarshalBinary() ([]byte, error)

func (*DeleteDatabaseResponse) UnmarshalBinary

func (r *DeleteDatabaseResponse) UnmarshalBinary(b []byte) error

type DeleteMeasurementRequest

type DeleteMeasurementRequest struct {
	Database string
	Name     string
}

func (*DeleteMeasurementRequest) MarshalBinary

func (r *DeleteMeasurementRequest) MarshalBinary() ([]byte, error)

func (*DeleteMeasurementRequest) UnmarshalBinary

func (r *DeleteMeasurementRequest) UnmarshalBinary(b []byte) error

type DeleteMeasurementResponse

type DeleteMeasurementResponse struct {
	Err string
}

func (*DeleteMeasurementResponse) MarshalBinary

func (r *DeleteMeasurementResponse) MarshalBinary() ([]byte, error)

func (*DeleteMeasurementResponse) UnmarshalBinary

func (r *DeleteMeasurementResponse) UnmarshalBinary(b []byte) error

type DeleteSeriesRequest

type DeleteSeriesRequest struct {
	Database string
	Sources  influxql.Sources
	Cond     influxql.Expr
}

func (*DeleteSeriesRequest) MarshalBinary

func (r *DeleteSeriesRequest) MarshalBinary() ([]byte, error)

func (*DeleteSeriesRequest) UnmarshalBinary

func (r *DeleteSeriesRequest) UnmarshalBinary(b []byte) error

type DeleteSeriesRequestProto

type DeleteSeriesRequestProto struct {
	Database string
	Sources  []byte
	Cond     string
}

type DeleteSeriesResponse

type DeleteSeriesResponse struct {
	Err string
}

func (*DeleteSeriesResponse) MarshalBinary

func (r *DeleteSeriesResponse) MarshalBinary() ([]byte, error)

func (*DeleteSeriesResponse) UnmarshalBinary

func (r *DeleteSeriesResponse) UnmarshalBinary(b []byte) error

type ExecuteStatementRequest

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

ExecuteStatementRequest represents the a request to execute a statement on a node.

func (*ExecuteStatementRequest) Database

func (r *ExecuteStatementRequest) Database() string

Database returns the database name.

func (*ExecuteStatementRequest) MarshalBinary

func (r *ExecuteStatementRequest) MarshalBinary() ([]byte, error)

MarshalBinary encodes the object to a binary format.

func (*ExecuteStatementRequest) SetDatabase

func (r *ExecuteStatementRequest) SetDatabase(database string)

SetDatabase sets the database name.

func (*ExecuteStatementRequest) SetStatement

func (r *ExecuteStatementRequest) SetStatement(statement string)

SetStatement sets the InfluxQL statement.

func (*ExecuteStatementRequest) Statement

func (r *ExecuteStatementRequest) Statement() string

Statement returns the InfluxQL statement.

func (*ExecuteStatementRequest) UnmarshalBinary

func (r *ExecuteStatementRequest) UnmarshalBinary(buf []byte) error

UnmarshalBinary populates ExecuteStatementRequest from a binary format.

type ExecuteStatementResponse

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

ExecuteStatementResponse represents the response returned from a remote ExecuteStatementRequest call.

func (*ExecuteStatementResponse) Code

func (w *ExecuteStatementResponse) Code() int

Code returns the response code.

func (*ExecuteStatementResponse) MarshalBinary

func (w *ExecuteStatementResponse) MarshalBinary() ([]byte, error)

MarshalBinary encodes the object to a binary format.

func (*ExecuteStatementResponse) Message

func (w *ExecuteStatementResponse) Message() string

Message returns the repsonse message.

func (*ExecuteStatementResponse) SetCode

func (w *ExecuteStatementResponse) SetCode(code int)

SetCode sets the Code

func (*ExecuteStatementResponse) SetMessage

func (w *ExecuteStatementResponse) SetMessage(message string)

SetMessage sets the Message

func (*ExecuteStatementResponse) UnmarshalBinary

func (w *ExecuteStatementResponse) UnmarshalBinary(buf []byte) error

UnmarshalBinary populates ExecuteStatementResponse from a binary format.

type Factory

type Factory func() (net.Conn, error)

Factory is a function to create new connections.

type FieldDimensionsRequest

type FieldDimensionsRequest struct {
	ShardIDs []uint64
	Sources  influxql.Sources
}

FieldDimensionsRequest represents a request to retrieve unique fields & dimensions.

func (*FieldDimensionsRequest) MarshalBinary

func (r *FieldDimensionsRequest) MarshalBinary() ([]byte, error)

MarshalBinary encodes r to a binary format.

func (*FieldDimensionsRequest) UnmarshalBinary

func (r *FieldDimensionsRequest) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes data into r.

type FieldDimensionsResponse

type FieldDimensionsResponse struct {
	Fields     map[string]influxql.DataType
	Dimensions map[string]struct{}
	Err        error
}

FieldDimensionsResponse represents a response from remote iterator creation.

func (*FieldDimensionsResponse) MarshalBinary

func (r *FieldDimensionsResponse) MarshalBinary() ([]byte, error)

MarshalBinary encodes r to a binary format.

func (*FieldDimensionsResponse) UnmarshalBinary

func (r *FieldDimensionsResponse) UnmarshalBinary(data []byte) error

UnmarshalBinary decodes data into r.

type InternalServiceStatistics

type InternalServiceStatistics struct {
	WriteShardReq       int64
	WriteShardPointsReq int64
	WriteShardFail      int64

	CreateIteratorReq  int64
	CreateIteratorFail int64

	FieldDimensionsReq  int64
	FieldDimensionsFail int64

	TagKeysReq  int64
	TagKeysFail int64

	TagValuesReq  int64
	TagValuesFail int64

	MeasurementNamesReq  int64
	MeasurementNamesFail int64

	SeriesCardinalityReq  int64
	SeriesCardinalityFail int64

	IteratorCostReq  int64
	IteratorCostFail int64

	MapTypeReq  int64
	MapTypeFail int64
}

type IteartorCostRequestProto

type IteartorCostRequestProto struct {
	Sources  []byte
	Opt      []byte
	ShardIDs []uint64
}

type IteratorCostRequest

type IteratorCostRequest struct {
	Sources  influxql.Sources
	Opt      query.IteratorOptions
	ShardIDs []uint64
}

func (*IteratorCostRequest) MarshalBinary

func (r *IteratorCostRequest) MarshalBinary() ([]byte, error)

func (*IteratorCostRequest) UnmarshalBinary

func (r *IteratorCostRequest) UnmarshalBinary(b []byte) error

type IteratorCostResponse

type IteratorCostResponse struct {
	Cost query.IteratorCost
	Err  string
}

func (*IteratorCostResponse) MarshalBinary

func (r *IteratorCostResponse) MarshalBinary() ([]byte, error)

func (*IteratorCostResponse) UnmarshalBinary

func (r *IteratorCostResponse) UnmarshalBinary(b []byte) error

type LocalTSDBStore

type LocalTSDBStore struct {
	*tsdb.Store
}

LocalTSDBStore embeds a tsdb.Store and implements IteratorCreator to satisfy the TSDBStore interface.

type MapTypeRequest

type MapTypeRequest struct {
	Sources  influxql.Sources
	Field    string
	ShardIDs []uint64
}

func (*MapTypeRequest) MarshalBinary

func (r *MapTypeRequest) MarshalBinary() ([]byte, error)

func (*MapTypeRequest) UnmarshalBinary

func (r *MapTypeRequest) UnmarshalBinary(b []byte) error

type MapTypeRequestProto

type MapTypeRequestProto struct {
	Sources  []byte
	Field    string
	ShardIDs []uint64
}

type MapTypeResponse

type MapTypeResponse struct {
	DataType influxql.DataType
	Err      string
}

func (*MapTypeResponse) MarshalBinary

func (r *MapTypeResponse) MarshalBinary() ([]byte, error)

func (*MapTypeResponse) UnmarshalBinary

func (r *MapTypeResponse) UnmarshalBinary(b []byte) error

type Measurement

type Measurement struct {
	Database        string
	RetentionPolicy string
	Name            string
	Regex           string
	IsTarget        bool
	// This field indicates that the measurement should read be read from the
	// specified system iterator.
	SystemIterator string
}

type MeasurementNamesProto

type MeasurementNamesProto struct {
	Database string
	Cond     string
}

type MeasurementNamesRequest

type MeasurementNamesRequest struct {
	Database string
	Cond     influxql.Expr
}

func (*MeasurementNamesRequest) MarshalBinary

func (r *MeasurementNamesRequest) MarshalBinary() ([]byte, error)

func (*MeasurementNamesRequest) UnmarshalBinary

func (r *MeasurementNamesRequest) UnmarshalBinary(b []byte) error

type MeasurementNamesResponse

type MeasurementNamesResponse struct {
	Names [][]byte
	Err   string
}

func (*MeasurementNamesResponse) MarshalBinary

func (r *MeasurementNamesResponse) MarshalBinary() ([]byte, error)

func (*MeasurementNamesResponse) UnmarshalBinary

func (r *MeasurementNamesResponse) UnmarshalBinary(b []byte) error

type MetaClient

type MetaClient interface {
	CreateContinuousQuery(database, name, query string) error
	CreateDatabase(name string) (*meta.DatabaseInfo, error)
	CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)
	CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error)
	CreateSubscription(database, rp, name, mode string, destinations []string) error
	CreateUser(name, password string, admin bool) (meta.User, error)
	Database(name string) *meta.DatabaseInfo
	Databases() []meta.DatabaseInfo
	DataNodes() ([]meta.NodeInfo, error)
	DataNode(nodeId uint64) (*meta.NodeInfo, error)
	DropShard(id uint64) error
	DropContinuousQuery(database, name string) error
	DropDatabase(name string) error
	DropRetentionPolicy(database, name string) error
	DropSubscription(database, rp, name string) error
	DropUser(name string) error
	RetentionPolicy(database, name string) (rpi *meta.RetentionPolicyInfo, err error)
	SetAdminPrivilege(username string, admin bool) error
	SetPrivilege(username, database string, p influxql.Privilege) error
	ShardGroupsByTimeRange(database, policy string, min, max time.Time) (a []meta.ShardGroupInfo, err error)
	ShardOwner(id uint64) (string, string, *meta.ShardGroupInfo)
	TruncateShardGroups(t time.Time) error
	UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error
	UpdateUser(name, password string) error
	UserPrivilege(username, database string) (*influxql.Privilege, error)
	UserPrivileges(username string) (map[string]influxql.Privilege, error)
	Users() []meta.UserInfo
}

MetaClient is an interface for accessing meta data.

type MetaClientImpl

type MetaClientImpl struct {
	Addrs []string
}

func (*MetaClientImpl) AcquireLease

func (me *MetaClientImpl) AcquireLease(NodeID uint64, name string) (*meta.Lease, error)

func (*MetaClientImpl) AddShardOwner

func (me *MetaClientImpl) AddShardOwner(shardID, nodeID uint64) error

func (*MetaClientImpl) Authenticate

func (me *MetaClientImpl) Authenticate(username, password string) (meta.User, error)

func (*MetaClientImpl) ClusterID

func (me *MetaClientImpl) ClusterID() uint64

func (*MetaClientImpl) CreateContinuousQuery

func (me *MetaClientImpl) CreateContinuousQuery(database, name, query string) error

func (*MetaClientImpl) CreateDataNode

func (me *MetaClientImpl) CreateDataNode(httpAddr, tcpAddr string) (*meta.NodeInfo, error)

func (*MetaClientImpl) CreateDatabase

func (me *MetaClientImpl) CreateDatabase(name string) (*meta.DatabaseInfo, error)

func (*MetaClientImpl) CreateDatabaseWithRetentionPolicy

func (me *MetaClientImpl) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)

func (*MetaClientImpl) CreateRetentionPolicy

func (me *MetaClientImpl) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec, makeDefault bool) (*meta.RetentionPolicyInfo, error)

func (*MetaClientImpl) CreateShardGroup

func (me *MetaClientImpl) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)

func (*MetaClientImpl) CreateSubscription

func (me *MetaClientImpl) CreateSubscription(database, rp, name, mode string, destinations []string) error

func (*MetaClientImpl) CreateUser

func (me *MetaClientImpl) CreateUser(name, password string, admin bool) (meta.User, error)

func (*MetaClientImpl) Data

func (me *MetaClientImpl) Data() (*imeta.Data, error)

func (*MetaClientImpl) DeleteDataNode

func (me *MetaClientImpl) DeleteDataNode(id uint64) error

func (*MetaClientImpl) DeleteShardGroup

func (me *MetaClientImpl) DeleteShardGroup(database, policy string, id uint64) error

func (*MetaClientImpl) DropContinuousQuery

func (me *MetaClientImpl) DropContinuousQuery(database, name string) error

func (*MetaClientImpl) DropDatabase

func (me *MetaClientImpl) DropDatabase(name string) error

func (*MetaClientImpl) DropRetentionPolicy

func (me *MetaClientImpl) DropRetentionPolicy(database, name string) error

func (*MetaClientImpl) DropShard

func (me *MetaClientImpl) DropShard(id uint64) error

func (*MetaClientImpl) DropSubscription

func (me *MetaClientImpl) DropSubscription(database, rp, name string) error

func (*MetaClientImpl) DropUser

func (me *MetaClientImpl) DropUser(name string) error

func (*MetaClientImpl) Ping

func (me *MetaClientImpl) Ping() (uint64, error)

func (*MetaClientImpl) PrecreateShardGroups

func (me *MetaClientImpl) PrecreateShardGroups(from, to time.Time) error

func (*MetaClientImpl) PruneShardGroups

func (me *MetaClientImpl) PruneShardGroups() error

func (*MetaClientImpl) RemoveShardOwner

func (me *MetaClientImpl) RemoveShardOwner(shardID, nodeID uint64) error

func (*MetaClientImpl) SetAdminPrivilege

func (me *MetaClientImpl) SetAdminPrivilege(username string, admin bool) error

func (*MetaClientImpl) SetPrivilege

func (me *MetaClientImpl) SetPrivilege(username, database string, p influxql.Privilege) error

func (*MetaClientImpl) TruncateShardGroups

func (me *MetaClientImpl) TruncateShardGroups(t time.Time) error

func (*MetaClientImpl) UpdateRetentionPolicy

func (me *MetaClientImpl) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate, makeDefault bool) error

func (*MetaClientImpl) UpdateUser

func (me *MetaClientImpl) UpdateUser(name, password string) error

func (*MetaClientImpl) Url

func (me *MetaClientImpl) Url(path string) string

type Node2ShardIDs

type Node2ShardIDs map[uint64][]uint64

func NewNode2ShardIDs

func NewNode2ShardIDs(mc interface {
	DataNode(nodeId uint64) (*meta.NodeInfo, error)
},
	localNode *influxdb.Node,
	shards []meta.ShardInfo) Node2ShardIDs

func (Node2ShardIDs) Apply

func (me Node2ShardIDs) Apply(fn func(nodeId uint64, shardIDs []uint64))

type NodeDialer

type NodeDialer struct {
	MetaClient interface {
		DataNode(nodeId uint64) (*meta.NodeInfo, error)
	}
	Timeout time.Duration
}

NodeDialer dials connections to a given node.

func (*NodeDialer) DialNode

func (d *NodeDialer) DialNode(nodeID uint64) (net.Conn, error)

DialNode returns a connection to a node.

type NodeIds

type NodeIds []uint64

func NewNodeIdsByNodes

func NewNodeIdsByNodes(nodeInfos []meta.NodeInfo) NodeIds

func NewNodeIdsByShards

func NewNodeIdsByShards(Shards []meta.ShardInfo) NodeIds

TODO:取个达意的名字

func (NodeIds) Apply

func (me NodeIds) Apply(fn func(nodeId uint64))

type PointsWriter

type PointsWriter struct {
	WriteTimeout time.Duration
	Logger       *zap.Logger

	Node *influxdb.Node

	HintedHandoff interface {
		WriteShard(shardID, ownerID uint64, points []models.Point) error
	}

	MetaClient interface {
		Database(name string) (di *meta.DatabaseInfo)
		RetentionPolicy(database, policy string) (*meta.RetentionPolicyInfo, error)
		CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)
	}

	TSDBStore interface {
		CreateShard(database, retentionPolicy string, shardID uint64, enabled bool) error
		WriteToShard(shardID uint64, points []models.Point) error
	}

	ShardWriter interface {
		WriteShard(shardID, ownerID uint64, points []models.Point) error
	}
	// contains filtered or unexported fields
}

PointsWriter handles writes across multiple local and remote data nodes.

func NewPointsWriter

func NewPointsWriter() *PointsWriter

NewPointsWriter returns a new instance of PointsWriter for a node.

func (*PointsWriter) AddWriteSubscriber

func (w *PointsWriter) AddWriteSubscriber(c chan<- *WritePointsRequest)

func (*PointsWriter) Close

func (w *PointsWriter) Close() error

Close closes the communication channel with the point writer.

func (*PointsWriter) MapShards

func (w *PointsWriter) MapShards(wp *WritePointsRequest) (*ShardMapping, error)

MapShards maps the points contained in wp to a ShardMapping. If a point maps to a shard group or shard that does not currently exist, it will be created before returning the mapping.

func (*PointsWriter) Open

func (w *PointsWriter) Open() error

Open opens the communication channel with the point writer.

func (*PointsWriter) Statistics

func (w *PointsWriter) Statistics(tags map[string]string) []models.Statistic

Statistics returns statistics for periodic monitoring.

func (*PointsWriter) WithLogger

func (w *PointsWriter) WithLogger(log *zap.Logger)

WithLogger sets the Logger on w.

func (*PointsWriter) WritePoints

func (w *PointsWriter) WritePoints(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, user meta.User, points []models.Point) error

WritePoints writes the data to the underlying storage. consitencyLevel and user are only used for clustered scenarios

func (*PointsWriter) WritePointsInto

WritePointsInto is a copy of WritePoints that uses a tsdb structure instead of a cluster structure for information. This is to avoid a circular dependency.

func (*PointsWriter) WritePointsPrivileged

func (w *PointsWriter) WritePointsPrivileged(database, retentionPolicy string, consistencyLevel models.ConsistencyLevel, points []models.Point) error

WritePointsPrivileged writes the data to the underlying storage, consitencyLevel is only used for clustered scenarios

type RemoteNodeExecutor

type RemoteNodeExecutor interface {
	TagKeys(nodeId uint64, ShardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)
	TagValues(nodeId uint64, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error)
	MeasurementNames(nodeId uint64, database string, cond influxql.Expr) ([][]byte, error)
	SeriesCardinality(nodeId uint64, database string) (int64, error)
	DeleteSeries(nodeId uint64, database string, sources []influxql.Source, condition influxql.Expr) error
	DeleteDatabase(nodeId uint64, database string) error
	DeleteMeasurement(nodeId uint64, database, name string) error
	FieldDimensions(nodeId uint64, m *influxql.Measurement, shardIds []uint64) (fields map[string]influxql.DataType, dimensions map[string]struct{}, err error)
	IteratorCost(nodeId uint64, m *influxql.Measurement, opt query.IteratorOptions, shardIds []uint64) (query.IteratorCost, error)
	MapType(nodeId uint64, m *influxql.Measurement, field string, shardIds []uint64) (influxql.DataType, error)
	CreateIterator(nodeId uint64, ctx context.Context, m *influxql.Measurement, opt query.IteratorOptions, shardIds []uint64) (query.Iterator, error)
	TaskManagerStatement(nodeId uint64, stmt influxql.Statement) (*query.Result, error)
}

type SeriesCardinalityRequest

type SeriesCardinalityRequest struct {
	Database string
}

func (*SeriesCardinalityRequest) MarshalBinary

func (r *SeriesCardinalityRequest) MarshalBinary() ([]byte, error)

func (*SeriesCardinalityRequest) UnmarshalBinary

func (r *SeriesCardinalityRequest) UnmarshalBinary(b []byte) error

type SeriesCardinalityResponse

type SeriesCardinalityResponse struct {
	N   int64
	Err string
}

func (*SeriesCardinalityResponse) MarshalBinary

func (r *SeriesCardinalityResponse) MarshalBinary() ([]byte, error)

func (*SeriesCardinalityResponse) UnmarshalBinary

func (r *SeriesCardinalityResponse) UnmarshalBinary(b []byte) error

type Service

type Service struct {
	Node *influxdb.Node

	Listener net.Listener

	MetaClient interface {
		ShardOwner(shardID uint64) (string, string, *meta.ShardGroupInfo)
	}

	TSDBStore   TSDBStore
	TaskManager *query.TaskManager

	Logger *zap.Logger
	// contains filtered or unexported fields
}

Service processes data received over raw TCP connections.

func NewService

func NewService(c Config) *Service

NewService returns a new instance of Service.

func (*Service) Close

func (s *Service) Close() error

Close shuts down the listener and waits for all connections to finish.

func (*Service) Open

func (s *Service) Open() error

Open opens the network listener and begins serving requests.

func (*Service) Statistics

func (w *Service) Statistics(tags map[string]string) []models.Statistic

func (*Service) WithLogger

func (s *Service) WithLogger(log *zap.Logger)

WithLogger sets the logger on the service.

type ShardMapping

type ShardMapping struct {
	Points  map[uint64][]models.Point  // The points associated with a shard ID
	Shards  map[uint64]*meta.ShardInfo // The shards that have been mapped, keyed by shard ID
	Dropped []models.Point             // Points that were dropped
	// contains filtered or unexported fields
}

ShardMapping contains a mapping of shards to points.

func NewShardMapping

func NewShardMapping(n int) *ShardMapping

NewShardMapping creates an empty ShardMapping.

func (*ShardMapping) MapPoint

func (s *ShardMapping) MapPoint(shardInfo *meta.ShardInfo, p models.Point)

MapPoint adds the point to the ShardMapping, associated with the given shardInfo.

type ShardWriter

type ShardWriter struct {
	MetaClient interface {
		DataNode(id uint64) (ni *meta.NodeInfo, err error)
		ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)
	}
	// contains filtered or unexported fields
}

ShardWriter writes a set of points to a shard.

func NewShardWriter

func NewShardWriter(timeout time.Duration, maxConnections int) *ShardWriter

NewShardWriter returns a new instance of ShardWriter.

func (*ShardWriter) Close

func (w *ShardWriter) Close() error

Close closes ShardWriter's pool

func (*ShardWriter) WriteShard

func (w *ShardWriter) WriteShard(shardID, ownerID uint64, points []models.Point) error

WriteShard writes time series points to a shard

type Source

type Source struct {
	Database        string
	RetentionPolicy string
}

Source contains the database and retention policy source for data.

type StringSlice

type StringSlice []string

func (StringSlice) Len

func (a StringSlice) Len() int

func (StringSlice) Less

func (a StringSlice) Less(i, j int) bool

func (StringSlice) Swap

func (a StringSlice) Swap(i, j int)

type TSDBStore

type TSDBStore interface {
	CreateShard(database, policy string, shardID uint64, enabled bool) error
	WriteToShard(shardID uint64, points []models.Point) error

	RestoreShard(id uint64, r io.Reader) error
	BackupShard(id uint64, since time.Time, w io.Writer) error

	DeleteDatabase(name string) error
	DeleteMeasurement(database, name string) error
	DeleteRetentionPolicy(database, name string) error
	DeleteSeries(database string, sources []influxql.Source, condition influxql.Expr) error
	DeleteShard(id uint64) error

	MeasurementNames(auth query.Authorizer, database string, cond influxql.Expr) ([][]byte, error)
	TagKeys(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagKeys, error)
	TagValues(auth query.Authorizer, shardIDs []uint64, cond influxql.Expr) ([]tsdb.TagValues, error)

	SeriesCardinality(database string) (int64, error)
	MeasurementsCardinality(database string) (int64, error)

	ShardGroup(ids []uint64) tsdb.ShardGroup
}

TSDBStore is an interface for accessing the time series data store.

type TagKeysProto

type TagKeysProto struct {
	ShardIDs []byte
	Cond     string
}

type TagKeysRequest

type TagKeysRequest struct {
	ShardIDs []uint64
	Cond     influxql.Expr
}

func (*TagKeysRequest) MarshalBinary

func (r *TagKeysRequest) MarshalBinary() ([]byte, error)

func (*TagKeysRequest) UnmarshalBinary

func (r *TagKeysRequest) UnmarshalBinary(b []byte) error

type TagKeysResponse

type TagKeysResponse struct {
	TagKeys []tsdb.TagKeys
	Err     string
}

func (*TagKeysResponse) MarshalBinary

func (r *TagKeysResponse) MarshalBinary() ([]byte, error)

func (*TagKeysResponse) UnmarshalBinary

func (r *TagKeysResponse) UnmarshalBinary(b []byte) error

type TagValuesRequest

type TagValuesRequest struct {
	TagKeysRequest
}

type TagValuesResponse

type TagValuesResponse struct {
	TagValues []tsdb.TagValues
	Err       string
}

func (*TagValuesResponse) MarshalBinary

func (r *TagValuesResponse) MarshalBinary() ([]byte, error)

func (*TagValuesResponse) UnmarshalBinary

func (r *TagValuesResponse) UnmarshalBinary(b []byte) error

type TaskManagerStatementRequest

type TaskManagerStatementRequest struct {
	ExecuteStatementRequest
}

type TaskManagerStatementRespProto

type TaskManagerStatementRespProto struct {
	Result []byte
	Err    string
}

type TaskManagerStatementResponse

type TaskManagerStatementResponse struct {
	Result query.Result
	Err    string
}

func (*TaskManagerStatementResponse) MarshalBinary

func (w *TaskManagerStatementResponse) MarshalBinary() ([]byte, error)

func (*TaskManagerStatementResponse) UnmarshalBinary

func (w *TaskManagerStatementResponse) UnmarshalBinary(buf []byte) error

type WritePointsRequest

type WritePointsRequest struct {
	Database        string
	RetentionPolicy string
	//ConsistencyLevel models.ConsistencyLevel
	Points []models.Point
}

WritePointsRequest represents a request to write point data to the cluster

func (*WritePointsRequest) AddPoint

func (w *WritePointsRequest) AddPoint(name string, value interface{}, timestamp time.Time, tags models.Tags)

AddPoint adds a point to the WritePointRequest with field key 'value'

type WriteShardRequest

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

WriteShardRequest represents the a request to write a slice of points to a shard

func (*WriteShardRequest) AddPoint

func (w *WriteShardRequest) AddPoint(name string, value interface{}, timestamp time.Time, tags models.Tags)

AddPoint adds a new time series point

func (*WriteShardRequest) AddPoints

func (w *WriteShardRequest) AddPoints(points []models.Point)

AddPoints adds a new time series point

func (*WriteShardRequest) Database

func (w *WriteShardRequest) Database() string

func (*WriteShardRequest) MarshalBinary

func (w *WriteShardRequest) MarshalBinary() ([]byte, error)

MarshalBinary encodes the object to a binary format.

func (*WriteShardRequest) Points

func (w *WriteShardRequest) Points() []models.Point

Points returns the time series Points

func (*WriteShardRequest) RetentionPolicy

func (w *WriteShardRequest) RetentionPolicy() string

func (*WriteShardRequest) SetDatabase

func (w *WriteShardRequest) SetDatabase(db string)

func (*WriteShardRequest) SetRetentionPolicy

func (w *WriteShardRequest) SetRetentionPolicy(rp string)

func (*WriteShardRequest) SetShardID

func (w *WriteShardRequest) SetShardID(id uint64)

SetShardID sets the ShardID

func (*WriteShardRequest) ShardID

func (w *WriteShardRequest) ShardID() uint64

ShardID gets the ShardID

func (*WriteShardRequest) UnmarshalBinary

func (w *WriteShardRequest) UnmarshalBinary(buf []byte) error

UnmarshalBinary populates WritePointRequest from a binary format.

type WriteShardResponse

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

WriteShardResponse represents the response returned from a remote WriteShardRequest call

func (*WriteShardResponse) Code

func (w *WriteShardResponse) Code() int

Code returns the Code

func (*WriteShardResponse) MarshalBinary

func (w *WriteShardResponse) MarshalBinary() ([]byte, error)

MarshalBinary encodes the object to a binary format.

func (*WriteShardResponse) Message

func (w *WriteShardResponse) Message() string

Message returns the Message

func (*WriteShardResponse) SetCode

func (w *WriteShardResponse) SetCode(code int)

SetCode sets the Code

func (*WriteShardResponse) SetMessage

func (w *WriteShardResponse) SetMessage(message string)

SetMessage sets the Message

func (*WriteShardResponse) UnmarshalBinary

func (w *WriteShardResponse) UnmarshalBinary(buf []byte) error

UnmarshalBinary populates WritePointRequest from a binary format.

type WriteStatistics

type WriteStatistics struct {
	WriteReq            int64
	PointWriteReq       int64
	PointWriteReqLocal  int64
	PointWriteReqRemote int64
	WriteOK             int64
	WriteDropped        int64
	WriteTimeout        int64
	WritePartial        int64
	WritePointReqHH     int64
	WriteErr            int64
	SubWriteOK          int64
	SubWriteDrop        int64
}

WriteStatistics keeps statistics related to the PointsWriter.

Directories

Path Synopsis
Package internal is a generated protocol buffer package.
Package internal is a generated protocol buffer package.

Jump to

Keyboard shortcuts

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