node

Documentation

Index

• type Config
  • func (e *Config) Validate() error
• type Record
  • func NewRecord(ctx context.Context, log logrus.FieldLogger, conf *Config, ...) (*Record, error)
  • func (r *Record) Start(ctx context.Context) error
  • func (r *Record) Stop(ctx context.Context) error
  • func (r *Record) Write(ctx context.Context, record *node.Record)
• type RecordExporter
  • func NewRecordExporter(log logrus.FieldLogger, p *persistence.Client) (*RecordExporter, error)
  • func (r RecordExporter) ExportItems(ctx context.Context, items []*node.Record) error
  • func (r RecordExporter) Shutdown(ctx context.Context) error

Types

type Config

type Config struct {
	MaxQueueSize       int           `yaml:"maxQueueSize" default:"51200"`
	BatchTimeout       time.Duration `yaml:"batchTimeout" default:"5s"`
	ExportTimeout      time.Duration `yaml:"exportTimeout" default:"30s"`
	MaxExportBatchSize int           `yaml:"maxExportBatchSize" default:"512"`
}

func (*Config) Validate

func (e *Config) Validate() error

type Record

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

func NewRecord

func NewRecord(ctx context.Context, log logrus.FieldLogger, conf *Config, p *persistence.Client) (*Record, error)

func (*Record) Start

func (r *Record) Start(ctx context.Context) error

func (*Record) Stop

func (r *Record) Stop(ctx context.Context) error

func (*Record) Write

func (r *Record) Write(ctx context.Context, record *node.Record)

type RecordExporter

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

func NewRecordExporter

func NewRecordExporter(log logrus.FieldLogger, p *persistence.Client) (*RecordExporter, error)

func (RecordExporter) ExportItems

func (r RecordExporter) ExportItems(ctx context.Context, items []*node.Record) error

func (RecordExporter) Shutdown

func (r RecordExporter) Shutdown(ctx context.Context) error