mongoDB

Documentation

Index

• type Config
• type MongoProducer
  • func (p *MongoProducer) Close() error
  • func (p *MongoProducer) Initialize(configFile string)
  • func (p *MongoProducer) Produce(k []byte, v []byte, o any)

Types

type Config

type Config struct {
	MongoURI   string `json:"mongo_uri"`
	Username   string `json:"username"`
	Password   string `json:"password"`
	Database   string `json:"database"`
	Collection string `json:"collection"`
}

type MongoProducer

type MongoProducer struct {
	// contains filtered or unexported fields
}

func (*MongoProducer) Close

func (p *MongoProducer) Close() error

func (*MongoProducer) Initialize

func (p *MongoProducer) Initialize(configFile string)

func (*MongoProducer) Produce

func (p *MongoProducer) Produce(k []byte, v []byte, o any)