mongo

package

Go to main page

Versions in this module

v1

v1.2.2

Dec 28, 2024

Changes in this version

+ type CertConfig interface

+ SetClientAuthType func(authType tls.ClientAuthType)

+ SetRootCertFiles func(files ...string) error

+ SetRootCerts func(certs ...[]byte)

+ SetServerCert func(cert []byte)

+ SetServerCertFile func(file string) error

+ SetServerKey func(key []byte)

+ SetServerKeyFile func(file string) error

+ SetTLSConfig func(tlsConfig *tls.Config)

+ TLSConfig func() (*tls.Config, error)

type Config

+ Address func() string

+ Port func() int

+ SetAddress func(addr string)

+ SetPort func(port int)

type Server

+ Config func() Config

+ SetAuthCommandExecutor func(fn AuthCommandExecutor)

+ SetDatabaseCommandExecutor func(fn DatabaseCommandExecutor)

+ SetUserCommandExecutor func(fn UserCommandExecutor)

+ type TLSConfig interface

+ IsTLSEnabled func() bool

+ SetTLSEnabled func(enabled bool)

v1.2.1

Sep 18, 2024

Changes in this version

type AuthCommandExecutor

+ SASLContinue func(*Conn, *Command) (bson.Document, error)

+ SASLStart func(*Conn, *Command) (bson.Document, error)

+ SASLSupportedMechs func(*Conn, string) ([]sasl.SASLMechanism, error)

type BaseCommandExecutor

+ func (executor *BaseCommandExecutor) BuildInfo(conn *Conn, cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) GetLastError(conn *Conn, cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) Hello(conn *Conn, cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) SASLContinue(*Conn, *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) SASLStart(conn *Conn, cmd *Command) (bson.Document, error)

type DiagnosticCommandExecutor

+ BuildInfo func(*Conn, *Command) (bson.Document, error)

+ type MessageResponse = message.Response

type ReplicationCommandExecutor

+ Hello func(*Conn, *Command) (bson.Document, error)

type Server

+ func (server *Server) BuildInfo(conn *Conn, cmd *Command) (bson.Document, error)

+ func (server *Server) Hello(conn *Conn, cmd *Command) (bson.Document, error)

+ func (server *Server) SASLContinue(conn *Conn, cmd *Command) (bson.Document, error)

+ func (server *Server) SASLStart(conn *Conn, cmd *Command) (bson.Document, error)

+ func (server *Server) SASLSupportedMechs(*Conn, string) ([]sasl.SASLMechanism, error)

type WriteOperationExecutor

+ GetLastError func(*Conn, *Command) (bson.Document, error)

v1.2.0

Aug 22, 2024

Changes in this version

+ var ErrCommand = errors.New("invalid command")

+ func NewErrorCommand(cmd *Command) error

type AuthCommandExecutor

+ ExecuteSaslContinue func(*Conn, *Command) (bson.Document, error)

type BaseCommandExecutor

+ func (executor *BaseCommandExecutor) ExecuteSaslContinue(*Conn, *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) SetAuthCommandExecutor(fn AuthCommandExecutor)

type Conn

+ func (conn *Conn) SASLContext() sasl.Context

+ func (conn *Conn) SetSASLContext(saslContext sasl.Context)

type Server

+ func (server *Server) ExecuteSaslContinue(conn *Conn, cmd *Command) (bson.Document, error)

+ func (server *Server) ExecuteSaslStart(conn *Conn, cmd *Command) (bson.Document, error)

v1.1.4

Jun 28, 2024

Changes in this version

type Config

+ func (config *Config) IsAuthrizationEnabled() bool

+ func (config *Config) SetAuthrizationEnabled(authorized bool)

type Conn

+ func (conn *Conn) Close() error

+ func (conn *Conn) UUID() uuid.UUID

+ type ConnManager struct

+ func NewConnManager() *ConnManager

+ func (mgr *ConnManager) AddConn(c *Conn)

+ func (mgr *ConnManager) Close() error

+ func (mgr *ConnManager) ConnByUUID(uuid uuid.UUID) (*Conn, bool)

+ func (mgr *ConnManager) Conns() []*Conn

+ func (mgr *ConnManager) RemoveConn(conn *Conn) error

+ func (mgr *ConnManager) Start() error

+ func (mgr *ConnManager) Stop() error

v1.1.3

May 25, 2024

Changes in this version

type Conn

+ func (conn *Conn) IsTLSConnection() bool

+ func (conn *Conn) TLSConnectionState() (*tls.ConnectionState, bool)

v1.1.2

May 21, 2024

v1.1.1

May 20, 2024

v1.1.0

May 19, 2024

Changes in this version

+ type AuthCommandExecutor interface

+ ExecuteSaslStart func(*Conn, *Command) (bson.Document, error)

type BaseCommandExecutor

+ func (executor *BaseCommandExecutor) ExecuteSaslStart(conn *Conn, cmd *Command) (bson.Document, error)

type Config

+ func (config *Config) Compressions() []string

+ func (config *Config) IsAuthrized() bool

+ func (config *Config) IsReadOnly() bool

+ func (config *Config) LogicalSessionTimeoutMinutes() int32

+ func (config *Config) MaxBsonObjectSize() int32

+ func (config *Config) MaxMessageSizeBytes() int32

+ func (config *Config) MaxWireVersion() int32

+ func (config *Config) MaxWriteBatchSize() int32

+ func (config *Config) MinWireVersion() int32

+ func (config *Config) SetAuthrization(authorized bool)

+ func (config *Config) Version() string

type Conn

+ func (conn *Conn) IsAuthrized() bool

+ func (conn *Conn) SetAuthrized(authrized bool)

+ type TLSConf struct

+ ClientAuthType tls.ClientAuthType

+ RootCerts [][]byte

+ ServerCert []byte

+ ServerKey []byte

+ func NewTLSConf() *TLSConf

+ func (config *TLSConf) IsTLSEnabled() bool

+ func (config *TLSConf) SetClientAuthType(authType tls.ClientAuthType)

+ func (config *TLSConf) SetRootCertFiles(files ...string) error

+ func (config *TLSConf) SetRootCerts(certs ...[]byte)

+ func (config *TLSConf) SetServerCert(cert []byte)

+ func (config *TLSConf) SetServerCertFile(file string) error

+ func (config *TLSConf) SetServerKey(key []byte)

+ func (config *TLSConf) SetServerKeyFile(file string) error

+ func (config *TLSConf) SetTLSConfig(tlsConfig *tls.Config)

+ func (config *TLSConf) SetTLSEnabled(enabled bool)

+ func (config *TLSConf) TLSConfig() (*tls.Config, error)

v1.0.2

May 4, 2023

v1.0.1

May 4, 2023

Changes in this version

type Conn

+ func (conn *Conn) SetSpanContext(span tracer.SpanContext)

+ func (conn *Conn) SpanContext() tracer.SpanContext

v1.0.0

May 3, 2023

Changes in this version

type Server

+ func (server *Server) GetAddress() string

+ func (server *Server) SetAddress(addr string)

v0

v0.9.5

Apr 23, 2023

Changes in this version

type Server

+ func (server *Server) SetTracer(t tracer.Tracer)

v0.9.4

Apr 8, 2023

v0.9.3

Apr 1, 2023

Changes in this version

+ const PackageName

v0.9.2

Mar 28, 2023

Changes in this version

type CommandExecutor

+ ExecuteCommand func(cmd *Command) (bson.Document, error)

+ type Conn struct

+ func (conn *Conn) Timestamp() time.Time

+ type QueryCommandExecutor interface

+ Delete func(*Conn, *Query) (int32, error)

+ Find func(*Conn, *Query) ([]bson.Document, error)

+ Insert func(*Conn, *Query) (int32, error)

+ Update func(*Conn, *Query) (int32, error)

v0.9.1

Feb 24, 2023

Changes in this version

+ var ErrQuery = errors.New("query error")

+ var ErrQueryNotSupported = errors.New("query not supported")

+ func NewNotSupported(q *Query) error

+ func NewQueryError(q *Query) error

v0.9.0

Aug 1, 2022

Changes in this version

+ const DefaultHost

+ const DefaultPort

+ const DefaultTimeoutSecond

+ const Version

+ type BaseCommandExecutor struct

+ func NewBaseCommandExecutor() *BaseCommandExecutor

+ func (executor *BaseCommandExecutor) Delete(q *Query) (int32, bool)

+ func (executor *BaseCommandExecutor) ExecuteBuildInfo(cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) ExecuteCommand(cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) ExecuteGetLastError(cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) ExecuteIsMaster(cmd *Command) (bson.Document, error)

+ func (executor *BaseCommandExecutor) Find(q *Query) ([]bson.Document, bool)

+ func (executor *BaseCommandExecutor) Insert(q *Query) (int32, bool)

+ func (executor *BaseCommandExecutor) SetDatabaseCommandExecutor(fn DatabaseCommandExecutor)

+ func (executor *BaseCommandExecutor) SetUserCommandExecutor(fn UserCommandExecutor)

+ func (executor *BaseCommandExecutor) Update(q *Query) (int32, bool)

+ type BaseMessageHandler struct

+ func NewBaseMessageHandler() *BaseMessageHandler

+ func (handler *BaseMessageHandler) OpDelete(msg *OpDelete) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpGetMore(msg *OpGetMore) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpInsert(msg *OpInsert) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpKillCursors(msg *OpKillCursors) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpMsg(msg *OpMsg) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpQuery(msg *OpQuery) (bson.Document, error)

+ func (handler *BaseMessageHandler) OpUpdate(msg *OpUpdate) (bson.Document, error)

+ func (handler *BaseMessageHandler) SetCommandExecutor(fn CommandExecutor)

+ func (handler *BaseMessageHandler) SetMessageExecutor(fn MessageExecutor)

+ type Client struct

+ Collection string

+ Database string

+ Host string

+ Port int

+ Timeout time.Duration

+ func NewClient() *Client

+ func (client *Client) Close() error

+ func (client *Client) Connect() error

+ func (client *Client) GetCollection() string

+ func (client *Client) GetDatabase() string

+ func (client *Client) GetHost() string

+ func (client *Client) GetPort() int

+ func (client *Client) GetTimeout() time.Duration

+ func (client *Client) InsertOne(doc interface{}) error

+ func (client *Client) SetCollection(col string)

+ func (client *Client) SetDatabase(db string)

+ func (client *Client) SetHost(host string)

+ func (client *Client) SetPort(port int)

+ func (client *Client) SetTimeout(d time.Duration)

+ type Command = message.Command

+ type CommandExecutor interface

+ type Config struct

+ func NewDefaultConfig() *Config

+ func (config *Config) GetCompressions() []string

+ func (config *Config) GetLogicalSessionTimeoutMinutes() int32

+ func (config *Config) GetMaxBsonObjectSize() int32

+ func (config *Config) GetMaxMessageSizeBytes() int32

+ func (config *Config) GetMaxWireVersion() int32

+ func (config *Config) GetMaxWriteBatchSize() int32

+ func (config *Config) GetMinWireVersion() int32

+ func (config *Config) GetReadOnly() bool

+ func (config *Config) GetVersion() string

+ func (config *Config) IsMaster() bool

+ type DatabaseCommandExecutor interface

+ type DiagnosticCommandExecutor interface

+ ExecuteBuildInfo func(cmd *Command) (bson.Document, error)

+ type Document = bsoncore.Document

+ type MessageExecutor interface

+ type MessageListener interface

+ type OpDelete = protocol.Delete

+ type OpFlag = protocol.Flag

+ type OpGetMore = protocol.GetMore

+ type OpInsert = protocol.Insert

+ type OpKillCursors = protocol.KillCursors

+ type OpMessage = protocol.Message

+ type OpMessageHandler interface

+ OpDelete func(q *OpDelete) (bson.Document, error)

+ OpGetMore func(q *OpGetMore) (bson.Document, error)

+ OpInsert func(q *OpInsert) (bson.Document, error)

+ OpKillCursors func(q *OpKillCursors) (bson.Document, error)

+ OpMsg func(q *OpMsg) (bson.Document, error)

+ OpQuery func(q *OpQuery) (bson.Document, error)

+ OpUpdate func(q *OpUpdate) (bson.Document, error)

+ type OpMsg = protocol.Msg

+ type OpQuery = protocol.Query

+ type OpReply = protocol.Reply

+ type OpUpdate = protocol.Update

+ type Query = message.Query

+ type ReplicationCommandExecutor interface

+ ExecuteIsMaster func(cmd *Command) (bson.Document, error)

+ type Server struct

+ Addr string

+ MessageHandler OpMessageHandler

+ Port int

+ func NewServer() *Server

+ func (server *Server) ExecuteBuildInfo(cmd *Command) (bson.Document, error)

+ func (server *Server) ExecuteIsMaster(cmd *Command) (bson.Document, error)

+ func (server *Server) GetPort() int

+ func (server *Server) Restart() error

+ func (server *Server) SetMessageHandler(h OpMessageHandler)

+ func (server *Server) SetMessageListener(l MessageListener)

+ func (server *Server) SetPort(port int)

+ func (server *Server) Start() error

+ func (server *Server) Stop() error

+ type UserCommandExecutor interface

+ type WriteOperationExecutor interface

+ ExecuteGetLastError func(cmd *Command) (bson.Document, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL