Versions in this module Expand all Collapse all v0 v0.98.1 Jul 23, 2026 v0.98.0 Jul 21, 2026 v0.97.8 Jul 20, 2026 Changes in this version + const OpAgentRun + const OpArchiveAdd + const OpArchiveGet + const OpArchiveSearch + const OpBookmarkArchive + const OpBookmarkAttachTags + const OpBookmarkCheckURL + const OpBookmarkCreate + const OpBookmarkDelete + const OpBookmarkDetachTags + const OpBookmarkGet + const OpBookmarkList + const OpBookmarkSearch + const OpExampleCreate + const OpExampleDelete + const OpExampleGet + const OpExampleHealth + const OpExampleList + const OpExampleUpdate + const OpFinanceAbout + const OpFinanceCreateTransaction + const OpFinanceCurrentUser + const OpFinanceHealth + const OpForgeGetCommitDiff + const OpForgeGetFileContent + const OpForgeGetIssue + const OpForgeGetRepo + const OpForgeGetUser + const OpForgeListIssues + const OpGithubGetCommitDiff + const OpGithubGetFileContent + const OpGithubGetIssue + const OpGithubGetRepo + const OpGithubGetUser + const OpGithubGetUserByLogin + const OpGithubListIssues + const OpGithubListNotifications + const OpGithubListReleases + const OpKanbanCompleteTask + const OpKanbanCreateTask + const OpKanbanDeleteTask + const OpKanbanGetColumns + const OpKanbanGetTask + const OpKanbanListTasks + const OpKanbanMoveTask + const OpKanbanSearchTasks + const OpKanbanUpdateTask + const OpMemoCreate + const OpMemoDelete + const OpMemoGet + const OpMemoHealth + const OpMemoList + const OpMemoUpdate + const OpNocoCreateRecord + const OpNocoDeleteRecord + const OpNocoGetRecord + const OpNocoGetTable + const OpNocoHealth + const OpNocoListBases + const OpNocoListRecords + const OpNocoListTables + const OpNocoUpdateRecord + const OpNoteCreate + const OpNoteDelete + const OpNoteGet + const OpNoteGetAppInfo + const OpNoteGetContent + const OpNoteList + const OpNoteSearch + const OpNoteSetContent + const OpNoteUpdate + const OpNotifyDigest + const OpNotifySend + const OpReaderCreateFeed + const OpReaderListEntries + const OpReaderListFeeds + const OpReaderMarkEntryRead + const OpReaderMarkEntryUnread + const OpReaderStarEntry + const OpReaderUnstarEntry + const OpTorrentAdd + const OpTorrentHealth + const OpTorrentList + const OpTorrentRemove + const OpTorrentStop + var DefaultRegistry = NewRegistry() + var Operations = map[hub.CapabilityType]map[string]string + func BoolParam(params map[string]any, key string) (bool, bool) + func EncodeCursor(secret []byte, payload CursorPayload) (string, error) + func GetEventPool() *ants.PoolWithFunc + func InitEventPool(size int, expiryDuration string, mc *metrics.CapabilityCollector) error + func Int64Param(params map[string]any, key string) (int64, bool) + func IntParam(params map[string]any, key string) (int, bool) + func IsMutation(op string) bool + func Op(capType hub.CapabilityType, key string) string + func Register(s Spec) error + func RegisterInvoker(capability hub.CapabilityType, operation string, invoker Invoker) error + func RegisterOperations(capType hub.CapabilityType, ops map[string]string) + func RequiredInt(params map[string]any, key string) (int, error) + func RequiredInt64(params map[string]any, key string) (int64, error) + func RequiredString(params map[string]any, key string) (string, error) + func SetBulkheadCallbacks() + func SetEventEmitter(emitter EventEmitter) + func SetEventSourceManager(m *EventSourceManager) + func SetMetricsCollector(mc *metrics.CapabilityCollector) + func ShutdownEventPool() + func StringParam(params map[string]any, key string) (string, bool) + func UnregisterInvoker(capability hub.CapabilityType, operation string) + type ArchiveItem struct + CreatedAt time.Time + ID string + Status string + Title string + URL string + type Bookmark struct + Archived bool + CreatedAt time.Time + Favourited bool + ID string + Summary string + Tags []string + Title string + URL string + type BookmarkListQuery struct + Archived *bool + Favourited *bool + Page PageRequest + Tags []string + type BookmarkSearchQuery struct + Page PageRequest + Q string + type CursorPayload struct + Backend string + Capability string + ExpiresAt time.Time + FilterHash string + Limit int + Offset int + Page int + ProviderCursor string + SortBy string + SortOrder string + Strategy string + func DecodeCursor(secret []byte, cursor string, now time.Time) (CursorPayload, error) + type DevopsDashboard struct + Title string + UID string + URL string + type DevopsDatasource struct + ID int64 + Name string + Type string + UID string + type DevopsDozzleInfo struct + Healthy bool + Version string + type DevopsGrafanaHealth struct + Database string + Version string + type DevopsGrafanaQueryField struct + Name string + Type string + Values any + type DevopsGrafanaQueryFrame struct + Fields []DevopsGrafanaQueryField + Name string + RefID string + type DevopsGrafanaQueryResult struct + Backend string + DatasourceType string + DatasourceUID string + Frames []DevopsGrafanaQueryFrame + type DevopsMetricFamily struct + Count int + Help string + Name string + type DevopsNetalertxDevice struct + IP string + MAC string + Name string + Status string + Type string + Vendor string + type DevopsNetalertxTotals struct + All int + Archived int + Connected int + Down int + Favorites int + New int + type DevopsRouter struct + Name string + Rule string + Service string + Status string + type DevopsService struct + Name string + Status string + Type string + type DevopsStatus struct + Backends map[string]bool + type DevopsSystem struct + Host string + ID string + Name string + Status string + type DevopsTraefikOverview struct + HTTPRouters int + HTTPServices int + type DevopsWakapiProject struct + ID string + Name string + type DevopsWakapiSummary struct + TotalSeconds int64 + type Entry struct + Content string + FeedTitle string + ID int64 + PublishedAt time.Time + Starred bool + Status string + Title string + URL string + type EventEmitter func(ctx context.Context, result *InvokeResult) + type EventRef struct + EntityID string + EventID string + EventType string + type EventSourceEmitter func(ctx context.Context, events []types.DataEvent) error + type EventSourceManager struct + func GetEventSourceManager() *EventSourceManager + func NewEventSourceManager(emitter EventSourceEmitter, stateStore *PollingState, ...) *EventSourceManager + func (m *EventSourceManager) RegisterPolling(r PollingResource) + func (m *EventSourceManager) RegisterWebhook(c WebhookConverter) + func (m *EventSourceManager) SetPool(pool *ants.PoolWithFunc) + func (m *EventSourceManager) Start(ctx context.Context) error + func (m *EventSourceManager) Stop(ctx context.Context) error + func (m *EventSourceManager) WebhookHandler() fiber.Handler + type EventStore interface + AppendDataEvent func(ctx context.Context, event types.DataEvent) error + AppendEventOutbox func(ctx context.Context, event types.DataEvent) error + type ExampleListQuery struct + Page PageRequest + type Feed struct + Category string + FeedURL string + ID int64 + SiteURL string + Title string + type FinanceAbout struct + APIVersion string + Driver string + OS string + PHPVersion string + Version string + type FinanceUser struct + Email string + ID string + Role string + type ForgeCommitDiff struct + CommitID string + CommitMessage string + DiffContent string + Files []string + type ForgeIssue struct + Author string + Body string + HTMLURL string + ID int64 + Index int64 + State string + Title string + type ForgeListIssuesQuery struct + Page PageRequest + State string + type ForgeRepo struct + CloneURL string + Description string + FullName string + HTMLURL string + ID int64 + Name string + Owner string + Private bool + type ForgeUser struct + AvatarURL string + Email string + ID int64 + UserName string + type GithubListIssuesQuery struct + Page PageRequest + State string + type GithubPageQuery struct + Page PageRequest + type Host struct + Address string + ID string + Name string + Status string + type InvokeResult struct + Capability hub.CapabilityType + Data any + Events []EventRef + Meta map[string]any + Operation string + Page *PageInfo + Resource *ResourceMeta + Text string + func Invoke(ctx context.Context, capability hub.CapabilityType, operation string, ...) (*InvokeResult, error) + type Invoker func(ctx context.Context, params map[string]any) (*InvokeResult, error) + type KanbanCreateTaskRequest struct + ColumnID int + Description string + ProjectID int + Reference string + Tags []string + Title string + type KanbanMoveTaskRequest struct + ColumnID int + Position int + ProjectID int + SwimlaneID int + type KanbanSearchQuery struct + Page PageRequest + ProjectID int + Q string + type KanbanTaskQuery struct + ColumnID int + Page PageRequest + ProjectID int + Status string + type KanbanUpdateTaskRequest struct + Description string + Title string + type ListResult struct + Items []*T + Page *PageInfo + type Memo struct + Content string + CreateTime time.Time + Creator string + Name string + Pinned bool + Snippet string + State string + Tags []string + UpdateTime time.Time + Visibility string + type MemoListQuery struct + Page PageRequest + type NocoBase struct + ID string + Title string + type NocoColumn struct + ID string + Title string + Type string + type NocoRecord struct + Fields map[string]any + ID string + type NocoTable struct + BaseID string + Columns []NocoColumn + ID string + Title string + type Note struct + ChildNoteIDs []string + Content string + DateCreated string + DateModified string + ID string + IsProtected bool + ParentNoteIDs []string + Title string + Type string + UtcDateCreated string + UtcDateModified string + type NoteListQuery struct + Page PageRequest + Query string + type Notification struct + ID string + LastReadAt time.Time + Reason string + RepoName string + Subject string + Unread bool + UpdatedAt time.Time + type OpDef struct + Description string + Handler Invoker + Input []hub.ParamDef + Mutation bool + Name string + Scopes []string + type PageInfo struct + HasMore bool + Limit int + NextCursor string + PrevCursor string + Total *int64 + type PageRequest struct + Cursor string + Limit int + SortBy string + SortOrder string + func PageRequestFromParams(params map[string]any) PageRequest + type Persistence interface + LoadAll func(ctx context.Context) (map[string]PollingEntry, error) + Save func(ctx context.Context, resourceName, cursor string, ...) error + type PollResult struct + HasMore bool + Items []any + NextCursor string + type PollingEntry struct + Cursor string + KnownHashes map[string]string + UpdatedAt time.Time + type PollingResource interface + ContentHash func(item any) string + CursorField func() string + DefaultInterval func() time.Duration + DiffKey func(item any) string + List func(ctx context.Context, cursor string) (PollResult, error) + ResourceName func() string + type PollingState struct + func NewPollingState(backend Persistence) *PollingState + func (*PollingState) FlushInterval() time.Duration + func (s *PollingState) Flush(ctx context.Context) error + func (s *PollingState) Get(name string) PollingEntry + func (s *PollingState) Load(ctx context.Context) error + func (s *PollingState) MarkDirty(name string) + func (s *PollingState) Update(name string, entry PollingEntry) + type ReaderEntryQuery struct + FeedID int64 + Page PageRequest + Status string + type ReaderFeedQuery struct + Page PageRequest + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Invoke(ctx context.Context, capability hub.CapabilityType, operation string, ...) (*InvokeResult, error) + func (r *Registry) Register(capability hub.CapabilityType, operation string, invoker Invoker) error + func (r *Registry) Unregister(capability hub.CapabilityType, operation string) + type Release struct + Body string + Draft bool + HTMLURL string + ID int64 + Name string + Prerelease bool + PublishedAt time.Time + TagName string + type ResourceMeta struct + App string + EntityID string + EventID string + type Spec struct + App string + Description string + Events []hub.EventDef + Instance any + Ops []OpDef + Type hub.CapabilityType + type Task struct + ColumnID int + Description string + ID int + ProjectID int + Reference string + Tags []string + Title string + type Torrent struct + DownloadDir string + ErrorString string + HashString string + ID int64 + Name string + PercentDone float64 + RateDownload int64 + RateUpload int64 + Status string + type Transaction struct + Amount string + CategoryName string + CurrencyCode string + Date string + Description string + DestinationName string + ID string + Notes string + SourceName string + Type string + type WebhookConverter interface + Convert func(body []byte, headers map[string]string) ([]types.DataEvent, error) + VerifySignature func(headers map[string]string, body []byte) error + WebhookPath func() string