logwriter

type Config struct {
	LogName string
}

type Kind uint

type LogWriter interface {
	// Init is called when the dispatcher starts. In case ErrWriterStop is returned, the writer won't be
	// considered while writing log messages.
	Init(config Config) error
	// WriteLogMessages shall write given logMessages, which are sorted by their timestamp. Since every message
	// is premarshalled, their timestamps are provided in a separate array of same length with corresponding indices.
	// In case there is an unrecoverable error detected ErrWriterStop shall be returned to disbale the LogWriter and prevent
	// that WriteLogMessages is called again.
	WriteLogMessages(logMessages []json.RawMessage, timestamps []time.Time) error
	// PropertiesSchemaChanged is called when the schema of log messages changed.
	// E.g. yet unknown property has been added to a log message.
	// PropertiesSchemaChanged is called before the according log message is written with WriteLogMessages().
	// An error can be returned to inform that something went wrong, but it won't be handled somehow.
	PropertiesSchemaChanged(schema map[string]Kind) error
	// Informs the writer that the dispatcher stopped
	Close()
}