services

func ConnectNATS ¶

func ConnectNATS(url string) (*nats.Conn, nats.JetStreamContext, error)

ConnectNATS connects to NATS and initializes JetStream and streams. It returns the underlying Conn and JetStreamContext for advanced usage.

func GetContentType ¶

func GetContentType(extension string) string

GetContentType Helper function to determine the content type

func InitializeMinio ¶

func InitializeMinio(endpoint, accessKey, secretKey, bucket string, useSSL bool) error

func PublishEvent ¶

func PublishEvent(subject string, payload interface{}) error

PublishEvent publishes an event via JetStream (durable, stored). subject e.g. "files.uploaded"

func PublishPlain ¶

func PublishPlain(subject string, payload []byte) error

PublishPlain publishes without JetStream (fire-and-forget). Keep this for compatibility, but prefer PublishEvent for critical events.

func SubscribeEvent ¶

func SubscribeEvent(subject, durableName string, handler nats.MsgHandler) (*nats.Subscription, error)

SubscribeEvent creates a durable, ack-based consumer. handler receives the nats.Msg and is responsible to Ack() when done. durableName should be unique per consumer service (e.g., "file-service-preview-consumer")