server

Documentation

Index

• type AppDelegate
• type CommissioningModeProvider
• type CommissioningWindowAdvertisement
• type CommissioningWindowManager
  • func (c *CommissioningWindowManager) GetNewSessionHandlingPolicy() transport.NewSessionHandlingPolicy
  • func (c *CommissioningWindowManager) Init(server *Server)
  • func (c *CommissioningWindowManager) OnSessionEstablished()
  • func (c *CommissioningWindowManager) OnSessionEstablishmentError()
  • func (c *CommissioningWindowManager) OnSessionEstablishmentStarted()
  • func (c *CommissioningWindowManager) OnSessionHang()
  • func (c *CommissioningWindowManager) OnSessionReleased()
  • func (c *CommissioningWindowManager) OpenBasicCommissioningWindow(commissioningTimeout time.Duration, ...) error
  • func (c *CommissioningWindowManager) OpenCommissioningWindow(timeout time.Duration) error
• type CommonCaseDeviceServerInitParams
  • func NewCommonCaseDeviceServerInitParams() *CommonCaseDeviceServerInitParams
• type GroupDataProviderListener
• type GroupDataProviderListenerImpl
  • func (g *GroupDataProviderListenerImpl) Init(server *Server) error
  • func (g *GroupDataProviderListenerImpl) OnGroupAdded(fabricIndex lib.FabricIndex, newGroup *credentials.GroupInfo)
  • func (g *GroupDataProviderListenerImpl) OnGroupRemoved(fabricIndex lib.FabricIndex, newGroup *credentials.GroupInfo)
• type IgnoreCertificateValidityPolicy
  • func NewIgnoreCertificateValidityPolicy() *IgnoreCertificateValidityPolicy
• type InitParams
  • func NewServerInitParams() *InitParams
  • func (params *InitParams) Init(options *config.DeviceOptions) (*InitParams, error)
  • func (params *InitParams) InitializeStaticResourcesBeforeServerInit() error
• type Server
  • func DefaultServer() *Server
  • func NewServer() *Server
  • func (s *Server) GetFabricTable() *credentials.FabricTable
  • func (s *Server) Init(initParams *InitParams) error
  • func (s *Server) Shutdown()
  • func (s *Server) StartServer() error
• type ServerTransportMgr
  • func NewServerTransportMgr(transports ...raw.TransportBase) *ServerTransportMgr

Types

type AppDelegate

type AppDelegate interface {
	OnCommissioningSessionStarted()
	OnCommissioningSessionStopped()
	OnCommissioningWindowOpened()
	OnCommissioningWindowClosed()
}

type CommissioningModeProvider

type CommissioningModeProvider interface {
	GetCommissioningMode() int
}

type CommissioningWindowAdvertisement

type CommissioningWindowAdvertisement uint8

type CommissioningWindowManager

type CommissioningWindowManager struct {
	// contains filtered or unexported fields
}

func (*CommissioningWindowManager) GetNewSessionHandlingPolicy

func (c *CommissioningWindowManager) GetNewSessionHandlingPolicy() transport.NewSessionHandlingPolicy

func (*CommissioningWindowManager) Init

func (c *CommissioningWindowManager) Init(server *Server)

func (*CommissioningWindowManager) OnSessionEstablished

func (c *CommissioningWindowManager) OnSessionEstablished()

func (*CommissioningWindowManager) OnSessionEstablishmentError

func (c *CommissioningWindowManager) OnSessionEstablishmentError()

func (*CommissioningWindowManager) OnSessionEstablishmentStarted

func (c *CommissioningWindowManager) OnSessionEstablishmentStarted()

func (*CommissioningWindowManager) OnSessionHang

func (c *CommissioningWindowManager) OnSessionHang()

func (*CommissioningWindowManager) OnSessionReleased

func (c *CommissioningWindowManager) OnSessionReleased()

func (*CommissioningWindowManager) OpenBasicCommissioningWindow

func (c *CommissioningWindowManager) OpenBasicCommissioningWindow(
	commissioningTimeout time.Duration,
	advertisementMode CommissioningWindowAdvertisement) error

func (*CommissioningWindowManager) OpenCommissioningWindow

func (c *CommissioningWindowManager) OpenCommissioningWindow(timeout time.Duration) error

type CommonCaseDeviceServerInitParams

type CommonCaseDeviceServerInitParams struct {
	InitParams
}

func NewCommonCaseDeviceServerInitParams

func NewCommonCaseDeviceServerInitParams() *CommonCaseDeviceServerInitParams

type GroupDataProviderListener

type GroupDataProviderListener interface {
	credentials.GroupListener
	Init(server *Server) error
}

type GroupDataProviderListenerImpl

type GroupDataProviderListenerImpl struct {
	// contains filtered or unexported fields
}

func (*GroupDataProviderListenerImpl) Init

func (g *GroupDataProviderListenerImpl) Init(server *Server) error

func (*GroupDataProviderListenerImpl) OnGroupAdded

func (g *GroupDataProviderListenerImpl) OnGroupAdded(fabricIndex lib.FabricIndex, newGroup *credentials.GroupInfo)

func (*GroupDataProviderListenerImpl) OnGroupRemoved

func (g *GroupDataProviderListenerImpl) OnGroupRemoved(fabricIndex lib.FabricIndex, newGroup *credentials.GroupInfo)

type IgnoreCertificateValidityPolicy

type IgnoreCertificateValidityPolicy struct {
	credentials.CertificateValidityPolicy
}

func NewIgnoreCertificateValidityPolicy

func NewIgnoreCertificateValidityPolicy() *IgnoreCertificateValidityPolicy

type InitParams

type InitParams struct {
	OperationalServicePort        uint16
	UserDirectedCommissioningPort uint16
	InterfaceId                   net.Interface
	AppDelegate                   AppDelegate

	// Persistent storage delegate: MUST be injected. Used to maintain storage by much common code.
	// Must be initialized before being provided.
	PersistentStorageDelegate store.PersistentStorageDelegate
	// Session resumption storage: Optional. Support session resumption when provided.
	// Must be initialized before being provided.
	SessionResumptionStorage lib.SessionResumptionStorage

	CertificateValidityPolicy credentials.CertificateValidityPolicy

	// Group data provider: MUST be injected. Used to maintain critical keys such as the Identity
	// Protection Key (IPK) for CASE. Must be initialized before being provided.
	GroupDataProvider *credentials.GroupDataProvider
	// Access control delegate: MUST be injected. Used to look up access control rules. Must be
	// initialized before being provided.
	AccessDelegate access.Delegate
	// ACL storage: MUST be injected. Used to store ACL entries in persistent storage. Must NOT
	// be initialized before being provided.
	//aclStorage app::AclStorage * aclStorage = nullptr;
	AclStorage core.AclStorage

	// Network native params can be injected depending on the
	// selected Endpoint implementation
	EndpointNativeParams func()

	// Optional. Support test event triggers when provided. Must be initialized before being
	// provided.
	TestEventTriggerDelegate core.TestEventTriggerDelegate
	// Operational keystore with access to the operational keys: MUST be injected.
	OperationalKeystore crypto2.OperationalKeystore
	// Operational certificate store with access to the operational certs in persisted storage:
	// must not be null at timne of Server::initCommissionableData().
	OpCertStore credentials.PersistentStorageOpCertStore
}

func NewServerInitParams

func NewServerInitParams() *InitParams

func (*InitParams) Init

func (params *InitParams) Init(options *config.DeviceOptions) (*InitParams, error)

func (*InitParams) InitializeStaticResourcesBeforeServerInit

func (params *InitParams) InitializeStaticResourcesBeforeServerInit() error

type Server

type Server struct {
	// contains filtered or unexported fields
}

func DefaultServer

func DefaultServer() *Server

func NewServer

func NewServer() *Server

func (*Server) GetFabricTable

func (s *Server) GetFabricTable() *credentials.FabricTable

GetFabricTable 返回CHIP服务中的Fabric

func (*Server) Init

func (s *Server) Init(initParams *InitParams) error

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) StartServer

func (s *Server) StartServer() error

type ServerTransportMgr

type ServerTransportMgr struct {
	*transport.Manager
}

func NewServerTransportMgr

func NewServerTransportMgr(transports ...raw.TransportBase) *ServerTransportMgr