fabric

package

Go to main page

Versions in this module

v0

v0.33.1

Mar 13, 2024

v0.33.0

Mar 12, 2024

Changes in this version

type StateManager

+ MarkSessionRecentlyRemoved func(token string)

type StateManagerImpl

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

v0.32.2

Feb 10, 2024

v0.32.1

Jan 31, 2024

v0.32.0

Jan 19, 2024

Changes in this version

type StateManager

+ WasSessionRecentlyRemoved func(token string) bool

type StateManagerImpl

+ func (sm *StateManagerImpl) WasSessionRecentlyRemoved(token string) bool

v0.31.4

Dec 18, 2023

v0.31.3

Dec 13, 2023

v0.31.2

Dec 7, 2023

v0.31.1

Dec 7, 2023

v0.31.0

Nov 1, 2023

v0.30.5

Oct 13, 2023

v0.30.4

Sep 30, 2023

Changes in this version

+ const EventAddedApiSession

+ const EventRemovedApiSession

+ const EventRemovedEdgeSession

+ const EventUpdatedApiSession

+ type ApiSession struct

+ Claims *oidc_auth.AccessClaims

+ JwtToken *jwt.Token

+ type DisconnectCB func(token string)

+ type MapWithMutex struct

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

+ type RemoveListener func()

+ type StateManager interface

+ AddApiSession func(apiSession *edge_ctrl_pb.ApiSession)

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

+ AddConnectedApiSession func(token string)

+ AddConnectedApiSessionWithChannel func(token string, removeCB func(), ch channel.Channel)

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

+ AddSignerPublicCert func(keys [][]byte)

+ DumpApiSessions func(c *bufio.ReadWriter) error

+ GetApiSession func(token string) *ApiSession

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

+ IsSyncInProgress func() bool

+ MarkSyncInProgress func(trackerId string)

+ MarkSyncStopped func(trackerId string)

+ RemoveApiSession func(token string)

+ RemoveConnectedApiSession func(token string)

+ RemoveConnectedApiSessionWithChannel func(token string, underlay channel.Channel)

+ RemoveEdgeSession func(token string)

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

+ StartHeartbeat func(env env.RouterEnv, seconds int, closeNotify <-chan struct{})

+ UpdateApiSession func(apiSession *edge_ctrl_pb.ApiSession)

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

+ func NewStateManager() StateManager

+ type StateManagerImpl struct

+ ClusterId string

+ ControllerAddr string

+ Hostname string

+ NodeId string

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

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

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

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

+ func (sm *StateManagerImpl) AddConnectedApiSessionWithChannel(token string, removeCB func(), ch channel.Channel)

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

+ func (sm *StateManagerImpl) AddSignerPublicCert(keys [][]byte)

+ func (sm *StateManagerImpl) DumpApiSessions(c *bufio.ReadWriter) error

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

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

+ func (sm *StateManagerImpl) IsSyncInProgress() bool

+ func (sm *StateManagerImpl) MarkSyncInProgress(trackerId string)

+ func (sm *StateManagerImpl) MarkSyncStopped(trackerId string)

+ func (sm *StateManagerImpl) RefreshSigners()

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

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

+ func (sm *StateManagerImpl) RemoveConnectedApiSessionWithChannel(token string, ch channel.Channel)

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

+ func (sm *StateManagerImpl) RemoveMissingApiSessions(knownApiSessions []*edge_ctrl_pb.ApiSession, beforeSessionId string)

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

+ func (sm *StateManagerImpl) StartHeartbeat(env env.RouterEnv, intervalSeconds int, closeNotify <-chan struct{})

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

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

+ type TokenProvider interface

+ ActiveApiSessionTokens func() []string

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