dagger

Documentation

Index

• Constants
• Variables
• type Dagger
  • func NewFromArgv(argv []string) (dgr *Dagger)
  • func (dgr *Dagger) Destroy()
  • func (dgr *Dagger) OutputSummary()
  • func (dgr *Dagger) ProcessReader(inputReader io.Reader, optionalEventChan chan<- IngestionEvent) (err error)
• type IngestionEvent
• type IngestionEventType

Constants

const (
	ErrorString = IngestionEventType(iota)
	NewChunkJsonl
	NewRootJsonl
)

Variables

var CheckGoroutineShutdown bool

Types

type Dagger

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

func NewFromArgv

func NewFromArgv(argv []string) (dgr *Dagger)

func (*Dagger) Destroy

func (dgr *Dagger) Destroy()

func (*Dagger) OutputSummary

func (dgr *Dagger) OutputSummary()

func (*Dagger) ProcessReader

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

type IngestionEvent

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

type IngestionEventType

type IngestionEventType int