mongo

Documentation

Index

• type Credentials
• type MongoAtlasClientNamespace
  • func (x *MongoAtlasClientNamespace) New(apiEndpoint string, publicKey string, privateKey string) MongoAtlasClienter
• type MongoAtlasClientNamespacer
• type MongoAtlasClienter
• type MongoClientNamespace
  • func (x *MongoClientNamespace) NewClient(opts ...*options.ClientOptions) (MongoClienter, error)
• type MongoClientNamespacer
• type MongoClienter
• type MongoCloudProvider
• type MongoData
• type MongoExtension
  • func (x *MongoExtension) Description() string
  • func (x *MongoExtension) Process(e transistor.Event) error
  • func (x *MongoExtension) SampleConfig() string
  • func (x *MongoExtension) Start(e chan transistor.Event) error
  • func (x *MongoExtension) Stop()
  • func (x *MongoExtension) Subscribe() []string

Types

type Credentials

type Credentials struct {
	Username string
	Password string
}

type MongoAtlasClientNamespace

type MongoAtlasClientNamespace struct {
}

func (*MongoAtlasClientNamespace) New

func (x *MongoAtlasClientNamespace) New(apiEndpoint string, publicKey string, privateKey string) MongoAtlasClienter

type MongoAtlasClientNamespacer

type MongoAtlasClientNamespacer interface {
	New(string, string, string) MongoAtlasClienter
}

type MongoAtlasClienter

type MongoAtlasClienter interface {
	GetDatabaseUsers(context.Context, string) (*atlas_models.GetDatabaseUsersResponse, error)
	GetDatabaseUser(context.Context, *atlas_models.GetDatabaseUserInput) (*atlas_models.DatabaseUser, error)

	CreateDatabaseUser(context.Context, *atlas_models.CreateDatabaseUserInput) (*atlas_models.DatabaseUser, error)
	DeleteDatabaseUser(context.Context, *atlas_models.DeleteDatabaseUserInput) error
}

type MongoClientNamespace

type MongoClientNamespace struct {
}

func (*MongoClientNamespace) NewClient

func (x *MongoClientNamespace) NewClient(opts ...*options.ClientOptions) (MongoClienter, error)

type MongoClientNamespacer

type MongoClientNamespacer interface {
	NewClient(...*options.ClientOptions) (MongoClienter, error)
}

type MongoClienter

type MongoClienter interface {
	Connect(context.Context) error
	Ping(context.Context, *readpref.ReadPref) error
	ListDatabaseNames(context.Context, interface{}, ...*options.ListDatabasesOptions) ([]string, error)
}

type MongoCloudProvider

type MongoCloudProvider struct {
	APIEndpoint string
	APIKey      string
	PublicKey   string
	ProjectID   string
	Timeout     int
}

type MongoData

type MongoData struct {
	Hostname                string
	Atlas                   MongoCloudProvider
	CredentialsCheckTimeout int
}

type MongoExtension

type MongoExtension struct {
	MongoAtlasClientNamespacer
	MongoClientNamespacer
	// contains filtered or unexported fields
}

func (*MongoExtension) Description

func (x *MongoExtension) Description() string

func (*MongoExtension) Process

func (x *MongoExtension) Process(e transistor.Event) error

How does this work? The artifacts that should be returned after a Mongo extension is successfuly created should be the credentials for which the project will be using to access the bucket, as well as the prefix that has been assigned for this application to use in addition to the region the bucket is in

Accepts:

	mongo_atlas_endpoint
	mongo_atlas_api_public_key
	mongo_atlas_api_private_key
	mongo_atlas_project_id
 mongo_atlas_api_timeout

 mongo_hostname
 mongo_credentials_check_timeout

func (*MongoExtension) SampleConfig

func (x *MongoExtension) SampleConfig() string

func (*MongoExtension) Start

func (x *MongoExtension) Start(e chan transistor.Event) error

func (*MongoExtension) Stop

func (x *MongoExtension) Stop()

func (*MongoExtension) Subscribe

func (x *MongoExtension) Subscribe() []string