Documentation
¶
Index ¶
- func DeleteEnterpriseConfigFromEtcd(ctx context.Context, etcd *clientv3.Client) error
- func EnterpriseConfigCollection(db *pachsql.DB, listener col.PostgresListener) col.PostgresCollection
- func EnterpriseConfigPostgresMigration(ctx context.Context, tx *pachsql.Tx, etcd *clientv3.Client) error
- func NewEnterpriseServer(env *Env, config Config) (*apiServer, error)
- func StopWorkers(ctx context.Context, kc kube.Interface, namespace string) error
- type Config
- type Env
- type PauseMode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnterpriseConfigCollection ¶
func EnterpriseConfigCollection(db *pachsql.DB, listener col.PostgresListener) col.PostgresCollection
func EnterpriseConfigPostgresMigration ¶
func EnterpriseConfigPostgresMigration(ctx context.Context, tx *pachsql.Tx, etcd *clientv3.Client) error
The enterpriseConfig collection stores the information necessary for the enterprise-service to heartbeat to the license service for ongoing license validity checks. For clusters with enterprise, if this information were lost, the cluster would eventually become locked out. We migrate This data is migrated to postgres so that the data stored in etcd can truly be considered ephemeral.
func NewEnterpriseServer ¶
NewEnterpriseServer returns an implementation of ec.APIServer. TODO: Envs should not be passed by pointer
Types ¶
type Env ¶
type Env struct {
DB *pachsql.DB
Listener col.PostgresListener
TxnEnv *txnenv.TransactionEnv
EtcdClient *clientv3.Client
EtcdPrefix string
AuthServer auth.APIServer
GetPachClient func(context.Context) *client.APIClient
GetKubeClient func() kube.Interface
Namespace string
BackgroundContext context.Context
Config pachconfig.Configuration
}
Source Files
Click to show internal directories.
Click to hide internal directories.