infrastructure

Documentation

Index

• type MongoConnections
• type MongoStatus
• type Repository
  • func NewRepository(db *mongo.Database, logger *zap.Logger) *Repository
  • func (r *Repository) GetMongoStatus(ctx context.Context) (*MongoStatus, error)
• type Service
  • func NewService(dao *Repository, logger *zap.Logger) *Service
  • func (s *Service) CheckMongoServerStatus(ctx context.Context) (bool, error)

Types

type MongoConnections

type MongoConnections struct {
	Current      int32 `bson:"current"`
	Available    int32 `bson:"available"`
	TotalCreated int32 `bson:"totalCreated"`
}

MongoConnections represents a mongo server connection.

type MongoStatus

type MongoStatus struct {
	Ok          int32             `bson:"ok"`
	Host        string            `bson:"host"`
	Version     string            `bson:"version"`
	Process     string            `bson:"process"`
	Pid         int32             `bson:"pid"`
	Uptime      int32             `bson:"uptime"`
	Connections *MongoConnections `bson:"connections"`
}

MongoStatus represent a mongo server status.

type Repository

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

Repository definition.

func NewRepository

func NewRepository(db *mongo.Database, logger *zap.Logger) *Repository

NewRepository create a new Repository.

func (*Repository) GetMongoStatus

func (r *Repository) GetMongoStatus(ctx context.Context) (*MongoStatus, error)

GetMongoStatus get mongo server status

type Service

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

func NewService

func NewService(dao *Repository, logger *zap.Logger) *Service

NewService create a new governor.Service.

func (*Service) CheckMongoServerStatus

func (s *Service) CheckMongoServerStatus(ctx context.Context) (bool, error)

CheckMongoServerStatus