Documentation
¶
Index ¶
- func NewMongoDB(logger logger.Logger) bindings.OutputBinding
- type MongoDBOperations
- func (mongoOps *MongoDBOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, ...) (string, error)
- func (mongoOps *MongoDBOperations) GetRoleOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
- func (mongoOps *MongoDBOperations) GetRunningPort() int
- func (mongoOps *MongoDBOperations) Init(metadata bindings.Metadata) error
- func (mongoOps *MongoDBOperations) InitDelay() error
- func (mongoOps *MongoDBOperations) Ping() error
- func (mongoOps *MongoDBOperations) StatusCheck(ctx context.Context, cmd string, response *bindings.InvokeResponse) (OpsResult, error)
- type OpTime
- type ReplSetGetStatus
- type ReplSetMember
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMongoDB ¶
func NewMongoDB(logger logger.Logger) bindings.OutputBinding
NewMongoDB returns a new MongoDB Binding
Types ¶
type MongoDBOperations ¶
type MongoDBOperations struct {
BaseOperations
// contains filtered or unexported fields
}
MongoDBOperations is a binding implementation for MongoDB.
func (*MongoDBOperations) GetRole ¶
func (mongoOps *MongoDBOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, response *bindings.InvokeResponse) (string, error)
func (*MongoDBOperations) GetRoleOps ¶
func (mongoOps *MongoDBOperations) GetRoleOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)
func (*MongoDBOperations) GetRunningPort ¶
func (mongoOps *MongoDBOperations) GetRunningPort() int
func (*MongoDBOperations) Init ¶
func (mongoOps *MongoDBOperations) Init(metadata bindings.Metadata) error
Init initializes the MongoDB Binding.
func (*MongoDBOperations) InitDelay ¶
func (mongoOps *MongoDBOperations) InitDelay() error
func (*MongoDBOperations) Ping ¶
func (mongoOps *MongoDBOperations) Ping() error
func (*MongoDBOperations) StatusCheck ¶
func (mongoOps *MongoDBOperations) StatusCheck(ctx context.Context, cmd string, response *bindings.InvokeResponse) (OpsResult, error)
type ReplSetGetStatus ¶
type ReplSetMember ¶
type ReplSetMember struct {
ID int64 `bson:"_id"`
Name string `bson:"name"`
Health int64 `bson:"health"`
State int64 `bson:"state"`
StateStr string `bson:"stateStr"`
Uptime int64 `bson:"uptime"`
Optime *OpTime `bson:"optime"`
OptimeDate time.Time `bson:"optimeDate"`
OptimeDurableDate time.Time `bson:"optimeDurableDate"`
LastAppliedWallTime time.Time `bson:"lastAppliedWallTime"`
LastDurableWallTime time.Time `bson:"lastDurableWallTime"`
LastHeartbeatMessage string `bson:"lastHeartbeatMessage"`
SyncSourceHost string `bson:"syncSourceHost"`
SyncSourceID int64 `bson:"syncSourceId"`
InfoMessage string `bson:"infoMessage"`
ElectionTime primitive.Timestamp `bson:"electionTime"`
ElectionDate time.Time `bson:"electionDate"`
ConfigVersion int64 `bson:"configVersion"`
ConfigTerm int64 `bson:"configTerm"`
Self bool `bson:"self"`
}
Click to show internal directories.
Click to hide internal directories.