Versions in this module Expand all Collapse all v0 v0.3.4 Aug 12, 2022 v0.3.3 Jun 8, 2022 v0.3.2 May 11, 2022 v0.3.1 Apr 25, 2022 v0.3.0 Apr 15, 2022 v0.2.6 Aug 26, 2022 v0.2.5 May 11, 2022 v0.2.4 Mar 29, 2022 v0.2.3 Mar 29, 2022 v0.2.2 Mar 29, 2022 v0.2.1 Mar 29, 2022 v0.2.0 Mar 23, 2022 v0.1.1 Mar 29, 2022 v0.1.0 Mar 21, 2022 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 AmqpPublisherConfirms + const AmqpQueueDir + const AmqpQueueLimit + const AmqpRoutingKey + const AmqpURL + const ElasticFormat + const ElasticIndex + const ElasticPassword + const ElasticQueueDir + const ElasticQueueLimit + const ElasticURL + const ElasticUsername + const EnvAMQPArguments + const EnvAMQPAutoDeleted + const EnvAMQPDeliveryMode + const EnvAMQPDurable + const EnvAMQPEnable + const EnvAMQPExchange + const EnvAMQPExchangeType + const EnvAMQPImmediate + const EnvAMQPInternal + const EnvAMQPMandatory + const EnvAMQPNoWait + const EnvAMQPPublisherConfirms + const EnvAMQPQueueDir + const EnvAMQPQueueLimit + const EnvAMQPRoutingKey + const EnvAMQPURL + const EnvElasticEnable + const EnvElasticFormat + const EnvElasticIndex + const EnvElasticPassword + const EnvElasticQueueDir + const EnvElasticQueueLimit + const EnvElasticURL + const EnvElasticUsername + const EnvKafkaBrokers + const EnvKafkaClientTLSCert + const EnvKafkaClientTLSKey + const EnvKafkaEnable + const EnvKafkaQueueDir + const EnvKafkaQueueLimit + const EnvKafkaSASLEnable + const EnvKafkaSASLMechanism + const EnvKafkaSASLPassword + const EnvKafkaSASLUsername + const EnvKafkaTLS + const EnvKafkaTLSClientAuth + const EnvKafkaTLSSkipVerify + const EnvKafkaTopic + const EnvKafkaVersion + 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 EnvMySQLMaxOpenConnections + 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 EnvPostgresMaxOpenConnections + 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 EnvWebhookClientCert + const EnvWebhookClientKey + const EnvWebhookEnable + const EnvWebhookEndpoint + const EnvWebhookQueueDir + const EnvWebhookQueueLimit + const KafkaBrokers + const KafkaClientTLSCert + const KafkaClientTLSKey + const KafkaQueueDir + const KafkaQueueLimit + const KafkaSASL + const KafkaSASLMechanism + const KafkaSASLPassword + const KafkaSASLUsername + const KafkaTLS + const KafkaTLSClientAuth + const KafkaTLSSkipVerify + const KafkaTopic + const KafkaVersion + 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 MySQLMaxOpenConnections + 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 PostgresMaxOpenConnections + 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 WebhookClientCert + const WebhookClientKey + const WebhookEndpoint + const WebhookQueueDir + const WebhookQueueLimit + var KafkaSHA256 scram.HashGeneratorFcn = sha256.New + var KafkaSHA512 scram.HashGeneratorFcn = sha512.New + 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 + PublisherConfirms 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) HasQueueStore() bool + 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 ESSupportStatus string + const ESSDeprecated + const ESSSupported + const ESSUnknown + const ESSUnsupported + type ElasticsearchArgs struct + Enable bool + Format string + Index string + Password string + QueueDir string + QueueLimit uint64 + Transport *http.Transport + URL xnet.URL + Username string + 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) HasQueueStore() bool + 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 KafkaArgs struct + Brokers []xnet.Host + Enable bool + QueueDir string + QueueLimit uint64 + SASL struct{ ... } + TLS struct{ ... } + Topic string + Version 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) HasQueueStore() bool + 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) HasQueueStore() bool + 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 + MaxOpenConnections int + 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) HasQueueStore() bool + 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) HasQueueStore() bool + 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) HasQueueStore() bool + 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 + MaxOpenConnections int + Password string + Port string + QueueDir string + QueueLimit uint64 + Table string + Username 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) HasQueueStore() bool + 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 RedisAccessEvent struct + Event []event.Event + EventTime string + 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) HasQueueStore() bool + 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 + ClientCert string + ClientKey string + Enable bool + Endpoint xnet.URL + QueueDir string + QueueLimit uint64 + Transport *http.Transport + func (w WebhookArgs) Validate() error + type WebhookTarget struct + func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, ...) (*WebhookTarget, error) + func (target *WebhookTarget) Close() error + func (target *WebhookTarget) HasQueueStore() bool + 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 + type XDGSCRAMClient struct + func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *XDGSCRAMClient) Done() bool + func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)
Go to main page