raw

type Config struct {
	Endpoint             string        `mapstructure:"address"`          // Endpoint of the nats server
	Cluster              string        `mapstructure:"clusterID"`        // CluserID of the nats cluster
	TLSInsecure          bool          `mapstructure:"tls-insecure"`     // Whether to verify TLS certificates
	TLSRootCACertificate string        `mapstructure:"tls-root-ca-cert"` // The root CA certificate used to validate the TLS certificate
	EnableTLS            bool          `mapstructure:"enable-tls"`       // Enable TLS
	AuthUsername         string        `mapstructure:"username"`         // Username for authentication
	AuthPassword         string        `mapstructure:"password"`         // Password for authentication
	MaxAckPending        int           `mapstructure:"max-ack-pending"`  // Maximum number of unacknowledged messages
	AckWait              time.Duration `mapstructure:"ack-wait"`         // Time to wait for an ack
}

type Event struct {
	events.Event
	// contains filtered or unexported fields
}

type RawEvent struct {
	Timestamp time.Time
	Metadata  map[string]string
	ID        string
	Topic     string
	Payload   []byte
	// contains filtered or unexported fields
}

type RawStream struct {
	// contains filtered or unexported fields
}

type Stream interface {
	Consume(group string, evs ...events.Unmarshaller) (<-chan Event, error)
	JetStream() jetstream.Stream
}