discovery

Nov 17, 2022

Changes in this version

type NilConnection

+ func (n NilConnection) RequestWithContext(ctx context.Context, subject string, v interface{}, vPtr interface{}) error

Jul 4, 2022

Changes in this version

+ type AllSourcesFailedError struct

+ NumSources int

+ func (e AllSourcesFailedError) Error() string

Jul 4, 2022

Changes in this version

type Engine

+ func (e *Engine) ExecuteRequestSync(ctx context.Context, req *sdp.ItemRequest) ([]*sdp.Item, []*sdp.ItemRequestError, error)

+ type SourceMethod int64

+ const Find

+ const Get

+ const Search

+ func (s SourceMethod) String() string

Jun 8, 2022

Changes in this version

+ const DefaultMaxRequestTimeout

type Engine

+ MaxRequestTimeout time.Duration

+ func (e *Engine) SetupMaxRequestTimeout()

May 30, 2022

Changes in this version

type Engine

+ func (e *Engine) ManagedConnection() *nats.EncodedConn

May 30, 2022

Changes in this version

type Engine

+ NATSQueueName string

May 13, 2022

Changes in this version

type Engine

+ func (e *Engine) CancelHandler(cancelRequest *sdp.CancelItemRequest)

+ func (e *Engine) HandleCancelItemRequest(cancelRequest *sdp.CancelItemRequest)

+ func (e *Engine) HandleItemRequest(itemRequest *sdp.ItemRequest)

May 9, 2022

Changes in this version

+ type NilConnection struct

+ func (n NilConnection) Publish(subject string, v interface{}) error

+ func (n NilConnection) Subscribe(subject string, cb nats.Handler) (*nats.Subscription, error)

Mar 19, 2022

Changes in this version

+ const UserAgentVersion

+ type BasicTokenClient struct

+ func NewBasicTokenClient(token string, keys nkeys.KeyPair) *BasicTokenClient

+ func (b *BasicTokenClient) GetJWT() (string, error)

+ func (b *BasicTokenClient) Sign(in []byte) ([]byte, error)

type NATSOptions

+ TokenClient TokenClient

+ type OAuthTokenClient struct

+ func NewOAuthTokenClient(clientID string, clientSecret string, oAuthTokenURL string, ...) *OAuthTokenClient

+ func (o *OAuthTokenClient) GetJWT() (string, error)

+ func (o *OAuthTokenClient) Sign(in []byte) ([]byte, error)

+ type TokenClient interface

+ GetJWT func() (string, error)

+ Sign func([]byte) ([]byte, error)

Jan 20, 2022

Changes in this version

+ const DefaultCheckInterval

type Engine

+ ConnectionWatchInterval time.Duration

+ ConnectionWatcher NATSWatcher

+ func (e *Engine) Restart() error

+ type NATSWatcher struct

+ Connection WatchableConnection

+ FailureHandler func()

+ func (w *NATSWatcher) Start(checkInterval time.Duration)

+ func (w *NATSWatcher) Stop()

+ type WatchableConnection interface

+ LastError func() error

+ Stats func() nats.Statistics

+ Status func() nats.Status

Jan 19, 2022

Changes in this version

type NATSOptions

+ MaxReconnect int

+ ReconnectJitter time.Duration

+ ReconnectWait time.Duration

Jan 17, 2022

Changes in this version

type Engine

+ func (e *Engine) ClearCache()

+ func (e *Engine) WillRespond(req *sdp.ItemRequest) bool

Jan 12, 2022

Changes in this version

+ var RFC1123 = regexp.MustCompile(`^[a-z0-9]([a-z0-9-]*[a-z0-9])?$`)

Dec 8, 2021

Changes in this version

type Engine

+ func (e *Engine) SendRequestSync(r *sdp.ItemRequest) (*sdp.RequestProgress, []*sdp.Item, error)

Dec 8, 2021

Changes in this version

+ func NewItemSubject() string

+ func NewResponseSubject() string

Dec 6, 2021

Changes in this version

type Engine

+ func (e *Engine) AddTriggers(triggers ...Trigger)

+ func (e *Engine) ClearTriggers()

+ func (e *Engine) ProcessTriggers(item *sdp.Item)

+ type Trigger struct

+ RequestGenerator func(in *sdp.Item) (*sdp.ItemRequest, error)

+ Type string

+ UniqueAttributeValueRegex *regexp.Regexp

+ func (t *Trigger) ProcessItem(i *sdp.Item) (*sdp.ItemRequest, error)

Nov 24, 2021

Changes in this version

type Engine

+ func (e *Engine) CancelItemRequestHandler(cancelRequest *sdp.CancelItemRequest)

+ func (e *Engine) DeleteTrackedRequest(uuid [16]byte)

+ func (e *Engine) ExpandRequest(request *sdp.ItemRequest) []*sdp.ItemRequest

+ func (e *Engine) GetTrackedRequest(uuid uuid.UUID) (*RequestTracker, error)

+ func (e *Engine) ItemRequestHandler(itemRequest *sdp.ItemRequest)

+ func (e *Engine) Subscribe(subject string, handler nats.Handler) error

+ func (e *Engine) TrackRequest(uuid uuid.UUID, request *RequestTracker)

type RequestTracker

+ Request *sdp.ItemRequest

+ func (r *RequestTracker) Cancel()

Nov 9, 2021

Changes in this version

+ func TestValidateItem(t *testing.T, i *sdp.Item)

+ func TestValidateItems(t *testing.T, is []*sdp.Item)

type Engine

+ func (e *Engine) NonHiddenSources() []Source

Nov 3, 2021

Changes in this version

+ type HiddenSource interface

+ Hidden func() bool

Nov 2, 2021

Changes in this version

+ const AllContexts

+ const WILDCARD

+ func GetCacheDuration(s Source) time.Duration

+ func IsWildcard(s string) bool

+ type CacheDefiner interface

+ DefaultCacheDuration func() time.Duration

+ type Engine struct

+ MaxParallelExecutions int

+ NATSOptions *NATSOptions

+ Name string

+ func (e *Engine) AddSources(sources ...Source)

+ func (e *Engine) Connect() error

+ func (e *Engine) ExecuteRequest(req *sdp.ItemRequest) ([]*sdp.Item, error)

+ func (e *Engine) FilterSources(typ string, context string) []Source

+ func (e *Engine) Find(typ string, context string) ([]*sdp.Item, error)

+ func (e *Engine) Get(typ string, context string, query string) (*sdp.Item, error)

+ func (e *Engine) IsNATSConnected() bool

+ func (e *Engine) NewItemRequestHandler(sources []Source) func(req *sdp.ItemRequest)

+ func (e *Engine) Search(typ string, context string, query string) ([]*sdp.Item, error)

+ func (e *Engine) SetupThrottle()

+ func (e *Engine) Sources() []Source

+ func (e *Engine) Start() error

+ func (e *Engine) Stop() error

+ type GetFindMutex struct

+ func (g *GetFindMutex) FindLock(itemContext string, typ string)

+ func (g *GetFindMutex) FindUnlock(itemContext string, typ string)

+ func (g *GetFindMutex) GetLock(itemContext string, typ string)

+ func (g *GetFindMutex) GetUnlock(itemContext string, typ string)

+ type NATSOptions struct

+ CAFile string

+ ConnectTimeout time.Duration

+ ConnectionName string

+ JWTFile string

+ NkeyFile string

+ NumRetries int

+ QueueName string

+ URLs []string

+ type NilPublisher struct

+ func (n NilPublisher) Publish(subject string, v interface{}) error

+ type RequestTracker struct

+ Engine *Engine

+ Requests []*sdp.ItemRequest

+ func (r *RequestTracker) Execute() ([]*sdp.Item, error)

+ func (r *RequestTracker) LinkedItems() []*sdp.Item

+ type SearchableSource interface

+ Search func(itemContext string, query string) ([]*sdp.Item, error)

+ type Source interface

+ Contexts func() []string

+ Find func(itemContext string) ([]*sdp.Item, error)

+ Get func(itemContext string, query string) (*sdp.Item, error)

+ Name func() string

+ Type func() string

+ Weight func() int

+ type Throttle struct

+ NumParallel int

+ func (t *Throttle) Lock()

+ func (t *Throttle) Unlock()