Skip to main content

nats

import "redn3t.com/odirscan/internal/nats"

Index​

Constants​

const (
    SubjectScanRequests = "scan.requests"
    SubjectScanStream   = "scan.stream."
    ConsumerName        = "scan-orchestrators"

    SubjectAnalysisRequests = "analysis.requests"
    SubjectAnalysisStream   = "analysis.stream."
    AnalysisConsumerName    = "analysis-orchestrators"
)

func AnalysisStreamSubject​

func AnalysisStreamSubject(analysisID string) string

func Connect​

func Connect(url string) (*nats.Conn, error)

func ScanStreamSubject​

func ScanStreamSubject(scanID string) string

Generated by gomarkdoc