mongodb

Documentation

Index

• type MongoDBOperations
  • func NewMongoDB() *MongoDBOperations
  • func (mongoOps *MongoDBOperations) GetLogger() logr.Logger
  • func (mongoOps *MongoDBOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (mongoOps *MongoDBOperations) GetRunningPort() int
  • func (mongoOps *MongoDBOperations) Init(properties component.Properties) error
  • func (mongoOps *MongoDBOperations) InternalExec(ctx context.Context, sql string) (int64, error)
  • func (mongoOps *MongoDBOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)
  • func (mongoOps *MongoDBOperations) LockInstance(ctx context.Context) error

Types

type MongoDBOperations

type MongoDBOperations struct {
	BaseOperations
	// contains filtered or unexported fields
}

MongoDBOperations is a binding implementation for MongoDB.

func NewMongoDB

func NewMongoDB() *MongoDBOperations

NewMongoDB returns a new MongoDB Binding

func (*MongoDBOperations) GetLogger

func (mongoOps *MongoDBOperations) GetLogger() logr.Logger

func (*MongoDBOperations) GetRole

func (mongoOps *MongoDBOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*MongoDBOperations) GetRunningPort

func (mongoOps *MongoDBOperations) GetRunningPort() int

func (*MongoDBOperations) Init

func (mongoOps *MongoDBOperations) Init(properties component.Properties) error

Init initializes the MongoDB Binding.

func (*MongoDBOperations) InternalExec

func (mongoOps *MongoDBOperations) InternalExec(ctx context.Context, sql string) (int64, error)

func (*MongoDBOperations) InternalQuery

func (mongoOps *MongoDBOperations) InternalQuery(ctx context.Context, sql string) ([]byte, error)

func (*MongoDBOperations) LockInstance

func (mongoOps *MongoDBOperations) LockInstance(ctx context.Context) error