fabric

Feb 18, 2021

Changes in this version

type StateManager

+ func NewStateManager() StateManager

+ ValidateSessions func(ch channel2.Channel, chunkSize uint32, minInterval, maxInterval time.Duration)

type StateManagerImpl

+ func (sm *StateManagerImpl) SessionConnectionClosed(token string)

+ func (sm *StateManagerImpl) ValidateSessions(ch channel2.Channel, chunkSize uint32, minInterval, maxInterval time.Duration)

Feb 5, 2021

Changes in this version

+ type MapWithMutex struct

+ func (self *MapWithMutex) Put(ch channel2.Channel, f func())

Jan 26, 2021

Changes in this version

type StateManager

+ GetApiSessionWithTimeout func(token string, timeout time.Duration) *edge_ctrl_pb.ApiSession

type StateManagerImpl

+ func (sm *StateManagerImpl) GetApiSessionWithTimeout(token string, timeout time.Duration) *edge_ctrl_pb.ApiSession

Jan 7, 2021

Changes in this version

type StateManager

+ AddApiSessionRemovedListener func(token string, callBack func(token string)) RemoveListener

+ AddConnectedApiSession func(token string, removeCB func(), ch channel2.Channel)

+ GetApiSession func(token string) *edge_ctrl_pb.ApiSession

+ GetApiSessionByFingerprint func(fingerprint string) chan *edge_ctrl_pb.ApiSession

+ GetSessionWithTimeout func(token string, timeout time.Duration) *edge_ctrl_pb.Session

+ RemoveConnectedApiSession func(token string, underlay channel2.Channel)

type StateManagerImpl

+ func (sm *StateManagerImpl) AddApiSessionRemovedListener(token string, callBack func(token string)) RemoveListener

+ func (sm *StateManagerImpl) AddConnectedApiSession(token string, removeCB func(), ch channel2.Channel)

+ func (sm *StateManagerImpl) GetApiSession(token string) *edge_ctrl_pb.ApiSession

+ func (sm *StateManagerImpl) GetApiSessionByFingerprint(fingerprint string) chan *edge_ctrl_pb.ApiSession

+ func (sm *StateManagerImpl) GetSessionWithTimeout(token string, timeout time.Duration) *edge_ctrl_pb.Session

+ func (sm *StateManagerImpl) RemoveConnectedApiSession(token string, ch channel2.Channel)

Oct 8, 2020

Changes in this version

+ const EventAddedNetworkSession

+ const EventAddedSession

+ const EventRemovedNetworkSession

+ const EventRemovedSession

+ const EventUpdatedNetworkSession

+ const EventUpdatedSession

+ type DisconnectCB func(token string)

+ type RemoveListener func()

+ type StateManager interface

+ AddApiSession func(ns *edge_ctrl_pb.ApiSession)

+ AddConnectedSession func(token string, removeCB func(), ch channel2.Channel)

+ AddNetworkSessionRemovedListener func(token string, callBack func(token string)) RemoveListener

+ AddSession func(ns *edge_ctrl_pb.Session)

+ AddSessionRemovedListener func(token string, callBack func(token string)) RemoveListener

+ GetNetworkSession func(token string) *edge_ctrl_pb.Session

+ GetNetworkSessionWithTimeout func(token string, timeout time.Duration) *edge_ctrl_pb.Session

+ GetSession func(token string) *edge_ctrl_pb.ApiSession

+ GetSessionByFingerprint func(fingerprint string) chan *edge_ctrl_pb.ApiSession

+ RemoveApiSession func(token string)

+ RemoveConnectedSession func(token string, underlay channel2.Channel)

+ RemoveMissingApiSessions func(knownSessions []*edge_ctrl_pb.ApiSession)

+ RemoveMissingSessions func(knownSessions []*edge_ctrl_pb.Session)

+ RemoveSession func(token string)

+ StartHeartbeat func(channel channel2.Channel, seconds int)

+ UpdateApiSession func(ns *edge_ctrl_pb.ApiSession)

+ UpdateSession func(ns *edge_ctrl_pb.Session)

+ func GetStateManager() StateManager

+ type StateManagerImpl struct

+ ClusterId string

+ ControllerAddr string

+ Hostname string

+ NodeId string

+ func (sm *StateManagerImpl) ActiveSessionTokens() []string

+ func (sm *StateManagerImpl) AddApiSession(session *edge_ctrl_pb.ApiSession)

+ func (sm *StateManagerImpl) AddConnectedSession(token string, removeCB func(), ch channel2.Channel)

+ func (sm *StateManagerImpl) AddNetworkSessionRemovedListener(token string, callBack func(token string)) RemoveListener

+ func (sm *StateManagerImpl) AddSession(ns *edge_ctrl_pb.Session)

+ func (sm *StateManagerImpl) AddSessionRemovedListener(token string, callBack func(token string)) RemoveListener

+ func (sm *StateManagerImpl) GetNetworkSession(token string) *edge_ctrl_pb.Session

+ func (sm *StateManagerImpl) GetNetworkSessionWithTimeout(token string, timeout time.Duration) *edge_ctrl_pb.Session

+ func (sm *StateManagerImpl) GetSession(token string) *edge_ctrl_pb.ApiSession

+ func (sm *StateManagerImpl) GetSessionByFingerprint(fingerprint string) chan *edge_ctrl_pb.ApiSession

+ func (sm *StateManagerImpl) RemoveApiSession(token string)

+ func (sm *StateManagerImpl) RemoveConnectedSession(token string, ch channel2.Channel)

+ func (sm *StateManagerImpl) RemoveMissingApiSessions(knownSessions []*edge_ctrl_pb.ApiSession)

+ func (sm *StateManagerImpl) RemoveMissingSessions(knownSessions []*edge_ctrl_pb.Session)

+ func (sm *StateManagerImpl) RemoveSession(token string)

+ func (sm *StateManagerImpl) StartHeartbeat(ctrl channel2.Channel, intervalSeconds int)

+ func (sm *StateManagerImpl) UpdateApiSession(session *edge_ctrl_pb.ApiSession)

+ func (sm *StateManagerImpl) UpdateSession(ns *edge_ctrl_pb.Session)

+ type TokenProvider interface

+ ActiveSessionTokens func() []string