client

package

Go to main page

Versions in this module

v0

v0.41.8

Oct 13, 2025

Changes in this version

+ func GetJobEvents(ctxt context.Context, serviceId string, jobId string, lastEventID *string, ...) error

+ func ReadServiceJobRaw(ctxt context.Context, cmd *ReadServiceJobRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ type JobCreateBadRequestResponseBody struct

+ Message *string

+ type JobCreateInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type JobCreateInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type JobCreateNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type JobCreateNotImplementedResponseBody struct

+ Message *string

+ type JobCreateNotReadyYetResponseBody struct

+ JobID *string

+ Location *string

+ RetryLater *int

+ type JobCreateT struct

+ JobID string

+ RetryLater float64

+ ServiceID string

+ func CreateServiceJobRaw(ctxt context.Context, serviceId string, pyld adapter.Payload, timeout int, ...) (adapter.Payload, *JobCreateT, error)

+ type JobEventsBadRequestResponseBody struct

+ Message *string

+ type JobEventsEventTimeoutResponseBody struct

+ Fault *bool

+ ID *string

+ Message *string

+ Name *string

+ Temporary *bool

+ Timeout *bool

+ type JobEventsInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type JobEventsInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type JobEventsJobInternalErrorResponseBody struct

+ Message *string

+ type JobEventsJobRequestErrorResponseBody struct

+ Message *string

+ type JobEventsNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type JobEventsNotImplementedResponseBody struct

+ Message *string

+ type JobEventsResponseBody struct

+ Data any

+ EventID *string

+ Schema *string

+ SeqID *string

+ Source *string

+ Timestamp *string

+ Type *string

+ type JobListBadRequestResponseBody struct

+ Message *string

+ type JobListInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type JobListInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type JobListItemResponseBody struct

+ FinishedAt *string

+ Href *string

+ ID *string

+ Name *string

+ Order *string

+ Service *string

+ StartedAt *string

+ Status *string

+ type JobListNotImplementedResponseBody struct

+ Message *string

+ type JobListResponseBody struct

+ AtTime *string

+ Items []*JobListItemResponseBody

+ Links []*LinkTResponseBody

+ type JobOutputBadRequestResponseBody struct

+ Message *string

+ type JobOutputInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type JobOutputInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type JobOutputJobInternalErrorResponseBody struct

+ Message *string

+ type JobOutputJobRequestErrorResponseBody struct

+ Message *string

+ type JobOutputNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type JobOutputNotImplementedResponseBody struct

+ Message *string

+ type JobOutputNotReadyYetResponseBody struct

+ JobID *string

+ RetryLater *int

+ type JobReadBadRequestResponseBody struct

+ Message *string

+ type JobReadInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type JobReadNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type JobReadNotImplementedResponseBody struct

+ Message *string

+ type JobReadResponseBody struct

+ Account *string

+ ErrorMessage *string

+ FinishedAt *string

+ ID *string

+ Links []*LinkTResponseBody

+ Name *string

+ Order *string

+ Policy *string

+ Products *PartialProductList2TResponseBody

+ RequestContent any

+ RequestContentType *string

+ RequestedAt *string

+ ResultContent any

+ ResultContentType *string

+ ResultContentUrn *string

+ Service *string

+ StartedAt *string

+ Status *string

+ Tags []string

+ func ReadServiceJob(ctxt context.Context, cmd *ReadServiceJobRequest, adpt *adapter.Adapter, ...) (*JobReadResponseBody, adapter.Payload, error)

+ type LinkTResponseBody struct

+ Href *string

+ Rel *string

+ Type *string

+ type ParameterDefT struct

+ Constant *bool

+ Default *string

+ Description string

+ Label *string

+ Name string

+ Optional *bool

+ Options []*ParameterOptT

+ Type string

+ Unary *bool

+ Unit *string

+ type ParameterDefTResponseBody struct

+ Constant *bool

+ Default *string

+ Description *string

+ Label *string

+ Name *string

+ Optional *bool

+ Options []*ParameterOptTResponseBody

+ Type *string

+ Unary *bool

+ Unit *string

+ type ParameterOptT struct

+ Description *string

+ Value *string

+ type ParameterOptTResponseBody struct

+ Description *string

+ Value *string

+ type PartialProductList2TResponseBody struct

+ Items []*ProductListItem2TResponseBody

+ Links []*LinkTResponseBody

+ type ProductListItem2TResponseBody struct

+ DataHref *string

+ Href *string

+ ID *string

+ MimeType *string

+ Name *string

+ Size *int64

+ Status *string

+ type ReadServiceJobRequest struct

+ JobId string

+ ServiceId string

+ type ServiceCreateAlreadyCreatedResponseBody struct

+ ID *string

+ Message *string

+ type ServiceCreateBadRequestResponseBody struct

+ Message *string

+ type ServiceCreateInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type ServiceCreateInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ServiceCreateNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type ServiceCreateNotImplementedResponseBody struct

+ Message *string

+ type ServiceCreateRequestBody struct

+ Controller any

+ ControllerSchema string

+ Description string

+ ID string

+ Name *string

+ Parameters []*ParameterDefT

+ Policy string

+ Tags []string

+ type ServiceCreateResponseBody struct

+ Account *string

+ Controller any

+ ControllerSchema *string

+ Description *string

+ ID *string

+ Links []*LinkTResponseBody

+ Name *string

+ Parameters []*ParameterDefTResponseBody

+ Policy *string

+ Status *string

+ Tags []string

+ ValidFrom *string

+ ValidTo *string

+ type ServiceDeleteBadRequestResponseBody struct

+ Message *string

+ type ServiceDeleteInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ServiceDeleteNotImplementedResponseBody struct

+ Message *string

+ type ServiceListBadRequestResponseBody struct

+ Message *string

+ type ServiceListInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type ServiceListInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ServiceListItemTResponseBody struct

+ ControllerSchema *string

+ Description *string

+ Href *string

+ ID *string

+ Name *string

+ Tags []string

+ ValidFrom *string

+ ValidTo *string

+ type ServiceListNotImplementedResponseBody struct

+ Message *string

+ type ServiceListResponseBody struct

+ AtTime *string

+ Items []*ServiceListItemTResponseBody

+ Links []*LinkTResponseBody

+ type ServiceReadBadRequestResponseBody struct

+ Message *string

+ type ServiceReadInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ServiceReadNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type ServiceReadNotImplementedResponseBody struct

+ Message *string

+ type ServiceReadResponseBody struct

+ Account *string

+ Controller any

+ ControllerSchema *string

+ Description *string

+ ID *string

+ Links []*LinkTResponseBody

+ Name *string

+ Parameters []*ParameterDefTResponseBody

+ Policy *string

+ Status *string

+ Tags []string

+ ValidFrom *string

+ ValidTo *string

+ type ServiceUpdateBadRequestResponseBody struct

+ Message *string

+ type ServiceUpdateInvalidParameterResponseBody struct

+ Message *string

+ Name *string

+ Value *string

+ type ServiceUpdateInvalidScopesResponseBody struct

+ ID *string

+ Message *string

+ type ServiceUpdateNotFoundResponseBody struct

+ ID *string

+ Message *string

+ type ServiceUpdateNotImplementedResponseBody struct

+ Message *string

+ type ServiceUpdateRequestBody struct

+ Controller any

+ ControllerSchema string

+ Description string

+ ID string

+ Name *string

+ Parameters []*ParameterDefT

+ Policy string

+ Tags []string

+ type ServiceUpdateResponseBody struct

+ Account *string

+ Controller any

+ ControllerSchema *string

+ Description *string

+ ID *string

+ Links []*LinkTResponseBody

+ Name *string

+ Parameters []*ParameterDefTResponseBody

+ Policy *string

+ Status *string

+ Tags []string

+ ValidFrom *string

+ ValidTo *string

v0.41.7

Jul 1, 2025

v0.41.6

Jun 20, 2025

v0.41.5

Apr 2, 2025

v0.41.4

Nov 19, 2024

Changes in this version

+ func GetSecret(ctxt context.Context, host string, req *GetSecretRequest, ...) (*api.GetResponseBody, error)

+ func GetSecretRaw(ctxt context.Context, host string, req *GetSecretRequest, ...) (adapter.Payload, error)

+ func ListSecrets(ctxt context.Context, host string, req *ListSecretsRequest, ...) (*api.ListResponseBody, error)

+ func ListSecretsRaw(ctxt context.Context, host string, req *ListSecretsRequest, ...) (adapter.Payload, error)

+ func SetSecret(ctxt context.Context, host string, req *api.SetRequestBody, ...) error

+ type GetSecretRequest struct

+ SecretName string

+ SecretType string

+ type ListSecretsRequest struct

+ Filter string

+ Limit int

+ OffsetToken string

+ Page string

v0.41.3

Aug 28, 2024

v0.41.2

Aug 1, 2024

Changes in this version

+ func CreateQueue(ctxt context.Context, cmd *api.CreateRequestBody, adpt *adapter.Adapter, ...) (*api.CreateResponseBody, error)

+ func CreateQueueRaw(ctxt context.Context, cmd *api.CreateRequestBody, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func DeleteQueueRaw(ctx context.Context, cmd *ReadQueueRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func Dequeue(ctx context.Context, cmd *ReadQueueRequest, limit int, adpt *adapter.Adapter, ...) (*api.DequeueResponseBody, error)

+ func DequeueRaw(ctx context.Context, cmd *ReadQueueRequest, limit int, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func Enqueue(ctx context.Context, cmd *ReadQueueRequest, schema string, message string, ...) (*api.EnqueueResponseBody, error)

+ func EnqueueRaw(ctx context.Context, cmd *ReadQueueRequest, schema string, message string, ...) (adapter.Payload, error)

+ func ListQueues(ctxt context.Context, cmd *ListRequest, adpt *adapter.Adapter, ...) (*api.ListResponseBody, error)

+ func ListQueuesRaw(ctxt context.Context, cmd *ListRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ReadQueue(ctxt context.Context, cmd *ReadQueueRequest, adpt *adapter.Adapter, ...) (*api.ReadResponseBody, error)

+ func ReadQueueRaw(ctxt context.Context, cmd *ReadQueueRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ type ReadQueueRequest struct

+ Id string

v0.40.5

Jul 10, 2024

Changes in this version

+ func ListPackages(ctxt context.Context, tag string, adpt *adapter.Adapter, logger *log.Logger) (*api.ListResponseBody, error)

+ func PullPackage(ctxt context.Context, tag string, adpt *adapter.Adapter, logger *log.Logger) error

+ func PushServicePackage(srcTagName string, forcePush, localImage bool, adpt *adapter.Adapter, ...) (*api.PushResponseBody, error)

+ func RemovePackage(ctxt context.Context, tag string, adpt *adapter.Adapter, logger *log.Logger) error

+ type PushStatus string

+ const PushStatusDone

+ const PushStatusErrored

+ const PushStatusInprogress

+ const PushStatusUnstarted

v0.35.2

Jun 18, 2024

v0.35.1

Apr 17, 2024

v0.35.0

Apr 17, 2024

Changes in this version

+ func GetAspectRaw(ctxt context.Context, recordID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

type AspectSelector

+ IncludeContent bool

+ type ListRequest struct

+ AtTime *time.Time

+ Filter *string

+ Limit int

+ OrderBy *string

+ OrderDesc bool

+ Page *string

v0.31.4

Mar 22, 2024

Changes in this version

type ListOrderRequest

+ OrderBy string

+ OrderDesc bool

type ListServiceRequest

+ OrderBy string

+ OrderDesc bool

v0.31.3

Jan 17, 2024

Changes in this version

+ func AddArtifactMeta(ctxt context.Context, artifactID string, schemaName string, meta io.Reader, ...) (adapter.Payload, error)

+ func AddArtifactToCollection(ctxt context.Context, artifactID string, collectionName string, ...) (adapter.Payload, error)

+ func AddProgressBar(description string, size int64, reader io.Reader) io.Reader

+ func AddUpdateAspect(ctxt context.Context, isAdd bool, entity string, schema string, policy string, ...) (adapter.Payload, error)

+ func AddUpdateMetadata(ctxt context.Context, isAdd bool, entity string, schema string, policy string, ...) (adapter.Payload, error)

+ func BaseEncode(value string) string

+ func CreateArtifact(ctxt context.Context, cmd *CreateArtifactRequest, contentType string, ...) (*api.UploadResponseBody, error)

+ func CreateArtifactRaw(ctxt context.Context, cmd *CreateArtifactRequest, contentType string, ...) (adapter.Payload, error)

+ func CreateOrder(ctxt context.Context, cmd *api.CreateRequestBody, adpt *adapter.Adapter, ...) (*api.CreateResponseBody, error)

+ func CreateOrderRaw(ctxt context.Context, cmd *api.CreateRequestBody, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func CreateService(ctxt context.Context, cmd *api.CreateServiceRequestBody, adpt *adapter.Adapter, ...) (*api.CreateServiceResponseBody, error)

+ func CreateServiceRaw(ctxt context.Context, cmd *api.CreateServiceRequestBody, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func DownloadOrderLog(ctxt context.Context, req *LogsRequestBody, adpt *adapter.Adapter, ...) error

+ func GetAspect(ctxt context.Context, recordID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func GetMetadata(ctxt context.Context, recordID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func GetProgressBar(description string, size int64) io.Writer

+ func ListArtifacts(ctxt context.Context, cmd *ListArtifactRequest, adpt *adapter.Adapter, ...) (*api.ListResponseBody, error)

+ func ListArtifactsRaw(ctxt context.Context, cmd *ListArtifactRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ListAspect(ctxt context.Context, selector AspectSelector, adpt *adapter.Adapter, ...) (*api.ListResponseBody, adapter.Payload, error)

+ func ListMetadata(ctxt context.Context, selector MetadataSelector, adpt *adapter.Adapter, ...) (*api.ListResponseBody, adapter.Payload, error)

+ func ListOrders(ctxt context.Context, cmd *ListOrderRequest, adpt *adapter.Adapter, ...) (*api.ListResponseBody, error)

+ func ListOrdersRaw(ctxt context.Context, cmd *ListOrderRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ListServices(ctxt context.Context, cmd *ListServiceRequest, adpt *adapter.Adapter, ...) (*api.ListResponseBody, error)

+ func ListServicesRaw(ctxt context.Context, cmd *ListServiceRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ReadArtifact(ctxt context.Context, cmd *ReadArtifactRequest, adpt *adapter.Adapter, ...) (*api.ReadResponseBody, error)

+ func ReadArtifactRaw(ctxt context.Context, cmd *ReadArtifactRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ReadOrder(ctxt context.Context, cmd *ReadOrderRequest, adpt *adapter.Adapter, ...) (*api.ReadResponseBody, error)

+ func ReadOrderRaw(ctxt context.Context, cmd *ReadOrderRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func ReadService(ctxt context.Context, cmd *ReadServiceRequest, adpt *adapter.Adapter, ...) (*api.ReadResponseBody, error)

+ func ReadServiceRaw(ctxt context.Context, cmd *ReadServiceRequest, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func RemoveArtifactToCollection(ctxt context.Context, artifactID string, collectionName string, ...) (adapter.Payload, error)

+ func RetractAspect(ctxt context.Context, recordID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func RevokeMetadata(ctxt context.Context, recordID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func TopOrder(ctxt context.Context, orderID string, adpt *adapter.Adapter, ...) (*api.TopResponseBody, error)

+ func TopOrderRaw(ctxt context.Context, orderID string, adpt *adapter.Adapter, ...) (adapter.Payload, error)

+ func UpdateService(ctxt context.Context, id string, createAnyway bool, cmd *api.UpdateRequestBody, ...) (*api.UpdateResponseBody, error)

+ func UpdateServiceRaw(ctxt context.Context, id string, createAnyway bool, cmd *api.UpdateRequestBody, ...) (adapter.Payload, error)

+ func UploadArtifact(ctxt context.Context, reader io.Reader, size int64, offset int64, ...) (err error)

+ type AspectSelector struct

+ Entity string

+ JsonFilter *string

+ Limit int

+ Page string

+ SchemaPrefix string

+ SimpleFilter *string

+ Timestamp *time.Time

+ type CreateArtifactRequest struct

+ Collection string

+ Meta map[string]string

+ Name string

+ Policy string

+ Size int64

+ type ListArtifactRequest struct

+ Limit int

+ Offset int

+ Page *string

+ type ListOrderRequest struct

+ Limit int

+ Offset int

+ Page *string

+ type ListServiceRequest struct

+ Limit int

+ Offset int

+ type LogsRequestBody struct

+ From int64

+ OrderID string

+ To int64

+ type MetadataSelector struct

+ Entity string

+ JsonFilter *string

+ Page string

+ SchemaPrefix string

+ SimpleFilter *string

+ Timestamp *time.Time

+ type ReadArtifactRequest struct

+ Id string

+ type ReadOrderRequest struct

+ Id string

+ type ReadServiceRequest struct

+ Id string

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