sysExport

Documentation

Index

• Constants
• func GenApiCacheKey(method, route string) string
• func GenSlotCacheKey(code string, subCode string) string
• func GenWebhookCacheKey(ctx context.Context, code string) string
• type AreaCacheT
  • func NewAreaInfoCache(pm areamanage.AreaManage, fastEvent *eventBus.FastEvent) (AreaCacheT, error)
• type ProjectCacheT
  • func NewProjectInfoCache(pm projectmanage.ProjectManage, fastEvent *eventBus.FastEvent) (ProjectCacheT, error)
• type SlotCacheT
  • func NewSlotCache(pm common.Common) (SlotCacheT, error)
• type TenantCacheT
  • func NewTenantInfoCache(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (TenantCacheT, error)
• type UserCacheT
  • func NewUserInfoCache(pm usermanage.UserManage, fastEvent *eventBus.FastEvent) (UserCacheT, error)
• type WebHookCacheT
  • func NewTenantOpenWebhookCache(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (WebHookCacheT, error)
• type Webhook
  • func NewTenantOpenWebhook(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (*Webhook, error)
  • func (i *Webhook) Publish(ctx context.Context, code string, in any) error

Constants

const (
	CodeDmDeviceConn           = "dmDeviceConn"
	CodeDmDevicePropertyReport = "devicePropertyReport"
)

Functions

func GenApiCacheKey

func GenApiCacheKey(method, route string) string

func GenSlotCacheKey

func GenSlotCacheKey(code string, subCode string) string

func GenWebhookCacheKey

func GenWebhookCacheKey(ctx context.Context, code string) string

Types

type AreaCacheT

type AreaCacheT = *caches.Cache[areamanage.AreaInfo, int64]

func NewAreaInfoCache

func NewAreaInfoCache(pm areamanage.AreaManage, fastEvent *eventBus.FastEvent) (AreaCacheT, error)

type ProjectCacheT

type ProjectCacheT = *caches.Cache[projectmanage.ProjectInfo, int64]

func NewProjectInfoCache

func NewProjectInfoCache(pm projectmanage.ProjectManage, fastEvent *eventBus.FastEvent) (ProjectCacheT, error)

type SlotCacheT

type SlotCacheT = *caches.Cache[slot.Infos, string]

func NewSlotCache

func NewSlotCache(pm common.Common) (SlotCacheT, error)

type TenantCacheT

type TenantCacheT = *caches.Cache[tenant.Info, string]

func NewTenantInfoCache

func NewTenantInfoCache(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (TenantCacheT, error)

type UserCacheT

type UserCacheT = *caches.Cache[usermanage.UserInfo, int64]

func NewUserInfoCache

func NewUserInfoCache(pm usermanage.UserManage, fastEvent *eventBus.FastEvent) (UserCacheT, error)

type WebHookCacheT

type WebHookCacheT = *caches.Cache[sys.TenantOpenWebHook, string]

func NewTenantOpenWebhookCache

func NewTenantOpenWebhookCache(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (WebHookCacheT, error)

type Webhook

type Webhook struct {
	*caches.Cache[sys.TenantOpenWebHook, string]
	// contains filtered or unexported fields
}

func NewTenantOpenWebhook

func NewTenantOpenWebhook(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (*Webhook, error)

func (*Webhook) Publish

func (i *Webhook) Publish(ctx context.Context, code string, in any) error