INNER CODE UNIT · Go

func

owlistic-notes/owlistic · src/backend/broker/producer.go:31

func (p *NatsProducer) CreateTopics(streamName string, topics []string) error {
	_, err := p.js.StreamInfo(streamName)
	if err != nil {
		_, err = p.js.AddStream(&nats.StreamConfig{
			Name:      streamName,
			Subjects:  topics,
			Storage:   nats.FileStorage,
			Retention: nats.LimitsPolicy,
		})
		if err != nil {
			log.Printf("Failed to create stream: %v", err)
			return err
		}
	}
	return nil
}

var (

View source record →