Versions in this module Expand all Collapse all v0 v0.1.0 Apr 20, 2020 v0.0.7 Apr 17, 2020 v0.0.6 Mar 20, 2020 v0.0.5 Mar 20, 2020 v0.0.4 Mar 20, 2020 Changes in this version + const EnvKafkaVersion + const KafkaVersion type KafkaArgs + Version string + type RedisAccessEvent struct + Event []event.Event + EventTime string v0.0.3 Mar 2, 2020 v0.0.2 Feb 4, 2020 v0.0.1 Jan 29, 2020 Changes in this version + const AmqpArguments + const AmqpAutoDeleted + const AmqpDeliveryMode + const AmqpDurable + const AmqpExchange + const AmqpExchangeType + const AmqpImmediate + const AmqpInternal + const AmqpMandatory + const AmqpNoWait + const AmqpPublishingHeaders + const AmqpQueueDir + const AmqpQueueLimit + const AmqpRoutingKey + const AmqpURL + const ElasticFormat + const ElasticIndex + const ElasticQueueDir + const ElasticQueueLimit + const ElasticURL + const EnvAMQPArguments + const EnvAMQPAutoDeleted + const EnvAMQPDeliveryMode + const EnvAMQPDurable + const EnvAMQPEnable + const EnvAMQPExchange + const EnvAMQPExchangeType + const EnvAMQPImmediate + const EnvAMQPInternal + const EnvAMQPMandatory + const EnvAMQPNoWait + const EnvAMQPPublishingHeaders + const EnvAMQPQueueDir + const EnvAMQPQueueLimit + const EnvAMQPRoutingKey + const EnvAMQPURL + const EnvElasticEnable + const EnvElasticFormat + const EnvElasticIndex + const EnvElasticQueueDir + const EnvElasticQueueLimit + const EnvElasticURL + const EnvKafkaBrokers + const EnvKafkaClientTLSCert + const EnvKafkaClientTLSKey + const EnvKafkaEnable + const EnvKafkaQueueDir + const EnvKafkaQueueLimit + const EnvKafkaSASLEnable + const EnvKafkaSASLPassword + const EnvKafkaSASLUsername + const EnvKafkaTLS + const EnvKafkaTLSClientAuth + const EnvKafkaTLSSkipVerify + const EnvKafkaTopic + const EnvMQTTBroker + const EnvMQTTEnable + const EnvMQTTKeepAliveInterval + const EnvMQTTPassword + const EnvMQTTQoS + const EnvMQTTQueueDir + const EnvMQTTQueueLimit + const EnvMQTTReconnectInterval + const EnvMQTTTopic + const EnvMQTTUsername + const EnvMySQLDSNString + const EnvMySQLDatabase + const EnvMySQLEnable + const EnvMySQLFormat + const EnvMySQLHost + const EnvMySQLPassword + const EnvMySQLPort + const EnvMySQLQueueDir + const EnvMySQLQueueLimit + const EnvMySQLTable + const EnvMySQLUsername + const EnvNATSAddress + const EnvNATSCertAuthority + const EnvNATSClientCert + const EnvNATSClientKey + const EnvNATSEnable + const EnvNATSPassword + const EnvNATSPingInterval + const EnvNATSQueueDir + const EnvNATSQueueLimit + const EnvNATSStreaming + const EnvNATSStreamingAsync + const EnvNATSStreamingClusterID + const EnvNATSStreamingMaxPubAcksInFlight + const EnvNATSSubject + const EnvNATSTLS + const EnvNATSTLSSkipVerify + const EnvNATSToken + const EnvNATSUsername + const EnvNSQAddress + const EnvNSQEnable + const EnvNSQQueueDir + const EnvNSQQueueLimit + const EnvNSQTLS + const EnvNSQTLSSkipVerify + const EnvNSQTopic + const EnvPostgresConnectionString + const EnvPostgresDatabase + const EnvPostgresEnable + const EnvPostgresFormat + const EnvPostgresHost + const EnvPostgresPassword + const EnvPostgresPort + const EnvPostgresQueueDir + const EnvPostgresQueueLimit + const EnvPostgresTable + const EnvPostgresUsername + const EnvRedisAddress + const EnvRedisEnable + const EnvRedisFormat + const EnvRedisKey + const EnvRedisPassword + const EnvRedisQueueDir + const EnvRedisQueueLimit + const EnvWebhookAuthToken + const EnvWebhookEnable + const EnvWebhookEndpoint + const EnvWebhookQueueDir + const EnvWebhookQueueLimit + const KafkaBrokers + const KafkaClientTLSCert + const KafkaClientTLSKey + const KafkaQueueDir + const KafkaQueueLimit + const KafkaSASL + const KafkaSASLPassword + const KafkaSASLUsername + const KafkaTLS + const KafkaTLSClientAuth + const KafkaTLSSkipVerify + const KafkaTopic + const MqttBroker + const MqttKeepAliveInterval + const MqttPassword + const MqttQoS + const MqttQueueDir + const MqttQueueLimit + const MqttReconnectInterval + const MqttTopic + const MqttUsername + const MySQLDSNString + const MySQLDatabase + const MySQLFormat + const MySQLHost + const MySQLPassword + const MySQLPort + const MySQLQueueDir + const MySQLQueueLimit + const MySQLTable + const MySQLUsername + const NATSAddress + const NATSCertAuthority + const NATSClientCert + const NATSClientKey + const NATSPassword + const NATSPingInterval + const NATSQueueDir + const NATSQueueLimit + const NATSStreaming + const NATSStreamingAsync + const NATSStreamingClusterID + const NATSStreamingMaxPubAcksInFlight + const NATSSubject + const NATSTLS + const NATSTLSSkipVerify + const NATSToken + const NATSUsername + const NSQAddress + const NSQQueueDir + const NSQQueueLimit + const NSQTLS + const NSQTLSSkipVerify + const NSQTopic + const PostgresConnectionString + const PostgresDatabase + const PostgresFormat + const PostgresHost + const PostgresPassword + const PostgresPort + const PostgresQueueDir + const PostgresQueueLimit + const PostgresTable + const PostgresUsername + const RedisAddress + const RedisFormat + const RedisKey + const RedisPassword + const RedisQueueDir + const RedisQueueLimit + const WebhookAuthToken + const WebhookEndpoint + const WebhookQueueDir + const WebhookQueueLimit + func IsConnErr(err error) bool + func IsConnRefusedErr(err error) bool + func IsConnResetErr(err error) bool + type AMQPArgs struct + AutoDeleted bool + DeliveryMode uint8 + Durable bool + Enable bool + Exchange string + ExchangeType string + Immediate bool + Internal bool + Mandatory bool + NoWait bool + QueueDir string + QueueLimit uint64 + RoutingKey string + URL xnet.URL + func (a *AMQPArgs) Validate() error + type AMQPTarget struct + func NewAMQPTarget(id string, args AMQPArgs, doneCh <-chan struct{}, ...) (*AMQPTarget, error) + func (target *AMQPTarget) Close() error + func (target *AMQPTarget) ID() event.TargetID + func (target *AMQPTarget) IsActive() (bool, error) + func (target *AMQPTarget) Save(eventData event.Event) error + func (target *AMQPTarget) Send(eventKey string) error + type ElasticsearchArgs struct + Enable bool + Format string + Index string + QueueDir string + QueueLimit uint64 + URL xnet.URL + func (a ElasticsearchArgs) Validate() error + type ElasticsearchTarget struct + func NewElasticsearchTarget(id string, args ElasticsearchArgs, doneCh <-chan struct{}, ...) (*ElasticsearchTarget, error) + func (target *ElasticsearchTarget) Close() error + func (target *ElasticsearchTarget) ID() event.TargetID + func (target *ElasticsearchTarget) IsActive() (bool, error) + func (target *ElasticsearchTarget) Save(eventData event.Event) error + func (target *ElasticsearchTarget) Send(eventKey string) error + type HTTPClientTarget struct + DoneCh chan struct{} + func NewHTTPClientTarget(host xnet.Host, w http.ResponseWriter) (*HTTPClientTarget, error) + func (target *HTTPClientTarget) Close() error + func (target *HTTPClientTarget) IsActive() (bool, error) + func (target *HTTPClientTarget) Save(eventData event.Event) error + func (target *HTTPClientTarget) Send(eventKey string) error + func (target HTTPClientTarget) ID() event.TargetID + type KafkaArgs struct + Brokers []xnet.Host + Enable bool + QueueDir string + QueueLimit uint64 + SASL struct{ ... } + TLS struct{ ... } + Topic string + func (k KafkaArgs) Validate() error + type KafkaTarget struct + func NewKafkaTarget(id string, args KafkaArgs, doneCh <-chan struct{}, ...) (*KafkaTarget, error) + func (target *KafkaTarget) Close() error + func (target *KafkaTarget) ID() event.TargetID + func (target *KafkaTarget) IsActive() (bool, error) + func (target *KafkaTarget) Save(eventData event.Event) error + func (target *KafkaTarget) Send(eventKey string) error + type MQTTArgs struct + Broker xnet.URL + Enable bool + KeepAlive time.Duration + MaxReconnectInterval time.Duration + Password string + QoS byte + QueueDir string + QueueLimit uint64 + RootCAs *x509.CertPool + Topic string + User string + func (m MQTTArgs) Validate() error + type MQTTTarget struct + func NewMQTTTarget(id string, args MQTTArgs, doneCh <-chan struct{}, ...) (*MQTTTarget, error) + func (target *MQTTTarget) Close() error + func (target *MQTTTarget) ID() event.TargetID + func (target *MQTTTarget) IsActive() (bool, error) + func (target *MQTTTarget) Save(eventData event.Event) error + func (target *MQTTTarget) Send(eventKey string) error + type MySQLArgs struct + DSN string + Database string + Enable bool + Format string + Host xnet.URL + Password string + Port string + QueueDir string + QueueLimit uint64 + Table string + User string + func (m MySQLArgs) Validate() error + type MySQLTarget struct + func NewMySQLTarget(id string, args MySQLArgs, doneCh <-chan struct{}, ...) (*MySQLTarget, error) + func (target *MySQLTarget) Close() error + func (target *MySQLTarget) ID() event.TargetID + func (target *MySQLTarget) IsActive() (bool, error) + func (target *MySQLTarget) Save(eventData event.Event) error + func (target *MySQLTarget) Send(eventKey string) error + type NATSArgs struct + Address xnet.Host + CertAuthority string + ClientCert string + ClientKey string + Enable bool + Password string + PingInterval int64 + QueueDir string + QueueLimit uint64 + RootCAs *x509.CertPool + Secure bool + Streaming struct{ ... } + Subject string + TLS bool + TLSSkipVerify bool + Token string + Username string + func (n NATSArgs) Validate() error + type NATSTarget struct + func NewNATSTarget(id string, args NATSArgs, doneCh <-chan struct{}, ...) (*NATSTarget, error) + func (target *NATSTarget) Close() (err error) + func (target *NATSTarget) ID() event.TargetID + func (target *NATSTarget) IsActive() (bool, error) + func (target *NATSTarget) Save(eventData event.Event) error + func (target *NATSTarget) Send(eventKey string) error + type NSQArgs struct + Enable bool + NSQDAddress xnet.Host + QueueDir string + QueueLimit uint64 + TLS struct{ ... } + Topic string + func (n NSQArgs) Validate() error + type NSQTarget struct + func NewNSQTarget(id string, args NSQArgs, doneCh <-chan struct{}, ...) (*NSQTarget, error) + func (target *NSQTarget) Close() (err error) + func (target *NSQTarget) ID() event.TargetID + func (target *NSQTarget) IsActive() (bool, error) + func (target *NSQTarget) Save(eventData event.Event) error + func (target *NSQTarget) Send(eventKey string) error + type PostgreSQLArgs struct + ConnectionString string + Database string + Enable bool + Format string + Host xnet.Host + Password string + Port string + QueueDir string + QueueLimit uint64 + Table string + User string + func (p PostgreSQLArgs) Validate() error + type PostgreSQLTarget struct + func NewPostgreSQLTarget(id string, args PostgreSQLArgs, doneCh <-chan struct{}, ...) (*PostgreSQLTarget, error) + func (target *PostgreSQLTarget) Close() error + func (target *PostgreSQLTarget) ID() event.TargetID + func (target *PostgreSQLTarget) IsActive() (bool, error) + func (target *PostgreSQLTarget) Save(eventData event.Event) error + func (target *PostgreSQLTarget) Send(eventKey string) error + type QueueStore struct + func (store *QueueStore) Del(key string) error + func (store *QueueStore) Get(key string) (event event.Event, err error) + func (store *QueueStore) List() ([]string, error) + func (store *QueueStore) Open() error + func (store *QueueStore) Put(e event.Event) error + type RedisArgs struct + Addr xnet.Host + Enable bool + Format string + Key string + Password string + QueueDir string + QueueLimit uint64 + func (r RedisArgs) Validate() error + type RedisTarget struct + func NewRedisTarget(id string, args RedisArgs, doneCh <-chan struct{}, ...) (*RedisTarget, error) + func (target *RedisTarget) Close() error + func (target *RedisTarget) ID() event.TargetID + func (target *RedisTarget) IsActive() (bool, error) + func (target *RedisTarget) Save(eventData event.Event) error + func (target *RedisTarget) Send(eventKey string) error + type Store interface + Del func(key string) error + Get func(key string) (event.Event, error) + List func() ([]string, error) + Open func() error + Put func(event event.Event) error + func NewQueueStore(directory string, limit uint64) Store + type WebhookArgs struct + AuthToken string + Enable bool + Endpoint xnet.URL + QueueDir string + QueueLimit uint64 + Transport *http.Transport + func (w WebhookArgs) Validate() error + type WebhookTarget struct + func NewWebhookTarget(id string, args WebhookArgs, doneCh <-chan struct{}, ...) (*WebhookTarget, error) + func (target *WebhookTarget) Close() error + func (target *WebhookTarget) IsActive() (bool, error) + func (target *WebhookTarget) Save(eventData event.Event) error + func (target *WebhookTarget) Send(eventKey string) error + func (target WebhookTarget) ID() event.TargetID