database

Documentation

Index

• Constants
• Variables
• type Config
• type MongoDbService
  • func NewMongoDbService(ctx context.Context, cfg *Config) (*MongoDbService, error)
  • func (c *MongoDbService) InsertRawRequest(requestType, verb, kind string, body []byte) error

Constants

const (
	RAW_REQUESTS_COLLECTION_NAME = "raw_requests"
)

Variables

var (
	DBDefaults map[string]interface{} = map[string]interface{}{
		"mode":             os.Getenv("TICKER_MODE"),
		"address":          os.Getenv("TICKER_SERVER_ADDRESS"),
		"serverPort":       os.Getenv("TICKER_SERVER_PORT"),
		"clientPort":       "31009",
		"workDir":          []string{"/app/"},
		"mongoURL":         os.Getenv("MONGO_URL"),
		"MongoDatabaseURI": os.Getenv("MONGO_DB_URI"),
		"MongoDBUserName":  os.Getenv("MONGO_DB_USERNAME"),
		"MongoDBPassword":  os.Getenv("MONGO_DB_PASSWORD"),
		"MongoDBName":      os.Getenv("MONGO_DB_NAME"),
	}
)

Types

type Config

type Config struct {
	Address          string
	ServerPort       string
	ClientPort       string
	WorkDir          []string
	MongoDatabaseURI string
	MongoDBUserName  string
	MongoDBPassword  string
	MongoDBName      string
}

type MongoDbService

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

MongoDbService for MongoDb

func NewMongoDbService

func NewMongoDbService(ctx context.Context, cfg *Config) (*MongoDbService, error)

NewMongoDbService creates a service to interact with MongoDb

func (*MongoDbService) InsertRawRequest

func (c *MongoDbService) InsertRawRequest(requestType, verb, kind string, body []byte) error