client

Documentation

Index

• Constants
• type PubSubClient
  • func NewPubSubClient(logger *zap.SugaredLogger) (*PubSubClient, error)
• type PubSubConfig

Constants

const (
	TOPIC_CI_SCAN         = "CI-SCAN"
	TOPIC_CI_SCAN_GRP     = "CI-SCAN-GRP-1"
	TOPIC_CI_SCAN_DURABLE = "CI-SCAN-DURABLE-1"
)

Types

type PubSubClient

type PubSubClient struct {
	Conn        stan.Conn
	AckDuration int
	// contains filtered or unexported fields
}

func NewPubSubClient

func NewPubSubClient(logger *zap.SugaredLogger) (*PubSubClient, error)

type PubSubConfig

type PubSubConfig struct {
	NatsServerHost string `env:"NATS_SERVER_HOST" envDefault:"nats://localhost:4222"`
	ClusterId      string `env:"CLUSTER_ID" envDefault:"devtron-stan"`
	ClientId       string `env:"CLIENT_ID" envDefault:"telemetry-telemetry-analytics"`
	AckDuration    string `env:"ACK_DURATION" envDefault:"30"`
}