corehub

func (c *CoreHub) AddDomain(domain *entities.TenantDomain) (int64, error)

func (c *CoreHub) AddSystemEvent(data *entities.SystemEvent) error

func (c *CoreHub) AddSystemKV(tenantId string, data *entities.SystemKV) error

func (c *CoreHub) AddTargetApp(data *entities.TargetApp) (int64, error)

func (c *CoreHub) AddTargetHook(data *entities.TargetHook) (int64, error)

func (c *CoreHub) AddTenant(tenant *entities.Tenant) error

func (c *CoreHub) AddUser(user *entities.User, data *entities.UserData) error

func (c *CoreHub) AddUserDevice(tenantId string, user string, data *entities.UserDevice) error

func (c *CoreHub) AddUserGroup(ug *entities.UserGroup) error

func (c *CoreHub) AddUserGroupAuth(data *entities.UserGroupAuth) error

func (c *CoreHub) AddUserGroupData(data *entities.UserGroupData) error

func (c *CoreHub) AddUserMessage(msg *entities.UserMessage) (int64, error)

func (c *CoreHub) AgentDel(tenantId, pid, agentId string) error

func (c *CoreHub) AgentExtensionDel(tenantId, pid, aid string, id int64) error

func (c *CoreHub) AgentExtensionGet(tenantId, pid, aid string, id int64) (*entities.AgentExtension, error)

func (c *CoreHub) AgentExtensionList(tenantId, pid, aid string) ([]*entities.AgentExtension, error)

func (c *CoreHub) AgentExtensionListByPlug(tenantId, pid string) ([]*entities.AgentExtension, error)

func (c *CoreHub) AgentExtensionNew(tenantId string, data *entities.AgentExtension) error

func (c *CoreHub) AgentExtensionUpdate(tenantId, pid, aid string, id int64, data map[string]any) error

func (c *CoreHub) AgentGet(tenantId, pid, id string) (*entities.Agent, error)

func (c *CoreHub) AgentLinkDel(tenantId, pid, aid string, id int64) error

func (c *CoreHub) AgentLinkGet(tenantId, pid, aid string, id int64) (*entities.AgentLink, error)

func (c *CoreHub) AgentLinkList(tenantId, pid, aid string) ([]*entities.AgentLink, error)

func (c *CoreHub) AgentLinkListByPlug(tenantId, pid string) ([]*entities.AgentLink, error)

func (c *CoreHub) AgentLinkListReverse(tenantId, pid, aid string) ([]*entities.AgentLink, error)

func (c *CoreHub) AgentLinkNew(tenantId string, data *entities.AgentLink) error

func (c *CoreHub) AgentLinkUpdate(tenantId, pid, aid string, id int64, data map[string]any) error

func (c *CoreHub) AgentList(tenantId, pid string) ([]*entities.Agent, error)

func (c *CoreHub) AgentNew(tenantId string, data *entities.Agent) error

func (c *CoreHub) AgentResourceDel(tenantId, pid, aid, slug string) error

func (c *CoreHub) AgentResourceGet(tenantId, pid, aid, slug string) (*entities.AgentResource, error)

func (c *CoreHub) AgentResourceList(tenantId, pid, aid string) ([]*entities.AgentResource, error)

func (c *CoreHub) AgentResourceNew(tenantId string, data *entities.AgentResource) error

func (c *CoreHub) AgentResourceUpdate(tenantId, pid, aid, slug string, data map[string]any) error

func (c *CoreHub) AgentUpdate(tenantId, pid, id string, data map[string]any) error

func (c *CoreHub) BprintDel(tenantId, id string) error

func (c *CoreHub) BprintGet(tenantId, id string) (*entities.BPrint, error)

func (c *CoreHub) BprintList(tenantId, group string) ([]*entities.BPrint, error)

func (c *CoreHub) BprintNew(tenantId string, et *entities.BPrint) error

func (c *CoreHub) BprintUpdate(tenantId, id string, data map[string]any) error

func (c *CoreHub) DeleteUserMessages(tenantId, userId string, id []int64) error

func (c *CoreHub) GetAuthZ(tenantId, group string) store.AuthZ

func (c *CoreHub) GetDomain(tenantId string, id int64) (*entities.TenantDomain, error)

func (c *CoreHub) GetDomainByName(tenantId string, name string) (*entities.TenantDomain, error)

func (c *CoreHub) GetFlowMap(tenantId string) (*flowmap.Data, error)

func (c *CoreHub) GetSystemKV(tenantId, key, ktype string) (*entities.SystemKV, error)

func (c *CoreHub) GetTargetApp(tenantId, ttype string, id int64) (*entities.TargetApp, error)

func (c *CoreHub) GetTargetHook(tenantId, ttype string, id int64) (*entities.TargetHook, error)

func (c *CoreHub) GetTenant(tenant string) (*entities.Tenant, error)

func (c *CoreHub) GetUserByEmail(tenantId string, email string) (*entities.User, error)

func (c *CoreHub) GetUserByID(tenantId string, username string) (*entities.User, error)

func (c *CoreHub) GetUserData(tenantId string, slug string) (*entities.UserData, error)

func (c *CoreHub) GetUserDevice(tenantId string, user string, id int64) (*entities.UserDevice, error)

func (c *CoreHub) GetUserGroup(tenantId string, slug string) (*entities.UserGroup, error)

func (c *CoreHub) GetUserGroupAuth(tenantId string, gslug string, id int64) (*entities.UserGroupAuth, error)

func (c *CoreHub) GetUserGroupData(tenantId string, gslug string, id int64) (*entities.UserGroupData, error)

func (c *CoreHub) Inject(app xtypes.App)

func (c *CoreHub) ListDomain(tenantId string) ([]*entities.TenantDomain, error)

func (c *CoreHub) ListResourcePairs(tenantId string, pid, aid string) ([]entities.ResourcePair, error)

func (c *CoreHub) ListSystemEvent(last int64) ([]*entities.SystemEvent, error)

func (c *CoreHub) ListSystemKV(tenantId, ktype, prefix string, last int64) ([]*entities.SystemKV, error)

func (c *CoreHub) ListTargetApp(tenantId string, cond map[string]any) ([]*entities.TargetApp, error)

func (c *CoreHub) ListTargetAppByPlug(tenantId, plug string) ([]*entities.TargetApp, error)

func (c *CoreHub) ListTargetAppByType(tenantId, ttype, target string) ([]*entities.TargetApp, error)

func (c *CoreHub) ListTargetAppByUgroup(tenantId, ugroup string) ([]*entities.TargetApp, error)

func (c *CoreHub) ListTargetHook(tenantId string, cond map[string]any) ([]*entities.TargetHook, error)

func (c *CoreHub) ListTargetHookByPlug(tenantId, plug string) ([]*entities.TargetHook, error)

func (c *CoreHub) ListTargetHookByType(tenantId, ttype, target string) ([]*entities.TargetHook, error)

func (c *CoreHub) ListTenant() ([]*entities.Tenant, error)

func (c *CoreHub) ListUserDevice(tenantId string, user string) ([]*entities.UserDevice, error)

func (c *CoreHub) ListUserGroupAuth(tenantId string, gslug string) ([]*entities.UserGroupAuth, error)

func (c *CoreHub) ListUserGroupData(tenantId string, gslug string) ([]*entities.UserGroupData, error)

func (c *CoreHub) ListUserGroups(tenantId string) ([]*entities.UserGroup, error)

func (c *CoreHub) ListUserMessages(tenantId string, data *entities.UserMessageReq) ([]*entities.UserMessage, error)

func (c *CoreHub) ListUsers(tenantId string) ([]*entities.User, error)

func (c *CoreHub) ListUsersByGroup(tenantId, group string) ([]*entities.User, error)

func (c *CoreHub) ListUsersMulti(tenantId string, ids ...string) ([]*entities.User, error)

func (c *CoreHub) Ping() error

func (c *CoreHub) PlugDel(tenantId, pid string) error

func (c *CoreHub) PlugGet(tenantId, pid string) (*entities.Plug, error)

func (c *CoreHub) PlugList(tenantId string, cond map[string]any) ([]*entities.Plug, error)

func (c *CoreHub) PlugListByBprint(tenantId, bid string) ([]*entities.Plug, error)

func (c *CoreHub) PlugNew(tenantId string, pg *entities.Plug) error

func (c *CoreHub) PlugUpdate(tenantId string, id string, data map[string]any) error

func (c *CoreHub) QuerySystemEvent(query store.EventQuery) ([]*entities.SystemEvent, error)

func (c *CoreHub) ReadUserMessages(tenantId, userId string, id []int64) error

func (c *CoreHub) RemoveDomain(tenantId string, id int64) error

func (c *CoreHub) RemoveSystemEvent(id int64) error

func (c *CoreHub) RemoveSystemKV(tenantId, key, ktype string) error

func (c *CoreHub) RemoveTargetApp(tenantId, ttype string, id int64) error

func (c *CoreHub) RemoveTargetHook(tenantId, ttype string, id int64) error

func (c *CoreHub) RemoveTenant(slug string) error

func (c *CoreHub) RemoveUser(tenantId string, username string) error

func (c *CoreHub) RemoveUserDevice(tenantId string, user string, id int64) error

func (c *CoreHub) RemoveUserGroup(tenantId string, ugslug string) error

func (c *CoreHub) RemoveUserGroupAuth(tenantId, gslug string, id int64) error

func (c *CoreHub) RemoveUserGroupData(tenantId, gslug string, id int64) error

func (c *CoreHub) RemoveUserMessage(tenantId string, username string, id int64) error

func (c *CoreHub) RepoDel(tenantId string, id int64) error

func (c *CoreHub) RepoGet(tenantId string, id int64) (*entities.Repo, error)

func (c *CoreHub) RepoList(tenantId string) ([]*entities.Repo, error)

func (c *CoreHub) RepoNew(tenantId string, data *entities.Repo) error

func (c *CoreHub) RepoUpdate(tenantId string, id int64, data map[string]any) error

func (c *CoreHub) ResourceDel(tenantId, rid string) error

func (c *CoreHub) ResourceGet(tenantId, rid string) (*entities.Resource, error)

func (c *CoreHub) ResourceList(tenantId string, cond map[string]any) ([]*entities.Resource, error)

func (c *CoreHub) ResourceNew(tenantId string, obj *entities.Resource) error

func (c *CoreHub) ResourceUpdate(tenantId string, id string, data map[string]any) error

func (c *CoreHub) ResourcesByTarget(tenantId string, target string) ([]*entities.Resource, error)

func (c *CoreHub) ResourcesMulti(tenantId string, rids ...string) ([]*entities.Resource, error)

func (c *CoreHub) UpdateDomain(tenantId string, id int64, data map[string]any) error

func (c *CoreHub) UpdateSystemKV(tenantId, key, ktype string, data map[string]any) error

func (c *CoreHub) UpdateTargetApp(tenantId, ttype string, id int64, data map[string]any) error

func (c *CoreHub) UpdateTargetHook(tenantId, ttype string, id int64, data map[string]any) error

func (c *CoreHub) UpdateTenant(slug string, data map[string]any) error

func (c *CoreHub) UpdateUser(tenantId, user string, data map[string]any) error

func (c *CoreHub) UpdateUserData(tenantId, slug string, data map[string]any) error

func (c *CoreHub) UpdateUserDevice(tenantId string, user string, id int64, data map[string]any) error

func (c *CoreHub) UpdateUserGroup(tenantId, slug string, data map[string]any) error

func (c *CoreHub) UpdateUserGroupAuth(tenantId string, gslug string, id int64, data map[string]any) error

func (c *CoreHub) UpdateUserGroupData(tenantId string, gslug string, id int64, data map[string]any) error

func (c *CoreHub) UserMessageSetRead(tenantId, user string, id int64) error