ziti

May 17, 2024

Changes in this version

type DialOptions

+ StickinessToken []byte

May 9, 2024

Changes in this version

+ const EnrollmentMethodCa

Apr 17, 2024

Changes in this version

+ const EventControllerUrlsUpdated

type ContextImpl

+ func (context *ContextImpl) AddControllerUrlsUpdateListener(handler func(Context, []*url.URL)) func()

Mar 11, 2024

Changes in this version

type Context

+ GetCurrentIdentityWithBackoff func() (*rest_model.IdentityDetail, error)

type ContextImpl

+ func (context *ContextImpl) GetCurrentIdentityWithBackoff() (*rest_model.IdentityDetail, error)

Mar 7, 2024

Changes in this version

type Config

+ EnableHa bool

Feb 22, 2024

Changes in this version

type ContextImpl

+ func (context *ContextImpl) RefreshApiSessionWithBackoff() error

Jan 17, 2024

Changes in this version

type ListenOptions

+ MaxTerminators int

Jan 3, 2024

Changes in this version

type Config

+ ZtAPIs []string

type CtrlClient

+ func (self *CtrlClient) GetSessionFromJwt(sessionToken string) (*rest_model.SessionDetail, error)

type EnrollmentClaims

+ Controllers []string

Dec 14, 2023

Changes in this version

+ const DefaultServiceRefreshInterval

+ const DefaultSessionRefreshInterval

+ const MinRefreshInterval

type Options

+ SessionRefreshInterval time.Duration

Dec 13, 2023

Changes in this version

+ type ListenEventObserver interface

+ Notify func(eventType ListenEventType)

+ type ListenEventType int

+ const ListenerAdded

+ const ListenerEstablished

+ const ListenerRemoved

type ListenOptions

+ WaitForNEstablishedListeners uint

Dec 12, 2023

Changes in this version

type Context

+ RefreshService func(serviceName string) (*rest_model.ServiceDetail, error)

type ContextImpl

+ func (context *ContextImpl) RefreshService(serviceName string) (*rest_model.ServiceDetail, error)

type CtrlClient

+ func (self *CtrlClient) GetService(name string) (*rest_model.ServiceDetail, error)

May 25, 2023

Changes in this version

type Options

+ EdgeRouterUrlFilter func(string) bool

May 25, 2023

Changes in this version

+ const EventAuthQuery

+ const EventAuthenticationStateFull

+ const EventAuthenticationStatePartial

+ const EventAuthenticationStateUnauthenticated

+ const EventMfaTotpCode

+ const EventRouterConnected

+ const EventRouterDisconnected

+ const EventServiceAdded

+ const EventServiceChanged

+ const EventServiceRemoved

type Context

+ Events func() Eventer

type ContextImpl

+ func (context *ContextImpl) AddAuthQueryListener(handler func(Context, *rest_model.AuthQueryDetail)) func()

+ func (context *ContextImpl) AddAuthenticationStateFullListener(handler func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ func (context *ContextImpl) AddAuthenticationStatePartialListener(handler func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ func (context *ContextImpl) AddAuthenticationStateUnauthenticatedListener(handler func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ func (context *ContextImpl) AddMfaTotpCodeListener(handler func(Context, *rest_model.AuthQueryDetail, MfaCodeResponse)) func()

+ func (context *ContextImpl) AddRouterConnectedListener(handler func(Context, string, string)) func()

+ func (context *ContextImpl) AddRouterDisconnectedListener(handler func(Context, string, string)) func()

+ func (context *ContextImpl) AddServiceAddedListener(handler func(Context, *rest_model.ServiceDetail)) func()

+ func (context *ContextImpl) AddServiceChangedListener(handler func(Context, *rest_model.ServiceDetail)) func()

+ func (context *ContextImpl) AddServiceRemovedListener(handler func(Context, *rest_model.ServiceDetail)) func()

+ func (context *ContextImpl) CloseAllEdgeRouterConns()

+ func (context *ContextImpl) Events() Eventer

+ func (context *ContextImpl) Reauthenticate() error

+ type Eventer interface

+ AddAuthQueryListener func(func(Context, *rest_model.AuthQueryDetail)) func()

+ AddAuthenticationStateFullListener func(func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ AddAuthenticationStatePartialListener func(func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ AddAuthenticationStateUnauthenticatedListener func(func(Context, *rest_model.CurrentAPISessionDetail)) func()

+ AddListener func(events.EventName, ...events.Listener)

+ AddMfaTotpCodeListener func(func(Context, *rest_model.AuthQueryDetail, MfaCodeResponse)) func()

+ AddRouterConnectedListener func(func(ztx Context, name string, addr string)) func()

+ AddRouterDisconnectedListener func(func(ztx Context, name string, addr string)) func()

+ AddServiceAddedListener func(func(Context, *rest_model.ServiceDetail)) func()

+ AddServiceChangedListener func(func(Context, *rest_model.ServiceDetail)) func()

+ AddServiceRemovedListener func(func(Context, *rest_model.ServiceDetail)) func()

+ EventNames func() []events.EventName

+ GetMaxListeners func() int

+ ListenerCount func(events.EventName) int

+ Listeners func(events.EventName) []events.Listener

+ On func(events.EventName, ...events.Listener)

+ Once func(events.EventName, ...events.Listener)

+ RemoveAllListeners func(events.EventName) bool

+ RemoveListener func(events.EventName, events.Listener) bool

+ type MfaCodeResponse func(code string) error

May 4, 2023

Changes in this version

type CtrlClient

+ ConfigTypes []string

May 4, 2023

Changes in this version

+ const IdentitiesEnv

+ func NewId() string

type Context

+ func NewContextFromFile(path string) (Context, error)

+ func NewContextFromFileWithOpts(path string, options *Options) (Context, error)

+ GetId func() string

+ SetId func(id string)

type ContextImpl

+ Id string

+ func (context *ContextImpl) GetId() string

+ func (context *ContextImpl) SetId(id string)

+ type CtxCollection struct

+ ConfigTypes []string

+ var DefaultCollection *CtxCollection

+ func NewSdkCollection() *CtxCollection

+ func NewSdkCollectionFromEnv(envVariable string) *CtxCollection

+ func (set *CtxCollection) Add(ctx Context)

+ func (set *CtxCollection) ForAll(f func(ctx Context))

+ func (set *CtxCollection) NewContext(cfg *Config) (Context, error)

+ func (set *CtxCollection) NewContextFromFile(file string) (Context, error)

+ func (set *CtxCollection) NewContextFromFileWithOpts(file string, options *Options) (Context, error)

+ func (set *CtxCollection) NewContextWithOpts(cfg *Config, options *Options) (Context, error)

+ func (set *CtxCollection) NewDialer() Dialer

+ func (set *CtxCollection) NewDialerWithFallback(ctx context.Context, fallback Dialer) Dialer

+ func (set *CtxCollection) Remove(ctx Context)

+ func (set *CtxCollection) RemoveById(id string)

Apr 24, 2023

Changes in this version

+ var EnrollUrl = url.Parse("/edge/client/v1/enroll")

+ func GetControllerWellKnownCaPool(controllerAddr string) (*x509.CertPool, error)

+ type Config struct

+ ConfigTypes []string

+ Credentials apis.Credentials

+ ID identity.Config

+ ZtAPI string

+ func NewConfig(ztApi string, idConfig identity.Config) *Config

+ func NewConfigFromFile(confFile string) (*Config, error)

type Context

+ GetCredentials func() apis.Credentials

+ SetCredentials func(authenticator apis.Credentials)

type ContextImpl

+ func (context *ContextImpl) GetCredentials() apis.Credentials

+ func (context *ContextImpl) SetCredentials(credentials apis.Credentials)

type CtrlClient

+ Credentials apis.Credentials

+ type EnrollmentClaims struct

+ EnrollmentMethod string

+ SignatureCert *x509.Certificate

+ func (t *EnrollmentClaims) EnrolmentUrl() string

+ func (t *EnrollmentClaims) ToMapClaims() (jwt.MapClaims, error)

+ func (t *EnrollmentClaims) Valid() error

+ type KeyAlgVar string

+ func (f *KeyAlgVar) EC() bool

+ func (f *KeyAlgVar) Get() string

+ func (f *KeyAlgVar) RSA() bool

+ func (f *KeyAlgVar) Set(value string) error

+ func (f *KeyAlgVar) String() string

+ func (f *KeyAlgVar) Type() string

+ type Versions struct

+ Api string

+ EnrollmentApi string

Apr 13, 2023

Changes in this version

type ContextImpl

+ CtrlClt *CtrlClient

Mar 31, 2023

Changes in this version

+ const ClientConfigV1

+ const InterceptV1

+ const SessionBind

+ const SessionDial

type Context

+ GetAuthenticator func() rest_util.Authenticator

+ SetAuthenticator func(authenticator rest_util.Authenticator)

+ type ContextImpl struct

+ func (context *ContextImpl) AddZitiMfaHandler(...)

+ func (context *ContextImpl) Authenticate() error

+ func (context *ContextImpl) Close()

+ func (context *ContextImpl) Dial(serviceName string) (edge.Conn, error)

+ func (context *ContextImpl) DialAddr(network string, addr string) (edge.Conn, error)

+ func (context *ContextImpl) DialWithOptions(serviceName string, options *DialOptions) (edge.Conn, error)

+ func (context *ContextImpl) EnrollZitiMfa() (*rest_model.DetailMfa, error)

+ func (context *ContextImpl) EnsureAuthenticated(options edge.ConnOptions) error

+ func (context *ContextImpl) GetAuthenticator() rest_util.Authenticator

+ func (context *ContextImpl) GetCurrentIdentity() (*rest_model.IdentityDetail, error)

+ func (context *ContextImpl) GetService(name string) (*rest_model.ServiceDetail, bool)

+ func (context *ContextImpl) GetServiceForAddr(network, hostname string, port uint16) (*rest_model.ServiceDetail, int, error)

+ func (context *ContextImpl) GetServiceId(name string) (string, bool, error)

+ func (context *ContextImpl) GetServiceTerminators(serviceName string, offset, limit int) ([]*rest_model.TerminatorClientDetail, int, error)

+ func (context *ContextImpl) GetServices() ([]rest_model.ServiceDetail, error)

+ func (context *ContextImpl) GetSession(serviceId string) (*rest_model.SessionDetail, error)

+ func (context *ContextImpl) Listen(serviceName string) (edge.Listener, error)

+ func (context *ContextImpl) ListenWithOptions(serviceName string, options *ListenOptions) (edge.Listener, error)

+ func (context *ContextImpl) Metrics() metrics.Registry

+ func (context *ContextImpl) OnClose(factory edge.RouterConn)

+ func (context *ContextImpl) RefreshServices() error

+ func (context *ContextImpl) RemoveZitiMfa(code string) error

+ func (context *ContextImpl) Sessions() ([]*rest_model.SessionDetail, error)

+ func (context *ContextImpl) SetAuthenticator(authenticator rest_util.Authenticator)

+ func (context *ContextImpl) VerifyZitiMfa(code string) error

+ type CtrlClient struct

+ ApiSession *rest_model.CurrentAPISessionDetail

+ ApiSessionCertInstance string

+ ApiSessionCertificate *x509.Certificate

+ ApiSessionCertificateDetail rest_model.CurrentAPISessionCertificateDetail

+ ApiSessionCsr x509.CertificateRequest

+ ApiSessionIdentity identity.Identity

+ ApiSessionPrivateKey *ecdsa.PrivateKey

+ Authenticator rest_util.Authenticator

+ CaPool *x509.CertPool

+ EdgeClientApiUrl *url.URL

+ PostureCache *posture.Cache

+ func (client *CtrlClient) Authenticate() (*rest_model.CurrentAPISessionDetail, error)

+ func (client *CtrlClient) AuthenticateMFA(code string) error

+ func (client *CtrlClient) AuthenticateRequest(request runtime.ClientRequest, registry strfmt.Registry) error

+ func (client *CtrlClient) CreateSession(id string, sessionType SessionType) (*rest_model.SessionDetail, error)

+ func (client *CtrlClient) EnrollMfa() (*rest_model.DetailMfa, error)

+ func (client *CtrlClient) EnsureApiSessionCertificate() error

+ func (client *CtrlClient) GetCurrentApiSession() *rest_model.CurrentAPISessionDetail

+ func (client *CtrlClient) GetCurrentIdentity() (*rest_model.IdentityDetail, error)

+ func (client *CtrlClient) GetIdentity() (identity.Identity, error)

+ func (client *CtrlClient) GetServiceTerminators(svc *rest_model.ServiceDetail, offset int, limit int) ([]*rest_model.TerminatorClientDetail, int, error)

+ func (client *CtrlClient) GetServices() ([]*rest_model.ServiceDetail, error)

+ func (client *CtrlClient) GetSession(id string) (*rest_model.SessionDetail, error)

+ func (client *CtrlClient) IsServiceListUpdateAvailable() (bool, error)

+ func (client *CtrlClient) NewApiSessionCertificate() error

+ func (client *CtrlClient) Refresh() (*time.Time, error)

+ func (client *CtrlClient) RemoveMfa(code string) error

+ func (client *CtrlClient) SendPostureResponse(response rest_model.PostureResponseCreate) error

+ func (client *CtrlClient) SendPostureResponseBulk(responses []rest_model.PostureResponseCreate) error

+ func (client *CtrlClient) SetInfo(envInfo *rest_model.EnvInfo, sdkInfo *rest_model.SdkInfo)

+ func (client *CtrlClient) VerifyMfa(code string) error

+ type SessionType rest_model.DialBind

Nov 19, 2022

Changes in this version

type Context

+ Reload func() error

Nov 18, 2022

Changes in this version

+ func ForAllContexts(f func(ctx Context) bool)

type Context

+ func LoadContext(config_ string) (Context, error)

+ DialAddr func(network string, addr string) (edge.Conn, error)

+ GetServiceForAddr func(network, hostname string, port uint16) (*edge.Service, int, error)

+ type ContextDialer interface

+ DialContext func(ctx context.Context, network, address string) (net.Conn, error)

+ type Dialer interface

+ Dial func(network, address string) (net.Conn, error)

+ func NewDialer() Dialer

+ func NewDialerWithFallback(ctx context.Context, fallback Dialer) Dialer

Aug 10, 2022

Changes in this version

type Context

+ RefreshServices func() error

Sep 8, 2021

Changes in this version

type Context

+ GetServiceTerminators func(serviceName string, offset, limit int) ([]*edge.Terminator, int, error)

Mar 26, 2021

Changes in this version

+ type ContextImplTest struct

+ func (self *ContextImplTest) GetApiSession() (*edge.ApiSession, error)

+ func (self *ContextImplTest) GetPostureCache() (*posture.Cache, error)

+ func (self *ContextImplTest) GetSessions() ([]*edge.Session, error)

Mar 17, 2021

Changes in this version

+ func SetApplication(theAppId, theAppVersion string)

Mar 1, 2021

Changes in this version

+ var DefaultOptions = &Options

+ type Options struct

+ OnContextReady func(ctx Context)

+ OnServiceUpdate serviceCB

+ RefreshInterval time.Duration

+ type ServiceEventType string

+ const ServiceAdded

+ const ServiceChanged

+ const ServiceRemoved

Feb 24, 2021

Changes in this version

+ const LatencyCheckTimeout

Jan 26, 2021

Changes in this version

+ const MfaProviderZiti

type Context

+ AddZitiMfaHandler func(handler func(query *edge.AuthQuery, resp func(code string) error) error)

+ EnrollZitiMfa func() (*api.MfaEnrollment, error)

+ RemoveZitiMfa func(code string) error

+ VerifyZitiMfa func(code string) error

Jan 26, 2021

Changes in this version

+ func SetAppInfo(appId, appVersion string)

Jan 12, 2021

Changes in this version

+ const PrecedenceDefaultLabel

+ const PrecedenceFailedLabel

+ const PrecedenceRequiredLabel

type Context

+ GetCurrentIdentity func() (*edge.CurrentIdentity, error)

type Precedence

+ func GetPrecedenceForLabel(p string) Precedence

+ func (p Precedence) String() string

Dec 16, 2020

Changes in this version

type ListenOptions

+ ManualStart bool

Nov 2, 2020

Changes in this version

type DialOptions

+ AppData []byte

Sep 29, 2020

Changes in this version

+ const PrecedenceDefault

+ const PrecedenceFailed

+ const PrecedenceRequired

type Context

+ DialWithOptions func(serviceName string, options *DialOptions) (edge.ServiceConn, error)

+ type DialOptions struct

+ ConnectTimeout time.Duration

+ Identity string

+ func (d DialOptions) GetConnectTimeout() time.Duration

+ type ListenOptions struct

+ BindUsingEdgeIdentity bool

+ ConnectTimeout time.Duration

+ Cost uint16

+ Identity string

+ MaxConnections int

+ Precedence Precedence

+ func DefaultListenOptions() *ListenOptions

+ type Precedence byte

Jun 11, 2020

Changes in this version

type Context

+ func NewContextWithOpts(cfg *config.Config, options *config.Options) Context

May 26, 2020

Changes in this version

+ const LatencyCheckInterval

+ var NotAuthorized = notAuthorized

+ type AuthFailure struct

+ func (e AuthFailure) Error() string

+ type Context interface

+ Authenticate func() error

+ Close func()

+ Dial func(serviceName string) (net.Conn, error)

+ GetBindSession func(id string) (*edge.Session, error)

+ GetService func(serviceName string) (*edge.Service, bool)

+ GetServiceId func(serviceName string) (string, bool, error)

+ GetServices func() ([]edge.Service, error)

+ GetSession func(id string) (*edge.Session, error)

+ Listen func(serviceName string) (edge.Listener, error)

+ ListenWithOptions func(serviceName string, options *edge.ListenOptions) (edge.Listener, error)

+ Metrics func() metrics.Registry

+ func NewContext() Context

+ func NewContextWithConfig(config *config.Config) Context

+ type NotAccessible struct

+ func (e NotAccessible) Error() string