session_analyzer

Documentation

Index

• Constants
• Variables
• func NewSessionAnalyzer(natsConn *nats_internal.NATSConnections, repository *repository.Repositories) interfaces.NatsService

Constants

const (
	// queue group
	QUEUE_GROUP = "session-analyzer"

	// consumer config
	CONSUMER_NAME         = "session-analyzer-consumer"
	ACK_WAIT              = 30 * time.Second
	MAX_DELIVERY_ATTEMPTS = 5
	MAX_ACK_PENDING       = 100
	FETCH_BATCH_SIZE      = 50
	MAX_FETCH_WAIT        = 500 * time.Millisecond
	ERR_BACKOFF           = 100 * time.Millisecond
)

Variables

var SUBSCRIBED_SUBJECT = enum.EventWebtrackerSessionClosed.String()

Functions

func NewSessionAnalyzer

func NewSessionAnalyzer(
	natsConn *nats_internal.NATSConnections,
	repository *repository.Repositories,
) interfaces.NatsService