splitter

type AdditionalJSONDataGenerator func(bytes []byte, lineIndex int, parameterData map[string][]byte) (JSONDataWithGeneratedValue []byte, generateDataParameter map[string]interface{}, err error)

type AppenderFunction func(path string, bytes []byte) (err error)

type AppenderSinglePathFunction func(bytes []byte) (err error)

type AppenderSinglePathMap map[string]AppenderSinglePathFunction

type ByteBufferJSONParseResultAppender interface {
	JSONParseSingleResultAppender
	//Bytes get bytes writed
	Bytes() []byte
	//WriteToFile write bytes to file. salin semua content ke file
	WriteToFile(DestinationFilePath string) (err error)
	//ReadBytes read byte dengan delimiter(\n)
	ReadBytes() (line []byte, err error)
}

type CleanupMethod func()

type ExtractJSONToByteDefinition struct {
	//PathToExtract path di extract dari json string
	PathToExtract string
	//Appender appender hasil parse
	Appender ByteBufferJSONParseResultAppender
}

type ExtractJSONToFileDefinition struct {
	//PathToExtract path di extract dari json string
	PathToExtract string
	//DestinationFilePath file tempat menulis hasil
	DestinationFilePath string
}

type FileJSONParseResultAppender interface {
	JSONParseSingleResultAppender
	DestinationFilePath() string
	//SetFlushSize size flush
	SetFlushSize(flushSize int)
	//GetFlushSize ukuran flush
	GetFlushSize() int
}

type GenerateCustomDataForCleanedData func(lineIndex int, rawJSONData []byte) (generatedValues map[string][]byte, err error)

type JSONItemRemover interface {
	//IsRemovedPath
	IsRemovedPath(nodePath string) bool
	//Reset reset catalog item remove
	Reset()
	//AddRangeToRemove tambahkan range untuk di remove dari string / array
	AddRangeToRemove(startIndex int, endIndex int)
	//MakeCleanedUpString membuat string dengan item array yang di masukan di kosongkan
	MakeCleanedUpString(dataToClean string) []byte
	//MakeCleanedUpByte membuat bye yang sudah di cleanup
	MakeCleanedUpByte(dataToClean []byte) []byte
	//RegisterRemovedPath tambah path untuk di remove
	RegisterRemovedPath(thePath string)
}

type JSONParseSingleResultAppender interface {
	//Append add data to appender
	Append(bytes []byte) (err error)
	//Close close appender kalau ada
	Close() (err error)
	//OpenAppender open appender. and start writing
	OpenAppender() (err error)
}

type JSONResultAppender interface {

	//Append add data to appender
	Append(path string, bytes []byte) (err error)
}

type LogCapturer interface {
	Release()
}

type MarkArrayForIndexOfDeletion func(jsonPath string, startIndex int, endIndex int)

type ModificatorJSONData func(bytes []byte, lineIndex int, parameterData map[string][]byte, generateDataParameter map[string]interface{}) (result []byte, err error)

type ParseByte1Line1JSONToByteBridgeSubJSONData struct {
	//SubJSONPath path untuk di extract
	SubJSONPath string
	//Modificator method untuk modify data.jika misal tidak ada handler maka pergunakan NoModificatorJSONDataHandler
	Modificator ModificatorJSONData
	//FinalAppender setelah selesai di clean up hasil di masukan ke appender mana
	FinalAppender AppenderSinglePathFunction
	//DoNotRemovePath kalau di flag true, data tidak akan di cleanup dari json
	DoNotRemovePath bool
}

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

type SubJSONFileNameGenerator func(JSONPath string, JSONRowIndex int) string