storage

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

type LightningMonkeyStorageDriver interface {
	Initialize(settings map[string]string) error
	GetRequestTimeoutDuration() time.Duration
	Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)
	Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan
	Txn(ctx context.Context) clientv3.Txn
	Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)
	NewLease() clientv3.Lease
}

type StorageDriver interface {
	Initialize(args map[string]string) error
	GetCluster(clusterId string) (*entities.Cluster, error)
	SaveCluster(cluster *entities.Cluster, certsMap *certs.GeneratedCertsMap) error
	GetCertificatesByClusterId(clusterId string) (entities.CertificateCollection, error)
	GetCertificatesByClusterIdAndName(clusterId string, name string) (*entities.Certificate, error)
	GetAllClusters() ([]*entities.Cluster, error)
	GetAllAgentsByClusterId(clusterId string) ([]*entities.Agent, error)
	GetAgentByMetadataId(metadataId string) (*entities.Agent, error)
	SaveAgent(agent *entities.Agent) error
	SaveCertificateToCluster(cluster *entities.Cluster, certsMap *certs.GeneratedCertsMap) error
	UpdateCluster(cluster *entities.Cluster) error
	UpdateAgentStatus(agent *entities.Agent) error
	BatchUpdateAgentStatus(agents []*entities.Agent) error
}

type StorageDriverFactory struct {
}