executive

type ExecutiveEndpoint struct {
	HealthChecker                  HealthChecker
	Exec                           ExecutiveInterface
	EnableDestructiveSchemaChanges bool
}

type ExecutiveInterface interface {
	CreateFamily(familyName string) error
	CreateTable(familyName string, tableName string, fieldNames []string, fieldTypes []schema.FieldType, keyFields []string) error
	CreateTables([]schema.Table) error
	AddFields(familyName string, tableName string, fieldNames []string, fieldTypes []schema.FieldType) error

	Mutate(writerName string, writerSecret string, familyName string, cookie []byte, checkCookie []byte, requests []ExecutiveMutationRequest) error
	GetWriterCookie(writerName string, writerSecret string) ([]byte, error)
	SetWriterCookie(writerName string, writerSecret string, cookie []byte) error
	RegisterWriter(writerName string, writerSecret string) error

	TableSchema(familyName string, tableName string) (*schema.Table, error)
	FamilySchemas(familyName string) ([]schema.Table, error)

	ReadRow(familyName string, tableName string, where map[string]interface{}) (map[string]interface{}, error)

	ReadTableSizeLimits() (limits.TableSizeLimits, error)
	UpdateTableSizeLimit(limit limits.TableSizeLimit) error
	DeleteTableSizeLimit(table schema.FamilyTable) error

	ReadWriterRateLimits() (limits.WriterRateLimits, error)
	UpdateWriterRateLimit(limit limits.WriterRateLimit) error
	DeleteWriterRateLimit(writerName string) error

	ClearTable(table schema.FamilyTable) error
	DropTable(table schema.FamilyTable) error
	ReadFamilyTableNames(familyName schema.FamilyName) ([]schema.FamilyTable, error)
}

type ExecutiveMutationRequest struct {
	TableName string
	Delete    bool
	Values    map[string]interface{}
}

type ExecutiveService interface {
	Start(ctx context.Context, bind string) error
	io.Closer
}

type ExecutiveServiceConfig struct {
	CtlDBDSN                       string
	RequestTimeout                 time.Duration
	MaxTableSize                   int64
	WarnTableSize                  int64
	WriterLimitPeriod              time.Duration
	WriterLimit                    int64
	EnableDestructiveSchemaChanges bool
}

type HealthChecker interface {
	HealthCheck() error
}

type SQLDBClient interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type TestExecutiveService struct {
	Addr net.Addr
	// contains filtered or unexported fields
}