INNER CODE UNIT · Go

func

samsara/samsara · clients/go/client.go:36

func (c *Client) PublishEvents(events []Event) (bool, error) {
	for _, event := range events {
		event.enrich(c.config)
		if err := event.validate(); err != nil {
			return false, err
		}
	}

	return c.publisher.Post(events), nil
}

// RecordEvent pushes event to internal events' queue.
func (c *Client) RecordEvent(event Event) error {
	event.enrich(c.config)
	if err := event.validate(); err != nil {
		return err
	}
	c.queue.Push(event)

View source record →