Versions in this module Expand all Collapse all v0 v0.2.5 Nov 6, 2023 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 EnvKafkaBatchSize + 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 EnvNATSJetStream + 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 KafkaBatchSize + 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 NATSJetStream + 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 DrainBody(respBody io.ReadCloser) + func IsConnErr(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, loggerOnce logger.LogOnce) (*AMQPTarget, error) + func (target *AMQPTarget) Close() error + func (target *AMQPTarget) ID() event.TargetID + func (target *AMQPTarget) IsActive() (bool, error) + func (target *AMQPTarget) Name() string + func (target *AMQPTarget) Save(eventData event.Event) error + func (target *AMQPTarget) SendFromStore(key store.Key) error + func (target *AMQPTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*ElasticsearchTarget, error) + func (target *ElasticsearchTarget) Close() error + func (target *ElasticsearchTarget) ID() event.TargetID + func (target *ElasticsearchTarget) IsActive() (bool, error) + func (target *ElasticsearchTarget) Name() string + func (target *ElasticsearchTarget) Save(eventData event.Event) error + func (target *ElasticsearchTarget) SendFromStore(key store.Key) error + func (target *ElasticsearchTarget) Store() event.TargetStore + type KafkaArgs struct + BatchSize uint32 + 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, loggerOnce logger.LogOnce) (*KafkaTarget, error) + func (target *KafkaTarget) Close() error + func (target *KafkaTarget) ID() event.TargetID + func (target *KafkaTarget) IsActive() (bool, error) + func (target *KafkaTarget) Name() string + func (target *KafkaTarget) Save(eventData event.Event) error + func (target *KafkaTarget) SendFromStore(key store.Key) error + func (target *KafkaTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*MQTTTarget, error) + func (target *MQTTTarget) Close() error + func (target *MQTTTarget) ID() event.TargetID + func (target *MQTTTarget) IsActive() (bool, error) + func (target *MQTTTarget) Name() string + func (target *MQTTTarget) Save(eventData event.Event) error + func (target *MQTTTarget) SendFromStore(key store.Key) error + func (target *MQTTTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*MySQLTarget, error) + func (target *MySQLTarget) Close() error + func (target *MySQLTarget) ID() event.TargetID + func (target *MySQLTarget) IsActive() (bool, error) + func (target *MySQLTarget) Name() string + func (target *MySQLTarget) Save(eventData event.Event) error + func (target *MySQLTarget) SendFromStore(key store.Key) error + func (target *MySQLTarget) Store() event.TargetStore + type NATSArgs struct + Address xnet.Host + CertAuthority string + ClientCert string + ClientKey string + Enable bool + JetStream struct{ ... } + 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, loggerOnce logger.LogOnce) (*NATSTarget, error) + func (target *NATSTarget) Close() (err error) + func (target *NATSTarget) ID() event.TargetID + func (target *NATSTarget) IsActive() (bool, error) + func (target *NATSTarget) Name() string + func (target *NATSTarget) Save(eventData event.Event) error + func (target *NATSTarget) SendFromStore(key store.Key) error + func (target *NATSTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*NSQTarget, error) + func (target *NSQTarget) Close() (err error) + func (target *NSQTarget) ID() event.TargetID + func (target *NSQTarget) IsActive() (bool, error) + func (target *NSQTarget) Name() string + func (target *NSQTarget) Save(eventData event.Event) error + func (target *NSQTarget) SendFromStore(key store.Key) error + func (target *NSQTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*PostgreSQLTarget, error) + func (target *PostgreSQLTarget) Close() error + func (target *PostgreSQLTarget) ID() event.TargetID + func (target *PostgreSQLTarget) IsActive() (bool, error) + func (target *PostgreSQLTarget) Name() string + func (target *PostgreSQLTarget) Save(eventData event.Event) error + func (target *PostgreSQLTarget) SendFromStore(key store.Key) error + func (target *PostgreSQLTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce) (*RedisTarget, error) + func (target *RedisTarget) Close() error + func (target *RedisTarget) ID() event.TargetID + func (target *RedisTarget) IsActive() (bool, error) + func (target *RedisTarget) Name() string + func (target *RedisTarget) Save(eventData event.Event) error + func (target *RedisTarget) SendFromStore(key store.Key) error + func (target *RedisTarget) Store() event.TargetStore + 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, loggerOnce logger.LogOnce, ...) (*WebhookTarget, error) + func (target *WebhookTarget) Close() error + func (target *WebhookTarget) ID() event.TargetID + func (target *WebhookTarget) IsActive() (bool, error) + func (target *WebhookTarget) Name() string + func (target *WebhookTarget) Save(eventData event.Event) error + func (target *WebhookTarget) SendFromStore(key store.Key) error + func (target *WebhookTarget) Store() event.TargetStore + 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) v0.2.5-mayhem Nov 6, 2023 v0.2.2-dev11-06-2023 Nov 6, 2023
Go to main page