agent

package

Go to main page

Versions in this module

v0

v0.3.6

Aug 24, 2026

v0.3.5

Aug 23, 2026

v0.3.4

Aug 21, 2026

v0.3.3

Aug 18, 2026

v0.3.2

Aug 11, 2026

v0.3.1

Aug 11, 2026

v0.3.0

Aug 7, 2026

v0.2.0

Aug 3, 2026

Changes in this version

type Capabilities

+ Enrollment []odp.EnrollmentProtocol

+ type ContinuationOptions struct

+ MaxItems int

+ MaxPages int

+ Representation odp.Representation

type DiscoveredAction

+ Authentication odp.AuthenticationRequirement

type ServiceClient

+ func (client *ServiceClient) ContinueListCollectionPages(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Page[odp.Collection], error]

+ func (client *ServiceClient) ContinueListCollections(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Collection, error]

+ func (client *ServiceClient) ContinueListOfferingPages(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.OfferingPage[odp.Offering], error]

+ func (client *ServiceClient) ContinueListOfferings(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Offering, error]

+ func (client *ServiceClient) ContinueSearchCollectionPages(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Page[odp.Collection], error]

+ func (client *ServiceClient) ContinueSearchCollections(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Collection, error]

+ func (client *ServiceClient) ContinueSearchOfferingPages(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.OfferingPage[odp.Offering], error]

+ func (client *ServiceClient) ContinueSearchOfferings(ctx context.Context, next string, options ContinuationOptions) iter.Seq2[odp.Offering, error]

v0.1.0

Aug 3, 2026

Changes in this version

+ const CollectionFallback

+ const OfferingFallback

+ const ServiceDocumentFallback

+ var ErrUnsupportedOperation = errors.New("ODP Service does not advertise the requested operation")

+ type Agent struct

+ func New(options AgentOptions) (*Agent, error)

+ func (agent *Agent) Environment() directory.Environment

+ func (agent *Agent) SearchOfferingsAcrossServices(ctx context.Context, request FederatedSearchRequest) iter.Seq2[DiscoveryEvent, error]

+ type AgentOptions struct

+ Directory *directory.Client

+ DirectoryHTTPClient *http.Client

+ Environment directory.Environment

+ ServiceClient ServiceClientFactory

+ type Cache interface

+ Delete func(context.Context, string) error

+ Get func(context.Context, string) (CacheRecord, bool, error)

+ Set func(context.Context, string, CacheRecord) error

+ type CacheFallbacks struct

+ Collection time.Duration

+ Offering time.Duration

+ ServiceDocument time.Duration

+ type CacheRecord struct

+ Body []byte

+ ETag string

+ ExpiresAt time.Time

+ FinalURL string

+ LastModified string

+ Status int

+ StoredAt time.Time

+ type Capabilities struct

+ Onboarding []odp.Protocol

+ Operations []odp.Operation

+ Payments []odp.Protocol

+ type CapabilityIssue struct

+ Kind CapabilityKind

+ Message string

+ Scope CapabilityScope

+ type CapabilityKind string

+ const CapabilityKindFilters

+ const CapabilityKindSorts

+ type CapabilityScope string

+ const CapabilityScopeCollection

+ const CapabilityScopeService

+ type CollectionSearchOptions struct

+ Limit int

+ MaxItems int

+ MaxPages int

+ ParentID odp.Optional[string]

+ Query string

+ Representation odp.Representation

+ type DiscoveredAction struct

+ Description string

+ HTTP *DiscoveredHTTPAction

+ ID string

+ OpenAPI *DiscoveredOpenAPIAction

+ Rel odp.ActionRelation

+ type DiscoveredHTTPAction struct

+ Method string

+ Request *odp.ActionRequest

+ ResponseContentTypes []string

+ URL string

+ type DiscoveredOpenAPIAction struct

+ OperationID string

+ URL string

+ type DiscoveryEvent struct

+ Err error

+ Offering *odp.Offering

+ Service directory.Service

+ Type DiscoveryEventType

+ type DiscoveryEventType string

+ const DiscoveryIssue

+ const DiscoveryOffering

+ type FederatedSearchRequest struct

+ Concurrency int

+ MaxOfferingsPerService int

+ MaxServices int

+ Offerings OfferingSearchOptions

+ Services directory.SearchRequest

+ type Freshness string

+ const FreshnessFetched

+ const FreshnessFresh

+ const FreshnessRevalidated

+ type Inspection struct

+ Capabilities Capabilities

+ Document odp.ServiceDocument

+ FinalURL string

+ Freshness Freshness

+ RequestedURL string

+ ServiceOrigin string

+ type ListOptions struct

+ Limit int

+ MaxItems int

+ MaxPages int

+ Representation odp.Representation

+ type MemoryCache struct

+ func NewMemoryCache() *MemoryCache

+ func (cache *MemoryCache) Delete(_ context.Context, key string) error

+ func (cache *MemoryCache) Get(_ context.Context, key string) (CacheRecord, bool, error)

+ func (cache *MemoryCache) Set(_ context.Context, key string, record CacheRecord) error

+ type OfferingDetails struct

+ Actions []DiscoveredAction

+ AttributeSchema map[string]any

+ Issues []OfferingIssue

+ type OfferingIssue struct

+ ActionID string

+ Message string

+ Scope OfferingIssueScope

+ type OfferingIssueScope string

+ const OfferingIssueAction

+ const OfferingIssueAttributeSchema

+ const OfferingIssueAttributes

+ type OfferingSearchOptions struct

+ CollectionID string

+ Filters []odp.FilterExpression

+ IncludeDescendants bool

+ Limit int

+ MaxItems int

+ MaxPages int

+ Query string

+ Refinements []string

+ Representation odp.Representation

+ Sort string

+ type RequestError struct

+ Code string

+ Header http.Header

+ Problem *odp.ProblemDetails

+ Retryable bool

+ Status int

+ func (err *RequestError) Error() string

+ type ResolvedAction struct

+ Action DiscoveredAction

+ OpenAPIDocument map[string]any

+ Operation map[string]any

+ RequestSchema map[string]any

+ type ResolvedSortDefinition struct

+ Filters []odp.FilterDefinition

+ type SearchCapabilityCatalog struct

+ Filters map[string]odp.FilterDefinition

+ Issues []CapabilityIssue

+ Sorts map[string]ResolvedSortDefinition

+ type ServiceClient struct

+ func NewServiceClient(options ServiceClientOptions) (*ServiceClient, error)

+ func (client *ServiceClient) GetCollection(ctx context.Context, id string, representation odp.Representation) (odp.Collection, error)

+ func (client *ServiceClient) GetCollectionSearchCapabilities(ctx context.Context, id string) (SearchCapabilityCatalog, error)

+ func (client *ServiceClient) GetOffering(ctx context.Context, id string, representation odp.Representation) (odp.Offering, error)

+ func (client *ServiceClient) GetOfferingDetails(ctx context.Context, id string) (OfferingDetails, error)

+ func (client *ServiceClient) GetOfferingSearchCapabilities(ctx context.Context, collectionID string) (SearchCapabilityCatalog, error)

+ func (client *ServiceClient) Inspect(ctx context.Context) (Inspection, error)

+ func (client *ServiceClient) ListCollectionOfferingPages(ctx context.Context, collectionID string, options ListOptions) iter.Seq2[odp.OfferingPage[odp.Offering], error]

+ func (client *ServiceClient) ListCollectionOfferings(ctx context.Context, collectionID string, options ListOptions) iter.Seq2[odp.Offering, error]

+ func (client *ServiceClient) ListCollectionPages(ctx context.Context, options ListOptions) iter.Seq2[odp.Page[odp.Collection], error]

+ func (client *ServiceClient) ListCollections(ctx context.Context, options ListOptions) iter.Seq2[odp.Collection, error]

+ func (client *ServiceClient) ListOfferingPages(ctx context.Context, options ListOptions) iter.Seq2[odp.OfferingPage[odp.Offering], error]

+ func (client *ServiceClient) ListOfferings(ctx context.Context, options ListOptions) iter.Seq2[odp.Offering, error]

+ func (client *ServiceClient) ResolveAction(ctx context.Context, offeringID, actionID string) (ResolvedAction, error)

+ func (client *ServiceClient) SearchCollectionPages(ctx context.Context, options CollectionSearchOptions) iter.Seq2[odp.Page[odp.Collection], error]

+ func (client *ServiceClient) SearchCollections(ctx context.Context, options CollectionSearchOptions) iter.Seq2[odp.Collection, error]

+ func (client *ServiceClient) SearchOfferingPages(ctx context.Context, options OfferingSearchOptions) iter.Seq2[odp.OfferingPage[odp.Offering], error]

+ func (client *ServiceClient) SearchOfferings(ctx context.Context, options OfferingSearchOptions) iter.Seq2[odp.Offering, error]

+ type ServiceClientFactory func(context.Context, directory.Service) (*ServiceClient, error)

+ type ServiceClientOptions struct

+ AcceptLanguage string

+ Cache Cache

+ CacheFallbacks CacheFallbacks

+ CachePartition string

+ HTTPClient *http.Client

+ InitialPageSize int

+ MaxRedirects int

+ ServiceURL string

+ SupportingHTTPClient *http.Client

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