adapter

Documentation

Index

• func NewAdminSettingsDbAdapter(db port.DbAdapter) port.AdminSettingsAdapter
• func NewBaselinesApiAdapter() port.BaselinesAdapter
• func NewDbAdapter(params *DbAdapterParams) port.DbAdapter
• func NewSshFsAdapter() port.SshKernelAdapter
• func NewSshKernelApiAdapter() port.SshAdapter
• type AdminSettingsDbAdapter
  • func (a *AdminSettingsDbAdapter) Get() (types.AdminSettings, error)
  • func (a *AdminSettingsDbAdapter) SetChannel(channel types.UpdatesChannel) error
  • func (a *AdminSettingsDbAdapter) SetWebhook(webhook string) error
• type BaselinesApiAdapter
  • func (a *BaselinesApiAdapter) GetLatest(ctx context.Context, channel types.UpdatesChannel) (types.Baseline, error)
• type DbAdapter
  • func (a *DbAdapter) Connect() error
  • func (a *DbAdapter) ConnectTo(driver string, dataSource string, retries int) error
  • func (a *DbAdapter) Get() *types.DB
  • func (a *DbAdapter) GetDBMSName() types.DbmsName
  • func (a *DbAdapter) GetDbConfig() types.DbConfig
  • func (a *DbAdapter) SetDBMSName(name types.DbmsName) error
• type DbAdapterParams
• type SshFsAdapter
  • func (a *SshFsAdapter) Add(key string, user user.User) error
  • func (a *SshFsAdapter) GetAll(users []user.User) ([]types.PublicKey, error)
  • func (a *SshFsAdapter) GetUsers() ([]user.User, error)
  • func (a *SshFsAdapter) Remove(fingerprint string, user user.User) error
• type SshKernelApiAdapter
  • func (a *SshKernelApiAdapter) Add(key string, username string) error
  • func (a *SshKernelApiAdapter) GetAll() ([]types.PublicKey, error)
  • func (a *SshKernelApiAdapter) GetUsers() ([]user.User, error)
  • func (a *SshKernelApiAdapter) Remove(fingerprint string, username string) error

Functions

func NewAdminSettingsDbAdapter

func NewAdminSettingsDbAdapter(db port.DbAdapter) port.AdminSettingsAdapter

func NewBaselinesApiAdapter

func NewBaselinesApiAdapter() port.BaselinesAdapter

func NewDbAdapter

func NewDbAdapter(params *DbAdapterParams) port.DbAdapter

func NewSshFsAdapter

func NewSshFsAdapter() port.SshKernelAdapter

func NewSshKernelApiAdapter

func NewSshKernelApiAdapter() port.SshAdapter

Types

type AdminSettingsDbAdapter

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

func (*AdminSettingsDbAdapter) Get

func (a *AdminSettingsDbAdapter) Get() (types.AdminSettings, error)

func (*AdminSettingsDbAdapter) SetChannel

func (a *AdminSettingsDbAdapter) SetChannel(channel types.UpdatesChannel) error

func (*AdminSettingsDbAdapter) SetWebhook

func (a *AdminSettingsDbAdapter) SetWebhook(webhook string) error

type BaselinesApiAdapter

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

func (*BaselinesApiAdapter) GetLatest

func (a *BaselinesApiAdapter) GetLatest(ctx context.Context, channel types.UpdatesChannel) (types.Baseline, error)

type DbAdapter

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

DbAdapter is an adapter to configure how Vertex will store data.

func (*DbAdapter) Connect

func (a *DbAdapter) Connect() error

func (*DbAdapter) ConnectTo

func (a *DbAdapter) ConnectTo(driver string, dataSource string, retries int) error

func (*DbAdapter) Get

func (a *DbAdapter) Get() *types.DB

func (*DbAdapter) GetDBMSName

func (a *DbAdapter) GetDBMSName() types.DbmsName

func (*DbAdapter) GetDbConfig

func (a *DbAdapter) GetDbConfig() types.DbConfig

func (*DbAdapter) SetDBMSName

func (a *DbAdapter) SetDBMSName(name types.DbmsName) error

SetDBMSName sets the database management system name. The user must also Connect to the database afterwords.

type DbAdapterParams

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

type SshFsAdapter

type SshFsAdapter struct {
}

func (*SshFsAdapter) Add

func (a *SshFsAdapter) Add(key string, user user.User) error

func (*SshFsAdapter) GetAll

func (a *SshFsAdapter) GetAll(users []user.User) ([]types.PublicKey, error)

func (*SshFsAdapter) GetUsers

func (a *SshFsAdapter) GetUsers() ([]user.User, error)

func (*SshFsAdapter) Remove

func (a *SshFsAdapter) Remove(fingerprint string, user user.User) error

type SshKernelApiAdapter

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

func (*SshKernelApiAdapter) Add

func (a *SshKernelApiAdapter) Add(key string, username string) error

func (*SshKernelApiAdapter) GetAll

func (a *SshKernelApiAdapter) GetAll() ([]types.PublicKey, error)

func (*SshKernelApiAdapter) GetUsers

func (a *SshKernelApiAdapter) GetUsers() ([]user.User, error)

func (*SshKernelApiAdapter) Remove

func (a *SshKernelApiAdapter) Remove(fingerprint string, username string) error