server

Documentation

Index

• Variables
• func HttpSrv()
• func InitCache()
• func SDSSrv(stop chan struct{})
• type CertT
  • func (c *CertT) IsValid() bool
• type MySDS
  • func (sds *MySDS) StreamSecrets(server secretv3.SecretDiscoveryService_StreamSecretsServer) error
• type ServerCacheFile
  • func MakeServerCacheFile() ServerCacheFile
  • func (s *ServerCacheFile) PrintCertInfo()
  • func (s *ServerCacheFile) ReadCacheFile() error
• type ServerCacheFileEntry
• type ServerCertCacheEntry
  • func (c *ServerCertCacheEntry) Cert() CertT
  • func (c *ServerCertCacheEntry) IsSubcribing() bool
  • func (c *ServerCertCacheEntry) Release()
  • func (c *ServerCertCacheEntry) Renew(retry bool) (bool, error)
  • func (c *ServerCertCacheEntry) Subscribe()
• type ServerCertCacheT
  • func (s *ServerCertCacheT) GetEntry(domains []string) *ServerCertCacheEntry

Variables

var Config = &config.ServerConfigT{}

Functions

func HttpSrv

func HttpSrv()

func InitCache

func InitCache()

func SDSSrv

func SDSSrv(stop chan struct{})

Types

type CertT

type CertT struct {
	FullChain   []byte    `json:"fullChain"`
	Key         []byte    `json:"key"`
	ValidBefore time.Time `json:"validBefore"`
	RenewAt     time.Time `json:"renewAt"`
}

func (*CertT) IsValid

func (c *CertT) IsValid() bool

type MySDS

type MySDS struct {
	secretv3.UnimplementedSecretDiscoveryServiceServer
	// contains filtered or unexported fields
}

func (*MySDS) StreamSecrets

func (sds *MySDS) StreamSecrets(server secretv3.SecretDiscoveryService_StreamSecretsServer) error

type ServerCacheFile

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

func MakeServerCacheFile

func MakeServerCacheFile() ServerCacheFile

func (*ServerCacheFile) PrintCertInfo

func (s *ServerCacheFile) PrintCertInfo()

func (*ServerCacheFile) ReadCacheFile

func (s *ServerCacheFile) ReadCacheFile() error

type ServerCacheFileEntry

type ServerCacheFileEntry struct {
	Domains []string `json:"domains"`
	Cert    CertT    `json:"cert"`
}

type ServerCertCacheEntry

type ServerCertCacheEntry struct {
	Listening atomic.Uint64
	Updated   atomic.Pointer[chan struct{}]
	Stop      atomic.Pointer[chan struct{}]
	// contains filtered or unexported fields
}

func (*ServerCertCacheEntry) Cert

func (c *ServerCertCacheEntry) Cert() CertT

func (*ServerCertCacheEntry) IsSubcribing

func (c *ServerCertCacheEntry) IsSubcribing() bool

func (*ServerCertCacheEntry) Release

func (c *ServerCertCacheEntry) Release()

func (*ServerCertCacheEntry) Renew

func (c *ServerCertCacheEntry) Renew(retry bool) (bool, error)

func (*ServerCertCacheEntry) Subscribe

func (c *ServerCertCacheEntry) Subscribe()

type ServerCertCacheT

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

func (*ServerCertCacheT) GetEntry

func (s *ServerCertCacheT) GetEntry(domains []string) *ServerCertCacheEntry