services

Documentation

Index

• type Finalizer
• type FinalizerWrap
  • func (c FinalizerWrap) Finalize(s string)
• type Persistence
  • func NewPersistence(remoteLocationPrefix string, logger *zap.Logger) *Persistence
  • func (p *Persistence) Finalize(filename string)
• type Switcher
  • func NewSwitcher(path string, flushSize int, bufferSize int, finalizer Finalizer, ...) (*Switcher, error)
  • func (s *Switcher) Close() error
  • func (s *Switcher) Count() uint64
  • func (s *Switcher) Insert(event *sdk.Event)
• type Writer
  • func NewWriter(filename string, logger *zap.Logger) (*Writer, error)
  • func (s *Writer) Close() error
  • func (s *Writer) Filename() string
  • func (s *Writer) Insert(event *sdk.Event) error

Types

type Finalizer

type Finalizer interface {
	Finalize(string)
}

type FinalizerWrap

type FinalizerWrap func(string)

func (FinalizerWrap) Finalize

func (c FinalizerWrap) Finalize(s string)

type Persistence

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

func NewPersistence

func NewPersistence(
	remoteLocationPrefix string,
	logger *zap.Logger,
) *Persistence

func (*Persistence) Finalize

func (p *Persistence) Finalize(filename string)

type Switcher

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

func NewSwitcher

func NewSwitcher(
	path string,
	flushSize int,
	bufferSize int,
	finalizer Finalizer,
	logger *zap.Logger,
) (*Switcher, error)

func (*Switcher) Close

func (s *Switcher) Close() error

func (*Switcher) Count

func (s *Switcher) Count() uint64

func (*Switcher) Insert

func (s *Switcher) Insert(event *sdk.Event)

type Writer

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

func NewWriter

func NewWriter(
	filename string,
	logger *zap.Logger,
) (*Writer, error)

func (*Writer) Close

func (s *Writer) Close() error

func (*Writer) Filename

func (s *Writer) Filename() string

func (*Writer) Insert

func (s *Writer) Insert(event *sdk.Event) error