mongodb

Documentation

Index

• type ExecArgs
• type MetricsRecorder
• type Model
• type OperationType
• type Raw
  • func (r *Raw) Convert() *ExecArgs

Types

type ExecArgs

type ExecArgs struct {
	Document  bson.M
	Operation OperationType
}

type MetricsRecorder

type MetricsRecorder interface {
	RecordUpdateSuccess(collection string, count int64)
	RecordUpdateError(collection string, count int64)
	RecordDeleteSuccess(collection string, count int64)
	RecordDeleteError(collection string, count int64)
	RecordProcessLatency(latencyMs int64)
	RecordBulkRequestProcessLatency(latencyMs int64)
}

type Model

type Model interface {
	Convert() *ExecArgs
}

type OperationType

type OperationType string

const (
	Insert OperationType = "insert"
	Update OperationType = "update"
	Delete OperationType = "delete"
	Upsert OperationType = "upsert"
)

type Raw

type Raw struct {
	ID              string
	Document        bson.M
	Operation       OperationType
	MongoCollection string
}

func (*Raw) Convert

func (r *Raw) Convert() *ExecArgs