api

package

Go to main page

Versions in this module

v1

v1.4.21

Aug 10, 2026

Changes in this version

+ func NewIPCProviderAdapter(ipcBundle IPCBundle) recording.IPCProvider

+ func NewPlayProviderAdapter(smsCore sms.Core) recording.PlayProvider

type IPCAPI

+ func (a IPCAPI) ListChannelsForDevice(c *gin.Context, in *ipc.FindDeviceInput) (any, error)

v1.4.0

Jun 4, 2026

Changes in this version

+ func NewEventCoreWithNotifier(conf *conf.Bootstrap, db *gorm.DB, notifier *push.Notifier) event.Core

+ func NewNotifier(conf *conf.Bootstrap) *push.Notifier

v1.3.34

May 30, 2026

Changes in this version

+ func AuthMiddleware(secret string, authURL string, handler ...web.HandlerOption) gin.HandlerFunc

+ func NewRecordingCore(store recording.Storer, cfg *conf.Bootstrap, provider recording.SMSProvider) recording.Core

+ func NewRecordingStore(db *gorm.DB) recording.Storer

+ func NewSMSProviderAdapter(smsCore sms.Core) recording.SMSProvider

+ func RegisterRecording(g gin.IRouter, api RecordingAPI, handler ...gin.HandlerFunc)

+ func RegisterRecordingVideoOnly(g gin.IRouter, api RecordingAPI, handler ...gin.HandlerFunc)

type AIWebhookAPI

+ func (a *AIWebhookAPI) ReloadAITask(ctx context.Context, ch *ipc.Channel) error

+ type IPCBundle struct

+ Core ipc.Core

+ Protocols map[string]ipc.Protocoler

+ func NewIPCCoreWithProtocols(store ipc.Storer, uni uniqueid.Core, adapter ipc.Adapter, smsCore sms.Core, ...) IPCBundle

+ type RecordingAPI struct

+ func NewRecordingAPI(core recording.Core, conf *conf.Bootstrap) RecordingAPI

type Usecase

+ MetadataAPI metadataapi.MetadataAPI

+ RecordingAPI RecordingAPI

v1.3.0

Jan 13, 2026

v1.2.0

Jan 9, 2026

Changes in this version

+ var ErrAIGlobalDisabled = reason.NewError("ErrAIGlobalDisabled", "AI 功能已在全局配置中禁用")

+ var ErrAIServiceNotReady = reason.NewError("ErrAIServiceNotReady", "AI 服务未初始化或连接失败")

+ var ErrChannelNotSupported = reason.NewError("ErrChannelNotSupported", "不支持的通道类型")

+ var ErrDevice = reason.NewError("ErrDevice", "设备错误")

+ var ProviderSet = wire.NewSet(wire.Struct(new(Usecase), "*"), NewHTTPHandler, versionapi.New, NewSMSCore, ...)

+ var ProviderVersionSet = wire.NewSet(versionapi.NewVersionCore)

+ func NewEventCore(db *gorm.DB, conf *conf.Bootstrap) event.Core

+ func NewGBAdapter(store ipc.Storer, uni uniqueid.Core) ipc.Adapter

+ func NewHTTPHandler(uc *Usecase) http.Handler

+ func NewIPCCore(store ipc.Storer, uni uniqueid.Core, protocols map[string]ipc.Protocoler) ipc.Core

+ func NewIPCStore(db *gorm.DB) ipc.Storer

+ func NewProtocols(adapter ipc.Adapter, sms sms.Core, proxyCore *proxy.Core, gbs *gbs.Server) map[string]ipc.Protocoler

+ func NewProxyCore(db *gorm.DB, uni uniqueid.Core) *proxy.Core

+ func NewPushCore(db *gorm.DB, uni uniqueid.Core) push.Core

+ func NewSMSCore(db *gorm.DB, cfg *conf.Bootstrap) sms.Core

+ func NewUniqueID(db *gorm.DB) uniqueid.Core

+ func RegisterEvent(g gin.IRouter, api EventAPI, handler ...gin.HandlerFunc)

+ func RegisterUser(r gin.IRouter, api UserAPI, mid ...gin.HandlerFunc)

+ type AIBoundingBox struct

+ XMax int

+ XMin int

+ YMax int

+ YMin int

+ type AIDetection struct

+ Area int

+ Box AIBoundingBox

+ Confidence float64

+ Label string

+ NormBox *AINormBox

+ type AIDetectionInput struct

+ CameraID string

+ Detections []AIDetection

+ Snapshot string

+ SnapshotHeight int

+ SnapshotWidth int

+ Timestamp orm.Time

+ type AIGlobalStats struct

+ ActiveStreams int

+ TotalDetections int64

+ UptimeSeconds int64

+ type AIKeepaliveInput struct

+ Message string

+ Stats *AIGlobalStats

+ Timestamp int64

+ type AINormBox struct

+ H float64

+ W float64

+ X float64

+ Y float64

+ type AIStartedInput struct

+ Message string

+ Timestamp int64

+ type AIStoppedInput struct

+ CameraID string

+ Message string

+ Reason string

+ Timestamp orm.Time

+ type AIWebhookAPI struct

+ func NewAIWebhookAPI(conf *conf.Bootstrap, eventCore event.Core, ipcCore ipc.Core) AIWebhookAPI

+ func NewAIWebhookAPIWithDeps(conf *conf.Bootstrap, eventCore event.Core, ipcCore ipc.Core) AIWebhookAPI

+ func (a *AIWebhookAPI) StartAIDetection(ctx context.Context, ch *ipc.Channel, rtspURL string) (*protos.StartCameraResponse, error)

+ func (a *AIWebhookAPI) StartAISyncLoop(ctx context.Context, smsCore sms.Core)

+ func (a *AIWebhookAPI) StopAIDetection(ctx context.Context, channelID string) error

+ type AIWebhookOutput struct

+ Code int

+ Msg string

+ type ConfigAPI struct

+ func NewConfigAPI(db *gorm.DB, conf *conf.Bootstrap) ConfigAPI

+ type Data struct

+ Buffer int

+ BufferLikeString int

+ BufferList int

+ BufferRaw int

+ Frame int

+ FrameImp int

+ MediaSource int

+ MultiMediaSourceMuxer int

+ RtmpPacket int

+ RtpPacket int

+ Socket int

+ TCPClient int

+ TCPServer int

+ TCPSession int

+ UDPServer int

+ UDPSession int

+ type DefaultOutput struct

+ Code int

+ Msg string

+ type EventAPI struct

+ func NewEventAPI(core event.Core, conf *conf.Bootstrap) EventAPI

+ type IOWriter struct

+ func (w IOWriter) Write(b []byte) (int, error)

+ type IPCAPI struct

+ func NewIPCAPI(core ipc.Core) IPCAPI

+ func (a IPCAPI) FindChannelsForDevice(c *gin.Context, in *ipc.FindDeviceInput) (any, error)

+ type KV struct

+ Key string

+ Value int64

+ type OriginSock struct

+ Identifier string

+ LocalIP string

+ LocalPort int

+ PeerIP string

+ PeerPort int

+ type ProxyAPI struct

+ func NewProxyAPI(proxyCore *proxy.Core) ProxyAPI

+ type PushAPI struct

+ func NewPushAPI(mc push.Core, sc sms.Core, conf *conf.Bootstrap) PushAPI

+ type Secret struct

+ func (s *Secret) Decrypt(ciphertext string) ([]byte, error)

+ func (s *Secret) GetOrCreatePublicKey() (*rsa.PublicKey, error)

+ func (s *Secret) MarshalPKIXPublicKey(key *rsa.PublicKey) []byte

+ type SmsAPI struct

+ func NewSmsAPI(core sms.Core) SmsAPI

+ type Tracks struct

+ Channels int

+ CodecID int

+ CodecIDName string

+ CodecType int

+ Fps float32

+ Height int

+ Ready bool

+ SampleBit int

+ SampleRate int

+ Width int

+ type Usecase struct

+ AIWebhookAPI AIWebhookAPI

+ Conf *conf.Bootstrap

+ ConfigAPI ConfigAPI

+ DB *gorm.DB

+ EventAPI EventAPI

+ GB28181API IPCAPI

+ MediaAPI PushAPI

+ ProxyAPI ProxyAPI

+ SMSAPI SmsAPI

+ SipServer *gbs.Server

+ UniqueID uniqueid.Core

+ UserAPI UserAPI

+ Version versionapi.API

+ WebHookAPI WebHookAPI

+ type UserAPI struct

+ func NewUserAPI(conf *conf.Bootstrap) UserAPI

+ type WebHookAPI struct

+ func NewWebHookAPI(core sms.Core, mediaCore push.Core, conf *conf.Bootstrap, gbs *gbs.Server, ...) WebHookAPI

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL