salesforce_logs_receiver

README

Salesforce Logs Receiver

A package for collecting sObjects data from Salesforce.

Usage

go get -u github.com/logzio/salesforce-logs-receiver

Documentation

Index

• Constants
• type SObjectToCollect
• type SalesforceLogsReceiver
  • func NewSalesforceLogsReceiver(url string, clientID string, apiVersion string, username string, ...) (*SalesforceLogsReceiver, error)
  • func (slr *SalesforceLogsReceiver) CollectSObjectRecord(record *simpleforce.SObject) ([]byte, *string, error)
  • func (slr *SalesforceLogsReceiver) EnrichEventLogFileSObjectData(data *simpleforce.SObject, jsonData []byte) ([][]byte, error)
  • func (slr *SalesforceLogsReceiver) GetSObjectRecords(sObject *SObjectToCollect) ([]simpleforce.SObject, error)
  • func (slr *SalesforceLogsReceiver) LoginSalesforce() error

Constants

const (
	EventLogFileSObjectName = "eventlogfile"
)

Types

type SObjectToCollect

type SObjectToCollect struct {
	SObjectType     string
	LatestTimestamp string
}

type SalesforceLogsReceiver

type SalesforceLogsReceiver struct {
	SObjects []*SObjectToCollect
	// contains filtered or unexported fields
}

func NewSalesforceLogsReceiver

func NewSalesforceLogsReceiver(
	url string,
	clientID string,
	apiVersion string,
	username string,
	password string,
	securityToken string,
	sObjects []*SObjectToCollect,
	customFields map[string]string) (*SalesforceLogsReceiver, error)

func (*SalesforceLogsReceiver) CollectSObjectRecord

func (slr *SalesforceLogsReceiver) CollectSObjectRecord(record *simpleforce.SObject) ([]byte, *string, error)

func (*SalesforceLogsReceiver) EnrichEventLogFileSObjectData

func (slr *SalesforceLogsReceiver) EnrichEventLogFileSObjectData(data *simpleforce.SObject, jsonData []byte) ([][]byte, error)

func (*SalesforceLogsReceiver) GetSObjectRecords

func (slr *SalesforceLogsReceiver) GetSObjectRecords(sObject *SObjectToCollect) ([]simpleforce.SObject, error)

func (*SalesforceLogsReceiver) LoginSalesforce

func (slr *SalesforceLogsReceiver) LoginSalesforce() error