api

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package catalog consists of catalog functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package catalog consists of catalog functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package api is the base for all aep rest functions. Copyright 2021 Michael Bungenstock

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

View Source 
const (
	// JSONOut is used for JSON
	AcceptIDs = iota
	AcceptLinks
	AcceptObjects
)

Variables

View Source 
var All = map[string]Func{

	"ACGetEffecticeACLPolicies": ACGetEffecticeACLPoliciesP,
	"CatalogGetBatches":         CatalogGetBatchesP,
	"CatalogGetDatasets":        CatalogGetDatasetsP,
	"DADownload":                DADownloadP,
	"DAGetFiles":                DAGetFilesP,
	"DAGetFils":                 DAGetFileP,
	"ODGet":                     ODGetP,
	"ODQuery":                   ODQueryP,
	"FlowGetConnections":        FlowGetConnectionsP,
	"SBGetSandbox":              SBGetSandboxP,

	"SRGetBehaviorsP": SRListBehaviorsP,
	"SRGetBehaviorP":  SRGetBehaviorP,

	"SRGetSchemas":   SRListSchemasP,
	"SRGetSchema":    SRGetSchemaP,
	"UPSGetEntities": UPSGetEntitiesP,
}

Functions

func ACGetEffecticeACLPolicies added in v0.3.0 

func ACGetEffecticeACLPolicies(ctx context.Context, p *AuthenticationConfig, params ACGetEffecticeACLPoliciesParams) (*http.Response, error)

ACGetEffecticeACLPolicies returns the effective acl policies

func ACGetEffecticeACLPoliciesP added in v0.3.0 

func ACGetEffecticeACLPoliciesP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

ACGetEffecticeACLPolicies returns the effective acl policies

func ACGetPermissionsAndResources added in v0.3.0 

func ACGetPermissionsAndResources(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

ACGetPermissionsAndResources returns the access control policies.

func CatalogCreateDataset added in v0.3.0 

func CatalogCreateDataset(ctx context.Context, p *AuthenticationConfig, obj interface{}) (*http.Response, error)

Create creates a new object

func CatalogCreateProfileUnionDataset added in v0.3.0 

func CatalogCreateProfileUnionDataset(ctx context.Context, p *AuthenticationConfig, name, format string) (*http.Response, error)

func CatalogGetBatches added in v0.3.0 

func CatalogGetBatches(ctx context.Context, p *AuthenticationConfig, options *BatchesOptions) (*http.Response, error)

CatalogGetBatches returns a list of batches

func CatalogGetBatchesP added in v0.3.0 

func CatalogGetBatchesP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

CatalogGetBatchesP returns a list of batches

func CatalogGetDatasets added in v0.3.0 

func CatalogGetDatasets(ctx context.Context, p *AuthenticationConfig, options *BatchesOptions) (*http.Response, error)

CatalogGetDatasets returns a list of batches

func CatalogGetDatasetsP added in v0.3.0 

func CatalogGetDatasetsP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

CatalogGetDatasets returns a list of batches

func DADownload added in v0.2.0 

func DADownload(ctx context.Context, p *AuthenticationConfig, fileId, path string) (*http.Response, error)

DADownload downloads a file fromt the given url

func DADownloadP added in v0.3.0 

func DADownloadP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

DADownload downloads a file fromt the given url

func DAGetFile added in v0.2.0 

func DAGetFile(ctx context.Context, p *AuthenticationConfig, options *DAOptions) (*http.Response, error)

DAGetFile returns a list of files for the passed fileId

func DAGetFileP added in v0.3.0 

func DAGetFileP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

DAGetFileP returns a list of files for the passed fileId

func DAGetFiles added in v0.2.0 

func DAGetFiles(ctx context.Context, p *AuthenticationConfig, options *DAOptions) (*http.Response, error)

DAGetFilesP returns a list of files for the passed batchId

func DAGetFilesP added in v0.3.0 

func DAGetFilesP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

DAGetFilesP returns a list of files for the passed batchId

func DropResponse added in v0.3.1 

func DropResponse(res *http.Response, err error) error

func FlowGetConnectionsP added in v0.3.0 

func FlowGetConnectionsP(ctx context.Context, auth *AuthenticationConfig, params *Request) (*http.Response, error)

DAGetFile returns a list of files for the passed fileId

func HandleStatusCode added in v0.2.0 

func HandleStatusCode(res *http.Response, err error) (*http.Response, error)

HandleStatusCode checks for a previous error and the HTTP status code. If an error exists or the status code is good then the passed objects will be returned. Otherwise it will create an error object from the status information and the returned HTTP body.

func ISCreateNamespace added in v0.3.1 

func ISCreateNamespace(ctx context.Context, a *AuthenticationConfig, body []byte) (*http.Response, error)

func ISGetCluster added in v0.3.1 

func ISGetCluster(ctx context.Context, a *AuthenticationConfig, p *ISClusterParams) (*http.Response, error)

func ISGetClusterR added in v0.3.1 

func ISGetClusterR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISGetClusters added in v0.3.1 

func ISGetClusters(ctx context.Context, a *AuthenticationConfig, p *ISClustersParams) (*http.Response, error)

func ISGetClustersR added in v0.3.1 

func ISGetClustersR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISGetHistories added in v0.3.1 

func ISGetHistories(ctx context.Context, a *AuthenticationConfig, p *ISClustersParams) (*http.Response, error)

func ISGetHistoriesR added in v0.3.1 

func ISGetHistoriesR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISGetHistory added in v0.3.1 

func ISGetHistory(ctx context.Context, a *AuthenticationConfig, p *ISClusterParams) (*http.Response, error)

func ISGetHistoryR added in v0.3.1 

func ISGetHistoryR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISGetMapping added in v0.3.1 

func ISGetMapping(ctx context.Context, a *AuthenticationConfig, p *ISGetMappingParams) (*http.Response, error)

func ISGetMappingR added in v0.3.1 

func ISGetMappingR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISGetMappings added in v0.3.1 

func ISGetMappings(ctx context.Context, a *AuthenticationConfig, p *ISClustersParams) (*http.Response, error)

func ISGetNamespace added in v0.3.1 

func ISGetNamespace(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func ISGetNamespaceIMSOrg added in v0.3.1 

func ISGetNamespaceIMSOrg(ctx context.Context, a *AuthenticationConfig, imsOrg, id string) (*http.Response, error)

func ISGetXID added in v0.3.1 

func ISGetXID(ctx context.Context, a *AuthenticationConfig, p *ISParams) (*http.Response, error)

ISGetXID returns the XID for the given namespace and id combination

func ISGetXIDR added in v0.3.1 

func ISGetXIDR(ctx context.Context, a *AuthenticationConfig, req *Request) (*http.Response, error)

func ISListNamespaces added in v0.3.1 

func ISListNamespaces(ctx context.Context, a *AuthenticationConfig) (*http.Response, error)

func ISListNamespacesIMSOrg added in v0.3.1 

func ISListNamespacesIMSOrg(ctx context.Context, a *AuthenticationConfig, imsOrg string) (*http.Response, error)

func ISUpdateNamespace added in v0.3.1 

func ISUpdateNamespace(ctx context.Context, a *AuthenticationConfig, id string, body []byte) (*http.Response, error)

func List added in v0.3.0 

func List(ctx context.Context, p *AuthenticationConfig) (interface{}, error)

List returns a list of usable sandboxes TODO implement new generic API

func NewJSONIterator added in v0.2.0 

func NewJSONIterator(res *http.Response, err error) (*util.JSONIterator, error)

func NewQuery added in v0.2.0 

func NewQuery(res *http.Response, err error) (*util.Query, error)

func ODGet added in v0.3.0 

func ODGet(ctx context.Context, p *AuthenticationConfig, params *ODGetParams) (*http.Response, error)

ODGet returns a collection by name (wild cards are supported) or id (exact match)

func ODGetP added in v0.3.0 

func ODGetP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

ODGetP returns a collection by name (wild cards are supported) or id (exact match)

func ODQueryP added in v0.3.0 

func ODQueryP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

ODQueryP sends a query to the offer decisioning API

func PrintResponse added in v0.3.1 

func PrintResponse(res *http.Response, err error) error

func QSCancelQuery added in v0.3.2 

func QSCancelQuery(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func QSCancelRun added in v0.3.2 

func QSCancelRun(ctx context.Context, a *AuthenticationConfig, scheduleId, runId string) (*http.Response, error)

func QSCreateQuery added in v0.3.2 

func QSCreateQuery(ctx context.Context, a *AuthenticationConfig, body []byte) (*http.Response, error)

func QSCreateQueryTemplate added in v0.3.2 

func QSCreateQueryTemplate(ctx context.Context, a *AuthenticationConfig, body []byte) (*http.Response, error)

func QSCreateSchedule added in v0.3.2 

func QSCreateSchedule(ctx context.Context, a *AuthenticationConfig, body []byte) (*http.Response, error)

func QSDeleteQuery added in v0.3.2 

func QSDeleteQuery(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func QSDeleteQueryTemplate added in v0.3.2 

func QSDeleteQueryTemplate(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func QSDeleteSchedule added in v0.3.2 

func QSDeleteSchedule(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func QSGetConnection added in v0.3.2 

func QSGetConnection(ctx context.Context, a *AuthenticationConfig) (*http.Response, error)

QSGetConnection retrieves connection parameters for the interactive interface

func QSGetQuery added in v0.3.2 

func QSGetQuery(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

QSGetQuery returns the details of a query by id

func QSGetRun added in v0.3.2 

func QSGetRun(ctx context.Context, a *AuthenticationConfig, scheduleId, runId string) (*http.Response, error)

QSGetRun returns the details of a scheduled query run by id

func QSGetSchedule added in v0.3.2 

func QSGetSchedule(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

QSGetSchedule returns the details of a scheduled query by id

func QSGetTemplate added in v0.3.2 

func QSGetTemplate(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

QSGetTemplate returns the details of a query template by id

func QSListQueries added in v0.3.2 

func QSListQueries(ctx context.Context, a *AuthenticationConfig, p *QSListQueriesParams) (*http.Response, error)

QSListQueries calls the query servie to list queries

func QSListQueriesP added in v0.3.2 

func QSListQueriesP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

QSListQueriesR calls the query servie to list queries

func QSListRunsP added in v0.3.2 

func QSListRunsP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

QSListRunsP calls the query service to list runs for a

func QSListSchedulesP added in v0.3.2 

func QSListSchedulesP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

QSListQueriesR calls the query servie to list queries

func QSListTemplatesP added in v0.3.2 

func QSListTemplatesP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

QSListTemplatesP calls the query service to list query templates

func QSTriggerRun added in v0.3.2 

func QSTriggerRun(ctx context.Context, a *AuthenticationConfig, scheduleId string) (*http.Response, error)

QSTriggerRun triggers an immediate scheduled trigger run

func QSUpdateQueryTemplate added in v0.3.2 

func QSUpdateQueryTemplate(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func QSUpdateSchedule added in v0.3.2 

func QSUpdateSchedule(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SBGetSandbox added in v0.3.0 

func SBGetSandbox(ctx context.Context, p *AuthenticationConfig, params SBGetSandboxParams) (*http.Response, error)

SBGetSandbox returns the details of a sandbox with the given name

func SBGetSandboxP added in v0.3.0 

func SBGetSandboxP(ctx context.Context, p *AuthenticationConfig, params *Request) (*http.Response, error)

SBGetSandboxP returns the details of a sandbox with the given name

func SBListAllSandboxes added in v0.3.0 

func SBListAllSandboxes(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

SBListAllSandboxes returns a list of all sandboxes

func SBListSandboxTypes added in v0.3.0 

func SBListSandboxTypes(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

SBListSandboxTypes lists the available sandbox types

func SBListSandboxes added in v0.3.0 

func SBListSandboxes(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

SBListSandboxes returns a list of usable sandboxes

func SRCreateClass added in v0.3.1 

func SRCreateClass(ctx context.Context, a *AuthenticationConfig, payload []byte) (*http.Response, error)

func SRCreateDataType added in v0.3.1 

func SRCreateDataType(ctx context.Context, a *AuthenticationConfig, payload []byte) (*http.Response, error)

func SRCreateDescriptor added in v0.3.1 

func SRCreateDescriptor(ctx context.Context, a *AuthenticationConfig, payload []byte) (*http.Response, error)

func SRCreateFieldGroup added in v0.3.1 

func SRCreateFieldGroup(ctx context.Context, a *AuthenticationConfig, payload []byte) (*http.Response, error)

func SRCreateSchema added in v0.3.1 

func SRCreateSchema(ctx context.Context, a *AuthenticationConfig, payload []byte) (*http.Response, error)

func SRDeleteClass added in v0.3.0 

func SRDeleteClass(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRDeleteDataType added in v0.3.0 

func SRDeleteDataType(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRDeleteDescriptor added in v0.3.0 

func SRDeleteDescriptor(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRDeleteFieldGroup added in v0.3.0 

func SRDeleteFieldGroup(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRDeleteSchema added in v0.3.0 

func SRDeleteSchema(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRExport added in v0.3.0 

func SRExport(ctx context.Context, a *AuthenticationConfig, id string) (*http.Response, error)

func SRExportP added in v0.3.0 

func SRExportP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetAuditLog added in v0.3.0 

func SRGetAuditLog(ctx context.Context, a *AuthenticationConfig, schemaID string) (*http.Response, error)

func SRGetBehavior added in v0.3.0 

func SRGetBehavior(ctx context.Context, a *AuthenticationConfig, p *SRGetGlobalParams) (*http.Response, error)

func SRGetBehaviorP added in v0.3.0 

func SRGetBehaviorP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetClass added in v0.3.0 

func SRGetClass(ctx context.Context, a *AuthenticationConfig, p *SRGetParams) (*http.Response, error)

func SRGetClassP added in v0.3.0 

func SRGetClassP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetDataType added in v0.3.0 

func SRGetDataType(ctx context.Context, a *AuthenticationConfig, p *SRGetParams) (*http.Response, error)

func SRGetDataTypeP added in v0.3.0 

func SRGetDataTypeP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetDescriptor added in v0.3.0 

func SRGetDescriptor(ctx context.Context, a *AuthenticationConfig, p *SRListDescriptorsParams) (*http.Response, error)

func SRGetDescriptorP added in v0.3.0 

func SRGetDescriptorP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetFieldGroup added in v0.3.0 

func SRGetFieldGroup(ctx context.Context, a *AuthenticationConfig, p *SRGetParams) (*http.Response, error)

func SRGetFieldGroupP added in v0.3.0 

func SRGetFieldGroupP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetSample added in v0.3.0 

func SRGetSample(ctx context.Context, a *AuthenticationConfig, schemaID string) (*http.Response, error)

func SRGetSchema added in v0.3.0 

func SRGetSchema(ctx context.Context, a *AuthenticationConfig, p *SRGetParams) (*http.Response, error)

func SRGetSchemaP added in v0.3.0 

func SRGetSchemaP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRGetStats added in v0.3.0 

func SRGetStats(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

GetStats returns schema registry informations

func SRGetStatsP added in v0.3.0 

func SRGetStatsP(ctx context.Context, p *AuthenticationConfig) (*http.Response, error)

GetStatsP returns schema registry informations

func SRGetUnion added in v0.3.0 

func SRGetUnion(ctx context.Context, a *AuthenticationConfig, p *SRGetParams) (*http.Response, error)

func SRGetUnionP added in v0.3.0 

func SRGetUnionP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRImport added in v0.3.0 

func SRImport(ctx context.Context, a *AuthenticationConfig, resource []byte) (*http.Response, error)

func SRImportStream added in v0.3.0 

func SRImportStream(ctx context.Context, a *AuthenticationConfig, r io.Reader) (*http.Response, error)

func SRListBehaviors added in v0.3.0 

func SRListBehaviors(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListBehaviorsP added in v0.3.0 

func SRListBehaviorsP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListClasses added in v0.3.0 

func SRListClasses(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListClassesP added in v0.3.0 

func SRListClassesP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListDataTypes added in v0.3.0 

func SRListDataTypes(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListDataTypesP added in v0.3.0 

func SRListDataTypesP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListDescriptors added in v0.3.0 

func SRListDescriptors(ctx context.Context, a *AuthenticationConfig, p *SRListDescriptorsParams) (*http.Response, error)

func SRListDescriptorsP added in v0.3.0 

func SRListDescriptorsP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListFieldGroups added in v0.3.0 

func SRListFieldGroups(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListFieldGroupsP added in v0.3.0 

func SRListFieldGroupsP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListSchemas added in v0.3.0 

func SRListSchemas(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListSchemasP added in v0.3.0 

func SRListSchemasP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRListUnions added in v0.3.0 

func SRListUnions(ctx context.Context, a *AuthenticationConfig, p *SRListParams) (*http.Response, error)

func SRListUnionsP added in v0.3.0 

func SRListUnionsP(ctx context.Context, a *AuthenticationConfig, p *Request) (*http.Response, error)

func SRPatchClass added in v0.3.1 

func SRPatchClass(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRPatchDataType added in v0.3.1 

func SRPatchDataType(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRPatchFieldGroup added in v0.3.1 

func SRPatchFieldGroup(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRPatchSchema added in v0.3.1 

func SRPatchSchema(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRUpdateClass added in v0.3.1 

func SRUpdateClass(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRUpdateDataType added in v0.3.1 

func SRUpdateDataType(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRUpdateDescriptor added in v0.3.1 

func SRUpdateDescriptor(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRUpdateFieldGroup added in v0.3.1 

func SRUpdateFieldGroup(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func SRUpdateSchema added in v0.3.1 

func SRUpdateSchema(ctx context.Context, a *AuthenticationConfig, id string, payload []byte) (*http.Response, error)

func UPSGetEntities added in v0.2.0 

func UPSGetEntities(ctx context.Context, auth *AuthenticationConfig, p *UPSEntitiesParams) (*http.Response, error)

func UPSGetEntitiesP added in v0.3.0 

func UPSGetEntitiesP(ctx context.Context, auth *AuthenticationConfig, p *Request) (*http.Response, error)

Types

type ACGetEffecticeACLPoliciesParams added in v0.3.0 

type ACGetEffecticeACLPoliciesParams []string

func (ACGetEffecticeACLPoliciesParams) Request added in v0.3.2 

func (p ACGetEffecticeACLPoliciesParams) Request() *Request

type AuthenticationConfig 

type AuthenticationConfig struct {
	Cache            bool
	DryRun           bool
	Server           string
	Organization     string
	TechnicalAccount string
	Audience         string
	ClientID         string
	ClientSecret     string
	Key              string
	Sandbox          string
	LoadToken        func() (*BearerToken, error)
	SaveToken        func(token *BearerToken) error
}

AuthenticationConfig contains the configuraion for getting the bearer token

func (*AuthenticationConfig) DeleteRequest 

func (o *AuthenticationConfig) DeleteRequest(ctx context.Context, url string, a ...interface{}) (interface{}, error)

DeleteRequest sends a http delete request to the passed url

func (*AuthenticationConfig) DeleteRequestRaw added in v0.3.0 

func (o *AuthenticationConfig) DeleteRequestRaw(ctx context.Context, url string, a ...interface{}) (*http.Response, error)

DeleteRequestRaw sends a HTTP DELETE request to the passed url

func (*AuthenticationConfig) FullRequest 

func (o *AuthenticationConfig) FullRequest(ctx context.Context, verb string, header map[string]string, body io.Reader, url string, a ...interface{}) (interface{}, error)

FullRequest sends a http request with the passed verb to the passed url

func (*AuthenticationConfig) FullRequestRaw added in v0.2.0 

func (o *AuthenticationConfig) FullRequestRaw(ctx context.Context, verb string, header map[string]string, body io.Reader, url string, a ...interface{}) (*http.Response, error)

FullRequestRaw sends a http request with the passed verb to the passed url

func (*AuthenticationConfig) GetRequest 

func (o *AuthenticationConfig) GetRequest(ctx context.Context, url string, a ...interface{}) (interface{}, error)

GetRequest sends a http get request to the passed url

func (*AuthenticationConfig) GetRequestHRaw added in v0.3.0 

func (o *AuthenticationConfig) GetRequestHRaw(ctx context.Context, header map[string]string, url string, a ...interface{}) (*http.Response, error)

GetRequestHRaw sends a http get request to the passed url

func (*AuthenticationConfig) GetRequestRaw added in v0.2.0 

func (o *AuthenticationConfig) GetRequestRaw(ctx context.Context, url string, a ...interface{}) (*http.Response, error)

GetRequestRaw sends a http get request to the passed url

func (*AuthenticationConfig) GetToken 

func (o *AuthenticationConfig) GetToken() (*BearerToken, error)

GetToken uses JWT to get a bearer token

func (*AuthenticationConfig) GetTokenRaw added in v0.2.0 

func (o *AuthenticationConfig) GetTokenRaw() (*http.Response, error)

GetTokenRaw uses JWT to get a bearer token

func (*AuthenticationConfig) NoDryRun added in v0.2.0 

func (o *AuthenticationConfig) NoDryRun() *AuthenticationConfig

func (*AuthenticationConfig) PatchRequest 

func (o *AuthenticationConfig) PatchRequest(ctx context.Context, header map[string]string, data []byte, url string, a ...interface{}) (interface{}, error)

PatchRequest sends a http patch request to the passed url

func (*AuthenticationConfig) PatchRequestRaw added in v0.3.1 

func (o *AuthenticationConfig) PatchRequestRaw(ctx context.Context, header map[string]string, data []byte, url string, a ...interface{}) (*http.Response, error)

PatchRequestRaw sends a http patch request to the passed url

func (*AuthenticationConfig) PostJSONRequest 

func (o *AuthenticationConfig) PostJSONRequest(ctx context.Context, obj interface{}, url string, a ...interface{}) (interface{}, error)

PostJSONRequest serializes the passed object to JSON and sends a http post request to the passed url

func (*AuthenticationConfig) PostJSONRequestRaw added in v0.2.0 

func (o *AuthenticationConfig) PostJSONRequestRaw(ctx context.Context, obj interface{}, url string, a ...interface{}) (*http.Response, error)

PostJSONRequestRaw serializes the passed object to JSON and sends a http post request to the passed url

func (*AuthenticationConfig) PostRequest 

func (o *AuthenticationConfig) PostRequest(ctx context.Context, header map[string]string, data []byte, url string, a ...interface{}) (interface{}, error)

PostRequest sends a http post request to the passed url

func (*AuthenticationConfig) PostRequestRaw added in v0.3.0 

func (o *AuthenticationConfig) PostRequestRaw(ctx context.Context, header map[string]string, data []byte, url string, a ...interface{}) (*http.Response, error)

PostRequestRaw sends a http post request to the passed url

func (*AuthenticationConfig) PostRequestStream added in v0.3.0 

func (o *AuthenticationConfig) PostRequestStream(ctx context.Context, header map[string]string, r io.Reader, url string, a ...interface{}) (*http.Response, error)

PostRequestRaw sends a http post request to the passed url

func (*AuthenticationConfig) PutRequestRaw added in v0.3.1 

func (o *AuthenticationConfig) PutRequestRaw(ctx context.Context, header map[string]string, data []byte, url string, a ...interface{}) (*http.Response, error)

PutRequestRaw sends a http put request to the passed url

func (*AuthenticationConfig) Request 

func (o *AuthenticationConfig) Request(ctx context.Context, verb, url string, a ...interface{}) (interface{}, error)

Request sends a http request with the passed verb to the passed url

func (*AuthenticationConfig) UpdateHeader 

func (o *AuthenticationConfig) UpdateHeader(req *http.Request) error

UpdateHeader adds the authentication headers to the passed http request

type BatchesOptions added in v0.3.0 

type BatchesOptions struct {
	Limit         int
	TimeFormat    string
	CreatedAfter  string
	CreatedBefore string
	Dataset       string
	EndAfter      string
	EndBefore     string
	Name          string
	OrderBy       string
	StartAfter    string
	StartBefore   string
}

BatchesOptions contains all options for batch requests

func (*BatchesOptions) Request added in v0.3.2 

func (b *BatchesOptions) Request() (*Request, error)

ToURLPar converts the options to a URL parameter query

type BearerToken 

type BearerToken struct {
	Token   string
	Expires time.Time
}

BearerToken contains a token and an expiration date

func (*BearerToken) LocalTime 

func (t *BearerToken) LocalTime() string

LocalTime returns the expiry date as string in the local time zone

func (*BearerToken) ValidIn 

func (t *BearerToken) ValidIn(d time.Duration) bool

ValidIn in checks if the token is still valid for passed duration

type DAOptions added in v0.3.0 

type DAOptions struct {
	ID    string
	Start int
	Limit int
}

func (*DAOptions) Request added in v0.3.2 

func (d *DAOptions) Request() *Request

type DataSetRequest added in v0.3.0 

type DataSetRequest struct {
	ConncectorID    string           `json:"connectorId,omitempty" yaml:"connectorId,omitempty"`
	ConncectoionID  string           `json:"connectionId,omitempty" yaml:"connectionId,omitempty"`
	Name            string           `json:"name,omitempty" yaml:"name,omitempty"`
	Namespace       string           `json:"namespace,omitempty" yaml:"namespace,omitempty"`
	FileDescription *FileDescription `json:"fileDescription,omitempty" yaml:"fileDescription,omitempty"`
	SchemaRef       *SchemaRef       `json:"schemaRef,omitempty" yaml:"schemaRef,omitempty"`
}

type FileDescription added in v0.3.0 

type FileDescription struct {
	Format          string `json:"format,omitempty" yaml:"format,omitempty"`
	ContainerFormat string `json:"containerFormat,omitempty" yaml:"containerFormat,omitempty"`
	Persisted       bool   `json:"persisted,omitempty" yaml:"persisted,omitempty"`
}

type FlowGetConnectionsParams added in v0.2.0 

type FlowGetConnectionsParams struct {
	PageParams
	Count bool
}

func (*FlowGetConnectionsParams) Request added in v0.3.2 

func (p *FlowGetConnectionsParams) Request() *Request

type Func added in v0.3.0 

type Func func(context.Context, *AuthenticationConfig, *Request) (*http.Response, error)

type FuncID added in v0.3.0 

type FuncID func(context.Context, *AuthenticationConfig, string) (*http.Response, error)

type FuncPost added in v0.3.1 

type FuncPost func(context.Context, *AuthenticationConfig, []byte) (*http.Response, error)

type FuncPostID added in v0.3.1 

type FuncPostID func(context.Context, *AuthenticationConfig, string, []byte) (*http.Response, error)

type FuncTable added in v0.3.0 

type FuncTable map[string]Func

func (FuncTable) Call added in v0.3.0 

func (ft FuncTable) Call(name string, ctx context.Context, auth *AuthenticationConfig, params *Request) (*http.Response, error)

type ISClusterParams added in v0.3.1 

type ISClusterParams struct {
	ISParams
	GraphType string
}

func (*ISClusterParams) Accept added in v0.3.1 

func (p *ISClusterParams) Accept() string

func (*ISClusterParams) Request added in v0.3.1 

func (p *ISClusterParams) Request() *Request

type ISClustersParams added in v0.3.1 

type ISClustersParams struct {
	Namespaces   []string
	NamesapceIDs []string
	IDs          []string
	GraphType    string
	Region       string
}

func (*ISClustersParams) Body added in v0.3.1 

func (p *ISClustersParams) Body() ([]byte, error)

func (*ISClustersParams) Request added in v0.3.1 

func (p *ISClustersParams) Request() (*Request, error)

type ISGetMappingParams added in v0.3.1 

type ISGetMappingParams struct {
	ISParams
	TargetNS string
}

type ISParams added in v0.3.1 

type ISParams struct {
	Namespace   string
	NamespaceID string
	ID          string
	Region      string
}

func (*ISParams) Request added in v0.3.1 

func (p *ISParams) Request() *Request

func (*ISParams) Validate added in v0.3.1 

func (p *ISParams) Validate() error

type ODGetParams added in v0.3.0 

type ODGetParams struct {
	ID          string
	ContainerID string
	Schema      string
}

func (*ODGetParams) Request added in v0.3.2 

func (p *ODGetParams) Request() *Request

Params returns the parameters in generic Request format

type ODQueryParames added in v0.3.0 

type ODQueryParames struct {
	ContainerID string
	Schema      string
	Query       string
	QOP         string
	Field       string
	OrderBy     string
	Limit       int
}

ODQueryParames contains all available parameters for offer decisioning queries.

func (*ODQueryParames) Request added in v0.3.2 

func (p *ODQueryParames) Request() *Request

Params returns the parameters in generic Request format

type PageParams added in v0.3.2 

type PageParams struct {
	Order  string
	Limit  int
	Start  string
	Filter string
}

PageParams contains often used parameters for paging

func (*PageParams) Request added in v0.3.2 

func (p *PageParams) Request() *Request

Request uses start parameter for paging

func (*PageParams) RequestToken added in v0.3.2 

func (p *PageParams) RequestToken() *Request

RequestToken uses continuationToken for paging

type Parameters added in v0.3.0 

type Parameters interface {
	Params() *Request
}

type ParametersE added in v0.3.0 

type ParametersE interface {
	Request() (*Request, error)
}

type QSListQueriesParams added in v0.3.2 

type QSListQueriesParams struct {
	PageParams
	ExcludeSoftDeleted bool
	ExcludeHidden      bool
}

QSListQueriesParams defines the parameters for list queries

func (*QSListQueriesParams) Request added in v0.3.2 

func (p *QSListQueriesParams) Request() *Request

type Request added in v0.3.1 

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

Request consists of HTTP header, body, query and auxiliary values

func NewRequest added in v0.3.1 

func NewRequest(queries ...string) *Request

NewRequest accepts string pairs of name and value for the HTTP query

func NewRequestBody added in v0.3.1 

func NewRequestBody(body []byte, queries ...string) *Request

NewRequestBody accpets a body payload and name value pairs for the HTTP query

func NewRequestHeader added in v0.3.1 

func NewRequestHeader(header ...string) *Request

NewRequestHeader accepts string pairs of name and value for the HTTP header

func NewRequestValues added in v0.3.2 

func NewRequestValues(values ...string) *Request

NewRequestValues accepts pairs of name and value for multiple purposes, e.g. in the path or host

func (*Request) Accept added in v0.3.1 

func (r *Request) Accept(value string)

func (*Request) AddQueries added in v0.3.2 

func (p *Request) AddQueries(values ...string)

func (*Request) AddQuery added in v0.3.2 

func (r *Request) AddQuery(name, value string)

func (*Request) Clone added in v0.3.2 

func (r *Request) Clone() *Request

Clone creates a copy with the same body array

func (*Request) ContentType added in v0.3.1 

func (r *Request) ContentType(value string)

func (*Request) EncodedQuery added in v0.3.1 

func (r *Request) EncodedQuery() string

func (*Request) GetArray added in v0.3.2 

func (r *Request) GetArray(name string) []string

func (*Request) GetValue added in v0.3.1 

func (r *Request) GetValue(name string) string

func (*Request) GetValuePath added in v0.3.1 

func (r *Request) GetValuePath(name string) string

func (*Request) GetValueQuery added in v0.3.1 

func (r *Request) GetValueQuery(name string) string

func (*Request) GetValueV added in v0.3.1 

func (r *Request) GetValueV(name, value string) string

GetValueV returns the value with the passed name. If the value doesn't exist it returns the second value.

func (*Request) Header added in v0.3.1 

func (r *Request) Header() map[string]string

func (*Request) SetArray added in v0.3.2 

func (r *Request) SetArray(name string, value []string)

func (*Request) SetHeader added in v0.3.1 

func (r *Request) SetHeader(name, value string)

func (*Request) SetHeaderIf added in v0.3.2 

func (r *Request) SetHeaderIf(name, value string)

func (*Request) SetHeaders added in v0.3.2 

func (p *Request) SetHeaders(values ...string)

func (*Request) SetValue added in v0.3.1 

func (r *Request) SetValue(name, value string)

func (*Request) SetValues added in v0.3.2 

func (p *Request) SetValues(values ...string)

type SBGetSandboxParams added in v0.3.0 

type SBGetSandboxParams string

func (SBGetSandboxParams) Request added in v0.3.2 

func (p SBGetSandboxParams) Request() *Request

type SRBaseParams added in v0.3.0 

type SRBaseParams struct {
	PageParams
	Predefined bool
}

func (*SRBaseParams) Request added in v0.3.2 

func (p *SRBaseParams) Request() *Request

type SRDescriptorFormat added in v0.3.0 

type SRDescriptorFormat int

func (SRDescriptorFormat) Accept added in v0.3.0 

func (f SRDescriptorFormat) Accept() string

type SRFormat added in v0.3.0 

type SRFormat struct {
	Short       bool
	Full        bool
	NoText      bool
	Descriptors bool
	Version     string
}

func (*SRFormat) Accept added in v0.3.0 

func (s *SRFormat) Accept() string

accept builds the accept string

func (*SRFormat) Request added in v0.3.2 

func (s *SRFormat) Request() *Request

type SRGetBaseParams added in v0.3.0 

type SRGetBaseParams struct {
	ID     string
	Global bool
}

func (*SRGetBaseParams) Request added in v0.3.2 

func (p *SRGetBaseParams) Request() *Request

type SRGetDescriptorParams added in v0.3.0 

type SRGetDescriptorParams struct {
	SRGetBaseParams
	SRDescriptorFormat
}

func (*SRGetDescriptorParams) Request added in v0.3.2 

func (p *SRGetDescriptorParams) Request() *Request

type SRGetGlobalParams added in v0.3.0 

type SRGetGlobalParams struct {
	SRFormat
	ID string
}

func (*SRGetGlobalParams) Request added in v0.3.2 

func (p *SRGetGlobalParams) Request() *Request

type SRGetParams added in v0.3.0 

type SRGetParams struct {
	SRGetBaseParams
	SRFormat
}

func (*SRGetParams) Request added in v0.3.2 

func (p *SRGetParams) Request() *Request

type SRListDescriptorsParams added in v0.3.0 

type SRListDescriptorsParams struct {
	SRBaseParams
	SRDescriptorFormat
}

func (*SRListDescriptorsParams) Request added in v0.3.2 

func (p *SRListDescriptorsParams) Request() *Request

type SRListParams added in v0.3.0 

type SRListParams struct {
	SRBaseParams
	SRFormat
}

func (*SRListParams) Request added in v0.3.2 

func (p *SRListParams) Request() *Request

type SchemaRef added in v0.3.0 

type SchemaRef struct {
	ID          string `json:"id,omitempty" yaml:"id,omitempty"`
	ContentType string `json:"contentType,omitempty" yaml:"contentType,omitempty"`
}

type UPSEntitiesParams added in v0.2.0 

type UPSEntitiesParams struct {
	Schema        string
	RelatedSchema string
	ID            string
	NS            string
	RelatedID     string
	RelatedNS     string
	Fields        string
	MP            string
	Start         string
	End           string
	Limit         int
	Order         string
	Property      string
	CA            bool
	TimeFormat    string
}

func (*UPSEntitiesParams) Request added in v0.3.2 

func (p *UPSEntitiesParams) Request() (*Request, error)

Source Files

View all Source files

Directories

Path Synopsis
Package od contains offer decisiong related functions.
 Package od contains offer decisiong related functions.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.