plugins

Mar 6, 2025

Changes in this version

type ClientConnection

+ func (c *ClientConnection) GetIpAddr() string

+ func (c *ClientConnection) GetUsername() string

Jun 2, 2022

Changes in this version

+ var Registry = make(map[string]PluginFunc)

+ func Register(f PluginFunc)

+ type ChainFunc func(PipelineFunc) PipelineFunc

+ type ClientConnection struct

+ Addr net.Addr

+ Identities []ClientIdentity

+ Map map[interface{}]interface{}

+ func NewClientConnection() *ClientConnection

+ func (c *ClientConnection) Close()

+ func (c *ClientConnection) GetAddr() string

+ type ClientIdentity interface

+ Roles func() []string

+ Type func() string

+ User func() string

+ type CursorCache interface

+ CloseCursor func(cursorID int64)

+ GetCursor func(cursorID int64) *CursorCacheEntry

+ type CursorCacheEntry struct

+ CursorConsumed int

+ ID int64

+ Map map[interface{}]interface{}

+ func NewCursorCacheEntry(id int64) *CursorCacheEntry

+ type PipelineFunc func(context.Context, *Request) (bson.D, error)

+ func BuildPipeline(m []Plugin, base PipelineFunc) PipelineFunc

+ type Plugin interface

+ Configure func(bson.D) error

+ Name func() string

+ Process func(context.Context, *Request, PipelineFunc) (bson.D, error)

+ func GetPlugin(n string) (Plugin, bool)

+ type PluginFunc func() Plugin

+ type Request struct

+ CC *ClientConnection

+ Command command.Command

+ CommandName string

+ Map map[string]interface{}

+ func (r *Request) Close()

+ type StaticIdentity struct

+ RS []string

+ T string

+ U string

+ func NewStaticIdentity(t, u string, rs ...string) *StaticIdentity

+ func (i *StaticIdentity) Roles() []string

+ func (i *StaticIdentity) Type() string

+ func (i *StaticIdentity) User() string