write

Documentation

Overview

Package write provides service and its stuff

Index

• type Batch
  • func NewBatch(data string, retryDelay uint) *Batch
• type Service
  • func NewService(org string, bucket string, httpService http2.Service, options *write.Options) *Service
  • func (w *Service) EncodePoints(points ...*write.Point) (string, error)
  • func (w *Service) HandleWrite(ctx context.Context, batch *Batch) error
  • func (w *Service) WriteBatch(ctx context.Context, batch *Batch) *http2.Error
  • func (w *Service) WriteURL() (string, error)

Types

type Batch

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

func NewBatch

func NewBatch(data string, retryDelay uint) *Batch

type Service

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

func NewService

func NewService(org string, bucket string, httpService http2.Service, options *write.Options) *Service

func (*Service) EncodePoints

func (w *Service) EncodePoints(points ...*write.Point) (string, error)

func (*Service) HandleWrite

func (w *Service) HandleWrite(ctx context.Context, batch *Batch) error

func (*Service) WriteBatch

func (w *Service) WriteBatch(ctx context.Context, batch *Batch) *http2.Error

func (*Service) WriteURL

func (w *Service) WriteURL() (string, error)