store

Documentation

Index

• type AgentStore
• type MockAgentStore
  • func NewMockAgentStore(ctrl *gomock.Controller) *MockAgentStore
  • func (_m *MockAgentStore) AllCertificates() ([]*x509.Certificate, error)
  • func (_m *MockAgentStore) Close()
  • func (_m *MockAgentStore) EXPECT() *_MockAgentStoreRecorder
  • func (_m *MockAgentStore) FindCertificate(_param0 string) (*x509.Certificate, error)
  • func (_m *MockAgentStore) SetRevocationsListener(_param0 common.RevocationsListener) error
• type MockServerStore
  • func NewMockServerStore(ctrl *gomock.Controller) *MockServerStore
  • func (_m *MockServerStore) AddCertificate(_param0 string, _param1 *x509.Certificate) error
  • func (_m *MockServerStore) AddRevocation(_param0 common.RawSha256, _param1 time.Time) error
  • func (_m *MockServerStore) AllCertificates() ([]*x509.Certificate, error)
  • func (_m *MockServerStore) Close()
  • func (_m *MockServerStore) EXPECT() *_MockServerStoreRecorder
  • func (_m *MockServerStore) FindCertificate(_param0 string) (*x509.Certificate, error)
  • func (_m *MockServerStore) RemoveCertificate(_param0 string) error
  • func (_m *MockServerStore) SetRevocationsListener(_param0 common.RevocationsListener) error
• type ServerStore
  • func NewStore(config *config.StoreConfig, logger logging.Logger) (ServerStore, error)

Types

type AgentStore

type AgentStore interface {
	// Find/lookup a certificate by its thumbprint
	FindCertificate(thumbprint string) (*x509.Certificate, error)

	// Get all certificates
	AllCertificates() ([]*x509.Certificate, error)

	// Set a listener for revocations
	// The implementation is supposed to send all existing revocations at once
	SetRevocationsListener(listener common.RevocationsListener) error

	// Close the store
	Close()
}

Agent storage backend (also applies to the server

type MockAgentStore

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

Mock of AgentStore interface

func NewMockAgentStore

func NewMockAgentStore(ctrl *gomock.Controller) *MockAgentStore

func (*MockAgentStore) AllCertificates

func (_m *MockAgentStore) AllCertificates() ([]*x509.Certificate, error)

func (*MockAgentStore) Close

func (_m *MockAgentStore) Close()

func (*MockAgentStore) EXPECT

func (_m *MockAgentStore) EXPECT() *_MockAgentStoreRecorder

func (*MockAgentStore) FindCertificate

func (_m *MockAgentStore) FindCertificate(_param0 string) (*x509.Certificate, error)

func (*MockAgentStore) SetRevocationsListener

func (_m *MockAgentStore) SetRevocationsListener(_param0 common.RevocationsListener) error

type MockServerStore

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

Mock of ServerStore interface

func NewMockServerStore

func NewMockServerStore(ctrl *gomock.Controller) *MockServerStore

func (*MockServerStore) AddCertificate

func (_m *MockServerStore) AddCertificate(_param0 string, _param1 *x509.Certificate) error

func (*MockServerStore) AddRevocation

func (_m *MockServerStore) AddRevocation(_param0 common.RawSha256, _param1 time.Time) error

func (*MockServerStore) AllCertificates

func (_m *MockServerStore) AllCertificates() ([]*x509.Certificate, error)

func (*MockServerStore) Close

func (_m *MockServerStore) Close()

func (*MockServerStore) EXPECT

func (_m *MockServerStore) EXPECT() *_MockServerStoreRecorder

func (*MockServerStore) FindCertificate

func (_m *MockServerStore) FindCertificate(_param0 string) (*x509.Certificate, error)

func (*MockServerStore) RemoveCertificate

func (_m *MockServerStore) RemoveCertificate(_param0 string) error

func (*MockServerStore) SetRevocationsListener

func (_m *MockServerStore) SetRevocationsListener(_param0 common.RevocationsListener) error

type ServerStore

type ServerStore interface {
	AgentStore

	// Add a certificate to the store
	AddCertificate(thumbprint string, certificate *x509.Certificate) error

	// Remove a certificate by is thumbprint
	RemoveCertificate(thumbprint string) error

	// Add a revocation
	// The revocation has to be send to the listener with its version number
	AddRevocation(sha256 common.RawSha256, expiresAt time.Time) error
}

Server storage backend

func NewStore

func NewStore(config *config.StoreConfig, logger logging.Logger) (ServerStore, error)