memory

Documentation

Index

• type CA
  • func NewCA(config *config.CertificateAuthority) *CA
  • func (c *CA) GetRevokedCertificates() []*database.RevokedCertificate
  • func (c *CA) GetSignedCertificate(_ context.Context, serial *big.Int) (*database.SignedCertificate, error)
  • func (c *CA) GetSignedCertificates(_ context.Context) ([]*database.SignedCertificate, error)
  • func (c *CA) NewAgentCertificate(ctx context.Context, name, comment string) ([]byte, error)
  • func (c *CA) NewClientCertificate(ctx context.Context, name, keyType string, keyBits int, ...) ([]byte, error)
  • func (c *CA) NewServerCertificate(commonName string) (*x509.Certificate, crypto.PrivateKey, error)
  • func (c *CA) Revoke(_ context.Context, certificate *database.SignedCertificate) error
  • func (c *CA) SetSignedCertificate(certificate *database.SignedCertificate) error
  • func (c *CA) SignCertificateRequest(ctx context.Context, csr *x509.CertificateRequest, comment string, agent bool) ([]byte, error)
  • func (c *CA) WatchRevokeCertificate() chan *database.RevokedCertificate
• type ClusterDatabase
  • func NewClusterDatabase() *ClusterDatabase
  • func (d *ClusterDatabase) Alive() bool
  • func (d *ClusterDatabase) Id() string
  • func (d *ClusterDatabase) Join(_ context.Context) error
  • func (d *ClusterDatabase) Leave(_ context.Context) error
  • func (d *ClusterDatabase) MemberList(ctx context.Context) ([]*database.Member, error)
• type RelayLocator
  • func NewRelayLocator() *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 NewTokenDatabase() *TokenDatabase
  • func (t *TokenDatabase) AllCodes(_ context.Context) ([]*database.Code, error)
  • func (t *TokenDatabase) AllTokens(_ context.Context) ([]*database.Token, error)
  • func (t *TokenDatabase) DeleteCode(_ context.Context, code string) error
  • func (t *TokenDatabase) DeleteToken(_ context.Context, token string) error
  • func (t *TokenDatabase) FindToken(_ context.Context, token string) (*database.Token, error)
  • func (t *TokenDatabase) IssueToken(_ context.Context, code, _ string) (*database.Token, error)
  • func (t *TokenDatabase) NewCode(_ context.Context, userId, _, _ string) (*database.Code, error)
  • func (t *TokenDatabase) SetUser(userId string) (*database.Token, error)
• type UserDatabase
  • func NewUserDatabase(systemUsers ...*database.User) *UserDatabase
  • func (u *UserDatabase) Delete(_ctx context.Context, id string) error
  • func (u *UserDatabase) DeleteState(_ context.Context, state string) error
  • func (u *UserDatabase) Get(id string) (*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) GetState(_ context.Context, state string) (string, error)
  • func (u *UserDatabase) Set(_ctx context.Context, user *database.User) error
  • func (u *UserDatabase) SetAccessToken(_ context.Context, token *database.AccessToken) error
  • func (u *UserDatabase) SetState(_ context.Context, unique string) (string, error)

Types

type CA

type CA struct {
	// contains filtered or unexported fields
}

func NewCA

func NewCA(config *config.CertificateAuthority) *CA

func (*CA) GetRevokedCertificates

func (c *CA) GetRevokedCertificates() []*database.RevokedCertificate

func (*CA) GetSignedCertificate

func (c *CA) GetSignedCertificate(_ context.Context, serial *big.Int) (*database.SignedCertificate, error)

func (*CA) GetSignedCertificates

func (c *CA) GetSignedCertificates(_ context.Context) ([]*database.SignedCertificate, error)

func (*CA) NewAgentCertificate

func (c *CA) NewAgentCertificate(ctx context.Context, name, comment string) ([]byte, error)

func (*CA) NewClientCertificate

func (c *CA) NewClientCertificate(ctx context.Context, name, keyType string, keyBits int, password, comment string) ([]byte, error)

func (*CA) NewServerCertificate

func (c *CA) NewServerCertificate(commonName string) (*x509.Certificate, crypto.PrivateKey, error)

func (*CA) Revoke

func (c *CA) Revoke(_ context.Context, certificate *database.SignedCertificate) error

func (*CA) SetSignedCertificate

func (c *CA) SetSignedCertificate(certificate *database.SignedCertificate) error

func (*CA) SignCertificateRequest

func (c *CA) SignCertificateRequest(ctx context.Context, csr *x509.CertificateRequest, comment string, agent bool) ([]byte, error)

func (*CA) WatchRevokeCertificate

func (c *CA) WatchRevokeCertificate() chan *database.RevokedCertificate

type ClusterDatabase

type ClusterDatabase struct {
	// contains filtered or unexported fields
}

func NewClusterDatabase

func NewClusterDatabase() *ClusterDatabase

func (*ClusterDatabase) Alive

func (d *ClusterDatabase) Alive() bool

func (*ClusterDatabase) Id

func (d *ClusterDatabase) Id() string

func (*ClusterDatabase) Join

func (d *ClusterDatabase) Join(_ context.Context) error

func (*ClusterDatabase) Leave

func (d *ClusterDatabase) Leave(_ context.Context) error

func (*ClusterDatabase) MemberList

func (d *ClusterDatabase) MemberList(ctx context.Context) ([]*database.Member, error)

type RelayLocator

type RelayLocator struct {
	// contains filtered or unexported fields
}

func NewRelayLocator

func NewRelayLocator() *RelayLocator

func (*RelayLocator) Delete

func (r *RelayLocator) Delete(ctx context.Context, name, addr string) error

func (*RelayLocator) Get

func (r *RelayLocator) Get(name string) (*database.Relay, bool)

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

func (*RelayLocator) Set

func (r *RelayLocator) Set(ctx context.Context, relay *database.Relay) error

func (*RelayLocator) Update

func (r *RelayLocator) Update(ctx context.Context, relay *database.Relay) error

type TokenDatabase

type TokenDatabase struct {
	// contains filtered or unexported fields
}

func NewTokenDatabase

func NewTokenDatabase() *TokenDatabase

func (*TokenDatabase) AllCodes

func (t *TokenDatabase) AllCodes(_ context.Context) ([]*database.Code, error)

func (*TokenDatabase) AllTokens

func (t *TokenDatabase) AllTokens(_ context.Context) ([]*database.Token, error)

func (*TokenDatabase) DeleteCode

func (t *TokenDatabase) DeleteCode(_ context.Context, code string) error

func (*TokenDatabase) DeleteToken

func (t *TokenDatabase) DeleteToken(_ context.Context, token string) error

func (*TokenDatabase) FindToken

func (t *TokenDatabase) FindToken(_ context.Context, token string) (*database.Token, error)

func (*TokenDatabase) IssueToken

func (t *TokenDatabase) IssueToken(_ context.Context, code, _ string) (*database.Token, error)

func (*TokenDatabase) NewCode

func (t *TokenDatabase) NewCode(_ context.Context, userId, _, _ string) (*database.Code, error)

func (*TokenDatabase) SetUser

func (t *TokenDatabase) SetUser(userId string) (*database.Token, error)

type UserDatabase

type UserDatabase struct {
	// contains filtered or unexported fields
}

func NewUserDatabase

func NewUserDatabase(systemUsers ...*database.User) *UserDatabase

func (*UserDatabase) Delete

func (u *UserDatabase) Delete(_ctx context.Context, id string) error

func (*UserDatabase) DeleteState

func (u *UserDatabase) DeleteState(_ context.Context, state string) error

func (*UserDatabase) Get

func (u *UserDatabase) Get(id string) (*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) GetAll

func (u *UserDatabase) GetAll() ([]*database.User, error)

func (*UserDatabase) GetAllServiceAccount

func (u *UserDatabase) GetAllServiceAccount() ([]*database.User, error)

func (*UserDatabase) GetState

func (u *UserDatabase) GetState(_ context.Context, state string) (string, error)

func (*UserDatabase) Set

func (u *UserDatabase) Set(_ctx context.Context, user *database.User) error

func (*UserDatabase) SetAccessToken

func (u *UserDatabase) SetAccessToken(_ context.Context, token *database.AccessToken) error

func (*UserDatabase) SetState

func (u *UserDatabase) SetState(_ context.Context, unique string) (string, error)