mongomodule

Documentation

Index

• type DialContext
  • func (c *DialContext) Close()
  • func (c *DialContext) Ref() *Session
  • func (c *DialContext) UnRef(s *Session)
• type MongoModule
  • func (slf *MongoModule) Init(url string, sessionNum uint32, dialTimeout time.Duration, ...) error
  • func (slf *MongoModule) Ref() *Session
  • func (slf *MongoModule) UnRef(s *Session)
• type Session
  • func (s *Session) EnsureCounter(db string, collection string, id string) error
  • func (s *Session) EnsureIndex(db string, collection string, key []string, bBackground bool) error
  • func (s *Session) EnsureUniqueIndex(db string, collection string, key []string, bBackground bool) error
  • func (s *Session) NextSeq(db string, collection string, id string) (int, error)
• type SessionHeap
  • func (h SessionHeap) Len() int
  • func (h SessionHeap) Less(i, j int) bool
  • func (h *SessionHeap) Pop() interface{}
  • func (h *SessionHeap) Push(s interface{})
  • func (h SessionHeap) Swap(i, j int)

Types

type DialContext

type DialContext struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*DialContext) Close

func (c *DialContext) Close()

goroutine safe

func (*DialContext) Ref

func (c *DialContext) Ref() *Session

goroutine safe

func (*DialContext) UnRef

func (c *DialContext) UnRef(s *Session)

goroutine safe

type MongoModule

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

func (*MongoModule) Init

func (slf *MongoModule) Init(url string, sessionNum uint32, dialTimeout time.Duration, timeout time.Duration) error

func (*MongoModule) Ref

func (slf *MongoModule) Ref() *Session

func (*MongoModule) UnRef

func (slf *MongoModule) UnRef(s *Session)

type Session

type Session struct {
	*mgo.Session
	// contains filtered or unexported fields
}

session

func (*Session) EnsureCounter

func (s *Session) EnsureCounter(db string, collection string, id string) error

goroutine safe

func (*Session) EnsureIndex

func (s *Session) EnsureIndex(db string, collection string, key []string, bBackground bool) error

goroutine safe

func (*Session) EnsureUniqueIndex

func (s *Session) EnsureUniqueIndex(db string, collection string, key []string, bBackground bool) error

goroutine safe

func (*Session) NextSeq

func (s *Session) NextSeq(db string, collection string, id string) (int, error)

goroutine safe

type SessionHeap

type SessionHeap []*Session

func (SessionHeap) Len

func (h SessionHeap) Len() int

func (SessionHeap) Less

func (h SessionHeap) Less(i, j int) bool

func (*SessionHeap) Pop

func (h *SessionHeap) Pop() interface{}

func (*SessionHeap) Push

func (h *SessionHeap) Push(s interface{})

func (SessionHeap) Swap

func (h SessionHeap) Swap(i, j int)