services

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 4, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ContentTypeCSV ContentType = "CSV"
	LineEndingLF   LineEnding  = "LF"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ApexServiceImpl

type ApexServiceImpl struct {
	// contains filtered or unexported fields
}

func NewApexService

func NewApexService(client *http.Client, apiVersion string) *ApexServiceImpl

func (*ApexServiceImpl) Execute

func (a *ApexServiceImpl) Execute(ctx context.Context, method, path string, body interface{}) ([]byte, error)

type BulkServiceImpl

type BulkServiceImpl struct {
	// contains filtered or unexported fields
}

func NewBulkService

func NewBulkService(client *http.Client, apiVersion string) *BulkServiceImpl

func (*BulkServiceImpl) AbortJob

func (b *BulkServiceImpl) AbortJob(ctx context.Context, jobID string) (*JobInfo, error)

func (*BulkServiceImpl) CloseJob

func (b *BulkServiceImpl) CloseJob(ctx context.Context, jobID string) (*JobInfo, error)

func (*BulkServiceImpl) CreateJob

func (b *BulkServiceImpl) CreateJob(ctx context.Context, req CreateJobRequest) (*JobInfo, error)

func (*BulkServiceImpl) DeleteJob

func (b *BulkServiceImpl) DeleteJob(ctx context.Context, jobID string) error

func (*BulkServiceImpl) GetFailedRecords

func (b *BulkServiceImpl) GetFailedRecords(ctx context.Context, jobID string) ([]FailedRecord, error)

func (*BulkServiceImpl) GetJobStatus

func (b *BulkServiceImpl) GetJobStatus(ctx context.Context, jobID string) (*JobInfo, error)

func (*BulkServiceImpl) GetSuccessfulRecords

func (b *BulkServiceImpl) GetSuccessfulRecords(ctx context.Context, jobID string) ([]map[string]interface{}, error)

func (*BulkServiceImpl) UploadData

func (b *BulkServiceImpl) UploadData(ctx context.Context, jobID string, data io.Reader) error

func (*BulkServiceImpl) WaitForCompletion

func (b *BulkServiceImpl) WaitForCompletion(ctx context.Context, jobID string, poll time.Duration) (*JobInfo, error)

type ContentType

type ContentType string

type CreateJobRequest

type CreateJobRequest struct {
	Object              string       `json:"object"`
	Operation           JobOperation `json:"operation"`
	ExternalIdFieldName string       `json:"externalIdFieldName,omitempty"`
	ContentType         ContentType  `json:"contentType,omitempty"`
	LineEnding          LineEnding   `json:"lineEnding,omitempty"`
}

type ExecuteAnonymousResult

type ExecuteAnonymousResult struct {
	Line           int         `json:"line"`
	Column         int         `json:"column"`
	Compiled       bool        `json:"compiled"`
	Success        bool        `json:"success"`
	CompileProblem interface{} `json:"compileProblem"`
}

type FailedRecord

type FailedRecord struct {
	ID    string                 `json:"sf__Id"`
	Error string                 `json:"sf__Error"`
	Data  map[string]interface{} `json:"-"`
}

type GlobalDescribeResult

type GlobalDescribeResult struct {
	SObjects []SObjectMetadata `json:"sobjects"`
}

type JobInfo

type JobInfo struct {
	ID                     string       `json:"id"`
	Object                 string       `json:"object"`
	Operation              JobOperation `json:"operation"`
	State                  JobState     `json:"state"`
	ContentType            ContentType  `json:"contentType"`
	NumberRecordsProcessed int          `json:"numberRecordsProcessed"`
	NumberRecordsFailed    int          `json:"numberRecordsFailed"`
}

func (*JobInfo) IsComplete

func (j *JobInfo) IsComplete() bool

type JobOperation

type JobOperation string
const (
	JobOperationInsert JobOperation = "insert"
	JobOperationUpdate JobOperation = "update"
	JobOperationUpsert JobOperation = "upsert"
	JobOperationDelete JobOperation = "delete"
	JobOperationQuery  JobOperation = "query"
)

type JobState

type JobState string
const (
	JobStateOpen           JobState = "Open"
	JobStateUploadComplete JobState = "UploadComplete"
	JobStateInProgress     JobState = "InProgress"
	JobStateJobComplete    JobState = "JobComplete"
	JobStateFailed         JobState = "Failed"
	JobStateAborted        JobState = "Aborted"
)

type LineEnding

type LineEnding string

type QueryBuilder

type QueryBuilder struct {
	// contains filtered or unexported fields
}

func NewQueryBuilder

func NewQueryBuilder(objectType string) *QueryBuilder

func (*QueryBuilder) Build

func (q *QueryBuilder) Build() string

func (*QueryBuilder) Limit

func (q *QueryBuilder) Limit(l int) *QueryBuilder

func (*QueryBuilder) Offset

func (q *QueryBuilder) Offset(o int) *QueryBuilder

func (*QueryBuilder) OrderByAsc

func (q *QueryBuilder) OrderByAsc(f string) *QueryBuilder

func (*QueryBuilder) OrderByDesc

func (q *QueryBuilder) OrderByDesc(f string) *QueryBuilder

func (*QueryBuilder) Select

func (q *QueryBuilder) Select(fields ...string) *QueryBuilder

func (*QueryBuilder) Where

func (q *QueryBuilder) Where(c string) *QueryBuilder

func (*QueryBuilder) WhereEquals

func (q *QueryBuilder) WhereEquals(f string, v interface{}) *QueryBuilder

func (*QueryBuilder) WhereLike

func (q *QueryBuilder) WhereLike(f, p string) *QueryBuilder

func (*QueryBuilder) WhereNotNull

func (q *QueryBuilder) WhereNotNull(f string) *QueryBuilder

type QueryResult

type QueryResult struct {
	TotalSize      int        `json:"totalSize"`
	Done           bool       `json:"done"`
	NextRecordsURL string     `json:"nextRecordsUrl,omitempty"`
	Records        []*SObject `json:"records"`
}

func (*QueryResult) HasMore

func (r *QueryResult) HasMore() bool

type QueryServiceImpl

type QueryServiceImpl struct {
	// contains filtered or unexported fields
}

func NewQueryService

func NewQueryService(client *http.Client, apiVersion string) *QueryServiceImpl

func (*QueryServiceImpl) Execute

func (q *QueryServiceImpl) Execute(ctx context.Context, query string) (*QueryResult, error)

func (*QueryServiceImpl) ExecuteAll

func (q *QueryServiceImpl) ExecuteAll(ctx context.Context, query string) (*QueryResult, error)

func (*QueryServiceImpl) NewBuilder

func (q *QueryServiceImpl) NewBuilder(objectType string) *QueryBuilder

func (*QueryServiceImpl) QueryMore

func (q *QueryServiceImpl) QueryMore(ctx context.Context, nextURL string) (*QueryResult, error)

type SObject

type SObject struct {
	// contains filtered or unexported fields
}

func NewSObject

func NewSObject(objectType string) *SObject

func NewSObjectFromMap

func NewSObjectFromMap(data map[string]interface{}) *SObject

func (*SObject) Attributes

func (s *SObject) Attributes() *SObjectAttributes

func (*SObject) FloatField

func (s *SObject) FloatField(key string) float64

func (*SObject) Get

func (s *SObject) Get(key string) interface{}

func (*SObject) ID

func (s *SObject) ID() string

func (*SObject) Set

func (s *SObject) Set(key string, value interface{}) *SObject

func (*SObject) StringField

func (s *SObject) StringField(key string) string

func (*SObject) ToCreatePayload

func (s *SObject) ToCreatePayload() map[string]interface{}

func (*SObject) ToMap

func (s *SObject) ToMap() map[string]interface{}

func (*SObject) Type

func (s *SObject) Type() string

type SObjectAttributes

type SObjectAttributes struct {
	Type string `json:"type"`
	URL  string `json:"url"`
}

type SObjectMetadata

type SObjectMetadata struct {
	Name       string `json:"name"`
	Label      string `json:"label"`
	Createable bool   `json:"createable"`
	Updateable bool   `json:"updateable"`
	Deletable  bool   `json:"deletable"`
	Queryable  bool   `json:"queryable"`
}

type SObjectServiceImpl

type SObjectServiceImpl struct {
	// contains filtered or unexported fields
}

func NewSObjectService

func NewSObjectService(client *http.Client, apiVersion string) *SObjectServiceImpl

func (*SObjectServiceImpl) Create

func (s *SObjectServiceImpl) Create(ctx context.Context, objectType string, data map[string]interface{}) (*SObject, error)

func (*SObjectServiceImpl) Delete

func (s *SObjectServiceImpl) Delete(ctx context.Context, objectType, id string) error

func (*SObjectServiceImpl) Describe

func (s *SObjectServiceImpl) Describe(ctx context.Context, objectType string) (*SObjectMetadata, error)

func (*SObjectServiceImpl) DescribeGlobal

func (s *SObjectServiceImpl) DescribeGlobal(ctx context.Context) (*GlobalDescribeResult, error)

func (*SObjectServiceImpl) Get

func (s *SObjectServiceImpl) Get(ctx context.Context, objectType, id string, fields ...string) (*SObject, error)

func (*SObjectServiceImpl) Update

func (s *SObjectServiceImpl) Update(ctx context.Context, objectType, id string, data map[string]interface{}) error

func (*SObjectServiceImpl) Upsert

func (s *SObjectServiceImpl) Upsert(ctx context.Context, objectType, extField, extID string, data map[string]interface{}) (*SObject, error)

type ToolingServiceImpl

type ToolingServiceImpl struct {
	// contains filtered or unexported fields
}

func NewToolingService

func NewToolingService(client *http.Client, apiVersion string) *ToolingServiceImpl

func (*ToolingServiceImpl) Describe

func (t *ToolingServiceImpl) Describe(ctx context.Context, objectType string) (*SObjectMetadata, error)

func (*ToolingServiceImpl) ExecuteAnonymous

func (t *ToolingServiceImpl) ExecuteAnonymous(ctx context.Context, apex string) (*ExecuteAnonymousResult, error)

func (*ToolingServiceImpl) Query

func (t *ToolingServiceImpl) Query(ctx context.Context, query string) (*QueryResult, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL