writers

var AMQPBaseForm = forms.Form{
	ErrorMsg: "invalid data encountered in the AMQP form",
	Fields: []forms.Field{
		{
			Name: "format",
			Validators: []forms.Validator{
				forms.IsOptional{Default: "json"},
				forms.IsIn{Choices: []interface{}{"json"}},
			},
		},
		{
			Name: "compress",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsBoolean{},
			},
		},
		{
			Name: "queue",
			Validators: []forms.Validator{
				forms.IsString{},
			},
		},
		{
			Name: "routing_key",
			Validators: []forms.Validator{
				forms.IsString{},
			},
		},
		{
			Name: "exchange",
			Validators: []forms.Validator{
				forms.IsString{},
			},
		},
		{
			Name: "exchange_type",
			Validators: []forms.Validator{
				forms.IsIn{Choices: []interface{}{"fanout", "direct", "topic"}},
			},
		},
		{
			Name: "queue_expires_after_ms",
			Validators: []forms.Validator{
				forms.IsOptional{Default: int64(0)},
				forms.IsInteger{HasMin: true, Min: 0},
			},
		},
		{
			Name: "url",
			Validators: []forms.Validator{
				forms.IsString{},
			},
		},
	},
}

var AMQPWriterForm = forms.Form{
	ErrorMsg: "invalid data encountered in the AMQP writer form",
	Fields: append([]forms.Field{
		{
			Name: "confirmation_timeout",
			Validators: []forms.Validator{
				forms.IsOptional{Default: 1.0},
				forms.IsFloat{Convert: false},
			},
		},
	}, AMQPBaseForm.Fields...),
}

var BytesWriterForm = forms.Form{
	ErrorMsg: "invalid data encountered in the bytes writer form",
	Fields: []forms.Field{
		{
			Name: "format",
			Validators: []forms.Validator{
				forms.IsIn{Choices: []interface{}{"json"}},
			},
		},
		{
			Name: "compress",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsBoolean{},
			},
		},
	},
}

var CountWriterForm = forms.Form{
	ErrorMsg: "invalid data encountered in the count writer form",
	Fields: []forms.Field{
		{
			Name: "max",
			Validators: []forms.Validator{
				forms.IsOptional{Default: 10},
				forms.IsInteger{HasMin: true, Min: 0, HasMax: true, Max: 100},
			},
		},
	},
}

var FileWriterForm = forms.Form{
	ErrorMsg: "invalid data encountered in the file writer form",
	Fields: []forms.Field{
		{
			Name: "path",
			Validators: []forms.Validator{
				forms.IsOptional{Default: ""},
				forms.IsString{},
			},
		},
		{
			Name: "base-name",
			Validators: []forms.Validator{
				forms.IsRequired{},
				forms.IsString{},
			},
		},
		{
			Name: "format",
			Validators: []forms.Validator{
				forms.IsOptional{Default: "json"},
				forms.IsIn{Choices: []interface{}{"json", "csv"}},
			},
		},
		{
			Name: "compress",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsBoolean{},
			},
		},
		{
			Name: "add-time",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsBoolean{},
			},
		},
	},
}

var HTTPWriterForm = forms.Form{
	ErrorMsg: "invalid data encountered in the HTTP writer form",
	Fields: []forms.Field{
		{
			Name: "format",
			Validators: []forms.Validator{
				forms.IsIn{Choices: []interface{}{"json"}},
			},
		},
		{
			Name: "url",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsString{},
			},
		},
		{
			Name: "headers",
			Validators: []forms.Validator{
				forms.IsOptional{Default: false},
				forms.IsStringMap{
					Form: &forms.Form{
						Fields: []forms.Field{
							{
								Name: "*",
								Validators: []forms.Validator{
									forms.IsString{},
								},
							},
						},
					},
				},
			},
		},
	},
}

var Writers = kodex.WriterDefinitions{
	"file": kodex.WriterDefinition{
		Maker:    MakeFileWriter,
		Form:     FileWriterForm,
		Internal: true,
	},
	"http": kodex.WriterDefinition{
		Maker: MakeHTTPWriter,
		Form:  HTTPWriterForm,
	},
	"bytes": kodex.WriterDefinition{
		Maker:    MakeBytesWriter,
		Form:     BytesWriterForm,
		Internal: true,
	},
	"in-memory": kodex.WriterDefinition{
		Maker:    MakeInMemoryWriter,
		Internal: true,
	},
	"stdout": kodex.WriterDefinition{
		Maker:    MakeStdoutWriter,
		Internal: true,
	},
	"amqp": kodex.WriterDefinition{
		Maker:    MakeAMQPWriter,
		Form:     AMQPWriterForm,
		Internal: false,
	},
	"count": kodex.WriterDefinition{
		Maker:    MakeCountWriter,
		Form:     CountWriterForm,
		Internal: true,
	},
}