Versions in this module Expand all Collapse all v1 v1.0.2 Mar 17, 2021 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 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 EnvAMQPPublishingHeaders + 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 + 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 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