Documentation ¶
Index ¶
- type CA
- func (ca *CA) GetRevokedCertificate(ctx context.Context, serialNumber *big.Int) ([]*database.RevokedCertificate, error)
- func (ca *CA) GetSignedCertificate(ctx context.Context, serialNumber *big.Int) ([]*database.SignedCertificate, error)
- func (ca *CA) NewSerialNumber(ctx context.Context) (*big.Int, error)
- func (ca *CA) SetRevokedCertificate(ctx context.Context, certificate *database.RevokedCertificate) error
- func (ca *CA) SetSignedCertificate(ctx context.Context, certificate *database.SignedCertificate) error
- func (ca *CA) WatchRevokeCertificate() chan struct{}
- type ClusterDatabase
- type RelayLocator
- func (r *RelayLocator) Delete(ctx context.Context, name, addr string) error
- func (r *RelayLocator) Get(name string) (*database.Relay, bool)
- func (r *RelayLocator) GetListenedAddrs() []string
- func (r *RelayLocator) Gone() chan *database.Relay
- func (r *RelayLocator) ListAllConnectedAgents() []*database.Relay
- func (r *RelayLocator) Set(ctx context.Context, relay *database.Relay) error
- func (r *RelayLocator) Update(ctx context.Context, relay *database.Relay) error
- type TokenDatabase
- func (t *TokenDatabase) AllCodes(ctx context.Context) ([]*database.Code, error)
- func (t *TokenDatabase) AllTokens(ctx context.Context) ([]*database.Token, error)
- func (t *TokenDatabase) DeleteCode(ctx context.Context, code string) error
- func (t *TokenDatabase) DeleteToken(ctx context.Context, token string) error
- func (t *TokenDatabase) FindToken(ctx context.Context, token string) (*database.Token, error)
- func (t *TokenDatabase) IssueToken(ctx context.Context, code, codeVerifier string) (*database.Token, error)
- func (t *TokenDatabase) NewCode(ctx context.Context, userId, challenge, challengeMethod string) (*database.Code, error)
- type UserDatabase
- func (u *UserDatabase) Delete(ctx context.Context, id string) error
- func (u *UserDatabase) DeleteState(ctx context.Context, state string) error
- func (u *UserDatabase) Get(id string, _ ...database.UserDatabaseOption) (*database.User, error)
- func (u *UserDatabase) GetAccessToken(value string) (*database.AccessToken, error)
- func (u *UserDatabase) GetAccessTokens(id string) ([]*database.AccessToken, error)
- func (u *UserDatabase) GetAll() ([]*database.User, error)
- func (u *UserDatabase) GetAllServiceAccount() ([]*database.User, error)
- func (u *UserDatabase) GetIdentityByLoginName(ctx context.Context, loginName string) (string, error)
- func (u *UserDatabase) GetState(ctx context.Context, state string) (string, error)
- func (u *UserDatabase) Set(ctx context.Context, user *database.User) error
- func (u *UserDatabase) SetAccessToken(ctx context.Context, token *database.AccessToken) error
- func (u *UserDatabase) SetState(ctx context.Context, unique string) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CA ¶
type CA struct {
// contains filtered or unexported fields
}
func NewCA ¶
func NewCA(dao *dao.Repository) *CA
func (*CA) GetRevokedCertificate ¶
func (*CA) GetSignedCertificate ¶
func (*CA) SetRevokedCertificate ¶
func (*CA) SetSignedCertificate ¶
func (*CA) WatchRevokeCertificate ¶
func (ca *CA) WatchRevokeCertificate() chan struct{}
type ClusterDatabase ¶
type ClusterDatabase struct {
// contains filtered or unexported fields
}
func NewCluster ¶
func NewCluster(dao *dao.Repository) (*ClusterDatabase, error)
func (*ClusterDatabase) Alive ¶
func (c *ClusterDatabase) Alive() bool
func (*ClusterDatabase) Id ¶
func (c *ClusterDatabase) Id() string
func (*ClusterDatabase) MemberList ¶
type RelayLocator ¶
type RelayLocator struct {
// contains filtered or unexported fields
}
func NewRelayLocator ¶
func NewRelayLocator(dao *dao.Repository) *RelayLocator
func (*RelayLocator) Delete ¶
func (r *RelayLocator) Delete(ctx context.Context, name, addr string) error
func (*RelayLocator) GetListenedAddrs ¶
func (r *RelayLocator) GetListenedAddrs() []string
func (*RelayLocator) Gone ¶
func (r *RelayLocator) Gone() chan *database.Relay
func (*RelayLocator) ListAllConnectedAgents ¶
func (r *RelayLocator) ListAllConnectedAgents() []*database.Relay
type TokenDatabase ¶
type TokenDatabase struct {
// contains filtered or unexported fields
}
func NewTokenDatabase ¶
func NewTokenDatabase(dao *dao.Repository) *TokenDatabase
func (*TokenDatabase) DeleteCode ¶
func (t *TokenDatabase) DeleteCode(ctx context.Context, code string) error
func (*TokenDatabase) DeleteToken ¶
func (t *TokenDatabase) DeleteToken(ctx context.Context, token string) error
func (*TokenDatabase) IssueToken ¶
type UserDatabase ¶
type UserDatabase struct {
// contains filtered or unexported fields
}
func NewUserDatabase ¶
func NewUserDatabase(dao *dao.Repository, systemUsers ...*database.User) *UserDatabase
func (*UserDatabase) DeleteState ¶
func (u *UserDatabase) DeleteState(ctx context.Context, state string) error
func (*UserDatabase) Get ¶
func (u *UserDatabase) Get(id string, _ ...database.UserDatabaseOption) (*database.User, error)
func (*UserDatabase) GetAccessToken ¶
func (u *UserDatabase) GetAccessToken(value string) (*database.AccessToken, error)
func (*UserDatabase) GetAccessTokens ¶
func (u *UserDatabase) GetAccessTokens(id string) ([]*database.AccessToken, error)
func (*UserDatabase) GetAllServiceAccount ¶
func (u *UserDatabase) GetAllServiceAccount() ([]*database.User, error)
func (*UserDatabase) GetIdentityByLoginName ¶ added in v0.10.0
func (*UserDatabase) SetAccessToken ¶
func (u *UserDatabase) SetAccessToken(ctx context.Context, token *database.AccessToken) error
Click to show internal directories.
Click to hide internal directories.