resource

Mar 16, 2026

Changes in this version

type Controller

+ Graph func() *graph.RelationshipGraph

+ type GraphService struct

+ func NewGraphService(g *graph.RelationshipGraph) *GraphService

+ func (s *GraphService) GetDependencyTree(pluginID, connectionID, resourceKey, namespace, id string, maxDepth int) (*graph.DependencyTree, error)

+ func (s *GraphService) GetRelated(pluginID, connectionID, resourceKey, namespace, id string, direction string, ...) ([]graph.GraphEdge, error)

+ func (s *GraphService) GetRelationshipChain(pluginID, connectionID, resourceKey, namespace, id string, relType string, ...) ([][]graph.GraphEdge, error)

Mar 10, 2026

Changes in this version

type AdapterV1

+ func (a *AdapterV1) CheckConnection(ctx context.Context, connectionID string) (types.ConnectionStatus, error)

type Client

+ func (c *Client) CheckConnection(pluginID, connectionID string) (types.ConnectionStatus, error)

type ResourceProvider

+ CheckConnection func(ctx context.Context, connectionID string) (types.ConnectionStatus, error)

type Service

+ CheckConnection func(pluginID, connectionID string) (types.ConnectionStatus, error)

Mar 7, 2026

Changes in this version

+ type ClientCreateInput struct

+ Input interface{}

+ Namespace string

+ type ClientListResult struct

+ NextCursor string

+ Result []interface{}

+ Success bool

+ TotalCount int

+ type ClientResult struct

+ Result interface{}

+ Success bool

+ type ClientUpdateInput struct

+ ID string

+ Input interface{}

+ Namespace string

Mar 6, 2026

Changes in this version

+ type AdapterV1 struct

+ func NewAdapterV1(inner resource.Provider) *AdapterV1

+ func (a *AdapterV1) Create(ctx context.Context, key string, input resource.CreateInput) (*resource.CreateResult, error)

+ func (a *AdapterV1) Delete(ctx context.Context, key string, input resource.DeleteInput) (*resource.DeleteResult, error)

+ func (a *AdapterV1) DeleteConnection(ctx context.Context, id string) error

+ func (a *AdapterV1) EnsureResourceWatch(ctx context.Context, connectionID, resourceKey string) error

+ func (a *AdapterV1) ExecuteAction(ctx context.Context, key, actionID string, input resource.ActionInput) (*resource.ActionResult, error)

+ func (a *AdapterV1) Find(ctx context.Context, key string, input resource.FindInput) (*resource.FindResult, error)

+ func (a *AdapterV1) Get(ctx context.Context, key string, input resource.GetInput) (*resource.GetResult, error)

+ func (a *AdapterV1) GetActions(ctx context.Context, key string) ([]resource.ActionDescriptor, error)

+ func (a *AdapterV1) GetConnection(ctx context.Context, id string) (types.Connection, error)

+ func (a *AdapterV1) GetConnectionNamespaces(ctx context.Context, id string) ([]string, error)

+ func (a *AdapterV1) GetEditorSchemas(ctx context.Context, connectionID string) ([]resource.EditorSchema, error)

+ func (a *AdapterV1) GetFilterFields(ctx context.Context, connectionID, resourceKey string) ([]resource.FilterField, error)

+ func (a *AdapterV1) GetHealth(ctx context.Context, connectionID, resourceKey string, data json.RawMessage) (*resource.ResourceHealth, error)

+ func (a *AdapterV1) GetRelationships(ctx context.Context, resourceKey string) ([]resource.RelationshipDescriptor, error)

+ func (a *AdapterV1) GetResourceCapabilities(ctx context.Context, resourceKey string) (*resource.ResourceCapabilities, error)

+ func (a *AdapterV1) GetResourceDefinition(ctx context.Context, id string) (resource.ResourceDefinition, error)

+ func (a *AdapterV1) GetResourceEvents(ctx context.Context, connectionID, resourceKey, id, namespace string, ...) ([]resource.ResourceEvent, error)

+ func (a *AdapterV1) GetResourceGroup(ctx context.Context, id string) (resource.ResourceGroup, error)

+ func (a *AdapterV1) GetResourceGroups(ctx context.Context, connectionID string) map[string]resource.ResourceGroup

+ func (a *AdapterV1) GetResourceSchema(ctx context.Context, connectionID, resourceKey string) (json.RawMessage, error)

+ func (a *AdapterV1) GetResourceType(ctx context.Context, id string) (*resource.ResourceMeta, error)

+ func (a *AdapterV1) GetResourceTypes(ctx context.Context, connectionID string) map[string]resource.ResourceMeta

+ func (a *AdapterV1) GetWatchState(ctx context.Context, connectionID string) (*resource.WatchConnectionSummary, error)

+ func (a *AdapterV1) HasResourceType(ctx context.Context, id string) bool

+ func (a *AdapterV1) HasWatch(ctx context.Context, connectionID string) bool

+ func (a *AdapterV1) IsResourceWatchRunning(ctx context.Context, connectionID, resourceKey string) (bool, error)

+ func (a *AdapterV1) List(ctx context.Context, key string, input resource.ListInput) (*resource.ListResult, error)

+ func (a *AdapterV1) ListConnections(ctx context.Context) ([]types.Connection, error)

+ func (a *AdapterV1) ListenForEvents(ctx context.Context, sink resource.WatchEventSink) error

+ func (a *AdapterV1) LoadConnections(ctx context.Context) ([]types.Connection, error)

+ func (a *AdapterV1) ResolveRelationships(ctx context.Context, connectionID, resourceKey, id, namespace string) ([]resource.ResolvedRelationship, error)

+ func (a *AdapterV1) RestartResourceWatch(ctx context.Context, connectionID, resourceKey string) error

+ func (a *AdapterV1) StartConnection(ctx context.Context, connectionID string) (types.ConnectionStatus, error)

+ func (a *AdapterV1) StartConnectionWatch(ctx context.Context, connectionID string) error

+ func (a *AdapterV1) StopConnection(ctx context.Context, connectionID string) (types.Connection, error)

+ func (a *AdapterV1) StopConnectionWatch(ctx context.Context, connectionID string) error

+ func (a *AdapterV1) StopResourceWatch(ctx context.Context, connectionID, resourceKey string) error

+ func (a *AdapterV1) StreamAction(ctx context.Context, key, actionID string, input resource.ActionInput, ...) error

+ func (a *AdapterV1) Update(ctx context.Context, key string, input resource.UpdateInput) (*resource.UpdateResult, error)

+ func (a *AdapterV1) UpdateConnection(ctx context.Context, connection types.Connection) (types.Connection, error)

+ func (a *AdapterV1) WatchConnections(ctx context.Context, stream chan<- []types.Connection) error

type Client

+ func (c *Client) EnsureResourceWatch(pluginID, connectionID, resourceKey string) error

+ func (c *Client) GetAllConnectionStates() (map[string][]ConnectionState, error)

+ func (c *Client) GetFilterFields(pluginID, connectionID, key string) ([]resource.FilterField, error)

+ func (c *Client) GetHealth(pluginID, connectionID, key string, data json.RawMessage) (*resource.ResourceHealth, error)

+ func (c *Client) GetRelationships(pluginID, key string) ([]resource.RelationshipDescriptor, error)

+ func (c *Client) GetResourceCapabilities(pluginID, key string) (*resource.ResourceCapabilities, error)

+ func (c *Client) GetResourceEvents(pluginID, connectionID, key, id, namespace string, limit int32) ([]resource.ResourceEvent, error)

+ func (c *Client) GetResourceSchema(pluginID, connectionID, key string) (json.RawMessage, error)

+ func (c *Client) GetWatchState(pluginID, connectionID string) (*resource.WatchConnectionSummary, error)

+ func (c *Client) IsResourceWatchRunning(pluginID, connectionID, resourceKey string) (bool, error)

+ func (c *Client) ResolveRelationships(pluginID, connectionID, key, id, namespace string) ([]resource.ResolvedRelationship, error)

+ func (c *Client) RestartResourceWatch(pluginID, connectionID, resourceKey string) error

+ func (c *Client) StartConnectionWatch(pluginID, connectionID string) error

+ func (c *Client) StopConnectionWatch(pluginID, connectionID string) error

+ func (c *Client) StopResourceWatch(pluginID, connectionID, resourceKey string) error

+ type ConnectionState struct

+ Connection types.Connection

+ ErrorCount int

+ LastSyncTime string

+ ResourceCounts map[string]int

+ Resources map[string]sdkresource.WatchState

+ Started bool

+ SyncedCount int

+ TotalResources int

+ type EventEmitter interface

+ Emit func(eventKey string, data interface{})

+ type ResourceProvider interface

+ Create func(ctx context.Context, key string, input resource.CreateInput) (*resource.CreateResult, error)

+ Delete func(ctx context.Context, key string, input resource.DeleteInput) (*resource.DeleteResult, error)

+ DeleteConnection func(ctx context.Context, id string) error

+ EnsureResourceWatch func(ctx context.Context, connectionID, resourceKey string) error

+ ExecuteAction func(ctx context.Context, key, actionID string, input resource.ActionInput) (*resource.ActionResult, error)

+ Find func(ctx context.Context, key string, input resource.FindInput) (*resource.FindResult, error)

+ Get func(ctx context.Context, key string, input resource.GetInput) (*resource.GetResult, error)

+ GetActions func(ctx context.Context, key string) ([]resource.ActionDescriptor, error)

+ GetConnection func(ctx context.Context, id string) (types.Connection, error)

+ GetConnectionNamespaces func(ctx context.Context, id string) ([]string, error)

+ GetEditorSchemas func(ctx context.Context, connectionID string) ([]resource.EditorSchema, error)

+ GetFilterFields func(ctx context.Context, connectionID, resourceKey string) ([]resource.FilterField, error)

+ GetHealth func(ctx context.Context, connectionID, resourceKey string, data json.RawMessage) (*resource.ResourceHealth, error)

+ GetRelationships func(ctx context.Context, resourceKey string) ([]resource.RelationshipDescriptor, error)

+ GetResourceCapabilities func(ctx context.Context, resourceKey string) (*resource.ResourceCapabilities, error)

+ GetResourceDefinition func(ctx context.Context, id string) (resource.ResourceDefinition, error)

+ GetResourceEvents func(ctx context.Context, connectionID, resourceKey, id, namespace string, ...) ([]resource.ResourceEvent, error)

+ GetResourceGroup func(ctx context.Context, id string) (resource.ResourceGroup, error)

+ GetResourceGroups func(ctx context.Context, connectionID string) map[string]resource.ResourceGroup

+ GetResourceSchema func(ctx context.Context, connectionID, resourceKey string) (json.RawMessage, error)

+ GetResourceType func(ctx context.Context, id string) (*resource.ResourceMeta, error)

+ GetResourceTypes func(ctx context.Context, connectionID string) map[string]resource.ResourceMeta

+ GetWatchState func(ctx context.Context, connectionID string) (*resource.WatchConnectionSummary, error)

+ HasResourceType func(ctx context.Context, id string) bool

+ HasWatch func(ctx context.Context, connectionID string) bool

+ IsResourceWatchRunning func(ctx context.Context, connectionID, resourceKey string) (bool, error)

+ List func(ctx context.Context, key string, input resource.ListInput) (*resource.ListResult, error)

+ ListConnections func(ctx context.Context) ([]types.Connection, error)

+ ListenForEvents func(ctx context.Context, sink resource.WatchEventSink) error

+ LoadConnections func(ctx context.Context) ([]types.Connection, error)

+ ResolveRelationships func(ctx context.Context, connectionID, resourceKey, id, namespace string) ([]resource.ResolvedRelationship, error)

+ RestartResourceWatch func(ctx context.Context, connectionID, resourceKey string) error

+ StartConnection func(ctx context.Context, connectionID string) (types.ConnectionStatus, error)

+ StartConnectionWatch func(ctx context.Context, connectionID string) error

+ StopConnection func(ctx context.Context, connectionID string) (types.Connection, error)

+ StopConnectionWatch func(ctx context.Context, connectionID string) error

+ StopResourceWatch func(ctx context.Context, connectionID, resourceKey string) error

+ StreamAction func(ctx context.Context, key, actionID string, input resource.ActionInput, ...) error

+ Update func(ctx context.Context, key string, input resource.UpdateInput) (*resource.UpdateResult, error)

+ UpdateConnection func(ctx context.Context, connection types.Connection) (types.Connection, error)

+ WatchConnections func(ctx context.Context, stream chan<- []types.Connection) error

+ type Service interface

+ AddConnection func(pluginID string, connection types.Connection) error

+ Create func(pluginID, connectionID, key string, input resource.CreateInput) (*resource.CreateResult, error)

+ Delete func(pluginID, connectionID, key string, input resource.DeleteInput) (*resource.DeleteResult, error)

+ EnsureResourceWatch func(pluginID, connectionID, resourceKey string) error

+ ExecuteAction func(pluginID, connectionID, key, actionID string, input resource.ActionInput) (*resource.ActionResult, error)

+ Find func(pluginID, connectionID, key string, input resource.FindInput) (*resource.FindResult, error)

+ Get func(pluginID, connectionID, key string, input resource.GetInput) (*resource.GetResult, error)

+ GetActions func(pluginID, connectionID, key string) ([]resource.ActionDescriptor, error)

+ GetAllConnectionStates func() (map[string][]ConnectionState, error)

+ GetConnection func(pluginID, connectionID string) (types.Connection, error)

+ GetConnectionNamespaces func(pluginID, connectionID string) ([]string, error)

+ GetEditorSchemas func(pluginID, connectionID string) ([]resource.EditorSchema, error)

+ GetFilterFields func(pluginID, connectionID, key string) ([]resource.FilterField, error)

+ GetHealth func(pluginID, connectionID, key string, data json.RawMessage) (*resource.ResourceHealth, error)

+ GetRelationships func(pluginID, key string) ([]resource.RelationshipDescriptor, error)

+ GetResourceCapabilities func(pluginID, key string) (*resource.ResourceCapabilities, error)

+ GetResourceDefinition func(pluginID, typeID string) (resource.ResourceDefinition, error)

+ GetResourceEvents func(pluginID, connectionID, key, id, namespace string, limit int32) ([]resource.ResourceEvent, error)

+ GetResourceGroup func(pluginID, groupID string) (resource.ResourceGroup, error)

+ GetResourceGroups func(pluginID, connectionID string) map[string]resource.ResourceGroup

+ GetResourceSchema func(pluginID, connectionID, key string) (json.RawMessage, error)

+ GetResourceType func(pluginID, typeID string) (*resource.ResourceMeta, error)

+ GetResourceTypes func(pluginID, connectionID string) map[string]resource.ResourceMeta

+ GetWatchState func(pluginID, connectionID string) (*resource.WatchConnectionSummary, error)

+ HasResourceType func(pluginID, typeID string) bool

+ IsResourceWatchRunning func(pluginID, connectionID, resourceKey string) (bool, error)

+ List func(pluginID, connectionID, key string, input resource.ListInput) (*resource.ListResult, error)

+ ListAllConnections func() (map[string][]types.Connection, error)

+ ListConnections func(pluginID string) ([]types.Connection, error)

+ ListPlugins func() ([]string, error)

+ LoadConnections func(pluginID string) ([]types.Connection, error)

+ RemoveConnection func(pluginID, connectionID string) error

+ ResolveRelationships func(pluginID, connectionID, key, id, namespace string) ([]resource.ResolvedRelationship, error)

+ RestartResourceWatch func(pluginID, connectionID, resourceKey string) error

+ StartConnection func(pluginID, connectionID string) (types.ConnectionStatus, error)

+ StartConnectionWatch func(pluginID, connectionID string) error

+ StopConnection func(pluginID, connectionID string) (types.Connection, error)

+ StopConnectionWatch func(pluginID, connectionID string) error

+ StopResourceWatch func(pluginID, connectionID, resourceKey string) error

+ StreamAction func(pluginID, connectionID, key, actionID string, input resource.ActionInput) (string, error)

+ SubscribeResource func(pluginID, connectionID, resourceKey string) error

+ UnsubscribeResource func(pluginID, connectionID, resourceKey string) error

+ Update func(pluginID, connectionID, key string, input resource.UpdateInput) (*resource.UpdateResult, error)

+ UpdateConnection func(pluginID string, connection types.Connection) (types.Connection, error)

Feb 28, 2026

Changes in this version

type Client

+ func (c *Client) SubscribeResource(pluginID, connectionID, resourceKey string) error

+ func (c *Client) UnsubscribeResource(pluginID, connectionID, resourceKey string) error

type IClient

+ SubscribeResource func(pluginID, connectionID, resourceKey string) error

+ UnsubscribeResource func(pluginID, connectionID, resourceKey string) error

Feb 26, 2026

Changes in this version

type Controller

+ SetCrashCallback func(cb func(pluginID string))

Feb 25, 2026

Changes in this version

+ const PluginName

+ const StoreName

+ type Client struct

+ func NewClient(controller Controller) *Client

+ func (c *Client) AddConnection(pluginID string, connection types.Connection) error

+ func (c *Client) Create(pluginID, connectionID, key string, input rt.CreateInput) (*rt.CreateResult, error)

+ func (c *Client) Delete(pluginID, connectionID, key string, input rt.DeleteInput) (*rt.DeleteResult, error)

+ func (c *Client) EnsureInformerForResource(pluginID, connectionID, resourceKey string) error

+ func (c *Client) ExecuteAction(pluginID, connectionID, key, actionID string, input rt.ActionInput) (*rt.ActionResult, error)

+ func (c *Client) Find(pluginID, connectionID, key string, input rt.FindInput) (*rt.FindResult, error)

+ func (c *Client) Get(pluginID, connectionID, key string, input rt.GetInput) (*rt.GetResult, error)

+ func (c *Client) GetActions(pluginID, connectionID, key string) ([]rt.ActionDescriptor, error)

+ func (c *Client) GetConnection(pluginID, connectionID string) (types.Connection, error)

+ func (c *Client) GetConnectionNamespaces(pluginID, connectionID string) ([]string, error)

+ func (c *Client) GetDefaultLayout(pluginID string) ([]rt.LayoutItem, error)

+ func (c *Client) GetEditorSchemas(pluginID, connectionID string) ([]rt.EditorSchema, error)

+ func (c *Client) GetInformerState(pluginID, connectionID string) (*rt.InformerConnectionSummary, error)

+ func (c *Client) GetLayout(pluginID string, layoutID string) ([]rt.LayoutItem, error)

+ func (c *Client) GetResourceDefinition(pluginID, typeID string) (rt.ResourceDefinition, error)

+ func (c *Client) GetResourceGroup(pluginID, groupID string) (rt.ResourceGroup, error)

+ func (c *Client) GetResourceGroups(pluginID, connectionID string) map[string]rt.ResourceGroup

+ func (c *Client) GetResourceType(pluginID, typeID string) (*rt.ResourceMeta, error)

+ func (c *Client) GetResourceTypes(pluginID, connectionID string) map[string]rt.ResourceMeta

+ func (c *Client) HasResourceType(pluginID, typeID string) bool

+ func (c *Client) List(pluginID, connectionID, key string, input rt.ListInput) (*rt.ListResult, error)

+ func (c *Client) ListAllConnections() (map[string][]types.Connection, error)

+ func (c *Client) ListConnections(pluginID string) ([]types.Connection, error)

+ func (c *Client) ListPlugins() ([]string, error)

+ func (c *Client) LoadConnections(pluginID string) ([]types.Connection, error)

+ func (c *Client) RemoveConnection(pluginID, connectionID string) error

+ func (c *Client) SetLayout(pluginID string, layoutID string, layout []rt.LayoutItem) error

+ func (c *Client) StartConnection(pluginID, connectionID string) (types.ConnectionStatus, error)

+ func (c *Client) StartConnectionInformer(pluginID, connectionID string) error

+ func (c *Client) StopConnection(pluginID, connectionID string) (types.Connection, error)

+ func (c *Client) StopConnectionInformer(pluginID, connectionID string) error

+ func (c *Client) StreamAction(pluginID, connectionID, key, actionID string, input rt.ActionInput) (string, error)

+ func (c *Client) Update(pluginID, connectionID, key string, input rt.UpdateInput) (*rt.UpdateResult, error)

+ func (c *Client) UpdateConnection(pluginID string, connection types.Connection) (types.Connection, error)

+ type Controller interface

+ func NewController(logger *zap.SugaredLogger, sp pkgsettings.Provider) Controller

+ type IClient interface

+ AddConnection func(pluginID string, connection types.Connection) error

+ Create func(pluginID, connectionID, key string, input rt.CreateInput) (*rt.CreateResult, error)

+ Delete func(pluginID, connectionID, key string, input rt.DeleteInput) (*rt.DeleteResult, error)

+ EnsureInformerForResource func(pluginID, connectionID, resourceKey string) error

+ ExecuteAction func(pluginID, connectionID, key, actionID string, input rt.ActionInput) (*rt.ActionResult, error)

+ Find func(pluginID, connectionID, key string, input rt.FindInput) (*rt.FindResult, error)

+ Get func(pluginID, connectionID, key string, input rt.GetInput) (*rt.GetResult, error)

+ GetActions func(pluginID, connectionID, key string) ([]rt.ActionDescriptor, error)

+ GetConnection func(pluginID, connectionID string) (types.Connection, error)

+ GetConnectionNamespaces func(pluginID, connectionID string) ([]string, error)

+ GetDefaultLayout func(pluginID string) ([]rt.LayoutItem, error)

+ GetEditorSchemas func(pluginID, connectionID string) ([]rt.EditorSchema, error)

+ GetInformerState func(pluginID, connectionID string) (*rt.InformerConnectionSummary, error)

+ GetLayout func(pluginID string, layoutID string) ([]rt.LayoutItem, error)

+ GetResourceDefinition func(pluginID, typeID string) (rt.ResourceDefinition, error)

+ GetResourceGroup func(pluginID, groupID string) (rt.ResourceGroup, error)

+ GetResourceGroups func(pluginID, connectionID string) map[string]rt.ResourceGroup

+ GetResourceType func(pluginID, typeID string) (*rt.ResourceMeta, error)

+ GetResourceTypes func(pluginID, connectionID string) map[string]rt.ResourceMeta

+ HasResourceType func(pluginID, typeID string) bool

+ List func(pluginID, connectionID, key string, input rt.ListInput) (*rt.ListResult, error)

+ ListAllConnections func() (map[string][]types.Connection, error)

+ ListConnections func(pluginID string) ([]types.Connection, error)

+ ListPlugins func() ([]string, error)

+ LoadConnections func(pluginID string) ([]types.Connection, error)

+ RemoveConnection func(pluginID, connectionID string) error

+ SetLayout func(pluginID string, layoutID string, layout []rt.LayoutItem) error

+ StartConnection func(pluginID, connectionID string) (types.ConnectionStatus, error)

+ StartConnectionInformer func(pluginID, connectionID string) error

+ StopConnection func(pluginID, connectionID string) (types.Connection, error)

+ StopConnectionInformer func(pluginID, connectionID string) error

+ StreamAction func(pluginID, connectionID, key, actionID string, input rt.ActionInput) (string, error)

+ Update func(pluginID, connectionID, key string, input rt.UpdateInput) (*rt.UpdateResult, error)

+ UpdateConnection func(pluginID string, connection types.Connection) (types.Connection, error)