grpcclient

Documentation

Index

• type PubSubClient
  • func NewGRPCClient(isDebug bool) (*PubSubClient, error)
  • func (c *PubSubClient) Authenticate(clientid string, clientsecret string, sfdcloginurl string) error
  • func (c *PubSubClient) Close()
  • func (c *PubSubClient) FetchUserInfo(sfdcloginurl string) error
  • func (c *PubSubClient) GetSchema(schemaId string) (*proto.SchemaInfo, error)
  • func (c *PubSubClient) GetTopic(topicName string) (*proto.TopicInfo, error)
  • func (c *PubSubClient) Subscribe(replayPreset proto.ReplayPreset, replayId []byte, channel chan []byte, ...) ([]byte, error)
• type SFDCEvent
  • func StringMapToSFDCEvent(data map[string]interface{}, eventType string, Debug bool) (*SFDCEvent, error)

Types

type PubSubClient

type PubSubClient struct {
	Debug bool
	// contains filtered or unexported fields
}

func NewGRPCClient

func NewGRPCClient(isDebug bool) (*PubSubClient, error)

Creates a new connection to the gRPC server and returns the wrapper struct

func (*PubSubClient) Authenticate

func (c *PubSubClient) Authenticate(clientid string, clientsecret string, sfdcloginurl string) error

Makes a call to the OAuth server to fetch credentials. Credentials are stored as part of the PubSubClient object so that they can be referenced later in other methods

func (*PubSubClient) Close

func (c *PubSubClient) Close()

Closes the underlying connection to the gRPC server

func (*PubSubClient) FetchUserInfo

func (c *PubSubClient) FetchUserInfo(sfdcloginurl string) error

Makes a call to the OAuth server to fetch user info. User info is stored as part of the PubSubClient object so that it can be referenced later in other methods

func (*PubSubClient) GetSchema

func (c *PubSubClient) GetSchema(schemaId string) (*proto.SchemaInfo, error)

Wrapper function around the GetSchema RPC. This will add the OAuth credentials and make a call to fetch data about a specific schema

func (*PubSubClient) GetTopic

func (c *PubSubClient) GetTopic(topicName string) (*proto.TopicInfo, error)

Wrapper function around the GetTopic RPC. This will add the OAuth credentials and make a call to fetch data about a specific topic

func (*PubSubClient) Subscribe

func (c *PubSubClient) Subscribe(replayPreset proto.ReplayPreset, replayId []byte, channel chan []byte, topicName string, eventType string) ([]byte, error)

Wrapper function around the Subscribe RPC. This will add the OAuth credentials and create a separate streaming client that will be used to fetch data from the topic. This method will continuously consume messages unless an error occurs; if an error does occur then this method will return the last successfully consumed ReplayId as well as the error message. If no messages were successfully consumed then this method will return the same ReplayId that it originally received as a parameter

type SFDCEvent

type SFDCEvent struct {
	EventType                string
	AcceptLanguage           string
	ApiType                  string
	ApiVersion               string
	Application              string
	AuthMethodReference      string
	AuthServiceId            string
	Browser                  string
	CipherSuite              string
	City                     string
	ClientVersion            string
	Country                  string
	CountryIso               string
	CreatedById              string
	CreatedDate              int64
	CurrentIp                string
	CurrentPlatform          string
	CurrentScreen            string
	CurrentUserAgent         string
	CurrentWindow            string
	DelegatedOrganizationId  string
	DelegatedUsername        string
	EvaluationTime           float64
	EventDate                int64
	EventIdentifier          string
	EventUuid                string
	EventSource              string
	HasExternalUsers         bool
	HttpMethod               string
	ImpactedUserIds          string
	LoginAsCategory          string
	LoginGeoId               string
	LoginHistoryId           string
	LoginKey                 string
	LoginLatitude            float64
	LoginLongitude           float64
	LoginSubType             string
	LoginType                string
	LoginUrl                 string
	Operation                string
	ParentIdList             string
	ParentNameList           string
	PermissionExpirationList string
	PermissionList           string
	PermissionType           string
	Platform                 string
	PolicyId                 string
	PolicyOutcome            string
	PostalCode               string
	PreviousIp               string
	PreviousPlatform         string
	PreviousScreen           string
	PreviousUserAgent        string
	PreviousWindow           string
	QueriedEntities          string
	RelatedEventIdentifier   string
	RequestIdentifier        string
	ReplayId                 string
	RowsProcessed            int64
	Score                    int64
	SecurityEventData        string
	SessionKey               string
	SessionLevel             string
	SourceIp                 string
	Summary                  string
	LoginStatus              string
	Subdivision              string
	TargetUrl                string
	TlsProtocol              string
	UserAgent                string
	UserCount                string
	UserId                   string
	UserType                 string
	Username                 string
	Uri                      string
}

User holds information about a user.

func StringMapToSFDCEvent

func StringMapToSFDCEvent(data map[string]interface{}, eventType string, Debug bool) (*SFDCEvent, error)