common

Sep 4, 2024

Changes in this version

+ const CustomClaimIsCertExtendable

type CustomClaims

+ IsCertExtendable bool

Aug 22, 2024

Changes in this version

+ const ClaimClientIdOpenZiti

+ const ClaimLegacyNative

Jul 29, 2024

Changes in this version

+ const EventAccessGained

+ const EventAccessRemoved

+ const EventFullState

+ const EventIdentityDeleted

+ const EventIdentityUpdated

+ const EventPostureChecksUpdated

+ const EventUpdated

+ func CloneMap[V any](m cmap.ConcurrentMap[string, V]) cmap.ConcurrentMap[string, V]

+ type Config struct

+ Index uint64

+ type ConfigType struct

+ Index uint64

+ type DataStateConfig = edge_ctrl_pb.DataState_Config

+ type DataStateConfigType = edge_ctrl_pb.DataState_ConfigType

+ type DataStatePostureCheck = edge_ctrl_pb.DataState_PostureCheck

+ type DataStateService = edge_ctrl_pb.DataState_Service

type Identity

+ IdentityIndex uint64

+ ServiceSetIndex uint64

+ type IdentityConfig struct

+ Config *Config

+ ConfigType *ConfigType

+ type IdentityEventSubscriber interface

+ NotifyIdentityEvent func(state *IdentityState, eventType IdentityEventType)

+ NotifyServiceChange func(state *IdentityState, service *IdentityService, eventType ServiceEventType)

+ type IdentityEventType byte

+ type IdentityService struct

+ BindAllowed bool

+ Checks map[string]struct{}

+ Configs map[string]*IdentityConfig

+ DialAllowed bool

+ Service *Service

+ func (self *IdentityService) Equals(other *IdentityService) bool

+ type IdentityState struct

+ Identity *Identity

+ PostureChecks map[string]*PostureCheck

+ Services map[string]*IdentityService

+ type IdentitySubscription struct

+ Checks map[string]*PostureCheck

+ Identity *Identity

+ IdentityId string

+ Listeners concurrenz.CopyOnWriteSlice[IdentityEventSubscriber]

+ Services map[string]*IdentityService

+ type PostureCheck struct

+ Index uint64

type RouterDataModel

+ ConfigTypes cmap.ConcurrentMap[string, *ConfigType]

+ Configs cmap.ConcurrentMap[string, *Config]

+ func (rdm *RouterDataModel) HandleConfigEvent(index uint64, event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandleConfigTypeEvent(index uint64, event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) InheritSubscribers(other *RouterDataModel)

+ func (rdm *RouterDataModel) Stop()

+ func (rdm *RouterDataModel) SubscribeToIdentityChanges(identityId string, subscriber IdentityEventSubscriber, isRouterIdentity bool) error

+ func (rdm *RouterDataModel) SyncAllSubscribers()

+ type Service struct

+ Index uint64

+ type ServiceEventType byte

Apr 25, 2024

Changes in this version

+ type DataStateIdentity = edge_ctrl_pb.DataState_Identity

+ type DataStateServicePolicy = edge_ctrl_pb.DataState_ServicePolicy

type IdTokenClaims

+ func (r *IdTokenClaims) GetAudience() (jwt.ClaimStrings, error)

+ func (r *IdTokenClaims) GetExpirationTime() (*jwt.NumericDate, error)

+ func (r *IdTokenClaims) GetIssuedAt() (*jwt.NumericDate, error)

+ func (r *IdTokenClaims) GetIssuer() (string, error)

+ func (r *IdTokenClaims) GetNotBefore() (*jwt.NumericDate, error)

+ func (r *IdTokenClaims) GetSubject() (string, error)

+ type Identity struct

+ ServicePolicies map[string]struct{}

type RouterDataModel

+ func (rdm *RouterDataModel) ApplyChangeSet(change *edge_ctrl_pb.DataState_ChangeSet)

+ func (rdm *RouterDataModel) HandleServicePolicyChange(model *edge_ctrl_pb.DataState_ServicePolicyChange)

+ type ServicePolicy struct

+ PostureChecks map[string]struct{}

+ Services map[string]struct{}

Apr 8, 2024

Changes in this version

type RouterDataModel

+ func (rdm *RouterDataModel) GetPublicKeys() map[string]*edge_ctrl_pb.DataState_PublicKey

Mar 25, 2024

Changes in this version

+ const ClaimAudienceOpenZiti

+ const CustomClaimApiSessionId

+ const CustomClaimExternalId

+ const CustomClaimIdentityId

+ const CustomClaimIsAdmin

+ const CustomClaimRemoteAddress

+ const CustomClaimServiceId

+ const CustomClaimServiceType

+ const CustomClaimsCertFingerprints

+ const CustomClaimsConfigTypes

+ const CustomClaimsTokenType

+ const DefaultAccessTokenDuration

+ const DefaultIdTokenDuration

+ const DefaultRefreshTokenDuration

+ const TokenTypeAccess

+ const TokenTypeRefresh

+ const TokenTypeServiceAccess

+ type AccessClaims struct

+ func (c *AccessClaims) HasAudience(targetAud string) bool

+ func (c *AccessClaims) TotpComplete() bool

+ func (r *AccessClaims) ConfigTypesAsMap() map[string]struct{}

+ func (r *AccessClaims) GetAudience() (jwt.ClaimStrings, error)

+ func (r *AccessClaims) GetExpirationTime() (*jwt.NumericDate, error)

+ func (r *AccessClaims) GetIssuedAt() (*jwt.NumericDate, error)

+ func (r *AccessClaims) GetIssuer() (string, error)

+ func (r *AccessClaims) GetNotBefore() (*jwt.NumericDate, error)

+ func (r *AccessClaims) GetSubject() (string, error)

+ func (r *AccessClaims) UnmarshalJSON(raw []byte) error

+ type AccessPolicies struct

+ Identity *edge_ctrl_pb.DataState_Identity

+ Policies []*edge_ctrl_pb.DataState_ServicePolicy

+ PostureChecks map[string]*edge_ctrl_pb.DataState_PostureCheck

+ Service *edge_ctrl_pb.DataState_Service

+ type CustomClaims struct

+ ApiSessionId string

+ ApplicationId string

+ CertFingerprints []string

+ ConfigTypes []string

+ EnvInfo *rest_model.EnvInfo

+ ExternalId string

+ IsAdmin bool

+ RemoteAddress string

+ Scopes []string

+ SdkInfo *rest_model.SdkInfo

+ Type string

+ func (c *CustomClaims) ToMap() (map[string]any, error)

+ type EventCache interface

+ CurrentIndex func() (uint64, bool)

+ ReplayFrom func(startIndex uint64) ([]*edge_ctrl_pb.DataState_Event, bool)

+ SetCurrentIndex func(uint64)

+ Store func(event *edge_ctrl_pb.DataState_Event, onSuccess OnStoreSuccess) error

+ WhileLocked func(func(uint64, bool))

+ type ForgetfulEventCache struct

+ func NewForgetfulEventCache() *ForgetfulEventCache

+ func (cache *ForgetfulEventCache) CurrentIndex() (uint64, bool)

+ func (cache *ForgetfulEventCache) ReplayFrom(_ uint64) ([]*edge_ctrl_pb.DataState_Event, bool)

+ func (cache *ForgetfulEventCache) SetCurrentIndex(index uint64)

+ func (cache *ForgetfulEventCache) Store(event *edge_ctrl_pb.DataState_Event, onSuccess OnStoreSuccess) error

+ func (cache *ForgetfulEventCache) WhileLocked(callback func(uint64, bool))

+ type IdTokenClaims struct

+ func (c *IdTokenClaims) TotpComplete() bool

+ type LoggingEventCache struct

+ Events map[uint64]*edge_ctrl_pb.DataState_Event

+ HeadLogIndex uint64

+ Log []uint64

+ LogSize uint64

+ func NewLoggingEventCache(logSize uint64) *LoggingEventCache

+ func (cache *LoggingEventCache) CurrentIndex() (uint64, bool)

+ func (cache *LoggingEventCache) ReplayFrom(startIndex uint64) ([]*edge_ctrl_pb.DataState_Event, bool)

+ func (cache *LoggingEventCache) SetCurrentIndex(index uint64)

+ func (cache *LoggingEventCache) Store(event *edge_ctrl_pb.DataState_Event, onSuccess OnStoreSuccess) error

+ func (cache *LoggingEventCache) WhileLocked(callback func(uint64, bool))

+ type OnStoreSuccess func(index uint64, event *edge_ctrl_pb.DataState_Event)

+ type RefreshClaims struct

+ func (c *RefreshClaims) MarshalJSON() ([]byte, error)

+ func (c *RefreshClaims) UnmarshalJSON(data []byte) error

+ func (r *RefreshClaims) GetAudience() (jwt.ClaimStrings, error)

+ func (r *RefreshClaims) GetExpirationTime() (*jwt.NumericDate, error)

+ func (r *RefreshClaims) GetIssuedAt() (*jwt.NumericDate, error)

+ func (r *RefreshClaims) GetIssuer() (string, error)

+ func (r *RefreshClaims) GetNotBefore() (*jwt.NumericDate, error)

+ func (r *RefreshClaims) GetSubject() (string, error)

+ type RouterDataModel struct

+ Identities cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_Identity]

+ PostureChecks cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_PostureCheck]

+ PublicKeys cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_PublicKey]

+ Revocations cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_Revocation]

+ ServicePolicies cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_ServicePolicy]

+ Services cmap.ConcurrentMap[string, *edge_ctrl_pb.DataState_Service]

+ func NewReceiverRouterDataModel(listenerBufferSize uint) *RouterDataModel

+ func NewReceiverRouterDataModelFromFile(path string, listenerBufferSize uint) (*RouterDataModel, error)

+ func NewSenderRouterDataModel(logSize uint64, listenerBufferSize uint) *RouterDataModel

+ func (rdm *RouterDataModel) Apply(event *edge_ctrl_pb.DataState_Event)

+ func (rdm *RouterDataModel) ApplyIdentityEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) ApplyPostureCheckEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) ApplyPublicKeyEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) ApplyRevocationEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) ApplyServiceEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) ApplyServicePolicyEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) GetDataState() *edge_ctrl_pb.DataState

+ func (rdm *RouterDataModel) GetServiceAccessPolicies(identityId string, serviceId string) (*AccessPolicies, error)

+ func (rdm *RouterDataModel) Handle(event *edge_ctrl_pb.DataState_Event)

+ func (rdm *RouterDataModel) HandleIdentityEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandlePostureCheckEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandlePublicKeyEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandleRevocationEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandleServiceEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) HandleServicePolicyEvent(event *edge_ctrl_pb.DataState_Event, ...)

+ func (rdm *RouterDataModel) NewListener() <-chan *edge_ctrl_pb.DataState_Event

+ func (rdm *RouterDataModel) Save(path string)

+ type ServiceAccessClaims struct

+ ApiSessionId string

+ IdentityId string

+ TokenType string

+ Type string

+ func (c *ServiceAccessClaims) HasAudience(targetAud string) bool

Sep 30, 2023

Changes in this version

+ const EdgeBinding

+ const TunnelBinding