internal

Documentation

Index

• type MongoDBAtlasClient
  • func NewMongoDBAtlasClient(publicKey string, privateKey string, ...) (*MongoDBAtlasClient, error)
  • func (s *MongoDBAtlasClient) Organizations(ctx context.Context) ([]*mongodbatlas.Organization, error)
  • func (s *MongoDBAtlasClient) ProcessDatabaseMetrics(ctx context.Context, resource pdata.Resource, projectID string, host string, ...) (pdata.Metrics, error)
  • func (s *MongoDBAtlasClient) ProcessDatabases(ctx context.Context, projectID string, host string, port int) ([]*mongodbatlas.ProcessDatabase, error)
  • func (s *MongoDBAtlasClient) ProcessDiskMetrics(ctx context.Context, resource pdata.Resource, projectID string, host string, ...) (pdata.Metrics, error)
  • func (s *MongoDBAtlasClient) ProcessDisks(ctx context.Context, projectID string, host string, port int) []*mongodbatlas.ProcessDisk
  • func (s *MongoDBAtlasClient) ProcessMetrics(ctx context.Context, resource pdata.Resource, projectID string, host string, ...) (pdata.Metrics, error)
  • func (s *MongoDBAtlasClient) Processes(ctx context.Context, projectID string) ([]*mongodbatlas.Process, error)
  • func (s *MongoDBAtlasClient) Projects(ctx context.Context, orgID string) ([]*mongodbatlas.Project, error)
  • func (s *MongoDBAtlasClient) Shutdown() error

Types

type MongoDBAtlasClient

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

MongoDBAtlasClient wraps the official MongoDB Atlas client to manage pagination and mapping to OpenTelmetry metric and log structures.

func NewMongoDBAtlasClient

func NewMongoDBAtlasClient(
	publicKey string,
	privateKey string,
	retrySettings exporterhelper.RetrySettings,
	log *zap.Logger,
) (*MongoDBAtlasClient, error)

NewMongoDBAtlasClient creates a new MongoDB Atlas client wrapper

func (*MongoDBAtlasClient) Organizations

func (s *MongoDBAtlasClient) Organizations(ctx context.Context) ([]*mongodbatlas.Organization, error)

Organizations returns a list of all organizations available with the supplied credentials

func (*MongoDBAtlasClient) ProcessDatabaseMetrics

func (s *MongoDBAtlasClient) ProcessDatabaseMetrics(
	ctx context.Context,
	resource pdata.Resource,
	projectID string,
	host string,
	port int,
	dbname string,
	start string,
	end string,
	resolution string,
) (pdata.Metrics, error)

ProcessDatabaseMetrics returns metrics about a particular database running within a MongoDB Atlas process

func (*MongoDBAtlasClient) ProcessDatabases

func (s *MongoDBAtlasClient) ProcessDatabases(
	ctx context.Context,
	projectID string,
	host string,
	port int,
) ([]*mongodbatlas.ProcessDatabase, error)

ProcessDatabases lists databases that are running in a given MongoDB Atlas process

func (*MongoDBAtlasClient) ProcessDiskMetrics

func (s *MongoDBAtlasClient) ProcessDiskMetrics(
	ctx context.Context,
	resource pdata.Resource,
	projectID string,
	host string,
	port int,
	partitionName string,
	start string,
	end string,
	resolution string,
) (pdata.Metrics, error)

ProcessDiskMetrics returns metrics supplied for a particular disk partition used by a MongoDB Atlas process

func (*MongoDBAtlasClient) ProcessDisks

func (s *MongoDBAtlasClient) ProcessDisks(
	ctx context.Context,
	projectID string,
	host string,
	port int,
) []*mongodbatlas.ProcessDisk

ProcessDisks enumerates the disks accessible to a specified MongoDB Atlas process

func (*MongoDBAtlasClient) ProcessMetrics

func (s *MongoDBAtlasClient) ProcessMetrics(
	ctx context.Context,
	resource pdata.Resource,
	projectID string,
	host string,
	port int,
	start string,
	end string,
	resolution string,
) (pdata.Metrics, error)

ProcessMetrics returns a set of metrics associated with the specified running process.

func (*MongoDBAtlasClient) Processes

func (s *MongoDBAtlasClient) Processes(
	ctx context.Context,
	projectID string,
) ([]*mongodbatlas.Process, error)

Processes returns the list of processes running for a given project.

func (*MongoDBAtlasClient) Projects

func (s *MongoDBAtlasClient) Projects(
	ctx context.Context,
	orgID string,
) ([]*mongodbatlas.Project, error)

Projects returns a list of projects accessible within the provided organization

func (*MongoDBAtlasClient) Shutdown

func (s *MongoDBAtlasClient) Shutdown() error