build

Documentation

Index

• Constants
• func GetNowStr(isClient bool) string
• func ReadBson2Json(r io.Reader) string
• func ReadInt32(r io.Reader) (n int32)
• func ReadInt64(r io.Reader) int64
• func ReadString(r io.Reader) string
• type Mongodb
  • func NewInstance() *Mongodb
  • func (m *Mongodb) BPFFilter() string
  • func (m *Mongodb) ResolveStream(net, transport gopacket.Flow, buf io.Reader)
  • func (m *Mongodb) SetFlag(flg []string)
  • func (m *Mongodb) Version() string

Constants

const (
	OP_REPLY  = 1    //Reply to a client request. responseTo is set.
	OP_UPDATE = 2001 //Update document.
	OP_INSERT = 2002 //Insert new document.
	RESERVED  = 2003 //Formerly used for OP_GET_BY_OID.

	OP_QUERY        = 2004 //Query a collection.
	OP_GET_MORE     = 2005 //Get more data from a query. See Cursors.
	OP_DELETE       = 2006 //Delete documents.
	OP_KILL_CURSORS = 2007 //Notify database that the client has finished with the cursor.

	OP_COMMAND      = 2010 //Cluster internal protocol representing a command request.
	OP_COMMANDREPLY = 2011 //Cluster internal protocol representing a reply to an OP_COMMAND.
	OP_MSG          = 2013 //Send a message using the format introduced in MongoDB 3.6.
)

const (
	Port    = 27017
	Version = "0.1"
	CmdPort = "-p"
)

Functions

func GetNowStr

func GetNowStr(isClient bool) string

func ReadBson2Json

func ReadBson2Json(r io.Reader) string

func ReadInt32

func ReadInt32(r io.Reader) (n int32)

func ReadInt64

func ReadInt64(r io.Reader) int64

func ReadString

func ReadString(r io.Reader) string

Types

type Mongodb

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

func NewInstance

func NewInstance() *Mongodb

func (*Mongodb) BPFFilter

func (m *Mongodb) BPFFilter() string

func (*Mongodb) ResolveStream

func (m *Mongodb) ResolveStream(net, transport gopacket.Flow, buf io.Reader)

func (*Mongodb) SetFlag

func (m *Mongodb) SetFlag(flg []string)

func (*Mongodb) Version

func (m *Mongodb) Version() string