handlers

package

Go to main page

Versions in this module

v1

v1.15.0

Nov 20, 2023

v1.14.0

Nov 7, 2023

Changes in this version

type Interface

+ MsgCompact func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v1.13.0

Oct 23, 2023

v1.12.1

Oct 10, 2023

v1.12.0

Oct 10, 2023

v1.11.0

Sep 25, 2023

v1.10.1

Sep 14, 2023

v1.10.0

Sep 14, 2023

v1.9.0

Aug 28, 2023

v1.8.0

Aug 14, 2023

v1.7.0

Jul 31, 2023

v1.6.1

Jul 26, 2023

v1.6.0

Jul 17, 2023

Changes in this version

type Interface

+ MsgKillCursors func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v1.5.0

Jul 3, 2023

v1.4.0

Jun 19, 2023

v1.3.0

Jun 5, 2023

Changes in this version

type Interface

+ MsgLogout func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v1.2.1

May 24, 2023

v1.2.0

May 22, 2023

v1.1.0

May 9, 2023

Changes in this version

type Interface

+ MsgRenameCollection func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v1.0.0

Apr 3, 2023

Changes in this version

type Interface

+ MsgDropIndexes func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0

v0.9.4

Mar 27, 2023

v0.9.4-rc.2

Mar 20, 2023

v0.9.4-rc.1

Mar 17, 2023

v0.9.3

Mar 13, 2023

v0.9.3-rc.1

Mar 10, 2023

v0.9.2

Feb 27, 2023

Changes in this version

type Interface

+ MsgGetMore func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.9.2-rc.1

Feb 23, 2023

v0.9.1

Feb 13, 2023

v0.9.0

Jan 31, 2023

v0.8.1

Jan 16, 2023

Changes in this version

type Interface

+ MsgDistinct func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.8.0

Jan 2, 2023

Changes in this version

type Interface

+ MsgCurrentOp func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgSASLStart func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.7.1

Dec 19, 2022

Changes in this version

type Interface

+ MsgValidate func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.7.0

Dec 5, 2022

Changes in this version

type Interface

+ MsgListIndexes func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.6.2

Nov 21, 2022

v0.6.1

Nov 7, 2022

v0.6.0

Oct 26, 2022

v0.5.4

Sep 22, 2022

v0.5.3

Sep 8, 2022

Changes in this version

type Interface

+ MsgCollMod func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.5.2

Aug 9, 2022

Changes in this version

type Interface

+ MsgAggregate func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.5.1

Jul 26, 2022

Changes in this version

type Interface

+ MsgExplain func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.5.0

Jul 11, 2022

v0.4.0

Jun 27, 2022

Changes in this version

type Interface

+ MsgGetFreeMonitoringStatus func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgSetFreeMonitoring func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.3.0

Jun 1, 2022

Changes in this version

+ type Interface interface

+ Close func()

+ CmdQuery func(ctx context.Context, query *wire.OpQuery) (*wire.OpReply, error)

+ MsgBuildInfo func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgCollStats func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgConnectionStatus func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgCount func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgCreate func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgCreateIndexes func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDBStats func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDataSize func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDebugError func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDelete func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDrop func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgDropDatabase func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgFind func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgFindAndModify func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgGetCmdLineOpts func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgGetLog func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgGetParameter func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgHello func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgHostInfo func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgInsert func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgIsMaster func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgListCollections func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgListCommands func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgListDatabases func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgPing func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgServerStatus func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgUpdate func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ MsgWhatsMyURI func(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

v0.2.1

May 17, 2022

v0.2.0

May 4, 2022

v0.1.1

Apr 19, 2022

v0.1.0

Apr 4, 2022

v0.0.6

Feb 10, 2022

Changes in this version

type Handler

+ func (h *Handler) MsgBuildInfo(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgCollStats(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgCreate(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgDBStats(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgDataSize(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgDrop(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgDropDatabase(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgGetCmdLineOpts(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgGetLog(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgGetParameter(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgHello(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgHostInfo(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgListCollections(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgListDatabases(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgPing(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgServerStatus(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) MsgWhatsMyURI(ctx context.Context, msg *wire.OpMsg) (*wire.OpMsg, error)

+ func (h *Handler) QueryCmd(ctx context.Context, query *wire.OpQuery) (*wire.OpReply, error)

type NewOpts

+ PeerAddr string

+ StartTime time.Time

v0.0.5

Jan 4, 2022

Changes in this version

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func (lm *Metrics) Collect(ch chan<- prometheus.Metric)

+ func (lm *Metrics) Describe(ch chan<- *prometheus.Desc)

+ type NewOpts struct

+ JSONB1Storage common.Storage

+ Logger *zap.Logger

+ Metrics *Metrics

+ PgPool *pg.Pool

+ SQLStorage common.Storage

+ SharedHandler *shared.Handler

v0.0.4

Dec 1, 2021

Changes in this version

+ type Handler struct

+ func New(pgPool *pg.Pool, l *zap.Logger, shared *shared.Handler, ...) *Handler

+ func (h *Handler) Handle(ctx context.Context, reqHeader *wire.MsgHeader, reqBody wire.MsgBody) (resHeader *wire.MsgHeader, resBody wire.MsgBody, closeConn bool)

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