writer

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Record2Rows 

func Record2Rows(dst []influx.Row, rec *record.Record) []influx.Row

func RetryExecute added in v1.4.1 

func RetryExecute(timeout time.Duration, fn func() error, assert func(error) bool) error

Types

type Authorizer 

type Authorizer interface {
	Authenticate(username, password, database string) error
}

type MetaClient added in v1.4.1 

type MetaClient interface {
	Database(name string) (*meta.DatabaseInfo, error)
	CreateShardGroup(db, rp string, tm time.Time, version uint32, eng config.EngineType) (*meta.ShardGroupInfo, error)
	DBPtView(db string) (meta.DBPtInfos, error)
	UpdateSchema(db string, rp string, mst string, schema []*proto.FieldSchema) error
	GetAliveShards(db string, sgi *meta.ShardGroupInfo, isRead bool) []int
	Measurement(db string, rpName string, mstName string) (*meta.MeasurementInfo, error)
	SimpleCreateMeasurement(db, rp, mst string, engineType config.EngineType) (*meta.MeasurementInfo, error)
}

type MetaManager added in v1.4.1 

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

func NewMetaManager added in v1.4.1 

func NewMetaManager() *MetaManager

func (*MetaManager) CheckDBRP added in v1.4.1 

func (m *MetaManager) CheckDBRP() error

func (*MetaManager) CreateMeasurement added in v1.4.1 

func (m *MetaManager) CreateMeasurement(name string, engineType config.EngineType) (*meta.MeasurementInfo, error)

func (*MetaManager) CreateShardGroupIfNeeded added in v1.4.1 

func (m *MetaManager) CreateShardGroupIfNeeded(times []int64) error

func (*MetaManager) GetShardKeyAndGroupInfo added in v1.5.0 

func (m *MetaManager) GetShardKeyAndGroupInfo(sameMst bool, ts int64) (*meta.ShardKeyInfo, *meta.ShardGroupInfo, []int)

func (*MetaManager) Init added in v1.4.1 

func (m *MetaManager) Init(mc MetaClient, db, rp string)

func (*MetaManager) Reset added in v1.4.1 

func (m *MetaManager) Reset()

func (*MetaManager) ResetDatabaseInfo added in v1.5.0 

func (m *MetaManager) ResetDatabaseInfo() error

func (*MetaManager) ResetMeasurementInfos added in v1.5.0 

func (m *MetaManager) ResetMeasurementInfos(mst string) error

func (*MetaManager) Shards added in v1.5.0 

func (m *MetaManager) Shards() map[uint64]*meta.ShardInfo

func (*MetaManager) UpdateSchemaIfNeeded added in v1.4.1 

func (m *MetaManager) UpdateSchemaIfNeeded(rec *record.Record, mst *meta.MeasurementInfo, originName string) error

type MstRecord added in v1.4.1 

type MstRecord struct {
	Mst string
	Rec record.Record
}

type PointWriter 

type PointWriter interface {
	RetryWritePointRows(database string, retentionPolicy string, rows []influx.Row) error
}

type RecordDecoder added in v1.4.1 

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

func NewRecordDecoder added in v1.4.1 

func NewRecordDecoder() (*RecordDecoder, func())

func (*RecordDecoder) Decode added in v1.4.1 

func (d *RecordDecoder) Decode(blocks []*pb.Record) ([]*MstRecord, []error)

func (*RecordDecoder) Instance added in v1.4.1 

func (d *RecordDecoder) Instance() *RecordDecoder

func (*RecordDecoder) MemSize added in v1.4.1 

func (d *RecordDecoder) MemSize() int

func (*RecordDecoder) Reset added in v1.4.1 

func (d *RecordDecoder) Reset()

type RecordMapper added in v1.4.1 

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

func NewRecordMapper added in v1.4.1 

func NewRecordMapper() *RecordMapper

func (*RecordMapper) MapRecord added in v1.4.1 

func (m *RecordMapper) MapRecord(id uint64, mst string, indexKey []byte, fields *record.Record, rowIdx int)

func (*RecordMapper) Reset added in v1.4.1 

func (m *RecordMapper) Reset()

func (*RecordMapper) Walk added in v1.4.1 

func (m *RecordMapper) Walk(call func(id uint64, group *shelf.BlobGroup))

type RecordStore added in v1.5.0 

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

func (*RecordStore) WriteBlobs added in v1.5.0 

func (s *RecordStore) WriteBlobs(db, rp string, pt uint32, shard uint64, blobGroup *shelf.BlobGroup, nodeID uint64, timeout time.Duration) error

type RecordWriteAuthorizer 

type RecordWriteAuthorizer struct {
	Client          *metaclient.Client
	WriteAuthorizer *auth.WriteAuthorizer
}

func (*RecordWriteAuthorizer) Authenticate 

func (a *RecordWriteAuthorizer) Authenticate(username, password, database string) error

type RecordWriter added in v1.4.1 

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

func NewRecordWriter added in v1.4.1 

func NewRecordWriter(mc MetaClient, timeout time.Duration) *RecordWriter

func (*RecordWriter) ApplyTimeRangeLimit added in v1.4.1 

func (w *RecordWriter) ApplyTimeRangeLimit(limit []toml.Duration)

func (*RecordWriter) Close added in v1.4.1 

func (w *RecordWriter) Close()

func (*RecordWriter) MapRecord added in v1.4.1 

func (w *RecordWriter) MapRecord(ctx *WriteContext, mst string, rec *record.Record)

func (*RecordWriter) RetryWriteRecords added in v1.4.1 

func (w *RecordWriter) RetryWriteRecords(db, rp string, recs []*MstRecord) error

func (*RecordWriter) SetStorage added in v1.4.1 

func (w *RecordWriter) SetStorage(store Storage)

func (*RecordWriter) WithLogger added in v1.4.1 

func (w *RecordWriter) WithLogger(lg *logger.Logger)

type Service 

type Service struct {
	pb.UnimplementedWriteServiceServer
	// contains filtered or unexported fields
}

func NewService 

func NewService(c config.RecordWriteConfig) (*Service, error)

func (*Service) Close 

func (s *Service) Close() error

func (*Service) Err 

func (s *Service) Err() <-chan error

func (*Service) Open 

func (s *Service) Open() error

func (*Service) Ping 

func (s *Service) Ping(_ context.Context, _ *pb.PingRequest) (*pb.PingResponse, error)

func (*Service) SetRecordWriter added in v1.4.1 

func (s *Service) SetRecordWriter(writer *RecordWriter)

func (*Service) WithAuthorizer 

func (s *Service) WithAuthorizer(a Authorizer)

func (*Service) WithLogger 

func (s *Service) WithLogger(logger *logger.Logger)

func (*Service) WithWriter 

func (s *Service) WithWriter(writer PointWriter)

func (*Service) Write 

func (s *Service) Write(_ context.Context, req *pb.WriteRequest) (*pb.WriteResponse, error)

type Storage added in v1.4.1 

type Storage interface {
	WriteBlobs(db, rp string, pt uint32, shard uint64, blobs *shelf.BlobGroup, nodeID uint64, timeout time.Duration) error
}

func NewRecordStore added in v1.5.0 

func NewRecordStore(mc meta2.MetaClient) Storage

type WriteContext added in v1.4.1 

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

func NewWriteContext added in v1.4.1 

func NewWriteContext(mc MetaClient, db, rp string) (*WriteContext, func())

func (WriteContext) Err added in v1.5.0 

func (w WriteContext) Err() *WriteError

func (WriteContext) Meta added in v1.5.0 

func (w WriteContext) Meta() *MetaManager

type WriteError added in v1.4.1 

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

func (*WriteError) AddDropRowError added in v1.4.1 

func (e *WriteError) AddDropRowError(err error)

func (*WriteError) Assert added in v1.4.1 

func (e *WriteError) Assert(err error, dropped int) error

func (*WriteError) Clean added in v1.4.1 

func (e *WriteError) Clean()

func (*WriteError) Error added in v1.4.1 

func (e *WriteError) Error() error

func (*WriteError) PartialErr added in v1.5.0 

func (e *WriteError) PartialErr() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.