writers

Oct 6, 2021

Changes in this version

+ var AMQPBaseForm = forms.Form

+ var AMQPWriterForm = forms.Form

+ var BytesWriterForm = forms.Form

+ var CountWriterForm = forms.Form

+ var FileWriterForm = forms.Form

+ var HTTPWriterForm = forms.Form

+ var Writers = kodex.WriterDefinitions

+ func MakeAMQPWriter(config map[string]interface{}) (kodex.Writer, error)

+ func MakeBytesWriter(config map[string]interface{}) (kodex.Writer, error)

+ func MakeCountWriter(config map[string]interface{}) (kodex.Writer, error)

+ func MakeFileWriter(config map[string]interface{}) (kodex.Writer, error)

+ func MakeHTTPWriter(config map[string]interface{}) (kodex.Writer, error)

+ func MakeInMemoryWriter(params map[string]interface{}) (kodex.Writer, error)

+ func MakeStdoutWriter(params map[string]interface{}) (kodex.Writer, error)

+ type AMQPBase struct

+ BaseQueueName string

+ BaseRoutingKey string

+ Channel *amqp.Channel

+ Compress bool

+ Connection *amqp.Connection

+ Exchange string

+ ExchangeType string

+ Format string

+ Model kodex.Model

+ Queue amqp.Queue

+ QueueExpiresAfterMs int64

+ QueueName string

+ RoutingKey string

+ URL string

+ func MakeAMQPBase(params map[string]interface{}) (AMQPBase, error)

+ func (a *AMQPBase) Setup(config kodex.Config) error

+ func (a *AMQPBase) SetupWithModel(model kodex.Model) error

+ func (a *AMQPBase) Teardown() error

+ type AMQPWriter struct

+ ConfirmationTimeout float64

+ Confirmations chan amqp.Confirmation

+ func (a *AMQPWriter) Setup(config kodex.Config) error

+ func (a *AMQPWriter) SetupWithModel(model kodex.Model) error

+ func (a *AMQPWriter) Write(payload kodex.Payload) error

+ type BytesWriter struct

+ Compress bool

+ Format string

+ Output []byte

+ func (s *BytesWriter) Setup(config kodex.Config) error

+ func (s *BytesWriter) Teardown() error

+ func (s *BytesWriter) Write(payload kodex.Payload) error

+ type CountWriter struct

+ func (s *CountWriter) Count() int64

+ func (s *CountWriter) LastItems() []map[string]interface{}

+ func (s *CountWriter) Setup(config kodex.Config) error

+ func (s *CountWriter) Teardown() error

+ func (s *CountWriter) Write(payload kodex.Payload) error

+ type FileWriter struct

+ AddTime bool

+ BasePath string

+ Compress bool

+ Format string

+ Name string

+ func (s *FileWriter) Setup(config kodex.Config) error

+ func (s *FileWriter) Teardown() error

+ func (s *FileWriter) Write(payload kodex.Payload) error

+ type HTTPWriter struct

+ Config kodex.Config

+ Format string

+ Headers map[string]interface{}

+ URL string

+ func (s *HTTPWriter) Setup(config kodex.Config) error

+ func (s *HTTPWriter) Teardown() error

+ func (s *HTTPWriter) Write(payload kodex.Payload) error

+ type InMemoryWriter struct

+ func (s *InMemoryWriter) Result() []map[string]interface{}

+ func (s *InMemoryWriter) Setup(config kodex.Config) error

+ func (s *InMemoryWriter) Teardown() error

+ func (s *InMemoryWriter) Write(payload kodex.Payload) error

+ type StdoutWriter struct

+ func (s *StdoutWriter) Setup(config kodex.Config) error

+ func (s *StdoutWriter) Teardown() error

+ func (s *StdoutWriter) Write(payload kodex.Payload) error

+ type TopicExchangeChosen struct

+ func (t TopicExchangeChosen) Validate(value interface{}, values map[string]interface{}) (interface{}, error)