handlers

Documentation

Index

• Constants
• Variables
• func CollectionStatsHandler(s Session, params map[string]string) (interface{}, error)
• func CollectionsDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)
• func CollectionsUsageHandler(s Session, _ map[string]string) (interface{}, error)
• func ConfigDiscoveryHandler(s Session, params map[string]string) (interface{}, error)
• func ConnPoolStatsHandler(s Session, params map[string]string) (interface{}, error)
• func DatabaseStatsHandler(s Session, params map[string]string) (interface{}, error)
• func DatabasesDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)
• func JumboChunksHandler(s Session, _ map[string]string) (interface{}, error)
• func OplogStatsHandler(s Session, _ map[string]string) (any, error)
• func PingHandler(s Session, _ map[string]string) (interface{}, error)
• func ReplSetConfigHandler(s Session, _ map[string]string) (interface{}, error)
• func ReplSetStatusHandler(s Session, _ map[string]string) (interface{}, error)
• func ServerStatusHandler(s Session, _ map[string]string) (interface{}, error)
• func ShardsDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)
• func VersionHandler(s Session, _ map[string]string) (any, error)
• type Collection
• type Database
• type Member
• type MockConn
  • func NewMockConn() *MockConn
  • func (conn *MockConn) DB(name string) Database
  • func (conn *MockConn) DatabaseNames() (names []string, err error)
  • func (conn *MockConn) GetMaxTimeMS() int64
  • func (conn *MockConn) Ping() error
• type MockMongoCollection
  • func (c *MockMongoCollection) Find(query interface{}, opts ...*options.FindOptions) (q Query, err error)
  • func (c *MockMongoCollection) FindOne(query interface{}, opts ...*options.FindOneOptions) Query
• type MockMongoDatabase
  • func (d *MockMongoDatabase) C(name string) Collection
  • func (d *MockMongoDatabase) CollectionNames() (names []string, err error)
  • func (d *MockMongoDatabase) Run(cmd, result interface{}) error
• type MockMongoQuery
  • func (q *MockMongoQuery) Count() (n int, err error)
  • func (q *MockMongoQuery) Get(result interface{}) error
  • func (q *MockMongoQuery) GetSingle(result interface{}) error
• type MockSession
• type Query
• type Session

Constants

const (
	PingFailed = 0
	PingOk     = 1
)

Variables

var Logger log.Logger

var UriDefaults = &uri.Defaults{Scheme: "tcp", Port: "27017"}

Functions

func CollectionStatsHandler

func CollectionStatsHandler(s Session, params map[string]string) (interface{}, error)

CollectionStatsHandler https://docs.mongodb.com/manual/reference/command/collStats/index.html

func CollectionsDiscoveryHandler

func CollectionsDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)

CollectionsDiscoveryHandler https://docs.mongodb.com/manual/reference/command/listDatabases/

func CollectionsUsageHandler

func CollectionsUsageHandler(s Session, _ map[string]string) (interface{}, error)

CollectionsUsageHandler https://docs.mongodb.com/manual/reference/command/top/index.html

func ConfigDiscoveryHandler

func ConfigDiscoveryHandler(s Session, params map[string]string) (interface{}, error)

ConfigDiscoveryHandler https://docs.mongodb.com/manual/reference/command/getShardMap/#dbcmd.getShardMap

func ConnPoolStatsHandler

func ConnPoolStatsHandler(s Session, params map[string]string) (interface{}, error)

ConnPoolStatsHandler https://docs.mongodb.com/manual/reference/command/connPoolStats/#dbcmd.connPoolStats

func DatabaseStatsHandler

func DatabaseStatsHandler(s Session, params map[string]string) (interface{}, error)

DatabaseStatsHandler https://docs.mongodb.com/manual/reference/command/dbStats/index.html

func DatabasesDiscoveryHandler

func DatabasesDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)

DatabasesDiscoveryHandler https://docs.mongodb.com/manual/reference/command/listDatabases/

func JumboChunksHandler

func JumboChunksHandler(s Session, _ map[string]string) (interface{}, error)

JumboChunksHandler https://docs.mongodb.com/manual/core/sharding-data-partitioning/#indivisible-jumbo-chunks

func OplogStatsHandler

func OplogStatsHandler(s Session, _ map[string]string) (any, error)

OplogStatsHandler https://docs.mongodb.com/manual/reference/method/db.getReplicationInfo/index.html

func PingHandler

func PingHandler(s Session, _ map[string]string) (interface{}, error)

PingHandler executes 'ping' command and returns pingOk if a connection is alive or pingFailed otherwise. https://docs.mongodb.com/manual/reference/command/ping/index.html

func ReplSetConfigHandler

func ReplSetConfigHandler(s Session, _ map[string]string) (interface{}, error)

ReplSetConfigHandler https://docs.mongodb.com/manual/reference/command/replSetGetConfig/index.html

func ReplSetStatusHandler

func ReplSetStatusHandler(s Session, _ map[string]string) (interface{}, error)

ReplSetStatusHandler https://docs.mongodb.com/manual/reference/command/replSetGetStatus/index.html

func ServerStatusHandler

func ServerStatusHandler(s Session, _ map[string]string) (interface{}, error)

ServerStatusHandler https://docs.mongodb.com/manual/reference/command/serverStatus/#dbcmd.serverStatus

func ShardsDiscoveryHandler

func ShardsDiscoveryHandler(s Session, _ map[string]string) (interface{}, error)

ShardsDiscoveryHandler https://docs.mongodb.com/manual/reference/method/sh.status/#sh.status

func VersionHandler

func VersionHandler(s Session, _ map[string]string) (any, error)

VersionHandler executes 'buildInfo' command extracting and returning version info from the response.

Types

type Collection

type Collection interface {
	Find(query interface{}, opts ...*options.FindOptions) (q Query, err error)
	FindOne(query interface{}, opts ...*options.FindOneOptions) Query
}

type Database

type Database interface {
	C(name string) Collection
	CollectionNames() (names []string, err error)
	Run(cmd, result interface{}) error
}

type Member

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

type MockConn

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

func NewMockConn

func NewMockConn() *MockConn

func (*MockConn) DB

func (conn *MockConn) DB(name string) Database

func (*MockConn) DatabaseNames

func (conn *MockConn) DatabaseNames() (names []string, err error)

func (*MockConn) GetMaxTimeMS

func (conn *MockConn) GetMaxTimeMS() int64

func (*MockConn) Ping

func (conn *MockConn) Ping() error

type MockMongoCollection

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

func (*MockMongoCollection) Find

func (c *MockMongoCollection) Find(query interface{}, opts ...*options.FindOptions) (q Query, err error)

func (*MockMongoCollection) FindOne

func (c *MockMongoCollection) FindOne(query interface{}, opts ...*options.FindOneOptions) Query

type MockMongoDatabase

type MockMongoDatabase struct {
	RunFunc func(dbName, cmd string) ([]byte, error)
	// contains filtered or unexported fields
}

func (*MockMongoDatabase) C

func (d *MockMongoDatabase) C(name string) Collection

func (*MockMongoDatabase) CollectionNames

func (d *MockMongoDatabase) CollectionNames() (names []string, err error)

func (*MockMongoDatabase) Run

func (d *MockMongoDatabase) Run(cmd, result interface{}) error

type MockMongoQuery

type MockMongoQuery struct {
	DataFunc func() ([]byte, error)
	// contains filtered or unexported fields
}

func (*MockMongoQuery) Count

func (q *MockMongoQuery) Count() (n int, err error)

func (*MockMongoQuery) Get

func (q *MockMongoQuery) Get(result interface{}) error

func (*MockMongoQuery) GetSingle

func (q *MockMongoQuery) GetSingle(result interface{}) error

type MockSession

type MockSession interface {
	DB(name string) Database
	DatabaseNames() (names []string, err error)
	GetMaxTimeMS() int64
	Ping() error
}

type Query

type Query interface {
	Count() (n int, err error)
	Get(result interface{}) error
	GetSingle(result interface{}) error
}

type Session

type Session interface {
	DB(name string) Database
	DatabaseNames() (names []string, err error)
	GetMaxTimeMS() int64
	Ping() error
}

Session is an interface to access to the session struct.