Documentation
¶
Index ¶
- Constants
- type ApexServiceImpl
- type BulkServiceImpl
- func (b *BulkServiceImpl) AbortJob(ctx context.Context, jobID string) (*JobInfo, error)
- func (b *BulkServiceImpl) CloseJob(ctx context.Context, jobID string) (*JobInfo, error)
- func (b *BulkServiceImpl) CreateJob(ctx context.Context, req CreateJobRequest) (*JobInfo, error)
- func (b *BulkServiceImpl) DeleteJob(ctx context.Context, jobID string) error
- func (b *BulkServiceImpl) GetFailedRecords(ctx context.Context, jobID string) ([]FailedRecord, error)
- func (b *BulkServiceImpl) GetJobStatus(ctx context.Context, jobID string) (*JobInfo, error)
- func (b *BulkServiceImpl) GetSuccessfulRecords(ctx context.Context, jobID string) ([]map[string]interface{}, error)
- func (b *BulkServiceImpl) UploadData(ctx context.Context, jobID string, data io.Reader) error
- func (b *BulkServiceImpl) WaitForCompletion(ctx context.Context, jobID string, poll time.Duration) (*JobInfo, error)
- type ContentType
- type CreateJobRequest
- type ExecuteAnonymousResult
- type FailedRecord
- type GlobalDescribeResult
- type JobInfo
- type JobOperation
- type JobState
- type LineEnding
- type QueryBuilder
- func (q *QueryBuilder) Build() string
- func (q *QueryBuilder) Limit(l int) *QueryBuilder
- func (q *QueryBuilder) Offset(o int) *QueryBuilder
- func (q *QueryBuilder) OrderByAsc(f string) *QueryBuilder
- func (q *QueryBuilder) OrderByDesc(f string) *QueryBuilder
- func (q *QueryBuilder) Select(fields ...string) *QueryBuilder
- func (q *QueryBuilder) Where(c string) *QueryBuilder
- func (q *QueryBuilder) WhereEquals(f string, v interface{}) *QueryBuilder
- func (q *QueryBuilder) WhereLike(f, p string) *QueryBuilder
- func (q *QueryBuilder) WhereNotNull(f string) *QueryBuilder
- type QueryResult
- type QueryServiceImpl
- func (q *QueryServiceImpl) Execute(ctx context.Context, query string) (*QueryResult, error)
- func (q *QueryServiceImpl) ExecuteAll(ctx context.Context, query string) (*QueryResult, error)
- func (q *QueryServiceImpl) NewBuilder(objectType string) *QueryBuilder
- func (q *QueryServiceImpl) QueryMore(ctx context.Context, nextURL string) (*QueryResult, error)
- type SObject
- func (s *SObject) Attributes() *SObjectAttributes
- func (s *SObject) FloatField(key string) float64
- func (s *SObject) Get(key string) interface{}
- func (s *SObject) ID() string
- func (s *SObject) Set(key string, value interface{}) *SObject
- func (s *SObject) StringField(key string) string
- func (s *SObject) ToCreatePayload() map[string]interface{}
- func (s *SObject) ToMap() map[string]interface{}
- func (s *SObject) Type() string
- type SObjectAttributes
- type SObjectMetadata
- type SObjectServiceImpl
- func (s *SObjectServiceImpl) Create(ctx context.Context, objectType string, data map[string]interface{}) (*SObject, error)
- func (s *SObjectServiceImpl) Delete(ctx context.Context, objectType, id string) error
- func (s *SObjectServiceImpl) Describe(ctx context.Context, objectType string) (*SObjectMetadata, error)
- func (s *SObjectServiceImpl) DescribeGlobal(ctx context.Context) (*GlobalDescribeResult, error)
- func (s *SObjectServiceImpl) Get(ctx context.Context, objectType, id string, fields ...string) (*SObject, error)
- func (s *SObjectServiceImpl) Update(ctx context.Context, objectType, id string, data map[string]interface{}) error
- func (s *SObjectServiceImpl) Upsert(ctx context.Context, objectType, extField, extID string, ...) (*SObject, error)
- type ToolingServiceImpl
- func (t *ToolingServiceImpl) Describe(ctx context.Context, objectType string) (*SObjectMetadata, error)
- func (t *ToolingServiceImpl) ExecuteAnonymous(ctx context.Context, apex string) (*ExecuteAnonymousResult, error)
- func (t *ToolingServiceImpl) Query(ctx context.Context, query string) (*QueryResult, error)
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
type BulkServiceImpl ¶
type BulkServiceImpl struct {
// contains filtered or unexported fields
}
func NewBulkService ¶
func NewBulkService(client *http.Client, apiVersion string) *BulkServiceImpl
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 (*BulkServiceImpl) GetSuccessfulRecords ¶
func (*BulkServiceImpl) UploadData ¶
func (*BulkServiceImpl) WaitForCompletion ¶
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 FailedRecord ¶
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 ¶
type JobOperation ¶
type JobOperation string
const ( JobOperationInsert JobOperation = "insert" JobOperationUpdate JobOperation = "update" JobOperationUpsert JobOperation = "upsert" JobOperationDelete JobOperation = "delete" JobOperationQuery JobOperation = "query" )
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 NewSObjectFromMap ¶
func (*SObject) Attributes ¶
func (s *SObject) Attributes() *SObjectAttributes
func (*SObject) FloatField ¶
func (*SObject) StringField ¶
func (*SObject) ToCreatePayload ¶
type SObjectAttributes ¶
type SObjectMetadata ¶
type SObjectServiceImpl ¶
type SObjectServiceImpl struct {
// contains filtered or unexported fields
}
func NewSObjectService ¶
func NewSObjectService(client *http.Client, apiVersion string) *SObjectServiceImpl
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)
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)
Click to show internal directories.
Click to hide internal directories.