mongodb

Documentation

Index

• Constants
• func ExportEndpoint() (map[string][]byte, error)
• type Store
  • func NewClient(parentCtx context.Context, _log types.LoggerFactory) *Store
  • func (db *Store) AlreadyCreated(cloud consts.KsctlCloud, region, clusterName string, ...) error
  • func (db *Store) Connect() error
  • func (db *Store) DeleteCluster() error
  • func (s *Store) Export(filters map[consts.KsctlSearchFilter]string) (*types.StorageStateExportImport, error)
  • func (db *Store) GetOneOrMoreClusters(filters map[consts.KsctlSearchFilter]string) (map[consts.KsctlClusterType][]*storageTypes.StorageDocument, error)
  • func (s *Store) Import(src *types.StorageStateExportImport) error
  • func (db *Store) Kill() error
  • func (db *Store) Read() (*storageTypes.StorageDocument, error)
  • func (db *Store) ReadCredentials(cloud consts.KsctlCloud) (*storageTypes.CredentialsDocument, error)
  • func (db *Store) Setup(cloud consts.KsctlCloud, region, clusterName string, ...) error
  • func (db *Store) Write(data *storageTypes.StorageDocument) error
  • func (db *Store) WriteCredentials(cloud consts.KsctlCloud, data *storageTypes.CredentialsDocument) error

Constants

const (
	CredsCollection string = "credentials"
)

Functions

func ExportEndpoint

func ExportEndpoint() (map[string][]byte, error)

Types

type Store

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

func NewClient

func NewClient(parentCtx context.Context, _log types.LoggerFactory) *Store

func (*Store) AlreadyCreated

func (db *Store) AlreadyCreated(cloud consts.KsctlCloud, region, clusterName string, clusterType consts.KsctlClusterType) error

func (*Store) Connect

func (db *Store) Connect() error

func (*Store) DeleteCluster

func (db *Store) DeleteCluster() error

func (*Store) Export

func (s *Store) Export(filters map[consts.KsctlSearchFilter]string) (*types.StorageStateExportImport, error)

func (*Store) GetOneOrMoreClusters

func (db *Store) GetOneOrMoreClusters(filters map[consts.KsctlSearchFilter]string) (map[consts.KsctlClusterType][]*storageTypes.StorageDocument, error)

func (*Store) Import

func (s *Store) Import(src *types.StorageStateExportImport) error

func (*Store) Kill

func (db *Store) Kill() error

func (*Store) Read

func (db *Store) Read() (*storageTypes.StorageDocument, error)

Read implements types.StorageFactory.

func (*Store) ReadCredentials

func (db *Store) ReadCredentials(cloud consts.KsctlCloud) (*storageTypes.CredentialsDocument, error)

ReadCredentials implements types.StorageFactory.

func (*Store) Setup

func (db *Store) Setup(cloud consts.KsctlCloud, region, clusterName string, clusterType consts.KsctlClusterType) error

func (*Store) Write

func (db *Store) Write(data *storageTypes.StorageDocument) error

Write implements types.StorageFactory.

func (*Store) WriteCredentials

func (db *Store) WriteCredentials(cloud consts.KsctlCloud, data *storageTypes.CredentialsDocument) error

WriteCredentials implements types.StorageFactory.