etcd

package
v0.15.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 21, 2023 License: MIT Imports: 25 Imported by: 0

Documentation

Index

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(client *clientv3.Client) *CA

func (*CA) Close added in v0.11.1 

func (c *CA) Close()

func (*CA) GetRevokedCertificate 

func (c *CA) GetRevokedCertificate(ctx context.Context, serial *big.Int) ([]*database.RevokedCertificate, error)

func (*CA) GetSignedCertificate 

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

func (*CA) NewSerialNumber 

func (c *CA) NewSerialNumber(ctx context.Context) (*big.Int, error)

func (*CA) SetRevokedCertificate 

func (c *CA) SetRevokedCertificate(ctx context.Context, certificate *database.RevokedCertificate) error

func (*CA) SetSignedCertificate 

func (c *CA) SetSignedCertificate(ctx context.Context, certificate *database.SignedCertificate) error

func (*CA) WatchRevokeCertificate 

func (c *CA) WatchRevokeCertificate() chan struct{}

type Cache added in v0.13.0 

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

func NewCache added in v0.13.0 

func NewCache(client *clientv3.Client, keyPrefix string, initData []*mvccpb.KeyValue) *Cache

func (*Cache) All added in v0.13.0 

func (c *Cache) All() ([]*mvccpb.KeyValue, error)

func (*Cache) Close added in v0.13.0 

func (c *Cache) Close()

func (*Cache) Get added in v0.13.0 

func (c *Cache) Get(key []byte) *mvccpb.KeyValue

func (*Cache) Len added in v0.13.0 

func (c *Cache) Len() int

func (*Cache) Notify added in v0.13.0 

func (c *Cache) Notify() chan struct{}

func (*Cache) Start added in v0.13.0 

func (c *Cache) Start(ctx context.Context)

func (*Cache) Synced added in v0.13.0 

func (c *Cache) Synced() (chan struct{}, error)

func (*Cache) WaitForSync added in v0.13.0 

func (c *Cache) WaitForSync(ctx context.Context) error

type ClusterDatabase 

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

func NewClusterDatabase 

func NewClusterDatabase(_ context.Context, client *clientv3.Client) (*ClusterDatabase, error)

func (*ClusterDatabase) Alive 

func (d *ClusterDatabase) Alive() bool

func (*ClusterDatabase) Id 

func (d *ClusterDatabase) Id() string

func (*ClusterDatabase) Join 

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

func (*ClusterDatabase) Leave 

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

func (*ClusterDatabase) MemberList 

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

type Compactor 

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

func NewCompactor 

func NewCompactor(client *clientv3.Client) (*Compactor, error)

func (*Compactor) Start 

func (c *Compactor) Start(ctx context.Context)

type RelayLocator 

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

func NewRelayLocator 

func NewRelayLocator(_ context.Context, client *clientv3.Client) (*RelayLocator, error)

func (*RelayLocator) Close added in v0.11.1 

func (l *RelayLocator) Close()

func (*RelayLocator) Delete 

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

func (*RelayLocator) Get 

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

func (*RelayLocator) GetListenedAddrs 

func (l *RelayLocator) GetListenedAddrs() []string

func (*RelayLocator) Gone 

func (l *RelayLocator) Gone() chan *database.Relay

func (*RelayLocator) ListAllConnectedAgents 

func (l *RelayLocator) ListAllConnectedAgents() []*database.Relay

func (*RelayLocator) Set 

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

func (*RelayLocator) Update 

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

type TemporaryToken 

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

func NewTemporaryToken 

func NewTemporaryToken(client *clientv3.Client) *TemporaryToken

func (*TemporaryToken) AllCodes 

func (t *TemporaryToken) AllCodes(ctx context.Context) ([]*database.Code, error)

func (*TemporaryToken) AllTokens 

func (t *TemporaryToken) AllTokens(ctx context.Context) ([]*database.Token, error)

func (*TemporaryToken) DeleteCode 

func (t *TemporaryToken) DeleteCode(ctx context.Context, code string) error

func (*TemporaryToken) DeleteToken 

func (t *TemporaryToken) DeleteToken(ctx context.Context, token string) error

func (*TemporaryToken) FindToken 

func (t *TemporaryToken) FindToken(ctx context.Context, token string) (*database.Token, error)

func (*TemporaryToken) IssueToken 

func (t *TemporaryToken) IssueToken(ctx context.Context, code, codeVerifier string) (*database.Token, error)

func (*TemporaryToken) NewCode 

func (t *TemporaryToken) NewCode(ctx context.Context, userId, challenge, challengeMethod string) (*database.Code, error)

type UserDatabase 

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

func NewUserDatabase 

func NewUserDatabase(_ context.Context, client *clientv3.Client, systemUsers ...*database.User) (*UserDatabase, error)

func (*UserDatabase) Close 

func (d *UserDatabase) Close()

func (*UserDatabase) Delete 

func (d *UserDatabase) Delete(ctx context.Context, id string) error

func (*UserDatabase) DeleteState 

func (d *UserDatabase) DeleteState(ctx context.Context, state string) error

func (*UserDatabase) Get 

func (d *UserDatabase) Get(id string, opts ...database.UserDatabaseOption) (*database.User, error)

func (*UserDatabase) GetAccessToken 

func (d *UserDatabase) GetAccessToken(value string) (*database.AccessToken, error)

func (*UserDatabase) GetAccessTokens 

func (d *UserDatabase) GetAccessTokens(id string) ([]*database.AccessToken, error)

func (*UserDatabase) GetAll 

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

func (*UserDatabase) GetAllServiceAccount 

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

func (*UserDatabase) GetIdentityByLoginName added in v0.10.0 

func (d *UserDatabase) GetIdentityByLoginName(_ context.Context, loginName string) (string, error)

func (*UserDatabase) GetState 

func (d *UserDatabase) GetState(ctx context.Context, stateString string) (string, error)

func (*UserDatabase) Set 

func (d *UserDatabase) Set(ctx context.Context, user *database.User) error

func (*UserDatabase) SetAccessToken 

func (d *UserDatabase) SetAccessToken(ctx context.Context, token *database.AccessToken) error

func (*UserDatabase) SetState 

func (d *UserDatabase) SetState(ctx context.Context, unique string) (string, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.