Documentation
¶
Index ¶
- Constants
- func CreateGRPCClientConnection(p *Plugin, oCtx *PluginInstance) *grpcclient.PubSubClient
- type Plugin
- func (p *Plugin) Extract(req sdk.ExtractRequest, evt sdk.EventReader) error
- func (p *Plugin) Fields() []sdk.FieldEntry
- func (p *Plugin) Info() *plugins.Info
- func (p *Plugin) Init(cfg string) error
- func (p *Plugin) InitSchema() *sdk.SchemaInfo
- func (p *Plugin) Open(params string) (source.Instance, error)
- type PluginConfig
- type PluginInstance
Constants ¶
View Source
const ( PluginID uint32 = 14 PluginName = "salesforce" PluginDescription = "Reads events from Salesforce using GRPC Connection" PluginContact = "github.com/falcosecurity/plugins" PluginVersion = "0.1.0" PluginEventSource = "salesforce" ExtractEventSource = "salesforce" )
Variables ¶
This section is empty.
Functions ¶
func CreateGRPCClientConnection ¶
func CreateGRPCClientConnection(p *Plugin, oCtx *PluginInstance) *grpcclient.PubSubClient
Types ¶
type Plugin ¶
type Plugin struct {
plugins.BasePlugin
// contains filtered or unexported fields
}
Plugin represent the Salesforce plugin
func (*Plugin) Extract ¶
func (p *Plugin) Extract(req sdk.ExtractRequest, evt sdk.EventReader) error
Extract a field value from an event.
func (*Plugin) Fields ¶
func (p *Plugin) Fields() []sdk.FieldEntry
Return the fields supported for extraction.
func (*Plugin) InitSchema ¶
func (p *Plugin) InitSchema() *sdk.SchemaInfo
type PluginConfig ¶
type PluginConfig struct {
SFDCClientId string `json:"sfdcclientid" jsonschema:"title=Salesforce Connect App Client Id"`
SFDCClientSecret string `json:"sfdcclientsecret" jsonschema:"title=Salesforce Connect App Client Secret"`
SFDCLoginURL string `` /* 187-byte string literal not displayed */
Debug bool `json:"Debug" jsonschema:"title=Enable debug output (true = yes, false=no)"`
}
PluginConfig represents a configuration of the GitHub plugin
func (*PluginConfig) Reset ¶
func (p *PluginConfig) Reset()
Reset sets the configuration to its default values
type PluginInstance ¶
type PluginInstance struct {
source.BaseInstance
// contains filtered or unexported fields
}
PluginInstance represents an opened instance of the plugin, which is returned by Open() and deinitialized during Close().
func (*PluginInstance) Close ¶
func (oCtx *PluginInstance) Close()
Closing the event stream and deinitialize the open plugin instance.
func (*PluginInstance) NextBatch ¶
func (o *PluginInstance) NextBatch(pState sdk.PluginState, evts sdk.EventWriters) (int, error)
Produce and return a new batch of events.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.