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 }
Click to show internal directories.
Click to hide internal directories.