index

Documentation

Index

• Variables
• type CallbackFn
• type Message
• type Value
• type Writer
  • func NewWriter(ctx context.Context, options WriterOptions) *Writer
  • func (s *Writer) Close() error
  • func (s *Writer) Write(value Message)
• type WriterOptions

Variables

var ErrUnsupportedIndexType = errors.New("unsupported index type")

Types

type CallbackFn

type CallbackFn func()

type Message

type Message struct {
	Scope       tsdb.Entry
	Value       Value
	LocalWriter tsdb.Writer
	BlockCloser io.Closer
	Cb          CallbackFn
}

type Value

type Value struct {
	TagFamilies []*modelv1.TagFamilyForWrite
	Timestamp   time.Time
}

type Writer

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

func NewWriter

func NewWriter(ctx context.Context, options WriterOptions) *Writer

func (*Writer) Close

func (s *Writer) Close() error

func (*Writer) Write

func (s *Writer) Write(value Message)

type WriterOptions

type WriterOptions struct {
	ShardNum          uint32
	Families          []*databasev1.TagFamilySpec
	IndexRules        []*databasev1.IndexRule
	DB                tsdb.Supplier
	EnableGlobalIndex bool
}