model

Index ¶

• Constants
• func CleanHexString(hexString string) string
• func ContextToProtobuf(context *change.Context) *edge_cmd_pb.ChangeContext
• func DecodeSalt(s string) ([]byte, error)
• func DispatchCreate[T models.Entity](c creator[T], entity T, ctx *change.Context) error
• func DispatchUpdate[T models.Entity](u updater[T], entity T, updatedFields fields.UpdatedFields, ...) error
• func InterfacesToBolt(val []*Interface) []*db.Interface
• func NewFieldChecker(fields ...string) boltz.FieldChecker
• func ProtobufToContext(context *edge_cmd_pb.ChangeContext) *change.Context
• func PublicKeySha256(cert *x509.Certificate) string
• func RegisterCommand[MT any, CT any, M CommandMsg[MT], C decodableCommand[CT, M]](env Env, _ C, _ M)
• func RegisterCreateDecoder[T models.Entity](env Env, creator command.EntityCreator[T])
• func RegisterDeleteDecoder(env Env, deleter command.EntityDeleter)
• func RegisterManagerDecoder[T models.Entity](env Env, ctrl command.EntityManager[T])
• func RegisterUpdateDecoder[T models.Entity](env Env, updater command.EntityUpdater[T])
• type AdvisorEdgeRouter
• type AdvisorIdentityEdgeRouterLinks
• type AdvisorIdentityServiceLinks
• type AdvisorServiceEdgeRouterLinks
• type AdvisorServiceReachability
• type AndFieldChecker
• • func (checker *AndFieldChecker) IsUpdated(field string) bool
• type ApiAddress
• type ApiSession
• type ApiSessionCertificate
• • func NewApiSessionCertificate(cert *x509.Certificate) *ApiSessionCertificate
• type ApiSessionCertificateListResult
• type ApiSessionCertificateManager
• • func NewApiSessionCertificateManager(env Env) *ApiSessionCertificateManager
• • func (self *ApiSessionCertificateManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ApiSessionCertificateManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ApiSessionCertificateManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionCertificateManager) BaseLoad(id string) (ME, error)
  • func (self *ApiSessionCertificateManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ApiSessionCertificateManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionCertificateManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionCertificateManager) Create(entity *ApiSessionCertificate, ctx *change.Context) (string, error)
  • func (self *ApiSessionCertificateManager) CreateFromCSR(identity *Identity, apiSession *ApiSession, isJwt bool, lifespan time.Duration, ...) (*ApiSessionCertificate, error)
  • func (self *ApiSessionCertificateManager) Delete(id string, ctx *change.Context) error
  • func (self *ApiSessionCertificateManager) Dispatch(command command.Command) error
  • func (self *ApiSessionCertificateManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ApiSessionCertificateManager) GetDb() boltz.Db
  • func (self *ApiSessionCertificateManager) GetEntityTypeId() string
  • func (self *ApiSessionCertificateManager) GetEnv() Env
  • func (self *ApiSessionCertificateManager) GetStore() boltz.EntityStore[PE]
  • func (self *ApiSessionCertificateManager) IsEntityPresent(id string) (bool, error)
  • func (self *ApiSessionCertificateManager) IsUpdated(_ string) bool
  • func (self *ApiSessionCertificateManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ApiSessionCertificateManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ApiSessionCertificateManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ApiSessionCertificateManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ApiSessionCertificateManager) Query(tx *bbolt.Tx, query string) (*ApiSessionCertificateListResult, error)
  • func (self *ApiSessionCertificateManager) Read(id string) (ME, error)
  • func (self *ApiSessionCertificateManager) ReadByApiSessionId(tx *bbolt.Tx, apiSessionId string) ([]*ApiSessionCertificate, error)
• type ApiSessionListResult
• type ApiSessionManager
• • func NewApiSessionManager(env Env) *ApiSessionManager
• • func (self *ApiSessionManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ApiSessionManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ApiSessionManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionManager) BaseLoad(id string) (ME, error)
  • func (self *ApiSessionManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ApiSessionManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ApiSessionManager) Create(ctx boltz.MutateContext, entity *ApiSession, ...) (string, error)
  • func (self *ApiSessionManager) CreateInCtx(ctx boltz.MutateContext, entity *ApiSession, ...) (string, error)
  • func (self *ApiSessionManager) Delete(id string, ctx *change.Context) error
  • func (self *ApiSessionManager) DeleteBatch(id []string, ctx *change.Context) error
  • func (self *ApiSessionManager) DeleteByIdentityId(identityId string, changeCtx *change.Context) error
  • func (self *ApiSessionManager) Dispatch(command command.Command) error
  • func (self *ApiSessionManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ApiSessionManager) GetDb() boltz.Db
  • func (self *ApiSessionManager) GetEntityTypeId() string
  • func (self *ApiSessionManager) GetEnv() Env
  • func (self *ApiSessionManager) GetStore() boltz.EntityStore[PE]
  • func (self *ApiSessionManager) IsEntityPresent(id string) (bool, error)
  • func (self *ApiSessionManager) IsUpdated(_ string) bool
  • func (self *ApiSessionManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ApiSessionManager) MarkLastActivityById(apiSessionId string)
  • func (self *ApiSessionManager) MarkLastActivityByTokens(tokens ...string) ([]string, []string, error)
  • func (self *ApiSessionManager) MfaCompleted(apiSession *ApiSession, ctx *change.Context) error
  • func (self *ApiSessionManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ApiSessionManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ApiSessionManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ApiSessionManager) Query(query string) (*ApiSessionListResult, error)
  • func (self *ApiSessionManager) Read(id string) (*ApiSession, error)
  • func (self *ApiSessionManager) ReadByToken(token string) (*ApiSession, error)
  • func (self *ApiSessionManager) ReadInTx(tx *bbolt.Tx, id string) (*ApiSession, error)
  • func (self *ApiSessionManager) SetMfaPassed(apiSession *ApiSession, changeCtx *change.Context) error
  • func (self *ApiSessionManager) Stream(query string, collect func(*ApiSession, error) error) error
  • func (self *ApiSessionManager) StreamIds(query string, collect func(string, error) error) error
  • func (self *ApiSessionManager) Update(apiSession *ApiSession, ctx *change.Context) error
  • func (self *ApiSessionManager) UpdateWithFieldChecker(apiSession *ApiSession, fieldChecker boltz.FieldChecker, ctx *change.Context) error
  • func (self *ApiSessionManager) VisitFingerprintsForApiSession(tx *bbolt.Tx, identityId, apiSessionId string, ...) error
  • func (self *ApiSessionManager) VisitFingerprintsForApiSessionId(apiSessionId string, visitor func(fingerprint string) bool) error
• type ApiSessionPostureData
• • func (self *ApiSessionPostureData) GetPassedMfaAt() *time.Time
• type AssociatedIdsResult
• type AuthBundle
• • func (a *AuthBundle) Apply(event *event.AuthenticationEvent)
• type AuthContext
• • func NewAuthContextHttp(request *http.Request, method string, data interface{}, ctx *change.Context) AuthContext
• type AuthContextHttp
• • func (context *AuthContextHttp) GetCerts() []*x509.Certificate
  • func (context *AuthContextHttp) GetChangeContext() *change.Context
  • func (context *AuthContextHttp) GetData() map[string]interface{}
  • func (context *AuthContextHttp) GetEnvInfo() *EnvInfo
  • func (context *AuthContextHttp) GetHeaders() map[string]interface{}
  • func (context *AuthContextHttp) GetMethod() string
  • func (context *AuthContextHttp) GetPrimaryIdentity() *Identity
  • func (context *AuthContextHttp) GetRemoteAddr() string
  • func (context *AuthContextHttp) GetSdkInfo() *SdkInfo
  • func (context *AuthContextHttp) SetPrimaryIdentity(primaryIdentity *Identity)
  • func (context *AuthContextHttp) SetRemoteAddr(addr string)
• type AuthModuleCert
• • func NewAuthModuleCert(env Env) *AuthModuleCert
• • func (module *AuthModuleCert) CanHandle(method string) bool
  • func (module *AuthModuleCert) Process(context AuthContext) (AuthResult, error)
• type AuthModuleExtJwt
• • func NewAuthModuleExtJwt(env Env) *AuthModuleExtJwt
• • func (a *AuthModuleExtJwt) CanHandle(method string) bool
  • func (a *AuthModuleExtJwt) Process(context AuthContext) (AuthResult, error)
  • func (a *AuthModuleExtJwt) ProcessSecondary(context AuthContext) (AuthResult, error)
• type AuthModuleUpdb
• • func NewAuthModuleUpdb(env Env) *AuthModuleUpdb
• • func (module *AuthModuleUpdb) CanHandle(method string) bool
  • func (module *AuthModuleUpdb) Process(context AuthContext) (AuthResult, error)
• type AuthPolicy
• type AuthPolicyCert
• type AuthPolicyExtJwt
• type AuthPolicyManager
• • func NewAuthPolicyManager(env Env) *AuthPolicyManager
• • func (self *AuthPolicyManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *AuthPolicyManager) ApplyCreate(cmd *command.CreateEntityCommand[*AuthPolicy], ctx boltz.MutateContext) error
  • func (self *AuthPolicyManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *AuthPolicyManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*AuthPolicy], ctx boltz.MutateContext) error
  • func (self *AuthPolicyManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *AuthPolicyManager) BaseLoad(id string) (ME, error)
  • func (self *AuthPolicyManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *AuthPolicyManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *AuthPolicyManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *AuthPolicyManager) Create(entity *AuthPolicy, ctx *change.Context) error
  • func (self *AuthPolicyManager) Delete(id string, ctx *change.Context) error
  • func (self *AuthPolicyManager) Dispatch(command command.Command) error
  • func (self *AuthPolicyManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *AuthPolicyManager) GetDb() boltz.Db
  • func (self *AuthPolicyManager) GetEntityTypeId() string
  • func (self *AuthPolicyManager) GetEnv() Env
  • func (self *AuthPolicyManager) GetStore() boltz.EntityStore[PE]
  • func (self *AuthPolicyManager) IsEntityPresent(id string) (bool, error)
  • func (self *AuthPolicyManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *AuthPolicyManager) Marshall(entity *AuthPolicy) ([]byte, error)
  • func (self *AuthPolicyManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *AuthPolicyManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *AuthPolicyManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *AuthPolicyManager) Read(id string) (*AuthPolicy, error)
  • func (self *AuthPolicyManager) Unmarshall(bytes []byte) (*AuthPolicy, error)
  • func (self *AuthPolicyManager) Update(entity *AuthPolicy, checker fields.UpdatedFields, ctx *change.Context) error
• type AuthPolicyPrimary
• type AuthPolicySecondary
• type AuthPolicyUpdb
• type AuthProcessor
• type AuthProcessorRegistryImpl
• • func (registry *AuthProcessorRegistryImpl) Add(processor AuthProcessor)
  • func (registry *AuthProcessorRegistryImpl) GetByMethod(method string) AuthProcessor
• type AuthRegistry
• type AuthResult
• type AuthResultBase
• • func (a *AuthResultBase) AuthPolicy() *AuthPolicy
  • func (a *AuthResultBase) Authenticator() *Authenticator
  • func (a *AuthResultBase) AuthenticatorId() string
  • func (a *AuthResultBase) Identity() *Identity
  • func (a *AuthResultBase) ImproperClientCertChain() bool
  • func (a *AuthResultBase) IsSuccessful() bool
  • func (a *AuthResultBase) SessionCerts() []*x509.Certificate
• type AuthResultJwt
• • func (a *AuthResultJwt) Authenticator() *Authenticator
  • func (a *AuthResultJwt) AuthenticatorId() string
  • func (a *AuthResultJwt) IsSuccessful() bool
• type Authenticator
• • func (entity *Authenticator) Fingerprints() []string
  • func (entity *Authenticator) ToCert() *AuthenticatorCert
  • func (entity *Authenticator) ToUpdb() *AuthenticatorUpdb
• type AuthenticatorCert
• type AuthenticatorListQueryResult
• type AuthenticatorManager
• • func NewAuthenticatorManager(env Env) *AuthenticatorManager
• • func (self *AuthenticatorManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *AuthenticatorManager) ApplyCreate(cmd *command.CreateEntityCommand[*Authenticator], ctx boltz.MutateContext) error
  • func (self *AuthenticatorManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *AuthenticatorManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Authenticator], ctx boltz.MutateContext) error
  • func (self *AuthenticatorManager) AuthenticatorToProtobuf(entity *Authenticator) (*edge_cmd_pb.Authenticator, error)
  • func (self *AuthenticatorManager) Authorize(authContext AuthContext) (AuthResult, error)
  • func (self *AuthenticatorManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *AuthenticatorManager) BaseLoad(id string) (ME, error)
  • func (self *AuthenticatorManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *AuthenticatorManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *AuthenticatorManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *AuthenticatorManager) Create(entity *Authenticator, ctx *change.Context) error
  • func (self *AuthenticatorManager) DecodeSalt(salt string) []byte
  • func (self *AuthenticatorManager) Delete(id string, ctx *change.Context) error
  • func (self *AuthenticatorManager) Dispatch(command command.Command) error
  • func (self *AuthenticatorManager) ExtendCertForIdentity(identityId string, authenticatorId string, peerCerts []*x509.Certificate, ...) ([]byte, error)
  • func (self *AuthenticatorManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *AuthenticatorManager) GetDb() boltz.Db
  • func (self *AuthenticatorManager) GetEntityTypeId() string
  • func (self *AuthenticatorManager) GetEnv() Env
  • func (self *AuthenticatorManager) GetStore() boltz.EntityStore[PE]
  • func (self *AuthenticatorManager) HashPassword(password string) *HashedPassword
  • func (self *AuthenticatorManager) IsEntityPresent(id string) (bool, error)
  • func (self *AuthenticatorManager) IsUpdated(field string) bool
  • func (self *AuthenticatorManager) ListForIdentity(identityId string, query ast.Query) (*models.EntityListResult[*Authenticator], error)
  • func (self *AuthenticatorManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *AuthenticatorManager) Marshall(entity *Authenticator) ([]byte, error)
  • func (self *AuthenticatorManager) PatchSelf(authenticatorSelf *AuthenticatorSelf, checker fields.UpdatedFields, ...) error
  • func (self *AuthenticatorManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *AuthenticatorManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *AuthenticatorManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *AuthenticatorManager) ProtobufToAuthenticator(msg *edge_cmd_pb.Authenticator) (*Authenticator, error)
  • func (self *AuthenticatorManager) ReEnroll(id string, expiresAt time.Time, ctx *change.Context) (string, error)
  • func (self *AuthenticatorManager) ReHashPassword(password string, salt []byte) *HashedPassword
  • func (self *AuthenticatorManager) Read(id string) (*Authenticator, error)
  • func (self *AuthenticatorManager) ReadByFingerprint(fingerprint string) (*Authenticator, error)
  • func (self *AuthenticatorManager) ReadByUsername(username string) (*Authenticator, error)
  • func (self *AuthenticatorManager) ReadFingerprints(authenticatorId string) ([]string, error)
  • func (self *AuthenticatorManager) ReadForIdentity(identityId string, authenticatorId string) (*Authenticator, error)
  • func (self *AuthenticatorManager) RequestExtend(authenticatorId string, rollKeys bool, ctx *change.Context) error
  • func (self *AuthenticatorManager) Unmarshall(bytes []byte) (*Authenticator, error)
  • func (self *AuthenticatorManager) Update(entity *Authenticator, unrestricted bool, checker fields.UpdatedFields, ...) error
  • func (self *AuthenticatorManager) UpdateSelf(authenticatorSelf *AuthenticatorSelf, ctx *change.Context) error
  • func (self *AuthenticatorManager) VerifyExtendCertForIdentity(isJwtBacked bool, apiSessionId, identityId, authenticatorId string, ...) error
• type AuthenticatorSelf
• type AuthenticatorUpdb
• • func (au *AuthenticatorUpdb) DecodedSalt() []byte
• type BaseAuthenticator
• • func (a *BaseAuthenticator) DispatchEvent(event *event.AuthenticationEvent)
  • func (a *BaseAuthenticator) NewAuthEventFailure(authCtx AuthContext, bundle *AuthBundle, reason string) *event.AuthenticationEvent
  • func (a *BaseAuthenticator) NewAuthEventSuccess(authCtx AuthContext, bundle *AuthBundle) *event.AuthenticationEvent
• type Ca
• • func (entity *Ca) GetExternalId(cert *x509.Certificate) (string, error)
• type CaListResult
• type CaManager
• • func NewCaManager(env Env) *CaManager
• • func (self *CaManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *CaManager) ApplyCreate(cmd *command.CreateEntityCommand[*Ca], ctx boltz.MutateContext) error
  • func (self *CaManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *CaManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Ca], ctx boltz.MutateContext) error
  • func (self *CaManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *CaManager) BaseLoad(id string) (ME, error)
  • func (self *CaManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *CaManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *CaManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *CaManager) Create(entity *Ca, ctx *change.Context) error
  • func (self *CaManager) Delete(id string, ctx *change.Context) error
  • func (self *CaManager) Dispatch(command command.Command) error
  • func (self *CaManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *CaManager) GetDb() boltz.Db
  • func (self *CaManager) GetEntityTypeId() string
  • func (self *CaManager) GetEnv() Env
  • func (self *CaManager) GetStore() boltz.EntityStore[PE]
  • func (self *CaManager) GetTrustCache() *TrustCache
  • func (self *CaManager) IsEntityPresent(id string) (bool, error)
  • func (self *CaManager) IsUpdated(field string) bool
  • func (self *CaManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *CaManager) Marshall(entity *Ca) ([]byte, error)
  • func (self *CaManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *CaManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *CaManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *CaManager) Query(query string) (*CaListResult, error)
  • func (self *CaManager) Read(id string) (*Ca, error)
  • func (self *CaManager) RefreshActiveAuthCaCertCache() error
  • func (self *CaManager) Stream(query string, collect func(*Ca, error) error) error
  • func (self *CaManager) Unmarshall(bytes []byte) (*Ca, error)
  • func (self *CaManager) Update(entity *Ca, checker fields.UpdatedFields, ctx *change.Context) error
  • func (self *CaManager) Verified(ca *Ca, ctx *change.Context) error
• type Circuit
• • func (self *Circuit) GetCreatedAt() time.Time
  • func (self *Circuit) GetId() string
  • func (self *Circuit) GetTags() map[string]interface{}
  • func (self *Circuit) GetUpdatedAt() time.Time
  • func (self *Circuit) HasRouter(routerId string) bool
  • func (self *Circuit) IsEndpointRouter(routerId string) bool
  • func (self *Circuit) IsSystemEntity() bool
  • func (self *Circuit) SetId(string)
• type CircuitManager
• • func NewCircuitManager() *CircuitManager
• • func (self *CircuitManager) Add(circuit *Circuit)
  • func (self *CircuitManager) All() []*Circuit
  • func (self *CircuitManager) Get(id string) (*Circuit, bool)
  • func (self *CircuitManager) GetStore() *objectz.ObjectStore[*Circuit]
  • func (self *CircuitManager) Remove(circuit *Circuit)
• type CommandManager
• type CommandMsg
• type Config
• type ConfigManager
• • func NewConfigManager(env Env) *ConfigManager
• • func (self *ConfigManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ConfigManager) ApplyCreate(cmd *command.CreateEntityCommand[*Config], ctx boltz.MutateContext) error
  • func (self *ConfigManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ConfigManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Config], ctx boltz.MutateContext) error
  • func (self *ConfigManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ConfigManager) BaseLoad(id string) (ME, error)
  • func (self *ConfigManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ConfigManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ConfigManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ConfigManager) Create(entity *Config, ctx *change.Context) error
  • func (self *ConfigManager) Delete(id string, ctx *change.Context) error
  • func (self *ConfigManager) Dispatch(command command.Command) error
  • func (self *ConfigManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ConfigManager) GetDb() boltz.Db
  • func (self *ConfigManager) GetEntityTypeId() string
  • func (self *ConfigManager) GetEnv() Env
  • func (self *ConfigManager) GetStore() boltz.EntityStore[PE]
  • func (self *ConfigManager) IsEntityPresent(id string) (bool, error)
  • func (self *ConfigManager) IsUpdated(field string) bool
  • func (self *ConfigManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ConfigManager) Marshall(entity *Config) ([]byte, error)
  • func (self *ConfigManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ConfigManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ConfigManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ConfigManager) Read(id string) (*Config, error)
  • func (self *ConfigManager) Unmarshall(bytes []byte) (*Config, error)
  • func (self *ConfigManager) Update(entity *Config, checker fields.UpdatedFields, ctx *change.Context) error
• type ConfigType
• • func (entity *ConfigType) GetCompiledSchema() (*gojsonschema.Schema, error)
• type ConfigTypeManager
• • func NewConfigTypeManager(env Env) *ConfigTypeManager
• • func (self *ConfigTypeManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ConfigTypeManager) ApplyCreate(cmd *command.CreateEntityCommand[*ConfigType], ctx boltz.MutateContext) error
  • func (self *ConfigTypeManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ConfigTypeManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*ConfigType], ctx boltz.MutateContext) error
  • func (self *ConfigTypeManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ConfigTypeManager) BaseLoad(id string) (ME, error)
  • func (self *ConfigTypeManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ConfigTypeManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ConfigTypeManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ConfigTypeManager) Create(entity *ConfigType, ctx *change.Context) error
  • func (self *ConfigTypeManager) Delete(id string, ctx *change.Context) error
  • func (self *ConfigTypeManager) Dispatch(command command.Command) error
  • func (self *ConfigTypeManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ConfigTypeManager) GetDb() boltz.Db
  • func (self *ConfigTypeManager) GetEntityTypeId() string
  • func (self *ConfigTypeManager) GetEnv() Env
  • func (self *ConfigTypeManager) GetStore() boltz.EntityStore[PE]
  • func (self *ConfigTypeManager) IsEntityPresent(id string) (bool, error)
  • func (self *ConfigTypeManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ConfigTypeManager) MapConfigTypeNamesToIds(values []string, identityId string) map[string]struct{}
  • func (self *ConfigTypeManager) Marshall(entity *ConfigType) ([]byte, error)
  • func (self *ConfigTypeManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ConfigTypeManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ConfigTypeManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ConfigTypeManager) Read(id string) (*ConfigType, error)
  • func (self *ConfigTypeManager) ReadByName(name string) (*ConfigType, error)
  • func (self *ConfigTypeManager) Unmarshall(bytes []byte) (*ConfigType, error)
  • func (self *ConfigTypeManager) Update(entity *ConfigType, checker fields.UpdatedFields, ctx *change.Context) error
• type ConnectionTracker
• • func (self *ConnectionTracker) GetIdentityOnlineState(identityId string) IdentityOnlineState
  • func (self *ConnectionTracker) Inspect() *inspect.CtrlIdentityConnections
  • func (self *ConnectionTracker) MarkConnected(identityId string, ch channel.Channel)
  • func (self *ConnectionTracker) MarkDisconnected(identityId string, ch channel.Channel)
  • func (self *ConnectionTracker) ScanForDisconnectedRouters()
  • func (self *ConnectionTracker) SendSdkOnlineStatusChangeEvent(identityId string, state IdentityOnlineState)
  • func (self *ConnectionTracker) SyncAllFromRouter(state *edge_ctrl_pb.ConnectEvents, ch channel.Channel)
• type Controller
• • func (entity *Controller) IsChanged(other *Controller) bool
• type ControllerManager
• • func NewControllerManager(env Env) *ControllerManager
• • func (self *ControllerManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ControllerManager) ApplyCreate(cmd *command.CreateEntityCommand[*Controller], ctx boltz.MutateContext) error
  • func (self *ControllerManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ControllerManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Controller], ctx boltz.MutateContext) error
  • func (self *ControllerManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ControllerManager) BaseLoad(id string) (ME, error)
  • func (self *ControllerManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ControllerManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ControllerManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ControllerManager) Create(entity *Controller, ctx *change.Context) error
  • func (self *ControllerManager) Delete(id string, ctx *change.Context) error
  • func (self *ControllerManager) DeleteRemovedPeers(peers []*event.ClusterPeer)
  • func (self *ControllerManager) Dispatch(command command.Command) error
  • func (self *ControllerManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ControllerManager) GetDb() boltz.Db
  • func (self *ControllerManager) GetEntityTypeId() string
  • func (self *ControllerManager) GetEnv() Env
  • func (self *ControllerManager) GetStore() boltz.EntityStore[PE]
  • func (self *ControllerManager) IsEntityPresent(id string) (bool, error)
  • func (self *ControllerManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ControllerManager) Marshall(entity *Controller) ([]byte, error)
  • func (self *ControllerManager) PeersDisconnected(peers []*event.ClusterPeer)
  • func (self *ControllerManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ControllerManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ControllerManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ControllerManager) Read(id string) (*Controller, error)
  • func (self *ControllerManager) ReadByName(name string) (*Controller, error)
  • func (self *ControllerManager) Unmarshall(bytes []byte) (*Controller, error)
  • func (self *ControllerManager) Update(entity *Controller, checker fields.UpdatedFields, ctx *change.Context) error
  • func (self *ControllerManager) UpdateControllerState(peers []*event.ClusterPeer, peerConnectedEvent bool)
  • func (self *ControllerManager) UpdateSelfOnNewLeader()
• type CreateCircuitParams
• type CreateEdgeRouterCmd
• • func (self *CreateEdgeRouterCmd) Apply(ctx boltz.MutateContext) error
  • func (self *CreateEdgeRouterCmd) Decode(env Env, msg *edge_cmd_pb.CreateEdgeRouterCmd) error
  • func (self *CreateEdgeRouterCmd) Encode() ([]byte, error)
  • func (self *CreateEdgeRouterCmd) GetChangeContext() *change.Context
• type CreateEdgeTerminatorCmd
• • func (self *CreateEdgeTerminatorCmd) Apply(ctx boltz.MutateContext) error
  • func (self *CreateEdgeTerminatorCmd) Decode(env Env, msg *edge_cmd_pb.CreateEdgeTerminatorCommand) error
  • func (self *CreateEdgeTerminatorCmd) Encode() ([]byte, error)
  • func (self *CreateEdgeTerminatorCmd) GetChangeContext() *change.Context
• type CreateIdentityWithAuthenticatorsCmd
• • func (self *CreateIdentityWithAuthenticatorsCmd) Apply(ctx boltz.MutateContext) error
  • func (self *CreateIdentityWithAuthenticatorsCmd) Decode(env Env, msg *edge_cmd_pb.CreateIdentityWithAuthenticatorsCmd) error
  • func (self *CreateIdentityWithAuthenticatorsCmd) Encode() ([]byte, error)
  • func (self *CreateIdentityWithAuthenticatorsCmd) GetChangeContext() *change.Context
• type CreateIdentityWithEnrollmentsCmd
• • func (self *CreateIdentityWithEnrollmentsCmd) Apply(ctx boltz.MutateContext) error
  • func (self *CreateIdentityWithEnrollmentsCmd) Decode(env Env, msg *edge_cmd_pb.CreateIdentityWithEnrollmentsCmd) error
  • func (self *CreateIdentityWithEnrollmentsCmd) Encode() ([]byte, error)
  • func (self *CreateIdentityWithEnrollmentsCmd) GetChangeContext() *change.Context
• type CreateTransitRouterCmd
• • func (self *CreateTransitRouterCmd) Apply(ctx boltz.MutateContext) error
  • func (self *CreateTransitRouterCmd) Decode(env Env, msg *edge_cmd_pb.CreateTransitRouterCmd) error
  • func (self *CreateTransitRouterCmd) Encode() ([]byte, error)
  • func (self *CreateTransitRouterCmd) GetChangeContext() *change.Context
• type DeleteTerminatorsBatchCommand
• • func (self *DeleteTerminatorsBatchCommand) Apply(ctx boltz.MutateContext) error
  • func (self *DeleteTerminatorsBatchCommand) Decode(env Env, msg *cmd_pb.DeleteTerminatorsBatchCommand) error
  • func (self *DeleteTerminatorsBatchCommand) Encode() ([]byte, error)
  • func (self *DeleteTerminatorsBatchCommand) GetChangeContext() *change.Context
• type EdgeRouter
• • func (self *EdgeRouter) GetName() string
• type EdgeRouterListResult
• type EdgeRouterManager
• • func NewEdgeRouterManager(env Env) *EdgeRouterManager
• • func (self *EdgeRouterManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *EdgeRouterManager) ApplyCreate(cmd *CreateEdgeRouterCmd, ctx boltz.MutateContext) error
  • func (self *EdgeRouterManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *EdgeRouterManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*EdgeRouter], ctx boltz.MutateContext) error
  • func (self *EdgeRouterManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterManager) BaseLoad(id string) (ME, error)
  • func (self *EdgeRouterManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *EdgeRouterManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterManager) CollectEnrollments(id string, collector func(entity *Enrollment) error) error
  • func (self *EdgeRouterManager) Create(edgeRouter *EdgeRouter, ctx *change.Context) error
  • func (self *EdgeRouterManager) Delete(id string, ctx *change.Context) error
  • func (self *EdgeRouterManager) Dispatch(command command.Command) error
  • func (self *EdgeRouterManager) EdgeRouterToProtobuf(entity *EdgeRouter) (*edge_cmd_pb.EdgeRouter, error)
  • func (self *EdgeRouterManager) ExtendEnrollment(router *EdgeRouter, clientCsrPem []byte, serverCertCsrPem []byte, ...) (*ExtendedCerts, error)
  • func (self *EdgeRouterManager) ExtendEnrollmentVerify(router *EdgeRouter, ctx *change.Context) error
  • func (self *EdgeRouterManager) ExtendEnrollmentWithVerify(router *EdgeRouter, clientCsrPem []byte, serverCertCsrPem []byte, ...) (*ExtendedCerts, error)
  • func (self *EdgeRouterManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *EdgeRouterManager) GetDb() boltz.Db
  • func (self *EdgeRouterManager) GetEntityTypeId() string
  • func (self *EdgeRouterManager) GetEnv() Env
  • func (self *EdgeRouterManager) GetStore() boltz.EntityStore[PE]
  • func (self *EdgeRouterManager) IsAccessToEdgeRouterAllowed(identityId, serviceId, edgeRouterId string) (bool, error)
  • func (self *EdgeRouterManager) IsEntityPresent(id string) (bool, error)
  • func (self *EdgeRouterManager) IsSharedEdgeRouterPresent(identityId, serviceId string) (bool, error)
  • func (self *EdgeRouterManager) ListForIdentityAndService(identityId, serviceId string) (*EdgeRouterListResult, error)
  • func (self *EdgeRouterManager) ListForIdentityAndServiceWithTx(tx *bbolt.Tx, identityId, serviceId string) (*EdgeRouterListResult, error)
  • func (self *EdgeRouterManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *EdgeRouterManager) Marshall(entity *EdgeRouter) ([]byte, error)
  • func (self *EdgeRouterManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *EdgeRouterManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *EdgeRouterManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *EdgeRouterManager) ProtobufToEdgeRouter(msg *edge_cmd_pb.EdgeRouter) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) Query(query string) (*EdgeRouterListResult, error)
  • func (self *EdgeRouterManager) QueryRoleAttributes(queryString string) ([]string, *models.QueryMetaData, error)
  • func (self *EdgeRouterManager) ReEnroll(router *EdgeRouter, ctx *change.Context) error
  • func (self *EdgeRouterManager) Read(id string) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) ReadOneByFingerprint(fingerprint string) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) ReadOneByQuery(query string) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) ReadOneByUnverifiedFingerprint(fingerprint string) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) Unmarshall(bytes []byte) (*EdgeRouter, error)
  • func (self *EdgeRouterManager) Update(entity *EdgeRouter, unrestricted bool, checker fields.UpdatedFields, ...) error
• type EdgeRouterPolicy
• type EdgeRouterPolicyManager
• • func NewEdgeRouterPolicyManager(env Env) *EdgeRouterPolicyManager
• • func (self *EdgeRouterPolicyManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *EdgeRouterPolicyManager) ApplyCreate(cmd *command.CreateEntityCommand[*EdgeRouterPolicy], ctx boltz.MutateContext) error
  • func (self *EdgeRouterPolicyManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *EdgeRouterPolicyManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*EdgeRouterPolicy], ctx boltz.MutateContext) error
  • func (self *EdgeRouterPolicyManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterPolicyManager) BaseLoad(id string) (ME, error)
  • func (self *EdgeRouterPolicyManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *EdgeRouterPolicyManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterPolicyManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeRouterPolicyManager) Create(entity *EdgeRouterPolicy, ctx *change.Context) error
  • func (self *EdgeRouterPolicyManager) Delete(id string, ctx *change.Context) error
  • func (self *EdgeRouterPolicyManager) Dispatch(command command.Command) error
  • func (self *EdgeRouterPolicyManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *EdgeRouterPolicyManager) GetDb() boltz.Db
  • func (self *EdgeRouterPolicyManager) GetEntityTypeId() string
  • func (self *EdgeRouterPolicyManager) GetEnv() Env
  • func (self *EdgeRouterPolicyManager) GetStore() boltz.EntityStore[PE]
  • func (self *EdgeRouterPolicyManager) IsEntityPresent(id string) (bool, error)
  • func (self *EdgeRouterPolicyManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *EdgeRouterPolicyManager) Marshall(entity *EdgeRouterPolicy) ([]byte, error)
  • func (self *EdgeRouterPolicyManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *EdgeRouterPolicyManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *EdgeRouterPolicyManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *EdgeRouterPolicyManager) Read(id string) (ME, error)
  • func (self *EdgeRouterPolicyManager) Unmarshall(bytes []byte) (*EdgeRouterPolicy, error)
  • func (self *EdgeRouterPolicyManager) Update(entity *EdgeRouterPolicy, checker fields.UpdatedFields, ctx *change.Context) error
• type EdgeService
• type EdgeServiceManager
• • func NewEdgeServiceManager(env Env) *EdgeServiceManager
• • func (self *EdgeServiceManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *EdgeServiceManager) ApplyCreate(cmd *command.CreateEntityCommand[*EdgeService], ctx boltz.MutateContext) error
  • func (self *EdgeServiceManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *EdgeServiceManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*EdgeService], ctx boltz.MutateContext) error
  • func (self *EdgeServiceManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *EdgeServiceManager) BaseLoad(id string) (ME, error)
  • func (self *EdgeServiceManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *EdgeServiceManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeServiceManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EdgeServiceManager) Create(entity *EdgeService, ctx *change.Context) error
  • func (self *EdgeServiceManager) Delete(id string, ctx *change.Context) error
  • func (self *EdgeServiceManager) Dispatch(command command.Command) error
  • func (self *EdgeServiceManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *EdgeServiceManager) GetDb() boltz.Db
  • func (self *EdgeServiceManager) GetDetailLister() *ServiceDetailLister
  • func (self *EdgeServiceManager) GetEntityTypeId() string
  • func (self *EdgeServiceManager) GetEnv() Env
  • func (self *EdgeServiceManager) GetPolicyPostureChecks(identityId, serviceId string) map[string]*PolicyPostureChecks
  • func (self *EdgeServiceManager) GetStore() boltz.EntityStore[PE]
  • func (self *EdgeServiceManager) IsBindableByIdentity(id string, identityId string) (bool, error)
  • func (self *EdgeServiceManager) IsDialableByIdentity(id string, identityId string) (bool, error)
  • func (self *EdgeServiceManager) IsEntityPresent(id string) (bool, error)
  • func (self *EdgeServiceManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *EdgeServiceManager) Marshall(entity *EdgeService) ([]byte, error)
  • func (self *EdgeServiceManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *EdgeServiceManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *EdgeServiceManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *EdgeServiceManager) PublicQueryForIdentity(sessionIdentity *Identity, configTypes map[string]struct{}, query ast.Query) (*ServiceListResult, error)
  • func (self *EdgeServiceManager) QueryForIdentity(identityId string, configTypes map[string]struct{}, query ast.Query) (*ServiceListResult, error)
  • func (self *EdgeServiceManager) QueryRoleAttributes(queryString string) ([]string, *models.QueryMetaData, error)
  • func (self *EdgeServiceManager) Read(id string) (ME, error)
  • func (self *EdgeServiceManager) ReadByName(name string) (*EdgeService, error)
  • func (self *EdgeServiceManager) ReadForIdentity(id string, identityId string, configTypes map[string]struct{}) (*ServiceDetail, error)
  • func (self *EdgeServiceManager) ReadForIdentityInTx(tx *bbolt.Tx, id string, identityId string, configTypes map[string]struct{}) (*ServiceDetail, error)
  • func (self *EdgeServiceManager) Unmarshall(bytes []byte) (*EdgeService, error)
  • func (self *EdgeServiceManager) Update(entity *EdgeService, checker fields.UpdatedFields, ctx *change.Context) error
• type EnrollModuleCa
• • func NewEnrollModuleCa(env Env) *EnrollModuleCa
• • func (module *EnrollModuleCa) CanHandle(method string) bool
  • func (module *EnrollModuleCa) Process(context EnrollmentContext) (*EnrollmentResult, error)
• type EnrollModuleEr
• • func NewEnrollModuleEdgeRouterOtt(env Env) *EnrollModuleEr
• • func (module *EnrollModuleEr) CanHandle(method string) bool
  • func (module *EnrollModuleEr) Process(context EnrollmentContext) (*EnrollmentResult, error)
  • func (module *EnrollModuleEr) ProcessClientCsrPem(clientCertCsrPem []byte, edgeRouterId string) ([]byte, error)
  • func (module *EnrollModuleEr) ProcessServerCsrPem(serverCertCsrPem []byte) ([]byte, error)
• type EnrollModuleOtt
• • func NewEnrollModuleOtt(env Env) *EnrollModuleOtt
• • func (module *EnrollModuleOtt) CanHandle(method string) bool
  • func (module *EnrollModuleOtt) Process(ctx EnrollmentContext) (*EnrollmentResult, error)
• type EnrollModuleOttCa
• • func NewEnrollModuleOttCa(env Env) *EnrollModuleOttCa
• • func (module *EnrollModuleOttCa) CanHandle(method string) bool
  • func (module *EnrollModuleOttCa) Process(ctx EnrollmentContext) (*EnrollmentResult, error)
• type EnrollModuleRouterOtt
• • func NewEnrollModuleTransitRouterOtt(env Env) *EnrollModuleRouterOtt
• • func (module *EnrollModuleRouterOtt) CanHandle(method string) bool
  • func (module *EnrollModuleRouterOtt) Process(context EnrollmentContext) (*EnrollmentResult, error)
• type EnrollModuleUpdb
• • func NewEnrollModuleUpdb(env Env) *EnrollModuleUpdb
• • func (module *EnrollModuleUpdb) CanHandle(method string) bool
  • func (module *EnrollModuleUpdb) Process(ctx EnrollmentContext) (*EnrollmentResult, error)
• type Enrollment
• • func (entity *Enrollment) FillJwtInfoForIdentity(env Env, subject string) error
  • func (entity *Enrollment) FillJwtInfoForRouter(env Env, subject string) error
  • func (entity *Enrollment) FillJwtInfoWithExpiresAt(env Env, subject string, expiresAt time.Time) error
• type EnrollmentContext
• type EnrollmentContextHttp
• • func (context *EnrollmentContextHttp) FillFromHttpRequest(request *http.Request, changeCtx *change.Context) error
  • func (context *EnrollmentContextHttp) GetCerts() []*x509.Certificate
  • func (context *EnrollmentContextHttp) GetChangeContext() *change.Context
  • func (context *EnrollmentContextHttp) GetData() *EnrollmentData
  • func (context *EnrollmentContextHttp) GetHeaders() map[string]interface{}
  • func (context *EnrollmentContextHttp) GetMethod() string
  • func (context *EnrollmentContextHttp) GetParameters() map[string]interface{}
  • func (context *EnrollmentContextHttp) GetToken() string
• type EnrollmentData
• type EnrollmentManager
• • func NewEnrollmentManager(env Env) *EnrollmentManager
• • func (self *EnrollmentManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *EnrollmentManager) ApplyCreate(cmd *command.CreateEntityCommand[*Enrollment], ctx boltz.MutateContext) error
  • func (self *EnrollmentManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *EnrollmentManager) ApplyReEnrollEdgeRouter(cmd *ReEnrollEdgeRouterCmd, ctx boltz.MutateContext) error
  • func (self *EnrollmentManager) ApplyReplaceEncoderWithAuthenticatorCommand(cmd *ReplaceEnrollmentWithAuthenticatorCmd, ctx boltz.MutateContext) error
  • func (self *EnrollmentManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Enrollment], ctx boltz.MutateContext) error
  • func (self *EnrollmentManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *EnrollmentManager) BaseLoad(id string) (ME, error)
  • func (self *EnrollmentManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *EnrollmentManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EnrollmentManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *EnrollmentManager) Create(entity *Enrollment, ctx *change.Context) error
  • func (self *EnrollmentManager) Delete(id string, ctx *change.Context) error
  • func (self *EnrollmentManager) Dispatch(command command.Command) error
  • func (self *EnrollmentManager) Enroll(ctx EnrollmentContext) (*EnrollmentResult, error)
  • func (self *EnrollmentManager) EnrollmentToProtobuf(entity *Enrollment) (*edge_cmd_pb.Enrollment, error)
  • func (self *EnrollmentManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *EnrollmentManager) GetCertChainPem(certRaw []byte) (string, error)
  • func (self *EnrollmentManager) GetDb() boltz.Db
  • func (self *EnrollmentManager) GetEntityTypeId() string
  • func (self *EnrollmentManager) GetEnv() Env
  • func (self *EnrollmentManager) GetStore() boltz.EntityStore[PE]
  • func (self *EnrollmentManager) IsEntityPresent(id string) (bool, error)
  • func (self *EnrollmentManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *EnrollmentManager) Marshall(entity *Enrollment) ([]byte, error)
  • func (self *EnrollmentManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *EnrollmentManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *EnrollmentManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *EnrollmentManager) ProtobufToEnrollment(msg *edge_cmd_pb.Enrollment) (*Enrollment, error)
  • func (self *EnrollmentManager) Query(query string) ([]*Enrollment, error)
  • func (self *EnrollmentManager) Read(id string) (*Enrollment, error)
  • func (self *EnrollmentManager) ReadByToken(token string) (*Enrollment, error)
  • func (self *EnrollmentManager) RefreshJwt(id string, expiresAt time.Time, ctx *change.Context) error
  • func (self *EnrollmentManager) ReplaceWithAuthenticator(enrollmentId string, authenticator *Authenticator, ctx *change.Context) error
  • func (self *EnrollmentManager) Unmarshall(bytes []byte) (*Enrollment, error)
  • func (self *EnrollmentManager) Update(entity *Enrollment, checker fields.UpdatedFields, ctx *change.Context) error
• type EnrollmentProcessor
• type EnrollmentRegistry
• type EnrollmentRegistryImpl
• • func (registry *EnrollmentRegistryImpl) Add(processor EnrollmentProcessor)
  • func (registry *EnrollmentRegistryImpl) GetByMethod(method string) EnrollmentProcessor
• type EnrollmentResult
• type EntityManager
• type Env
• type EnvInfo
• • func (self *EnvInfo) Equals(other *EnvInfo) bool
• type ExtendedCerts
• type ExternalIdClaim
• type ExternalIdFieldType
• type ExternalJwtSigner
• type ExternalJwtSignerManager
• • func NewExternalJwtSignerManager(env Env) *ExternalJwtSignerManager
• • func (self *ExternalJwtSignerManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ExternalJwtSignerManager) ApplyCreate(cmd *command.CreateEntityCommand[*ExternalJwtSigner], ctx boltz.MutateContext) error
  • func (self *ExternalJwtSignerManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ExternalJwtSignerManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*ExternalJwtSigner], ctx boltz.MutateContext) error
  • func (self *ExternalJwtSignerManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ExternalJwtSignerManager) BaseLoad(id string) (ME, error)
  • func (self *ExternalJwtSignerManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ExternalJwtSignerManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ExternalJwtSignerManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ExternalJwtSignerManager) Create(entity *ExternalJwtSigner, ctx *change.Context) error
  • func (self *ExternalJwtSignerManager) Delete(id string, ctx *change.Context) error
  • func (self *ExternalJwtSignerManager) Dispatch(command command.Command) error
  • func (self *ExternalJwtSignerManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ExternalJwtSignerManager) GetDb() boltz.Db
  • func (self *ExternalJwtSignerManager) GetEntityTypeId() string
  • func (self *ExternalJwtSignerManager) GetEnv() Env
  • func (self *ExternalJwtSignerManager) GetStore() boltz.EntityStore[PE]
  • func (self *ExternalJwtSignerManager) IsEntityPresent(id string) (bool, error)
  • func (self *ExternalJwtSignerManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ExternalJwtSignerManager) Marshall(entity *ExternalJwtSigner) ([]byte, error)
  • func (self *ExternalJwtSignerManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ExternalJwtSignerManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ExternalJwtSignerManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ExternalJwtSignerManager) PublicQuery(query ast.Query) (*ListExtJwtSignerResult, error)
  • func (self *ExternalJwtSignerManager) Read(id string) (ME, error)
  • func (self *ExternalJwtSignerManager) Unmarshall(bytes []byte) (*ExternalJwtSigner, error)
  • func (self *ExternalJwtSignerManager) Update(entity *ExternalJwtSigner, checker fields.UpdatedFields, ctx *change.Context) error
• type Formatter
• • func NewFormatter(symbols map[string]string) *Formatter
  • func NewIdentityNameFormatter(ca *Ca, clientCert *x509.Certificate, identityName, identityId string) *Formatter
• • func (formatter *Formatter) Format(name string) string
• type HashResult
• • func Hash(password string) *HashResult
  • func ReHash(password string, s []byte) *HashResult
• type HashedPassword
• type Heartbeat
• type HeartbeatCollector
• • func NewHeartbeatCollector(env Env, batchSize int, updateInterval time.Duration, ...) *HeartbeatCollector
• • func (self *HeartbeatCollector) LastAccessedAt(apiSessionId string) (*time.Time, bool)
  • func (self *HeartbeatCollector) Mark(apiSessionId string)
  • func (self *HeartbeatCollector) Remove(id string)
  • func (self *HeartbeatCollector) Start()
• type HeartbeatStatus
• type Identity
• type IdentityManager
• • func NewIdentityManager(env Env) *IdentityManager
• • func (self *IdentityManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *IdentityManager) ApplyCreate(cmd *command.CreateEntityCommand[*Identity], ctx boltz.MutateContext) error
  • func (self *IdentityManager) ApplyCreateWithAuthenticators(cmd *CreateIdentityWithAuthenticatorsCmd, ctx boltz.MutateContext) error
  • func (self *IdentityManager) ApplyCreateWithEnrollments(cmd *CreateIdentityWithEnrollmentsCmd, ctx boltz.MutateContext) error
  • func (self *IdentityManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *IdentityManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Identity], ctx boltz.MutateContext) error
  • func (self *IdentityManager) ApplyUpdateServiceConfigs(cmd *UpdateServiceConfigsCmd, ctx boltz.MutateContext) error
  • func (self *IdentityManager) AssignServiceConfigs(id string, serviceConfigs []ServiceConfig, ctx *change.Context) error
  • func (self *IdentityManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *IdentityManager) BaseLoad(id string) (ME, error)
  • func (self *IdentityManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *IdentityManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *IdentityManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *IdentityManager) CollectAuthenticators(id string, collector func(entity *Authenticator) error) error
  • func (self *IdentityManager) CollectEnrollments(id string, collector func(entity *Enrollment) error) error
  • func (self *IdentityManager) Create(entity *Identity, ctx *change.Context) error
  • func (self *IdentityManager) CreateWithAuthenticators(identity *Identity, authenticators []*Authenticator, ctx *change.Context) (string, []string, error)
  • func (self *IdentityManager) CreateWithEnrollments(identityModel *Identity, enrollmentsModels []*Enrollment, ctx *change.Context) error
  • func (self *IdentityManager) Delete(id string, ctx *change.Context) error
  • func (self *IdentityManager) Disable(identityId string, duration time.Duration, ctx *change.Context) error
  • func (self *IdentityManager) Dispatch(command command.Command) error
  • func (self *IdentityManager) Enable(identityId string, ctx *change.Context) error
  • func (self *IdentityManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *IdentityManager) GetConnectionTracker() *ConnectionTracker
  • func (self *IdentityManager) GetDb() boltz.Db
  • func (self *IdentityManager) GetEntityTypeId() string
  • func (self *IdentityManager) GetEnv() Env
  • func (self *IdentityManager) GetIdentityStatusMapCopy() map[string]map[string]channel.Channel
  • func (self *IdentityManager) GetStore() boltz.EntityStore[PE]
  • func (self *IdentityManager) HasErConnection(id string) bool
  • func (self *IdentityManager) IdentityToProtobuf(entity *Identity) (*edge_cmd_pb.Identity, error)
  • func (self *IdentityManager) InitializeDefaultAdmin(username, password, name string) error
  • func (self *IdentityManager) IsEntityPresent(id string) (bool, error)
  • func (self *IdentityManager) IsUpdated(field string) bool
  • func (self *IdentityManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *IdentityManager) Marshall(entity *Identity) ([]byte, error)
  • func (self *IdentityManager) PatchInfo(identity *Identity, checker boltz.FieldChecker, changeCtx *change.Context) error
  • func (self *IdentityManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *IdentityManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *IdentityManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *IdentityManager) ProtobufToIdentity(msg *edge_cmd_pb.Identity) (*Identity, error)
  • func (self *IdentityManager) QueryRoleAttributes(queryString string) ([]string, *models.QueryMetaData, error)
  • func (self *IdentityManager) Read(id string) (ME, error)
  • func (self *IdentityManager) ReadByExternalId(externalId string) (*Identity, error)
  • func (self *IdentityManager) ReadByName(name string) (*Identity, error)
  • func (self *IdentityManager) ReadDefaultAdmin() (*Identity, error)
  • func (self *IdentityManager) ReadOneByQuery(query string) (*Identity, error)
  • func (self *IdentityManager) RemoveServiceConfigs(id string, serviceConfigs []ServiceConfig, ctx *change.Context) error
  • func (self *IdentityManager) SetHasErConnection(identityId string)
  • func (self *IdentityManager) Unmarshall(bytes []byte) (*Identity, error)
  • func (self *IdentityManager) Update(entity *Identity, checker fields.UpdatedFields, ctx *change.Context) error
  • func (self *IdentityManager) UpdateSdkEnvInfo(identity *Identity, envInfo *EnvInfo, sdkInfo *SdkInfo, ...) error
  • func (self *IdentityManager) VisitIdentityAuthenticatorFingerprints(tx *bbolt.Tx, identityId string, visitor func(string) bool) (bool, error)
• type IdentityOnlineState
• • func (self IdentityOnlineState) String() string
• type IdentityType
• type IdentityTypeManager
• • func NewIdentityTypeManager(env Env) *IdentityTypeManager
• • func (self *IdentityTypeManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *IdentityTypeManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *IdentityTypeManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *IdentityTypeManager) BaseLoad(id string) (ME, error)
  • func (self *IdentityTypeManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *IdentityTypeManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *IdentityTypeManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *IdentityTypeManager) Delete(id string, ctx *change.Context) error
  • func (self *IdentityTypeManager) Dispatch(command command.Command) error
  • func (self *IdentityTypeManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *IdentityTypeManager) GetDb() boltz.Db
  • func (self *IdentityTypeManager) GetEntityTypeId() string
  • func (self *IdentityTypeManager) GetEnv() Env
  • func (self *IdentityTypeManager) GetStore() boltz.EntityStore[PE]
  • func (self *IdentityTypeManager) IsEntityPresent(id string) (bool, error)
  • func (self *IdentityTypeManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *IdentityTypeManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *IdentityTypeManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *IdentityTypeManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *IdentityTypeManager) Read(id string) (ME, error)
  • func (self *IdentityTypeManager) ReadByIdOrName(idOrName string) (*IdentityType, error)
  • func (self *IdentityTypeManager) ReadByName(name string) (*IdentityType, error)
• type Interface
• • func InterfaceFromBolt(entity *db.Interface) *Interface
  • func InterfacesFromBolt(m []*db.Interface) []*Interface
• • func (self *Interface) IsBroadcast() bool
  • func (self *Interface) IsFlagSet(f net.Flags) bool
  • func (self *Interface) IsLoopback() bool
  • func (self *Interface) IsMulticast() bool
  • func (self *Interface) IsRunning() bool
  • func (self *Interface) IsUp() bool
  • func (entity *Interface) ToBolt() *db.Interface
• type Link
• • func NewTestLink(id string, src, dst *Router) *Link
• • func (link *Link) CurrentState() LinkState
  • func (link *Link) GetConnsState() *ctrl_pb.LinkConnState
  • func (link *Link) GetCost() int64
  • func (link *Link) GetDest() *Router
  • func (link *Link) GetDstLatency() int64
  • func (link *Link) GetId() string
  • func (link *Link) GetSrcLatency() int64
  • func (link *Link) GetStaticCost() int32
  • func (link *Link) IsDown() bool
  • func (link *Link) IsUsable() bool
  • func (link *Link) RecalculateCost()
  • func (link *Link) SetConnsState(state *ctrl_pb.LinkConnState)
  • func (link *Link) SetDown(down bool)
  • func (link *Link) SetDstLatency(latency int64)
  • func (link *Link) SetSrcLatency(latency int64)
  • func (link *Link) SetState(m LinkMode)
  • func (link *Link) SetStaticCost(cost int32)
• type LinkManager
• • func NewLinkManager(env Env) *LinkManager
• • func (self *LinkManager) Add(link *Link)
  • func (self *LinkManager) All() []*Link
  • func (self *LinkManager) BuildRouterLinks(router *Router)
  • func (self *LinkManager) ClearExpiredPending(pendingTimeout time.Duration)
  • func (self *LinkManager) ConnectedNeighborsOfRouter(router *Router) []*Router
  • func (self *LinkManager) Get(linkId string) (*Link, bool)
  • func (self *LinkManager) GetLinkMap() map[string]*Link
  • func (self *LinkManager) GetStore() *objectz.ObjectStore[*Link]
  • func (self *LinkManager) LeastExpensiveLink(a, b *Router) (*Link, bool)
  • func (self *LinkManager) LinksInMode(mode LinkMode) []*Link
  • func (self *LinkManager) MissingLinks(routers []*Router, pendingTimeout time.Duration) ([]*Link, error)
  • func (self *LinkManager) Remove(link *Link)
  • func (self *LinkManager) RouterReportedLink(reportedLink *ctrl_pb.RouterLinks_RouterLink, src, dst *Router) (*Link, bool)
  • func (self *LinkManager) ScanForDeadLinks()
• type LinkMode
• • func (t LinkMode) String() string
• type LinkState
• type ListExtJwtSignerResult
• type Listener
• type Managers
• • func NewManagers() *Managers
• • func (managers *Managers) Init(env Env) *Managers
• type Mfa
• type MfaListResult
• type MfaManager
• • func NewMfaManager(env Env) *MfaManager
• • func (self *MfaManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *MfaManager) ApplyCreate(cmd *command.CreateEntityCommand[*Mfa], ctx boltz.MutateContext) error
  • func (self *MfaManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *MfaManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Mfa], ctx boltz.MutateContext) error
  • func (self *MfaManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *MfaManager) BaseLoad(id string) (ME, error)
  • func (self *MfaManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *MfaManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *MfaManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *MfaManager) CompleteTotpEnrollment(identityId string, code string, changeCtx *change.Context) error
  • func (self *MfaManager) Create(entity *Mfa, ctx *change.Context) error
  • func (self *MfaManager) CreateForIdentity(identity *Identity, ctx *change.Context) (string, error)
  • func (self *MfaManager) CreateForIdentityId(identityId string, ctx *change.Context) (string, error)
  • func (self *MfaManager) Delete(id string, ctx *change.Context) error
  • func (self *MfaManager) DeleteAllForIdentity(id string, ctx *change.Context) error
  • func (self *MfaManager) DeleteForIdentity(identity *Identity, code string, ctx *change.Context) error
  • func (self *MfaManager) Dispatch(command command.Command) error
  • func (self *MfaManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *MfaManager) GetDb() boltz.Db
  • func (self *MfaManager) GetEntityTypeId() string
  • func (self *MfaManager) GetEnv() Env
  • func (self *MfaManager) GetProvisioningUrl(mfa *Mfa) string
  • func (self *MfaManager) GetStore() boltz.EntityStore[PE]
  • func (self *MfaManager) IsEntityPresent(id string) (bool, error)
  • func (self *MfaManager) IsUpdated(field string) bool
  • func (self *MfaManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *MfaManager) Marshall(entity *Mfa) ([]byte, error)
  • func (self *MfaManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *MfaManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *MfaManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *MfaManager) QrCodePng(mfa *Mfa) ([]byte, error)
  • func (self *MfaManager) Query(query string) (*MfaListResult, error)
  • func (self *MfaManager) Read(id string) (ME, error)
  • func (self *MfaManager) ReadOneByIdentityId(identityId string) (*Mfa, error)
  • func (self *MfaManager) RecreateRecoveryCodes(mfa *Mfa, ctx *change.Context) error
  • func (self *MfaManager) Unmarshall(bytes []byte) (*Mfa, error)
  • func (self *MfaManager) Update(entity *Mfa, checker fields.UpdatedFields, ctx *change.Context) error
  • func (self *MfaManager) Verify(mfa *Mfa, code string, ctx *change.Context) (bool, error)
  • func (self *MfaManager) VerifyTOTP(mfa *Mfa, code string) (bool, error)
• type NotFieldChecker
• • func (checker NotFieldChecker) IsUpdated(field string) bool
• type OperatingSystem
• type OrFieldChecker
• • func NewOrFieldChecker(checker boltz.FieldChecker, fields ...string) *OrFieldChecker
• • func (checker *OrFieldChecker) IsUpdated(field string) bool
• type Path
• • func (self *Path) Cost(minRouterCost uint16) int64
  • func (self *Path) EgressRouter() *Router
  • func (self *Path) EqualPath(other *Path) bool
  • func (self *Path) String() string
  • func (self *Path) UsesLink(l *Link) bool
• type PolicyAdvisor
• • func NewPolicyAdvisor(env Env) *PolicyAdvisor
• • func (advisor *PolicyAdvisor) AnalyzeServiceReachability(identityId, serviceId string) (*AdvisorServiceReachability, error)
  • func (advisor *PolicyAdvisor) InspectIdentityEdgeRouterLinks(identityId, edgeRouterId string) (*AdvisorIdentityEdgeRouterLinks, error)
  • func (advisor *PolicyAdvisor) InspectIdentityServiceLinks(identityId, serviceId string) (*AdvisorIdentityServiceLinks, error)
  • func (advisor *PolicyAdvisor) InspectServiceEdgeRouterLinks(serviceId, edgeRouterId string) (*AdvisorServiceEdgeRouterLinks, error)
• type PolicyPostureChecks
• type PostureCache
• • func (pc *PostureCache) Add(identityId string, postureResponses []*PostureResponse)
  • func (pc *PostureCache) AddSessionRequestFailure(identityId string, failure *PostureSessionRequestFailure)
  • func (pc *PostureCache) ApiSessionCreated(apiSession *db.ApiSession)
  • func (pc *PostureCache) ApiSessionDeleted(apiSession *db.ApiSession)
  • func (pc *PostureCache) Evaluate(identityId, apiSessionId string, postureChecks []*PostureCheck) (bool, []*PostureCheckFailure)
  • func (pc *PostureCache) IdentityDeleted(identity *db.Identity)
  • func (pc *PostureCache) PostureCheckChanged(entity boltz.Entity)
  • func (pc *PostureCache) PostureData(identityId string) *PostureData
  • func (pc *PostureCache) Upsert(identityId string, emitDataAltered bool, ...)
  • func (pc *PostureCache) WithPostureData(identityId string, f func(data *PostureData))
• type PostureCheck
• • func (entity *PostureCheck) Evaluate(apiSessionId string, pd *PostureData) (bool, *PostureCheckFailure)
  • func (entity *PostureCheck) LastUpdatedAt(apiSessionId string, pd *PostureData) *time.Time
  • func (entity *PostureCheck) TimeoutRemainingSeconds(apiSessionId string, pd *PostureData) int64
  • func (entity *PostureCheck) TimeoutSeconds() int64
• type PostureCheckDomains
• • func (p *PostureCheckDomains) ActualValue(_ string, pd *PostureData) interface{}
  • func (p *PostureCheckDomains) Evaluate(_ string, pd *PostureData) bool
  • func (p *PostureCheckDomains) ExpectedValue() interface{}
  • func (p *PostureCheckDomains) FailureValues(_ string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckDomains) GetTimeoutRemainingSeconds(_ string, _ *PostureData) int64
  • func (p *PostureCheckDomains) GetTimeoutSeconds() int64
  • func (p *PostureCheckDomains) LastUpdatedAt(string, *PostureData) *time.Time
  • func (p *PostureCheckDomains) TypeId() string
• type PostureCheckFailure
• • func (self PostureCheckFailure) ToClientErrorData() interface{}
• type PostureCheckFailureSubType
• type PostureCheckFailureValues
• type PostureCheckFailureValuesDomain
• • func (p PostureCheckFailureValuesDomain) Actual() interface{}
  • func (p PostureCheckFailureValuesDomain) Expected() interface{}
• type PostureCheckFailureValuesMac
• • func (p PostureCheckFailureValuesMac) Actual() interface{}
  • func (p PostureCheckFailureValuesMac) Expected() interface{}
• type PostureCheckFailureValuesMfa
• • func (p PostureCheckFailureValuesMfa) Actual() interface{}
  • func (p PostureCheckFailureValuesMfa) Expected() interface{}
• type PostureCheckFailureValuesOperatingSystem
• • func (p PostureCheckFailureValuesOperatingSystem) Actual() interface{}
  • func (p PostureCheckFailureValuesOperatingSystem) Expected() interface{}
• type PostureCheckFailureValuesProcess
• • func (p PostureCheckFailureValuesProcess) Actual() interface{}
  • func (p PostureCheckFailureValuesProcess) Expected() interface{}
• type PostureCheckFailureValuesProcessMulti
• • func (p PostureCheckFailureValuesProcessMulti) Actual() interface{}
  • func (p PostureCheckFailureValuesProcessMulti) Expected() interface{}
• type PostureCheckListResult
• type PostureCheckMacAddresses
• • func (p *PostureCheckMacAddresses) Evaluate(_ string, pd *PostureData) bool
  • func (p *PostureCheckMacAddresses) FailureValues(_ string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckMacAddresses) GetTimeoutRemainingSeconds(_ string, _ *PostureData) int64
  • func (p *PostureCheckMacAddresses) GetTimeoutSeconds() int64
  • func (p *PostureCheckMacAddresses) LastUpdatedAt(apiSessionId string, pd *PostureData) *time.Time
  • func (p *PostureCheckMacAddresses) TypeId() string
• type PostureCheckManager
• • func NewPostureCheckManager(env Env) *PostureCheckManager
• • func (self *PostureCheckManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *PostureCheckManager) ApplyCreate(cmd *command.CreateEntityCommand[*PostureCheck], ctx boltz.MutateContext) error
  • func (self *PostureCheckManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *PostureCheckManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*PostureCheck], ctx boltz.MutateContext) error
  • func (self *PostureCheckManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckManager) BaseLoad(id string) (ME, error)
  • func (self *PostureCheckManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *PostureCheckManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckManager) Create(entity *PostureCheck, ctx *change.Context) error
  • func (self *PostureCheckManager) Delete(id string, ctx *change.Context) error
  • func (self *PostureCheckManager) Dispatch(command command.Command) error
  • func (self *PostureCheckManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *PostureCheckManager) GetDb() boltz.Db
  • func (self *PostureCheckManager) GetEntityTypeId() string
  • func (self *PostureCheckManager) GetEnv() Env
  • func (self *PostureCheckManager) GetStore() boltz.EntityStore[PE]
  • func (self *PostureCheckManager) IsEntityPresent(id string) (bool, error)
  • func (self *PostureCheckManager) IsUpdated(field string) bool
  • func (self *PostureCheckManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *PostureCheckManager) Marshall(entity *PostureCheck) ([]byte, error)
  • func (self *PostureCheckManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *PostureCheckManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *PostureCheckManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *PostureCheckManager) Query(query string) (*PostureCheckListResult, error)
  • func (self *PostureCheckManager) QueryPostureChecks(query ast.Query) (*PostureCheckListResult, error)
  • func (self *PostureCheckManager) QueryRoleAttributes(queryString string) ([]string, *models.QueryMetaData, error)
  • func (self *PostureCheckManager) Read(id string) (*PostureCheck, error)
  • func (self *PostureCheckManager) Unmarshall(bytes []byte) (*PostureCheck, error)
  • func (self *PostureCheckManager) Update(entity *PostureCheck, checker fields.UpdatedFields, ctx *change.Context) error
• type PostureCheckMfa
• • func (p *PostureCheckMfa) Evaluate(apiSessionId string, pd *PostureData) bool
  • func (p *PostureCheckMfa) FailureValues(apiSessionId string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckMfa) GetTimeoutRemainingSeconds(apiSessionId string, pd *PostureData) int64
  • func (p *PostureCheckMfa) GetTimeoutSeconds() int64
  • func (p *PostureCheckMfa) IsLegacyClient(apiSessionData *ApiSessionPostureData) bool
  • func (p *PostureCheckMfa) LastUpdatedAt(apiSessionId string, pd *PostureData) *time.Time
  • func (p *PostureCheckMfa) PassedOnUnlock(apiSessionData *ApiSessionPostureData, now time.Time) bool
  • func (p *PostureCheckMfa) PassedOnWake(apiSessionData *ApiSessionPostureData, now time.Time) bool
  • func (p *PostureCheckMfa) TypeId() string
• type PostureCheckMfaCriteria
• type PostureCheckMfaValues
• type PostureCheckOperatingSystem
• • func (p *PostureCheckOperatingSystem) Evaluate(_ string, pd *PostureData) bool
  • func (p *PostureCheckOperatingSystem) FailureValues(_ string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckOperatingSystem) GetTimeoutRemainingSeconds(_ string, _ *PostureData) int64
  • func (p *PostureCheckOperatingSystem) GetTimeoutSeconds() int64
  • func (p *PostureCheckOperatingSystem) LastUpdatedAt(id string, pd *PostureData) *time.Time
  • func (p *PostureCheckOperatingSystem) TypeId() string
• type PostureCheckProcess
• • func (p *PostureCheckProcess) Evaluate(_ string, pd *PostureData) bool
  • func (p *PostureCheckProcess) FailureValues(_ string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckProcess) GetTimeoutRemainingSeconds(_ string, _ *PostureData) int64
  • func (p *PostureCheckProcess) GetTimeoutSeconds() int64
  • func (p *PostureCheckProcess) LastUpdatedAt(id string, pd *PostureData) *time.Time
  • func (p *PostureCheckProcess) TypeId() string
• type PostureCheckProcessMulti
• • func (p *PostureCheckProcessMulti) Evaluate(_ string, pd *PostureData) bool
  • func (p *PostureCheckProcessMulti) FailureValues(_ string, pd *PostureData) PostureCheckFailureValues
  • func (p *PostureCheckProcessMulti) GetTimeoutRemainingSeconds(_ string, _ *PostureData) int64
  • func (p *PostureCheckProcessMulti) GetTimeoutSeconds() int64
  • func (p *PostureCheckProcessMulti) LastUpdatedAt(string, *PostureData) *time.Time
  • func (p *PostureCheckProcessMulti) TypeId() string
• type PostureCheckSubType
• type PostureCheckType
• type PostureCheckTypeManager
• • func NewPostureCheckTypeManager(env Env) *PostureCheckTypeManager
• • func (self *PostureCheckTypeManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *PostureCheckTypeManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *PostureCheckTypeManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckTypeManager) BaseLoad(id string) (ME, error)
  • func (self *PostureCheckTypeManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *PostureCheckTypeManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckTypeManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *PostureCheckTypeManager) Delete(id string, ctx *change.Context) error
  • func (self *PostureCheckTypeManager) Dispatch(command command.Command) error
  • func (self *PostureCheckTypeManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *PostureCheckTypeManager) GetDb() boltz.Db
  • func (self *PostureCheckTypeManager) GetEntityTypeId() string
  • func (self *PostureCheckTypeManager) GetEnv() Env
  • func (self *PostureCheckTypeManager) GetStore() boltz.EntityStore[PE]
  • func (self *PostureCheckTypeManager) IsEntityPresent(id string) (bool, error)
  • func (self *PostureCheckTypeManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *PostureCheckTypeManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *PostureCheckTypeManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *PostureCheckTypeManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *PostureCheckTypeManager) Read(id string) (ME, error)
• type PostureData
• • func (pd *PostureData) Copy() *PostureData
  • func (pd *PostureData) Evaluate(apiSessionId string, checks []*PostureCheck) (bool, []*PostureCheckFailure)
• type PosturePolicyFailure
• type PostureResponse
• • func (pr *PostureResponse) Apply(postureData *PostureData)
• type PostureResponseDomain
• • func (pr *PostureResponseDomain) Apply(postureData *PostureData)
• type PostureResponseEndpointState
• • func (pr *PostureResponseEndpointState) Apply(postureData *PostureData)
• type PostureResponseMac
• • func (pr *PostureResponseMac) Apply(postureData *PostureData)
• type PostureResponseManager
• • func NewPostureResponseManager(env Env) *PostureResponseManager
• • func (self *PostureResponseManager) AddPostureDataListener(cb func(env Env, identityId string))
  • func (self *PostureResponseManager) Create(identityId string, postureResponses []*PostureResponse)
  • func (self *PostureResponseManager) Evaluate(identityId, apiSessionId string, check *PostureCheck) (bool, *PostureCheckFailure)
  • func (self *PostureResponseManager) GetEndpointStateChangeAffectedServices(timeSinceLastMfa, gracePeriod time.Duration, onWake bool, onUnlock bool) []*ServiceWithTimeout
  • func (self *PostureResponseManager) PostureData(id string) *PostureData
  • func (self *PostureResponseManager) SetMfaPosture(identityId string, apiSessionId string, isPassed bool)
  • func (self *PostureResponseManager) SetMfaPostureForIdentity(identityId string, isPassed bool)
  • func (self *PostureResponseManager) SetSdkInfo(identityId, apiSessionId string, sdkInfo *SdkInfo)
  • func (self *PostureResponseManager) WithPostureData(id string, f func(data *PostureData))
• type PostureResponseMfa
• • func (pr *PostureResponseMfa) Apply(postureData *PostureData)
• type PostureResponseOs
• • func (pr *PostureResponseOs) Apply(postureData *PostureData)
• type PostureResponseProcess
• • func (pr *PostureResponseProcess) Apply(postureData *PostureData)
  • func (pr *PostureResponseProcess) VerifyMultiCriteria(process *ProcessMulti) bool
• type PostureResponseSubType
• type PostureSessionData
• type PostureSessionRequestFailure
• type ProcessMulti
• type ReEnrollEdgeRouterCmd
• • func (d *ReEnrollEdgeRouterCmd) Apply(ctx boltz.MutateContext) error
  • func (d *ReEnrollEdgeRouterCmd) Decode(env Env, msg *edge_cmd_pb.ReEnrollEdgeRouterCmd) error
  • func (d *ReEnrollEdgeRouterCmd) Encode() ([]byte, error)
  • func (d *ReEnrollEdgeRouterCmd) GetChangeContext() *change.Context
• type ReplaceEnrollmentWithAuthenticatorCmd
• • func (self *ReplaceEnrollmentWithAuthenticatorCmd) Apply(ctx boltz.MutateContext) error
  • func (self *ReplaceEnrollmentWithAuthenticatorCmd) Decode(env Env, msg *edge_cmd_pb.ReplaceEnrollmentWithAuthenticatorCmd) error
  • func (self *ReplaceEnrollmentWithAuthenticatorCmd) Encode() ([]byte, error)
  • func (self *ReplaceEnrollmentWithAuthenticatorCmd) GetChangeContext() *change.Context
• type Revocation
• type RevocationManager
• • func NewRevocationManager(env Env) *RevocationManager
• • func (self *RevocationManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *RevocationManager) ApplyCreate(cmd *command.CreateEntityCommand[*Revocation], ctx boltz.MutateContext) error
  • func (self *RevocationManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *RevocationManager) ApplyUpdate(_ *command.UpdateEntityCommand[*Revocation], ctx boltz.MutateContext) error
  • func (self *RevocationManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *RevocationManager) BaseLoad(id string) (ME, error)
  • func (self *RevocationManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *RevocationManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *RevocationManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *RevocationManager) Create(entity *Revocation, ctx *change.Context) error
  • func (self *RevocationManager) Delete(id string, ctx *change.Context) error
  • func (self *RevocationManager) Dispatch(command command.Command) error
  • func (self *RevocationManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *RevocationManager) GetDb() boltz.Db
  • func (self *RevocationManager) GetEntityTypeId() string
  • func (self *RevocationManager) GetEnv() Env
  • func (self *RevocationManager) GetStore() boltz.EntityStore[PE]
  • func (self *RevocationManager) IsEntityPresent(id string) (bool, error)
  • func (self *RevocationManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *RevocationManager) Marshall(entity *Revocation) ([]byte, error)
  • func (self *RevocationManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *RevocationManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *RevocationManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *RevocationManager) Read(id string) (*Revocation, error)
  • func (self *RevocationManager) Unmarshall(bytes []byte) (*Revocation, error)
• type Router
• • func NewRouter(id, name, fingerprint string, cost uint16, noTraversal bool) *Router
  • func NewRouterForTest(id string, fingerprint string, advLstnr transport.Address, ...) *Router
• • func (entity *Router) AddLinkListener(addr, linkProtocol string, linkCostTags []string, groups []string)
  • func (entity *Router) GetLinks() []*Link
  • func (entity *Router) HasCapability(capability ctrl_pb.RouterCapability) bool
  • func (entity *Router) SetLinkListeners(listeners []*ctrl_pb.Listener)
  • func (entity *Router) SetMetadata(metadata *ctrl_pb.RouterMetadata)
  • func (entity *Router) SupportsRouterLinkMgmt() bool
• type RouterLinks
• • func (self *RouterLinks) Add(link *Link, otherRouterId string)
  • func (self *RouterLinks) Clear()
  • func (self *RouterLinks) GetLinks() []*Link
  • func (self *RouterLinks) GetLinksByRouter() map[string][]*Link
  • func (self *RouterLinks) Remove(link *Link, otherRouterId string)
• type RouterManager
• • func (self *RouterManager) AllConnected() []*Router
  • func (self *RouterManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *RouterManager) ApplyCreate(cmd *command.CreateEntityCommand[*Router], ctx boltz.MutateContext) error
  • func (self *RouterManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *RouterManager) ApplyDequiesce(cmd *command.UpdateEntityCommand[*Router], ctx boltz.MutateContext) error
  • func (self *RouterManager) ApplyQuiesce(cmd *command.UpdateEntityCommand[*Router], ctx boltz.MutateContext) error
  • func (self *RouterManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Router], ctx boltz.MutateContext) error
  • func (self *RouterManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *RouterManager) BaseLoad(id string) (ME, error)
  • func (self *RouterManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *RouterManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *RouterManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *RouterManager) ConnectedCount() int
  • func (self *RouterManager) Create(entity *Router, ctx *change.Context) error
  • func (self *RouterManager) Delete(id string, ctx *change.Context) error
  • func (self *RouterManager) DequiesceRouter(entity *Router, ctx *change.Context) error
  • func (self *RouterManager) Dispatch(command command.Command) error
  • func (self *RouterManager) Exists(id string) (bool, error)
  • func (self *RouterManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *RouterManager) GetConnected(id string) *Router
  • func (self *RouterManager) GetDb() boltz.Db
  • func (self *RouterManager) GetEntityTypeId() string
  • func (self *RouterManager) GetEnv() Env
  • func (self *RouterManager) GetStore() boltz.EntityStore[PE]
  • func (self *RouterManager) HandleRouterDelete(id string)
  • func (self *RouterManager) IsConnected(id string) bool
  • func (self *RouterManager) IsEntityPresent(id string) (bool, error)
  • func (self *RouterManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *RouterManager) MarkConnected(r *Router)
  • func (self *RouterManager) MarkDisconnected(r *Router)
  • func (self *RouterManager) Marshall(entity *Router) ([]byte, error)
  • func (self *RouterManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *RouterManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *RouterManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *RouterManager) QuiesceRouter(entity *Router, ctx *change.Context) error
  • func (self *RouterManager) Read(id string) (entity *Router, err error)
  • func (self *RouterManager) RemoveFromCache(id string)
  • func (self *RouterManager) ReportRouterErtTerminatorsError(router *Router, err error, ...)
  • func (self *RouterManager) ReportRouterSdkTerminatorsError(router *Router, err error, ...)
  • func (self *RouterManager) Unmarshall(bytes []byte) (*Router, error)
  • func (self *RouterManager) Update(entity *Router, updatedFields fields.UpdatedFields, ctx *change.Context) error
  • func (self *RouterManager) UpdateCachedRouter(id string)
  • func (self *RouterManager) UpdateRouterInterfaces(routerId string, interfaces []*Interface, ctx *change.Context) error
  • func (self *RouterManager) UpdateTerminators(router *Router, ctx boltz.MutateContext, ...) error
  • func (self *RouterManager) ValidateRouterErtTerminators(router *Router, cb func(detail *mgmt_pb.RouterErtTerminatorsDetails))
  • func (self *RouterManager) ValidateRouterSdkTerminators(router *Router, cb func(detail *mgmt_pb.RouterSdkTerminatorsDetails))
• type RouterPresenceHandler
• type RoutingTerminator
• • func (r *RoutingTerminator) GetRouteCost() uint32
• type SdkInfo
• • func (self *SdkInfo) Equals(other *SdkInfo) bool
• type Service
• • func (entity *Service) GetName() string
• type ServiceConfig
• type ServiceDetail
• type ServiceDetailLister
• • func (self *ServiceDetailLister) BaseLoadInTx(tx *bbolt.Tx, id string) (*ServiceDetail, error)
  • func (self *ServiceDetailLister) BasePreparedList(query ast.Query) (*models.EntityListResult[*ServiceDetail], error)
  • func (self *ServiceDetailLister) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[*ServiceDetail], error)
  • func (self *ServiceDetailLister) GetListStore() boltz.Store
• type ServiceEdgeRouterPolicy
• type ServiceEdgeRouterPolicyManager
• • func NewServiceEdgeRouterPolicyManager(env Env) *ServiceEdgeRouterPolicyManager
• • func (self *ServiceEdgeRouterPolicyManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ServiceEdgeRouterPolicyManager) ApplyCreate(cmd *command.CreateEntityCommand[*ServiceEdgeRouterPolicy], ...) error
  • func (self *ServiceEdgeRouterPolicyManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ServiceEdgeRouterPolicyManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*ServiceEdgeRouterPolicy], ...) error
  • func (self *ServiceEdgeRouterPolicyManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ServiceEdgeRouterPolicyManager) BaseLoad(id string) (ME, error)
  • func (self *ServiceEdgeRouterPolicyManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ServiceEdgeRouterPolicyManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServiceEdgeRouterPolicyManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServiceEdgeRouterPolicyManager) Create(entity *ServiceEdgeRouterPolicy, ctx *change.Context) error
  • func (self *ServiceEdgeRouterPolicyManager) Delete(id string, ctx *change.Context) error
  • func (self *ServiceEdgeRouterPolicyManager) Dispatch(command command.Command) error
  • func (self *ServiceEdgeRouterPolicyManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ServiceEdgeRouterPolicyManager) GetDb() boltz.Db
  • func (self *ServiceEdgeRouterPolicyManager) GetEntityTypeId() string
  • func (self *ServiceEdgeRouterPolicyManager) GetEnv() Env
  • func (self *ServiceEdgeRouterPolicyManager) GetStore() boltz.EntityStore[PE]
  • func (self *ServiceEdgeRouterPolicyManager) IsEntityPresent(id string) (bool, error)
  • func (self *ServiceEdgeRouterPolicyManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ServiceEdgeRouterPolicyManager) Marshall(entity *ServiceEdgeRouterPolicy) ([]byte, error)
  • func (self *ServiceEdgeRouterPolicyManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ServiceEdgeRouterPolicyManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ServiceEdgeRouterPolicyManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ServiceEdgeRouterPolicyManager) Read(id string) (ME, error)
  • func (self *ServiceEdgeRouterPolicyManager) Unmarshall(bytes []byte) (*ServiceEdgeRouterPolicy, error)
  • func (self *ServiceEdgeRouterPolicyManager) Update(entity *ServiceEdgeRouterPolicy, checker fields.UpdatedFields, ...) error
• type ServiceListResult
• type ServiceManager
• • func (self *ServiceManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ServiceManager) ApplyCreate(cmd *command.CreateEntityCommand[*Service], ctx boltz.MutateContext) error
  • func (self *ServiceManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ServiceManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Service], ctx boltz.MutateContext) error
  • func (self *ServiceManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ServiceManager) BaseLoad(id string) (ME, error)
  • func (self *ServiceManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ServiceManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServiceManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServiceManager) Create(entity *Service, ctx *change.Context) error
  • func (self *ServiceManager) Delete(id string, ctx *change.Context) error
  • func (self *ServiceManager) Dispatch(command command.Command) error
  • func (self *ServiceManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ServiceManager) GetDb() boltz.Db
  • func (self *ServiceManager) GetEntityTypeId() string
  • func (self *ServiceManager) GetEnv() Env
  • func (self *ServiceManager) GetIdForName(id string) (string, error)
  • func (self *ServiceManager) GetStore() boltz.EntityStore[PE]
  • func (self *ServiceManager) IsEntityPresent(id string) (bool, error)
  • func (self *ServiceManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ServiceManager) Marshall(entity *Service) ([]byte, error)
  • func (self *ServiceManager) NotifyTerminatorChanged(terminator *db.Terminator) *db.Terminator
  • func (self *ServiceManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ServiceManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ServiceManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ServiceManager) Read(id string) (entity *Service, err error)
  • func (self *ServiceManager) RemoveFromCache(id string)
  • func (self *ServiceManager) Unmarshall(bytes []byte) (*Service, error)
  • func (self *ServiceManager) Update(entity *Service, updatedFields fields.UpdatedFields, ctx *change.Context) error
• type ServicePolicy
• type ServicePolicyManager
• • func NewServicePolicyManager(env Env) *ServicePolicyManager
• • func (self *ServicePolicyManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *ServicePolicyManager) ApplyCreate(cmd *command.CreateEntityCommand[*ServicePolicy], ctx boltz.MutateContext) error
  • func (self *ServicePolicyManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *ServicePolicyManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*ServicePolicy], ctx boltz.MutateContext) error
  • func (self *ServicePolicyManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *ServicePolicyManager) BaseLoad(id string) (ME, error)
  • func (self *ServicePolicyManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *ServicePolicyManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServicePolicyManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *ServicePolicyManager) Create(entity *ServicePolicy, ctx *change.Context) error
  • func (self *ServicePolicyManager) Delete(id string, ctx *change.Context) error
  • func (self *ServicePolicyManager) Dispatch(command command.Command) error
  • func (self *ServicePolicyManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *ServicePolicyManager) GetDb() boltz.Db
  • func (self *ServicePolicyManager) GetEntityTypeId() string
  • func (self *ServicePolicyManager) GetEnv() Env
  • func (self *ServicePolicyManager) GetStore() boltz.EntityStore[PE]
  • func (self *ServicePolicyManager) IsEntityPresent(id string) (bool, error)
  • func (self *ServicePolicyManager) ListAssociatedIds(tx *bbolt.Tx, id string) *AssociatedIdsResult
  • func (self *ServicePolicyManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *ServicePolicyManager) Marshall(entity *ServicePolicy) ([]byte, error)
  • func (self *ServicePolicyManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *ServicePolicyManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *ServicePolicyManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *ServicePolicyManager) Read(id string) (ME, error)
  • func (self *ServicePolicyManager) Unmarshall(bytes []byte) (*ServicePolicy, error)
  • func (self *ServicePolicyManager) Update(entity *ServicePolicy, checker fields.UpdatedFields, ctx *change.Context) error
• type ServiceWithTimeout
• type Session
• type SessionListResult
• type SessionManager
• • func NewSessionManager(env Env) *SessionManager
• • func (self *SessionManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *SessionManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *SessionManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *SessionManager) BaseLoad(id string) (ME, error)
  • func (self *SessionManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *SessionManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *SessionManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *SessionManager) Create(entity *Session, ctx *change.Context) (string, error)
  • func (self *SessionManager) CreateJwt(entity *Session, ctx *change.Context) (string, error)
  • func (self *SessionManager) Delete(id string, ctx *change.Context) error
  • func (self *SessionManager) DeleteForIdentity(id, identityId string, ctx *change.Context) error
  • func (self *SessionManager) Dispatch(command command.Command) error
  • func (self *SessionManager) EvaluatePostureForService(identityId, apiSessionId, sessionType, serviceId, serviceName string) *SessionPostureResult
  • func (self *SessionManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *SessionManager) GetDb() boltz.Db
  • func (self *SessionManager) GetEntityTypeId() string
  • func (self *SessionManager) GetEnv() Env
  • func (self *SessionManager) GetStore() boltz.EntityStore[PE]
  • func (self *SessionManager) IsEntityPresent(id string) (bool, error)
  • func (self *SessionManager) ListSessionsForEdgeRouter(edgeRouterId string) (*SessionListResult, error)
  • func (self *SessionManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *SessionManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *SessionManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *SessionManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *SessionManager) PublicQueryForIdentity(sessionIdentity *Identity, query ast.Query) (*SessionListResult, error)
  • func (self *SessionManager) Query(query string) (*SessionListResult, error)
  • func (self *SessionManager) Read(id string) (*Session, error)
  • func (self *SessionManager) ReadByToken(token string) (*Session, error)
  • func (self *SessionManager) ReadForIdentity(id string, identityId string) (*Session, error)
• type SessionPostureResult
• type SyncRouterPresenceHandler
• type Terminator
• • func (entity *Terminator) GetAddress() string
  • func (entity *Terminator) GetBinding() string
  • func (entity *Terminator) GetCost() uint16
  • func (entity *Terminator) GetHostId() string
  • func (entity *Terminator) GetInstanceId() string
  • func (entity *Terminator) GetInstanceSecret() []byte
  • func (entity *Terminator) GetPeerData() xt.PeerData
  • func (entity *Terminator) GetPrecedence() xt.Precedence
  • func (entity *Terminator) GetRouterId() string
  • func (entity *Terminator) GetServiceId() string
  • func (entity *Terminator) GetSourceCtrl() string
• type TerminatorListResult
• type TerminatorManager
• • func (self *TerminatorManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *TerminatorManager) ApplyCreate(cmd *command.CreateEntityCommand[*Terminator], ctx boltz.MutateContext) error
  • func (self *TerminatorManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *TerminatorManager) ApplyDeleteBatch(cmd *DeleteTerminatorsBatchCommand, ctx boltz.MutateContext) error
  • func (self *TerminatorManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*Terminator], ctx boltz.MutateContext) error
  • func (self *TerminatorManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *TerminatorManager) BaseLoad(id string) (ME, error)
  • func (self *TerminatorManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *TerminatorManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *TerminatorManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *TerminatorManager) Create(entity *Terminator, ctx *change.Context) error
  • func (self *TerminatorManager) Delete(id string, ctx *change.Context) error
  • func (self *TerminatorManager) DeleteBatch(ids []string, ctx *change.Context) error
  • func (self *TerminatorManager) Dispatch(command command.Command) error
  • func (self *TerminatorManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *TerminatorManager) GetDb() boltz.Db
  • func (self *TerminatorManager) GetEntityTypeId() string
  • func (self *TerminatorManager) GetEnv() Env
  • func (self *TerminatorManager) GetStore() boltz.EntityStore[PE]
  • func (self *TerminatorManager) HandlePrecedenceChange(terminatorId string, precedence xt.Precedence)
  • func (self *TerminatorManager) IsEntityPresent(id string) (bool, error)
  • func (self *TerminatorManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *TerminatorManager) Marshall(entity *Terminator) ([]byte, error)
  • func (self *TerminatorManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *TerminatorManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *TerminatorManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *TerminatorManager) Query(query string) (*TerminatorListResult, error)
  • func (self *TerminatorManager) Read(id string) (ME, error)
  • func (self *TerminatorManager) Unmarshall(bytes []byte) (*Terminator, error)
  • func (self *TerminatorManager) Update(entity *Terminator, updatedFields fields.UpdatedFields, ctx *change.Context) error
  • func (self *TerminatorManager) ValidateTerminators(filter string, fixInvalid bool, cb TerminatorValidationCallback) (uint64, error)
• type TerminatorValidationCallback
• type TestContext
• • func NewTestContext(t testing.TB) *TestContext
• • func (self *TestContext) AddRouterPresenceHandler(RouterPresenceHandler)
  • func (ctx *TestContext) Cleanup()
  • func (ctx *TestContext) Generate(jwt.Claims) (string, error)
  • func (self *TestContext) GetApiAddresses() (map[string][]event.ApiAddress, []byte)
  • func (ctx *TestContext) GetApiClientCsrSigner() cert.Signer
  • func (ctx *TestContext) GetApiServerCsrSigner() cert.Signer
  • func (ctx *TestContext) GetAuthRegistry() AuthRegistry
  • func (ctx *TestContext) GetClientApiDefaultServerCert() (*tls.Certificate, string, jwt.SigningMethod)
  • func (ctx *TestContext) GetClientApiDefaultTlsJwtSigner() *jwtsigner.TlsJwtSigner
  • func (self *TestContext) GetCloseNotifyChannel() <-chan struct{}
  • func (self *TestContext) GetCommandDispatcher() command.Dispatcher
  • func (ctx *TestContext) GetConfig() *config.Config
  • func (ctx *TestContext) GetControlClientCsrSigner() cert.Signer
  • func (ctx *TestContext) GetEnrollRegistry() EnrollmentRegistry
  • func (ctx *TestContext) GetEnrollmentJwtSigner() (jwtsigner.Signer, error)
  • func (ctx *TestContext) GetEventDispatcher() event.Dispatcher
  • func (ctx *TestContext) GetFingerprintGenerator() cert.FingerprintGenerator
  • func (ctx *TestContext) GetId() string
  • func (ctx *TestContext) GetManagers() *Managers
  • func (ctx *TestContext) GetMetricsRegistry() metrics.Registry
  • func (ctx *TestContext) GetPeerControllerAddresses() []string
  • func (self *TestContext) GetPeerSigners() []*x509.Certificate
  • func (self *TestContext) GetRaftInfo() (string, string, string)
  • func (ctx *TestContext) GetRootTlsJwtSigner() *jwtsigner.TlsJwtSigner
  • func (ctx *TestContext) GetServerJwtSigner() jwtsigner.Signer
  • func (ctx *TestContext) HandleServiceUpdatedEventForIdentityId(string)
  • func (self *TestContext) Identity() identity.Identity
  • func (ctx *TestContext) IsEdgeRouterOnline(string) bool
  • func (ctx *TestContext) JwtSignerKeyFunc(*jwt.Token) (interface{}, error)
  • func (ctx *TestContext) KeyId() string
  • func (ctx *TestContext) OidcIssuer() string
  • func (ctx *TestContext) RootIssuer() string
  • func (self *TestContext) Shutdown()
  • func (ctx *TestContext) SigningMethod() jwt.SigningMethod
  • func (self *TestContext) Stop()
  • func (ctx *TestContext) ValidateAccessToken(token string) (*common.AccessClaims, error)
  • func (ctx *TestContext) ValidateServiceAccessToken(token string, apiSessionId *string) (*common.ServiceAccessClaims, error)
• type TransitRouter
• • func (self *TransitRouter) GetName() string
• type TransitRouterManager
• • func NewTransitRouterManager(env Env) *TransitRouterManager
• • func (self *TransitRouterManager) Annotate(ctx boltz.MutateContext, entityId string, key, value string) error
  • func (self *TransitRouterManager) ApplyCreate(cmd *CreateTransitRouterCmd, ctx boltz.MutateContext) error
  • func (self *TransitRouterManager) ApplyDelete(cmd *command.DeleteEntityCommand, ctx boltz.MutateContext) error
  • func (self *TransitRouterManager) ApplyUpdate(cmd *command.UpdateEntityCommand[*TransitRouter], ctx boltz.MutateContext) error
  • func (self *TransitRouterManager) BaseList(query string) (*models.EntityListResult[ME], error)
  • func (self *TransitRouterManager) BaseLoad(id string) (ME, error)
  • func (self *TransitRouterManager) BaseLoadInTx(tx *bbolt.Tx, id string) (ME, error)
  • func (self *TransitRouterManager) BasePreparedList(query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *TransitRouterManager) BasePreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query) (*models.EntityListResult[ME], error)
  • func (self *TransitRouterManager) CollectEnrollments(id string, collector func(entity *Enrollment) error) error
  • func (self *TransitRouterManager) Create(txRouter *TransitRouter, ctx *change.Context) error
  • func (self *TransitRouterManager) Delete(id string, ctx *change.Context) error
  • func (self *TransitRouterManager) Dispatch(command command.Command) error
  • func (self *TransitRouterManager) ExtendEnrollment(router *TransitRouter, clientCsrPem []byte, serverCertCsrPem []byte, ...) (*ExtendedCerts, error)
  • func (self *TransitRouterManager) ExtendEnrollmentVerify(router *TransitRouter, ctx *change.Context) error
  • func (self *TransitRouterManager) ExtendEnrollmentWithVerify(router *TransitRouter, clientCsrPem []byte, serverCertCsrPem []byte, ...) (*ExtendedCerts, error)
  • func (self *TransitRouterManager) GetAnnotation(entityId string, key string) (*string, error)
  • func (self *TransitRouterManager) GetDb() boltz.Db
  • func (self *TransitRouterManager) GetEntityTypeId() string
  • func (self *TransitRouterManager) GetEnv() Env
  • func (self *TransitRouterManager) GetStore() boltz.EntityStore[PE]
  • func (self *TransitRouterManager) IsEntityPresent(id string) (bool, error)
  • func (self *TransitRouterManager) ListWithHandler(queryString string, resultHandler models.ListResultHandler) error
  • func (self *TransitRouterManager) Marshall(entity *TransitRouter) ([]byte, error)
  • func (self *TransitRouterManager) PreparedListAssociatedWithHandler(id string, association string, query ast.Query, ...) error
  • func (self *TransitRouterManager) PreparedListIndexed(cursorProvider ast.SetCursorProvider, query ast.Query, ...) error
  • func (self *TransitRouterManager) PreparedListWithHandler(query ast.Query, resultHandler models.ListResultHandler) error
  • func (self *TransitRouterManager) ProtobufToTransitRouter(msg *edge_cmd_pb.TransitRouter) (*TransitRouter, error)
  • func (self *TransitRouterManager) Read(id string) (ME, error)
  • func (self *TransitRouterManager) ReadOneByFingerprint(fingerprint string) (*TransitRouter, error)
  • func (self *TransitRouterManager) ReadOneByQuery(query string) (*TransitRouter, error)
  • func (self *TransitRouterManager) ReadOneByUnverifiedFingerprint(fingerprint string) (*TransitRouter, error)
  • func (self *TransitRouterManager) TransitRouterToProtobuf(entity *TransitRouter) (*edge_cmd_pb.TransitRouter, error)
  • func (self *TransitRouterManager) Unmarshall(bytes []byte) (*TransitRouter, error)
  • func (self *TransitRouterManager) Update(entity *TransitRouter, unrestricted bool, checker fields.UpdatedFields, ...) error
• type TrustCache
• • func (self *TrustCache) GetAllPool() *x509.CertPool
• type UpdateServiceConfigsCmd
• • func (self *UpdateServiceConfigsCmd) Apply(ctx boltz.MutateContext) error
  • func (self *UpdateServiceConfigsCmd) Decode(env Env, msg *edge_cmd_pb.UpdateServiceConfigsCmd) error
  • func (self *UpdateServiceConfigsCmd) Encode() ([]byte, error)
  • func (self *UpdateServiceConfigsCmd) GetChangeContext() *change.Context
• type ValidateTerminatorRequestSendable
• • func (self *ValidateTerminatorRequestSendable) AcceptReply(message *channel.Message)
  • func (self *ValidateTerminatorRequestSendable) Context() context.Context
  • func (self *ValidateTerminatorRequestSendable) ReplyReceiver() channel.ReplyReceiver
  • func (self *ValidateTerminatorRequestSendable) SendListener() channel.SendListener