mongodb

Documentation

Overview

Package mongodb

Index

• Constants
• type Config
  • func NewConfig() (Config, error)
• type ErrNotConfigured
  • func (err ErrNotConfigured) Error() string
  • func (err ErrNotConfigured) Is(target error) bool
• type ErrNotSupported
  • func (err ErrNotSupported) Error() string
• type MongoClient
  • func New(ctx context.Context) (MongoClient, error)
  • func (m MongoClient) Close(ctx context.Context) error
  • func (m MongoClient) CreateMission(ctx context.Context, name string, description string, ...) error
  • func (m MongoClient) GetValues(ctx context.Context, id string) ([]map[string]interface{}, error)
  • func (m MongoClient) ListMissions(ctx context.Context) ([]map[string]string, error)
  • func (m MongoClient) MissionInfo(context.Context, string) (map[string]interface{}, error)
  • func (m MongoClient) Save(ctx context.Context, document map[string]interface{}) error
  • func (m MongoClient) UpdateMission(context.Context, string, string) error

Constants

const (
	EnvMongoDBHost     = "MONGODB_HOST"
	EnvMongoDBPort     = "MONGODB_PORT"
	EnvMongoDB         = "MONGODB_DATABASE"
	EnvMongoDBUsername = "MONGODB_USERNAME"
	EnvMongoDBPassword = "MONGODB_PASSWORD"
)

Constants containing names of ENV variables

const (
	ConnectionString       = `mongodb://{{.Username}}:{{.Password}}@{{.Host}}:{{.Port}}`
	DefaultMongoDBDatabase = "sat-dev"
	DefaultMongoDBHost     = "mongo"
	DefaultMongoDBPort     = "27017"
)

Types

type Config

type Config struct {
	Host     string
	Port     string
	Username string
	Password string
}

func NewConfig

func NewConfig() (Config, error)

type ErrNotConfigured

type ErrNotConfigured struct {
	What string
}

func (ErrNotConfigured) Error

func (err ErrNotConfigured) Error() string

func (ErrNotConfigured) Is

func (err ErrNotConfigured) Is(target error) bool

type ErrNotSupported

type ErrNotSupported struct {
	Backend string
}

func (ErrNotSupported) Error

func (err ErrNotSupported) Error() string

type MongoClient

type MongoClient struct {
	Client *mongo.Client
	// contains filtered or unexported fields
}

MongoClient

func New

func New(ctx context.Context) (MongoClient, error)

New

func (MongoClient) Close

func (m MongoClient) Close(ctx context.Context) error

Close

func (MongoClient) CreateMission

func (m MongoClient) CreateMission(ctx context.Context, name string, description string, columns map[string]string) error

func (MongoClient) GetValues

func (m MongoClient) GetValues(ctx context.Context, id string) ([]map[string]interface{}, error)

func (MongoClient) ListMissions

func (m MongoClient) ListMissions(ctx context.Context) ([]map[string]string, error)

func (MongoClient) MissionInfo

func (m MongoClient) MissionInfo(context.Context, string) (map[string]interface{}, error)

func (MongoClient) Save

func (m MongoClient) Save(ctx context.Context, document map[string]interface{}) error

Save

func (MongoClient) UpdateMission

func (m MongoClient) UpdateMission(context.Context, string, string) error