anelace

Documentation

Index

• Constants
• type Anelace
  • func NewAnelace() *Anelace
  • func NewAnelaceFromArgv(argv []string) (anl *Anelace)
  • func NewAnelaceWithWriters(stderr io.Writer, stdout io.Writer) (*Anelace, []error)
  • func (anl *Anelace) Destroy()
  • func (anl *Anelace) OutputSummary()
  • func (anl *Anelace) ProcessReader(inputReader io.Reader, optionalEventChan chan<- IngestionEvent) (err error)
  • func (anl *Anelace) SetCarWriter(w io.Writer)
  • func (anl *Anelace) SetMultipart(m bool)
• type IngestionEvent
• type IngestionEventType

Constants

const (
	ErrorString = IngestionEventType(iota)
	NewRootJsonl
)

Types

type Anelace

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

func NewAnelace

func NewAnelace() *Anelace

func NewAnelaceFromArgv

func NewAnelaceFromArgv(argv []string) (anl *Anelace)

func NewAnelaceWithWriters

func NewAnelaceWithWriters(stderr io.Writer, stdout io.Writer) (*Anelace, []error)

func (*Anelace) Destroy

func (anl *Anelace) Destroy()

func (*Anelace) OutputSummary

func (anl *Anelace) OutputSummary()

func (*Anelace) ProcessReader

func (anl *Anelace) ProcessReader(inputReader io.Reader, optionalEventChan chan<- IngestionEvent) (err error)

func (*Anelace) SetCarWriter

func (anl *Anelace) SetCarWriter(w io.Writer)

func (*Anelace) SetMultipart

func (anl *Anelace) SetMultipart(m bool)

type IngestionEvent

type IngestionEvent struct {
	Type IngestionEventType
	Body string
	// contains filtered or unexported fields
}

type IngestionEventType

type IngestionEventType int